endpoint_ipc.c

Go to the documentation of this file.

/****************************************************************************
 * This file is part of the project Gwenhywfar.
 * Gwenhywfar (c) by 2023 Martin Preuss, all rights reserved.
 *
 * The license for this file can be found in the file COPYING which you
 * should have received along with this file.
 ****************************************************************************/
 
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
 
/*#define DISABLE_DEBUGLOG*/
 
 
#include "./endpoint_ipc.h"
#include "./endpoint_msgio.h"
#include "./endpoint_tcpc.h"
#include "./msg_ipc.h"
 
#include <gwenhywfar/debug.h>
 
 
#define GWEN_MSG_ENDPOINT_IPC_NAME       "ipc"
 
 
 
/* ------------------------------------------------------------------------------------------------
 * forward declarations
 * ------------------------------------------------------------------------------------------------
 */
 
static int _getBytesNeededForMessage(GWEN_MSG_ENDPOINT *ep, GWEN_MSG *msg);
 
 
 
/* ------------------------------------------------------------------------------------------------
 * implementations
 * ------------------------------------------------------------------------------------------------
 */
 
void GWEN_IpcEndpoint_Extend(GWEN_MSG_ENDPOINT *ep)
{
  if (ep) {
    GWEN_MsgIoEndpoint_SetGetNeededBytesFn(ep, _getBytesNeededForMessage);
  }
}
 
 
 
int _getBytesNeededForMessage(GWEN_UNUSED GWEN_MSG_ENDPOINT *ep, GWEN_MSG *msg)
{
  uint32_t bytesInMsg;
 
  bytesInMsg=GWEN_Msg_GetBytesInBuffer(msg);
  if (bytesInMsg<GWEN_MSGIPC_OFFS_PAYLOAD) {
    DBG_DEBUG(GWEN_LOGDOMAIN, "Header not yet complete");
    return (int) (GWEN_MSGIPC_OFFS_PAYLOAD-bytesInMsg);
  }
  else {
    uint32_t msgSize;
 
    msgSize=GWEN_IpcMsg_GetMsgSize(msg); /* IPC length field contains ALL bytes including header */
    return (int) (msgSize-bytesInMsg);
  }
}
 
 
 
GWEN_MSG_ENDPOINT *GWEN_IpcEndpoint_CreateIpcTcpClient(const char *host, int port, const char *name, int groupId)
{
  GWEN_MSG_ENDPOINT *ep;
 
  ep=GWEN_TcpcEndpoint_new(host, port, name?name:GWEN_MSG_ENDPOINT_IPC_NAME, groupId);
  GWEN_MsgIoEndpoint_Extend(ep);
  GWEN_IpcEndpoint_Extend(ep);
  return ep;
}
 
 
 
GWEN_MSG_ENDPOINT *GWEN_IpcEndpoint_CreateIpcTcpServiceForSocket(GWEN_SOCKET *sk, const char *name, int groupId)
{
  GWEN_MSG_ENDPOINT *ep;
 
  ep=GWEN_MsgEndpoint_new(name?name:GWEN_MSG_ENDPOINT_IPC_NAME, groupId);
  GWEN_MsgEndpoint_SetSocket(ep, sk);
  GWEN_MsgIoEndpoint_Extend(ep);
  GWEN_IpcEndpoint_Extend(ep);
  return ep;
}