TGBlobBs Class Reference

#include <blobbs.h>

Inherits TBlobBs.

Public Member Functions
	TGBlobBs (const TStr &BlobBsFNm, const TFAccess &_Access=faRdOnly, const int &_MxSegLen=-1)
	~TGBlobBs ()
TGBlobBs &	operator= (const TGBlobBs &)
TStr	GetVersionStr () const
TBlobPt	PutBlob (const PSIn &SIn)
TBlobPt	PutBlob (const TBlobPt &BlobPt, const PSIn &SIn)
PSIn	GetBlob (const TBlobPt &BlobPt)
void	DelBlob (const TBlobPt &BlobPt)
TBlobPt	GetFirstBlobPt ()
TBlobPt	FFirstBlobPt ()
bool	FNextBlobPt (TBlobPt &TrvBlobPt, TBlobPt &BlobPt, PSIn &BlobSIn)
Public Member Functions inherited from TBlobBs
	UndefCopyAssign (TBlobBs)
	TBlobBs ()
virtual	~TBlobBs ()
	TBlobBs (TSIn &)
void	Save (TSOut &) const
void	PutVersionStr (const PFRnd &FBlobBs)
void	AssertVersionStr (const PFRnd &FBlobBs)
TStr	GetBlobBsStateStr (const TBlobBsState &BlobBsState)
int	GetStateStrLen ()
void	PutBlobBsStateStr (const PFRnd &FBlobBs, const TBlobBsState &State)
void	AssertBlobBsStateStr (const PFRnd &FBlobBs, const TBlobBsState &State)
void	PutMxSegLen (const PFRnd &FBlobBs, const int &MxSegLen)
int	GetMxSegLen (const PFRnd &FBlobBs)
void	GenBlockLenV (TIntV &BlockLenV)
void	PutBlockLenV (const PFRnd &FBlobBs, const TIntV &BlockLenV)
void	GetBlockLenV (const PFRnd &FBlobBs, TIntV &BlockLenV)
void	GenFFreeBlobPtV (const TIntV &BlockLenV, TBlobPtV &FFreeBlobPtV)
void	PutFFreeBlobPtV (const PFRnd &FBlobBs, const TBlobPtV &FFreeBlobPtV)
void	GetFFreeBlobPtV (const PFRnd &FBlobBs, TBlobPtV &FFreeBlobPtV)
void	GetAllocInfo (const int &BfL, const TIntV &BlockLenV, int &MxBfL, int &FFreeBlobPtN)
uint	GetBeginBlobTag ()
uint	GetEndBlobTag ()
void	PutBlobTag (const PFRnd &FBlobBs, const TBlobTag &BlobTag)
void	AssertBlobTag (const PFRnd &FBlobBs, const TBlobTag &BlobTag)
void	PutBlobState (const PFRnd &FBlobBs, const TBlobState &State)
TBlobState	GetBlobState (const PFRnd &FBlobBs)
void	AssertBlobState (const PFRnd &FBlobBs, const TBlobState &State)
void	AssertBfCsEqFlCs (const TCs &BfCs, const TCs &FCs)
TBlobPt	PutBlob (const TStr &Str)
bool	FNextBlobPt (TBlobPt &TrvBlobPt, PSIn &BlobSIn)

Static Public Member Functions
static PBlobBs	New (const TStr &BlobBsFNm, const TFAccess &Access=faRdOnly, const int &MxSegLen=-1)
static bool	Exists (const TStr &BlobBsFNm)
Static Public Member Functions inherited from TBlobBs
static PBlobBs	Load (TSIn &)

Static Private Member Functions
static TStr	GetNrBlobBsFNm (const TStr &BlobBsFNm)

Private Attributes
PFRnd	FBlobBs
TFAccess	Access
int	MxSegLen
TIntV	BlockLenV
TBlobPtV	FFreeBlobPtV
TBlobPt	FirstBlobPt

Additional Inherited Members
Static Public Attributes inherited from TBlobBs
static const int	MnBlobBfL =16
static const int	MxBlobFLen =1000000000
static const TStr	MxSegLenVNm ="MxSegLen"
static const TStr	BlockLenVNm ="BlockLenV"
static const TStr	FFreeBlobPtVNm ="FFreeBlobPtV"

