le_messaging.h

Go to the documentation of this file.

#ifndef LE_MESSAGING_H_INCLUDE_GUARD
#define LE_MESSAGING_H_INCLUDE_GUARD

// =======================================
//  DATA TYPES
// =======================================

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef struct le_msg_Protocol* le_msg_ProtocolRef_t;

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef struct le_msg_Service* le_msg_ServiceRef_t;

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef struct le_msg_Session* le_msg_SessionRef_t;

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef struct le_msg_Message* le_msg_MessageRef_t;


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef void (* le_msg_SessionEventHandler_t)
(
    le_msg_SessionRef_t sessionRef,
    void*               contextPtr
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef void (* le_msg_ReceiveHandler_t)
(
    le_msg_MessageRef_t msgRef,
    void*               contextPtr
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
typedef void (* le_msg_ResponseCallback_t)
(
    le_msg_MessageRef_t msgRef,
    void*               contextPtr
);


// =======================================
//  PROTOCOL FUNCTIONS
// =======================================

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_ProtocolRef_t le_msg_GetProtocolRef
(
    const char* protocolId,     
    size_t largestMsgSize       
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
const char* le_msg_GetProtocolIdStr
(
    le_msg_ProtocolRef_t protocolRef    
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
size_t le_msg_GetProtocolMaxMsgSize
(
    le_msg_ProtocolRef_t protocolRef    
);


// =======================================
//  SESSION FUNCTIONS
// =======================================

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_SessionRef_t le_msg_CreateSession
(
    le_msg_ProtocolRef_t    protocolRef,    
    const char*             serviceName     
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetSessionContextPtr
(
    le_msg_SessionRef_t sessionRef, 

    void*               contextPtr  
);

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void* le_msg_GetSessionContextPtr
(
    le_msg_SessionRef_t sessionRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_DeleteSession
(
    le_msg_SessionRef_t sessionRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetSessionRecvHandler
(
    le_msg_SessionRef_t     sessionRef, 
    le_msg_ReceiveHandler_t handlerFunc,
    void*                   contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetSessionCloseHandler
(
    le_msg_SessionRef_t             sessionRef, 
    le_msg_SessionEventHandler_t    handlerFunc,
    void*                           contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_OpenSession
(
    le_msg_SessionRef_t             sessionRef,     
    le_msg_SessionEventHandler_t    callbackFunc,   
    void*                           contextPtr      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_OpenSessionSync
(
    le_msg_SessionRef_t             sessionRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_CloseSession
(
    le_msg_SessionRef_t sessionRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_ProtocolRef_t le_msg_GetSessionProtocol
(
    le_msg_SessionRef_t sessionRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_ServiceRef_t le_msg_GetSessionService
(
    le_msg_SessionRef_t sessionRef  
);

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_result_t le_msg_GetClientUserId
(
    le_msg_SessionRef_t sessionRef, 
    uid_t*              userIdPtr   
);
//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_result_t le_msg_GetClientProcessId
(
    le_msg_SessionRef_t sessionRef,   
    pid_t*              processIdPtr  
);

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_result_t le_msg_GetClientUserCreds
(
    le_msg_SessionRef_t sessionRef,   
    uid_t*              userIdPtr,    
    pid_t*              processIdPtr  
);



// =======================================
//  MESSAGE FUNCTIONS
// =======================================

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_MessageRef_t le_msg_CreateMsg
(
    le_msg_SessionRef_t sessionRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_AddRef
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_ReleaseMsg
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
bool le_msg_NeedsResponse
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void* le_msg_GetPayloadPtr
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
size_t le_msg_GetMaxPayloadSize
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetFd
(
    le_msg_MessageRef_t msgRef,     
    int                 fd          
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
int le_msg_GetFd
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_Send
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_SessionRef_t le_msg_GetSession
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_RequestResponse
(
    le_msg_MessageRef_t         msgRef,     
    le_msg_ResponseCallback_t   handlerFunc,
    void*                       contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_MessageRef_t le_msg_RequestSyncResponse
(
    le_msg_MessageRef_t msgRef      
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_Respond
(
    le_msg_MessageRef_t msgRef      
);


// =======================================
//  SERVICE FUNCTIONS
// =======================================

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_ServiceRef_t le_msg_CreateService
(
    le_msg_ProtocolRef_t    protocolRef,    
    const char*             serviceName     
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_DeleteService
(
    le_msg_ServiceRef_t             serviceRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetServiceOpenHandler
(
    le_msg_ServiceRef_t             serviceRef, 
    le_msg_SessionEventHandler_t    handlerFunc,
    void*                           contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_GetServiceOpenHandler
(
    le_msg_ServiceRef_t             serviceRef, 
    le_msg_SessionEventHandler_t*   handlerFunc,
    void**                          contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetServiceCloseHandler
(
    le_msg_ServiceRef_t             serviceRef, 
    le_msg_SessionEventHandler_t    handlerFunc,
    void*                           contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_GetServiceCloseHandler
(
    le_msg_ServiceRef_t             serviceRef, 
    le_msg_SessionEventHandler_t*   handlerFunc,
    void**                          contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetServiceRecvHandler
(
    le_msg_ServiceRef_t     serviceRef, 
    le_msg_ReceiveHandler_t handlerFunc,
    void*                   contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_SetServiceContextPtr
(
    le_msg_ServiceRef_t serviceRef, 

    void*               contextPtr  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void* le_msg_GetServiceContextPtr
(
    le_msg_ServiceRef_t serviceRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_AdvertiseService
(
    le_msg_ServiceRef_t serviceRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
void le_msg_HideService
(
    le_msg_ServiceRef_t serviceRef  
);

//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
const char* le_msg_GetServiceName
(
    le_msg_ServiceRef_t serviceRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_ProtocolRef_t le_msg_GetServiceProtocol
(
    le_msg_ServiceRef_t serviceRef  
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
le_msg_MessageRef_t le_msg_GetServiceRxMsg
(
    void
);


//--------------------------------------------------------------------------------------------------
//--------------------------------------------------------------------------------------------------
#define LE_KILL_CLIENT(formatString, ...)  \
{ \
    le_msg_MessageRef_t msgRef = le_msg_GetServiceRxMsg(); \
    LE_FATAL_IF(msgRef == NULL, formatString, ##__VA_ARGS__); \
    LE_EMERG(formatString, ##__VA_ARGS__); \
    le_msg_CloseSession(le_msg_GetSession(msgRef)); \
}

#endif // LEGATO_MESSAGING_INCLUDE_GUARD