Go to the source code of this file.
Data Structures | |
| struct | CcsSecAttr |
| struct | CcsImplHeader |
Functions | |
| void | CcsImpl_netRequest (CcsImplHeader *hdr, const void *reqData) |
| This is the entrance point of a CCS request into the server. | |
| void | CcsImpl_reply (CcsImplHeader *hdr, int repLen, const void *repData) |
| Send a Ccs reply back to the requestor, down the given socket. | |
| void | CcsImpl_kill (void) |
| char * | CcsImpl_ccs2converse (const CcsImplHeader *hdr, const void *data, int *ret_len) |
| void | CcsServer_new (skt_ip_t *ret_ip, int *use_port, const char *securityFile) |
| SOCKET | CcsServer_fd (void) |
| int | CcsServer_recvRequest (CcsImplHeader *hdr, void **reqData) |
| void | CcsServer_sendReply (CcsImplHeader *hdr, int repBytes, const void *repData) |
| void | CcsServer_noReply (CcsImplHeader *hdr) |
| void CcsImpl_netRequest | ( | CcsImplHeader * | hdr, | |
| const void * | reqData | |||
| ) |
This is the entrance point of a CCS request into the server.
It is executed only on proc 0, and it forwards the request to the appropriate PE.
Definition at line 451 of file conv-ccs.c.
References CcsImpl_ccs2converse(), CcsSendReply(), ChMessageInt(), CmiPrintf(), Converse::CmiSyncSendAndFree(), msg, and CcsImplHeader::pe.
Referenced by CcsServerCheck().
| void CcsImpl_reply | ( | CcsImplHeader * | rep, | |
| int | repLen, | |||
| const void * | repData | |||
| ) |
Send a Ccs reply back to the requestor, down the given socket.
Since there is no conv-host, node 0 does all the CCS communication-- this means all requests come to node 0 and are forwarded out; all replies are forwarded back to node 0.
Note: on Net- versions, CcsImpl_reply is implemented in machine.c
Definition at line 418 of file conv-ccs.c.
References CcsServer_sendReply(), ChMessageInt_new(), CmiAlloc(), CmiMyPe(), Converse::CmiSyncSendAndFree(), CcsImplHeader::len, and msg.
Referenced by CcsReply(), KillOnAllSigs(), and rep_fw_handler().
| void CcsImpl_kill | ( | void | ) |
Definition at line 57 of file ccs-builtins.C.
References killPortStruct::ip, killPortStruct::next, noMoreErrors(), killPortStruct::port, skt_close(), skt_connect(), skt_sendN(), and skt_set_abort().
Referenced by ConverseCommonExit().
| char* CcsImpl_ccs2converse | ( | const CcsImplHeader * | hdr, | |
| const void * | data, | |||
| int * | ret_len | |||
| ) |
Definition at line 340 of file conv-ccs.c.
References CcsBufferMessage(), ChMessageInt(), CmiAbort(), CmiAlloc(), CcsImplHeader::len, msg, and CcsImplHeader::pe.
Referenced by CcsImpl_netRequest(), and KillOnAllSigs().
Definition at line 344 of file ccs-server.c.
References CCS_AUTH_new(), CcsSecMan_default(), printf(), skt_init(), skt_my_ip(), skt_print_ip(), and skt_server().
Referenced by arg_init(), and CcsInit().
| SOCKET CcsServer_fd | ( | void | ) |
| int CcsServer_recvRequest | ( | CcsImplHeader * | hdr, | |
| void ** | reqData | |||
| ) |
Definition at line 413 of file ccs-server.c.
References CcsImplHeader::attr, CcsServer_recvRequestData(), ChMessageInt_new(), CcsSecAttr::ip, CcsSecAttr::port, req_abortFn(), skt_accept(), skt_close(), skt_print_ip(), and skt_set_abort().
Referenced by arg_init(), and CcsServerCheck().
| void CcsServer_sendReply | ( | CcsImplHeader * | hdr, | |
| int | repBytes, | |||
| const void * | repData | |||
| ) |
Definition at line 453 of file ccs-server.c.
References CcsImplHeader::attr, CcsServer_writeReply(), ChMessageInt(), CcsImplHeader::len, reply_abortFn(), CcsImplHeader::replyFd, skt_close(), and skt_set_abort().
Referenced by arg_init(), CcsImpl_reply(), check_stdio_header(), and write_stdio_duplicate().
| void CcsServer_noReply | ( | CcsImplHeader * | hdr | ) |
1.5.5