#include <blobbs.h>

Collaboration diagram for TGBlobBs:

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)
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 Private Member Functions
static TStr	GetNrBlobBsFNm (const TStr &BlobBsFNm)
Private Attributes
PFRnd	FBlobBs
TFAccess	Access
int	MxSegLen
TIntV	BlockLenV
TBlobPtV	FFreeBlobPtV
TBlobPt	FirstBlobPt

Detailed Description

Definition at line 152 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.

References Access, AssertBlobBsStateStr(), AssertVersionStr(), bbsClosed, bbsOpened, BlockLenV, faCreate, Fail, faRdOnly, faRestore, faUpdate, FBlobBs, FFreeBlobPtV, FirstBlobPt, GenBlockLenV(), GenFFreeBlobPtV(), GetBlockLenV(), GetFFreeBlobPtV(), GetMxSegLen(), GetNrBlobBsFNm(), MxBlobFLen, MxSegLen, New(), PutBlobBsStateStr(), PutBlockLenV(), PutFFreeBlobPtV(), PutMxSegLen(), PutVersionStr(), and TBlobPt().

Referenced by New().

                                                                      :
  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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

TGBlobBs::~TGBlobBs ( )

Definition at line 262 of file blobbs.cpp.

References Access, bbsClosed, BlockLenV, faRdOnly, FBlobBs, FFreeBlobPtV, MxSegLen, PutBlobBsStateStr(), PutBlockLenV(), PutFFreeBlobPtV(), PutMxSegLen(), and PutVersionStr().

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

Here is the call graph for this function:

Member Function Documentation

void TGBlobBs::DelBlob ( const TBlobPt & BlobPt )

Definition at line 353 of file blobbs.cpp.

References Access, AssertBlobState(), AssertBlobTag(), BlockLenV, bsActive, bsFree, btBegin, btEnd, EAssert, faCreate, faRestore, faUpdate, FBlobBs, FFreeBlobPtV, GetAllocInfo(), TCh::NullCh, and PutBlobState().

Referenced by PutBlob().

                                           {
  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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool TGBlobBs::Exists ( const TStr & BlobBsFNm ) [static]

Definition at line 410 of file blobbs.cpp.

References GetNrBlobBsFNm().

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

Here is the call graph for this function:

TBlobPt TGBlobBs::FFirstBlobPt ( )

Definition at line 373 of file blobbs.cpp.

References FirstBlobPt.

                              {
  return FirstBlobPt;
}

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

Definition at line 377 of file blobbs.cpp.

References AssertBfCsEqFlCs(), AssertBlobTag(), bsActive, bsFree, btBegin, btEnd, Fail, FBlobBs, forever, GetBlobState(), and TBlobPt().

                                                                            {
  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;
      }
    }
  }
}

Here is the call graph for this function:

PSIn TGBlobBs::GetBlob ( const TBlobPt & BlobPt )

Definition at line 339 of file blobbs.cpp.

References AssertBfCsEqFlCs(), AssertBlobState(), AssertBlobTag(), bsActive, btBegin, btEnd, and FBlobBs.

                                           {
  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;
}

Here is the call graph for this function:

TBlobPt TGBlobBs::GetFirstBlobPt ( ) [inline]

Definition at line 177 of file blobbs.h.

References FirstBlobPt.

{return FirstBlobPt;}

TStr TGBlobBs::GetNrBlobBsFNm ( const TStr & BlobBsFNm ) [static, private]

Definition at line 213 of file blobbs.cpp.

References TStr::Empty(), and TStr::GetFExt().

Referenced by Exists(), and TGBlobBs().

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

Here is the call graph for this function:

Here is the caller graph for this function:

TStr TGBlobBs::GetVersionStr ( ) const [inline]

Definition at line 171 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`
	)		`[inline, static]`

Definition at line 164 of file blobbs.h.

References Access, MxSegLen, and TGBlobBs().

Referenced by TGBlobBs(), and TMBlobBs::TMBlobBs().

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

Here is the call graph for this function:

Here is the caller graph for this function:

TGBlobBs& TGBlobBs::operator= ( const TGBlobBs & ) [inline]

Definition at line 169 of file blobbs.h.

References Fail.

{Fail; return *this;}

TBlobPt TGBlobBs::PutBlob ( const PSIn & SIn )

Definition at line 275 of file blobbs.cpp.

References Access, AssertBlobState(), AssertBlobTag(), BlockLenV, bsActive, bsFree, btBegin, btEnd, EAssert, Empty(), faCreate, faRestore, faUpdate, FBlobBs, FFreeBlobPtV, GetAllocInfo(), TSIn::Len(), LoadAddr(), MxBlobFLen, MxSegLen, TCh::NullCh, PutBlobState(), PutBlobTag(), and TBlobPt().

Referenced by PutBlob().

                                        {
  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 316 of file blobbs.cpp.

References Access, AssertBlobState(), AssertBlobTag(), bsActive, btBegin, btEnd, DelBlob(), EAssert, faCreate, faRestore, faUpdate, FBlobBs, TSIn::Len(), TCh::NullCh, PutBlob(), and PutBlobTag().

                                                               {
  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;
  }
}