--- libaitrpc/src/srv.c 2013/11/14 23:38:41 1.21.2.2 +++ libaitrpc/src/srv.c 2013/11/15 00:21:46 1.21.2.3 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: srv.c,v 1.21.2.2 2013/11/14 23:38:41 misho Exp $ +* $Id: srv.c,v 1.21.2.3 2013/11/15 00:21:46 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -537,9 +537,11 @@ rxUDPPacket(sched_task_t *task) } c = _allocClient(srv, &sa); - if (!c) + if (!c) { + EVERBOSE(1, "RPC client quota exceeded! Connection will be shutdown!\n"); + usleep(2000); /* blocked client delay */ goto end; - else { + } else { estlen = ntohl(rpc->call_len); if (estlen > AIT_LEN(&c->cli_buf)) AIT_RE_BUF(&c->cli_buf, estlen); @@ -571,6 +573,7 @@ rxUDPPacket(sched_task_t *task) c, 0, NULL, 0); return NULL; } + salen = sa.ss.ss_len = sizeof(sockaddr_t); rlen = recvfrom(TASK_FD(task), buf, len, 0, &sa.sa, &salen); if (rlen == -1) { /* close connection */ @@ -578,6 +581,8 @@ rxUDPPacket(sched_task_t *task) c, 0, NULL, 0); return NULL; } + if (e_addrcmp(&c->cli_sa, &sa, 42)) + rlen ^= rlen; /* skip if arrive from different address */ } len = estlen;