00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025 #ifndef __ZTxn__
00026 #define __ZTxn__ 1
00027 #include "zconfig.h"
00028
00029 #include "ZCompat_NonCopyable.h"
00030 #include "ZThread.h"
00031 #include "ZTypes.h"
00032
00033 #include <map>
00034 #include <vector>
00035
00036 class ZTxnTarget;
00037
00038
00039 #pragma mark -
00040 #pragma mark * ZTxn
00041
00043 class ZTxn : ZooLib::NonCopyable
00044 {
00045 public:
00046 ZTxn();
00047 ~ZTxn();
00048
00049 bool Commit();
00050 void Abort();
00051
00052 int32 GetID() const;
00053
00054 private:
00055 bool pCommit();
00056 void pAbort();
00057 void pRegisterTarget(ZTxnTarget* iTarget) const;
00058
00059 static void sValidateCallback(bool iOkay, void* iRefcon);
00060 static void sCommitCallback(void* iRefcon);
00061
00062 int32 fID;
00063
00064 ZMutex fMutex;
00065 mutable std::vector<ZTxnTarget*> fTargets;
00066
00067 friend class ZTxnTarget;
00068 };
00069
00070
00071 #pragma mark -
00072 #pragma mark * ZTxnTarget
00073
00074 class ZTxnTarget
00075 {
00076 protected:
00077 void RegisterWithTxn(const ZTxn& iTxn);
00078
00079 typedef void (*ValidateCallbackProc)(bool iOkay, void* iRefcon);
00080 typedef void (*CommitCallbackProc)(void* iRefcon);
00081
00082 virtual void TxnAbortPreValidate(int32 iTxnID) = 0;
00083 virtual void TxnValidate(int32 iTxnID, ValidateCallbackProc iCallback, void* iRefcon) = 0;
00084 virtual void TxnAbortPostValidate(int32 iTxnID, bool iValidationSucceeded) = 0;
00085 virtual void TxnCommit(int32 iTxnID, CommitCallbackProc iCallback, void* iRefcon) = 0;
00086
00087 friend class ZTxn;
00088 };
00089
00090 #endif // __ZTxn__