MessagePipe.c

 
#include <winpr/config.h>
 
#include <winpr/crt.h>
#include <winpr/sysinfo.h>
 
#include <winpr/collections.h>
 
void MessagePipe_PostQuit(wMessagePipe* pipe, int nExitCode)
{
  MessageQueue_PostQuit(pipe->In, nExitCode);
  MessageQueue_PostQuit(pipe->Out, nExitCode);
}
 
wMessagePipe* MessagePipe_New(void)
{
  wMessagePipe* pipe = NULL;
 
  pipe = (wMessagePipe*)malloc(sizeof(wMessagePipe));
 
  if (!pipe)
    return NULL;
 
  pipe->In = MessageQueue_New(NULL);
  if (!pipe->In)
    goto error_in;
 
  pipe->Out = MessageQueue_New(NULL);
  if (!pipe->Out)
    goto error_out;
 
  return pipe;
 
error_out:
  MessageQueue_Free(pipe->In);
error_in:
  free(pipe);
  return NULL;
}
 
void MessagePipe_Free(wMessagePipe* pipe)
{
  if (pipe)
  {
    MessageQueue_Free(pipe->In);
    MessageQueue_Free(pipe->Out);
 
    free(pipe);
  }
}