|
|
| version 1.24.2.4, 2015/01/18 00:06:55 | version 1.26.2.4, 2015/06/24 23:02:28 |
|---|---|
| Line 58 static void *rxUDPPacket(sched_task_t *); | Line 58 static void *rxUDPPacket(sched_task_t *); |
| static void *txUDPPacket(sched_task_t *); | static void *txUDPPacket(sched_task_t *); |
| /* SOCK_RAW */ | /* SOCK_RAW */ |
| static void *rxRAWPacket(sched_task_t *); | |
| static void *txRAWPacket(sched_task_t *); | |
| /* SOCK_BPF */ | /* SOCK_BPF */ |
| static void *rxBPFPacket(sched_task_t *); | static void *rxBPFPacket(sched_task_t *); |
| static void *txBPFPacket(sched_task_t *); | static void *txBPFPacket(sched_task_t *); |
| /* SOCK_EXT */ | /* SOCK_EXT */ |
| static void *rxEXTPacket(sched_task_t *); | |
| static void *txEXTPacket(sched_task_t *); | |
| static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = { | static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = { |
| { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ | { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ |
| { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ | { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ |
| { rxUDPPacket, freeClient, rxUDPPacket, txUDPPacket }, /* SOCK_DGRAM */ | { rxUDPPacket, freeClient, rxUDPPacket, txUDPPacket }, /* SOCK_DGRAM */ |
| { NULL, NULL, NULL, NULL }, /* SOCK_RAW */ | { rxRAWPacket, freeClient, rxRAWPacket, txRAWPacket }, /* SOCK_RAW */ |
| { rxBPFPacket, freeClient, rxBPFPacket, txBPFPacket }, /* SOCK_BPF */ | { rxBPFPacket, freeClient, rxBPFPacket, txBPFPacket }, /* SOCK_BPF */ |
| { NULL, NULL, NULL, NULL } /* SOCK_EXT */ | { rxEXTPacket, freeClient, rxEXTPacket, txEXTPacket } /* SOCK_EXT */ |
| }; | }; |
| /* Global Signal Argument when kqueue support disabled */ | /* Global Signal Argument when kqueue support disabled */ |
| Line 119 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t * | Line 123 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t * |
| rpc_cli_t *c = NULL; | rpc_cli_t *c = NULL; |
| int n; | int n; |
| n = _check4freeslot(srv, sa); | if (srv->srv_proto != SOCK_EXT) |
| n = _check4freeslot(srv, sa); | |
| else | |
| n = 0; | |
| if (n == -1) | if (n == -1) |
| return NULL; | return NULL; |
| else | else |
| Line 201 txPacket(sched_task_t *task) | Line 208 txPacket(sched_task_t *task) |
| buf = AIT_GET_BUF(&c->cli_buf); | buf = AIT_GET_BUF(&c->cli_buf); |
| rpc = (struct tagRPCCall*) buf; | rpc = (struct tagRPCCall*) buf; |
| rpc->call_argc = htons(array_Size(RPC_RETVARS(c))); | rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
| /* Go Encapsulate variables */ | /* Go Encapsulate variables */ |
| ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, | ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
| RPC_RETVARS(c)); | RPC_RETVARS(c)); |
| Line 219 txPacket(sched_task_t *task) | Line 226 txPacket(sched_task_t *task) |
| } | } |
| rpc->call_len = htonl(wlen); | rpc->call_len = htonl(wlen); |
| rpc->call_io = RPC_ACK; | |
| #if 0 | #if 0 |
| /* calculate CRC */ | /* calculate CRC */ |
| Line 262 execCall(sched_task_t *task) | Line 270 execCall(sched_task_t *task) |
| array_t *arr = NULL; | array_t *arr = NULL; |
| u_char *buf = AIT_GET_BUF(&c->cli_buf); | u_char *buf = AIT_GET_BUF(&c->cli_buf); |
| struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | struct tagRPCCall *rpc = (struct tagRPCCall*) buf; |
| int argc = ntohs(rpc->call_argc); | int argc = rpc->call_argc; |
| /* Go decapsulate variables ... */ | /* Go decapsulate variables ... */ |
| if (argc) { | if (argc) { |
| Line 303 execCall(sched_task_t *task) | Line 311 execCall(sched_task_t *task) |
| rpc->call_argc ^= rpc->call_argc; | rpc->call_argc ^= rpc->call_argc; |
| } else { | } else { |
| /* reply */ | /* reply */ |
| rpc->call_argc = htons(array_Size(RPC_RETVARS(c))); | rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
| } | } |
| } | } |
| } | } |
| Line 373 rxPacket(sched_task_t *task) | Line 381 rxPacket(sched_task_t *task) |
| } | } |
| len = estlen; | len = estlen; |
| /* skip loop packet */ | |
| if (rpc->call_io & RPC_ACK) { | |
| schedReadSelf(task); | |
| return NULL; | |
| } | |
| #if 0 | #if 0 |
| /* check integrity of packet */ | /* check integrity of packet */ |
| crc = ntohs(rpc->call_crc); | crc = ntohs(rpc->call_crc); |
| Line 483 txUDPPacket(sched_task_t *task) | Line 497 txUDPPacket(sched_task_t *task) |
| buf = AIT_GET_BUF(&c->cli_buf); | buf = AIT_GET_BUF(&c->cli_buf); |
| rpc = (struct tagRPCCall*) buf; | rpc = (struct tagRPCCall*) buf; |
| rpc->call_argc = htons(array_Size(RPC_RETVARS(c))); | rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
| /* Go Encapsulate variables */ | /* Go Encapsulate variables */ |
| ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, | ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
| RPC_RETVARS(c)); | RPC_RETVARS(c)); |
| Line 500 txUDPPacket(sched_task_t *task) | Line 514 txUDPPacket(sched_task_t *task) |
| } | } |
| rpc->call_len = htonl(wlen); | rpc->call_len = htonl(wlen); |
| rpc->call_io = RPC_ACK; | |
| /* calculate CRC */ | /* calculate CRC */ |
| rpc->call_crc ^= rpc->call_crc; | rpc->call_crc ^= rpc->call_crc; |
| Line 605 rxUDPPacket(sched_task_t *task) | Line 620 rxUDPPacket(sched_task_t *task) |
| } | } |
| len = estlen; | len = estlen; |
| /* skip loop packet */ | |
| if (rpc->call_io & RPC_ACK) | |
| goto end; | |
| /* check integrity of packet */ | /* check integrity of packet */ |
| crc = ntohs(rpc->call_crc); | crc = ntohs(rpc->call_crc); |
| rpc->call_crc ^= rpc->call_crc; | rpc->call_crc ^= rpc->call_crc; |
| Line 641 end: | Line 660 end: |
| static void * | static void * |
| txRAWPacket(sched_task_t *task) | |
| { | |
| rpc_cli_t *c = TASK_ARG(task); | |
| rpc_srv_t *s = c->cli_parent; | |
| rpc_func_t *f = NULL; | |
| u_char *buf = AIT_GET_BUF(&c->cli_buf); | |
| struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | |
| int ret, estlen, wlen = sizeof(struct tagRPCCall); | |
| struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; | |
| schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, TASK_ARG(task), NULL); | |
| schedTimer(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | |
| TASK_ARG(task), ts, TASK_ARG(task), 0); | |
| if (rpc->call_argc) { | |
| f = rpc_srv_getCall(s, ntohs(rpc->call_tag)); | |
| if (!f) { | |
| rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(rpc_Errno); | |
| } else { | |
| /* calc estimated length */ | |
| estlen = ait_resideVars(RPC_RETVARS(c)) + wlen; | |
| if (estlen > AIT_LEN(&c->cli_buf)) | |
| AIT_RE_BUF(&c->cli_buf, estlen); | |
| buf = AIT_GET_BUF(&c->cli_buf); | |
| rpc = (struct tagRPCCall*) buf; | |
| rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); | |
| /* Go Encapsulate variables */ | |
| ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, | |
| RPC_RETVARS(c)); | |
| /* Free return values */ | |
| ait_freeVars(&c->cli_vars); | |
| if (ret == -1) { | |
| rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(rpc_Errno); | |
| } else | |
| wlen += ret; | |
| } | |
| } | |
| rpc->call_len = htonl(wlen); | |
| rpc->call_io = RPC_ACK; | |
| /* calculate CRC */ | |
| rpc->call_crc ^= rpc->call_crc; | |
| rpc->call_crc = htons(crcFletcher16((u_short*) buf, wlen / 2)); | |
| /* send reply */ | |
| ret = sendto(TASK_FD(task), buf, MIN(wlen, s->srv_netbuf), MSG_NOSIGNAL, | |
| &c->cli_sa.sa, c->cli_sa.sa.sa_len); | |
| if (ret == -1) { | |
| /* close connection */ | |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | |
| TASK_ARG(task), 0, NULL, 0); | |
| return NULL; | |
| } | |
| return NULL; | |
| } | |
| static void * | |
| rxRAWPacket(sched_task_t *task) | |
| { | |
| rpc_srv_t *srv = TASK_ARG(task); | |
| rpc_cli_t *c = NULL; | |
| int len, rlen, noreply; | |
| u_short crc; | |
| struct tagRPCCall *rpc; | |
| sockaddr_t sa; | |
| socklen_t salen; | |
| struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; | |
| ait_val_t b = AIT_VAL_INIT; | |
| /* receive connect packet */ | |
| AIT_SET_BUF(&b, NULL, srv->srv_netbuf); | |
| salen = sa.ss.ss_len = sizeof(sockaddr_t); | |
| rlen = recvfrom(TASK_FD(task), AIT_GET_BUF(&b), AIT_LEN(&b), 0, &sa.sa, &salen); | |
| if (sa.sa.sa_family == AF_INET) { | |
| struct ip *h; | |
| h = (struct ip*) AIT_GET_BUF(&b); | |
| if (rlen < ntohs(h->ip_len) || h->ip_p != IPPROTO_ERPC) | |
| goto end; | |
| else { | |
| rlen -= sizeof(struct ip); | |
| rpc = (struct tagRPCCall*) | |
| (AIT_GET_BUF(&b) + sizeof(struct ip)); | |
| } | |
| } else { | |
| struct ip6_hdr *h; | |
| h = (struct ip6_hdr*) AIT_GET_BUF(&b); | |
| if (rlen < (ntohs(h->ip6_plen) + sizeof(struct ip6_hdr)) || | |
| h->ip6_nxt != IPPROTO_ERPC) | |
| goto end; | |
| else { | |
| rlen -= sizeof(struct ip6_hdr); | |
| rpc = (struct tagRPCCall*) | |
| (AIT_GET_BUF(&b) + sizeof(struct ip6_hdr)); | |
| } | |
| } | |
| if (rlen < sizeof(struct tagRPCCall)) { | |
| rpc_SetErr(ERPCMISMATCH, "Short RPC packet"); | |
| goto end; | |
| } | |
| /* skip loop packet */ | |
| if (rpc->call_io & RPC_ACK) | |
| goto end; | |
| c = _allocClient(srv, &sa); | |
| if (!c) { | |
| EVERBOSE(1, "RPC client quota exceeded! Connection will be shutdown!\n"); | |
| usleep(2000); /* blocked client delay */ | |
| goto end; | |
| } else { | |
| len = ntohl(rpc->call_len); | |
| if (len > AIT_LEN(&c->cli_buf)) | |
| AIT_RE_BUF(&c->cli_buf, len); | |
| memcpy(AIT_GET_BUF(&c->cli_buf), rpc, len); | |
| rpc = (struct tagRPCCall*) AIT_GET_BUF(&c->cli_buf); | |
| c->cli_sock = TASK_FD(task); | |
| memcpy(&c->cli_sa, &sa, sizeof c->cli_sa); | |
| /* armed timer for close stateless connection */ | |
| schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, c, NULL); | |
| schedTimer(TASK_ROOT(task), cbProto[srv->srv_proto][CB_CLOSECLIENT], | |
| c, ts, c, 0); | |
| } | |
| /* check integrity of packet */ | |
| crc = ntohs(rpc->call_crc); | |
| rpc->call_crc ^= rpc->call_crc; | |
| if (crc != crcFletcher16((u_short*) rpc, len / 2)) { | |
| rpc_SetErr(ERPCMISMATCH, "Bad CRC RPC packet"); | |
| /* close connection */ | |
| schedEvent(TASK_ROOT(task), cbProto[srv->srv_proto][CB_CLOSECLIENT], | |
| c, 0, NULL, 0); | |
| goto end; | |
| } | |
| noreply = RPC_CHK_NOREPLY(rpc); | |
| /* check RPC packet session info */ | |
| if (rpc_chkPktSession(&rpc->call_session, &srv->srv_session)) { | |
| rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(errno); | |
| } else { | |
| /* execute RPC call */ | |
| schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); | |
| } | |
| /* send RPC reply */ | |
| if (!noreply) | |
| schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], | |
| c, TASK_FD(task), rpc, len); | |
| end: | |
| AIT_FREE_VAL(&b); | |
| schedReadSelf(task); | |
| return NULL; | |
| } | |
| static void * | |
| txBPFPacket(sched_task_t *task) | txBPFPacket(sched_task_t *task) |
| { | { |
| rpc_cli_t *c = TASK_ARG(task); | rpc_cli_t *c = TASK_ARG(task); |
| Line 672 txBPFPacket(sched_task_t *task) | Line 862 txBPFPacket(sched_task_t *task) |
| buf = AIT_GET_BUF(&c->cli_buf); | buf = AIT_GET_BUF(&c->cli_buf); |
| rpc = (struct tagRPCCall*) buf; | rpc = (struct tagRPCCall*) buf; |
| rpc->call_argc = htons(array_Size(RPC_RETVARS(c))); | rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
| /* Go Encapsulate variables */ | /* Go Encapsulate variables */ |
| ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, | ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
| RPC_RETVARS(c)); | RPC_RETVARS(c)); |
| Line 689 txBPFPacket(sched_task_t *task) | Line 879 txBPFPacket(sched_task_t *task) |
| } | } |
| rpc->call_len = htonl(wlen); | rpc->call_len = htonl(wlen); |
| rpc->call_io = RPC_ACK; | |
| /* calculate CRC */ | /* calculate CRC */ |
| rpc->call_crc ^= rpc->call_crc; | rpc->call_crc ^= rpc->call_crc; |
| Line 741 rxBPFPacket(sched_task_t *task) | Line 932 rxBPFPacket(sched_task_t *task) |
| eh = (struct ether_header*) (AIT_GET_BUF(&b) + h->bh_hdrlen); | eh = (struct ether_header*) (AIT_GET_BUF(&b) + h->bh_hdrlen); |
| rlen -= ETHER_HDR_LEN; | rlen -= ETHER_HDR_LEN; |
| rpc = (struct tagRPCCall*) (eh + 1); | rpc = (struct tagRPCCall*) (eh + 1); |
| #if 0 | |
| /* skip loop packet */ | |
| if (rpc->call_io & RPC_ACK) | |
| goto end; | |
| #endif | |
| if (eh->ether_type != ntohs(RPC_DEFPORT)) | if (eh->ether_type != ntohs(RPC_DEFPORT)) |
| goto end; | goto end; |
| else | else |
| Line 756 rxBPFPacket(sched_task_t *task) | Line 954 rxBPFPacket(sched_task_t *task) |
| len = ntohl(rpc->call_len); | len = ntohl(rpc->call_len); |
| if (len > AIT_LEN(&c->cli_buf)) | if (len > AIT_LEN(&c->cli_buf)) |
| AIT_RE_BUF(&c->cli_buf, len); | AIT_RE_BUF(&c->cli_buf, len); |
| memcpy(AIT_GET_BUF(&c->cli_buf), rpc, AIT_LEN(&c->cli_buf)); | memcpy(AIT_GET_BUF(&c->cli_buf), rpc, len); |
| rpc = (struct tagRPCCall*) AIT_GET_BUF(&c->cli_buf); | rpc = (struct tagRPCCall*) AIT_GET_BUF(&c->cli_buf); |
| c->cli_sock = TASK_FD(task); | c->cli_sock = TASK_FD(task); |
| Line 803 end: | Line 1001 end: |
| return NULL; | return NULL; |
| } | } |
| static void * | |
| txEXTPacket(sched_task_t *task) | |
| { | |
| rpc_cli_t *c = TASK_ARG(task); | |
| rpc_srv_t *s = c->cli_parent; | |
| rpc_func_t *f = NULL; | |
| u_char *buf = AIT_GET_BUF(&c->cli_buf); | |
| struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | |
| int ret, len, wlen = sizeof(struct tagRPCCall); | |
| struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; | |
| schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, TASK_ARG(task), NULL); | |
| schedTimer(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | |
| TASK_ARG(task), ts, TASK_ARG(task), 0); | |
| if (rpc->call_argc) { | |
| f = rpc_srv_getCall(s, ntohs(rpc->call_tag)); | |
| if (!f) { | |
| rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(rpc_Errno); | |
| } else { | |
| /* calc estimated length */ | |
| len = ait_resideVars(RPC_RETVARS(c)) + wlen; | |
| if (len > AIT_LEN(&c->cli_buf)) | |
| AIT_RE_BUF(&c->cli_buf, len); | |
| buf = AIT_GET_BUF(&c->cli_buf); | |
| rpc = (struct tagRPCCall*) buf; | |
| rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); | |
| /* Go Encapsulate variables */ | |
| ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, | |
| RPC_RETVARS(c)); | |
| /* Free return values */ | |
| ait_freeVars(&RPC_RETVARS(c)); | |
| if (ret == -1) { | |
| rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(rpc_Errno); | |
| } else | |
| wlen += ret; | |
| } | |
| } | |
| rpc->call_len = htonl(wlen); | |
| rpc->call_io = RPC_ACK; | |
| /* send reply */ | |
| ret = write(TASK_FD(task), buf, MIN(wlen, s->srv_netbuf)); | |
| if (ret == -1) { | |
| /* close connection */ | |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | |
| TASK_ARG(task), 0, NULL, 0); | |
| return NULL; | |
| } | |
| return NULL; | |
| } | |
| static void * | |
| rxEXTPacket(sched_task_t *task) | |
| { | |
| rpc_srv_t *srv = TASK_ARG(task); | |
| rpc_cli_t *c = NULL; | |
| int len, rlen, noreply; | |
| struct tagRPCCall *rpc; | |
| struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; | |
| ait_val_t b = AIT_VAL_INIT; | |
| sockaddr_t sa; | |
| memset(&sa, 0, sizeof sa); | |
| /* receive connect packet */ | |
| AIT_SET_BUF(&b, NULL, srv->srv_netbuf); | |
| rlen = read(TASK_FD(task), AIT_GET_BUF(&b), AIT_LEN(&b)); | |
| if (rlen < sizeof(struct tagRPCCall)) { | |
| rpc_SetErr(ERPCMISMATCH, "Short RPC packet"); | |
| goto end; | |
| } else { | |
| rpc = (struct tagRPCCall*) AIT_GET_BUF(&b); | |
| /* skip loop packet */ | |
| if (rpc->call_io & RPC_ACK) | |
| goto end; | |
| } | |
| c = _allocClient(srv, &sa); | |
| if (!c) { | |
| EVERBOSE(1, "RPC client quota exceeded! Connection will be shutdown!\n"); | |
| usleep(2000); /* blocked client delay */ | |
| goto end; | |
| } else { | |
| len = ntohl(rpc->call_len); | |
| if (len > AIT_LEN(&c->cli_buf)) | |
| AIT_RE_BUF(&c->cli_buf, len); | |
| memcpy(AIT_GET_BUF(&c->cli_buf), rpc, AIT_LEN(&c->cli_buf)); | |
| rpc = (struct tagRPCCall*) AIT_GET_BUF(&c->cli_buf); | |
| c->cli_sock = TASK_FD(task); | |
| /* armed timer for close stateless connection */ | |
| schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, c, NULL); | |
| schedTimer(TASK_ROOT(task), cbProto[srv->srv_proto][CB_CLOSECLIENT], | |
| c, ts, c, 0); | |
| } | |
| noreply = RPC_CHK_NOREPLY(rpc); | |
| /* check RPC packet session info */ | |
| if (rpc_chkPktSession(&rpc->call_session, &srv->srv_session)) { | |
| rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session"); | |
| rpc->call_argc ^= rpc->call_argc; | |
| rpc->call_rep.ret = RPC_ERROR(-1); | |
| rpc->call_rep.eno = RPC_ERROR(errno); | |
| } else { | |
| /* execute RPC call */ | |
| schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); | |
| } | |
| /* send RPC reply */ | |
| if (!noreply) | |
| schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], | |
| c, TASK_FD(task), rpc, len); | |
| end: | |
| AIT_FREE_VAL(&b); | |
| schedReadSelf(task); | |
| return NULL; | |
| } | |
| /* ------------------------------------------------------ */ | /* ------------------------------------------------------ */ |
| void | void |
| Line 1148 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv) | Line 1478 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv) |
| srv->srv_blob.kill = 1; | srv->srv_blob.kill = 1; |
| schedEnd(&srv->srv_blob.root); | schedEnd(&srv->srv_blob.root); |
| if (srv->srv_blob.server.cli_sa.sa.sa_family == AF_LOCAL) | |
| unlink(srv->srv_blob.server.cli_sa.sun.sun_path); | |
| } | } |
| /* | /* |
| Line 1249 rpc_srv_initServer(u_char InstID, int concurentClients | Line 1582 rpc_srv_initServer(u_char InstID, int concurentClients |
| rpc_SetErr(EINVAL, "Invalid parameters can`t init RPC server"); | rpc_SetErr(EINVAL, "Invalid parameters can`t init RPC server"); |
| return NULL; | return NULL; |
| } | } |
| if (!Port && proto < SOCK_RAW) | |
| Port = RPC_DEFPORT; | |
| if (!e_gethostbyname(csHost, Port, &sa)) | if (!e_gethostbyname(csHost, Port, &sa)) |
| return NULL; | return NULL; |
| if (!Port) | |
| Port = RPC_DEFPORT; | |
| if (!proto) | if (!proto) |
| proto = SOCK_STREAM; | proto = SOCK_STREAM; |
| if (netBuf < RPC_MIN_BUFSIZ) | if (netBuf < RPC_MIN_BUFSIZ) |
| Line 1308 rpc_srv_initServer(u_char InstID, int concurentClients | Line 1641 rpc_srv_initServer(u_char InstID, int concurentClients |
| } | } |
| /* create server socket */ | /* create server socket */ |
| srv->srv_server.cli_sock = socket(srv->srv_server.cli_sa.sa.sa_family, srv->srv_proto, 0); | srv->srv_server.cli_sock = socket(srv->srv_server.cli_sa.sa.sa_family, |
| srv->srv_proto, srv->srv_proto == SOCK_RAW ? IPPROTO_ERPC : 0); | |
| if (srv->srv_server.cli_sock == -1) { | if (srv->srv_server.cli_sock == -1) { |
| LOGERR; | LOGERR; |
| array_Destroy(&srv->srv_clients); | array_Destroy(&srv->srv_clients); |
| Line 1370 rpc_srv_endServer(rpc_srv_t ** __restrict psrv) | Line 1704 rpc_srv_endServer(rpc_srv_t ** __restrict psrv) |
| schedEnd(&(*psrv)->srv_root); | schedEnd(&(*psrv)->srv_root); |
| if ((*psrv)->srv_server.cli_sa.sa.sa_family == AF_LOCAL) | |
| unlink((*psrv)->srv_server.cli_sa.sun.sun_path); | |
| pthread_mutex_destroy(&(*psrv)->srv_funcs.mtx); | pthread_mutex_destroy(&(*psrv)->srv_funcs.mtx); |
| e_free(*psrv); | e_free(*psrv); |
| *psrv = NULL; | *psrv = NULL; |
| Line 1640 rpc_srv_initServerExt(u_char InstID, int netBuf, int f | Line 1977 rpc_srv_initServerExt(u_char InstID, int netBuf, int f |
| memset(srv, 0, sizeof(rpc_srv_t)); | memset(srv, 0, sizeof(rpc_srv_t)); |
| srv->srv_proto = SOCK_EXT; | srv->srv_proto = SOCK_EXT; |
| srv->srv_netbuf = netBuf; | srv->srv_netbuf = (netBuf < RPC_MIN_BUFSIZ) ? |
| getpagesize() : E_ALIGN(netBuf, 2); | |
| srv->srv_session.sess_version = RPC_VERSION; | srv->srv_session.sess_version = RPC_VERSION; |
| srv->srv_session.sess_instance = InstID; | srv->srv_session.sess_instance = InstID; |