PPL Logo

util/sockRoutines.c File Reference

Go to the source code of this file.

Typedefs

typedef int socklen_t
typedef void(* skt_signal_handler_fn )(int sig)

Functions

static int default_skt_abort (int code, const char *msg)
void skt_set_idle (skt_idleFn f)
skt_abortFn skt_set_abort (skt_abortFn f)
static void doCleanup (void)
void skt_init (void)
void skt_close (SOCKET fd)
static void skt_SIGPIPE_handler (int sig)
void skt_buffer_begin (SOCKET sk)
void skt_buffer_end (SOCKET sk)
static int skt_should_retry (void)
int skt_tcp_no_nagle (SOCKET fd)
int skt_select1 (SOCKET fd, int msec)
skt_ip_t skt_my_ip (void)
static int skt_parse_dotted (const char *str, skt_ip_t *ret)
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_setSockBuf (SOCKET skt, int bufsize)
int skt_recvN (SOCKET hSocket, void *buff, int nBytes)
int skt_sendN (SOCKET hSocket, const void *buff, int nBytes)
int skt_sendV (SOCKET fd, int nBuffers, const void **bufs, int *lens)
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

static skt_idleFn idleFunc = NULL
static skt_abortFn skt_abort = default_skt_abort
static int skt_ignore_SIGPIPE = 0
static int skt_inited = 0
static skt_signal_handler_fn skt_fallback_SIGPIPE = NULL
static int ERRNO = -1
skt_ip_t _skt_invalid_ip = {{0}}

Typedef Documentation

typedef int socklen_t

Definition at line 29 of file sockRoutines.c.

typedef void(* skt_signal_handler_fn)(int sig)

Definition at line 82 of file sockRoutines.c.

Function Documentation

static int default_skt_abort ( int  code,
const char *  msg 
) [static]

Definition at line 39 of file sockRoutines.c.

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

static void doCleanup ( void   )  [static]

Definition at line 62 of file sockRoutines.c.

Referenced by skt_init().

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

static void skt_SIGPIPE_handler ( int  sig  )  [static]

Definition at line 84 of file sockRoutines.c.

References skt_fallback_SIGPIPE.

void skt_buffer_begin ( SOCKET  sk  ) 

Definition at line 110 of file sockRoutines.c.

void skt_buffer_end ( SOCKET  sk  ) 

Definition at line 111 of file sockRoutines.c.

static int skt_should_retry ( void   )  [static]

Definition at line 122 of file sockRoutines.c.

References errno, idleFunc, and sleep().

Referenced by skt_accept(), skt_connect(), skt_datagram(), skt_recvN(), skt_select1(), skt_sendN(), and skt_server_ip().

int skt_tcp_no_nagle ( SOCKET  fd  ) 

Definition at line 161 of file sockRoutines.c.

Referenced by arg_init(), and KillOnAllSigs().

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

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 int skt_parse_dotted ( const char *  str,
skt_ip_t *  ret 
) [static]

Definition at line 268 of file sockRoutines.c.

References skt_ip_t::data.

Referenced by skt_lookup_ip().

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_setSockBuf ( SOCKET  skt,
int  bufsize 
)

Definition at line 482 of file sockRoutines.c.

References skt_abort.

int skt_recvN ( SOCKET  hSocket,
void *  buff,
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_sendN ( SOCKET  hSocket,
const void *  buff,
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_sendV ( SOCKET  fd,
int  nBuffers,
const void **  bufs,
int *  lens 
)

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

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_idleFn idleFunc = NULL [static]

Definition at line 46 of file sockRoutines.c.

Referenced by skt_set_idle(), and skt_should_retry().

skt_abortFn skt_abort = default_skt_abort [static]

Definition at line 47 of file sockRoutines.c.

Referenced by skt_accept(), skt_connect(), skt_datagram(), skt_recvN(), skt_select1(), skt_sendN(), skt_server_ip(), skt_set_abort(), and skt_setSockBuf().

int skt_ignore_SIGPIPE = 0 [static]

Definition at line 59 of file sockRoutines.c.

int skt_inited = 0 [static]

Definition at line 64 of file sockRoutines.c.

skt_signal_handler_fn skt_fallback_SIGPIPE = NULL [static]

Definition at line 83 of file sockRoutines.c.

Referenced by skt_SIGPIPE_handler().

int ERRNO = -1 [static]

Definition at line 115 of file sockRoutines.c.

skt_ip_t _skt_invalid_ip = {{0}}

Definition at line 234 of file sockRoutines.c.

Referenced by arg_init(), and KillOnAllSigs().

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