PPL Logo

util/sockRoutines.h File Reference

Go to the source code of this file.

Data Structures

struct  skt_ip_t
struct  skt_ip_t
struct  ChMessageInt_t
struct  ChMessageLong_t
struct  ChMessageHeader
struct  ChMessage
struct  ChInfiAddr
struct  ChNodeinfo
struct  ChSingleNodeinfo
struct  CcsMessageHeader

Typedefs

typedef void(* skt_idleFn )(void)
typedef int(* skt_abortFn )(int errCode, const char *msg)

Functions

skt_ip_t skt_my_ip (void)
static void sleep (int secs)
void skt_init (void)
void skt_set_idle (skt_idleFn f)
skt_abortFn skt_set_abort (skt_abortFn f)
skt_ip_t skt_lookup_ip (const char *name)
skt_ip_t skt_innode_my_ip (void)
skt_ip_t skt_innode_lookup_ip (const char *name)
char * skt_print_ip (char *dest, skt_ip_t addr)
int skt_ip_match (skt_ip_t a, skt_ip_t b)
struct sockaddr_in skt_build_addr (skt_ip_t IP, int port)
SOCKET skt_datagram (unsigned int *port, int bufsize)
SOCKET skt_server (unsigned int *port)
SOCKET skt_server_ip (unsigned int *port, skt_ip_t *ip)
SOCKET skt_accept (SOCKET src_fd, skt_ip_t *pip, unsigned int *port)
SOCKET skt_connect (skt_ip_t ip, int port, int timeout)
void skt_close (SOCKET fd)
int skt_select1 (SOCKET fd, int msec)
void skt_setSockBuf (SOCKET skt, int bufsize)
int skt_sendN (SOCKET hSocket, const void *pBuff, int nBytes)
int skt_recvN (SOCKET hSocket, void *pBuff, int nBytes)
int skt_sendV (SOCKET fd, int nBuffers, const void **buffers, int *lengths)
int skt_tcp_no_nagle (SOCKET fd)
ChMessageInt_t ChMessageInt_new (unsigned int src)
unsigned int ChMessageInt (ChMessageInt_t src)
ChMessageLong_t ChMessageLong_new (CMK_TYPEDEF_UINT8 src)
CMK_TYPEDEF_UINT8 ChMessageLong (ChMessageLong_t src)
int ChMessage_recv (SOCKET fd, ChMessage *dst)
int ChMessageHeader_recv (SOCKET fd, ChMessage *dst)
int ChMessageData_recv (SOCKET fd, ChMessage *dst)
void ChMessage_free (ChMessage *doomed)
void ChMessageHeader_new (const char *type, int len, ChMessageHeader *dst)
void ChMessage_new (const char *type, int len, ChMessage *dst)
int ChMessage_send (SOCKET fd, const ChMessage *src)

Variables

skt_ip_t _skt_invalid_ip

Typedef Documentation

typedef void(* skt_idleFn)(void)

Definition at line 147 of file sockRoutines.h.

typedef int(* skt_abortFn)(int errCode, const char *msg)

Definition at line 148 of file sockRoutines.h.

Function Documentation

skt_ip_t skt_my_ip ( void   ) 

Definition at line 236 of file sockRoutines.c.

References skt_lookup_ip().

Referenced by CcsServer_new(), CmiInitCPUAffinity(), getenv_display(), LrtsInitCpuTopo(), and skt_innode_my_ip().

static void sleep ( int  secs  )  [static]

Definition at line 117 of file sockRoutines.h.

Referenced by _recvRestartCheckpointHandler(), _updateHomeAckHandler(), ADIOI_NFS_aio(), ADIOI_UFS_aio(), ADIOI_XFS_aio(), arg_init(), CmiAmmassoOpenQueuePairs(), CmiNodeBarrierCount(), CmiYield(), driver(), goFaceless(), KillOnAllSigs(), sendAck(), SendMsgBuf(), and skt_should_retry().

void skt_init ( void   ) 

Definition at line 66 of file sockRoutines.c.

References doCleanup().

Referenced by arg_init(), CcsConnectIpWithTimeout(), CcsConnectWithTimeout(), CcsServer_new(), KillOnAllSigs(), and main().

void skt_set_idle ( skt_idleFn  f  ) 

Definition at line 48 of file sockRoutines.c.

References idleFunc.

Referenced by arg_init(), and KillOnAllSigs().

skt_abortFn skt_set_abort ( skt_abortFn  f  ) 

Definition at line 49 of file sockRoutines.c.

References skt_abort.

Referenced by arg_init(), CcsImpl_kill(), CcsServer_recvRequest(), CcsServer_sendReply(), KillOnAllSigs(), and main().

skt_ip_t skt_lookup_ip ( const char *  name  ) 

Definition at line 288 of file sockRoutines.c.

References skt_parse_dotted().

