DARWIN: Fix processing using rx_ifaddr_* macros in afsi_SetServerIPRank()
[openafs.git] / src / afs / afs_server.c
index f5e25cf..086ab4d 100644 (file)
@@ -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
  * afsi_SetServerIPRank
  * afs_GetServer
  * afs_ActivateServer
- * 
+ *
  *
  * Local:
  * HaveCallBacksFrom
  * CheckVLServer
  * afs_SortOneServer
  * afs_SetServerPrefs
- * 
+ *
  */
 #include <afsconfig.h>
 #include "afs/param.h"
@@ -130,8 +130,8 @@ GetUpDownStats(struct server *srv)
 void
 afs_MarkServerUpOrDown(struct srvAddr *sa, int a_isDown)
 {
-    register struct server *a_serverP = sa->server;
-    register struct srvAddr *sap;
+    struct server *a_serverP = sa->server;
+    struct srvAddr *sap;
     osi_timeval_t currTime, *currTimeP;        /*Current time */
     afs_int32 downTime;                /*Computed downtime, in seconds */
     struct afs_stats_SrvUpDownInfo *upDownP;   /*Ptr to up/down info record */
@@ -153,7 +153,7 @@ afs_MarkServerUpOrDown(struct srvAddr *sa, int a_isDown)
                return;
            }
        }
-       /* 
+       /*
         * All ips are down we treat the whole server down
         */
        a_serverP->flags |= SRVR_ISDOWN;
