data.h

Go to the documentation of this file.

#ifndef _BLURB_
#define _BLURB_
/*
 
            Coda: an Experimental Distributed File System
                             Release 6
 
          Copyright (c) 1987-2003 Carnegie Mellon University
                         All Rights Reserved
 
Permission  to  use, copy, modify and distribute this software and its
documentation is hereby granted,  provided  that  both  the  copyright
notice  and  this  permission  notice  appear  in  all  copies  of the
software, derivative works or  modified  versions,  and  any  portions
thereof, and that both notices appear in supporting documentation, and
that credit is given to Carnegie Mellon University  in  all  documents
and publicity pertaining to direct or indirect use of this code or its
derivatives.
 
CODA IS AN EXPERIMENTAL SOFTWARE SYSTEM AND IS  KNOWN  TO  HAVE  BUGS,
SOME  OF  WHICH MAY HAVE SERIOUS CONSEQUENCES.  CARNEGIE MELLON ALLOWS
FREE USE OF THIS SOFTWARE IN ITS "AS IS" CONDITION.   CARNEGIE  MELLON
DISCLAIMS  ANY  LIABILITY  OF  ANY  KIND  FOR  ANY  DAMAGES WHATSOEVER
RESULTING DIRECTLY OR INDIRECTLY FROM THE USE OF THIS SOFTWARE  OR  OF
ANY DERIVATIVE WORK.
 
Carnegie  Mellon  encourages  users  of  this  software  to return any
improvements or extensions that  they  make,  and  to  grant  Carnegie
Mellon the rights to redistribute these changes without encumbrance.
*/
#endif /*_BLURB_*/
 
#ifndef _DATA_H_
#define _DATA_H_
 
//
// data.h
//
// This file contains defns for the assorted data that mond catches
//  -- mostly very simple.  Just the container class + subclasses.
// It also contains the defn of the buffer pool class.
 
//
// First, the superclass of all data classes that encapsulate
// types that mond will put in it's bounded buffer...
//
// It consists only of a type field.
 
/* buffer pools */
/* TODO: think about being able to remove buffers from the pool */
 
//
// A Note about Copy Constructors:
//    Copy constructors for those data classes that have specialized constructors
//    and destructors are not implemented.  I've created simple ones that simply
//    cause an abort.  The reason is that the default copy constructor can cause
//    obscure bugs in the case that the data class contains an imbedded array.
//    The default copy constructor will bcopy the array from the original.  If the
//    specialized destructor knows to delete the imbedded array, you'll end up
//    deleting the thing twice.  So, we've chosen to create simple copy constructors
//    that abort in an obvious way to prevent new mond programmers from shooting
//    themselves in the foot.  ;-)  If you want a copy constructor, feel free to
//    implement one and remove the abort.
//
 
class callCountArray;
class multiCallArray;
class vmon_data;
class session_data;
class comm_data;
class clientCall_data;
class clientMCall_data;
class clientRVM_data;
class vcb_data;
class miniCache_data;
class overflow_data;
class srvrCall_data;
class resEvent_data;
class srvOverflow_data;
class bufpool;
 
