fork download
copy 
  1. #include "stdafx.h"
  2. #include <winsock2.h>
  3. #pragma comment(lib, "ws2_32")
  4. #include <windows.h>
  5. #include <list>
  6. #include <iterator>
  7. #include<time.h>
  8. /////////////////////////////////////////////////////////////////////////
  9. CRITICAL_SECTION	g_cs;			//Thread synchronization object.
  10. SOCKET				g_hSocket;		//server's listen socket
  11. std::list<SOCKET>	g_listClient;	//List of linked client sockets. Manage sockets with a linked list.
  12.  
  13. //Save the socket of the newly connected client to the list.
  14. BOOL AddUser(SOCKET hSocket)
  15. {
  16. 	::EnterCriticalSection(&g_cs);	
  17. 	g_listClient.push_back( hSocket ); 
  18. 	::LeaveCriticalSection(&g_cs);	
  19.  
  20. 	return TRUE;
  21. }
  22.  
  23. /////////////////////////////////////////////////////////////////////////
  24. //Send messages to all connected clients.
  25. void SendChattingMessage(char *pszParam)
  26. {
  27. 	int nLength = strlen(pszParam);
  28. 	std::list<SOCKET>::iterator it;
  29.  
  30. 	::EnterCriticalSection(&g_cs);	
  31. 	for (it = g_listClient.begin(); it != g_listClient.end(); ++it)
  32. 		::send(*it, pszParam, sizeof(char)* (nLength + 1), 0);
  33. 	::LeaveCriticalSection(&g_cs);		
  34. }
  35.  
  36. /////////////////////////////////////////////////////////////////////////
  37. //Ctrl+C when detect event, terminate program
  38. BOOL CtrlHandler(DWORD dwType)
  39. {
  40. 	if (dwType == CTRL_C_EVENT)
  41. 	{
  42. 		std::list<SOCKET>::iterator it;
  43.  
  44. 		//Close all connected clients and listening sockets and exit the program.
  45. 		::shutdown(g_hSocket, SD_BOTH);
  46.  
  47. 		::EnterCriticalSection(&g_cs);
  48. 		for (it = g_listClient.begin(); it != g_listClient.end(); ++it)
  49. 			::closesocket(*it);
  50. 		//Delete all information registered in the list of links.
  51. 		g_listClient.clear();
  52. 		::LeaveCriticalSection(&g_cs);	
  53.  
  54. 		puts("All client connections have been terminated.");
  55. 		//Wait for the threads communicating with the client to end.
  56. 		::Sleep(100);
  57. 		::DeleteCriticalSection(&g_cs);
  58. 		::closesocket(g_hSocket);
  59.  
  60. 		::WSACleanup();
  61. 		exit(0);
  62. 		return TRUE;
  63. 	}
  64.  
  65. 	return FALSE;
  66. }
  67. int flag = 0;
  68. time_t start, end;
  69. /////////////////////////////////////////////////////////////////////////
  70. //thread function that provides a chat message service to clients.
  71. //One thread is created for each connected client.
  72. DWORD WINAPI ThreadFunction(LPVOID pParam)
  73. {
  74. 	char szBuffer[128] = { 0 };
  75. 	int nReceive = 0;
  76. 	SOCKET hClient = (SOCKET)pParam;
  77.  
  78. 	/*if (flag == 0) {
  79. 		flag = 1;
  80. 		start = time(NULL);
  81. 	}
  82. 	std::cout << (double)(time(NULL) - start) << std::endl;
  83.  */
  84. 	puts("connected new client");
  85. 	while ((nReceive = ::recv(hClient,
  86. 							szBuffer, sizeof(szBuffer), 0)) > 0)
  87. 	{
  88. 		puts(szBuffer);
  89. 		//Send received strings to all connected clients
  90. 		SendChattingMessage(szBuffer);
  91. 		memset(szBuffer, 0, sizeof(szBuffer));
  92. 	}
  93.  
  94. 	puts("disconnected by client");
  95. 	::EnterCriticalSection(&g_cs);	
  96. 	g_listClient.remove(hClient);
  97. 	::LeaveCriticalSection(&g_cs);		
  98.  
  99. 	::closesocket(hClient);
  100. 	return 0;
  101. }
  102.  
  103.  
  104.  DWORD WINAPI HeartBeatFunc(LPVOID pParm) {
  105. 	end = clock();
  106. 	double duration = (double)((end - start) / CLOCKS_PER_SEC);
  107. 	if ((int)duration % 3 == 0) {
  108. 		std::cout << "check" << std::endl;
  109. 	}
  110. 	return 0;
  111. }
  112.  
  113. /////////////////////////////////////////////////////////////////////////
  114. int _tmain(int argc, _TCHAR* argv[])
  115. {
  116.  
  117. 	WSADATA wsa = { 0 };
  118. 	if (::WSAStartup(MAKEWORD(2, 2), &wsa) != 0)
  119. 	{
  120. 		puts("ERROR: Can't initial window socket");
  121. 		return 0;
  122. 	}
  123.  
  124.  
  125. 	::InitializeCriticalSection(&g_cs);
  126.  
  127. 	//When the Ctrl+C key is pressed, it detects it and registers the function to be processed.
  128. 	if ( ::SetConsoleCtrlHandler(
  129. 				(PHANDLER_ROUTINE)CtrlHandler, TRUE) == FALSE )
  130. 		puts("ERROR: Unable to enroll Ctrl+C controller");
  131.  
  132. 	//Create Connection Waiting Socket
  133. 	g_hSocket = ::socket(AF_INET, SOCK_STREAM, 0);
  134. 	if (g_hSocket == INVALID_SOCKET)
  135. 	{
  136. 		puts("ERROR: Unable to create connection waiting socket.");
  137. 		return 0;
  138. 	}
  139.  
  140.  
  141. 	SOCKADDR_IN	svraddr = { 0 };
  142. 	svraddr.sin_family = AF_INET;
  143. 	svraddr.sin_port = htons(25000);
  144. 	svraddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
  145. 	if (::bind(g_hSocket,
  146. 			(SOCKADDR*)&svraddr, sizeof(svraddr)) == SOCKET_ERROR)
  147. 	{
  148. 		puts("ERROR: Unable to port and Ip into socket");
  149. 		return 0;
  150. 	}
  151.  
  152. 	//
  153. 	if (::listen(g_hSocket, SOMAXCONN) == SOCKET_ERROR)
  154. 	{
  155. 		puts("ERROR: Unable to convert Listen status");
  156. 		return 0;
  157. 	}
  158. 	puts("*** Start Chatting server ***");
  159.  
  160. 	//Process and respond to client connections
  161. 	SOCKADDR_IN clientaddr = { 0 };
  162. 	int nAddrLen = sizeof(clientaddr);
  163. 	SOCKET hClient = 0;
  164. 	DWORD dwThreadID = 0;
  165. 	HANDLE hThread;
  166.  
  167. 	//Accept client connections and create a new socket (open)
  168. 	start = clock();
  169. 	HANDLE heartBeat = ::CreateThread(NULL,	//보안속성 상속
  170. 		0,			
  171. 		HeartBeatFunc,	
  172. 		(LPVOID)hClient,	
  173. 		0,			
  174. 		&dwThreadID);
  175.  
  176. 	while ((hClient = ::accept(g_hSocket,
  177. 		(SOCKADDR*)&clientaddr, &nAddrLen)) != INVALID_SOCKET)
  178. 	{
  179. 		if (AddUser(hClient) == FALSE)
  180. 		{
  181. 			puts("ERROR: Unable to process client connection.");
  182. 			CtrlHandler(CTRL_C_EVENT);
  183. 			break;
  184. 		}
  185.  
  186. 		//Received a string from the client.
  187. 		hThread = ::CreateThread(NULL,	
  188. 			0,				
  189. 			ThreadFunction,
  190. 			(LPVOID)hClient,
  191. 			0,				
  192. 			&dwThreadID);
  193.  
  194. 		::CloseHandle(hThread);
  195. 	}
  196.  
  197. 	puts("*** terminate chatting server ***");
  198. 	return 0;
  199. }
  200.  
Compilation error #stdin compilation error #stdout 0s 0KB
comments (?)
stdin
copy 
Standard input is empty
compilation info 
prog.cpp:1:10: fatal error: stdafx.h: No such file or directory
 #include "stdafx.h"
          ^~~~~~~~~~
compilation terminated.
stdout
copy 
Standard output is empty
https://ideone.com/7YeptO
language:
C++14 (gcc 8.3)
created:
2 years ago
visibility:
secret

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!