version 1.16.8.1, 2013/08/21 22:34:18
|
version 1.19.6.1, 2013/11/14 22:53:12
|
Line 172 rpc_cli_openClient(u_char InstID, int netBuf, const ch
|
Line 172 rpc_cli_openClient(u_char InstID, int netBuf, const ch
|
else |
else |
netBuf = E_ALIGN(netBuf, 2); /* align netBuf length */ |
netBuf = E_ALIGN(netBuf, 2); /* align netBuf length */ |
|
|
#ifdef HAVE_SRANDOMDEV |
|
srandomdev(); |
|
#else |
|
time_t tim; |
|
|
|
srandom((time(&tim) ^ getpid())); |
|
#endif |
|
|
|
cli = e_malloc(sizeof(rpc_cli_t)); |
cli = e_malloc(sizeof(rpc_cli_t)); |
if (!cli) { |
if (!cli) { |
LOGERR; |
LOGERR; |
Line 273 rpc_cli_closeClient(rpc_cli_t ** __restrict cli)
|
Line 265 rpc_cli_closeClient(rpc_cli_t ** __restrict cli)
|
int |
int |
rpc_pkt_Send(int sock, int type, sockaddr_t * __restrict sa, ait_val_t * __restrict pkt, int len) |
rpc_pkt_Send(int sock, int type, sockaddr_t * __restrict sa, ait_val_t * __restrict pkt, int len) |
{ |
{ |
struct pollfd pfd; |
|
int ret; |
|
u_char *buf; |
u_char *buf; |
|
|
if (!pkt) { |
if (!pkt) { |
Line 283 rpc_pkt_Send(int sock, int type, sockaddr_t * __restri
|
Line 273 rpc_pkt_Send(int sock, int type, sockaddr_t * __restri
|
} else |
} else |
buf = AIT_GET_BUF(pkt); |
buf = AIT_GET_BUF(pkt); |
|
|
pfd.fd = sock; | return rpc_Write(sock, type, MSG_NOSIGNAL, sa, buf, len); |
pfd.events = POLLOUT; | |
if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || | |
pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) { | |
if (ret) | |
LOGERR; | |
else | |
rpc_SetErr(ETIMEDOUT, "Timeout, can't send to RPC server"); | |
return -1; | |
} | |
do { | |
if (type == SOCK_STREAM) | |
ret = send(sock, buf, len, MSG_NOSIGNAL); | |
else if (sa) | |
ret = sendto(sock, buf, len, MSG_NOSIGNAL, &sa->sa, sa->sa.sa_len); | |
else { | |
rpc_SetErr(EINVAL, "Invalid argument(s)!"); | |
return -1; | |
} | |
if (ret == -1) { | |
if (errno == EAGAIN) | |
continue; | |
LOGERR; | |
return -1; | |
} else if (ret != len) { | |
rpc_SetErr(EPROCUNAVAIL, "RPC request, should be send %d bytes, " | |
"really sended %d bytes", len, ret); | |
return -1; | |
} | |
} while (0); | |
| |
return ret; | |
} |
} |
|
|
/* |
/* |
Line 329 rpc_pkt_Send(int sock, int type, sockaddr_t * __restri
|
Line 288 rpc_pkt_Send(int sock, int type, sockaddr_t * __restri
|
int |
int |
rpc_pkt_Receive(int sock, int type, sockaddr_t * __restrict sa, ait_val_t * __restrict pkt) |
rpc_pkt_Receive(int sock, int type, sockaddr_t * __restrict sa, ait_val_t * __restrict pkt) |
{ |
{ |
struct pollfd pfd; | int ret, estlen = 0, blen = sizeof(struct tagRPCCall); |
int ret, len = 0; | |
u_char *buf; |
u_char *buf; |
sockaddr_t sa2; | struct tagRPCCall *rpc; |
socklen_t salen; | |
|
|
if (!pkt) { |
if (!pkt) { |
rpc_SetErr(EINVAL, "Invalid argument(s)!"); |
rpc_SetErr(EINVAL, "Invalid argument(s)!"); |
Line 342 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
|
Line 299 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
|
buf = AIT_GET_BUF(pkt); |
buf = AIT_GET_BUF(pkt); |
|
|
/* reply from RPC server */ |
/* reply from RPC server */ |
pfd.fd = sock; |
|
pfd.events = POLLIN | POLLPRI; |
|
do { |
do { |
if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || |
|
pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) { |
|
if (ret) { |
|
LOGERR; |
|
} else { |
|
if (len++ < 7) |
|
continue; |
|
else |
|
rpc_SetErr(ETIMEDOUT, |
|
"Timeout, no answer from RPC server"); |
|
} |
|
|
|
return -1; |
|
} |
|
|
|
memset(buf, 0, AIT_LEN(pkt)); |
|
if (type == SOCK_STREAM) |
if (type == SOCK_STREAM) |
ret = recv(sock, buf, AIT_LEN(pkt), 0); | ret = rpc_Read(sock, type, !estlen ? MSG_PEEK : 0, NULL, buf, blen); |
else { | else |
memset(&sa2, 0, sizeof sa2); | ret = rpc_Read(sock, type, !estlen ? MSG_PEEK : 0, sa, buf, blen); |
salen = sa2.ss.ss_len = sizeof(sockaddr_t); | |
ret = recvfrom(sock, buf, AIT_LEN(pkt), 0, &sa2.sa, &salen); | |
} | |
if (ret < 1) { |
if (ret < 1) { |
if (ret) { | LOGERR; |
if (errno == EAGAIN) | |
continue; | |
else | |
LOGERR; | |
} | |
return -1; |
return -1; |
} |
} |
|
|
/* check for response from known address */ |
/* check for response from known address */ |
if (type == SOCK_DGRAM) | if (!estlen) { |
if (e_addrcmp(sa, &sa2, 42)) { | /* 1st read for RPC header */ |
rpc_SetErr(ERPCMISMATCH, | if (ret < sizeof(struct tagRPCCall)) { |
"Received RPC response from unknown address"); | rpc_SetErr(ERPCMISMATCH, "Short RPC packet %d bytes", ret); |
continue; | return -1; |
} |
} |
} while (0); | |
| /* calc estimated length */ |
| rpc = (struct tagRPCCall*) buf; |
| estlen = ntohl(rpc->call_len); |
| if (estlen > AIT_LEN(pkt)) |
| AIT_RE_BUF(pkt, estlen); |
| buf = AIT_GET_BUF(pkt); |
| blen = estlen; |
| rpc = (struct tagRPCCall*) buf; |
| continue; |
| } |
| |
| /* compiler optimize loop if while(0) and stop working 'continue' on some platforms */ |
| break; |
| } while (42); |
| |
if (ret < sizeof(struct tagRPCCall)) { |
if (ret < sizeof(struct tagRPCCall)) { |
rpc_SetErr(ERPCMISMATCH, "Short RPC packet %d bytes", ret); |
rpc_SetErr(ERPCMISMATCH, "Short RPC packet %d bytes", ret); |
return -1; |
return -1; |
Line 410 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
Line 356 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
array_t * __restrict vars, int noreply, int nocrc) |
array_t * __restrict vars, int noreply, int nocrc) |
{ |
{ |
struct tagRPCCall *rpc; |
struct tagRPCCall *rpc; |
int ret = 0, len = sizeof(struct tagRPCCall); | int ret = 0, estlen, len = sizeof(struct tagRPCCall); |
u_char *buf; |
u_char *buf; |
|
|
if (!pkt || !sess) { |
if (!pkt || !sess) { |
rpc_SetErr(EINVAL, "Invalid argument(s)!"); |
rpc_SetErr(EINVAL, "Invalid argument(s)!"); |
return -1; |
return -1; |
} else | } |
buf = AIT_GET_BUF(pkt); | |
|
|
|
/* calc estimated length */ |
|
estlen = ait_resideVars(vars) + len; |
|
if (estlen > AIT_LEN(pkt)) |
|
AIT_RE_BUF(pkt, estlen); |
|
buf = AIT_GET_BUF(pkt); |
|
|
/* prepare RPC call */ |
/* prepare RPC call */ |
rpc = (struct tagRPCCall*) buf; |
rpc = (struct tagRPCCall*) buf; |
rpc_addPktSession(&rpc->call_session, sess); |
rpc_addPktSession(&rpc->call_session, sess); |
Line 429 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
Line 380 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
rpc->call_argc = htons(array_Size(vars)); |
rpc->call_argc = htons(array_Size(vars)); |
|
|
/* set reply */ |
/* set reply */ |
rpc->call_req.flags = noreply ? RPC_NOREPLY : RPC_REPLY; | rpc->call_req.flags = (uint64_t) htonl(noreply ? RPC_NOREPLY : RPC_REPLY); |
|
|
if (array_Size(vars)) { |
if (array_Size(vars)) { |
/* marshaling variables */ |
/* marshaling variables */ |
Line 442 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
Line 393 rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_sess_t
|
} |
} |
|
|
/* total packet length */ |
/* total packet length */ |
rpc->call_len = htons(len); | rpc->call_len = htonl(len); |
|
|
if (!nocrc) { |
if (!nocrc) { |
/* calculate CRC */ |
/* calculate CRC */ |
Line 483 rpc_pkt_Replay(ait_val_t * __restrict pkt, rpc_sess_t
|
Line 434 rpc_pkt_Replay(ait_val_t * __restrict pkt, rpc_sess_t
|
/* calculate CRC */ |
/* calculate CRC */ |
crc = ntohs(rpc->call_crc); |
crc = ntohs(rpc->call_crc); |
rpc->call_crc ^= rpc->call_crc; |
rpc->call_crc ^= rpc->call_crc; |
if (crc != crcFletcher16((u_short*) buf, ntohs(rpc->call_len) / 2)) { | if (crc != crcFletcher16((u_short*) buf, ntohl(rpc->call_len) / 2)) { |
rpc_SetErr(ERPCMISMATCH, "Bad CRC RPC packet"); |
rpc_SetErr(ERPCMISMATCH, "Bad CRC RPC packet"); |
return -1; |
return -1; |
} |
} |
Line 509 rpc_pkt_Replay(ait_val_t * __restrict pkt, rpc_sess_t
|
Line 460 rpc_pkt_Replay(ait_val_t * __restrict pkt, rpc_sess_t
|
rpc_SetErr(EMSGSIZE, "Reply RPC packet not enough buffer space ..."); |
rpc_SetErr(EMSGSIZE, "Reply RPC packet not enough buffer space ..."); |
return -1; |
return -1; |
} |
} |
if (len > ntohs(rpc->call_len) - sizeof(struct tagRPCCall)) { | if (len > ntohl(rpc->call_len) - sizeof(struct tagRPCCall)) { |
rpc_SetErr(EMSGSIZE, "Reply RPC packet is too short ..."); |
rpc_SetErr(EMSGSIZE, "Reply RPC packet is too short ..."); |
return -1; |
return -1; |
} |
} |