Referenced by arg_init(), CcsConnectWithTimeout(), KillOnAllSigs(), ping_developers(), skt_innode_lookup_ip(), and skt_my_ip().

skt_ip_t skt_innode_my_ip ( void   ) 

Definition at line 305 of file sockRoutines.c.

References skt_innode_lookup_ip(), and skt_my_ip().

Referenced by arg_init(), KillOnAllSigs(), and LrtsInitCpuTopo().

skt_ip_t skt_innode_lookup_ip ( const char *  name  ) 

Definition at line 317 of file sockRoutines.c.

References skt_lookup_ip().

Referenced by arg_init(), and skt_innode_my_ip().

char* skt_print_ip ( char *  dest,
skt_ip_t  addr 
)

Definition at line 336 of file sockRoutines.c.

References skt_ip_t::data.

Referenced by arg_init(), CcsServer_new(), CcsServer_recvRequest(), CmiMXMakeConnection(), getenv_display(), main(), and printSvr().

int skt_ip_match ( skt_ip_t  a,
skt_ip_t  b 
)

Definition at line 348 of file sockRoutines.c.

Referenced by arg_init(), and KillOnAllSigs().

struct sockaddr_in skt_build_addr ( skt_ip_t  IP,
int  port 
) [read]

Definition at line 352 of file sockRoutines.c.

Referenced by node_addresses_store(), ping_developers(), skt_connect(), skt_datagram(), and skt_server_ip().

SOCKET skt_datagram ( unsigned int *  port,
int  bufsize 
)

Definition at line 361 of file sockRoutines.c.

References skt_abort, skt_build_addr(), and skt_should_retry().

Referenced by KillOnAllSigs().

SOCKET skt_server ( unsigned int *  port  ) 

Definition at line 393 of file sockRoutines.c.

References skt_server_ip().

Referenced by arg_init(), CcsServer_new(), KillOnAllSigs(), and main().

SOCKET skt_server_ip ( unsigned int *  port,
skt_ip_t *  ip 
)

Definition at line 398 of file sockRoutines.c.

References skt_abort, skt_build_addr(), and skt_should_retry().

Referenced by skt_server().

SOCKET skt_accept ( SOCKET  src_fd,
skt_ip_t *  pip,
unsigned int *  port 
)

Definition at line 428 of file sockRoutines.c.

References skt_abort, and skt_should_retry().

Referenced by arg_init(), CcsServer_recvRequest(), and main().

SOCKET skt_connect ( skt_ip_t  ip,
int  port,
int  timeout 
)

Definition at line 447 of file sockRoutines.c.

References skt_abort, skt_build_addr(), skt_close(), skt_should_retry(), and stats::time().

Referenced by arg_init(), CcsConnectIpWithTimeout(), CcsImpl_kill(), CcsSendRequestGeneric(), and KillOnAllSigs().

void skt_close ( SOCKET  fd  ) 

Definition at line 76 of file sockRoutines.c.

Referenced by arg_init(), CcsConnectIpWithTimeout(), CcsFinalize(), CcsImpl_kill(), CcsNoResponse(), CcsRecvResponse(), CcsRecvResponseMsg(), CcsSendRequestGeneric(), CcsServer_recvRequest(), CcsServer_sendReply(), CcsServer_writeReply(), main(), ping_developers(), and skt_connect().

int skt_select1 ( SOCKET  fd,
int  msec 
)

Definition at line 170 of file sockRoutines.c.

References skt_abort, skt_should_retry(), and stats::time().

Referenced by arg_init(), CcsProbe(), CcsProbeTimeout(), CcsRecvResponse(), CcsRecvResponseMsg(), CcsServerCheck(), KillOnAllSigs(), and skt_recvN().

void skt_setSockBuf ( SOCKET  skt,
int  bufsize 
)

Definition at line 482 of file sockRoutines.c.

References skt_abort.

int skt_sendN ( SOCKET  hSocket,
const void *  pBuff,
int  nBytes 
)

Definition at line 519 of file sockRoutines.c.

References skt_abort, and skt_should_retry().

Referenced by arg_init(), CcsImpl_authInit(), CcsImpl_kill(), CcsServer_createSalt(), main(), and skt_sendV().

int skt_recvN ( SOCKET  hSocket,
void *  pBuff,
int  nBytes 
)

Definition at line 491 of file sockRoutines.c.

References skt_abort, skt_select1(), and skt_should_retry().

Referenced by arg_init(), CcsImpl_authInit(), CcsImpl_recvReplyAuth(), CcsRecvResponse(), CcsRecvResponseMsg(), CcsServer_createSalt(), CcsServer_readHeader(), CcsServer_recvRequestData(), CcsServer_SHA1_message(), ChMessageData_recv(), ChMessageHeader_recv(), and main().

int skt_sendV ( SOCKET  fd,
int  nBuffers,
const void **  buffers,
int *  lengths 
)

Definition at line 550 of file sockRoutines.c.

