endpoint_tcpc.c File Reference

#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)
void GWENHYWFAR_CB	_freeData (GWEN_UNUSED void *bp, void *p)
static void GWENHYWFAR_CB	_freeData (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]

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().

Here is the call 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(), GWEN_UNUSED, and NULL.

Here is the call graph for this function:

_checkSockets() [1/2]

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

static

_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(), GWEN_SocketSet_HasSocket(), and GWEN_UNUSED.

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]

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

Definition at line 109 of file endpoint_tcpc.c.

References GWEN_FREE_OBJECT, GWEN_UNUSED, and GWENHYWFAR_CB.

_freeData() [2/2]

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

static

References GWENHYWFAR_CB.

_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, GWEN_TcpcEndpoint_new(), and NULL.

Referenced by GWEN_IpcEndpoint_CreateIpcTcpClient(), and GWEN_TcpcEndpoint_new().

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: