epics/pcas
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

restart sendto system call if it is interrupted

Browse Source
This commit is contained in:
Jeff Hill
2001-05-24 21:14:40 +00:00
parent 8d1e2327df
commit a7f8f90ddc
1 changed files with 45 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/rsrv/caserverio.c
+45 -43
View File
@@ -68,55 +68,57 @@ void cas_send_msg ( struct client *pclient, int lock_needed )
SEND_LOCK ( pclient );
}
if ( pclient->send.stk ) {
status = sendto (pclient->sock, pclient->send.buf, pclient->send.stk, 0,
(struct sockaddr *)&pclient->addr, sizeof(pclient->addr));
if ( pclient->send.stk != (unsigned)status) {
if (status < 0) {
int anerrno;
char buf[64];
anerrno = SOCKERRNO;
ipAddrToDottedIP (&pclient->addr, buf, sizeof(buf));
if(pclient->proto == IPPROTO_TCP) {
if ( (anerrno!=SOCK_ECONNABORTED&&
anerrno!=SOCK_ECONNRESET&&
anerrno!=SOCK_EPIPE&&
anerrno!=SOCK_ETIMEDOUT)||
CASDEBUG>2){
errlogPrintf (
"CAS: TCP send to \"%s\" failed because \"%s\"\n",
buf, SOCKERRSTR(anerrno));
}
pclient->disconnect = TRUE;
}
else if (pclient->proto == IPPROTO_UDP) {
errlogPrintf(
"CAS: UDP send to \"%s\" failed because \"%s\"\n",
(int)buf,
(int)SOCKERRSTR(anerrno));
}
else {
assert (0);
}
while ( pclient->send.stk ) {
status = sendto ( pclient->sock, pclient->send.buf, pclient->send.stk, 0,
(struct sockaddr *)&pclient->addr, sizeof(pclient->addr) );
if ( status >= 0 ) {
unsigned transferSize = (unsigned) status;
if ( transferSize >= pclient->send.stk ) {
pclient->send.stk = 0;
epicsTimeGetCurrent (&pclient->time_at_last_send);
break;
}
else{
errlogPrintf(
"CAS: blk sock partial send: req %d sent %d \n",
pclient->send.stk,
status);
else {
unsigned bytesLeft = pclient->send.stk - transferSize;
memmove ( pclient->send.buf, &pclient->send.buf[transferSize],
bytesLeft );
pclient->send.stk = bytesLeft;
}
}
else {
int anerrno = SOCKERRNO;
char buf[64];
pclient->send.stk = 0;
epicsTimeGetCurrent (&pclient->time_at_last_send);
ipAddrToDottedIP ( &pclient->addr, buf, sizeof(buf) );
if(pclient->proto == IPPROTO_TCP) {
if ( (anerrno!=SOCK_ECONNABORTED&&
anerrno!=SOCK_ECONNRESET&&
anerrno!=SOCK_EPIPE&&
anerrno!=SOCK_ETIMEDOUT)||
CASDEBUG>2){
errlogPrintf (
"CAS: TCP send to \"%s\" failed because \"%s\"\n",
buf, SOCKERRSTR(anerrno));
}
pclient->disconnect = TRUE;
}
else if (pclient->proto == IPPROTO_UDP) {
errlogPrintf(
"CAS: UDP send to \"%s\" failed because \"%s\"\n",
(int)buf,
(int)SOCKERRSTR(anerrno));
}
else {
assert (0);
}
pclient->send.stk = 0u;
break;
}
}
if(lock_needed){
if ( lock_needed ) {
SEND_UNLOCK(pclient);
}