From a7f8f90ddc33e09c1e8f31a465ef857f26f98323 Mon Sep 17 00:00:00 2001
From: Jeff Hill <johill@lanl.gov>
Date: Thu, 24 May 2001 21:14:40 +0000
Subject: [PATCH] restart sendto system call if it is interrupted

---
 src/rsrv/caserverio.c | 88 ++++++++++++++++++++++---------------------
 1 file changed, 45 insertions(+), 43 deletions(-)

diff --git a/src/rsrv/caserverio.c b/src/rsrv/caserverio.c
index 31efe0f14..34c72367e 100644
--- a/src/rsrv/caserverio.c
+++ b/src/rsrv/caserverio.c
@@ -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);
     }