version 1.29, 2016/08/08 13:21:13
|
version 1.30.2.9, 2024/02/26 18:07:32
|
Line 12 terms:
|
Line 12 terms:
|
All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
|
|
Copyright 2004 - 2016 | Copyright 2004 - 2024 |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
|
|
Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
Line 87 rpc_freeCli(rpc_cli_t * __restrict c)
|
Line 87 rpc_freeCli(rpc_cli_t * __restrict c)
|
{ |
{ |
rpc_srv_t *s = c->cli_parent; |
rpc_srv_t *s = c->cli_parent; |
|
|
schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL); | if (s->srv_proto == SOCK_STREAM) |
| schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL); |
|
|
/* free buffer */ |
/* free buffer */ |
AIT_FREE_VAL(&c->cli_buf); |
AIT_FREE_VAL(&c->cli_buf); |
Line 291 execCall(sched_task_t *task)
|
Line 292 execCall(sched_task_t *task)
|
if (TASK_VAL(task)) { |
if (TASK_VAL(task)) { |
/* without reply */ |
/* without reply */ |
ait_freeVars(&c->cli_vars); |
ait_freeVars(&c->cli_vars); |
} else { | } else if (rpc->call_io & RPC_REQ) { |
/* reply */ |
/* reply */ |
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
} |
} |
Line 302 execCall(sched_task_t *task)
|
Line 303 execCall(sched_task_t *task)
|
taskExit(task, NULL); |
taskExit(task, NULL); |
} |
} |
|
|
|
int |
|
rpc_srv_Return(sched_root_task_t *root, rpc_cli_t *c) |
|
{ |
|
rpc_srv_t *s = c->cli_parent; |
|
u_char *buf = AIT_GET_BUF(&c->cli_buf); |
|
struct tagRPCCall *rpc = (struct tagRPCCall*) buf; |
|
|
|
if (!RPC_CHK_NOREPLY(rpc)) { |
|
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
|
schedWrite(root, cbProto[s->srv_proto][CB_TXPACKET], c, c->cli_sock, rpc, 0); |
|
} |
|
|
|
return rpc->call_argc; |
|
} |
|
|
static void * |
static void * |
rxPacket(sched_task_t *task) |
rxPacket(sched_task_t *task) |
{ |
{ |
Line 323 rxPacket(sched_task_t *task)
|
Line 339 rxPacket(sched_task_t *task)
|
|
|
/* prepare rx */ |
/* prepare rx */ |
len = recv(TASK_FD(task), &b, sizeof b, MSG_PEEK); |
len = recv(TASK_FD(task), &b, sizeof b, MSG_PEEK); |
if (len == sizeof b) | if (len < 1) { |
| /* close connection */ |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], |
| TASK_ARG(task), 0, NULL, 0); |
| taskExit(task, NULL); |
| } else if (len == sizeof b) |
rlen = ntohl(b.call_len); |
rlen = ntohl(b.call_len); |
|
else |
|
goto end; |
|
|
rlen = recv(TASK_FD(task), buf, rlen, 0); |
rlen = recv(TASK_FD(task), buf, rlen, 0); |
if (rlen == -1) { |
if (rlen == -1) { |
Line 387 rxPacket(sched_task_t *task)
|
Line 410 rxPacket(sched_task_t *task)
|
schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task), (int) noreply, rpc, len); |
schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task), (int) noreply, rpc, len); |
err: |
err: |
/* send RPC reply */ |
/* send RPC reply */ |
if (!noreply) | if (!noreply && (rpc->call_io & RPC_REQ)) |
schedWrite(TASK_ROOT(task), cbProto[s->srv_proto][CB_TXPACKET], |
schedWrite(TASK_ROOT(task), cbProto[s->srv_proto][CB_TXPACKET], |
TASK_ARG(task), TASK_FD(task), rpc, len); |
TASK_ARG(task), TASK_FD(task), rpc, len); |
| end: |
/* lets get next packet */ |
/* lets get next packet */ |
schedReadSelf(task); |
schedReadSelf(task); |
taskExit(task, NULL); |
taskExit(task, NULL); |
Line 424 acceptClients(sched_task_t *task)
|
Line 447 acceptClients(sched_task_t *task)
|
AIT_FREE_VAL(&c->cli_buf); |
AIT_FREE_VAL(&c->cli_buf); |
array_Del(srv->srv_clients, c->cli_id, 42); |
array_Del(srv->srv_clients, c->cli_id, 42); |
goto end; |
goto end; |
} else | } else { |
fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) | O_NONBLOCK); |
fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) | O_NONBLOCK); |
|
fcntl(c->cli_sock, F_SETFD, FD_CLOEXEC); |
|
} |
|
|
#ifdef TCP_SESSION_TIMEOUT |
#ifdef TCP_SESSION_TIMEOUT |
/* armed timer for close stateless connection */ |
/* armed timer for close stateless connection */ |
Line 542 rxUDPPacket(sched_task_t *task)
|
Line 567 rxUDPPacket(sched_task_t *task)
|
/* 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; |
if (crc != crcFletcher16((u_short*) rpc, len / 2)) | if (crc != crcFletcher16((u_short*) AIT_GET_BUF(&b), len / 2)) |
goto end; |
goto end; |
|
|
/* check RPC packet session info */ |
/* check RPC packet session info */ |
Line 551 rxUDPPacket(sched_task_t *task)
|
Line 576 rxUDPPacket(sched_task_t *task)
|
|
|
c = _allocClient(srv, &sa); |
c = _allocClient(srv, &sa); |
if (!c) { |
if (!c) { |
EVERBOSE(1, "RPC client quota exceeded! Connection will be shutdown!\n"); | EVERBOSE(1, "RPC client quota exceeded!"); |
usleep(2000); /* blocked client delay */ |
usleep(2000); /* blocked client delay */ |
goto end; |
goto end; |
} else { |
} else { |
Line 573 rxUDPPacket(sched_task_t *task)
|
Line 598 rxUDPPacket(sched_task_t *task)
|
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
|
|
/* send RPC reply */ |
/* send RPC reply */ |
if (!noreply) | if (!noreply && (rpc->call_io & RPC_REQ)) |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
c, TASK_FD(task), rpc, len); |
c, TASK_FD(task), rpc, len); |
end: |
end: |
Line 706 rxRAWPacket(sched_task_t *task)
|
Line 731 rxRAWPacket(sched_task_t *task)
|
/* 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; |
if (crc != crcFletcher16((u_short*) rpc, len / 2)) | if (crc != crcFletcher16((u_short*) AIT_GET_BUF(&b), len / 2)) |
goto end; |
goto end; |
|
|
/* check RPC packet session info */ |
/* check RPC packet session info */ |
Line 737 rxRAWPacket(sched_task_t *task)
|
Line 762 rxRAWPacket(sched_task_t *task)
|
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
|
|
/* send RPC reply */ |
/* send RPC reply */ |
if (!noreply) | if (!noreply && (rpc->call_io & RPC_REQ)) |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
c, TASK_FD(task), rpc, len); |
c, TASK_FD(task), rpc, len); |
end: |
end: |
Line 907 rxBPFPacket(sched_task_t *task)
|
Line 932 rxBPFPacket(sched_task_t *task)
|
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
|
|
/* send RPC reply */ |
/* send RPC reply */ |
if (!noreply) | if (!noreply && (rpc->call_io & RPC_REQ)) |
schedEvent(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
schedEvent(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
c, TASK_FD(task), rpc, len); |
c, TASK_FD(task), rpc, len); |
end: |
end: |
Line 1037 rxEXTPacket(sched_task_t *task)
|
Line 1062 rxEXTPacket(sched_task_t *task)
|
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
schedEvent(TASK_ROOT(task), execCall, c, (int) noreply, rpc, len); |
|
|
/* send RPC reply */ |
/* send RPC reply */ |
if (!noreply) | if (!noreply && (rpc->call_io & RPC_REQ)) |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
schedWrite(TASK_ROOT(task), cbProto[srv->srv_proto][CB_TXPACKET], |
c, TASK_FD(task), rpc, len); |
c, TASK_FD(task), rpc, len); |
end: |
end: |
Line 1264 acceptBLOBClients(sched_task_t *task)
|
Line 1289 acceptBLOBClients(sched_task_t *task)
|
setsockopt(c->cli_sock, IPPROTO_TCP, TCP_NOPUSH, &n, sizeof n); |
setsockopt(c->cli_sock, IPPROTO_TCP, TCP_NOPUSH, &n, sizeof n); |
#endif |
#endif |
fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) | O_NONBLOCK); |
fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) | O_NONBLOCK); |
|
fcntl(c->cli_sock, F_SETFD, FD_CLOEXEC); |
} |
} |
|
|
schedRead(TASK_ROOT(task), rxBLOB, c, c->cli_sock, NULL, 0); |
schedRead(TASK_ROOT(task), rxBLOB, c, c->cli_sock, NULL, 0); |
Line 1555 rpc_srv_initServer(u_char InstID, int concurentClients
|
Line 1581 rpc_srv_initServer(u_char InstID, int concurentClients
|
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
e_free(srv); |
e_free(srv); |
return NULL; |
return NULL; |
} | } else |
| schedSignalDispatch(srv->srv_root, 42); |
|
|
/* init pool for clients */ |
/* init pool for clients */ |
srv->srv_clients = array_Init(concurentClients); |
srv->srv_clients = array_Init(concurentClients); |
Line 1677 rpc_srv_loopServer(rpc_srv_t * __restrict srv)
|
Line 1704 rpc_srv_loopServer(rpc_srv_t * __restrict srv)
|
schedPolling(srv->srv_root, &ts, NULL); |
schedPolling(srv->srv_root, &ts, NULL); |
/* main rpc loop */ |
/* main rpc loop */ |
schedRun(srv->srv_root, &srv->srv_kill); |
schedRun(srv->srv_root, &srv->srv_kill); |
|
schedSignalDispatch(srv->srv_root, 0); |
|
|
/* close all clients connections & server socket */ |
/* close all clients connections & server socket */ |
for (i = 0; i < array_Size(srv->srv_clients); i++) { |
for (i = 0; i < array_Size(srv->srv_clients); i++) { |
Line 1815 rpc_srv_initServer2(u_char InstID, int concurentClient
|
Line 1843 rpc_srv_initServer2(u_char InstID, int concurentClient
|
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
e_free(srv); |
e_free(srv); |
return NULL; |
return NULL; |
} | } else |
| schedSignalDispatch(srv->srv_root, 42); |
|
|
/* init pool for clients */ |
/* init pool for clients */ |
srv->srv_clients = array_Init(concurentClients); |
srv->srv_clients = array_Init(concurentClients); |
Line 1933 rpc_srv_initServerExt(u_char InstID, int netBuf, int f
|
Line 1962 rpc_srv_initServerExt(u_char InstID, int netBuf, int f
|
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
pthread_mutex_destroy(&srv->srv_funcs.mtx); |
e_free(srv); |
e_free(srv); |
return NULL; |
return NULL; |
} | } else |
| schedSignalDispatch(srv->srv_root, 42); |
|
|
/* init pool for clients */ |
/* init pool for clients */ |
srv->srv_clients = array_Init(1); |
srv->srv_clients = array_Init(1); |