mirrors/FreeRDP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Using handle close callback now.

Browse Source
This commit is contained in:
Armin Novak 2015-03-11 15:11:03 +01:00
parent 0daae8a2aa
commit a6f27f48ea
1 changed files with 45 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
winpr/libwinpr/pipe/pipe.c
View File

@ -42,6 +42,7 @@
#include <sys/stat.h>
#include <sys/socket.h>
#include <assert.h>
#include <pthread.h>
#include "pipe.h"
@ -70,6 +71,47 @@ typedef struct _NamedPipeServerSocketEntry
int references;
} NamedPipeServerSocketEntry;
static pthread_once_t pipe_initialized = PTHREAD_ONCE_INIT;
static HANDLE_CLOSE_CB _PipeHandleCloseCb;
static BOOL PipeCloseHandle(HANDLE handle);
static BOOL PipeIsHandled(HANDLE handle)
{
WINPR_PIPE* pPipe = (WINPR_PIPE*) handle;
if (!pPipe || pPipe->Type != HANDLE_TYPE_ANONYMOUS_PIPE)
{
SetLastError(ERROR_INVALID_HANDLE);
return FALSE;
}
return TRUE;
}
static void PipeInitialize(void)
{
_PipeHandleCloseCb.IsHandled = PipeIsHandled;
_PipeHandleCloseCb.CloseHandle = PipeCloseHandle;
RegisterHandleCloseCb(&_PipeHandleCloseCb);
}
BOOL PipeCloseHandle(HANDLE handle) {
WINPR_PIPE* pipe = (WINPR_PIPE *)handle;
if (!PipeIsHandled(handle))
return FALSE;
if (pipe->fd != -1)
{
close(pipe->fd);
}
free(handle);
return TRUE;
}
static void InitWinPRPipeModule()
{
if (g_NamedPipeServerSockets)
@ -91,6 +133,9 @@ BOOL CreatePipe(PHANDLE hReadPipe, PHANDLE hWritePipe, LPSECURITY_ATTRIBUTES lpP
pipe_fd[0] = -1;
pipe_fd[1] = -1;
if (pthread_once(&pipe_initialized, PipeInitialize))
return FALSE;
if (pipe(pipe_fd) < 0)
{
WLog_ERR(TAG, "failed to create pipe");