00001 #ifndef _ManagementObject_
00002 #define _ManagementObject_
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025 #include "qpid/sys/Time.h"
00026 #include "qpid/sys/Mutex.h"
00027 #include <qpid/framing/Buffer.h>
00028 #include <boost/shared_ptr.hpp>
00029 #include <map>
00030
00031 namespace qpid {
00032 namespace management {
00033
00034 class Manageable;
00035
00036 class ManagementObject
00037 {
00038 protected:
00039
00040 uint64_t createTime;
00041 uint64_t destroyTime;
00042 uint64_t objectId;
00043 bool configChanged;
00044 bool instChanged;
00045 bool deleted;
00046 Manageable* coreObject;
00047 sys::RWlock accessLock;
00048
00049 static const uint8_t TYPE_U8 = 1;
00050 static const uint8_t TYPE_U16 = 2;
00051 static const uint8_t TYPE_U32 = 3;
00052 static const uint8_t TYPE_U64 = 4;
00053 static const uint8_t TYPE_SSTR = 6;
00054 static const uint8_t TYPE_LSTR = 7;
00055 static const uint8_t TYPE_ABSTIME = 8;
00056 static const uint8_t TYPE_DELTATIME = 9;
00057 static const uint8_t TYPE_REF = 10;
00058 static const uint8_t TYPE_BOOL = 11;
00059 static const uint8_t TYPE_FLOAT = 12;
00060 static const uint8_t TYPE_DOUBLE = 13;
00061 static const uint8_t TYPE_UUID = 14;
00062 static const uint8_t TYPE_FTABLE = 15;
00063
00064 static const uint8_t ACCESS_RC = 1;
00065 static const uint8_t ACCESS_RW = 2;
00066 static const uint8_t ACCESS_RO = 3;
00067
00068 static const uint8_t DIR_I = 1;
00069 static const uint8_t DIR_O = 2;
00070 static const uint8_t DIR_IO = 3;
00071
00072 static const uint8_t FLAG_CONFIG = 0x01;
00073 static const uint8_t FLAG_INDEX = 0x02;
00074 static const uint8_t FLAG_END = 0x80;
00075
00076 void writeTimestamps (qpid::framing::Buffer& buf);
00077
00078 public:
00079 typedef boost::shared_ptr<ManagementObject> shared_ptr;
00080 typedef void (*writeSchemaCall_t) (qpid::framing::Buffer&);
00081
00082 ManagementObject (Manageable* _core) :
00083 destroyTime(0), objectId (0), configChanged(true),
00084 instChanged(true), deleted(false), coreObject(_core)
00085 { createTime = uint64_t (qpid::sys::Duration (qpid::sys::now ())); }
00086 virtual ~ManagementObject () {}
00087
00088 virtual writeSchemaCall_t getWriteSchemaCall (void) = 0;
00089 virtual void writeConfig (qpid::framing::Buffer& buf) = 0;
00090 virtual void writeInstrumentation (qpid::framing::Buffer& buf,
00091 bool skipHeaders = false) = 0;
00092 virtual void doMethod (std::string methodName,
00093 qpid::framing::Buffer& inBuf,
00094 qpid::framing::Buffer& outBuf) = 0;
00095
00096 virtual std::string getClassName (void) = 0;
00097 virtual std::string getPackageName (void) = 0;
00098 virtual uint8_t* getMd5Sum (void) = 0;
00099
00100 void setObjectId (uint64_t oid) { objectId = oid; }
00101 uint64_t getObjectId (void) { return objectId; }
00102 inline bool getConfigChanged (void) { return configChanged; }
00103 virtual bool getInstChanged (void) { return instChanged; }
00104 inline void setAllChanged (void)
00105 {
00106 configChanged = true;
00107 instChanged = true;
00108 }
00109
00110 inline void resourceDestroy (void) {
00111 destroyTime = uint64_t (qpid::sys::Duration (qpid::sys::now ()));
00112 deleted = true;
00113 }
00114 bool isDeleted (void) { return deleted; }
00115
00116 };
00117
00118 typedef std::map<uint64_t,ManagementObject::shared_ptr> ManagementObjectMap;
00119
00120 }}
00121
00122
00123
00124 #endif