#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_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 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 155 of file endpoint.c.

◆ GWEN_MsgEndpoint_AddReceivedMessage()

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

Definition at line 200 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 229 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 268 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_CheckSockets()

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

Definition at line 276 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 284 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 300 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 371 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 163 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 439 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 462 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 52 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().

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 253 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 171 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 210 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 239 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 140 of file endpoint.c.

◆ GWEN_MsgEndpoint_GetGroupId()

GWENHYWFAR_API int GWEN_MsgEndpoint_GetGroupId ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 83 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 76 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_GetReceivedMessageList()

GWENHYWFAR_API GWEN_MSG_LIST * GWEN_MsgEndpoint_GetReceivedMessageList ( const GWEN_MSG_ENDPOINT * ep )

Definition at line 186 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 193 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 90 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 110 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 130 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 246 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 339 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_NEW_OBJECT, and GWEN_TREE2_INIT.

Referenced by GWEN_IpcEndpoint_CreateIpcTcpServiceForSocket(), 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 403 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 316 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 483 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 497 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 260 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 178 of file endpoint.c.

◆ GWEN_MsgEndpoint_SetFlags()

GWENHYWFAR_API void GWEN_MsgEndpoint_SetFlags	(	GWEN_MSG_ENDPOINT *	ep,
		uint32_t	f )

Definition at line 147 of file endpoint.c.

◆ GWEN_MsgEndpoint_SetSocket()

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

Definition at line 97 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 117 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 217 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 423 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_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_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()