rx: Introduce rxi_NetSend

[openafs.git] / src / afs / afs_mariner.c

diff --git a/src/afs/afs_mariner.c b/src/afs/afs_mariner.c
index 022640b..0ae4d3c 100644 (file)
--- a/src/afs/afs_mariner.c
+++ b/src/afs/afs_mariner.c
@@ -1,7 +1,7 @@
 /*
  * Copyright 2000, International Business Machines Corporation and others.
  * All Rights Reserved.
- * 
+ *
  * This software has been released under the terms of the IBM Public
  * License.  For details, see the LICENSE file in the top-level source
  * directory or online at http://www.openafs.org/dl/license10.html
@@ -14,20 +14,19 @@
  * Implements:
  */
 #include <afsconfig.h>
-#include "../afs/param.h"
+#include "afs/param.h"
 
-RCSID("$Header$");
 
-#include "../afs/sysincludes.h" /*Standard vendor system headers*/
-#include "../afs/afsincludes.h" /*AFS-based standard headers*/
-#include "../afs/afs_stats.h"  /* statistics */
+#include "afs/sysincludes.h"   /*Standard vendor system headers */
+#include "afsincludes.h"       /*AFS-based standard headers */
+#include "afs/afs_stats.h"     /* statistics */
 
 /* Exported variables */
 struct rx_service *afs_server;
 
 
-#define        SMAR        20                  /* size of a mariner name */
-#define        NMAR        10                  /* number of mariner names */
+#define        SMAR        20          /* size of a mariner name */
+#define        NMAR        10          /* number of mariner names */
 static char marinerNames[NMAR][SMAR];
 static struct vcache *marinerVCs[NMAR];
 static int marinerPtr = 0;     /* pointer to next mariner slot to use */
@@ -36,10 +35,11 @@ static int marinerPtr = 0;  /* pointer to next mariner slot to use */
 afs_int32 afs_mariner = 0;
 afs_int32 afs_marinerHost = 0;
 
-int afs_AddMarinerName(register char *aname, register struct vcache *avc)
+int
+afs_AddMarinerName(char *aname, struct vcache *avc)
 {
-    register int i;
-    register char *tp;
+    int i;
+    char *tp;
 
     AFS_STATCNT(afs_AddMarinerName);
     i = marinerPtr++;
@@ -49,16 +49,17 @@ int afs_AddMarinerName(register char *aname, register struct vcache *avc)
     }
     tp = marinerNames[i];
     strncpy(tp, aname, SMAR);
-    tp[SMAR-1] = 0;
+    tp[SMAR - 1] = 0;
     marinerVCs[i] = avc;
     return 0;
 }
 
-char *afs_GetMariner(register struct vcache *avc)
+char *
+afs_GetMariner(struct vcache *avc)
 {
-    register int i;
+    int i;
     AFS_STATCNT(afs_GetMariner);
-    for(i=0; i<NMAR; i++) {
+    for (i = 0; i < NMAR; i++) {
        if (marinerVCs[i] == avc) {
            return marinerNames[i];
        }
@@ -66,44 +67,18 @@ char *afs_GetMariner(register struct vcache *avc)
     return "a file";
 }
 
-void afs_MarinerLogFetch(register struct vcache *avc, register afs_int32 off, 
-       register afs_int32 bytes, register afs_int32 idx)
+void
+afs_MarinerLogFetch(struct vcache *avc, afs_int32 off,
+                   afs_int32 bytes, afs_int32 idx)
 {
-    struct sockaddr_in taddr;
-    register char *tp, *tp1, *tp2;
-    struct iovec dvec;
-    int len;
-
-
-    AFS_STATCNT(afs_MarinerLog);
-    taddr.sin_family = AF_INET;
-    taddr.sin_addr.s_addr = afs_marinerHost;
-    taddr.sin_port = htons(2106);
-#ifdef  STRUCT_SOCKADDR_HAS_SA_LEN
-    taddr.sin_len = sizeof(taddr);
-#endif  /* AFS_OSF_ENV */
-    tp = tp1 = (char *) osi_AllocSmallSpace(AFS_SMALLOCSIZ);
-    strcpy(tp, "fetch$Fetching ");
-    tp += 15; /* change it if string changes */
-    tp2 = afs_GetMariner(avc);
-    strcpy(tp, tp2);
-    tp += strlen(tp2);
-    *tp++ = '\n';
-    /* note, console doesn't want a terminating null */
-    len = strlen(tp1) - 1;
-    /* I don't care if mariner packets fail to be sent */
-    dvec.iov_base = tp1;
-    dvec.iov_len = len;
-    AFS_GUNLOCK();
-    (void) osi_NetSend(afs_server->socket, &taddr, &dvec, 1, len, 0);
-    AFS_GLOCK();
-    osi_FreeSmallSpace(tp1);
-} /*afs_MarinerLogFetch*/
+    afs_MarinerLog("fetch$Fetching", avc);
+}                              /*afs_MarinerLogFetch */
 
-void afs_MarinerLog(register char *astring, register struct vcache *avc)
+void
+afs_MarinerLog(char *astring, struct vcache *avc)
 {
     struct sockaddr_in taddr;
-    register char *tp, *tp1, *buf;
+    char *tp, *tp1, *buf;
     struct iovec dvec;
 
     AFS_STATCNT(afs_MarinerLog);
@@ -112,59 +87,36 @@ void afs_MarinerLog(register char *astring, register struct vcache *avc)
     taddr.sin_port = htons(2106);
 #ifdef  STRUCT_SOCKADDR_HAS_SA_LEN
     taddr.sin_len = sizeof(taddr);
-#endif  /* AFS_OSF_ENV */
-    tp = buf = (char *) osi_AllocSmallSpace(AFS_SMALLOCSIZ);
+#endif
+    tp = buf = osi_AllocSmallSpace(AFS_SMALLOCSIZ);
 
     strcpy(tp, astring);
     tp += strlen(astring);
-    *tp++ = ' ';
-    tp1 = afs_GetMariner(avc);
-    strcpy(tp, tp1);
-    tp += strlen(tp1);
+    if (avc) {
+       *tp++ = ' ';
+       tp1 = afs_GetMariner(avc);
+       strcpy(tp, tp1);
+       tp += strlen(tp1);
+    }
     *tp++ = '\n';
     /* note, console doesn't want a terminating null */
     /* I don't care if mariner packets fail to be sent */
     dvec.iov_base = buf;
-    dvec.iov_len = tp-buf;
+    dvec.iov_len = tp - buf;
     AFS_GUNLOCK();
-    (void) osi_NetSend(afs_server->socket, &taddr, &dvec, 1, tp-buf, 0);
+    (void)rxi_NetSend(afs_server->socket, &taddr, &dvec, 1, tp - buf, 0);
     AFS_GLOCK();
     osi_FreeSmallSpace(buf);
-} /*afs_MarinerLog*/
+}                              /*afs_MarinerLog */
 
-void shutdown_mariner(void)
+void
+shutdown_mariner(void)
 {
     int i;
 
     marinerPtr = 0;
     afs_mariner = 0;
 
-    for (i=0; i<NMAR; i++)
+    for (i = 0; i < NMAR; i++)
        marinerVCs[i] = 0;
 }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-