Detailed Description

Definition at line 154 of file blobbs.h.

Constructor & Destructor Documentation

TGBlobBs::TGBlobBs	(	const TStr &	BlobBsFNm,
		const TFAccess &	_Access = faRdOnly,
		const int &	_MxSegLen = -1
	)

Definition at line 220 of file blobbs.cpp.

                                                                      :
  TBlobBs(), FBlobBs(), Access(_Access), MxSegLen(_MxSegLen),
  BlockLenV(), FFreeBlobPtV(TB4Def::B4Bits), FirstBlobPt(){
  if (MxSegLen==-1){MxSegLen=MxBlobFLen;}
  TStr NrBlobBsFNm=GetNrBlobBsFNm(BlobBsFNm);
  switch (Access){
    case faCreate:
      FBlobBs=TFRnd::New(NrBlobBsFNm, faCreate, true); break;
    case faUpdate:
    case faRdOnly:
    case faRestore:
      FBlobBs=TFRnd::New(NrBlobBsFNm, faUpdate, true); break;
    default: Fail;
  }
  if (FBlobBs->Empty()){
    FBlobBs->SetFPos(0);
    PutVersionStr(FBlobBs);
    PutBlobBsStateStr(FBlobBs, bbsOpened);
    PutMxSegLen(FBlobBs, MxSegLen);
    GenBlockLenV(BlockLenV);
    PutBlockLenV(FBlobBs, BlockLenV);
    GenFFreeBlobPtV(BlockLenV, FFreeBlobPtV);
    PutFFreeBlobPtV(FBlobBs, FFreeBlobPtV);
  } else {
    FBlobBs->SetFPos(0);
    AssertVersionStr(FBlobBs);
    int FPos=FBlobBs->GetFPos();
    if (Access!=faRestore){
      AssertBlobBsStateStr(FBlobBs, bbsClosed);}
    if (Access!=faRdOnly){
      FBlobBs->SetFPos(FPos);
      PutBlobBsStateStr(FBlobBs, bbsOpened);
    }
    MxSegLen=GetMxSegLen(FBlobBs);
    GetBlockLenV(FBlobBs, BlockLenV);
    GetFFreeBlobPtV(FBlobBs, FFreeBlobPtV);
  }
  FirstBlobPt=TBlobPt(FBlobBs->GetFPos());
  FBlobBs->Flush();
}

TGBlobBs::~TGBlobBs

(

)

Definition at line 262 of file blobbs.cpp.

                   {
  if (Access!=faRdOnly){
    FBlobBs->SetFPos(0);
    PutVersionStr(FBlobBs);
    PutBlobBsStateStr(FBlobBs, bbsClosed);
    PutMxSegLen(FBlobBs, MxSegLen);
    PutBlockLenV(FBlobBs, BlockLenV);
    PutFFreeBlobPtV(FBlobBs, FFreeBlobPtV);
  }
  FBlobBs->Flush();
  FBlobBs=NULL;
}

Member Function Documentation

void TGBlobBs::DelBlob ( const TBlobPt &  BlobPt )

virtual

Implements TBlobBs.

Definition at line 353 of file blobbs.cpp.

                                           {
  EAssert((Access==faCreate)||(Access==faUpdate)||(Access==faRestore));
  FBlobBs->SetFPos(BlobPt.GetAddr());
  AssertBlobTag(FBlobBs, btBegin);
  int MxBfL=FBlobBs->GetInt();
  int FPos=FBlobBs->GetFPos();
  AssertBlobState(FBlobBs, bsActive);
  /*int BfL=*/FBlobBs->GetInt();
  FBlobBs->SetFPos(FPos);
  PutBlobState(FBlobBs, bsFree);
  int _MxBfL; int FFreeBlobPtN;
  GetAllocInfo(MxBfL, BlockLenV, _MxBfL, FFreeBlobPtN);
  EAssert(MxBfL==_MxBfL);
  FFreeBlobPtV[FFreeBlobPtN].SaveAddr(FBlobBs);
  FFreeBlobPtV[FFreeBlobPtN]=BlobPt;
  FBlobBs->PutCh(TCh::NullCh, MxBfL+sizeof(TCs));
  AssertBlobTag(FBlobBs, btEnd);
  FBlobBs->Flush();
}

