gwenhywfar: endpoint_tcpc.c File Reference

gwenhywfar 5.14.1

#include "./endpoint_tcpc_p.h"
#include <gwenhywfar/debug.h>

Include dependency graph for endpoint_tcpc.c:

Go to the source code of this file.

Macros
#define	GWEN_ENDPOINT_TCPC_RECONNECT_TIME 5

#define	GWEN_MSG_ENDPOINT_TCPC_NAME "tcpclient"

Functions
static void	_addSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)

void	_addSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_UNUSED GWEN_SOCKETSET xSet)

static void	_checkSockets (GWEN_MSG_ENDPOINT ep, GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_SOCKETSET xSet)

void	_checkSockets (GWEN_MSG_ENDPOINT ep, GWEN_UNUSED GWEN_SOCKETSET readSet, GWEN_SOCKETSET writeSet, GWEN_UNUSED GWEN_SOCKETSET xSet)

static GWEN_INETADDRESS *	_createAndSetupAddress (const char *host, int port)

static GWEN_SOCKET *	_createAndSetupSocket (void)

static void GWENHYWFAR_CB	_freeData (void bp, void p)

void GWENHYWFAR_CB	_freeData (GWEN_UNUSED void bp, void p)

static int	_startConnect (GWEN_MSG_ENDPOINT *ep)

GWEN_MSG_ENDPOINT *	GWEN_TcpcEndpoint_new (const char host, int port, const char name, int groupId)

int	GWEN_TcpcEndpoint_StartConnect (GWEN_MSG_ENDPOINT *ep)

Macro Definition Documentation

◆ GWEN_ENDPOINT_TCPC_RECONNECT_TIME

#define GWEN_ENDPOINT_TCPC_RECONNECT_TIME 5

Definition at line 23 of file endpoint_tcpc.c.

Referenced by _addSockets().

◆ GWEN_MSG_ENDPOINT_TCPC_NAME

#define GWEN_MSG_ENDPOINT_TCPC_NAME "tcpclient"

Definition at line 22 of file endpoint_tcpc.c.

Referenced by GWEN_TcpcEndpoint_new().

Function Documentation

◆ _addSockets() [1/2]

static void _addSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet
	)

static

Definition at line 246 of file endpoint_multilayer.c.

References _addSocketsWhenConnected(), _addSocketsWhenConnecting(), _checkForNeedToReconnect(), DBG_ERROR, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_CONNECTED, GWEN_MSG_ENDPOINT_STATE_CONNECTING, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MsgEndpoint_Disconnect(), and GWEN_MsgEndpoint_GetState().

Referenced by GWEN_TcpcEndpoint_new().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _addSockets() [2/2]

void _addSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_UNUSED GWEN_SOCKETSET *	xSet
	)

Definition at line 120 of file endpoint_tcpc.c.

References DBG_INFO, GWEN_ENDPOINT_TCPC_RECONNECT_TIME, GWEN_ERROR_IN_PROGRESS, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_CONNECTED, GWEN_MSG_ENDPOINT_STATE_CONNECTING, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MsgEndpoint_GetSocket(), GWEN_MsgEndpoint_GetState(), GWEN_MsgEndpoint_GetTimeOfLastStateChange(), GWEN_MsgEndpoint_HaveMessageToSend(), GWEN_SocketSet_AddSocket(), GWEN_TcpcEndpoint_StartConnect(), and NULL.

Referenced by GWEN_MultilayerEndpoint_new().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _checkSockets() [1/2]

static void _checkSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_SOCKETSET *	xSet
	)

static

Referenced by GWEN_TcpcEndpoint_new().

Here is the caller graph for this function:

◆ _checkSockets() [2/2]

void _checkSockets	(	GWEN_MSG_ENDPOINT *	ep,
		GWEN_UNUSED GWEN_SOCKETSET *	readSet,
		GWEN_SOCKETSET *	writeSet,
		GWEN_UNUSED GWEN_SOCKETSET *	xSet
	)

Definition at line 153 of file endpoint_tcpc.c.

