version 1.12.2.5, 2012/11/19 10:29:02
|
version 1.12.2.6, 2012/11/19 12:43:21
|
Line 855 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
|
Line 855 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
|
return -1; |
return -1; |
} |
} |
|
|
if (listen(srv->srv_blob.server.cli_sock, io_arraySize(srv->srv_blob.clients)) == -1) { | if (srv->srv_proto == SOCK_STREAM) |
LOGERR; | if (listen(srv->srv_blob.server.cli_sock, |
return -1; | io_arraySize(srv->srv_blob.clients)) == -1) { |
} | LOGERR; |
| return -1; |
| } |
|
|
if (!schedRead(srv->srv_blob.root, acceptBLOBClients, srv, |
if (!schedRead(srv->srv_blob.root, acceptBLOBClients, srv, |
srv->srv_blob.server.cli_sock, NULL, 0)) { |
srv->srv_blob.server.cli_sock, NULL, 0)) { |
Line 924 rpc_srv_initServer(u_int regProgID, u_char regProcID,
|
Line 926 rpc_srv_initServer(u_int regProgID, u_char regProcID,
|
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 (!proto) |
|
proto = SOCK_STREAM; |
|
if (!io_gethostbyname(csHost, Port, &sa)) |
if (!io_gethostbyname(csHost, Port, &sa)) |
return NULL; |
return NULL; |
if (!Port) |
if (!Port) |
Port = RPC_DEFPORT; |
Port = RPC_DEFPORT; |
|
if (!proto) |
|
proto = SOCK_STREAM; |
if (netBuf < RPC_MIN_BUFSIZ) |
if (netBuf < RPC_MIN_BUFSIZ) |
netBuf = BUFSIZ; |
netBuf = BUFSIZ; |
else |
else |