class callCountArray {
    long size;
    CallCountEntry *array;
 
public:
    callCountArray(void);
    callCountArray(callCountArray &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~callCountArray(void);
    void set(long, CallCountEntry *);
    long getSize(void) { return size; }
    CallCountEntry *getArray(void) { return array; }
    Print(void);
};
 
class multiCallArray {
    long size;
    MultiCallEntry *array;
 
public:
    multiCallArray();
    multiCallArray(multiCallArray &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~multiCallArray();
    void set(long, MultiCallEntry *);
    long getSize(void) { return size; }
    MultiCallEntry *getArray(void) { return array; }
};
 
class vmon_data {
    vmon_data *next;
 
public:
    virtual ~vmon_data(void)     = 0;
    virtual void Report(void)    = 0;
    virtual dataClass Type(void) = 0;
    virtual char *TypeName(void) = 0;
    virtual void Release(void)   = 0;
    virtual void Print(void);
    inline void SetNext(vmon_data *theNext) { next = theNext; }
    inline void NotOnList(void) { next = NULL; }
    inline vmon_data *Next() { return next; }
};
 
class session_data : private vmon_data {
    VmonVenusId Venus;
    VmonSessionId Session;
    VolumeId Volume;
    UserId User;
    VmonAVSG AVSG;
    unsigned long StartTime;
    unsigned long EndTime;
    unsigned long CETime;
    VmonSessionEventArray Events;
    SessionStatistics Stats;
    CacheStatistics CacheStats;
 
public:
    dataClass Type(void) { return SESSION; }
    char *TypeName(void) { return "Session"; }
    void Report(void)
    {
        (void)ReportSession(&Venus, Session, Volume, User, &AVSG, StartTime,
                            EndTime, CETime, &Events, &Stats, &CacheStats);
    }
    void Release(void);
    void init(VmonVenusId *, VmonSessionId, VolumeId, UserId, VmonAVSG *,
              unsigned long, unsigned long, unsigned long, long,
              VmonSessionEvent[], SessionStatistics *, CacheStatistics *);
    VmonSessionEventArray *theEvents() { return &Events; }
};
 
class comm_data : private vmon_data {
    VmonVenusId Venus;
    unsigned long ServerIPAddress;
    long SerialNumber;
    unsigned long Time;
    VmonCommEventType EvType;
 
public:
    inline dataClass Type(void) { return COMM; }
    char *TypeName(void) { return "CommEvent"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportCommEvent(&Venus, ServerIPAddress, SerialNumber, Time,
                              EvType);
    }
    void init(VmonVenusId *, unsigned long, long, unsigned long,
              VmonCommEventType);
};
 
class clientCall_data : private vmon_data {
    VmonVenusId Venus;
    long Time;
    class callCountArray SrvCount;
 
public:
    inline dataClass Type(void) { return CLNTCALL; }
    char *TypeName(void) { return "Client Call"; }
    void Release(void);
    void Report(void) { (void)ReportClntCall(&Venus, Time, &SrvCount); }
    void init(VmonVenusId *, long, long, CallCountEntry *);
    void Print(void);
};
 
class clientMCall_data : private vmon_data {
    VmonVenusId Venus;
    long Time;
    class multiCallArray MSrvCount;
 
public:
    inline dataClass Type(void) { return CLNTMCALL; }
    char *TypeName(void) { return "Client Call"; }
    void Release(void);
    void Report(void) { (void)ReportClntMCall(&Venus, Time, &MSrvCount); }
    void init(VmonVenusId *, long, long, MultiCallEntry *);
};
 
class clientRVM_data : private vmon_data {
    VmonVenusId Venus;
    long Time;
    RvmStatistics Stats;
 
public:
    inline dataClass Type(void) { return CLNTRVM; }
    char *TypeName(void) { return "Client Call"; }
    void Release(void);
    void Report(void) { (void)ReportClntRVM(&Venus, Time, &Stats); }
    void init(VmonVenusId *, long, RvmStatistics *);
};
 
class vcb_data : private vmon_data {
    VmonVenusId Venus;
    long VenusInit;
    long Time;
    VolumeId Volume;
    VCBStatistics Stats;
 
public:
    inline dataClass Type(void) { return VCB; }
    char *TypeName(void) { return "VCB Stats"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportVCB(&Venus, VenusInit, Time, Volume, &Stats);
    }
    void init(VmonVenusId *, long, long, VolumeId, VCBStatistics *);
};
 
class advice_data : private vmon_data {
    VmonVenusId Venus;
    long Time;
    UserId User;
    AdviceStatistics Stats;
    unsigned long Call_Size;
    AdviceCalls *Call_Stats;
    unsigned long Result_Size;
    AdviceResults *Result_Stats;
 
public:
    advice_data();
    advice_data(advice_data &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~advice_data();
    inline dataClass Type(void) { return ADVICE; }
    char *TypeName(void) { return "Client Advice Stats"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportAdviceCall(&Venus, Time, User, &Stats, Call_Size,
                               Call_Stats, Result_Size, Result_Stats);
    }
    void init(VmonVenusId *, long, UserId, AdviceStatistics *, unsigned long,
              AdviceCalls[], unsigned long, AdviceResults[]);
};
 
class miniCache_data : private vmon_data {
    VmonVenusId Venus;
    long Time;
    unsigned long VN_Size;
    VmonMiniCacheStat *VN_Stats;
    unsigned long VFS_Size;
    VmonMiniCacheStat *VFS_Stats;
 
public:
    miniCache_data();
    miniCache_data(miniCache_data &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~miniCache_data();
    inline dataClass Type(void) { return MINICACHE; }
    char *TypeName(void) { return "Client MiniCache Stats"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportMiniCacheCall(&Venus, Time, VN_Size, VN_Stats, VFS_Size,
                                  VFS_Stats);
    }
    void init(VmonVenusId *, long, unsigned long, VmonMiniCacheStat[],
              unsigned long, VmonMiniCacheStat[]);
};
 
class overflow_data : private vmon_data {
    VmonVenusId Venus;
    unsigned long VMStartTime;
    unsigned long VMEndTime;
    long VMCount;
    unsigned long RVMStartTime;
    unsigned long RVMEndTime;
    long RVMCount;
 
public:
    inline dataClass Type(void) { return OVERFLOW; }
    char *TypeName(void) { return "Client Overflow"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportOverflow(&Venus, VMStartTime, VMEndTime, VMCount,
                             RVMStartTime, RVMEndTime, RVMCount);
    }
    void init(VmonVenusId *, unsigned long, unsigned long, long, unsigned long,
              unsigned long, long);
};
 
enum countArrayType
{
    CALLBACK,
    RESOLVE,
    SMON,
    VOLD,
    MULTICAST
};
 
class srvrCall_data : private vmon_data {
    SmonViceId Vice;
    unsigned long Time;
    class callCountArray CBCount;
    class callCountArray ResCount;
    class callCountArray SmonCount;
    class callCountArray VolDCount;
    class multiCallArray MultiCount;
    SmonStatistics Stats;
 
public:
    dataClass Type(void) { return SRVCALL; }
    char *TypeName(void) { return "Server Call"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportSrvrCall(&Vice, Time, &CBCount, &ResCount, &SmonCount,
                             &VolDCount, &MultiCount, &Stats);
    }
    void init(SmonViceId *, unsigned long, long, CallCountEntry *, long,
              CallCountEntry *, long, CallCountEntry *, long, CallCountEntry *,
              long, MultiCallEntry *, SmonStatistics *);
};
 
class resEvent_data : private vmon_data {
    SmonViceId Vice;
    unsigned long Time;
    VolumeId Volid;
    long HighWaterMark;
    long AllocNumber;
    long DeallocNumber;
    long ResOp_size;
    ResOpEntry *ResOp;
 
public:
    dataClass Type(void) { return SRVRES; }
    char *TypeName(void) { return "Res Event"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportResEvent(&Vice, Time, Volid, HighWaterMark, AllocNumber,
                             DeallocNumber, ResOp_size, ResOp);
    }
    void init(SmonViceId *, RPC2_Unsigned, VolumeId, RPC2_Integer, RPC2_Integer,
              RPC2_Integer, RPC2_Integer, ResOpEntry[]);
    resEvent_data(void);
    resEvent_data(resEvent_data &)
    {
        abort();
    } /* Not implemented. See comment above. */
    //no destructor is needed
};
 
class srvOverflow_data : private vmon_data {
    SmonViceId Vice;
    unsigned long Time;
    unsigned long StartTime;
    unsigned long EndTime;
    long Count;
 
public:
    dataClass Type(void) { return SRVOVRFLW; }
    char *TypeName(void) { return "Server Overflow"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportSrvOverflow(&Vice, Time, StartTime, EndTime, Count);
    }
    void init(SmonViceId *, RPC2_Unsigned, RPC2_Unsigned, RPC2_Unsigned,
              RPC2_Integer);
};
 
class iotInfo_data : private vmon_data {
    VmonVenusId Venus;
    IOT_INFO Info;
    RPC2_Integer AppNameLen;
    RPC2_String AppName;
 
public:
    iotInfo_data();
    iotInfo_data(iotInfo_data &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~iotInfo_data();
    inline dataClass Type(void) { return IOTINFO; }
    char *TypeName(void) { return "Client IOT Info"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportIotInfoCall(&Venus, &Info, AppNameLen, AppName);
    }
    void init(VmonVenusId *, IOT_INFO *, RPC2_Integer, RPC2_String);
};
 
class iotStat_data : private vmon_data {
    VmonVenusId Venus;
    RPC2_Integer Time;
    IOT_STAT Stats;
 
public:
    inline dataClass Type(void) { return IOTSTAT; }
    char *TypeName(void) { return "Client IOT Stat"; }
    void Release(void);
    void Report(void) { (void)ReportIotStatsCall(&Venus, Time, &Stats); }
    void init(VmonVenusId *, RPC2_Integer, IOT_STAT *);
};
 
class subtree_data : private vmon_data {
    VmonVenusId Venus;
    RPC2_Integer Time;
    LocalSubtreeStats Stats;
 
public:
    inline dataClass Type(void) { return SUBTREE; }
    char *TypeName(void) { return "Client Localized Subtree Stats"; }
    void Release(void);
    void Report(void) { (void)ReportSubtreeCall(&Venus, Time, &Stats); }
    void init(VmonVenusId *, RPC2_Integer, LocalSubtreeStats *);
};
 
class repair_data : private vmon_data {
    VmonVenusId Venus;
    RPC2_Integer Time;
    RepairSessionStats Stats;
 
public:
    inline dataClass Type(void) { return REPAIR; }
    char *TypeName(void) { return "Client Local/Global Repair Session Stats"; }
    void Release(void);
    void Report(void) { (void)ReportRepairCall(&Venus, Time, &Stats); }
    void init(VmonVenusId *, RPC2_Integer, RepairSessionStats *);
};
 
class rwsStat_data : private vmon_data {
    VmonVenusId Venus;
    RPC2_Integer Time;
    ReadWriteSharingStats Stats;
 
public:
    inline dataClass Type(void) { return RWSSTAT; }
    char *TypeName(void) { return "Client RWS Stat"; }
    void Release(void);
    void Report(void) { (void)ReportRwsStatsCall(&Venus, Time, &Stats); }
    void init(VmonVenusId *, RPC2_Integer, ReadWriteSharingStats *);
};
 
class bufpool {
    MUTEX lock;
    vmon_data *Pool;
    dataClass type;
 
public:
    bufpool(dataClass);
    vmon_data *getSlot(void);
    void putSlot(vmon_data *);
};
 
struct Histogram {
    long size;
    HistoElem *buckets;
 
