Function NamedPipeServerThreadProc

libipc/server.cpp:99–136

}

DWORD WINAPI NamedPipeServerThreadProc(PVOID lpvParam)
{
	//_tprintf(TEXT("\nPipe Server: Main thread awaiting client connection on %s\n"), lpszPipename);
	
	while (true) {
		// Wait for the client to connect; if it succeeds, 
		// the function returns a nonzero value. If the function
		// returns zero, GetLastError returns ERROR_PIPE_CONNECTED. 

		auto hPipe = CreateNamedPipe(
			GetNamedPipeName(false),       // pipe name 
			PIPE_ACCESS_DUPLEX,       // read/write access 
			PIPE_TYPE_MESSAGE |       // message type pipe 
			PIPE_READMODE_MESSAGE |   // message-read mode 
			PIPE_WAIT | PIPE_REJECT_REMOTE_CLIENTS,  // blocking mode, local only 
			PIPE_UNLIMITED_INSTANCES, // max. instances  
			CMD_NAMED_PIPE_BUFSIZE,   // output buffer size 
			CMD_NAMED_PIPE_BUFSIZE,   // input buffer size 
			0,                        // client time-out 
			NULL);                    // default security attribute 

		if (hPipe == INVALID_HANDLE_VALUE)
			return 1;

		auto fConnected = ConnectNamedPipe(hPipe, NULL) ?
			TRUE : (GetLastError() == ERROR_PIPE_CONNECTED);

		if (fConnected) {
			auto con = reinterpret_cast<NamedPipeServerContext*>(lpvParam);
			con->callback(con->context, hPipe);
		} else {
			// The client could not connect, so close the pipe. 
			CloseHandle(hPipe);
		}
	}

	return 0;
}