References CmiTmpAlloc(), CmiTmpFree(), dest, and skt_sendN().

Referenced by arg_init(), CcsSendRequestGeneric(), CcsServer_writeReply(), ChMessage_send(), and KillOnAllSigs().

int skt_tcp_no_nagle ( SOCKET  fd  ) 

Definition at line 161 of file sockRoutines.c.

Referenced by arg_init(), and KillOnAllSigs().

ChMessageInt_t ChMessageInt_new ( unsigned int  src  ) 

Definition at line 608 of file sockRoutines.c.

References ChMessageInt_t::data.

Referenced by arg_init(), CCS_AUTH_hash(), ccs_getinfo(), CcsImpl_authInit(), CcsImpl_reply(), CcsMerge_concat(), CcsNoDelayedReply(), CcsNoReply(), CcsReply(), CcsSendDelayedReply(), CcsSendReply(), CcsSendRequestGeneric(), CcsServer_createSalt(), CcsServer_readHeader(), CcsServer_recvRequest(), CcsServer_recvRequestData(), CcsServer_writeReply(), check_stdio_header(), ChMessageHeader_new(), copyInfiAddr(), CpdDebugHandlerStatus(), CpdList_ccs_list_len(), and KillOnAllSigs().

unsigned int ChMessageInt ( ChMessageInt_t  src  ) 

Definition at line 614 of file sockRoutines.c.

References ChMessageInt_t::data.

Referenced by arg_init(), bg_req_fw_handler(), ccs_killport(), CcsCallerId(), CcsDelayReply(), CcsHandleRequest(), CcsImpl_authInit(), CcsImpl_ccs2converse(), CcsImpl_netRequest(), CcsMerge_concat(), CcsRecvResponse(), CcsRecvResponseMsg(), CcsReply(), CcsServer_createSalt(), CcsServer_recvRequestData(), CcsServer_sendReply(), CcsServer_SHA1_message(), CcsServer_writeReply(), ChMessageHeader_recv(), CpdListHeader_ccs_list_items(), CpdListLookup(), crash_node_handle(), main(), node_addresses_store(), parseInfo(), rep_fw_handler(), and req_fw_handler().

ChMessageLong_t ChMessageLong_new ( CMK_TYPEDEF_UINT8  src  ) 

Definition at line 621 of file sockRoutines.c.

References ChMessageLong_t::data.

Referenced by KillOnAllSigs().

CMK_TYPEDEF_UINT8 ChMessageLong ( ChMessageLong_t  src  ) 

Definition at line 627 of file sockRoutines.c.

References ChMessageLong_t::data.

Referenced by node_addresses_store().

int ChMessage_recv ( SOCKET  fd,
ChMessage *  dst 
)

Definition at line 634 of file sockRoutines.c.

References ChMessageData_recv(), and ChMessageHeader_recv().

Referenced by arg_init(), and KillOnAllSigs().

int ChMessageHeader_recv ( SOCKET  fd,
ChMessage *  dst 
)

Definition at line 642 of file sockRoutines.c.

References ChMessageInt(), ChMessage::data, ChMessage::header, ChMessageHeader::len, ChMessage::len, and skt_recvN().

Referenced by arg_init(), and ChMessage_recv().

int ChMessageData_recv ( SOCKET  fd,
ChMessage *  dst 
)

Definition at line 651 of file sockRoutines.c.

References ChMessage::data, ChMessage::len, malloc(), and skt_recvN().

Referenced by arg_init(), and ChMessage_recv().

void ChMessage_free ( ChMessage *  doomed  ) 

Definition at line 659 of file sockRoutines.c.

References ChMessage::data, free(), ChMessage::header, ChMessage::len, and ChMessageHeader::type.

Referenced by arg_init(), and KillOnAllSigs().

void ChMessageHeader_new ( const char *  type,
int  len,
ChMessageHeader *  dst 
)

Definition at line 666 of file sockRoutines.c.

References ChMessageInt_new(), ChMessageHeader::len, and ChMessageHeader::type.

Referenced by arg_init(), ChMessage_new(), and KillOnAllSigs().

void ChMessage_new ( const char *  type,
int  len,
ChMessage *  dst 
)

Definition at line 672 of file sockRoutines.c.

References ChMessageHeader_new(), ChMessage::data, ChMessage::header, ChMessage::len, and malloc().

Referenced by KillOnAllSigs().

int ChMessage_send ( SOCKET  fd,
const ChMessage *  src 
)

Definition at line 678 of file sockRoutines.c.

References ChMessage::data, ChMessage::header, ChMessage::len, and skt_sendV().

Variable Documentation

skt_ip_t _skt_invalid_ip

Definition at line 156 of file sockRoutines.h.

Referenced by arg_init(), and KillOnAllSigs().

Generated on Sat May 26 08:08:11 2012 for Charm++ by  doxygen 1.5.5