dox/irods-4.2.8/sockComm_8h_source.html

/* sockComm.h - header file for sockComm.c

 */


#ifndef SOCK_COMM_H__

#define SOCK_COMM_H__


// =-=-=-=-=-=-=

// irods includes

#include "rodsDef.h"

#include "rcConnect.h"

#include "rodsPackInstruct.h"


#define MAX_LISTEN_QUE  50

#define DEF_NUMBER_SVR_PORT     200     /* default number of of server ports */

#define CONNECT_TIMEOUT_TIME    100     /* connection timeout time in sec */

#define RECONNECT_WAIT_TIME  100        /* re-connection timeout time in sec */

#define RECONNECT_SLEEP_TIME  300               /* re-connection sleep time in sec */

#define MAX_RECONN_RETRY_CNT 4          /* max connect retry count */

#define MAX_CONN_RETRY_CNT 3    /* max connect retry count */

#define CONNECT_SLEEP_TIME 200000      /* connect sleep time in uSec */


#define READ_STARTUP_PACK_TOUT_SEC      100     /* 1 sec timeout */

#define READ_VERSION_TOUT_SEC           100     /* 10 sec timeout */


#define RECONNECT_ENV "irodsReconnect"          /* reconnFlag will be set to

* RECONN_TIMEOUT if this

* env is set */


/* definition for socket close function */

#define READING_FROM_CLI        0

#define PROCESSING_API          1


#ifdef _WIN32

#define CLOSE_SOCK       closesocket

#else

#define CLOSE_SOCK       close

#endif


#ifdef __cplusplus

extern "C" {

#endif


// =-=-=-=-=-=-=-

// other legacy functions

int sockOpenForInConn( rsComm_t *rsComm, int *portNum, char **addr, int proto );

int rodsSetSockOpt( int sock, int tcp_buffer_size );

int connectToRhost( rcComm_t *conn, int connectCnt, int reconnFlag );

int connectToRhostWithRaddr( struct sockaddr_in *remoteAddr, int windowSize,

                             int timeoutFlag );

int connectToRhostWithTout( struct sockaddr *sin );

int rodsSleep( int sec, int microSec );

int setConnAddr( rcComm_t *conn );

int setRemoteAddr( int sock, struct sockaddr_in *remoteAddr );

int setLocalAddr( int sock, struct sockaddr_in *localAddr );

int sendStartupPack( rcComm_t *conn, int connectCnt, int reconnFlag );

int connectToRhostPortal( char *rodsHost, int rodsPort, int cookie, int windowSize );

int rsAcceptConn( rsComm_t *svrComm );

int irodsCloseSock( int sock );

int addUdpPortToPortList( portList_t *thisPortList, int udpport );

int getUdpPortFromPortList( portList_t *thisPortList );

int getTcpPortFromPortList( portList_t *thisPortList );

int addUdpSockToPortList( portList_t *thisPortList, int udpsock );

int getUdpSockFromPortList( portList_t *thisPortList );

int getTcpSockFromPortList( portList_t *thisPortList );

int isReadMsgError( int status );

int svrSwitchConnect( rsComm_t *rsComm );

int cliSwitchConnect( rcComm_t *conn );

int redirectConnToRescSvr( rcComm_t **conn, dataObjInp_t *dataObjInp, rodsEnv *myEnv, int reconnFlag );

int rcReconnect( rcComm_t **conn, char *newHost, rodsEnv *myEnv, int reconnFlag );

int mySockClose( int sock ); // server stop fcn <==> rsAccept?

#ifdef __cplusplus

}

#endif


#endif  /* SOCK_COMM_H__ */