src/ubik/uinit.c

   1 /*
   2  * Copyright 2000, International Business Machines Corporation and others.
   3  * All Rights Reserved.
   4  *
   5  * This software has been released under the terms of the IBM Public
   6  * License.  For details, see the LICENSE file in the top-level source
   7  * directory or online at http://www.openafs.org/dl/license10.html
   8  */
   9
  10 #include <afsconfig.h>
  11 #include <afs/param.h>
  12
  13
  14 #include <afs/stds.h>
  15 #ifdef AFS_NT40_ENV
  16 #include <fcntl.h>
  17 #include <winsock2.h>
  18 #else
  19 #include <sys/types.h>
  20 #include <sys/file.h>
  21 #include <netdb.h>
  22 #include <netinet/in.h>
  23 #endif /* AFS_NT40_ENV */
  24 #include <sys/stat.h>
  25 #ifdef AFS_AIX_ENV
  26 #include <sys/statfs.h>
  27 #endif
  28
  29 #include <string.h>
  30
  31 #include <afs/dirpath.h>
  32 #include <errno.h>
  33 #include <lock.h>
  34 #include <rx/xdr.h>
  35 #include <rx/rx.h>
  36 #include <rx/rx_globals.h>
  37 #include <afs/auth.h>
  38 #include <afs/cellconfig.h>
  39 #include <afs/keys.h>
  40 #include <ubik.h>
  41 #include <afs/afsint.h>
  42 #include <afs/cmd.h>
  43
  44 /*!
  45  * \brief Get the appropriate type of ubik client structure out from the system.
  46  */
  47 afs_int32
  48 ugen_ClientInit(int noAuthFlag, const char *confDir, char *cellName, afs_int32 sauth,
  49                struct ubik_client **uclientp,
  50                int (*secproc) (struct rx_securityClass *, afs_int32),
  51                char *funcName, afs_int32 gen_rxkad_level,
  52                afs_int32 maxservers, char *serviceid, afs_int32 deadtime,
  53                afs_uint32 server, afs_uint32 port, afs_int32 usrvid)
  54 {
  55     afs_int32 code, scIndex, secFlags, i;
  56     struct afsconf_cell info;
  57     struct afsconf_dir *tdir;
  58     struct rx_securityClass *sc;
  59     /* This must change if VLDB_MAXSERVERS becomes larger than MAXSERVERS */
  60     static struct rx_connection *serverconns[MAXSERVERS];
  61     const char *confdir;
  62
  63     code = rx_Init(0);
  64     if (code) {
  65         fprintf(stderr, "%s: could not initialize rx.\n", funcName);
  66         return code;
  67     }
  68     rx_SetRxDeadTime(deadtime);
  69
  70     secFlags = AFSCONF_SECOPTS_FALLBACK_NULL;
  71     if (sauth) {
  72         secFlags |= AFSCONF_SECOPTS_LOCALAUTH;
  73         confdir = AFSDIR_SERVER_ETC_DIRPATH;
  74     } else {
  75         confdir = AFSDIR_CLIENT_ETC_DIRPATH;
  76     }
  77
  78     tdir = afsconf_Open(confdir);
  79     if (!tdir) {
  80         fprintf(stderr,
  81                 "%s: Could not process files in configuration directory (%s).\n",
  82                 funcName, confdir);
  83         return -1;
  84     }
  85     code = afsconf_GetCellInfo(tdir, tdir->cellName, serviceid, &info);
  86     if (code) {
  87         afsconf_Close(tdir);
  88         fprintf(stderr, "%s: can't find cell %s's hosts in %s/%s\n",
  89                 funcName, cellName, confdir, AFSDIR_CELLSERVDB_FILE);
  90         return -1;
  91     }
  92     code = afsconf_PickClientSecObj(tdir, secFlags, &info, tdir->cellName, &sc,
  93                                     &scIndex, NULL);
  94     if (code) {
  95         fprintf(stderr, "%s: can't create client security object", funcName);
  96         return -1;
  97     }
  98     if (scIndex == 0) {
  99         fprintf(stderr,
 100                 "%s: Could not get afs tokens, running unauthenticated.\n",
 101                 funcName);
 102     }
 103
 104     afsconf_Close(tdir);
 105
 106     if (secproc)        /* tell UV module about default authentication */
 107         (*secproc) (sc, scIndex);
 108     if (server) {
 109         serverconns[0] = rx_NewConnection(server, port,
 110                                           usrvid, sc, scIndex);
 111     } else {
 112         if (info.numServers > maxservers) {
 113             fprintf(stderr,
 114                     "%s: info.numServers=%d (> maxservers=%d)\n",
 115                     funcName, info.numServers, maxservers);
 116             return -1;
 117         }
 118         for (i = 0; i < info.numServers; i++) {
 119             serverconns[i] =
 120                 rx_NewConnection(info.hostAddr[i].sin_addr.s_addr,
 121                                  info.hostAddr[i].sin_port, usrvid,
 122                                  sc, scIndex);
 123         }
 124     }
 125     /* Are we just setting up connections, or is this really ubik stuff? */
 126     if (uclientp) {
 127         *uclientp = 0;
 128         code = ubik_ClientInit(serverconns, uclientp);
 129         if (code) {
 130             fprintf(stderr, "%s: ubik client init failed.\n", funcName);
 131             return code;
 132         }
 133     }
 134     return 0;
 135 }
 136
 137