reindent-20030715
[openafs.git] / src / rx / NBSD / rx_knet.c
index fb1a3e5..fee9c37 100644 (file)
 #include <afsconfig.h>
 #include "afs/param.h"
 
-RCSID("$Header$");
+RCSID
+    ("$Header$");
 
 #include "rx/rx_kcommon.h"
 
-int osi_NetReceive(osi_socket so, struct sockaddr_in *addr, struct iovec *dvec,
-        int nvecs, int *alength)
-{  
+int
+osi_NetReceive(osi_socket so, struct sockaddr_in *addr, struct iovec *dvec,
+              int nvecs, int *alength)
+{
     struct socket *asocket = (struct socket *)so;
     struct uio u;
     int i;
@@ -25,27 +27,27 @@ int osi_NetReceive(osi_socket so, struct sockaddr_in *addr, struct iovec *dvec,
     int code;
 
     int haveGlock = ISAFS_GLOCK();
-    /*AFS_STATCNT(osi_NetReceive);*/
+    /*AFS_STATCNT(osi_NetReceive); */
 
     if (nvecs > RX_MAXIOVECS) {
-        osi_Panic("osi_NetReceive: %d: Too many iovecs.\n", nvecs);
+       osi_Panic("osi_NetReceive: %d: Too many iovecs.\n", nvecs);
     }
 
-    for (i = 0 ; i < nvecs ; i++) {
-        iov[i].iov_base = dvec[i].iov_base;
-        iov[i].iov_len = dvec[i].iov_len;
+    for (i = 0; i < nvecs; i++) {
+       iov[i].iov_base = dvec[i].iov_base;
+       iov[i].iov_len = dvec[i].iov_len;
     }
 
-    u.uio_iov=&iov[0];
-    u.uio_iovcnt=nvecs;
-    u.uio_offset=0;
-    u.uio_resid=*alength;
-    u.uio_segflg=UIO_SYSSPACE; 
-    u.uio_rw=UIO_READ;
-    u.uio_procp=NULL;  
+    u.uio_iov = &iov[0];
+    u.uio_iovcnt = nvecs;
+    u.uio_offset = 0;
+    u.uio_resid = *alength;
+    u.uio_segflg = UIO_SYSSPACE;
+    u.uio_rw = UIO_READ;
+    u.uio_procp = NULL;
 
-    if (haveGlock) { 
-        AFS_GUNLOCK();
+    if (haveGlock) {
+       AFS_GUNLOCK();
     }
 #if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
     thread_funnel_switch(KERNEL_FUNNEL, NETWORK_FUNNEL);
@@ -55,34 +57,36 @@ int osi_NetReceive(osi_socket so, struct sockaddr_in *addr, struct iovec *dvec,
     thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
 #endif
     if (haveGlock) {
-        AFS_GLOCK();
+       AFS_GLOCK();
     }
-    *alength=*alength-u.uio_resid;
+    *alength = *alength - u.uio_resid;
     if (sa) {
-       if (sa->sa_family == AF_INET) {
-          if (addr) *addr=*(struct sockaddr_in *)sa;
-       } else {
-          printf("Unknown socket family %d in NetReceive\n");
-       }
+       if (sa->sa_family == AF_INET) {
+           if (addr)
+               *addr = *(struct sockaddr_in *)sa;
+       } else {
+           printf("Unknown socket family %d in NetReceive\n");
+       }
     }
     return code;
 }
 
 extern int rxk_ListenerPid;
-void osi_StopListener(void)
+void
+osi_StopListener(void)
 {
-   struct proc *p;
+    struct proc *p;
 
 #if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
     thread_funnel_switch(KERNEL_FUNNEL, NETWORK_FUNNEL);
 #endif
-   soclose(rx_socket);
+    soclose(rx_socket);
 #if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
     thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
 #endif
-   p=pfind(rxk_ListenerPid); 
-   if (p)
-       psignal(p, SIGUSR1);
+    p = pfind(rxk_ListenerPid);
+    if (p)
+       psignal(p, SIGUSR1);
 }
 
 /* rx_NetSend - send asize bytes at adata from asocket to host at addr.
@@ -103,8 +107,8 @@ void osi_StopListener(void)
 
 
 int
-osi_NetSend(osi_socket asocket, struct sockaddr_in *addr,
-           struct iovec *dvec, int nvecs, afs_int32 alength, int istack)
+osi_NetSend(osi_socket asocket, struct sockaddr_in *addr, struct iovec *dvec,
+           int nvecs, afs_int32 alength, int istack)
 {
     register afs_int32 code;
     int s;
@@ -118,37 +122,37 @@ osi_NetSend(osi_socket asocket, struct sockaddr_in *addr,
 
     AFS_STATCNT(osi_NetSend);
     if (nvecs > RX_MAXIOVECS) {
-        osi_Panic("osi_NetSend: %d: Too many iovecs.\n", nvecs);
-    } 
-
-    for (i = 0 ; i < nvecs ; i++) {
-        iov[i].iov_base = dvec[i].iov_base; 
-        iov[i].iov_len = dvec[i].iov_len; 
-    } 
-
-    u.uio_iov=&iov[0];
-    u.uio_iovcnt=nvecs;
-    u.uio_offset=0;
-    u.uio_resid=alength;
-    u.uio_segflg=UIO_SYSSPACE;
-    u.uio_rw=UIO_WRITE;
-    u.uio_procp=NULL;
+       osi_Panic("osi_NetSend: %d: Too many iovecs.\n", nvecs);
+    }
+
+    for (i = 0; i < nvecs; i++) {
+       iov[i].iov_base = dvec[i].iov_base;
+       iov[i].iov_len = dvec[i].iov_len;
+    }
+
+    u.uio_iov = &iov[0];
+    u.uio_iovcnt = nvecs;
+    u.uio_offset = 0;
+    u.uio_resid = alength;
+    u.uio_segflg = UIO_SYSSPACE;
+    u.uio_rw = UIO_WRITE;
+    u.uio_procp = NULL;
     if (haveGlock) {
        AFS_GUNLOCK();
     }
 #if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
     thread_funnel_switch(KERNEL_FUNNEL, NETWORK_FUNNEL);
 #endif
-    nam=m_get(M_DONTWAIT, MT_SONAME);
+    nam = m_get(M_DONTWAIT, MT_SONAME);
     if (nam == NULL) {
-        code=ENOBUFS;
-        goto bad;
+       code = ENOBUFS;
+       goto bad;
     }
-    nam->m_len=addr->sin_len=sizeof(struct sockaddr_in);
-    memcpy(mtod(nam, caddr_t), (caddr_t)addr, addr->sin_len);
+    nam->m_len = addr->sin_len = sizeof(struct sockaddr_in);
+    memcpy(mtod(nam, caddr_t), (caddr_t) addr, addr->sin_len);
     code = sosend(asocket, mtod(nam, struct sockaddr *), &u, NULL, NULL, 0);
     m_freem(nam);
-bad:
+  bad:
 #if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
     thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
 #endif