hdb.h

Go to the documentation of this file.

/* BLURB gpl
 
                           Coda File System
                              Release 8
 
          Copyright (c) 1987-2025 Carnegie Mellon University
                  Additional copyrights listed below
 
This  code  is  distributed "AS IS" without warranty of any kind under
the terms of the GNU General Public Licence Version 2, as shown in the
file  LICENSE.  The  technical and financial  contributors to Coda are
listed in the file CREDITS.
 
                        Additional copyrights
                           none currently
 
#*/
 
/*
 *  Hoard database management: first part used by Venus & hoard, latter only by Venus
 */
 
#ifndef _VENUS_HDB_H_
#define _VENUS_HDB_H_ 1
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <stdio.h>
#include <sys/param.h>
#include <time.h>
#include <netdb.h>
 
#ifdef __cplusplus
}
#endif
 
/* interfaces */
#include <vice.h>
#include <coda.h>
 
#define HDB_ASSERT(ex)                                                  \
    {                                                                   \
        if (!(ex)) {                                                    \
            CHOKE("Assertion failed: file \"%s\", line %d\n", __FILE__, \
                  __LINE__);                                            \
        }                                                               \
    }
 
/* Hoard priority range. */
#define H_MAX_PRI 1000
#define H_DFLT_PRI 10
#define H_MIN_PRI 1
 
/* Hoard attribute flags. */
#define H_INHERIT 1 /* New children inherit their parent's hoard status. */
#define H_CHILDREN 2 /* Meta-expand directory to include its children. */
#define H_DESCENDENTS \
    4 /* Meta-expand directory to include all its descendents. */
#define H_DFLT_ATTRS 0
 
/* *****  Definition of pioctl message structures.  ***** */
 
/* Should be in venusioctl.h! -JJK */
 
struct hdb_clear_msg {
    uid_t cuid;
    int spare;
};
 
struct hdb_add_msg {
    VolumeId vid;
    char realm[MAXHOSTNAMELEN + 1];
    char name[CODA_MAXPATHLEN];
    int priority;
    int attributes;
};
 
struct hdb_delete_msg {
    VolumeId vid;
    char realm[MAXHOSTNAMELEN + 1];
    char name[CODA_MAXPATHLEN];
};
 
struct hdb_list_msg {
    char outfile[CODA_MAXPATHLEN];
    uid_t luid;
    int spare;
};
 
struct hdb_walk_msg {
    int spare;
};
 
struct hdb_verify_msg {
    char outfile[CODA_MAXPATHLEN];
    uid_t luid;
    int spare;
    int verbosity;
};
 
/*  ****************************************  */
 
#ifdef VENUS /* Portion below here not used in vtools/hoard.c */
 
/* from util */
#include <bstree.h>
#include <olist.h>
#include <rec_olist.h>
#include <ohash.h>
#include <rec_ohash.h>
 
/* from venus */
#include "fso.h"
#include "venusrecov.h"
#include "venus.private.h"
 
/*
 *    Allocated HDB entries are linked into a hash table, keyed by <vid, name>.
 *    Unallocated entries are linked into a free-list.
 *
 *    A transient "name-context" is associated with each allocated entry.
 *    A name-context may be linked into one of two priority queues, depending on its state.
 *    There are "suspect" and "indigent" queues for name-context's of those
 *    two states.  Name-context's in the third state, "valid," are not in a priority queue.
 *    An HDB entry which has been meta-expanded will have additional name-contexts
 *    associated with it.
 *
 */
 
/* Forward declarations. */
class hdb;
class hdb_key;
class hdbent;
class hdb_iterator;
class namectxt;
 
/*  *****  Constants  *****  */
 
#define HDB (rvg->recov_HDB)
const int HDB_MagicNumber    = 5551212;
const int HDB_NBUCKETS       = 2048;
const int HDBENT_MagicNumber = 8204933;
const int HDBMaxFreeEntries  = 32;
 
/*  *****  Types  *****  */
 
enum hdbd_request
{
    HdbAdd,
    HdbDelete,
    HdbClear,
    HdbList,
    HdbWalk,
    HdbVerify,
    HdbEnable,
    HdbDisable
};
 
/*
 * Allow user to specify if periodic hoard walks should happen. I put this outside
 * of the hdb class to avoid the necessity of a reinit. -- DCS 5/5/94
 */
 
extern char PeriodicWalksAllowed;
 
/* used to be member of class hdb (Satya 3/31/95) */
void HDBDaemon(void) EXCLUDES_TRANSACTION;
 
class hdb {
    friend void HDB_Init(void);
    friend void HDBD_Init(void);
    friend void HDBDaemon(void);
    friend class hdbent;
    friend class hdb_iterator;
    friend class namectxt;
    friend void RecovInit();
 
    int MagicNumber;
 
    /* Size parameters. */
    int MaxHDBEs;
 
    /* The table. */
    rec_ohashtab htab;
 
    /* The free list. */
    rec_olist freelist;
 
    /* The priority queue. */
    /*T*/ bstree *prioq;
 
    /* Advice Information */
    long TimeOfLastDemandWalk;
    int NumHoardWalkAdvice;
    int SolicitAdvice;
 
    /* Constructors, destructors. */
    void *operator new(size_t) REQUIRES_TRANSACTION;
    void operator delete(void *);
    hdb();
    void ResetTransient();
    ~hdb() { abort(); }
 
    /* Allocation/Deallocation routines. */
    hdbent *Create(VolumeId, char *realm, char *name, uid_t, int, int,
                   int) EXCLUDES_TRANSACTION;
 
public:
    hdbent *Find(VolumeId, char *realm, char *name);
 
    /* The external interface. */
    int Add(hdb_add_msg *, uid_t local_id) EXCLUDES_TRANSACTION;
    int Delete(hdb_delete_msg *, uid_t local_id) EXCLUDES_TRANSACTION;
    int Clear(hdb_clear_msg *, uid_t local_id) EXCLUDES_TRANSACTION;
    int List(hdb_list_msg *, uid_t local_id);
    int Walk(hdb_walk_msg *, uid_t local_id) EXCLUDES_TRANSACTION;
    int Verify(hdb_verify_msg *, uid_t local_id);
    int Enable(hdb_walk_msg *, uid_t local_id);
    int Disable(hdb_walk_msg *, uid_t local_id);
 
    void ResetUser(uid_t);
 
    /* Helper Routines hdb::Walk */
    void ValidateCacheStatus(vproc *, int *, int *) EXCLUDES_TRANSACTION;
    void ListPriorityQueue();
    void WalkPriorityQueue(vproc *, int *, int *) EXCLUDES_TRANSACTION;
    int CalculateTotalBytesToFetch();
    void StatusWalk(vproc *, int *, int *) EXCLUDES_TRANSACTION;
    void DataWalk(vproc *, int, int) EXCLUDES_TRANSACTION;
    void PostWalkStatus();
 
    /* Advice Related*/
    void SetSolicitAdvice(int uid)
    {
        LOG(0, ("SetSolicitAdvice: uid=%d\n", uid));
        SolicitAdvice = uid;
    }
 
    void SetDemandWalkTime() EXCLUDES_TRANSACTION;
    long GetDemandWalkTime();
 
    void print() { print(stdout); }
    void print(FILE *fp)
    {
        fflush(fp);
        print(fileno(fp));
    }
    void print(int, int = 0);
};
 
class hdb_key {
public:
    VolumeId vid;
    char *realm;
    char *name;
 
    hdb_key(VolumeId, char *realm, char *name);
};
 
class hdbent {
    friend void HDB_Init();
    friend class hdb;
    friend class hdb_iterator;
    friend class fsobj;
 
    int MagicNumber;
 
    /* Key. */
    VolumeId vid;
    char *realm;
    char *name;
 
    /* Assoc(key). */
    uid_t uid;
    int priority;
    unsigned expand_children : 1; /* meta-expand children */
    unsigned expand_descendents : 1; /* meta-expand descendents */
    unsigned time : 30; /* currently unused! */
    /*T*/ namectxt *nc; /* pre-computed path expansion */
 
    /* Linkage. */
    rec_olink tbl_handle; /* link for {allocated-table, free-list} */
 
    /* Constructors, destructors. */
    void *operator new(size_t) REQUIRES_TRANSACTION;
    hdbent(VolumeId, char *, char *, uid_t, int, int, int) REQUIRES_TRANSACTION;
    void ResetTransient() EXCLUDES_TRANSACTION;
    ~hdbent() REQUIRES_TRANSACTION;
    void operator delete(void *);
 
public:
    void print() { print(stdout); }
    void print(FILE *fp)
    {
        fflush(fp);
        print(fileno(fp));
    }
    void print(int);
    void printsuspect(int, int);
};
 
class hdb_iterator : public rec_ohashtab_iterator {
    uid_t uid;
 
public:
    hdb_iterator();
    hdb_iterator(uid_t);
    hdb_iterator(hdb_key *);
    hdbent *operator()();
};
 
enum pestate
{
    PeValid, /* expansion need not be checked */
    PeSuspect, /* expansion must be checked at next walk */
    PeIndigent, /* expansion is impeded due to resource shortage */
    PeInconsistent /* expansion is impeded due to inconsistency */
};
 
class namectxt {
    friend class fsobj;
    friend class hdb;
    friend class hdbent;
    friend class hdb_iterator;
    friend int MetaExpand(PDirEntry de, void *hook);
    friend int NC_PriorityFN(bsnode *, bsnode *);
    friend void NotifyUsersOfKillEvent(dlist *, int);
 
    /* Key. */
    VenusFid cdir; /* starting directory of expansion */
    char *path; /* subsequent components */
 
    /* Assoc(key). */
    uid_t uid; /* owner of this context */
    int priority; /* priority to be used for resource allocation */
    enum pestate state; /* {Valid, Suspect, Indigent} */
    unsigned inuse : 1; /* state cannot change when inuse */
    unsigned dying : 1; /* commit suicide when next !inuse */
    unsigned demote_pending : 1; /* transit to "suspect" state when next !inuse */
    unsigned
        meta_expanded : 1; /* this context was created due to meta-expansion */
    unsigned expand_children : 1; /* meta-expand the children of bound object */
    unsigned
        expand_descendents : 1; /* meta-expand the descendents of bound object */
    unsigned depth : 10; /* depth of meta-expansion (0 if not meta-expanded) */
    unsigned random : 16; /* for binary-tree balancing */
    dlist expansion; /* ordered set of bindings */
    dlist_iterator *next; /* shadow list for validation */
 
    /* Expander info. */
    dlist *children; /* list of expanded children */
    VenusFid expander_fid; /* Fid of expanded directory */
    ViceVersionVector expander_vv; /* VersionVector of expanded directory */
    unsigned long expander_dv; /* DataVersion of expanded directory */
 
    /* Expandee info. */
    namectxt *parent; /* back pointer to expander */
    dlink child_link; /* link for expander's children list */
 
    /* Linkage. */
    bsnode prio_handle; /* link for HDB priority queues */
    dlink fl_handle; /* link for freelist */
 
    /* Private member functions. */
    void hold(); /* inhibit state transitions */
    void release(); /* permit state transitions */
    void Transit(enum pestate); /* transit to specified state */
    void Kill(); /* delete this context at first opportunity */
    void KillChildren(); /* delete children contexts at first opportunity */
    pestate CheckExpansion() EXCLUDES_TRANSACTION; /* return next state */
    void MetaExpand() EXCLUDES_TRANSACTION;
 
public:
    void *operator new(size_t);
    namectxt(VenusFid *, char *, uid_t, int, int, int);
    namectxt(namectxt *, char *);
    namectxt(namectxt &); /* not supported! */
    int operator=(namectxt &); /* not supported! */
    ~namectxt();
    void operator delete(void *);
 
    void
    Demote(int recursive =
               0); /* --> immediate or eventual transition to suspect state */
    void CheckComponent(fsobj *);
 
    int GetPriority() { return (priority); }
    uid_t GetUid() { return (uid); }
 
    void print(void * = 0) { print(stdout); }
    void print(FILE *fp, void * = 0)
    {
        fflush(fp);
        print(fileno(fp));
    }
    void print(int, void * = 0);
    void printsuspect(int, int);
    void getpath(char *);
    void putmsg(int fd, const char *reason, int include_modifier);
};
 
#ifdef VENUSDEBUG
/* Too many problems in trying to keep these variables static member of class namectxt */
extern int NameCtxt_allocs;
extern int NameCtxt_deallocs;
#endif /* VENUSDEBUG */
 
/*  *****  Variables  *****  */
 
extern int HDBEs;
extern int IndigentCount;
 
/*  *****  Functions/Procedures  *****  */
 
/* hdb.c */
void HDB_Init(void) EXCLUDES_TRANSACTION;
extern int NC_PriorityFN(bsnode *, bsnode *);
 
/* hdb_daemon.c */
extern void HDBD_Init(void);
extern int HDBD_Request(hdbd_request, void *,
                        struct uarea *u) EXCLUDES_TRANSACTION;
extern long HDBD_GetNextHoardWalkTime();
 
#define PRINT_HDBDREQTYPE(type)         \
    ((type) == HdbAdd     ? "Add" :     \
     (type) == HdbDelete  ? "Delete" :  \
     (type) == HdbClear   ? "Clear" :   \
     (type) == HdbList    ? "List" :    \
     (type) == HdbWalk    ? "Walk" :    \
     (type) == HdbVerify  ? "Verify" :  \
     (type) == HdbEnable  ? "Enable" :  \
     (type) == HdbDisable ? "Disable" : \
                            "???")
 
#define PRINT_PESTATE(state)                      \
    ((state) == PeValid        ? "Valid" :        \
     (state) == PeSuspect      ? "Suspect" :      \
     (state) == PeIndigent     ? "Indigent" :     \
     (state) == PeInconsistent ? "Inconsistent" : \
                                 "???")
 
#endif /* VENUS */
 
#endif /* _VENUS_HDB_H_ */