#include <gwenhywfar/inherit.h>
#include <gwenhywfar/tree2.h>
#include <gwenhywfar/inetsocket.h>
#include <gwenhywfar/msg.h>
#include <time.h>

Include dependency graph for endpoint.h:

Macros
#define	GWEN_MSG_ENDPOINT_FLAGS_DELETE 0x80000000u
#define	GWEN_MSG_ENDPOINT_FLAGS_NOIO 0x40000000u
#define	GWEN_MSG_ENDPOINT_STATE_CONNECTED 2
#define	GWEN_MSG_ENDPOINT_STATE_CONNECTING 1
#define	GWEN_MSG_ENDPOINT_STATE_UNCONNECTED 0

Typedefs
typedef struct GWEN_MSG_ENDPOINT	GWEN_MSG_ENDPOINT
	Object which can send and receive messages (base class).
typedef void(*	GWEN_MSG_ENDPOINT_ADDSOCKETS_FN) (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)
typedef void(*	GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN) (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)

Functions
GWENHYWFAR_API void	GWEN_MsgEndpoint_AddFlags (GWEN_MSG_ENDPOINT *ep, uint32_t f)
GWENHYWFAR_API void	GWEN_MsgEndpoint_AddReceivedMessage (GWEN_MSG_ENDPOINT ep, GWEN_MSG m)
GWENHYWFAR_API void	GWEN_MsgEndpoint_AddSendMessage (GWEN_MSG_ENDPOINT ep, GWEN_MSG m)
GWENHYWFAR_API void	GWEN_MsgEndpoint_AddSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)
GWENHYWFAR_API void	GWEN_MsgEndpoint_Attach (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API void	GWEN_MsgEndpoint_CheckSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)
GWENHYWFAR_API void	GWEN_MsgEndpoint_ChildrenAddSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)
GWENHYWFAR_API void	GWEN_MsgEndpoint_ChildrenCheckSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)
GWENHYWFAR_API void	GWEN_MsgEndpoint_ChildrenIoLoop (GWEN_MSG_ENDPOINT *ep, int timeout)
GWENHYWFAR_API void	GWEN_MsgEndpoint_DelFlags (GWEN_MSG_ENDPOINT *ep, uint32_t f)
GWENHYWFAR_API int	GWEN_MsgEndpoint_DiscardInput (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API void	GWEN_MsgEndpoint_Disconnect (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API void	GWEN_MsgEndpoint_free (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG *	GWEN_MsgEndpoint_GetCurrentlyReceivedMsg (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API int	GWEN_MsgEndpoint_GetDefaultMessageSize (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG *	GWEN_MsgEndpoint_GetFirstReceivedMessage (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG *	GWEN_MsgEndpoint_GetFirstSendMessage (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API uint32_t	GWEN_MsgEndpoint_GetFlags (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API int	GWEN_MsgEndpoint_GetGroupId (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API const char *	GWEN_MsgEndpoint_GetName (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API uint32_t	GWEN_MsgEndpoint_GetNextMessageId (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG_LIST *	GWEN_MsgEndpoint_GetReceivedMessageList (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG_LIST *	GWEN_MsgEndpoint_GetSendMessageList (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_SOCKET *	GWEN_MsgEndpoint_GetSocket (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API int	GWEN_MsgEndpoint_GetState (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API time_t	GWEN_MsgEndpoint_GetTimeOfLastStateChange (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API int	GWEN_MsgEndpoint_HaveMessageToSend (const GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API void	GWEN_MsgEndpoint_IoLoop (GWEN_MSG_ENDPOINT *ep, int timeout)
GWENHYWFAR_API GWEN_MSG_ENDPOINT *	GWEN_MsgEndpoint_new (const char *name, int groupId)
GWENHYWFAR_API int	GWEN_MsgEndpoint_ReadFromSocket (GWEN_MSG_ENDPOINT ep, uint8_t bufferPtr, uint32_t bufferLen)
GWENHYWFAR_API void	GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API GWEN_MSG_ENDPOINT_ADDSOCKETS_FN	GWEN_MsgEndpoint_SetAddSocketsFn (GWEN_MSG_ENDPOINT *ep, GWEN_MSG_ENDPOINT_ADDSOCKETS_FN fn)
GWENHYWFAR_API GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN	GWEN_MsgEndpoint_SetCheckSocketsFn (GWEN_MSG_ENDPOINT *ep, GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN fn)
GWENHYWFAR_API void	GWEN_MsgEndpoint_SetCurrentlyReceivedMsg (GWEN_MSG_ENDPOINT ep, GWEN_MSG m)
GWENHYWFAR_API void	GWEN_MsgEndpoint_SetDefaultMessageSize (GWEN_MSG_ENDPOINT *ep, int i)
GWENHYWFAR_API void	GWEN_MsgEndpoint_SetFlags (GWEN_MSG_ENDPOINT *ep, uint32_t f)
GWENHYWFAR_API void	GWEN_MsgEndpoint_SetSocket (GWEN_MSG_ENDPOINT ep, GWEN_SOCKET sk)
GWENHYWFAR_API void	GWEN_MsgEndpoint_SetState (GWEN_MSG_ENDPOINT *ep, int m)
GWENHYWFAR_API GWEN_MSG *	GWEN_MsgEndpoint_TakeFirstReceivedMessage (GWEN_MSG_ENDPOINT *ep)
GWENHYWFAR_API int	GWEN_MsgEndpoint_WriteToSocket (GWEN_MSG_ENDPOINT ep, const uint8_t bufferPtr, uint32_t bufferLen)

Macro Definition Documentation

◆ GWEN_MSG_ENDPOINT_FLAGS_DELETE

#define GWEN_MSG_ENDPOINT_FLAGS_DELETE 0x80000000u

Definition at line 19 of file endpoint.h.

◆ GWEN_MSG_ENDPOINT_FLAGS_NOIO

#define GWEN_MSG_ENDPOINT_FLAGS_NOIO 0x40000000u

Definition at line 20 of file endpoint.h.

◆ GWEN_MSG_ENDPOINT_STATE_CONNECTED

#define GWEN_MSG_ENDPOINT_STATE_CONNECTED 2

Definition at line 25 of file endpoint.h.

Referenced by _addSockets(), _addSockets(), _addSockets(), _addSockets(), _checkSockets(), _checkSockets(), _checkSockets(), _checkSockets(), GWEN_TcpcEndpoint_StartConnect(), and GWEN_TcpdEndpoint_StartListening().

◆ GWEN_MSG_ENDPOINT_STATE_CONNECTING

#define GWEN_MSG_ENDPOINT_STATE_CONNECTING 1

Definition at line 24 of file endpoint.h.

Referenced by _addSockets(), _addSockets(), _checkSockets(), _checkSockets(), GWEN_MultilayerEndpoint_StartConnect(), and GWEN_TcpcEndpoint_StartConnect().

◆ GWEN_MSG_ENDPOINT_STATE_UNCONNECTED

#define GWEN_MSG_ENDPOINT_STATE_UNCONNECTED 0

Definition at line 23 of file endpoint.h.

Referenced by _addSockets(), _addSockets(), _addSockets(), _addSocketsWhenConnected(), _addSocketsWhenConnecting(), _checkSockets(), GWEN_MsgEndpoint_Disconnect(), GWEN_MsgEndpoint_GetState(), GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(), GWEN_MultilayerEndpoint_StartConnect(), GWEN_TcpcEndpoint_new(), GWEN_TcpcEndpoint_StartConnect(), GWEN_TcpdEndpoint_new(), and GWEN_TcpdEndpoint_StartListening().

Typedef Documentation

◆ GWEN_MSG_ENDPOINT

typedef struct GWEN_MSG_ENDPOINT GWEN_MSG_ENDPOINT

Object which can send and receive messages (base class).

Definition at line 37 of file endpoint.h.

◆ GWEN_MSG_ENDPOINT_ADDSOCKETS_FN

typedef void(* GWEN_MSG_ENDPOINT_ADDSOCKETS_FN) (GWEN_MSG_ENDPOINT *ep, GWEN_SOCKETSET *readSet, GWEN_SOCKETSET *writeSet, GWEN_SOCKETSET *xSet)

Definition at line 183 of file endpoint.h.

◆ GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN

typedef void(* GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN) (GWEN_MSG_ENDPOINT *ep, GWEN_SOCKETSET *readSet, GWEN_SOCKETSET *writeSet, GWEN_SOCKETSET *xSet)

Definition at line 188 of file endpoint.h.

Function Documentation

◆ GWEN_MsgEndpoint_AddFlags()

GWENHYWFAR_API void GWEN_MsgEndpoint_AddFlags	(	GWEN_MSG_ENDPOINT *	ep,
		uint32_t	f )

Definition at line 169 of file endpoint.c.

◆ GWEN_MsgEndpoint_AddReceivedMessage()

GWENHYWFAR_API void GWEN_MsgEndpoint_AddReceivedMessage	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_MSG *	m )

Definition at line 221 of file endpoint.c.

References GWEN_Msg_List_Add(), and GWEN_Msg_RewindCurrentPos().

Referenced by _distributeBufferContent().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_AddSendMessage()

GWENHYWFAR_API void GWEN_MsgEndpoint_AddSendMessage	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_MSG *	m )

Definition at line 250 of file endpoint.c.

References GWEN_Msg_List_Add(), and GWEN_Msg_RewindCurrentPos().

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_AddSockets()

GWENHYWFAR_API void GWEN_MsgEndpoint_AddSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet )

Definition at line 289 of file endpoint.c.

Referenced by _addSocketsWhenConnected(), _addSocketsWhenConnecting(), GWEN_MsgEndpoint_ChildrenAddSockets(), and GWEN_MsgEndpoint_IoLoop().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_Attach()

GWENHYWFAR_API void GWEN_MsgEndpoint_Attach ( GWEN_MSG_ENDPOINT * ep )

Definition at line 53 of file endpoint.c.

Referenced by GWEN_MsgRequest_SetEndpoint().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_CheckSockets()

GWENHYWFAR_API void GWEN_MsgEndpoint_CheckSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet )

Definition at line 297 of file endpoint.c.

Referenced by _checkSocketsWhenConnected(), _checkSocketsWhenConnecting(), GWEN_MsgEndpoint_ChildrenCheckSockets(), and GWEN_MsgEndpoint_IoLoop().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_ChildrenAddSockets()

GWENHYWFAR_API void GWEN_MsgEndpoint_ChildrenAddSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet )

Definition at line 305 of file endpoint.c.

References GWEN_MsgEndpoint_AddSockets().

Referenced by _addSockets(), and GWEN_MsgEndpoint_ChildrenIoLoop().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_ChildrenCheckSockets()

GWENHYWFAR_API void GWEN_MsgEndpoint_ChildrenCheckSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet )

Definition at line 321 of file endpoint.c.

References GWEN_MsgEndpoint_CheckSockets().

Referenced by _checkSockets(), and GWEN_MsgEndpoint_ChildrenIoLoop().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_ChildrenIoLoop()

GWENHYWFAR_API void GWEN_MsgEndpoint_ChildrenIoLoop	(	GWEN_MSG_ENDPOINT *	ep,
		int	timeout )

Handles IO for all first-level children of the given endpoint (like GWEN_MsgEndpoint_IoLoop does for a single endpoint).

Parameters

ep	endpoint whose direct first-level children are handles
timeout	timeout in milliseconds for the select() system call internally used

Definition at line 392 of file endpoint.c.

References DBG_INFO, GWEN_ERROR_INTERRUPTED, GWEN_ERROR_TIMEOUT, GWEN_LOGDOMAIN, GWEN_MsgEndpoint_ChildrenAddSockets(), GWEN_MsgEndpoint_ChildrenCheckSockets(), GWEN_Socket_Select(), GWEN_SocketSet_free(), GWEN_SocketSet_GetSocketCount(), GWEN_SocketSet_new(), and NULL.

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_DelFlags()

GWENHYWFAR_API void GWEN_MsgEndpoint_DelFlags	(	GWEN_MSG_ENDPOINT *	ep,
		uint32_t	f )

Definition at line 177 of file endpoint.c.

◆ GWEN_MsgEndpoint_DiscardInput()

GWENHYWFAR_API int GWEN_MsgEndpoint_DiscardInput ( GWEN_MSG_ENDPOINT * ep )

This function can be used to drain the file descriptor/socket from waiting data. An example is an endpoint implementation from AqHome which uses an USB serial device. When message receiption errors occur (e.g. due to collisions on the data line) the rest of data on the line needs to be discarded because it might belong the the errornous previous message.

Definition at line 460 of file endpoint.c.

References DBG_INFO, GWEN_ERROR_IO, GWEN_ERROR_TIMEOUT, GWEN_LOGDOMAIN, and GWEN_MsgEndpoint_ReadFromSocket().

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_Disconnect()

GWENHYWFAR_API void GWEN_MsgEndpoint_Disconnect ( GWEN_MSG_ENDPOINT * ep )

Definition at line 483 of file endpoint.c.

References DBG_INFO, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MsgEndpoint_SetState(), GWEN_Socket_Close(), GWEN_Socket_free(), and NULL.

Referenced by _addSockets(), _addSocketsWhenConnected(), _addSocketsWhenConnecting(), _checkSockets(), and _checkSockets().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_free()

GWENHYWFAR_API void GWEN_MsgEndpoint_free ( GWEN_MSG_ENDPOINT * ep )

Definition at line 61 of file endpoint.c.

References DBG_INFO, GWEN_FREE_OBJECT, GWEN_INHERIT_FINI, GWEN_LOGDOMAIN, GWEN_Msg_free(), GWEN_Msg_List_free(), GWEN_Msg_List_GetCount(), GWEN_Socket_Close(), GWEN_Socket_free(), and GWEN_TREE2_FINI.

Referenced by GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(), GWEN_MsgRequest_free(), and GWEN_MsgRequest_SetEndpoint().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetCurrentlyReceivedMsg()

GWENHYWFAR_API GWEN_MSG * GWEN_MsgEndpoint_GetCurrentlyReceivedMsg ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 274 of file endpoint.c.

References NULL.

Referenced by _distributeBufferContent().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetDefaultMessageSize()

GWENHYWFAR_API int GWEN_MsgEndpoint_GetDefaultMessageSize ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 185 of file endpoint.c.

Referenced by _distributeBufferContent().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetFirstReceivedMessage()

GWENHYWFAR_API GWEN_MSG * GWEN_MsgEndpoint_GetFirstReceivedMessage ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 231 of file endpoint.c.

References GWEN_Msg_List_First(), and NULL.

Referenced by GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(), and GWEN_MsgEndpoint_TakeFirstReceivedMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetFirstSendMessage()

GWENHYWFAR_API GWEN_MSG * GWEN_MsgEndpoint_GetFirstSendMessage ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 260 of file endpoint.c.

References GWEN_Msg_List_First(), and NULL.

Referenced by _writeCurrentMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetFlags()

GWENHYWFAR_API uint32_t GWEN_MsgEndpoint_GetFlags ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 154 of file endpoint.c.

◆ GWEN_MsgEndpoint_GetGroupId()

GWENHYWFAR_API int GWEN_MsgEndpoint_GetGroupId ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 97 of file endpoint.c.

Referenced by _distributeBufferContent().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetName()

GWENHYWFAR_API const char * GWEN_MsgEndpoint_GetName ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 90 of file endpoint.c.

References NULL.

Referenced by _addSockets(), _addSockets(), _checkSockets(), _checkSockets(), _checkSockets(), _distributeBufferContent(), _readCurrentMessage(), _writeCurrentMessage(), GWEN_MsgEndpoint_ReadFromSocket(), GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(), GWEN_MsgEndpoint_SetState(), GWEN_MultilayerEndpoint_StartConnect(), GWEN_TcpcEndpoint_StartConnect(), and GWEN_TcpdEndpoint_StartListening().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetNextMessageId()

GWENHYWFAR_API uint32_t GWEN_MsgEndpoint_GetNextMessageId ( GWEN_MSG_ENDPOINT * ep )

Definition at line 200 of file endpoint.c.

◆ GWEN_MsgEndpoint_GetReceivedMessageList()

GWENHYWFAR_API GWEN_MSG_LIST * GWEN_MsgEndpoint_GetReceivedMessageList ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 207 of file endpoint.c.

References NULL.

Referenced by _checkSocketsWhenConnected().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetSendMessageList()

GWENHYWFAR_API GWEN_MSG_LIST * GWEN_MsgEndpoint_GetSendMessageList ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 214 of file endpoint.c.

References NULL.

Referenced by _addSocketsWhenConnected(), and _checkSocketsWhenConnected().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetSocket()

GWENHYWFAR_API GWEN_SOCKET * GWEN_MsgEndpoint_GetSocket ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 104 of file endpoint.c.

References NULL.

Referenced by _addSockets(), _addSockets(), _addSockets(), _checkSockets(), _checkSockets(), and _checkSockets().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetState()

GWENHYWFAR_API int GWEN_MsgEndpoint_GetState ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 124 of file endpoint.c.

References GWEN_MSG_ENDPOINT_STATE_UNCONNECTED.

Referenced by _addSockets(), _addSockets(), _addSockets(), _addSockets(), _addSocketsWhenConnected(), _addSocketsWhenConnecting(), _checkSockets(), _checkSockets(), _checkSockets(), GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(), GWEN_MultilayerEndpoint_StartConnect(), GWEN_TcpcEndpoint_StartConnect(), and GWEN_TcpdEndpoint_StartListening().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_GetTimeOfLastStateChange()

GWENHYWFAR_API time_t GWEN_MsgEndpoint_GetTimeOfLastStateChange ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 144 of file endpoint.c.

Referenced by _addSockets(), _addSocketsWhenConnecting(), and _checkForNeedToReconnect().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_HaveMessageToSend()

GWENHYWFAR_API int GWEN_MsgEndpoint_HaveMessageToSend ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 267 of file endpoint.c.

References GWEN_Msg_List_GetCount().

Referenced by _addSockets(), and _addSockets().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_IoLoop()

GWENHYWFAR_API void GWEN_MsgEndpoint_IoLoop	(	GWEN_MSG_ENDPOINT *	ep,
		int	timeout )

Does one IO loop which internally does this:

call GWEN_MsgEndpoint_AddSockets()
call GWEN_Socket_Select()
call GWEN_MsgEndpoint_CheckSockets() which handles reading and writing of messages

Parameters

ep	endpoint to handle
timeout	timeout in milliseconds for the GWEN_Socket_Select() call.

Definition at line 360 of file endpoint.c.

References DBG_INFO, GWEN_ERROR_INTERRUPTED, GWEN_ERROR_TIMEOUT, GWEN_LOGDOMAIN, GWEN_MsgEndpoint_AddSockets(), GWEN_MsgEndpoint_CheckSockets(), GWEN_Socket_Select(), GWEN_SocketSet_free(), GWEN_SocketSet_GetSocketCount(), GWEN_SocketSet_new(), and NULL.

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_new()

GWENHYWFAR_API GWEN_MSG_ENDPOINT * GWEN_MsgEndpoint_new	(	const char *	name,
		int	groupId )

Definition at line 31 of file endpoint.c.

References GWEN_INHERIT_INIT, GWEN_MSG_ENDPOINT_DEFAULT_MSGSIZE, GWEN_Msg_List_new(), GWEN_MsgEndpoint_new(), GWEN_NEW_OBJECT, and GWEN_TREE2_INIT.

Referenced by GWEN_IpcEndpoint_CreateIpcTcpServiceForSocket(), GWEN_MsgEndpoint_new(), GWEN_MultilayerEndpoint_new(), GWEN_TcpcEndpoint_new(), and GWEN_TcpdEndpoint_new().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_ReadFromSocket()

GWENHYWFAR_API int GWEN_MsgEndpoint_ReadFromSocket	(	GWEN_MSG_ENDPOINT *	ep,
		uint8_t *	bufferPtr,
		uint32_t	bufferLen )

Definition at line 424 of file endpoint.c.

References DBG_DEBUG, DBG_INFO, GWEN_ERROR_INTERRUPTED, GWEN_LOGDOMAIN, GWEN_MsgEndpoint_GetName(), and GWEN_Socket_Read().

Referenced by _readCurrentMessage(), and GWEN_MsgEndpoint_DiscardInput().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren()

GWENHYWFAR_API void GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren ( GWEN_MSG_ENDPOINT * ep )

Definition at line 337 of file endpoint.c.

References DBG_INFO, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MsgEndpoint_free(), GWEN_MsgEndpoint_GetFirstReceivedMessage(), GWEN_MsgEndpoint_GetName(), GWEN_MsgEndpoint_GetState(), and NULL.

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_SetAddSocketsFn()

GWENHYWFAR_API GWEN_MSG_ENDPOINT_ADDSOCKETS_FN GWEN_MsgEndpoint_SetAddSocketsFn	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_MSG_ENDPOINT_ADDSOCKETS_FN	fn )

Definition at line 504 of file endpoint.c.

References NULL.

Referenced by GWEN_MsgIoEndpoint_Extend(), GWEN_MultilayerEndpoint_new(), GWEN_TcpcEndpoint_new(), and GWEN_TcpdEndpoint_new().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_SetCheckSocketsFn()

GWENHYWFAR_API GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN GWEN_MsgEndpoint_SetCheckSocketsFn	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN	fn )

Definition at line 518 of file endpoint.c.

References NULL.

Referenced by _freeData(), GWEN_MsgIoEndpoint_Extend(), GWEN_MultilayerEndpoint_new(), GWEN_TcpcEndpoint_new(), and GWEN_TcpdEndpoint_new().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_SetCurrentlyReceivedMsg()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetCurrentlyReceivedMsg	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_MSG *	m )

Definition at line 281 of file endpoint.c.

Referenced by _distributeBufferContent().

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_SetDefaultMessageSize()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetDefaultMessageSize	(	GWEN_MSG_ENDPOINT *	ep,
		int	i )

Definition at line 192 of file endpoint.c.

◆ GWEN_MsgEndpoint_SetFlags()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetFlags	(	GWEN_MSG_ENDPOINT *	ep,
		uint32_t	f )

Definition at line 161 of file endpoint.c.

◆ GWEN_MsgEndpoint_SetSocket()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetSocket	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKET *	sk )

Definition at line 111 of file endpoint.c.

References GWEN_Socket_Close(), and GWEN_Socket_free().

Referenced by _startConnect(), _startListen(), and GWEN_IpcEndpoint_CreateIpcTcpServiceForSocket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_SetState()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetState	(	GWEN_MSG_ENDPOINT *	ep,
		int	m )

Definition at line 131 of file endpoint.c.

References DBG_INFO, GWEN_LOGDOMAIN, GWEN_MsgEndpoint_GetName(), and NULL.

Referenced by _addSockets(), _checkSockets(), _checkSockets(), GWEN_MsgEndpoint_Disconnect(), GWEN_MultilayerEndpoint_StartConnect(), GWEN_TcpcEndpoint_new(), GWEN_TcpcEndpoint_StartConnect(), GWEN_TcpdEndpoint_new(), and GWEN_TcpdEndpoint_StartListening().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_MsgEndpoint_TakeFirstReceivedMessage()

GWENHYWFAR_API GWEN_MSG * GWEN_MsgEndpoint_TakeFirstReceivedMessage ( GWEN_MSG_ENDPOINT * ep )

Definition at line 238 of file endpoint.c.

References GWEN_Msg_List_Del(), and GWEN_MsgEndpoint_GetFirstReceivedMessage().

Here is the call graph for this function:

◆ GWEN_MsgEndpoint_WriteToSocket()

GWENHYWFAR_API int GWEN_MsgEndpoint_WriteToSocket	(	GWEN_MSG_ENDPOINT *	ep,
		const uint8_t *	bufferPtr,
		uint32_t	bufferLen )

Definition at line 444 of file endpoint.c.

References GWEN_ERROR_INTERRUPTED, and GWEN_Socket_Write().

Referenced by _writeCurrentMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

Macros

Typedefs

Functions

Macro Definition Documentation

◆ GWEN_MSG_ENDPOINT_FLAGS_DELETE

◆ GWEN_MSG_ENDPOINT_FLAGS_NOIO

◆ GWEN_MSG_ENDPOINT_STATE_CONNECTED

◆ GWEN_MSG_ENDPOINT_STATE_CONNECTING

◆ GWEN_MSG_ENDPOINT_STATE_UNCONNECTED

Typedef Documentation

◆ GWEN_MSG_ENDPOINT

◆ GWEN_MSG_ENDPOINT_ADDSOCKETS_FN

◆ GWEN_MSG_ENDPOINT_CHECKSOCKETS_FN

Function Documentation

◆ GWEN_MsgEndpoint_AddFlags()

◆ GWEN_MsgEndpoint_AddReceivedMessage()

◆ GWEN_MsgEndpoint_AddSendMessage()

◆ GWEN_MsgEndpoint_AddSockets()

◆ GWEN_MsgEndpoint_Attach()

◆ GWEN_MsgEndpoint_CheckSockets()

◆ GWEN_MsgEndpoint_ChildrenAddSockets()

◆ GWEN_MsgEndpoint_ChildrenCheckSockets()

◆ GWEN_MsgEndpoint_ChildrenIoLoop()

◆ GWEN_MsgEndpoint_DelFlags()

◆ GWEN_MsgEndpoint_DiscardInput()

◆ GWEN_MsgEndpoint_Disconnect()

◆ GWEN_MsgEndpoint_free()

◆ GWEN_MsgEndpoint_GetCurrentlyReceivedMsg()

◆ GWEN_MsgEndpoint_GetDefaultMessageSize()

◆ GWEN_MsgEndpoint_GetFirstReceivedMessage()

◆ GWEN_MsgEndpoint_GetFirstSendMessage()

◆ GWEN_MsgEndpoint_GetFlags()

◆ GWEN_MsgEndpoint_GetGroupId()

◆ GWEN_MsgEndpoint_GetName()

◆ GWEN_MsgEndpoint_GetNextMessageId()

◆ GWEN_MsgEndpoint_GetReceivedMessageList()

◆ GWEN_MsgEndpoint_GetSendMessageList()

◆ GWEN_MsgEndpoint_GetSocket()

◆ GWEN_MsgEndpoint_GetState()

◆ GWEN_MsgEndpoint_GetTimeOfLastStateChange()

◆ GWEN_MsgEndpoint_HaveMessageToSend()

◆ GWEN_MsgEndpoint_IoLoop()

◆ GWEN_MsgEndpoint_new()

◆ GWEN_MsgEndpoint_ReadFromSocket()

◆ GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren()

◆ GWEN_MsgEndpoint_SetAddSocketsFn()

◆ GWEN_MsgEndpoint_SetCheckSocketsFn()

◆ GWEN_MsgEndpoint_SetCurrentlyReceivedMsg()

◆ GWEN_MsgEndpoint_SetDefaultMessageSize()

◆ GWEN_MsgEndpoint_SetFlags()

◆ GWEN_MsgEndpoint_SetSocket()

◆ GWEN_MsgEndpoint_SetState()

◆ GWEN_MsgEndpoint_TakeFirstReceivedMessage()

◆ GWEN_MsgEndpoint_WriteToSocket()