Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-08-03 12:55:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix formatting

Browse source 
svn path=/trunk/; revision=32491
This commit is contained in:
Christoph von Wittich 2008-02-26 13:54:12 +00:00
parent 232221602a
commit 271529ea21
1 changed files with 38 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

76
reactos/base/services/tcpsvcs/skelserver.c
View file

@ -59,53 +59,53 @@ AcceptConnections(SOCKET ListeningSocket,
while (!bShutDown) while (!bShutDown)
{ {
INT SelRet = 0; INT SelRet = 0;
FD_ZERO(&ReadFDS); FD_ZERO(&ReadFDS);
FD_SET(ListeningSocket, &ReadFDS); FD_SET(ListeningSocket, &ReadFDS);
SelRet = select(0, &ReadFDS, NULL, NULL, &TimeVal); SelRet = select(0, &ReadFDS, NULL, NULL, &TimeVal);
if (SelRet == SOCKET_ERROR) if (SelRet == SOCKET_ERROR)
{ {
LogEvent(_T("select failed\n"), 0, TRUE); LogEvent(_T("select failed\n"), 0, TRUE);
return; return;
} }
else if (SelRet > 0) else if (SelRet > 0)
{ {
/* don't call FD_ISSET if bShutDown flag is set */ /* don't call FD_ISSET if bShutDown flag is set */
if ((! bShutDown) || (FD_ISSET(ListeningSocket, &ReadFDS))) if ((! bShutDown) || (FD_ISSET(ListeningSocket, &ReadFDS)))
{ {
Sock = accept(ListeningSocket, (SOCKADDR*)&Client, &nAddrSize); Sock = accept(ListeningSocket, (SOCKADDR*)&Client, &nAddrSize);
if (Sock != INVALID_SOCKET) if (Sock != INVALID_SOCKET)
{ {
_stprintf(buf, _T("Accepted connection to %s server from %s:%d\n"), _stprintf(buf, _T("Accepted connection to %s server from %s:%d\n"),
Name, inet_ntoa(Client.sin_addr), ntohs(Client.sin_port)); Name, inet_ntoa(Client.sin_addr), ntohs(Client.sin_port));
LogEvent(buf, 0, FALSE); LogEvent(buf, 0, FALSE);
_stprintf(buf, _T("Creating new thread for %s\n"), Name); _stprintf(buf, _T("Creating new thread for %s\n"), Name);
LogEvent(buf, 0, FALSE); LogEvent(buf, 0, FALSE);
hThread = CreateThread(0, 0, Service, (void*)Sock, 0, &ThreadID); hThread = CreateThread(0, 0, Service, (void*)Sock, 0, &ThreadID);
/* Check the return value for success. */ /* Check the return value for success. */
if (hThread == NULL) if (hThread == NULL)
{ {
_stprintf(buf, _T("Failed to start worker thread for " _stprintf(buf, _T("Failed to start worker thread for "
"the %s server....\n"), Name); "the %s server....\n"), Name);
LogEvent(buf, 0, TRUE); LogEvent(buf, 0, TRUE);
} }
else else
{ {
WaitForSingleObject(hThread, INFINITE); WaitForSingleObject(hThread, INFINITE);
CloseHandle(hThread); CloseHandle(hThread);
} }
} }
else else
{ {
LogEvent(_T("accept failed\n"), 0, TRUE); LogEvent(_T("accept failed\n"), 0, TRUE);
return; return;
} }
} }
} }
} }
} }