if (!GenerateChars(Sock))
{
- _tprintf(_T("Char generation failed\n"));
+ LogEvent(_T("Chargen: Char generation failed\n"), 0, FALSE);
RetVal = -1;
}
- _tprintf(_T("Shutting connection down...\n"));
+ LogEvent(_T("Chargen: Shutting connection down...\n"), 0, FALSE);
if (ShutdownConnection(Sock, FALSE))
- _tprintf(_T("Connection is down.\n"));
+ LogEvent(_T("Chargen: Connection is down.\n"), 0, FALSE);
else
{
- _tprintf(_T("Connection shutdown failed\n"));
+ LogEvent(_T("Chargen: Connection shutdown failed\n"), 0, FALSE);
RetVal = -1;
}
- _tprintf(_T("Terminating chargen thread\n"));
+ LogEvent(_T("Chargen: Terminating thread\n"), 0, FALSE);
ExitThread(RetVal);
}
{
if (RetVal != LineSize)
{
- _tprintf(("Not sent enough\n"));
+ LogEvent(_T("Chargen: Not sent enough bytes\n"), 0, FALSE);
return FALSE;
}
SentBytes += RetVal;
}
else if (RetVal == SOCKET_ERROR)
{
- _tprintf(("Socket error\n"));
+ LogEvent(_T("Chargen: Socket error\n"), 0, FALSE);
return FALSE;
}
else
- _tprintf(("unknown error\n"));
+ LogEvent(_T("Chargen: unknown error\n"), 0, FALSE);
//WSAGetLastError()
- _tprintf(("Connection closed by peer.\n"));
+ LogEvent(_T("Chargen: Connection closed by peer.\n"), 0, FALSE);
return TRUE;
}
SendTime(Sock, pszTime);
- _tprintf(_T("Shutting connection down...\n"));
+ LogEvent(_T("DayTime: Shutting connection down...\n"), 0, FALSE);
if (ShutdownConnection(Sock, FALSE))
- _tprintf(_T("Connection is down.\n"));
+ LogEvent(_T("DayTime: Connection is down.\n"), 0, FALSE);
else
{
- _tprintf(_T("Connection shutdown failed\n"));
+ LogEvent(_T("DayTime: Connection shutdown failed\n"), 0, FALSE);
RetVal = -1;
}
- _tprintf(_T("Terminating daytime thread\n"));
+ LogEvent(_T("DayTime: Terminating thread\n"), 0, FALSE);
ExitThread(RetVal);
}
if (RetVal == SOCKET_ERROR)
return FALSE;
- _tprintf(("Connection closed by peer.\n"));
+ LogEvent(_T("DayTime: Connection closed by peer.\n"), 0, FALSE);
return TRUE;
}
*\r
*/\r
\r
-#include <stdio.h>\r
-#include <winsock2.h>\r
-#include <tchar.h>\r
#include "tcpsvcs.h"\r
\r
DWORD WINAPI DiscardHandler(VOID* Sock_)\r
\r
if (!RecieveIncomingPackets(Sock))\r
{\r
- _tprintf(_T("RecieveIncomingPackets failed\n"));\r
+ LogEvent(_T("Discard: RecieveIncomingPackets failed\n"), 0, FALSE);\r
RetVal = -1;\r
}\r
\r
- _tprintf(_T("Shutting connection down...\n"));\r
+ LogEvent(_T("Discard: Shutting connection down...\n"), 0, FALSE);\r
if (ShutdownConnection(Sock, TRUE))\r
- {\r
- _tprintf(_T("Connection is down.\n"));\r
- }\r
+ LogEvent(_T("Discard: Connection is down.\n"), 0, FALSE);\r
else\r
{\r
- _tprintf(_T("Connection shutdown failed\n"));\r
+ LogEvent(_T("Discard: Connection shutdown failed\n"), 0, FALSE);\r
RetVal = -1;\r
}\r
\r
- _tprintf(_T("Terminating discard thread\n"));\r
+ LogEvent(_T("Discard: Terminating thread\n"), 0, FALSE);\r
ExitThread(RetVal);\r
}\r
\r
BOOL RecieveIncomingPackets(SOCKET Sock)\r
{\r
TCHAR ReadBuffer[BUF];\r
+ TCHAR temp[512]; // temp for holding LogEvent text\r
INT ReadBytes;\r
\r
do\r
{\r
ReadBytes = recv(Sock, ReadBuffer, BUF, 0);\r
if (ReadBytes > 0)\r
- _tprintf(_T("Received %d bytes from client\n"), ReadBytes);\r
+ {\r
+ _stprintf(temp, _T("Received %d bytes from client\n"), ReadBytes);\r
+ LogEvent(temp, 0, FALSE);\r
+ }\r
else if (ReadBytes == SOCKET_ERROR)\r
{\r
- _tprintf(("Socket Error: %d\n"), WSAGetLastError());\r
+ _stprintf(temp, ("Socket Error: %d\n"), WSAGetLastError());\r
+ LogEvent(temp, 0, TRUE);\r
return FALSE;\r
}\r
} while (ReadBytes > 0);\r
\r
- _tprintf(("Connection closed by peer.\n"));\r
+ LogEvent(_T("Discard: Connection closed by peer.\n"), 0, FALSE);\r
return TRUE;\r
}\r
*
*/
-#include <stdio.h>
-#include <winsock2.h>
-#include <tchar.h>
#include "tcpsvcs.h"
DWORD WINAPI EchoHandler(VOID* Sock_)
SOCKET Sock = (SOCKET)Sock_;
if (!EchoIncomingPackets(Sock)) {
- _tprintf(_T("Echo incoming packets failed\n"));
+ LogEvent(_T("Echo: EchoIncomingPackets failed\n"), 0, FALSE);
RetVal = -1;
}
- _tprintf(_T("Shutting connection down...\n"));
- if (ShutdownConnection(Sock, TRUE)) {
- _tprintf(_T("Connection is down.\n"));
- }
+ LogEvent(_T("Echo: Shutting connection down...\n"), 0, FALSE);
+
+ if (ShutdownConnection(Sock, TRUE))
+ LogEvent(_T("Echo: Connection is down\n"), 0, FALSE);
else
{
- _tprintf(_T("Connection shutdown failed\n"));
+ LogEvent(_T("Echo: Connection shutdown failed\n"), 0, FALSE);
RetVal = -1;
}
- _tprintf(_T("Terminating echo thread\n"));
+ LogEvent(_T("Echo: Terminating thread\n"), 0, FALSE);
ExitThread(RetVal);
}
BOOL EchoIncomingPackets(SOCKET Sock)
{
TCHAR ReadBuffer[BUF];
+ TCHAR temp[512]; // temp for holding LogEvent text
INT Temp;
INT ReadBytes;
INT SentBytes;
ReadBytes = recv(Sock, ReadBuffer, BUF, 0);
if (ReadBytes > 0)
{
- _tprintf(_T("Received %d bytes from client\n"), ReadBytes);
+ _stprintf(temp, _T("Received %d bytes from client\n"), ReadBytes);
+ LogEvent(temp, 0, FALSE);
SentBytes = 0;
while (SentBytes < ReadBytes)
ReadBytes - SentBytes, 0);
if (Temp > 0)
{
- _tprintf(_T("Sent %d bytes back to client\n"), Temp);
+ _stprintf(temp, _T("Sent %d bytes back to client\n"), Temp);
+ LogEvent(temp, 0, FALSE);
SentBytes += Temp;
}
else if (Temp == SOCKET_ERROR)
{
/* Client closed connection before we could reply to
all the data it sent, so quit early. */
- _tprintf(_T("Peer unexpectedly dropped connection!\n"));
+ _stprintf(temp, _T("Peer unexpectedly dropped connection!\n"));
+ LogEvent(temp, 0, FALSE);
return FALSE;
}
}
} while (ReadBytes != 0);
- _tprintf(("Connection closed by peer.\n"));
+ LogEvent(_T("Echo: Connection closed by peer.\n"), 0, FALSE);
return TRUE;
}
#include "tcpsvcs.h"
#define QBUFSIZ 160
-#define NUMQUOTES 60
LPCTSTR FilePath = _T("\\drivers\\etc\\quotes");
FILE *fp;
SOCKET Sock;
TCHAR Sys[MAX_PATH];
- TCHAR Quote[NUMQUOTES][BUFSIZ]; // need to set this dynamically
+ TCHAR Quote[60][BUFSIZ]; // need to set this dynamically
INT QuoteToPrint;
- INT i = 0;
+ INT NumQuotes;
Sock = (SOCKET)Sock_;
if(! GetSystemDirectory(Sys, MAX_PATH))
- _tprintf(_T("Getting system path failed. Error: %lu\n"), GetLastError());
+ {
+ LogEvent(_T("QOTD: Getting system path failed.\n"), 0, TRUE);
+ ExitThread(-1);
+ }
_tcscat(Sys, FilePath);
- _tprintf(_T("Opening quotes file\n"));
+ LogEvent(_T("QOTD: Opening quotes file\n"), 0, FALSE);
if ((fp = _tfopen(Sys, "r")) == NULL)
{
- _tprintf(_T("Error opening file: %lu\n"), GetLastError());
- _tprintf(_T("Terminating qotd thread\n"));
+ LogEvent(_T("QOTD: Error opening quote file\n"), 0, TRUE);
+ LogEvent(_T("QOTD: Terminating thread\n"), 0, FALSE);
ExitThread(-1);
}
- while (_fgetts(Quote[i], QBUFSIZ, fp) != NULL)
- i++;
+ /* read all quotes in the file into an array */
+ NumQuotes = 0;
+ while (_fgetts(Quote[NumQuotes], QBUFSIZ, fp) != NULL)
+ NumQuotes++;
- _tprintf(_T("Closing quotes file\n"));
+ LogEvent(_T("QOTD: Closing quotes file\n"), 0, FALSE);
fclose(fp);
/* randomise the quote */
srand((unsigned int) time(0));
- QuoteToPrint = rand() % NUMQUOTES;
+ QuoteToPrint = rand() % NumQuotes;
if (!SendQuote(Sock, Quote[QuoteToPrint]))
- {
- _tprintf(_T("Error sending data. Error: %x\n"), WSAGetLastError());
- }
+ LogEvent(_T("QOTD: Error sending data\n"), 0, TRUE);
+
- _tprintf(_T("Shutting connection down...\n"));
+ LogEvent(_T("QOTD: Shutting connection down...\n"), 0, FALSE);
if (ShutdownConnection(Sock, FALSE))
- _tprintf(_T("Connection is down.\n"));
+ LogEvent(_T("QOTD: Connection is down\n"), 0, FALSE);
else
{
- _tprintf(_T("Connection shutdown failed\n"));
- _tprintf(_T("Terminating qotd thread\n"));
+ LogEvent(_T("QOTD: Connection shutdown failed\n"), 0, FALSE);
+ LogEvent(_T("QOTD: Terminating thread\n"), 0, FALSE);
ExitThread(-1);
}
- _tprintf(_T("Terminating qotd thread\n"));
+ LogEvent(_T("QOTD: Terminating thread\n"), 0, FALSE);
ExitThread(0);
//return Retval;
if (RetVal == SOCKET_ERROR)
return FALSE;
- _tprintf(("Connection closed by peer.\n"));
+ LogEvent(_T("QOTD: Connection closed by peer\n"), 0, FALSE);
return TRUE;
}
*
*/
-#include <stdio.h>
-#include <winsock2.h>
-#include <tchar.h>
#include "tcpsvcs.h"
+extern BOOL bShutDownFlag;
+extern BOOL bPauseFlag;
+
DWORD WINAPI StartServer(LPVOID lpParam)
{
SOCKET ListeningSocket;
+ PSERVICES pServices;
const TCHAR* HostIP = "127.0.0.1";
- PSERVICES pServices;
+ TCHAR temp[512];
pServices = (PSERVICES)lpParam;
-
+
+//DebugBreak();
ListeningSocket = SetUpListener(HostIP, htons(pServices->Port));
if (ListeningSocket == INVALID_SOCKET)
{
- _tprintf(_T("error setting up socket\n"));
+ LogEvent("Socket error when setting up listener", 0, TRUE);
return 3;
}
- _tprintf(_T("%s is waiting for connections on port %d...\n"),
+ _stprintf(temp, _T("%s is waiting for connections on port %d...\n"),
pServices->Name, pServices->Port);
- while (1)
- {
- AcceptConnections(ListeningSocket, pServices->Service, pServices->Name);
- printf("Acceptor restarting...\n");
- }
+ LogEvent(temp, 0, FALSE);
- /* won't see this yet as we kill the service with ctrl+c */
- _tprintf(_T("Detaching Winsock2...\n"));
+ AcceptConnections(ListeningSocket, pServices->Service, pServices->Name);
+
+ LogEvent(_T("Detaching Winsock2...\n"), 0, FALSE);
WSACleanup();
return 0;
}
return Sock;
}
else
- printf("bind() failed\n");
+ LogEvent(_T("bind() failed\n"), 0, TRUE);
}
return INVALID_SOCKET;
}
+/* note: consider allowing a maximum number of connections
+ * A number of threads can be allocated and worker threads will
+ * only be spawned if a free space is available
+
+typedef struct _WORKER_THREAD {
+ DWORD num;
+ BOOL available;
+ HANDLE hThread;
+} WORKER_THREAD;
-
+*/
VOID AcceptConnections(SOCKET ListeningSocket,
LPTHREAD_START_ROUTINE Service, TCHAR *Name)
{
SOCKADDR_IN Client;
SOCKET Sock;
+ HANDLE hThread;
+ TIMEVAL TimeVal;
+ FD_SET ReadFDS;
INT nAddrSize = sizeof(Client);
DWORD ThreadID;
+ TCHAR temp[512];
+ INT TimeOut = 2000; // 2 seconds
+
+//DebugBreak();
+ /* monitor for incomming connections */
+ FD_ZERO(&ReadFDS);
- while (1)
+ /* set timeout values */
+ TimeVal.tv_sec = TimeOut / 1000;
+ TimeVal.tv_usec = TimeOut % 1000;
+
+ while (! bShutDownFlag) // (i<MAX_CLIENTS && !bShutDownFlag)
{
- Sock = accept(ListeningSocket, (SOCKADDR*)&Client, &nAddrSize);
- if (Sock != INVALID_SOCKET)
+ FD_SET(ListeningSocket, &ReadFDS);
+ if (select(0, &ReadFDS, NULL, NULL, &TimeVal) == SOCKET_ERROR)
{
- _tprintf(_T("Accepted connection to %s server from %s:%d\n"),
- Name, inet_ntoa(Client.sin_addr), ntohs(Client.sin_port));
- _tprintf(_T("Creating new thread for %s\n"), Name);
- CreateThread(0, 0, Service, (void*)Sock, 0, &ThreadID);
+ LogEvent(_T("select failed\n"), 0, TRUE);
+ return;
}
- else
+
+ if (FD_ISSET(ListeningSocket, &ReadFDS))
{
- _tprintf(_T("accept() failed\n"));
- return;
+ Sock = accept(ListeningSocket, (SOCKADDR*)&Client, &nAddrSize);
+ if (Sock != INVALID_SOCKET)
+ {
+ _stprintf(temp, _T("Accepted connection to %s server from %s:%d\n"),
+ Name, inet_ntoa(Client.sin_addr), ntohs(Client.sin_port));
+ LogEvent(temp, 0, FALSE);
+ _stprintf(temp, _T("Creating new thread for %s\n"), Name);
+ LogEvent(temp, 0, FALSE);
+
+ hThread = CreateThread(0, 0, Service, (void*)Sock, 0, &ThreadID);
+
+ /* Check the return value for success. */
+ if (hThread == NULL)
+ {
+ _stprintf(temp, _T("Failed to start worker thread for "
+ "the %s server....\n"), Name);
+ LogEvent(temp, 0, TRUE);
+ }
+
+ //Do we need to wait, or just kill it?
+ WaitForSingleObject(hThread, INFINITE);
+
+ }
+ else
+ {
+ LogEvent(_T("accept failed\n"), 0, TRUE);
+ return;
+ }
}
}
}
BOOL ShutdownConnection(SOCKET Sock, BOOL bRec)
{
+ TCHAR temp[512];
+
/* Disallow any further data sends. This will tell the other side
that we want to go away now. If we skip this step, we don't
shut the connection down nicely. */
if (shutdown(Sock, SD_SEND) == SOCKET_ERROR)
{
- _tprintf(_T("Error in shutdown"));
+ LogEvent(_T("Error in shutdown()\n"), 0, TRUE);
return FALSE;
}
if (NewBytes == SOCKET_ERROR)
return FALSE;
else if (NewBytes != 0)
- _tprintf(_T("FYI, received %d unexpected bytes during shutdown\n"), NewBytes);
+ {
+ _stprintf(temp, _T("FYI, received %d unexpected bytes during shutdown\n"), NewBytes);
+ LogEvent(temp, 0, FALSE);
+ }
}
/* Close the socket. */
* TODO:
* - Start tcpsvcs as a service.
* - write debugging function and print all dbg info via that.
- *
+ * - change 'temp' to something meaningfull
*/
-#include <stdio.h>
-#include <winsock2.h>
-#include <tchar.h>
+
#include "tcpsvcs.h"
-#if 0
+//#define NDEBUG
+//#include <debug.h>
+
+
/*
* globals
*/
+VOID WINAPI ServiceMain(DWORD argc, LPTSTR argv[]);
+
static SERVICE_STATUS hServStatus;
static SERVICE_STATUS_HANDLE hSStat;
+
FILE *hLogFile;
-BOOL bLogEvents = TRUE;
-BOOL ShutDown, PauseFlag;
-LPCTSTR LogFileName = "tcpsvcs_log.log";
+BOOL bShutDownFlag = FALSE;
+BOOL bPauseFlag = FALSE;
-static SERVICE_TABLE_ENTRY
-ServiceTable[2] =
-{
- {_T("tcpsvcs"), ServiceMain},
- {NULL, NULL}
-};
-#endif
+LPCTSTR LogFileName = "\\tcpsvcs_log.log";
+LPTSTR ServiceName = _T("Simp Tcp");
+//LPTSTR DisplayName = _T("Simple TCP/IP Services");
static SERVICES
Services[NUM_SERVICES] =
};
-int main(void)
-{
- DWORD dwThreadId[NUM_SERVICES];
- HANDLE hThread[NUM_SERVICES];
- WSADATA wsaData;
- DWORD RetVal;
- INT i;
-
- if ((RetVal = WSAStartup(MAKEWORD(2, 2), &wsaData)) != 0)
- {
- _tprintf(_T("WSAStartup() failed : %lu\n"), RetVal);
- return -1;
- }
-
- /* Create MAX_THREADS worker threads. */
- for( i=0; i<NUM_SERVICES; i++ )
- {
- _tprintf(_T("Starting %s server....\n"), Services[i].Name);
-
- hThread[i] = CreateThread(
- NULL, // default security attributes
- 0, // use default stack size
- StartServer, // thread function
- &Services[i], // argument to thread function
- 0, // use default creation flags
- &dwThreadId[i]); // returns the thread identifier
-
- /* Check the return value for success. */
- if (hThread[i] == NULL)
- {
- _tprintf(_T("Failed to start %s server....\n"), Services[i].Name);
- //ExitProcess(i);
- }
- }
-
- /* Wait until all threads have terminated. */
- WaitForMultipleObjects(NUM_SERVICES, hThread, TRUE, INFINITE);
-
- /* Close all thread handles upon completion. */
- for(i=0; i<NUM_SERVICES; i++)
- {
- CloseHandle(hThread[i]);
- }
- return 0;
-}
-
-
-
-/* code to run tcpsvcs as a service through services.msc */
-#if 0
int
main(int argc, char *argv[])
{
- //DPRINT("tcpsvcs: main() started. See tcpsvcs_log.txt for info\n");
+ SERVICE_TABLE_ENTRY ServiceTable[] =
+ {
+ {ServiceName, ServiceMain},
+ {NULL, NULL}
+ };
+
+ //DPRINT("Starting tcpsvcs service. See \system32%s for logs\n", LogFileName);
- if (!StartServiceCtrlDispatcher(ServiceTable))
- _tprintf(_T("failed to start the service control dispatcher\n"));
+ if (! StartServiceCtrlDispatcher(ServiceTable))
+ LogEvent(_T("failed to start the service control dispatcher\n"), -1, TRUE);
- //DPRINT("tcpsvcs: main() done\n");
+ //DPRINT("Shutdown tcpsvcs service\n");
return 0;
}
-static VOID WINAPI
+VOID WINAPI
ServiceMain(DWORD argc, LPTSTR argv[])
{
- DWORD i;
+ TCHAR LogFilePath[MAX_PATH];
- hLogFile = fopen(LogFileName, _T("w+"));
- if (hLogFile == NULL)
+ if(! GetSystemDirectory(LogFilePath, MAX_PATH))
return;
+
+ _tcscat(LogFilePath, LogFileName);
+
+ hLogFile = fopen(LogFilePath, _T("w"));
+ if (hLogFile == NULL)
+ {
+ TCHAR *temp = NULL;
+ _stprintf(temp, _T("Could not open log file: %s"), LogFilePath);
+ MessageBox(NULL, temp, NULL, MB_OK);
+ return;
+ }
+
LogEvent(_T("Entering ServiceMain"), 0, FALSE);
hServStatus.dwServiceType = SERVICE_WIN32_OWN_PROCESS;
hServStatus.dwControlsAccepted = SERVICE_ACCEPT_STOP |
SERVICE_ACCEPT_SHUTDOWN | SERVICE_ACCEPT_PAUSE_CONTINUE;
hServStatus.dwWin32ExitCode = ERROR_SERVICE_SPECIFIC_ERROR;
- hServStatus.dwServiceSpecificExitCode = 0;
+ hServStatus.dwServiceSpecificExitCode = NO_ERROR;
hServStatus.dwCheckPoint = 0;
hServStatus.dwWaitHint = 2*CS_TIMEOUT;
- hSStat = RegisterServiceCtrlHandler("tcpsvcs", ServerCtrlHandler);
+ hSStat = RegisterServiceCtrlHandler(ServiceName, ServerCtrlHandler);
if (hSStat == 0)
- LogEvent(_T("Failed to register service\n"), 100, TRUE);
+ LogEvent(_T("Failed to register service\n"), -1, TRUE);
LogEvent(_T("Control handler registered successfully"), 0, FALSE);
SetServiceStatus (hSStat, &hServStatus);
completes, indicating system shutdown. */
UpdateStatus (SERVICE_STOPPED, 0);
LogEvent(_T("Service status set to SERVICE_STOPPED"), 0, FALSE);
+ LogEvent(_T("Leaving ServiceMain"), 0, FALSE);
fclose(hLogFile); /* Clean up everything, in general */
return;
{
case SERVICE_CONTROL_SHUTDOWN: /* fall through */
case SERVICE_CONTROL_STOP:
- ShutDown = TRUE;
+ bShutDownFlag = TRUE;
UpdateStatus(SERVICE_STOP_PENDING, -1);
break;
case SERVICE_CONTROL_PAUSE:
- PauseFlag = TRUE;
+ bPauseFlag = TRUE;
break;
case SERVICE_CONTROL_CONTINUE:
- PauseFlag = FALSE;
+ bPauseFlag = FALSE;
break;
case SERVICE_CONTROL_INTERROGATE:
break;
void UpdateStatus (int NewStatus, int Check)
/* Set a new service status and checkpoint (either specific value or increment) */
{
- if (Check < 0 ) hServStatus.dwCheckPoint++;
- else hServStatus.dwCheckPoint = Check;
- if (NewStatus >= 0) hServStatus.dwCurrentState = NewStatus;
- if (!SetServiceStatus (hSStat, &hServStatus))
- LogEvent (_T("Cannot set service status"), 101, TRUE);
+ if (Check < 0 )
+ hServStatus.dwCheckPoint++;
+ else
+ hServStatus.dwCheckPoint = Check;
+
+ if (NewStatus >= 0)
+ hServStatus.dwCurrentState = NewStatus;
+
+ if (! SetServiceStatus (hSStat, &hServStatus))
+ LogEvent(_T("Cannot set service status"), -1, TRUE);
+
return;
}
{
DWORD dwThreadId[NUM_SERVICES];
HANDLE hThread[NUM_SERVICES];
+ WSADATA wsaData;
+ TCHAR temp[512]; // temp for holding LogEvent text
INT i;
+ DWORD RetVal;
+
+ if ((RetVal = WSAStartup(MAKEWORD(2, 2), &wsaData)) != 0)
+ {
+ _stprintf(temp, _T("WSAStartup() failed : %lu\n"), RetVal);
+ LogEvent(temp, RetVal, TRUE);
+ return -1;
+ }
UpdateStatus(-1, -1); /* increment checkpoint */
+ LogEvent(_T("Creating server Threads\n"), 0, FALSE);
+
/* Create MAX_THREADS worker threads. */
for( i=0; i<NUM_SERVICES; i++ )
{
- _tprintf(_T("Starting %s server....\n"), Services[i].Name);
+ _stprintf(temp, _T("Starting %s server....\n"), Services[i].Name);
+ LogEvent(temp, 0, FALSE);
hThread[i] = CreateThread(
NULL, // default security attributes
/* Check the return value for success. */
if (hThread[i] == NULL)
{
- _tprintf(_T("Failed to start %s server....\n"), Services[i].Name);
+ _stprintf(temp, _T("Failed to start %s server....\n"), Services[i].Name);
+ /* don't exit process via LogEvent. We want to exit via the server
+ * which failed to start, which could mean i=0 */
+ LogEvent(temp, 0, TRUE);
ExitProcess(i);
}
}
+
+ LogEvent(_T("setting service status to running\n"), 0, FALSE);
+
+ UpdateStatus(SERVICE_RUNNING, 0);
/* Wait until all threads have terminated. */
WaitForMultipleObjects(NUM_SERVICES, hThread, TRUE, INFINITE);
LPTSTR lpvSysMsg;
TCHAR MessageBuffer[512];
- if (PrintErrorMsg) {
+ if (PrintErrorMsg)
+ {
eMsgLen = FormatMessage (FORMAT_MESSAGE_ALLOCATE_BUFFER |
FORMAT_MESSAGE_FROM_SYSTEM, NULL,
ErrNum, MAKELANGID (LANG_NEUTRAL, SUBLANG_DEFAULT),
(LPTSTR)&lpvSysMsg, 0, NULL);
- _stprintf (MessageBuffer, _T("\n%s %s ErrNum = %d. ExitCode = %d."),
+ _stprintf(MessageBuffer, _T("\n%s %s ErrNum = %lu. ExitCode = %lu."),
UserMessage, lpvSysMsg, ErrNum, ExitCode);
- HeapFree (GetProcessHeap (), 0, lpvSysMsg);
- } else {
- _stprintf (MessageBuffer, _T("\n%s ExitCode = %d."),
+ HeapFree(GetProcessHeap (), 0, lpvSysMsg);
+ }
+ else
+ {
+ _stprintf(MessageBuffer, _T("\n%s ExitCode = %lu."),
UserMessage, ExitCode);
}
fputs (MessageBuffer, hLogFile);
- if (ExitCode > 0)
- ExitProcess (ExitCode);
+ if (ExitCode != 0)
+ ExitProcess(ExitCode);
else
return;
}
-
-#endif
*
*/
+#define WIN32_LEAN_AND_MEAN
+#include <stdio.h>
+#include <winsock2.h>
+#include <tchar.h>
+
+#define UNICODE
+#define _UNICODE
+
/* default port numbers */
#define ECHO_PORT 7
#define DISCARD_PORT 9
LPTHREAD_START_ROUTINE Service;
} SERVICES, *PSERVICES;
-
/* tcpsvcs functions */
//static VOID WINAPI ServiceMain(DWORD argc, LPTSTR argv[]);
VOID WINAPI ServerCtrlHandler(DWORD control);
projects / reactos.git / commitdiff