hyung-hwan
efc34cdd69
removed StdMmgr::getInstance() and initialized the default mmgr inside Mmgr::getDFL() to work around an issue related to c++ initialization order across translation units
153 lines
3.3 KiB
C++
153 lines
3.3 KiB
C++
#include <qse/si/TcpServer.hpp>
|
|
#include <qse/si/Mutex.hpp>
|
|
#include <qse/si/sio.h>
|
|
#include <qse/si/os.h>
|
|
#include <qse/cmn/mem.h>
|
|
#include <qse/cmn/str.h>
|
|
#include <qse/cmn/HeapMmgr.hpp>
|
|
#include <qse/sttp/Sttp.hpp>
|
|
#include <qse/si/App.hpp>
|
|
|
|
#include <locale.h>
|
|
#if defined(_WIN32)
|
|
# include <windows.h>
|
|
#endif
|
|
|
|
#include <unistd.h>
|
|
#include <signal.h>
|
|
#include <string.h>
|
|
|
|
#if defined(QSE_LANG_CPP11)
|
|
QSE::TcpServerL<int(QSE::TcpServer::Worker*)>* g_server;
|
|
#else
|
|
|
|
class ClientHandler
|
|
{
|
|
public:
|
|
int operator() (QSE::TcpServer* server, QSE::TcpServer::Worker* worker)
|
|
{
|
|
qse_char_t addrbuf[128];
|
|
qse_uint8_t bb[256];
|
|
qse_ssize_t n;
|
|
|
|
worker->address.toStrBuf(addrbuf, QSE_COUNTOF(addrbuf));
|
|
qse_printf (QSE_T("hello word..from %s[%zu]\n"), addrbuf, worker->getWid());
|
|
|
|
QSE::Sttp sttp (&worker->socket);
|
|
QSE::SttpCmd cmd;
|
|
while (!server->isStopRequested())
|
|
{
|
|
int n = sttp.receiveCmd(&cmd);
|
|
if (n <= -1)
|
|
{
|
|
qse_printf (QSE_T("%s[%zu] -> got error\n"), addrbuf, worker->getWid());
|
|
break;
|
|
}
|
|
else if (n == 0) break;
|
|
|
|
if (cmd.name == QSE_T("quit")) break;
|
|
|
|
qse_printf (QSE_T("received command %s\n"), cmd.name.getBuffer());
|
|
sttp.sendCmd(cmd);
|
|
}
|
|
|
|
qse_printf (QSE_T("byte to %s -> wid %zu\n"), addrbuf, worker->getWid());
|
|
return 0;
|
|
}
|
|
};
|
|
|
|
static QSE::TcpServerF<ClientHandler>* g_server;
|
|
#endif
|
|
|
|
|
|
static int test1 (void)
|
|
{
|
|
QSE::HeapMmgr heap_mmgr (30000, QSE::Mmgr::getDFL());
|
|
|
|
#if defined(QSE_LANG_CPP11)
|
|
QSE::TcpServerL<int(QSE::TcpServer::Worker*)> server (
|
|
|
|
// workload by lambda
|
|
([&server](QSE::TcpServer::Worker* worker) {
|
|
qse_char_t addrbuf[128];
|
|
qse_uint8_t bb[256];
|
|
qse_ssize_t n;
|
|
|
|
worker->address.toStrBuf(addrbuf, QSE_COUNTOF(addrbuf));
|
|
qse_printf (QSE_T("hello word..from %s --> wid %zu\n"), addrbuf, worker->getWid());
|
|
|
|
QSE::Sttp sttp (&worker->socket);
|
|
QSE::SttpCmd cmd;
|
|
while (!server.isStopRequested())
|
|
{
|
|
int n = sttp.receiveCmd(&cmd);
|
|
if (n <= -1)
|
|
{
|
|
qse_printf (QSE_T("%s<%zu> --> got error\n"), addrbuf, worker->getWid());
|
|
break;
|
|
}
|
|
else if (n == 0) break;
|
|
|
|
if (cmd.name == QSE_T("quit")) break;
|
|
|
|
qse_printf (QSE_T("%s<%zu> --> received command %s\n"), addrbuf, worker->getWid(), cmd.name.getBuffer());
|
|
sttp.sendCmd(cmd);
|
|
}
|
|
|
|
qse_printf (QSE_T("byte to %s -> wid %zu\n"), addrbuf, worker->getWid());
|
|
return 0;
|
|
}),
|
|
|
|
&heap_mmgr
|
|
|
|
);
|
|
#else
|
|
QSE::TcpServerF<ClientHandler> server (&heap_mmgr);
|
|
#endif
|
|
|
|
server.setThreadStackSize (256000);
|
|
g_server = &server;
|
|
//server.start (QSE_T("0.0.0.0:9998"));
|
|
server.start (QSE_T("[::]:9998,0.0.0.0:9998"));
|
|
//server.start (QSE_T("[fe80::1c4:a90d:a0f0:d52%wlan0]:9998,0.0.0.0:9998"));
|
|
g_server = QSE_NULL;
|
|
return 0;
|
|
}
|
|
|
|
static void handle_sigint (int sig)
|
|
{
|
|
if (g_server) g_server->stop ();
|
|
}
|
|
|
|
int main ()
|
|
{
|
|
#if defined(_WIN32)
|
|
char locale[100];
|
|
UINT codepage = GetConsoleOutputCP();
|
|
if (codepage == CP_UTF8)
|
|
{
|
|
/*SetConsoleOutputCP (CP_UTF8);*/
|
|
qse_setdflcmgrbyid (QSE_CMGR_UTF8);
|
|
}
|
|
else
|
|
{
|
|
qse_mbsxfmt (locale, QSE_COUNTOF(locale), ".%u", (unsigned int)codepage);
|
|
setlocale (LC_ALL, locale);
|
|
/*qse_setdflcmgrbyid (QSE_CMGR_SLMB);*/
|
|
}
|
|
#else
|
|
setlocale (LC_ALL, "");
|
|
/*qse_setdflcmgrbyid (QSE_CMGR_SLMB);*/
|
|
#endif
|
|
|
|
qse_open_stdsios ();
|
|
|
|
QSE::App::setSignalHandler (SIGINT, handle_sigint);
|
|
test1();
|
|
QSE::App::unsetSignalHandler (SIGINT);
|
|
|
|
qse_close_stdsios ();
|
|
|
|
return 0;
|
|
}
|