@@ -240,10 +240,10 @@ afs_MarkServerUpOrDown(struct srvAddr *sa, int a_isDown)
 afs_int32
 afs_ServerDown(struct srvAddr *sa)
 {
-    register struct server *aserver = sa->server;
+    struct server *aserver = sa->server;
 
     AFS_STATCNT(ServerDown);
-    if (aserver->flags & SRVR_ISDOWN || sa->sa_flags & SRVADDR_ISDOWN) 
+    if (aserver->flags & SRVR_ISDOWN || sa->sa_flags & SRVADDR_ISDOWN)
        return 0;
     afs_MarkServerUpOrDown(sa, SRVR_ISDOWN);
     if (sa->sa_portal == aserver->cell->vlport)
@@ -260,9 +260,9 @@ afs_ServerDown(struct srvAddr *sa)
 int
 afs_HaveCallBacksFrom(struct server *aserver)
 {
-    register afs_int32 now;
-    register int i;
-    register struct vcache *tvc;
+    afs_int32 now;
+    int i;
+    struct vcache *tvc;
 
     AFS_STATCNT(HaveCallBacksFrom);
     now = osi_Time();          /* for checking for expired callbacks */
@@ -283,11 +283,11 @@ afs_HaveCallBacksFrom(struct server *aserver)
 
 
 static void
-CheckVLServer(register struct srvAddr *sa, struct vrequest *areq)
+CheckVLServer(struct srvAddr *sa, struct vrequest *areq)
 {
-    register struct server *aserver = sa->server;
-    register struct afs_conn *tc;
-    register afs_int32 code;
+    struct server *aserver = sa->server;
+    struct afs_conn *tc;
+    afs_int32 code;
 
     AFS_STATCNT(CheckVLServer);
     /* Ping dead servers to see if they're back */
@@ -422,7 +422,7 @@ afs_CountServers(void)
 
            /*
             * Any further tallying for this record will only be done if it has
-            * been activated. 
+            * been activated.
             */
            if ((currSrvP->flags & AFS_SERVER_FLAG_ACTIVATED)
                && currSrvP->addr && currSrvP->cell) {
@@ -505,6 +505,7 @@ ForceAllNewConnections(void)
     }
 
     addrs = afs_osi_Alloc(srvAddrCount * sizeof(*addrs));
+    osi_Assert(addrs != NULL);
     j = 0;
     for (i = 0; i < NSERVERS; i++) {
        for (sa = afs_srvAddrs[i]; sa; sa = sa->next_bkt) {
@@ -540,12 +541,13 @@ afs_CheckServers(int adown, struct cell *acellp)
     struct srvAddr **addrs;
     struct afs_conn **conns;
     int nconns;
-    struct rx_connection **rxconns;      
+    struct rx_connection **rxconns;
     afs_int32 *conntimer, *deltas, *results;
+    Capabilities *caps = NULL;
 
     AFS_STATCNT(afs_CheckServers);
 
-    /* 
+    /*
      * No sense in doing the server checks if we are running in disconnected
      * mode
      */
@@ -570,6 +572,7 @@ afs_CheckServers(int adown, struct cell *acellp)
     }
 
     addrs = afs_osi_Alloc(srvAddrCount * sizeof(*addrs));
+    osi_Assert(addrs != NULL);
     j = 0;
     for (i = 0; i < NSERVERS; i++) {
        for (sa = afs_srvAddrs[i]; sa; sa = sa->next_bkt) {
@@ -582,11 +585,20 @@ afs_CheckServers(int adown, struct cell *acellp)
     ReleaseReadLock(&afs_xsrvAddr);
     ReleaseReadLock(&afs_xserver);
 
-    conns = (struct afs_conn **)afs_osi_Alloc(j * sizeof(struct afs_conn *));
-    rxconns = (struct rx_connection **)afs_osi_Alloc(j * sizeof(struct rx_connection *));
-    conntimer = (afs_int32 *)afs_osi_Alloc(j * sizeof (afs_int32));
-    deltas = (afs_int32 *)afs_osi_Alloc(j * sizeof (afs_int32));
-    results = (afs_int32 *)afs_osi_Alloc(j * sizeof (afs_int32));
+    conns = afs_osi_Alloc(j * sizeof(struct afs_conn *));
+    osi_Assert(conns != NULL);
+    rxconns = afs_osi_Alloc(j * sizeof(struct rx_connection *));
+    osi_Assert(rxconns != NULL);
+    conntimer = afs_osi_Alloc(j * sizeof (afs_int32));
+    osi_Assert(conntimer != NULL);
+    deltas = afs_osi_Alloc(j * sizeof (afs_int32));
+    osi_Assert(deltas != NULL);
+    results = afs_osi_Alloc(j * sizeof (afs_int32));
+    osi_Assert(results != NULL);
+
+    caps = afs_osi_Alloc(j * sizeof (Capabilities));
+    osi_Assert(caps != NULL);
+    memset(caps, 0, j * sizeof(Capabilities));
 
     for (i = 0; i < j; i++) {
        deltas[i] = 0;
@@ -624,7 +636,7 @@ afs_CheckServers(int adown, struct cell *acellp)
 
        if ((sa->sa_flags & SRVADDR_ISDOWN) || afs_HaveCallBacksFrom(sa->server)
            || (tc->srvr->server == afs_setTimeHost)) {
-           conns[nconns]=tc; 
+           conns[nconns]=tc;
            rxconns[nconns]=tc->id;
            if (sa->sa_flags & SRVADDR_ISDOWN) {
                rx_SetConnDeadTime(tc->id, 3);
@@ -636,38 +648,87 @@ afs_CheckServers(int adown, struct cell *acellp)
        }
     } /* Outer loop over addrs */
 
-    start = osi_Time();         /* time the gettimeofday call */
-    AFS_GUNLOCK(); 
+    AFS_GUNLOCK();
     multi_Rx(rxconns,nconns)
       {
-       tv.tv_sec = tv.tv_usec = 0;
-       multi_RXAFS_GetTime((afs_uint32 *)&tv.tv_sec, (afs_uint32 *)&tv.tv_usec);
-       tc = conns[multi_i];
-       sa = tc->srvr;
-       if (conntimer[multi_i] == 1)
-         rx_SetConnDeadTime(tc->id, afs_rx_deadtime);
-       end = osi_Time();
-       results[multi_i]=multi_error;
-       if ((start == end) && !multi_error)
-         deltas[multi_i] = end - tv.tv_sec;
-       
+       multi_RXAFS_GetCapabilities(&caps[multi_i]);
+       results[multi_i] = multi_error;
       } multi_End;
-    AFS_GLOCK(); 
-    
+    AFS_GLOCK();
+
+    for ( i = 0 ; i < nconns ; i++ ) {
+       ts = addrs[i]->server;
+       if ( !ts )
+           continue;
+       ts->capabilities = 0;
+       ts->flags |= SCAPS_KNOWN;
+       if ( results[i] == RXGEN_OPCODE ) {
+           /* Mark server as up - it responded */
+           results[i] = 0;
+           continue;
+       }
+       if ( results[i] >= 0 )
+           /* we currently handle 32-bits of capabilities */
+           if (caps[i].Capabilities_len > 0) {
+               ts->capabilities = caps[i].Capabilities_val[0];
+               xdr_free((xdrproc_t)xdr_Capabilities, &caps[i]);
+               caps[i].Capabilities_val = NULL;
+               caps[i].Capabilities_len = 0;
+           }
+    }
+
+    if ( afs_setTime != 0 ) {
+       start = osi_Time();         /* time the gettimeofday call */
+       AFS_GUNLOCK();
+       if ( afs_setTimeHost == NULL ) {
+           multi_Rx(rxconns,nconns)
+             {
+               tv.tv_sec = tv.tv_usec = 0;
+               multi_RXAFS_GetTime(
+                       (afs_uint32 *)&tv.tv_sec, (afs_uint32 *)&tv.tv_usec);
+               tc = conns[multi_i];
+               sa = tc->srvr;
+               if (conntimer[multi_i] == 1)
+                 rx_SetConnDeadTime(tc->id, afs_rx_deadtime);
+               end = osi_Time();
+               results[multi_i]=multi_error;
+               if ((start == end) && !multi_error)
+                 deltas[multi_i] = end - tv.tv_sec;
+
+             } multi_End;
+           }
+       else {                  /* find and query setTimeHost only */
+           for ( i = 0 ; i < j ; i++ ) {
+               if ( conns[i] == NULL || conns[i]->srvr == NULL )
+                   continue;
+               if ( conns[i]->srvr->server == afs_setTimeHost ) {
+                   tv.tv_sec = tv.tv_usec = 0;
+                   results[i] = RXAFS_GetTime(rxconns[i],
+                               (afs_uint32 *)&tv.tv_sec, (afs_uint32 *)&tv.tv_usec);
+                   end = osi_Time();
+                   if ((start == end) && !results[i])
+                       deltas[i] = end - tv.tv_sec;
+                   break;
+               }
+           }
+       }
+       AFS_GLOCK();
+    }
+
     for(i=0;i<nconns;i++){
       tc = conns[i];
       sa = tc->srvr;
-      
+
       if (( results[i] >= 0 ) && (sa->sa_flags & SRVADDR_ISDOWN) && (tc->srvr == sa)) {
        /* server back up */
        print_internet_address("afs: file server ", sa, " is back up", 2);
-       
+
        ObtainWriteLock(&afs_xserver, 244);
-       ObtainWriteLock(&afs_xsrvAddr, 245);        
+       ObtainWriteLock(&afs_xsrvAddr, 245);
        afs_MarkServerUpOrDown(sa, 0);
        ReleaseWriteLock(&afs_xsrvAddr);
        ReleaseWriteLock(&afs_xserver);
-       
+
        if (afs_waitForeverCount) {
          afs_osi_Wakeup(&afs_waitForever);
        }
@@ -691,7 +752,7 @@ afs_CheckServers(int adown, struct cell *acellp)
            delta = deltas[i];
            tc = conns[i];
            sa = tc->srvr;
-           
+
            if ((tc->srvr->server == afs_setTimeHost ||
                 /* Sync only to a server in the local cell */
                 (afs_setTimeHost == (struct server *)0 &&
@@ -699,7 +760,7 @@ afs_CheckServers(int adown, struct cell *acellp)
                /* set the time */
                char msgbuf[90];  /* strlen("afs: setting clock...") + slop */
                delta = end - tv.tv_sec;   /* how many secs fast we are */
-               
+
                afs_setTimeHost = tc->srvr->server;
                /* see if clock has changed enough to make it worthwhile */
                if (delta >= AFS_MINCHANGE || delta <= -AFS_MINCHANGE) {
@@ -714,33 +775,33 @@ afs_CheckServers(int adown, struct cell *acellp)
                    if (delta > 0) {
                        strcpy(msgbuf, "afs: setting clock back ");
                        if (delta > AFS_MAXCHANGEBACK) {
-                           afs_strcat(msgbuf, 
-                                      afs_cv2string(&tbuffer[CVBS], 
+                           afs_strcat(msgbuf,
+                                      afs_cv2string(&tbuffer[CVBS],
                                                     AFS_MAXCHANGEBACK));
                            afs_strcat(msgbuf, " seconds (of ");
-                           afs_strcat(msgbuf, 
-                                      afs_cv2string(&tbuffer[CVBS], 
-                                                    delta - 
+                           afs_strcat(msgbuf,
+                                      afs_cv2string(&tbuffer[CVBS],
+                                                    delta -
                                                     AFS_MAXCHANGEBACK));
                            afs_strcat(msgbuf, ", via ");
-                           print_internet_address(msgbuf, sa, 
+                           print_internet_address(msgbuf, sa,
                                                   "); clock is still fast.",
                                                   0);
                        } else {
-                           afs_strcat(msgbuf, 
+                           afs_strcat(msgbuf,
                                       afs_cv2string(&tbuffer[CVBS], delta));
                            afs_strcat(msgbuf, " seconds (via ");
                            print_internet_address(msgbuf, sa, ").", 0);
                        }
                    } else {
                        strcpy(msgbuf, "afs: setting clock ahead ");
-                       afs_strcat(msgbuf, 
+                       afs_strcat(msgbuf,
                                   afs_cv2string(&tbuffer[CVBS], -delta));
                        afs_strcat(msgbuf, " seconds (via ");
                        print_internet_address(msgbuf, sa, ").", 0);
                    }
                     /* We're only going to set it once; why bother looping? */
-                   break; 
+                   break;
                }
            }
        }
@@ -748,14 +809,15 @@ afs_CheckServers(int adown, struct cell *acellp)
     for (i = 0; i < nconns; i++) {
        afs_PutConn(conns[i], SHARED_LOCK);     /* done with it now */
     }
-    
+
     afs_osi_Free(addrs, srvAddrCount * sizeof(*addrs));
     afs_osi_Free(conns, j * sizeof(struct afs_conn *));
     afs_osi_Free(rxconns, j * sizeof(struct rx_connection *));
     afs_osi_Free(conntimer, j * sizeof(afs_int32));
     afs_osi_Free(deltas, j * sizeof(afs_int32));
     afs_osi_Free(results, j * sizeof(afs_int32));
-    
+    afs_osi_Free(caps, j * sizeof(Capabilities));
+
 } /*afs_CheckServers*/
 
 
@@ -802,19 +864,19 @@ afs_FindServer(afs_int32 aserver, afs_uint16 aport, afsUUID * uuidp,
 
 /* Rules:
    X = (aX + c) % m
-   m is a power of two 
+   m is a power of two
    a % 8 is 5
    a is 0.73m  should be 0.01m .. 0.99m
    c is more or less immaterial.  1 or a is suggested.
-  
+
 NB:  LOW ORDER BITS are not very random.  To get small random numbers,
-     treat result as <1, with implied binary point, and multiply by 
+     treat result as <1, with implied binary point, and multiply by
      desired modulus.
 NB:  Has to be unsigned, since shifts on signed quantities may preserve
      the sign bit.
 */
-/* added rxi_getaddr() to try to get as much initial randomness as 
-   possible, since at least one customer reboots ALL their clients 
+/* added rxi_getaddr() to try to get as much initial randomness as
+   possible, since at least one customer reboots ALL their clients
    simultaneously -- so osi_Time is bound to be the same on some of the
    clients.  This is probably OK, but I don't want to see too much of it.
 */
@@ -825,7 +887,7 @@ unsigned int
 afs_random(void)
 {
     static afs_int32 state = 0;
-    register int i;
+    int i;
 
     AFS_STATCNT(afs_random);
     if (!state) {
@@ -850,7 +912,7 @@ afs_random(void)
 /* returns int 0..14 using the high bits of a pseudo-random number instead of
    the low bits, as the low bits are "less random" than the high ones...
    slight roundoff error exists, an excercise for the reader.
-   need to multiply by something with lots of ones in it, so multiply by 
+   need to multiply by something with lots of ones in it, so multiply by
    8 or 16 is right out.
  */
 int
@@ -939,7 +1001,7 @@ afs_SortServers(struct server *aservers[], int count)
 }                              /*afs_SortServers */
 
 /* afs_SetServerPrefs is rather system-dependent.  It pokes around in kernel
-   data structures to determine what the local IP addresses and subnet masks 
+   data structures to determine what the local IP addresses and subnet masks
    are in order to choose which server(s) are on the local subnet.
 
    As I see it, there are several cases:
@@ -951,19 +1013,19 @@ afs_SortServers(struct server *aservers[], int count)
    4. The server is on a different logical subnet or net than this host, but
    this host is a 'metric 0 gateway' to it.  Ie, two address-spaces share
    one physical medium.
-   5. This host has a direct (point-to-point, ie, PPP or SLIP) link to the 
+   5. This host has a direct (point-to-point, ie, PPP or SLIP) link to the
    server.
    6. This host and the server are disjoint.
 
    That is a rough order of preference.  If a point-to-point link has a high
-   metric, I'm assuming that it is a very slow link, and putting it at the 
-   bottom of the list (at least until RX works better over slow links).  If 
-   its metric is 1, I'm assuming that it's relatively fast (T1) and putting 
+   metric, I'm assuming that it is a very slow link, and putting it at the
+   bottom of the list (at least until RX works better over slow links).  If
+   its metric is 1, I'm assuming that it's relatively fast (T1) and putting
    it ahead of #6.
    It's not easy to check for case #4, so I'm ignoring it for the time being.
 
    BSD "if" code keeps track of some rough network statistics (cf 'netstat -i')
-   That could be used to prefer certain servers fairly easily.  Maybe some 
+   That could be used to prefer certain servers fairly easily.  Maybe some
    other time...
 
    NOTE: this code is very system-dependent, and very dependent on the TCP/IP
@@ -1092,8 +1154,8 @@ typedef struct ill_s {
 /*
  * The IP addresses and ranks are determined by afsd (in user space) and
  * passed into the kernel at startup time through the AFSOP_ADVISEADDR
- * system call. These are stored in the data structure 
- * called 'afs_cb_interface'. 
+ * system call. These are stored in the data structure
+ * called 'afs_cb_interface'.
  *
  * struct srvAddr *sa;         remote server
  * afs_int32 addr;                one of my local addr in net order
@@ -1179,9 +1241,7 @@ afsi_SetServerIPRank(struct srvAddr *sa, struct in_ifaddr *ifa)
 #define afs_min(A,B) ((A)<(B)) ? (A) : (B)
 #endif
 void
-afsi_SetServerIPRank(sa, ifa)
-     struct srvAddr *sa;
-     rx_ifaddr_t ifa;
+afsi_SetServerIPRank(struct srvAddr *sa, rx_ifaddr_t ifa)
 {
     struct sockaddr sout;
     struct sockaddr_in *sin;
@@ -1193,7 +1253,7 @@ afsi_SetServerIPRank(sa, ifa)
     if (rx_ifaddr_address_family(ifa) != AF_INET)
        return;
     t = rx_ifaddr_address(ifa, &sout, sizeof(sout));
-    if (t == 0) {
+    if (t != 0) {
        sin = (struct sockaddr_in *)&sout;
        myAddr = ntohl(sin->sin_addr.s_addr);   /* one of my IP addr in host order */
     } else {
@@ -1201,14 +1261,14 @@ afsi_SetServerIPRank(sa, ifa)
     }
     serverAddr = ntohl(sa->sa_ip);     /* server's IP addr in host order */
     t = rx_ifaddr_netmask(ifa, &sout, sizeof(sout));
-    if (t == 0) {
+    if (t != 0) {
        sin = (struct sockaddr_in *)&sout;
        subnetmask = ntohl(sin->sin_addr.s_addr);       /* subnet mask in host order */
     } else {
        subnetmask = 0;
     }
     t = rx_ifaddr_dstaddress(ifa, &sout, sizeof(sout));
-    if (t == 0) {
+    if (t != 0) {
        sin = (struct sockaddr_in *)&sout;
        myDstaddr = sin->sin_addr.s_addr;
     } else {
@@ -1256,14 +1316,16 @@ afsi_SetServerIPRank(sa, ifa)
 
 #ifdef AFS_SGI62_ENV
 static int
-
-  afsi_enum_set_rank(struct hashbucket *h, caddr_t mkey, caddr_t arg1,
-                    caddr_t arg2) {
+afsi_enum_set_rank(struct hashbucket *h, caddr_t mkey, caddr_t arg1,
+                  caddr_t arg2)
+{
     afsi_SetServerIPRank((struct srvAddr *)arg1, (struct in_ifaddr *)h);
     return 0;                  /* Never match, so we enumerate everyone */
 }
 #endif                         /* AFS_SGI62_ENV */
-static int afs_SetServerPrefs(struct srvAddr *sa) {
+static int
+afs_SetServerPrefs(struct srvAddr *sa)
+{
 #if     defined(AFS_USERSPACE_IP_ADDR)
     int i;
 
@@ -1304,7 +1366,7 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
 
 #ifdef notdef
        if (!s) {
-           if (afsifinfo[i].ipaddr != 0x7f000001) {    /* ignore loopback */
+           if (!rx_IsLoopbackAddr(afsifinfo[i].ipaddr)) {      /* ignore loopback */
                *cnt += 1;
                if (*cnt > 16)
                    return;
@@ -1338,7 +1400,7 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
             }
         }
     }
-    
+
     rw_exit(&afsifinfo_lock);
 #else
     for (ill = (struct ill_s *)*addr /*ill_g_headp */ ; ill;
@@ -1352,7 +1414,7 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
            subnet = ipif->ipif_local_addr & ipif->ipif_net_mask;
            subnetmask = ipif->ipif_net_mask;
            /*
-            * Generate the local net using the local address and 
+            * Generate the local net using the local address and
             * whate we know about Class A, B and C networks.
             */
            if (IN_CLASSA(ipif->ipif_local_addr)) {
@@ -1367,7 +1429,7 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
            net = ipif->ipif_local_addr & netmask;
 #ifdef notdef
            if (!s) {
-               if (ipif->ipif_local_addr != 0x7f000001) {      /* ignore loopback */
+               if (!rx_IsLoopbackAddr(ipif->ipif_local_addr)) {        /* ignore loopback */
                    *cnt += 1;
                    if (*cnt > 16)
                        return;
@@ -1512,6 +1574,13 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
        for (ifa = in_ifaddr.tqh_first; ifa; ifa = ifa->ia_list.tqe_next)
            afsi_SetServerIPRank(sa, ifa);
     }
+#elif defined(AFS_NBSD40_ENV)
+     {
+       extern struct in_ifaddrhead in_ifaddrhead;
+       struct in_ifaddr *ifa;
+       for (ifa = in_ifaddrhead.tqh_first; ifa; ifa = ifa->ia_list.tqe_next)
+           afsi_SetServerIPRank(sa, ifa);
+     }
 #else
     {
        struct in_ifaddr *ifa;
@@ -1542,7 +1611,9 @@ static int afs_SetServerPrefs(struct srvAddr *sa) {
  * clean up all other structures that may reference it.
  * The afs_xserver and afs_xsrvAddr locks are assumed taken.
  */
-void afs_FlushServer(struct server *srvp) {
+void
+afs_FlushServer(struct server *srvp)
+{
     afs_int32 i;
     struct server *ts, **pts;
 
@@ -1597,7 +1668,9 @@ void afs_FlushServer(struct server *srvp) {
  * The afs_xserver and afs_xsrvAddr locks are assumed taken.
  *    It is not removed from the afs_srvAddrs hash chain.
  */
-void afs_RemoveSrvAddr(struct srvAddr *sap) {
+void
+afs_RemoveSrvAddr(struct srvAddr *sap)
+{
     struct srvAddr **psa, *sa;
     struct server *srv;
 
@@ -1619,16 +1692,65 @@ void afs_RemoveSrvAddr(struct srvAddr *sap) {
     }
 }
 
+/* afs_GetCapabilities
+ * Try and retrieve capabilities of a given file server. Carps on actual
+ * failure. Servers are not expected to support this RPC. */
+void
+afs_GetCapabilities(struct server *ts)
+{
+    Capabilities caps = {0, NULL};
+    struct vrequest treq;
+    struct afs_conn *tc;
+    struct unixuser *tu;
+    afs_int32 code;
+
+    if ( !ts || !ts->cell )
+       return;
+    if ( !afs_osi_credp )
+       return;
+
+    if ((code = afs_InitReq(&treq, afs_osi_credp)))
+       return;
+    tu = afs_GetUser(treq.uid, ts->cell->cellNum, SHARED_LOCK);
+    if ( !tu )
+       return;
+    tc = afs_ConnBySA(ts->addr, ts->cell->fsport, ts->cell->cellNum, tu, 0, 1,
+                                                               SHARED_LOCK);
+    if ( !tc )
+       return;
+    /* InitCallBackStateN, triggered by our RPC, may need this */
+    ReleaseWriteLock(&afs_xserver);
+    code = RXAFS_GetCapabilities(tc->id, &caps);
+    ObtainWriteLock(&afs_xserver, 723);
+    afs_PutConn(tc, SHARED_LOCK);
+    if ( code && code != RXGEN_OPCODE ) {
+       afs_warn("RXAFS_GetCapabilities failed with code %d\n", code);
+       /* better not be anything to free. we failed! */
+       return;
+    }
+
+    ts->flags |= SCAPS_KNOWN;
+
+    if ( caps.Capabilities_len > 0 ) {
+       ts->capabilities = caps.Capabilities_val[0];
+       xdr_free((xdrproc_t)xdr_Capabilities, &caps);
+       caps.Capabilities_len = 0;
+       caps.Capabilities_val = NULL;
+    }
+
+}
+
 /* afs_GetServer()
  * Return an updated and properly initialized server structure
  * corresponding to the server ID, cell, and port specified.
  * If one does not exist, then one will be created.
  * aserver and aport must be in NET byte order.
  */
-struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
-                            afs_int32 acell, u_short aport,
-                            afs_int32 locktype, afsUUID * uuidp,
-                            afs_int32 addr_uniquifier) {
+struct server *
+afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers, afs_int32 acell,
+             u_short aport, afs_int32 locktype, afsUUID * uuidp,
+             afs_int32 addr_uniquifier)
+{
     struct server *oldts = 0, *ts, *newts, *orphts = 0;
     struct srvAddr *oldsa, *newsa, *nextsa, *orphsa;
     u_short fsport;
@@ -1678,7 +1800,7 @@ struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
     if (oldts) {
        newts = oldts;
     } else {
-       newts = (struct server *)afs_osi_Alloc(sizeof(struct server));
+       newts = afs_osi_Alloc(sizeof(struct server));
        if (!newts)
            panic("malloc of server struct");
        afs_totalServers++;
@@ -1723,7 +1845,7 @@ struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
        if (oldsa) {
            newsa = oldsa;
        } else {
-           newsa = (struct srvAddr *)afs_osi_Alloc(sizeof(struct srvAddr));
+           newsa = afs_osi_Alloc(sizeof(struct srvAddr));
            if (!newsa)
                panic("malloc of srvAddr struct");
            afs_totalSrvAddrs++;
@@ -1773,8 +1895,7 @@ struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
 
            /* Have a srvAddr struct. Now get a server struct (if not already) */
            if (!orphts) {
-               orphts =
-                   (struct server *)afs_osi_Alloc(sizeof(struct server));
+               orphts = afs_osi_Alloc(sizeof(struct server));
                if (!orphts)
                    panic("malloc of lo server struct");
                memset(orphts, 0, sizeof(struct server));
@@ -1782,7 +1903,7 @@ struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
 
                /* Add the orphaned server to the afs_servers[] hash chain.
                 * Its iphash does not matter since we never look up the server
-                * in the afs_servers table by its ip address (only by uuid - 
+                * in the afs_servers table by its ip address (only by uuid -
                 * which this has none).
                 */
                iphash = SHash(aserverp[k]);
@@ -1819,11 +1940,17 @@ struct server *afs_GetServer(afs_uint32 * aserverp, afs_int32 nservers,
     }
 
     ReleaseWriteLock(&afs_xsrvAddr);
+
+    if ( aport == AFS_FSPORT && !(newts->flags & SCAPS_KNOWN))
+       afs_GetCapabilities(newts);
+
     ReleaseWriteLock(&afs_xserver);
     return (newts);
 }                              /* afs_GetServer */
 
-void afs_ActivateServer(struct srvAddr *sap) {
+void
+afs_ActivateServer(struct srvAddr *sap)
+{
     osi_timeval_t currTime;    /*Filled with current time */
     osi_timeval_t *currTimeP;  /*Ptr to above */
     struct afs_stats_SrvUpDownInfo *upDownP;   /*Ptr to up/down info record */
@@ -1848,7 +1975,8 @@ void afs_ActivateServer(struct srvAddr *sap) {
     }
 }
 
-void afs_RemoveAllConns(void)
+void
+afs_RemoveAllConns(void)
 {
     int i;
     struct server *ts, *nts;
@@ -1857,7 +1985,7 @@ void afs_RemoveAllConns(void)
 
     ObtainReadLock(&afs_xserver);
     ObtainWriteLock(&afs_xconn, 1001);
-    
+
     /*printf("Destroying connections ... ");*/
     for (i = 0; i < NSERVERS; i++) {
         for (ts = afs_servers[i]; ts; ts = nts) {
@@ -1882,10 +2010,11 @@ void afs_RemoveAllConns(void)
 
     ReleaseWriteLock(&afs_xconn);
     ReleaseReadLock(&afs_xserver);
-    
+
 }
 
-void afs_MarkAllServersUp(void)
+void
+afs_MarkAllServersUp(void)
 {
     int i;
     struct server *ts;