bool TGBlobBs::Exists ( const TStr &  BlobBsFNm )

static

Definition at line 410 of file blobbs.cpp.

                                          {
  TStr NrBlobBsFNm=GetNrBlobBsFNm(BlobBsFNm);
  return TFile::Exists(NrBlobBsFNm);
}

TBlobPt TGBlobBs::FFirstBlobPt ( )

virtual

Implements TBlobBs.

Definition at line 373 of file blobbs.cpp.

                              {
  return FirstBlobPt;
}

bool TGBlobBs::FNextBlobPt ( TBlobPt &  TrvBlobPt, TBlobPt &  BlobPt, PSIn &  BlobSIn  )

virtual

Implements TBlobBs.

Definition at line 377 of file blobbs.cpp.

                                                                            {
  forever {
    uint TrvBlobAddr=TrvBlobPt.GetAddr();
    if (TrvBlobAddr>=uint(FBlobBs->GetFLen())){
      TrvBlobPt.Clr(); BlobPt.Clr(); BlobSIn=NULL;
      return false;
    } else {
      FBlobBs->SetFPos(TrvBlobAddr);
      AssertBlobTag(FBlobBs, btBegin);
      int MxBfL=FBlobBs->GetInt();
      TBlobState BlobState=GetBlobState(FBlobBs);
      switch (BlobState){
        case bsActive:{
          int BfL=FBlobBs->GetInt();
          TCs BfCs; BlobSIn=FBlobBs->GetSIn(BfL, BfCs);
          FBlobBs->MoveFPos(MxBfL-BfL);
          TCs FCs=FBlobBs->GetCs();
          AssertBlobTag(FBlobBs, btEnd);
          AssertBfCsEqFlCs(BfCs, FCs);
          BlobPt=TrvBlobPt;
          TrvBlobPt=TBlobPt(FBlobBs->GetFPos());
          return true;}
        case bsFree:
          FBlobBs->MoveFPos(sizeof(uint)+MxBfL+sizeof(TCs));
          AssertBlobTag(FBlobBs, btEnd);
          TrvBlobPt=TBlobPt(FBlobBs->GetFPos());
          break;
        default: Fail; return false;
      }
    }
  }
}

PSIn TGBlobBs::GetBlob ( const TBlobPt &  BlobPt )

virtual

Implements TBlobBs.

Definition at line 339 of file blobbs.cpp.

                                           {
  FBlobBs->SetFPos(BlobPt.GetAddr());
  AssertBlobTag(FBlobBs, btBegin);
  int MxBfL=FBlobBs->GetInt();
  AssertBlobState(FBlobBs, bsActive);
  int BfL=FBlobBs->GetInt();
  TCs BfCs; PSIn SIn=FBlobBs->GetSIn(BfL, BfCs);
  FBlobBs->MoveFPos(MxBfL-BfL);
  TCs FCs=FBlobBs->GetCs();
  AssertBlobTag(FBlobBs, btEnd);
  AssertBfCsEqFlCs(BfCs, FCs);
  return SIn;
}

TBlobPt TGBlobBs::GetFirstBlobPt ( )

inlinevirtual

Implements TBlobBs.

Definition at line 179 of file blobbs.h.

{return FirstBlobPt;}

TStr TGBlobBs::GetNrBlobBsFNm ( const TStr &  BlobBsFNm )

staticprivate

Definition at line 213 of file blobbs.cpp.

                                                  {
  TStr NrBlobBsFNm=BlobBsFNm;
  if (NrBlobBsFNm.GetFExt().Empty()){
    NrBlobBsFNm=NrBlobBsFNm+".gbb";}
  return NrBlobBsFNm;
}

TStr TGBlobBs::GetVersionStr ( ) const

inlinevirtual

Implements TBlobBs.

Definition at line 173 of file blobbs.h.

{return TStr("General Blob Base Format 1.0");}

static PBlobBs TGBlobBs::New ( const TStr &  BlobBsFNm, const TFAccess &  Access = faRdOnly, const int &  MxSegLen = -1  )

inlinestatic

Definition at line 166 of file blobbs.h.

                          {
    return PBlobBs(new TGBlobBs(BlobBsFNm, Access, MxSegLen));}