References DBG_DEBUG, DBG_INFO, GWEN_ERROR_IN_PROGRESS, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_CONNECTED, GWEN_MSG_ENDPOINT_STATE_CONNECTING, GWEN_MsgEndpoint_GetName(), GWEN_MsgEndpoint_GetSocket(), GWEN_MsgEndpoint_GetState(), GWEN_MsgEndpoint_SetState(), GWEN_Socket_GetSocketError(), and GWEN_SocketSet_HasSocket().

Here is the call graph for this function:

◆ _createAndSetupAddress()

GWEN_INETADDRESS * _createAndSetupAddress	(	const char *	host,
		int	port
	)

static

Definition at line 256 of file endpoint_tcpc.c.

References DBG_INFO, GWEN_AddressFamilyIP, GWEN_InetAddr_free(), GWEN_InetAddr_new(), GWEN_InetAddr_SetAddress(), GWEN_InetAddr_SetName(), GWEN_InetAddr_SetPort(), GWEN_LOGDOMAIN, and NULL.

Referenced by _startConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _createAndSetupSocket()

GWEN_SOCKET * _createAndSetupSocket ( void )

static

Definition at line 231 of file endpoint_tcpc.c.

References DBG_INFO, GWEN_LOGDOMAIN, GWEN_Socket_free(), GWEN_Socket_new(), GWEN_Socket_Open(), GWEN_Socket_SetBlocking(), GWEN_SocketTypeTCP, and NULL.

Referenced by _startConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _freeData() [1/2]

static void GWENHYWFAR_CB _freeData	(	void *	bp,
		void *	p
	)

static

Referenced by GWEN_TcpcEndpoint_new().

Here is the caller graph for this function:

◆ _freeData() [2/2]

void GWENHYWFAR_CB _freeData	(	GWEN_UNUSED void *	bp,
		void *	p
	)

Definition at line 109 of file endpoint_tcpc.c.

References GWEN_FREE_OBJECT.

◆ _startConnect()

int _startConnect ( GWEN_MSG_ENDPOINT * ep )

static

Definition at line 189 of file endpoint_tcpc.c.

References _createAndSetupAddress(), _createAndSetupSocket(), DBG_INFO, GWEN_ERROR_GENERIC, GWEN_ERROR_IN_PROGRESS, GWEN_InetAddr_free(), GWEN_INHERIT_GETDATA, GWEN_LOGDOMAIN, GWEN_MsgEndpoint_SetSocket(), GWEN_Socket_Connect(), GWEN_Socket_free(), and NULL.

Referenced by GWEN_TcpcEndpoint_StartConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_TcpcEndpoint_new()

GWEN_MSG_ENDPOINT* GWEN_TcpcEndpoint_new	(	const char *	host,
		int	port,
		const char *	name,
		int	groupId
	)

Definition at line 54 of file endpoint_tcpc.c.

References _addSockets(), _checkSockets(), _freeData(), GWEN_INHERIT_SETDATA, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MSG_ENDPOINT_TCPC_NAME, GWEN_MsgEndpoint_new(), GWEN_MsgEndpoint_SetAddSocketsFn(), GWEN_MsgEndpoint_SetCheckSocketsFn(), GWEN_MsgEndpoint_SetState(), GWEN_NEW_OBJECT, and NULL.

Referenced by GWEN_IpcEndpoint_CreateIpcTcpClient().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GWEN_TcpcEndpoint_StartConnect()

int GWEN_TcpcEndpoint_StartConnect ( GWEN_MSG_ENDPOINT * ep )

Definition at line 75 of file endpoint_tcpc.c.

References _startConnect(), DBG_ERROR, DBG_INFO, GWEN_ERROR_GENERIC, GWEN_ERROR_IN_PROGRESS, GWEN_LOGDOMAIN, GWEN_MSG_ENDPOINT_STATE_CONNECTED, GWEN_MSG_ENDPOINT_STATE_CONNECTING, GWEN_MSG_ENDPOINT_STATE_UNCONNECTED, GWEN_MsgEndpoint_GetName(), GWEN_MsgEndpoint_GetState(), and GWEN_MsgEndpoint_SetState().

Referenced by _addSockets().

Here is the call graph for this function:

Here is the caller graph for this function: