Files
qse/qse/samples/si/tcpsvr01.cpp

122 lines
2.0 KiB
C++

#include <qse/si/TcpServer.hpp>
#include <qse/si/mtx.h>
#include <qse/si/sio.h>
#include <qse/cmn/mem.h>
#include <locale.h>
#if defined(_WIN32)
# include <windows.h>
#endif
#include <unistd.h>
#include <signal.h>
#include <string.h>
static int g_stopreq = 0;
class ClientHandler
{
public:
int operator() (QSE::Socket* sck, QSE::SocketAddress* addr)
{
return 0;
}
};
static int test1 (void)
{
QSE::TcpServerF<ClientHandler> server;
QSE::SocketAddress addr;
addr.set ("0.0.0.0:9998");
server.setThreadStackSize (256000);
server.setBindingAddress (addr);
server.start ();
return 0;
}
static int test2 (void)
{
#if defined(QSE_LANG_CPP11)
QSE::TcpServerL<int(QSE::Thread*)> server;
thr5.setStackSize (64000);
if (server.start(
([](QSE::Socket* clisock, QSE::SocketAddress* cliaddr) {
return 0;
})
) <= -1)
{
qse_printf (QSE_T("cannot start server\n"));
return -1;
}
#endif
return 0;
}
static void handle_sigint (int sig, siginfo_t* siginfo, void* ctx)
{
g_stopreq = 1;
}
static void set_signal (int sig, void(*handler)(int, siginfo_t*, void*))
{
struct sigaction sa;
memset (&sa, 0, sizeof(sa));
/*sa.sa_handler = handler;*/
sa.sa_flags = SA_SIGINFO;
sa.sa_sigaction = handler;
sigemptyset (&sa.sa_mask);
sigaction (sig, &sa, NULL);
}
static void set_signal_to_default (int sig)
{
struct sigaction sa;
memset (&sa, 0, sizeof(sa));
sa.sa_handler = SIG_DFL;
sa.sa_flags = 0;
sigemptyset (&sa.sa_mask);
sigaction (sig, &sa, NULL);
}
int main ()
{
#if defined(_WIN32)
char locale[100];
UINT codepage = GetConsoleOutputCP();
if (codepage == CP_UTF8)
{
/*SetConsoleOUtputCP (CP_UTF8);*/
qse_setdflcmgrbyid (QSE_CMGR_UTF8);
}
else
{
sprintf (locale, ".%u", (unsigned int)codepage);
setlocale (LC_ALL, locale);
/*qse_setdflcmgrbyid (QSE_CMGR_SLMB);*/
}
#else
setlocale (LC_ALL, "");
/*qse_setdflcmgrbyid (QSE_CMGR_SLMB);*/
#endif
set_signal (SIGINT, handle_sigint);
qse_open_stdsios ();
test1();
qse_close_stdsios ();
set_signal_to_default (SIGINT);
return 0;
}