TGBlobBs& TGBlobBs::operator= ( const TGBlobBs &  )

inline

Definition at line 171 of file blobbs.h.

{Fail; return *this;}

TBlobPt TGBlobBs::PutBlob ( const PSIn &  SIn )

virtual

Implements TBlobBs.

Definition at line 275 of file blobbs.cpp.

                                        {
  EAssert((Access==faCreate)||(Access==faUpdate)||(Access==faRestore));
  int BfL=SIn->Len();
  int MxBfL; int FFreeBlobPtN;
  GetAllocInfo(BfL, BlockLenV, MxBfL, FFreeBlobPtN);
  TBlobPt BlobPt; TCs Cs;
  if (FFreeBlobPtV[FFreeBlobPtN].Empty()){
    int FLen=FBlobBs->GetFLen();
    if (FLen<=MxSegLen){
      EAssert(FLen<=MxBlobFLen);
      BlobPt=TBlobPt(FLen);
      FBlobBs->SetFPos(BlobPt.GetAddr());
      PutBlobTag(FBlobBs, btBegin);
      FBlobBs->PutInt(MxBfL);
      PutBlobState(FBlobBs, bsActive);
      FBlobBs->PutInt(BfL);
      FBlobBs->PutSIn(SIn, Cs);
      FBlobBs->PutCh(TCh::NullCh, MxBfL-BfL);
      FBlobBs->PutCs(Cs);
      PutBlobTag(FBlobBs, btEnd);
    }
  } else {
    BlobPt=FFreeBlobPtV[FFreeBlobPtN];
    FBlobBs->SetFPos(BlobPt.GetAddr());
    AssertBlobTag(FBlobBs, btBegin);
    int MxBfL=FBlobBs->GetInt();
    int FPos=FBlobBs->GetFPos();
    AssertBlobState(FBlobBs, bsFree);
    FFreeBlobPtV[FFreeBlobPtN]=TBlobPt::LoadAddr(FBlobBs);
    FBlobBs->SetFPos(FPos);
    PutBlobState(FBlobBs, bsActive);
    FBlobBs->PutInt(BfL);
    FBlobBs->PutSIn(SIn, Cs);
    FBlobBs->PutCh(TCh::NullCh, MxBfL-BfL);
    FBlobBs->PutCs(Cs);
    AssertBlobTag(FBlobBs, btEnd);
  }
  FBlobBs->Flush();
  return BlobPt;
}

TBlobPt TGBlobBs::PutBlob ( const TBlobPt &  BlobPt, const PSIn &  SIn  )

virtual

Implements TBlobBs.

Definition at line 316 of file blobbs.cpp.

                                                               {
  EAssert((Access==faCreate)||(Access==faUpdate)||(Access==faRestore));
  int BfL=SIn->Len();

  FBlobBs->SetFPos(BlobPt.GetAddr());
  AssertBlobTag(FBlobBs, btBegin);
  int MxBfL=FBlobBs->GetInt();
  AssertBlobState(FBlobBs, bsActive);
  if (BfL>MxBfL){
    DelBlob(BlobPt);
    return PutBlob(SIn);
  } else {
    TCs Cs;
    FBlobBs->PutInt(BfL);
    FBlobBs->PutSIn(SIn, Cs);
    FBlobBs->PutCh(TCh::NullCh, MxBfL-BfL);
    FBlobBs->PutCs(Cs);
    PutBlobTag(FBlobBs, btEnd);
    FBlobBs->Flush();
    return BlobPt;
  }
}

Member Data Documentation

TFAccess TGBlobBs::Access

private

Definition at line 157 of file blobbs.h.

TIntV TGBlobBs::BlockLenV

private

Definition at line 159 of file blobbs.h.

PFRnd TGBlobBs::FBlobBs

private

Definition at line 156 of file blobbs.h.

TBlobPtV TGBlobBs::FFreeBlobPtV

private

Definition at line 160 of file blobbs.h.

TBlobPt TGBlobBs::FirstBlobPt

private

Definition at line 161 of file blobbs.h.

int TGBlobBs::MxSegLen

private

Definition at line 158 of file blobbs.h.

---

The documentation for this class was generated from the following files:

• glib-core/blobbs.h
• glib-core/blobbs.cpp