diff options
| author | George Hazan <george.hazan@gmail.com> | 2014-07-20 14:54:37 +0000 |
|---|---|---|
| committer | George Hazan <george.hazan@gmail.com> | 2014-07-20 14:54:37 +0000 |
| commit | 91d312baa652df4977bf1195053e28480970e20f (patch) | |
| tree | a5d55eda73ccba6dd68f3a8711b4764fe6eb5ac6 /plugins/FavContacts/src/cserver.cpp | |
| parent | 5163941eb4fcc1e90dcbda60e0a2496b55d36303 (diff) | |
support for the FavContacts's gadget
git-svn-id: http://svn.miranda-ng.org/main/trunk@9891 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c
Diffstat (limited to 'plugins/FavContacts/src/cserver.cpp')
| -rw-r--r-- | plugins/FavContacts/src/cserver.cpp | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/plugins/FavContacts/src/cserver.cpp b/plugins/FavContacts/src/cserver.cpp new file mode 100644 index 0000000000..d3a7ff5a0a --- /dev/null +++ b/plugins/FavContacts/src/cserver.cpp @@ -0,0 +1,68 @@ +#include "headers.h"
+
+#include "csocket.h"
+#include "cserver.h"
+
+void CServer::Start(int port, IConnectionProcessorFactory *connectionProcessorFactory, bool background)
+{
+ m_socket = socket(AF_INET, SOCK_STREAM, 0);
+ if (m_socket == INVALID_SOCKET) return;
+
+ sockaddr_in addr = { 0 };
+ addr.sin_family = AF_INET;
+ addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
+ addr.sin_port = htons((WORD)port);
+ if (bind(m_socket, (sockaddr *)&addr, sizeof(addr)) == SOCKET_ERROR) {
+ closesocket(m_socket);
+ m_socket = INVALID_SOCKET;
+ return;
+ }
+
+ listen(m_socket, SOMAXCONN);
+
+ m_connectionProcessorFactory = connectionProcessorFactory;
+
+ if (background)
+ mir_forkthread(GlobalConnectionAcceptThread, this);
+ else
+ ConnectionAcceptThread();
+}
+
+void CServer::Stop()
+{
+ shutdown(m_socket, SD_BOTH);
+ closesocket(m_socket);
+}
+
+DWORD CServer::ConnectionAcceptThread()
+{
+ while (1) {
+ SOCKET s = accept(m_socket, NULL, NULL);
+ if (s == INVALID_SOCKET) break;
+
+ mir_forkthread(GlobalConnectionProcessThread, new GlobalConnectionProcessThreadArgs(this, s));
+ }
+ return 0;
+}
+
+DWORD CServer::ConnectionProcessThread(SOCKET s)
+{
+ CSocket sock(s);
+ IConnectionProcessor *processor = m_connectionProcessorFactory->Create(&sock);
+ processor->ProcessConnection();
+ delete processor;
+ return 0;
+}
+
+void CServer::GlobalConnectionAcceptThread(void *arg)
+{
+ CServer *server = (CServer *)arg;
+ server->ConnectionAcceptThread();
+}
+
+void CServer::GlobalConnectionProcessThread(void *arg)
+{
+ GlobalConnectionProcessThreadArgs *args = (GlobalConnectionProcessThreadArgs *)arg;
+ args->m_server->ConnectionProcessThread(args->m_socket);
+ delete args;
+}
|