version 1.18.2.1, 2015/06/28 21:40:45
|
version 1.19.2.2, 2015/07/22 15:07:10
|
Line 51 SUCH DAMAGE.
|
Line 51 SUCH DAMAGE.
|
int rpc_Errno; |
int rpc_Errno; |
char rpc_Error[STRSIZ]; |
char rpc_Error[STRSIZ]; |
|
|
inline int |
|
rpc_funcs_cmp(struct tagRPCFunc *a, struct tagRPCFunc *b) |
|
{ |
|
int ret; |
|
|
|
assert(a && b); |
|
|
|
ret = AIT_KEY(&a->func_name) - AIT_KEY(&b->func_name); |
|
|
|
if (ret < 0) |
|
return -1; |
|
else if (ret > 0) |
|
return 1; |
|
|
|
return ret; |
|
} |
|
|
|
AVL_GENERATE(tagRPCFuncs, tagRPCFunc, func_node, rpc_funcs_cmp); |
|
|
|
#pragma GCC visibility pop |
#pragma GCC visibility pop |
|
|
// rpc_GetErrno() Get error code of last operation |
// rpc_GetErrno() Get error code of last operation |
Line 170 try2read:
|
Line 151 try2read:
|
pfd.events = POLLIN | POLLPRI; |
pfd.events = POLLIN | POLLPRI; |
memset(buf, 0, blen); |
memset(buf, 0, blen); |
memset(&sa2, 0, sizeof sa2); |
memset(&sa2, 0, sizeof sa2); |
salen = sa2.ss.ss_len = sizeof(sockaddr_t); | salen = sa2.ss.ss_len = (u_char) MIN(sizeof(sockaddr_t), 0xff); |
if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || |
if ((ret = poll(&pfd, 1, DEF_RPC_TIMEOUT * 1000)) < 1 || |
pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) { |
pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) { |
if (ret) |
if (ret) |
Line 377 rpc_Write(int sock, int type, int flags, sockaddr_t *
|
Line 358 rpc_Write(int sock, int type, int flags, sockaddr_t *
|
} |
} |
|
|
return ret; |
return ret; |
|
} |
|
|
|
/* |
|
* rpc_pktFreeSpace() - Get free space for payload into RPC packet |
|
* |
|
* @c = RPC client |
|
* return: remains free bytes from packet |
|
*/ |
|
size_t |
|
rpc_pktFreeSpace(rpc_cli_t * __restrict c) |
|
{ |
|
return (sizeof(struct tagRPCCall) + ait_resideVars(RPC_RETVARS(c))); |
} |
} |