libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

version 1.21.2.2, 2013/11/14 23:38:41	version 1.21.2.3, 2013/11/15 00:21:46
Line 537 rxUDPPacket(sched_task_t *task)	Line 537 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");
	usleep(2000); /* blocked client delay */
goto end;	goto end;
else {	} else {
estlen = ntohl(rpc->call_len);	estlen = ntohl(rpc->call_len);
if (estlen > AIT_LEN(&c->cli_buf))	if (estlen > AIT_LEN(&c->cli_buf))
AIT_RE_BUF(&c->cli_buf, estlen);	AIT_RE_BUF(&c->cli_buf, estlen);
Line 571 rxUDPPacket(sched_task_t *task)	Line 573 rxUDPPacket(sched_task_t *task)
c, 0, NULL, 0);	c, 0, NULL, 0);
return NULL;	return NULL;
}	}
	salen = sa.ss.ss_len = sizeof(sockaddr_t);
rlen = recvfrom(TASK_FD(task), buf, len, 0, &sa.sa, &salen);	rlen = recvfrom(TASK_FD(task), buf, len, 0, &sa.sa, &salen);
if (rlen == -1) {	if (rlen == -1) {
/* close connection */	/* close connection */
Line 578 rxUDPPacket(sched_task_t *task)	Line 581 rxUDPPacket(sched_task_t *task)
c, 0, NULL, 0);	c, 0, NULL, 0);
return NULL;	return NULL;
}	}
	if (e_addrcmp(&c->cli_sa, &sa, 42))
	rlen ^= rlen; /* skip if arrive from different address */
}	}
len = estlen;	len = estlen;