#include <afsconfig.h>
#include <afs/param.h>
+#include <afs/stds.h>
#include <roken.h>
-#include <afs/stds.h>
-#include <string.h>
#include <ctype.h>
-#ifdef AFS_NT40_ENV
-#include <fcntl.h>
-#include <winsock2.h>
-#else
-#include <sys/types.h>
-#include <sys/file.h>
-#include <netdb.h>
-#include <netinet/in.h>
-#endif /* AFS_NT40_ENV */
-#include <sys/stat.h>
#ifdef AFS_AIX_ENV
#include <sys/statfs.h>
#endif
-#include <errno.h>
#include <lock.h>
#include <rx/xdr.h>
#include <rx/rx.h>
#include <afs/afsint.h>
#include <afs/cmd.h>
#include <rx/rxkad.h>
+
#include "volser.h"
#include "volint.h"
#include "lockdata.h"
#include "vsutils_prototypes.h"
struct ubik_client *cstruct;
-static rxkad_level vsu_rxkad_level = rxkad_clear;
static void
ovlentry_to_nvlentry(struct vldbentry *oentryp,
memset(nentryp, 0, sizeof(struct nvldbentry));
strncpy(nentryp->name, oentryp->name, sizeof(nentryp->name));
for (i = 0; i < oentryp->nServers; i++) {
- bulkaddrs m_addrs;
- ListAddrByAttributes m_attrs;
- afs_int32 m_nentries;
-
- m_attrs.Mask = VLADDR_IPADDR;
- m_attrs.ipaddr = oentryp->serverNumber[i];
- m_nentries = 0;
- m_addrs.bulkaddrs_val = 0;
- m_addrs.bulkaddrs_len = 0;
- nentryp->serverNumber[i] = oentryp->serverNumber[i];
+ nentryp->serverNumber[i] = oentryp->serverNumber[i];
nentryp->serverPartition[i] = oentryp->serverPartition[i];
nentryp->serverFlags[i] = oentryp->serverFlags[i];
}
nentryp->flags = oentryp->flags;
}
-#if 0
-/* It is here for when we need it. Not currently used. */
static int
nvlentry_to_ovlentry(struct nvldbentry *nentryp,
struct vldbentry *oentryp)
oentryp->flags = nentryp->flags;
return 0;
}
-#endif
-
-static void
-ovlentry_to_uvlentry(struct vldbentry *oentryp,
- struct uvldbentry *uentryp)
-{
- int i;
-
- memset(uentryp, 0, sizeof(struct uvldbentry));
- strncpy(uentryp->name, oentryp->name, sizeof(uentryp->name));
- for (i = 0; i < oentryp->nServers; i++) {
- afs_int32 vcode, m_uniq=0;
- bulkaddrs m_addrs;
- ListAddrByAttributes m_attrs;
- afs_int32 m_nentries;
-
- m_attrs.Mask = VLADDR_IPADDR;
- m_attrs.ipaddr = oentryp->serverNumber[i];
- m_nentries = 0;
- m_addrs.bulkaddrs_val = 0;
- m_addrs.bulkaddrs_len = 0;
- vcode =
- ubik_VL_GetAddrsU(cstruct, 0, &m_attrs,
- &uentryp->serverNumber[i],
- &m_uniq, &m_nentries,
- &m_addrs);
- uentryp->serverUnique[i] = oentryp->serverNumber[i];
- uentryp->serverPartition[i] = oentryp->serverPartition[i];
- uentryp->serverFlags[i] = oentryp->serverFlags[i];
- }
- uentryp->nServers = oentryp->nServers;
- for (i = 0; i < MAXTYPES; i++)
- uentryp->volumeId[i] = oentryp->volumeId[i];
- uentryp->cloneId = oentryp->cloneId;
- uentryp->flags = oentryp->flags;
-}
-
-static int
-uvlentry_to_ovlentry(struct uvldbentry *uentryp,
- struct vldbentry *oentryp)
-{
- int i;
-
- memset(oentryp, 0, sizeof(struct vldbentry));
- strncpy(oentryp->name, uentryp->name, sizeof(oentryp->name));
- if (uentryp->nServers > OMAXNSERVERS) {
- /*
- * The alternative is to store OMAXSERVERS but it's always better
- * to know what's going on...
- */
- return VL_BADSERVER;
- }
- for (i = 0; i < uentryp->nServers; i++) {
- oentryp->serverNumber[i] = uentryp->serverUnique[i];
- oentryp->serverPartition[i] = uentryp->serverPartition[i];
- oentryp->serverFlags[i] = uentryp->serverFlags[i];
- }
- oentryp->nServers = i;
- for (i = 0; i < MAXTYPES; i++)
- oentryp->volumeId[i] = uentryp->volumeId[i];
- oentryp->cloneId = uentryp->cloneId;
- oentryp->flags = uentryp->flags;
- return 0;
-}
-
-void
-nvlentry_to_uvlentry(struct nvldbentry *nentryp,
- struct uvldbentry *uentryp)
-{
- int i;
-
- memset(uentryp, 0, sizeof(struct uvldbentry));
- strncpy(uentryp->name, nentryp->name, sizeof(uentryp->name));
- for (i = 0; i < nentryp->nServers; i++) {
- afs_int32 vcode, m_uniq=0;
- bulkaddrs m_addrs;
- ListAddrByAttributes m_attrs;
- afs_int32 m_nentries;
-
- m_attrs.Mask = VLADDR_IPADDR;
- m_attrs.ipaddr = nentryp->serverNumber[i];
- m_nentries = 0;
- m_addrs.bulkaddrs_val = 0;
- m_addrs.bulkaddrs_len = 0;
- vcode =
- ubik_VL_GetAddrsU(cstruct, 0, &m_attrs,
- &uentryp->serverNumber[i],
- &m_uniq, &m_nentries,
- &m_addrs);
- uentryp->serverUnique[i] = nentryp->serverNumber[i];
- uentryp->serverPartition[i] = nentryp->serverPartition[i];
- uentryp->serverFlags[i] = nentryp->serverFlags[i];
- }
- uentryp->nServers = nentryp->nServers;
- for (i = 0; i < MAXTYPES; i++)
- uentryp->volumeId[i] = nentryp->volumeId[i];
- uentryp->cloneId = nentryp->cloneId;
- uentryp->flags = nentryp->flags;
- uentryp->matchindex = nentryp->matchindex;
-}
-
-int
-uvlentry_to_nvlentry(struct uvldbentry *uentryp,
- struct nvldbentry *nentryp)
-{
- int i;
-
- memset(nentryp, 0, sizeof(struct vldbentry));
- strncpy(nentryp->name, uentryp->name, sizeof(nentryp->name));
- if (uentryp->nServers > NMAXNSERVERS) {
- /*
- * The alternative is to store NMAXSERVERS but it's always better
- * to know what's going on...
- */
- return VL_BADSERVER;
- }
- for (i = 0; i < uentryp->nServers; i++) {
- nentryp->serverNumber[i] = uentryp->serverUnique[i];
- nentryp->serverPartition[i] = uentryp->serverPartition[i];
- nentryp->serverFlags[i] = uentryp->serverFlags[i];
- }
- nentryp->nServers = i;
- for (i = 0; i < MAXTYPES; i++)
- nentryp->volumeId[i] = uentryp->volumeId[i];
- nentryp->cloneId = uentryp->cloneId;
- nentryp->flags = uentryp->flags;
- nentryp->matchindex = uentryp->matchindex;
- return 0;
-}
enum _vlserver_type {
vltype_unknown = 0,
int
VLDB_CreateEntry(struct nvldbentry *entryp)
{
- int code;
- struct uvldbentry uentry;
-
- nvlentry_to_uvlentry(entryp, &uentry);
- code = VLDB_CreateEntryU(&uentry);
- if (!code)
- code = uvlentry_to_nvlentry(&uentry, entryp);
- return code;
-}
-
-int
-VLDB_CreateEntryU(struct uvldbentry *entryp)
-{
- struct nvldbentry nentry;
+ struct vldbentry oentry;
int code;
if (newvlserver == vltype_old) {
- struct vldbentry oentry;
tryold:
- code = uvlentry_to_ovlentry(entryp, &oentry);
+ code = nvlentry_to_ovlentry(entryp, &oentry);
if (code)
return code;
code = ubik_VL_CreateEntry(cstruct, 0, &oentry);
return code;
}
-
- code = uvlentry_to_nvlentry(entryp, &nentry);
- if (code)
- return code;
- code = ubik_VL_CreateEntryN(cstruct, 0, &nentry);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old;
- goto tryold;
+ code = ubik_VL_CreateEntryN(cstruct, 0, entryp);
+ if (newvlserver == vltype_unknown) {
+ if (code == RXGEN_OPCODE) {
+ newvlserver = vltype_old; /* Doesn't support new interface */
+ goto tryold;
+ } else if (!code) {
+ newvlserver = vltype_new;
+ }
}
return code;
}
int
VLDB_GetEntryByID(afs_uint32 volid, afs_int32 voltype, struct nvldbentry *entryp)
{
- int code;
- struct uvldbentry uentry;
-
- nvlentry_to_uvlentry(entryp, &uentry);
- code = VLDB_GetEntryByIDU(volid, voltype, &uentry);
- if (!code)
- code = uvlentry_to_nvlentry(&uentry, entryp);
- return code;
-}
-
-int
-VLDB_GetEntryByIDU(afs_uint32 volid, afs_int32 voltype, struct uvldbentry *entryp)
-{
- struct nvldbentry nentry;
+ struct vldbentry oentry;
int code;
if (newvlserver == vltype_old) {
- struct vldbentry oentry;
tryold:
code =
ubik_VL_GetEntryByID(cstruct, 0, volid, voltype, &oentry);
if (!code)
- ovlentry_to_uvlentry(&oentry, entryp);
+ ovlentry_to_nvlentry(&oentry, entryp);
return code;
}
-
- code = ubik_VL_GetEntryByIDN(cstruct, 0, volid, voltype, &nentry);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old;
- goto tryold;
+ code = ubik_VL_GetEntryByIDN(cstruct, 0, volid, voltype, entryp);
+ if (newvlserver == vltype_unknown) {
+ if (code == RXGEN_OPCODE) {
+ newvlserver = vltype_old; /* Doesn't support new interface */
+ goto tryold;
+ } else if (!code) {
+ newvlserver = vltype_new;
+ }
}
- if (!code)
- nvlentry_to_uvlentry(&nentry, entryp);
return code;
}
int
VLDB_GetEntryByName(char *namep, struct nvldbentry *entryp)
{
- int code;
- struct uvldbentry uentry;
-
- nvlentry_to_uvlentry(entryp, &uentry);
- code = VLDB_GetEntryByNameU(namep, &uentry);
- if (!code)
- code = uvlentry_to_nvlentry(&uentry, entryp);
- return code;
-}
-
-int
-VLDB_GetEntryByNameU(char *namep, struct uvldbentry *entryp)
-{
+ struct vldbentry oentry;
int code;
if (newvlserver == vltype_old) {
- struct vldbentry oentry;
tryold:
code = ubik_VL_GetEntryByNameO(cstruct, 0, namep, &oentry);
if (!code)
- ovlentry_to_uvlentry(&oentry, entryp);
+ ovlentry_to_nvlentry(&oentry, entryp);
return code;
}
- if (newvlserver == vltype_new) {
- struct nvldbentry nentry;
- trynew:
- code = ubik_VL_GetEntryByNameN(cstruct, 0, namep, &nentry);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old;
- goto tryold;
- }
- if (!code)
- nvlentry_to_uvlentry(&nentry, entryp);
- }
- code = ubik_VL_GetEntryByNameU(cstruct, 0, namep, entryp);
+ code = ubik_VL_GetEntryByNameN(cstruct, 0, namep, entryp);
if (newvlserver == vltype_unknown) {
if (code == RXGEN_OPCODE) {
- newvlserver = vltype_new;
- goto trynew;
+ newvlserver = vltype_old; /* Doesn't support new interface */
+ goto tryold;
} else if (!code) {
- newvlserver = vltype_uuid;
+ newvlserver = vltype_new;
}
}
return code;
}
int
-VLDB_ReplaceEntry(afs_uint32 volid, afs_int32 voltype, struct nvldbentry *nentryp, afs_int32 releasetype)
+VLDB_ReplaceEntry(afs_uint32 volid, afs_int32 voltype, struct nvldbentry *entryp, afs_int32 releasetype)
{
- struct uvldbentry uentry;
+ struct vldbentry oentry;
int code;
- nvlentry_to_uvlentry(nentryp, &uentry);
- code = VLDB_ReplaceEntryU(volid, voltype, &uentry, releasetype);
- if (!code)
- code = uvlentry_to_nvlentry(&uentry, nentryp);
-
- return code;
-}
-
-int
-VLDB_ReplaceEntryU(afs_uint32 volid, afs_int32 voltype, struct uvldbentry *entryp, afs_int32 releasetype)
-{
- int code;
- struct nvldbentry nentry;
-
if (newvlserver == vltype_old) {
- struct vldbentry oentry;
tryold:
- code = uvlentry_to_ovlentry(entryp, &oentry);
+ code = nvlentry_to_ovlentry(entryp, &oentry);
if (code)
return code;
code =
- ubik_VL_ReplaceEntry(cstruct, 0, volid, voltype, &oentry, releasetype);
+ ubik_VL_ReplaceEntry(cstruct, 0, volid, voltype, &oentry,
+ releasetype);
return code;
}
- code = uvlentry_to_nvlentry(entryp, &nentry);
- if (code)
- return code;
- code = ubik_VL_ReplaceEntryN(cstruct, 0, volid, voltype, &nentry, releasetype);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old;
- goto tryold;
+ code =
+ ubik_VL_ReplaceEntryN(cstruct, 0, volid, voltype, entryp,
+ releasetype);
+ if (newvlserver == vltype_unknown) {
+ if (code == RXGEN_OPCODE) {
+ newvlserver = vltype_old; /* Doesn't support new interface */
+ goto tryold;
+ } else if (!code) {
+ newvlserver = vltype_new;
+ }
}
return code;
}
static void
convertBulkToNBulk(bulkentries *bulk, nbulkentries *nbulk) {
- int i;
+ unsigned int i;
if (bulk->bulkentries_len == 0)
return;
}
}
-static void
-convertBulkToUBulk(bulkentries *bulk, ubulkentries *ubulk) {
- int i;
-
- if (bulk->bulkentries_len == 0)
- return;
-
- ubulk->ubulkentries_len = bulk->bulkentries_len;
- ubulk->ubulkentries_val =
- xdr_alloc(bulk->bulkentries_len * sizeof(struct uvldbentry));
- for (i = 0; i < bulk->bulkentries_len; i++) {
- ovlentry_to_uvlentry(&bulk->bulkentries_val[i],
- &ubulk->ubulkentries_val[i]);
- }
-}
-
-static void
-convertNBulkToUBulk(nbulkentries *nbulk, ubulkentries *ubulk) {
- int i;
-
- if (nbulk->nbulkentries_len == 0)
- return;
-
- ubulk->ubulkentries_len = nbulk->nbulkentries_len;
- ubulk->ubulkentries_val =
- xdr_alloc(nbulk->nbulkentries_len * sizeof(struct uvldbentry));
- for (i = 0; i < nbulk->nbulkentries_len; i++) { /* process each entry */
- nvlentry_to_uvlentry(&nbulk->nbulkentries_val[i],
- &ubulk->ubulkentries_val[i]);
- }
-}
-
int
VLDB_ListAttributes(VldbListByAttributes *attrp,
afs_int32 *entriesp,
nbulkentries *blkentriesp)
{
+ bulkentries arrayEntries;
int code;
if (newvlserver == vltype_old) {
- bulkentries arrayEntries;
tryold:
memset(&arrayEntries, 0, sizeof(arrayEntries));
code =
xdr_free((xdrproc_t) xdr_bulkentries, &arrayEntries);
return code;
}
-
code =
ubik_VL_ListAttributesN(cstruct, 0, attrp, entriesp, blkentriesp);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old; /* Doesn't support new interface */
- goto tryold;
+ if (newvlserver == vltype_unknown) {
+ if (code == RXGEN_OPCODE) {
+ newvlserver = vltype_old; /* Doesn't support new interface */
+ goto tryold;
+ } else if (!code) {
+ newvlserver = vltype_new;
+ }
}
- if (code)
- return code;
-
/* Ensure the number of entries claimed matches the no. returned */
if (*entriesp < 0)
*entriesp = 0;
}
int
-VLDB_ListAttributesU(VldbListByAttributes *attrp,
- afs_int32 *entriesp,
- ubulkentries *blkentriesp)
-{
- nbulkentries narrayEntries;
- int code;
-
- if (newvlserver == vltype_old) {
- bulkentries arrayEntries;
- tryold:
- memset(&arrayEntries, 0, sizeof(arrayEntries));
- code =
- ubik_VL_ListAttributes(cstruct, 0, attrp, entriesp,
- &arrayEntries);
- if (code)
- return code;
-
- /* Ensure the number of entries claimed matches the no. returned */
- if (*entriesp < 0)
- *entriesp = 0;
- if (*entriesp > arrayEntries.bulkentries_len)
- *entriesp = arrayEntries.bulkentries_len;
-
- convertBulkToUBulk(&arrayEntries, blkentriesp);
-
- xdr_free((xdrproc_t) xdr_bulkentries, &arrayEntries);
- return code;
- }
-
- memset(&narrayEntries, 0, sizeof(narrayEntries));
- code =
- ubik_VL_ListAttributesN(cstruct, 0, attrp, entriesp, &narrayEntries);
- if (code == RXGEN_OPCODE) {
- newvlserver = vltype_old; /* Doesn't support new interface */
- goto tryold;
- }
- if (code)
- return code;
-
- /* Ensure the number of entries claimed matches the no. returned */
- if (*entriesp < 0)
- *entriesp = 0;
- if (*entriesp > narrayEntries.nbulkentries_len)
- *entriesp = narrayEntries.nbulkentries_len;
-
- convertNBulkToUBulk(&narrayEntries, blkentriesp);
-
- xdr_free((xdrproc_t) xdr_bulkentries, &narrayEntries);
- return code;
-}
-
-int
VLDB_ListAttributesN2(VldbListByAttributes *attrp,
char *name,
afs_int32 thisindex,
return code;
}
-int
-VLDB_ListAttributesN2U(VldbListByAttributes *attrp,
- char *name,
- afs_int32 thisindex,
- afs_int32 *nentriesp,
- ubulkentries *blkentriesp,
- afs_int32 *nextindexp)
-{
- afs_int32 code = RXGEN_OPCODE;
-
- if (newvlserver != vltype_old) {
- nbulkentries narrayEntries;
-
- memset(&narrayEntries, 0, sizeof(narrayEntries)); /*initialize to hint the stub to alloc space */
- code =
- ubik_VL_ListAttributesN2(cstruct, 0, attrp, (name ? name : ""),
- thisindex, nentriesp, &narrayEntries, nextindexp);
- if (code)
- return code;
-
- /* Ensure the number of entries claimed matches the no. returned */
- if (*nentriesp < 0)
- *nentriesp = 0;
- if (*nentriesp > narrayEntries.nbulkentries_len)
- *nentriesp = narrayEntries.nbulkentries_len;
-
- convertNBulkToUBulk(&narrayEntries, blkentriesp);
-
- xdr_free((xdrproc_t) xdr_bulkentries, &narrayEntries);
- return code;
- }
- return code;
-}
-
-
struct cacheips {
afs_uint32 server;
- afs_int32 count;
+ afs_uint32 count;
afs_uint32 addrs[16];
};
/*
int code;
ListAddrByAttributes attrs;
bulkaddrs addrs;
- afs_uint32 *addrp, f1, f2;
- afs_int32 i, j, unique, nentries;
+ afs_uint32 *addrp, j, f1, f2;
+ afs_int32 unique, nentries, i;
afsUUID uuid;
static int initcache = 0;
if (serv1 == serv2)
return 1;
- if (newvlserver == vltype_old ||
- newvlserver == vltype_new) {
+ if (newvlserver == vltype_old || newvlserver == vltype_new) {
return 0;
}
if (!initcache) {
&addrs);
if (newvlserver == vltype_unknown) {
if (code == RXGEN_OPCODE) {
- newvlserver = vltype_new;
return 0;
} else if (!code) {
newvlserver = vltype_uuid;
return code;
}
-
-/*
- Set encryption. If 'cryptflag' is nonzero, encrpytion is turned on
- for authenticated connections; if zero, encryption is turned off.
- Calling this function always results in a level of at least rxkad_auth;
- to get a rxkad_clear connection, simply don't call this.
-*/
-void
-vsu_SetCrypt(int cryptflag)
-{
- if (cryptflag) {
- vsu_rxkad_level = rxkad_crypt;
- } else {
- vsu_rxkad_level = rxkad_auth;
- }
-}
-
-
/*
Get the appropriate type of ubik client structure out from the system.
*/
-afs_int32
-vsu_ClientInit(int noAuthFlag, const char *confDir, char *cellName, afs_int32 sauth,
- struct ubik_client **uclientp,
- int (*secproc)(struct rx_securityClass *, afs_int32))
+int
+vsu_ClientInit(const char *confDir, char *cellName, int secFlags,
+ ugen_secproc_func secproc,
+ struct ubik_client **uclientp)
{
- return ugen_ClientInit(noAuthFlag, confDir, cellName, sauth, uclientp,
- secproc, "vsu_ClientInit", vsu_rxkad_level,
- VLDB_MAXSERVERS, AFSCONF_VLDBSERVICE, 90,
- 0, 0, USER_SERVICE_ID);
+ return ugen_ClientInitFlags(confDir, cellName, secFlags, uclientp,
+ secproc, VLDB_MAXSERVERS, AFSCONF_VLDBSERVICE,
+ 90);
}
-
/*extract the name of volume <name> without readonly or backup suffixes
* and return the result as <rname>.
*/
vsu_GetVolumeID(char *astring, struct ubik_client *acstruct, afs_int32 *errp)
{
char volname[VOLSER_OLDMAXVOLNAME + 1];
- struct uvldbentry entry;
+ struct nvldbentry entry;
afs_int32 vcode = 0;
size_t total;
/* It was not a volume number but something else */
total = strlen(astring);
vsu_ExtractName(volname, astring);
- vcode = VLDB_GetEntryByNameU(volname, &entry);
+ vcode = VLDB_GetEntryByName(volname, &entry);
if (!vcode) {
if ((total >= 9) && (!strcmp(&astring[total - 9], ".readonly")))
return entry.volumeId[ROVOL];
git://git.openafs.org / openafs.git / blobdiff