MessagePipe.c

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