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_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) |
| 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 |
| skt_ip_t | _skt_invalid_ip = {{0}} |
| skt_ip_t | _skt_invalid_ip = {{0}} |
Definition at line 33 of file sockRoutines.c.
| typedef void(*) skt_signal_handler_fn(int sig) |
Definition at line 80 of file sockRoutines.c.
Definition at line 37 of file sockRoutines.c.
| void skt_set_idle | ( | skt_idleFn | f | ) |
Definition at line 46 of file sockRoutines.c.
References idleFunc.
Referenced by arg_init(), and KillOnAllSigs().
| skt_abortFn skt_set_abort | ( | skt_abortFn | f | ) |
Definition at line 47 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] |
| void skt_init | ( | void | ) |
Definition at line 64 of file sockRoutines.c.
References doCleanup(), and skt_inited.
Referenced by arg_init(), CcsConnectIpWithTimeout(), CcsConnectWithTimeout(), CcsServer_new(), KillOnAllSigs(), and main().
| void skt_close | ( | SOCKET | fd | ) |
Definition at line 74 of file sockRoutines.c.
Referenced by arg_init(), CcsConnectIpWithTimeout(), CcsFinalize(), CcsImpl_kill(), CcsImpl_noReply(), CcsNoResponse(), CcsRecvResponse(), CcsRecvResponseMsg(), CcsSendRequestWithTimeout(), CcsServer_recvRequest(), CcsServer_sendReply(), CcsServer_writeReply(), main(), ping_developers(), and skt_connect().
| static void skt_SIGPIPE_handler | ( | int | sig | ) | [static] |
Definition at line 82 of file sockRoutines.c.
References skt_fallback_SIGPIPE, and skt_ignore_SIGPIPE.
| void skt_buffer_begin | ( | SOCKET | sk | ) |
Definition at line 108 of file sockRoutines.c.
| void skt_buffer_end | ( | SOCKET | sk | ) |
Definition at line 109 of file sockRoutines.c.
| static int skt_should_retry | ( | void | ) | [static] |
Definition at line 118 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().
Definition at line 147 of file sockRoutines.c.
References skt_abort, skt_ignore_SIGPIPE, 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 182 of file sockRoutines.c.
References _skt_invalid_ip, and skt_lookup_ip().
Referenced by CcsServer_new(), CmiInitCPUAffinity(), getenv_display(), and skt_innode_my_ip().
Definition at line 192 of file sockRoutines.c.
References _skt_invalid_ip, and skt_ip_t::data.
Referenced by skt_lookup_ip().
| skt_ip_t skt_lookup_ip | ( | const char * | name | ) |
Definition at line 212 of file sockRoutines.c.
References _skt_invalid_ip, and 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 229 of file sockRoutines.c.
References skt_innode_lookup_ip(), and skt_my_ip().
Referenced by arg_init().
| skt_ip_t skt_innode_lookup_ip | ( | const char * | name | ) |
Definition at line 241 of file sockRoutines.c.
References _skt_invalid_ip, and 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 260 of file sockRoutines.c.
Referenced by arg_init(), CcsServer_new(), CcsServer_recvRequest(), CmiMXMakeConnection(), getenv_display(), main(), and printSvr().
Definition at line 276 of file sockRoutines.c.
Referenced by node_addresses_store(), ping_developers(), skt_connect(), skt_datagram(), and skt_server_ip().
Definition at line 285 of file sockRoutines.c.
References _skt_invalid_ip, skt_abort, skt_build_addr(), and skt_should_retry().
Referenced by KillOnAllSigs().
| SOCKET skt_server | ( | unsigned int * | port | ) |
Definition at line 317 of file sockRoutines.c.
References skt_server_ip().
Referenced by arg_init(), CcsServer_new(), KillOnAllSigs(), and main().
Definition at line 322 of file sockRoutines.c.
References _skt_invalid_ip, skt_abort, skt_build_addr(), and skt_should_retry().
Referenced by skt_server().
Definition at line 352 of file sockRoutines.c.
References skt_abort, and skt_should_retry().
Referenced by arg_init(), CcsServer_recvRequest(), main(), and open_tcp_sockets().
Definition at line 371 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(), CcsSendRequestWithTimeout(), KillOnAllSigs(), and open_tcp_sockets().
| void skt_setSockBuf | ( | SOCKET | skt, | |
| int | bufsize | |||
| ) |
Definition at line 401 of file sockRoutines.c.
References skt_abort.
Referenced by open_tcp_sockets().
Definition at line 410 of file sockRoutines.c.
References skt_abort, skt_ignore_SIGPIPE, 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(), main(), open_tcp_sockets(), and ReceiveDatagram().
Definition at line 442 of file sockRoutines.c.
References skt_abort, skt_ignore_SIGPIPE, and skt_should_retry().
Referenced by arg_init(), CcsImpl_authInit(), CcsImpl_kill(), CcsServer_createSalt(), main(), open_tcp_sockets(), and skt_sendV().
Definition at line 473 of file sockRoutines.c.
References CmiTmpAlloc(), CmiTmpFree(), dest, and skt_sendN().
Referenced by arg_init(), CcsSendRequestWithTimeout(), CcsServer_writeReply(), ChMessage_send(), and KillOnAllSigs().
| ChMessageInt_t ChMessageInt_new | ( | unsigned int | src | ) |
Definition at line 531 of file sockRoutines.c.
References ChMessageInt_t::data.
Referenced by arg_init(), CCS_AUTH_hash(), ccs_getinfo(), CcsImpl_authInit(), CcsImpl_netRequest(), CcsImpl_reply(), CcsNoDelayedReply(), CcsNoReply(), CcsSendDelayedReply(), CcsSendReply(), CcsSendRequestWithTimeout(), CcsServer_createSalt(), CcsServer_readHeader(), CcsServer_recvRequest(), CcsServer_recvRequestData(), CcsServer_writeReply(), ChMessageHeader_new(), copyInfiAddr(), CpdList_ccs_list_len(), and KillOnAllSigs().
| unsigned int ChMessageInt | ( | ChMessageInt_t | src | ) |
Definition at line 537 of file sockRoutines.c.
References ChMessageInt_t::data.
Referenced by arg_init(), ccs_killport(), CcsCallerId(), CcsHandleRequest(), CcsImpl_authInit(), CcsImpl_ccs2converse(), CcsImpl_netRequest(), CcsImpl_noReply(), CcsRecvResponse(), CcsRecvResponseMsg(), 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(), and rep_fw_handler().
| ChMessageLong_t ChMessageLong_new | ( | CMK_TYPEDEF_UINT8 | src | ) |
Definition at line 544 of file sockRoutines.c.
References ChMessageLong_t::data.
Referenced by KillOnAllSigs().
| CMK_TYPEDEF_UINT8 ChMessageLong | ( | ChMessageLong_t | src | ) |
Definition at line 550 of file sockRoutines.c.
References ChMessageLong_t::data.
Referenced by node_addresses_store().
Definition at line 557 of file sockRoutines.c.
References ChMessageData_recv(), and ChMessageHeader_recv().
Referenced by arg_init(), and KillOnAllSigs().
Definition at line 565 of file sockRoutines.c.
References ChMessageInt(), ChMessage::data, ChMessage::header, ChMessage::len, ChMessageHeader::len, and skt_recvN().
Referenced by arg_init(), and ChMessage_recv().
Definition at line 574 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 582 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 589 of file sockRoutines.c.
References ChMessageInt_new(), ChMessageHeader::len, and ChMessageHeader::type.
Referenced by arg_init(), ChMessage_new(), and KillOnAllSigs().
Definition at line 595 of file sockRoutines.c.
References ChMessageHeader_new(), ChMessage::data, ChMessage::header, ChMessage::len, and malloc().
Referenced by KillOnAllSigs().
Definition at line 601 of file sockRoutines.c.
References ChMessage::data, ChMessage::header, ChMessage::len, and skt_sendV().
skt_idleFn idleFunc = NULL [static] |
skt_abortFn skt_abort = default_skt_abort [static] |
Definition at line 45 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 57 of file sockRoutines.c.
Referenced by skt_recvN(), skt_select1(), skt_sendN(), and skt_SIGPIPE_handler().
int skt_inited = 0 [static] |
skt_signal_handler_fn skt_fallback_SIGPIPE = NULL [static] |
| skt_ip_t _skt_invalid_ip = {{0}} |
Definition at line 180 of file sockRoutines.c.
Referenced by arg_init(), KillOnAllSigs(), skt_datagram(), skt_innode_lookup_ip(), skt_lookup_ip(), skt_my_ip(), skt_parse_dotted(), and skt_server_ip().
| skt_ip_t _skt_invalid_ip = {{0}} |
Definition at line 611 of file sockRoutines.c.
1.5.1