mirror of
https://github.com/ultimatepp/ultimatepp.git
synced 2026-05-15 22:02:49 -06:00
e038550cb2
Refactor UnixSocket.cpp with error handling Updated UnixSocket.cpp to include error handling and platform-specific path definitions. UnixSocketClient: Update socket path for cross-platform compatibility UnixSocketServer: Update socket path for Windows and Unix platforms Core: UnixSocket example code, socket path fixed autotest/UnixSocket: path correction and unlink.
64 lines
1.3 KiB
C++
64 lines
1.3 KiB
C++
#include <Core/Core.h>
|
|
|
|
using namespace Upp;
|
|
|
|
String GetSocketPath()
|
|
{
|
|
String temp;
|
|
#ifdef PLATFORM_WIN32
|
|
temp = GetEnv("TEMP");
|
|
#else
|
|
temp = GetTempPath();
|
|
#endif
|
|
return AppendFileName(temp, "upp-unixsocket.socket");
|
|
}
|
|
|
|
CONSOLE_APP_MAIN
|
|
{
|
|
StdLogSetup(LOG_COUT|LOG_FILE);
|
|
|
|
String path = GetSocketPath();
|
|
|
|
try {
|
|
Socket server, client;
|
|
|
|
DeleteFile(path); // "unlink" existing FS socket if possible
|
|
|
|
// Test server listen
|
|
if(!server.ListenFileSystem(path, 5, false)) {
|
|
throw Exc("Server listen failed: " << server.GetErrorDesc());
|
|
}
|
|
|
|
// Test client connect
|
|
if(!client.ConnectFileSystem(path)) {
|
|
throw Exc("Client connect failed: " << client.GetErrorDesc());
|
|
}
|
|
|
|
// Test data exchange
|
|
String test_data = "Hello, world!";
|
|
client.Put(test_data + "\n");
|
|
|
|
Socket accepted;
|
|
if(!accepted.Accept(server)) {
|
|
throw Exc("Accept failed: " << accepted.GetErrorDesc());
|
|
}
|
|
|
|
String received = accepted.GetLine();
|
|
DUMP(received);
|
|
|
|
ASSERT(received == test_data);
|
|
|
|
// Test peer PID (on supported platforms)
|
|
int pid = accepted.GetPeerPid();
|
|
DUMP(pid);
|
|
if(pid != -1)
|
|
ASSERT(pid == getpid()); // Should be our own process in this test
|
|
|
|
LOG("=========== OK");
|
|
}
|
|
catch(const Exc& e)
|
|
{
|
|
LOG(e);
|
|
SetExitCode(1);
|
|
}
|
|
}
|