    Histogram();
    Histogram(Histogram &)
    {
        abort();
    } /* Not implemented. See comment above. */
    ~Histogram();
    void set(long _size, HistoElem _buckets[]);
};
 
class rvmResEvent_data : private vmon_data {
    SmonViceId Vice;
    unsigned long Time;
    unsigned long VolID;
    FileResStats FileRes;
    DirResStats DirRes;
    Histogram LogSizeHisto;
    Histogram LogMaxHisto;
    ResConflictStats Conflicts;
    Histogram SuccHierHist;
    Histogram FailHierHist;
    ResLogStats ResLog;
    Histogram VarLogHisto;
    Histogram LogSize;
 
public:
    dataClass Type(void) { return SRVRVMRES; }
    char *TypeName(void) { return "Rvm Resolution Stats"; }
    void Release(void);
    void Report(void)
    {
        (void)ReportRvmResEvent(Vice, Time, VolID, FileRes, DirRes,
                                &LogSizeHisto, &LogMaxHisto, Conflicts,
                                &SuccHierHist, &FailHierHist, ResLog,
                                &VarLogHisto, &LogSize);
    }
    void init(SmonViceId, unsigned long, unsigned long, FileResStats,
              DirResStats, long, HistoElem[], long, HistoElem[],
              ResConflictStats, long, HistoElem[], long, HistoElem[],
              ResLogStats, long, HistoElem[], long, HistoElem[]);
    /* use the default ctor */
    //rvmResEvent_data(void);
    //no destructor is needed
};
 
// extern'ed bufpools
 
extern bufpool session_pool;
extern bufpool comm_pool;
extern bufpool clientCall_pool;
extern bufpool clientMCall_pool;
extern bufpool clientRVM_pool;
extern bufpool vcb_pool;
extern bufpool advice_pool;
extern bufpool miniCache_pool;
extern bufpool overflow_pool;
extern bufpool srvrCall_pool;
extern bufpool resEvent_pool;
extern bufpool rvmResEvent_pool;
extern bufpool srvOverflow_pool;
extern bufpool iotInfo_pool;
extern bufpool iotStat_pool;
extern bufpool subtree_pool;
extern bufpool repair_pool;
extern bufpool rwsStat_pool;
 
#endif _DATA_H_