From 8007a659cd115857a71947cf6d309ab8e96895dc Mon Sep 17 00:00:00 2001
From: mataes2007 <mataes2007@e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb>
Date: Wed, 4 May 2011 19:04:57 +0000
Subject: added FavContacts

git-svn-id: http://miranda-plugins.googlecode.com/svn/trunk@65 e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb
---
 FavContacts/src/cserver.cpp | 82 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 82 insertions(+)
 create mode 100644 FavContacts/src/cserver.cpp

(limited to 'FavContacts/src/cserver.cpp')

diff --git a/FavContacts/src/cserver.cpp b/FavContacts/src/cserver.cpp
new file mode 100644
index 0000000..957d1a6
--- /dev/null
+++ b/FavContacts/src/cserver.cpp
@@ -0,0 +1,82 @@
+#include <winsock2.h>
+#include <windows.h>
+#include <ws2tcpip.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)
+	{
+		CreateThread(NULL, 0,
+			GlobalConnectionAcceptThread,
+			this,
+			0, NULL);
+	} 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;
+
+		CreateThread(NULL, 0,
+			GlobalConnectionProcessThread,
+			new GlobalConnectionProcessThreadArgs(this, s),
+			0, NULL);
+	}
+	return 0;
+}
+
+DWORD CServer::ConnectionProcessThread(SOCKET s)
+{
+	CSocket sock(s);
+	IConnectionProcessor *processor = m_connectionProcessorFactory->Create(&sock);
+	processor->ProcessConnection();
+	delete processor;
+	return 0;
+}
+
+DWORD WINAPI CServer::GlobalConnectionAcceptThread(void *arg)
+{
+	CServer *server = (CServer *)arg;
+	return server->ConnectionAcceptThread();
+}
+
+DWORD WINAPI CServer::GlobalConnectionProcessThread(void *arg)
+{
+	GlobalConnectionProcessThreadArgs *args = (GlobalConnectionProcessThreadArgs *)arg;
+	DWORD result = args->m_server->ConnectionProcessThread(args->m_socket);
+	delete args;
+	return result;
+}
-- 
cgit v1.2.3