diff options
Diffstat (limited to 'comm/mailnews/db/mork/morkThumb.cpp')
| -rw-r--r-- | comm/mailnews/db/mork/morkThumb.cpp | 455 |
1 files changed, 455 insertions, 0 deletions
diff --git a/comm/mailnews/db/mork/morkThumb.cpp b/comm/mailnews/db/mork/morkThumb.cpp new file mode 100644 index 0000000000..3076ca6f3e --- /dev/null +++ b/comm/mailnews/db/mork/morkThumb.cpp @@ -0,0 +1,455 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +#ifndef _MDB_ +# include "mdb.h" +#endif + +#ifndef _MORK_ +# include "mork.h" +#endif + +#ifndef _MORKNODE_ +# include "morkNode.h" +#endif + +#ifndef _MORKENV_ +# include "morkEnv.h" +#endif + +#ifndef _MORKTHUMB_ +# include "morkThumb.h" +#endif + +#ifndef _MORKSTORE_ +# include "morkStore.h" +#endif + +// #ifndef _MORKFILE_ +// #include "morkFile.h" +// #endif + +#ifndef _MORKWRITER_ +# include "morkWriter.h" +#endif + +#ifndef _MORKPARSER_ +# include "morkParser.h" +#endif + +#ifndef _MORKBUILDER_ +# include "morkBuilder.h" +#endif + +// 456789_123456789_123456789_123456789_123456789_123456789_123456789_123456789 + +// ````` ````` ````` ````` ````` +// { ===== begin morkNode interface ===== + +/*public virtual*/ void morkThumb::CloseMorkNode( + morkEnv* ev) // CloseThumb() only if open +{ + if (this->IsOpenNode()) { + this->MarkClosing(); + this->CloseThumb(ev); + this->MarkShut(); + } +} + +/*public virtual*/ +morkThumb::~morkThumb() // assert CloseThumb() executed earlier +{ + CloseMorkNode(mMorkEnv); + MORK_ASSERT(mThumb_Magic == 0); + MORK_ASSERT(mThumb_Store == 0); + MORK_ASSERT(mThumb_File == 0); +} + +/*public non-poly*/ +morkThumb::morkThumb(morkEnv* ev, const morkUsage& inUsage, nsIMdbHeap* ioHeap, + nsIMdbHeap* ioSlotHeap, mork_magic inMagic) + : morkObject(ev, inUsage, ioHeap, morkColor_kNone, (morkHandle*)0), + mThumb_Magic(0), + mThumb_Total(0), + mThumb_Current(0) + + , + mThumb_Done(morkBool_kFalse), + mThumb_Broken(morkBool_kFalse), + mThumb_Seed(0) + + , + mThumb_Store(0), + mThumb_File(0), + mThumb_Writer(0), + mThumb_Builder(0), + mThumb_SourcePort(0) + + , + mThumb_DoCollect(morkBool_kFalse) { + if (ev->Good()) { + if (ioSlotHeap) { + mThumb_Magic = inMagic; + mNode_Derived = morkDerived_kThumb; + } else + ev->NilPointerError(); + } +} + +NS_IMPL_ISUPPORTS_INHERITED(morkThumb, morkObject, nsIMdbThumb) + +/*public non-poly*/ void morkThumb::CloseThumb( + morkEnv* ev) // called by CloseMorkNode(); +{ + if (this->IsNode()) { + mThumb_Magic = 0; + if (mThumb_Builder && mThumb_Store) mThumb_Store->ForgetBuilder(ev); + morkBuilder::SlotStrongBuilder((morkBuilder*)0, ev, &mThumb_Builder); + + morkWriter::SlotStrongWriter((morkWriter*)0, ev, &mThumb_Writer); + nsIMdbFile_SlotStrongFile((nsIMdbFile*)0, ev, &mThumb_File); + morkStore::SlotStrongStore((morkStore*)0, ev, &mThumb_Store); + morkStore::SlotStrongPort((morkPort*)0, ev, &mThumb_SourcePort); + this->MarkShut(); + } else + this->NonNodeError(ev); +} + +// } ===== end morkNode methods ===== +// ````` ````` ````` ````` ````` + +// { ===== begin nsIMdbThumb methods ===== +NS_IMETHODIMP +morkThumb::GetProgress(nsIMdbEnv* mev, mdb_count* outTotal, + mdb_count* outCurrent, mdb_bool* outDone, + mdb_bool* outBroken) { + nsresult outErr = NS_OK; + morkEnv* ev = morkEnv::FromMdbEnv(mev); + if (ev) { + GetProgress(ev, outTotal, outCurrent, outDone, outBroken); + outErr = ev->AsErr(); + } + return outErr; +} + +NS_IMETHODIMP +morkThumb::DoMore(nsIMdbEnv* mev, mdb_count* outTotal, mdb_count* outCurrent, + mdb_bool* outDone, mdb_bool* outBroken) { + nsresult outErr = NS_OK; + morkEnv* ev = morkEnv::FromMdbEnv(mev); + if (ev) { + DoMore(ev, outTotal, outCurrent, outDone, outBroken); + outErr = ev->AsErr(); + } + return outErr; +} + +NS_IMETHODIMP +morkThumb::CancelAndBreakThumb(nsIMdbEnv* mev) { + nsresult outErr = NS_OK; + morkEnv* ev = morkEnv::FromMdbEnv(mev); + if (ev) { + mThumb_Done = morkBool_kTrue; + mThumb_Broken = morkBool_kTrue; + CloseMorkNode(ev); // should I close this here? + outErr = ev->AsErr(); + } + return outErr; +} +// } ===== end nsIMdbThumb methods ===== + +/*static*/ void morkThumb::NonThumbTypeError(morkEnv* ev) { + ev->NewError("non morkThumb"); +} + +/*static*/ void morkThumb::UnsupportedThumbMagicError(morkEnv* ev) { + ev->NewError("unsupported mThumb_Magic"); +} + +/*static*/ void morkThumb::NilThumbStoreError(morkEnv* ev) { + ev->NewError("nil mThumb_Store"); +} + +/*static*/ void morkThumb::NilThumbFileError(morkEnv* ev) { + ev->NewError("nil mThumb_File"); +} + +/*static*/ void morkThumb::NilThumbWriterError(morkEnv* ev) { + ev->NewError("nil mThumb_Writer"); +} + +/*static*/ void morkThumb::NilThumbBuilderError(morkEnv* ev) { + ev->NewError("nil mThumb_Builder"); +} + +/*static*/ void morkThumb::NilThumbSourcePortError(morkEnv* ev) { + ev->NewError("nil mThumb_SourcePort"); +} + +/*static*/ morkThumb* morkThumb::Make_OpenFileStore(morkEnv* ev, + nsIMdbHeap* ioHeap, + morkStore* ioStore) { + morkThumb* outThumb = 0; + if (ioHeap && ioStore) { + nsIMdbFile* file = ioStore->mStore_File; + if (file) { + mork_pos fileEof = 0; + file->Eof(ev->AsMdbEnv(), &fileEof); + if (ev->Good()) { + outThumb = + new (*ioHeap, ev) morkThumb(ev, morkUsage::kHeap, ioHeap, ioHeap, + morkThumb_kMagic_OpenFileStore); + + if (outThumb) { + morkBuilder* builder = ioStore->LazyGetBuilder(ev); + if (builder) { + outThumb->mThumb_Total = (mork_count)fileEof; + morkStore::SlotStrongStore(ioStore, ev, &outThumb->mThumb_Store); + morkBuilder::SlotStrongBuilder(builder, ev, + &outThumb->mThumb_Builder); + } + } + } + } else + ioStore->NilStoreFileError(ev); + } else + ev->NilPointerError(); + + return outThumb; +} + +/*static*/ morkThumb* morkThumb::Make_LargeCommit(morkEnv* ev, + nsIMdbHeap* ioHeap, + morkStore* ioStore) { + morkThumb* outThumb = 0; + if (ioHeap && ioStore) { + nsIMdbFile* file = ioStore->mStore_File; + if (file) { + outThumb = new (*ioHeap, ev) morkThumb( + ev, morkUsage::kHeap, ioHeap, ioHeap, morkThumb_kMagic_LargeCommit); + + if (outThumb) { + morkWriter* writer = new (*ioHeap, ev) + morkWriter(ev, morkUsage::kHeap, ioHeap, ioStore, file, ioHeap); + if (writer) { + writer->mWriter_CommitGroupIdentity = + ++ioStore->mStore_CommitGroupIdentity; + writer->mWriter_NeedDirtyAll = morkBool_kFalse; + outThumb->mThumb_DoCollect = morkBool_kFalse; + morkStore::SlotStrongStore(ioStore, ev, &outThumb->mThumb_Store); + + nsIMdbFile_SlotStrongFile(file, ev, &outThumb->mThumb_File); + + outThumb->mThumb_Writer = writer; // pass writer ownership to thumb + } + } + } else + ioStore->NilStoreFileError(ev); + } else + ev->NilPointerError(); + + return outThumb; +} + +/*static*/ morkThumb* morkThumb::Make_CompressCommit(morkEnv* ev, + nsIMdbHeap* ioHeap, + morkStore* ioStore, + mork_bool inDoCollect) { + morkThumb* outThumb = 0; + if (ioHeap && ioStore) { + nsIMdbFile* file = ioStore->mStore_File; + if (file) { + outThumb = + new (*ioHeap, ev) morkThumb(ev, morkUsage::kHeap, ioHeap, ioHeap, + morkThumb_kMagic_CompressCommit); + + if (outThumb) { + morkWriter* writer = new (*ioHeap, ev) + morkWriter(ev, morkUsage::kHeap, ioHeap, ioStore, file, ioHeap); + if (writer) { + writer->mWriter_NeedDirtyAll = morkBool_kTrue; + outThumb->mThumb_DoCollect = inDoCollect; + morkStore::SlotStrongStore(ioStore, ev, &outThumb->mThumb_Store); + nsIMdbFile_SlotStrongFile(file, ev, &outThumb->mThumb_File); + outThumb->mThumb_Writer = writer; // pass writer ownership to thumb + + // cope with fact that parsed transaction groups are going away: + ioStore->mStore_FirstCommitGroupPos = 0; + ioStore->mStore_SecondCommitGroupPos = 0; + } + } + } else + ioStore->NilStoreFileError(ev); + } else + ev->NilPointerError(); + + return outThumb; +} + +// { ===== begin non-poly methods imitating nsIMdbThumb ===== +void morkThumb::GetProgress(morkEnv* ev, mdb_count* outTotal, + mdb_count* outCurrent, mdb_bool* outDone, + mdb_bool* outBroken) { + MORK_USED_1(ev); + if (outTotal) *outTotal = mThumb_Total; + if (outCurrent) *outCurrent = mThumb_Current; + if (outDone) *outDone = mThumb_Done; + if (outBroken) *outBroken = mThumb_Broken; +} + +void morkThumb::DoMore(morkEnv* ev, mdb_count* outTotal, mdb_count* outCurrent, + mdb_bool* outDone, mdb_bool* outBroken) { + if (!mThumb_Done && !mThumb_Broken) { + switch (mThumb_Magic) { + case morkThumb_kMagic_OpenFilePort: // 1 /* factory method */ + this->DoMore_OpenFilePort(ev); + break; + + case morkThumb_kMagic_OpenFileStore: // 2 /* factory method */ + this->DoMore_OpenFileStore(ev); + break; + + case morkThumb_kMagic_ExportToFormat: // 3 /* port method */ + this->DoMore_ExportToFormat(ev); + break; + + case morkThumb_kMagic_ImportContent: // 4 /* store method */ + this->DoMore_ImportContent(ev); + break; + + case morkThumb_kMagic_LargeCommit: // 5 /* store method */ + this->DoMore_LargeCommit(ev); + break; + + case morkThumb_kMagic_SessionCommit: // 6 /* store method */ + this->DoMore_SessionCommit(ev); + break; + + case morkThumb_kMagic_CompressCommit: // 7 /* store method */ + this->DoMore_CompressCommit(ev); + break; + + case morkThumb_kMagic_SearchManyColumns: // 8 /* table method */ + this->DoMore_SearchManyColumns(ev); + break; + + case morkThumb_kMagic_NewSortColumn: // 9 /* table metho) */ + this->DoMore_NewSortColumn(ev); + break; + + case morkThumb_kMagic_NewSortColumnWithCompare: // 10 /* table method */ + this->DoMore_NewSortColumnWithCompare(ev); + break; + + case morkThumb_kMagic_CloneSortColumn: // 11 /* table method */ + this->DoMore_CloneSortColumn(ev); + break; + + case morkThumb_kMagic_AddIndex: // 12 /* table method */ + this->DoMore_AddIndex(ev); + break; + + case morkThumb_kMagic_CutIndex: // 13 /* table method */ + this->DoMore_CutIndex(ev); + break; + + default: + this->UnsupportedThumbMagicError(ev); + break; + } + } + if (outTotal) *outTotal = mThumb_Total; + if (outCurrent) *outCurrent = mThumb_Current; + if (outDone) *outDone = mThumb_Done; + if (outBroken) *outBroken = mThumb_Broken; +} + +void morkThumb::CancelAndBreakThumb(morkEnv* ev) { + MORK_USED_1(ev); + mThumb_Broken = morkBool_kTrue; +} + +// } ===== end non-poly methods imitating nsIMdbThumb ===== + +morkStore* morkThumb::ThumbToOpenStore(morkEnv* ev) +// for orkinFactory::ThumbToOpenStore() after OpenFileStore() +{ + MORK_USED_1(ev); + return mThumb_Store; +} + +void morkThumb::DoMore_OpenFilePort(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_OpenFileStore(morkEnv* ev) { + morkBuilder* builder = mThumb_Builder; + if (builder) { + mork_pos pos = 0; + builder->ParseMore(ev, &pos, &mThumb_Done, &mThumb_Broken); + // mThumb_Total = builder->mBuilder_TotalCount; + // mThumb_Current = builder->mBuilder_DoneCount; + mThumb_Current = (mork_count)pos; + } else { + this->NilThumbBuilderError(ev); + mThumb_Broken = morkBool_kTrue; + mThumb_Done = morkBool_kTrue; + } +} + +void morkThumb::DoMore_ExportToFormat(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_ImportContent(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_LargeCommit(morkEnv* ev) { this->DoMore_Commit(ev); } + +void morkThumb::DoMore_SessionCommit(morkEnv* ev) { this->DoMore_Commit(ev); } + +void morkThumb::DoMore_Commit(morkEnv* ev) { + morkWriter* writer = mThumb_Writer; + if (writer) { + writer->WriteMore(ev); + mThumb_Total = writer->mWriter_TotalCount; + mThumb_Current = writer->mWriter_DoneCount; + mThumb_Done = (ev->Bad() || writer->IsWritingDone()); + mThumb_Broken = ev->Bad(); + } else { + this->NilThumbWriterError(ev); + mThumb_Broken = morkBool_kTrue; + mThumb_Done = morkBool_kTrue; + } +} + +void morkThumb::DoMore_CompressCommit(morkEnv* ev) { this->DoMore_Commit(ev); } + +void morkThumb::DoMore_SearchManyColumns(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_NewSortColumn(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_NewSortColumnWithCompare(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_CloneSortColumn(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_AddIndex(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +void morkThumb::DoMore_CutIndex(morkEnv* ev) { + this->UnsupportedThumbMagicError(ev); +} + +// 456789_123456789_123456789_123456789_123456789_123456789_123456789_123456789 |