// @(#)root/base:$Name: $:$Id: TKey.cxx,v 1.48 2005/05/15 05:53:44 brun Exp $
// Author: Rene Brun 28/12/94
/*************************************************************************
* Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
* All rights reserved. *
* *
* For the licensing terms see $ROOTSYS/LICENSE. *
* For the list of contributors see $ROOTSYS/README/CREDITS. *
*************************************************************************/
//////////////////////////////////////////////////////////////////////////
// //
// The TKey class includes functions to book space on a file, //
// to create I/O buffers, to fill these buffers, //
// to compress/uncompress data buffers. //
// //
// Before saving (making persistent) an object on a file, a key must //
// be created. The key structure contains all the information to //
// uniquely identify a persistent object on a file. //
// fNbytes = number of bytes for the compressed object+key //
// fObjlen = Length of uncompressed object //
// fDatime = Date/Time when the object was written //
// fKeylen = number of bytes for the key structure //
// fCycle = cycle number of the object //
// fSeekKey = Address of the object on file (points to fNbytes) //
// This is a redundant information used to cross-check //
// the data base integrity. //
// fSeekPdir = Pointer to the directory supporting this object //
// fClassName = Object class name //
// fName = name of the object //
// fTitle = title of the object //
// //
// The TKey class is used by ROOT to: //
// - to write an object in the Current Directory //
// - to write a new ntuple buffer //
// //
// The structure of a file is shown in TFile::TFile. //
// The structure of a directory is shown in TDirectory::TDirectory. //
// The TKey class is used by the TBasket class. //
// See also TTree. //
// //
//////////////////////////////////////////////////////////////////////////
#include "Riostream.h"
#include "TROOT.h"
#include "TClass.h"
#include "TDirectory.h"
#include "TFile.h"
#include "TKey.h"
#include "TFree.h"
#include "TBrowser.h"
#include "Bytes.h"
#include "TInterpreter.h"
#include "TError.h"
#include "Api.h"
extern "C" void R__zip (Int_t cxlevel, Int_t *nin, char *bufin, Int_t *lout, char *bufout, Int_t *nout);
extern "C" void R__unzip(Int_t *nin, UChar_t *bufin, Int_t *lout, char *bufout, Int_t *nout);
const Int_t kMAXBUF = 0xffffff;
const Int_t kTitleMax = 32000;
#if 0
const Int_t kMAXFILEBUFFER = 262144;
#endif
UInt_t keyAbsNumber = 0;
ClassImp(TKey)
//______________________________________________________________________________
TKey::TKey() : TNamed(), fDatime((UInt_t)0)
{
//*-*-*-*-*-*-*-*-*-*-*TKey default constructor*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* ========================
fVersion = TKey::Class_Version();
fSeekKey = 0;
fNbytes = 0;
fBuffer = 0;
fKeylen = Sizeof();
fObjlen = 0;
fBufferRef = 0;
fCycle = 0;
fSeekPdir = 0;
keyAbsNumber++; SetUniqueID(keyAbsNumber);
}
//______________________________________________________________________________
TKey::TKey(Long64_t pointer, Int_t nbytes) : TNamed()
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Create a TKey object to read keys*-*-*-*-*-*-*-*
//*-* =================================
// Constructor called by TDirectory::ReadKeys and by TFile::TFile
// A TKey object is created to read the keys structure itself
//
fVersion = TKey::Class_Version();
if (pointer > TFile::kStartBigFile) fVersion += 1000;
fSeekKey = pointer;
fNbytes = nbytes;
fBuffer = new char[nbytes];
fKeylen = 0;
fObjlen = 0;
fBufferRef = 0;
fCycle = 0;
fSeekPdir = 0;
keyAbsNumber++; SetUniqueID(keyAbsNumber);
}
//______________________________________________________________________________
TKey::TKey(const char *name, const char *title, const TClass *cl, Int_t nbytes)
: TNamed(name,title)
{
if (fTitle.Length() > kTitleMax) fTitle.Resize(kTitleMax);
fVersion = TKey::Class_Version();
if (gFile && gFile->GetEND() > TFile::kStartBigFile) fVersion += 1000;
fClassName = cl->GetName();
fNbytes = 0;
fBuffer = 0;
fKeylen = Sizeof();
fObjlen = nbytes;
fBufferRef = 0;
fCycle = 0;
Create(nbytes);
}
//______________________________________________________________________________
TKey::TKey(const TString &name, const TString &title, const TClass *cl, Int_t nbytes)
: TNamed(name,title)
{
if (fTitle.Length() > kTitleMax) fTitle.Resize(kTitleMax);
fVersion = TKey::Class_Version();
if (gFile && gFile->GetEND() > TFile::kStartBigFile) fVersion += 1000;
fClassName = cl->GetName();
fNbytes = 0;
fBuffer = 0;
fKeylen = Sizeof();
fObjlen = nbytes;
fBufferRef = 0;
fCycle = 0;
Create(nbytes);
}
//______________________________________________________________________________
TKey::TKey(const TObject *obj, const char *name, Int_t bufsize)
: TNamed(name, obj->GetTitle())
{
// Create a TKey object for a TObject* and fill output buffer
Assert(obj);
if (!obj->IsA()->HasDefaultConstructor()) {
Warning("TKey", "since %s had no public constructor\n"
"\twhich can be called without argument, objects of this class\n"
"\tcan not be read with the current library. You would need to\n"
"\tadd a default constructor before attempting to read it.",
obj->ClassName());
}
if (fTitle.Length() > kTitleMax) fTitle.Resize(kTitleMax);
Int_t lbuf, nout, noutot, bufmax, nzip;
fClassName = obj->ClassName();
fNbytes = 0;
fBuffer = 0;
fBufferRef = new TBuffer(TBuffer::kWrite, bufsize);
fBufferRef->SetParent(gFile);
fCycle = gDirectory->AppendKey(this);
fObjlen = 0;
fKeylen = 0;
fSeekKey = 0;
fSeekPdir = 0;
fVersion = TKey::Class_Version();
if (gFile && gFile->GetEND() > TFile::kStartBigFile) fVersion += 1000;
Streamer(*fBufferRef); //write key itself
fKeylen = fBufferRef->Length();
fBufferRef->MapObject(obj); //register obj in map in case of self reference
((TObject*)obj)->Streamer(*fBufferRef); //write object
lbuf = fBufferRef->Length();
fObjlen = lbuf - fKeylen;
Int_t cxlevel = gFile->GetCompressionLevel();
if (cxlevel && fObjlen > 256) {
if (cxlevel == 2) cxlevel--;
Int_t nbuffers = fObjlen/kMAXBUF;
Int_t buflen = TMath::Max(512,fKeylen + fObjlen + 9*nbuffers + 8); //add 8 bytes in case object is placed in a deleted gap
fBuffer = new char[buflen];
char *objbuf = fBufferRef->Buffer() + fKeylen;
char *bufcur = &fBuffer[fKeylen];
noutot = 0;
nzip = 0;
for (Int_t i=0;i<=nbuffers;i++) {
if (i == nbuffers) bufmax = fObjlen -nzip;
else bufmax = kMAXBUF;
R__zip(cxlevel, &bufmax, objbuf, &bufmax, bufcur, &nout);
if (nout == 0 || nout >= fObjlen) { //this happens when the buffer cannot be compressed
fBuffer = fBufferRef->Buffer();
Create(fObjlen);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
return;
}
bufcur += nout;
noutot += nout;
objbuf += kMAXBUF;
nzip += kMAXBUF;
}
Create(noutot);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
memcpy(fBuffer,fBufferRef->Buffer(),fKeylen);
delete fBufferRef; fBufferRef = 0;
} else {
fBuffer = fBufferRef->Buffer();
Create(fObjlen);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
}
}
//______________________________________________________________________________
TKey::TKey(const void *obj, const TClass *cl, const char *name, Int_t bufsize)
: TNamed(name, "object title")
{
// Create a TKey object for any object obj of class cl and fill output buffer
Assert(obj && cl);
if (!cl->HasDefaultConstructor()) {
Warning("TKey", "since %s had no public constructor\n"
"\twhich can be called without argument, objects of this class\n"
"\tcan not be read with the current library. You would need to\n"
"\tadd a default constructor before attempting to read it.",
cl->GetName());
}
if (fTitle.Length() > kTitleMax) fTitle.Resize(kTitleMax);
TClass *clActual = cl->GetActualClass(obj);
const void* actualStart;
if (clActual) {
const char *temp = (const char*) obj;
// clActual->GetStreamerInfo();
Int_t offset = (cl != clActual) ?
clActual->GetBaseClassOffset(cl) : 0;
temp -= offset;
actualStart = temp;
} else {
actualStart = obj;
}
Int_t lbuf, nout, noutot, bufmax, nzip;
fClassName = clActual->GetName();
fNbytes = 0;
fBuffer = 0;
fBufferRef = new TBuffer(TBuffer::kWrite, bufsize);
fBufferRef->SetParent(gFile);
fCycle = gDirectory->AppendKey(this);
fObjlen = 0;
fKeylen = 0;
fSeekKey = 0;
fSeekPdir = 0;
fVersion = TKey::Class_Version();
if (gFile && gFile->GetEND() > TFile::kStartBigFile) fVersion += 1000;
Streamer(*fBufferRef); //write key itself
fKeylen = fBufferRef->Length();
fBufferRef->MapObject(actualStart,clActual); //register obj in map in case of self reference
clActual->Streamer((void*)actualStart, *fBufferRef); //write object
lbuf = fBufferRef->Length();
fObjlen = lbuf - fKeylen;
Int_t cxlevel = gFile->GetCompressionLevel();
if (cxlevel && fObjlen > 256) {
if (cxlevel == 2) cxlevel--;
Int_t nbuffers = fObjlen/kMAXBUF;
Int_t buflen = TMath::Max(512,fKeylen + fObjlen + 9*nbuffers + 8); //add 8 bytes in case object is placed in a deleted gap
fBuffer = new char[buflen];
char *objbuf = fBufferRef->Buffer() + fKeylen;
char *bufcur = &fBuffer[fKeylen];
noutot = 0;
nzip = 0;
for (Int_t i=0;i<=nbuffers;i++) {
if (i == nbuffers) bufmax = fObjlen -nzip;
else bufmax = kMAXBUF;
R__zip(cxlevel, &bufmax, objbuf, &bufmax, bufcur, &nout);
if (nout == 0 || nout >= fObjlen) { //this happens when the buffer cannot be compressed
fBuffer = fBufferRef->Buffer();
Create(fObjlen);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
return;
}
bufcur += nout;
noutot += nout;
objbuf += kMAXBUF;
nzip += kMAXBUF;
}
Create(noutot);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
memcpy(fBuffer,fBufferRef->Buffer(),fKeylen);
delete fBufferRef; fBufferRef = 0;
} else {
fBuffer = fBufferRef->Buffer();
Create(fObjlen);
fBufferRef->SetBufferOffset(0);
Streamer(*fBufferRef); //write key itself again
}
}
//______________________________________________________________________________
void TKey::Browse(TBrowser *b)
{
// Read object from disk and call its Browse() method.
// If object with same name already exist in memory delete it (like
// TDirectory::Get() is doing), except when the key references a
// folder in which case we don't want to re-read the folder object
// since it might contain new objects not yet saved.
// check that key points to the current dir
if (fSeekPdir != gDirectory->GetSeekDir()) {
Error("Browse"," Key: %s is not in the current directory: %s",GetName(),gDirectory->GetName());
return;
}
TObject *obj = gDirectory->GetList()->FindObject(GetName());
if (obj && !obj->IsFolder()) {
if (obj->InheritsFrom(TCollection::Class()))
obj->Delete(); // delete also collection elements
delete obj;
obj = 0;
}
if (!obj)
obj = ReadObj();
if (b && obj) {
obj->Browse(b);
b->SetRefreshFlag(kTRUE);
}
}
//______________________________________________________________________________
void TKey::Create(Int_t nbytes)
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Create a TKey object *-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* ====================
//*-*-------------------find free segment
//*-* =================
keyAbsNumber++; SetUniqueID(keyAbsNumber);
Int_t nsize = nbytes + fKeylen;
TList *lfree = gFile->GetListOfFree();
TFree *f1 = (TFree*)lfree->First();
TFree *bestfree = f1->GetBestFree(lfree,nsize);
if (bestfree == 0) {
Error("Create","Cannot allocate %d bytes for ID = %s Title = %s",
nsize,GetName(),GetTitle());
return;
}
fDatime.Set();
fSeekKey = bestfree->GetFirst();
//*-*----------------- Case Add at the end of the file
if (fSeekKey == gFile->GetEND()) {
gFile->SetEND(fSeekKey+nsize);
bestfree->SetFirst(fSeekKey+nsize);
fLeft = -1;
if (!fBuffer) fBuffer = new char[nsize];
} else {
fLeft = Int_t(bestfree->GetLast() - fSeekKey - nsize + 1);
}
//*-*----------------- Case where new object fills exactly a deleted gap
fNbytes = nsize;
if (fLeft == 0) {
if (!fBuffer) {
fBuffer = new char[nsize];
}
lfree->Remove(bestfree);
delete bestfree;
}
//*-*----------------- Case where new object is placed in a deleted gap larger than itself
if (fLeft > 0) { // found a bigger segment
if (!fBuffer) {
fBuffer = new char[nsize+sizeof(Int_t)];
}
char *buffer = fBuffer+nsize;
Int_t nbytesleft = -fLeft; // set header of remaining record
tobuf(buffer, nbytesleft);
bestfree->SetFirst(fSeekKey+nsize);
}
fSeekPdir = gDirectory->GetSeekDir();
}
//______________________________________________________________________________
TKey::~TKey()
{
//*-*-*-*-*-*-*-*-*-*-*TKey default destructor*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* =======================
// delete [] fBuffer; fBuffer = 0;
// delete fBufferRef; fBufferRef = 0;
DeleteBuffer();
}
//______________________________________________________________________________
void TKey::Delete(Option_t *option)
{
//*-*-*-*-*-*-*-*-*-*-*-*Delete an object from the file*-*-*-*-*-*-*-*-*-*-*
//*-* ==============================
// Note: the key is not deleted. You still have to call "delete key".
// This is different from the behaviour of TObject::Delete()!
if (option && option[0] == 'v') printf("Deleting key: %s at address %lld, nbytes = %d\n",GetName(),fSeekKey,fNbytes);
Long64_t first = fSeekKey;
Long64_t last = fSeekKey + fNbytes -1;
gFile->MakeFree(first, last); // release space used by this key
gDirectory->GetListOfKeys()->Remove(this);
}
//______________________________________________________________________________
void TKey::DeleteBuffer()
{
//*-*-*-*-*-*-*-*-*-*-*-*Delete key buffer(s)*-*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* ====================
if (fBufferRef) {
delete fBufferRef;
fBufferRef = 0;
} else {
if (fBuffer) delete [] fBuffer;
}
fBuffer = 0;
}
//______________________________________________________________________________
Short_t TKey::GetCycle() const
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Return cycle number associated to this key*-*-*-*
//*-* ==========================================
return ((fCycle >0) ? fCycle : -fCycle);
}
//______________________________________________________________________________
Short_t TKey::GetKeep() const
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Returns the "KEEP" status*-*-*-*-*-*-*-*-*-*-*-*
//*-* =========================
return ((fCycle >0) ? 0 : 1);
}
//______________________________________________________________________________
void TKey::FillBuffer(char *&buffer)
{
//*-*-*-*-*-*-*-*-*-*-*-*Encode key header into output buffer-*-*-*-*-*-*-*
//*-* ====================================
tobuf(buffer, fNbytes);
Version_t version = fVersion;
tobuf(buffer, version);
tobuf(buffer, fObjlen);
fDatime.FillBuffer(buffer);
tobuf(buffer, fKeylen);
tobuf(buffer, fCycle);
if (fVersion > 1000) {
tobuf(buffer, fSeekKey);
tobuf(buffer, fSeekPdir);
} else {
tobuf(buffer, (Int_t)fSeekKey);
tobuf(buffer, (Int_t)fSeekPdir);
}
fClassName.FillBuffer(buffer);
fName.FillBuffer(buffer);
fTitle.FillBuffer(buffer);
}
//______________________________________________________________________________
ULong_t TKey::Hash() const
{
// This Hash function should redefine the default from TNamed
return TNamed::Hash();
}
//______________________________________________________________________________
Bool_t TKey::IsFolder() const
{
// Check if object referenced by the key is a folder.
Bool_t ret = kFALSE;
TClass *classPtr = gROOT->GetClass((const char *) fClassName);
if (classPtr && classPtr->GetClassInfo()) {
TObject *obj = (TObject *) classPtr->New(TClass::kDummyNew);
if (obj) {
ret = obj->IsFolder();
delete obj;
}
}
return ret;
}
//______________________________________________________________________________
void TKey::Keep()
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Set the "KEEP" status*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* =====================
// When the KEEP flag is set to 1 the object cannot be purged
//
if (fCycle >0) fCycle = -fCycle;
}
//______________________________________________________________________________
void TKey::ls(Option_t *) const
{
//*-*-*-*-*-*-*-*-*-*-*-*-*List Key contents-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* =================
TROOT::IndentLevel();
cout <<"KEY: "<<fClassName<<"\t"<<GetName()<<";"<<GetCycle()<<"\t"<<GetTitle()<<endl;
}
//______________________________________________________________________________
void TKey::Print(Option_t *) const
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Print key contents*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* ==================
printf("TKey Name = %s, Title = %s, Cycle = %d\n",GetName(),GetTitle(),GetCycle());
}
//______________________________________________________________________________
TObject *TKey::ReadObj()
{
// To read a TObject* from the file
//
// The object associated to this key is read from the file into memory
// Once the key structure is read (via Streamer) the class identifier
// of the object is known.
// Using the class identifier we find the TClass object for this class.
// A TClass object contains a full description (i.e. dictionary) of the
// associated class. In particular the TClass object can create a new
// object of the class type it describes. This new object now calls its
// Streamer function to rebuilt itself.
//
// see TKey::ReadObjectAny to read any object non-derived from TObject
//
// NOTE:
// In case the class of this object derives from TObject but not
// as a first inheritance, one must cast the return value twice.
// Example1: Normal case:
// class MyClass : public TObject, public AnotherClass
// then on return, one can do:
// MyClass *obj = (MyClass*)key->ReadObj();
//
// Example2: Special case:
// class MyClass : public AnotherClass, public TObject
// then on return, one must do:
// MyClass *obj = dynamic_cast<MyClass*>(key->ReadObj());
//
// Of course, dynamic_cast<> can also be used in the example 1.
TClass *cl = gROOT->GetClass(fClassName.Data());
if (!cl) {
Error("ReadObj", "Unknown class %s", fClassName.Data());
return 0;
}
if (!cl->InheritsFrom(TObject::Class())) {
// in principle user should call TKey::ReadObjectAny!
return (TObject*)ReadObjectAny(0);
}
fBufferRef = new TBuffer(TBuffer::kRead, fObjlen+fKeylen);
if (!fBufferRef) {
Error("ReadObj", "Cannot allocate buffer: fObjlen = %d", fObjlen);
return 0;
}
if (!gFile) return 0;
fBufferRef->SetParent(gFile);
if (fObjlen > fNbytes-fKeylen) {
fBuffer = new char[fNbytes];
ReadFile(); //Read object structure from file
memcpy(fBufferRef->Buffer(),fBuffer,fKeylen);
} else {
fBuffer = fBufferRef->Buffer();
ReadFile(); //Read object structure from file
}
// get version of key
fBufferRef->SetBufferOffset(sizeof(fNbytes));
Version_t kvers = fBufferRef->ReadVersion();
fBufferRef->SetBufferOffset(fKeylen);
TObject *tobj = 0;
TDirectory *cursav = gDirectory;
// Create an instance of this class
char *pobj = (char*)cl->New();
Int_t baseOffset = cl->GetBaseClassOffset(TObject::Class());
if (baseOffset==-1) {
// cl does not inherit from TObject.
// Since this is not possible yet, the only reason we could reach this code
// is because something is screw up in the ROOT code.
Fatal("ReadObj","Incorrect detection of the inheritance from TObject for class %s.\n",
fClassName.Data());
}
tobj = (TObject*)(pobj+baseOffset);
if (!pobj) {
Error("ReadObj", "Cannot create new object of class %s", fClassName.Data());
return 0;
}
if (kvers > 1)
fBufferRef->MapObject(pobj,cl); //register obj in map to handle self reference
if (fObjlen > fNbytes-fKeylen) {
char *objbuf = fBufferRef->Buffer() + fKeylen;
UChar_t *bufcur = (UChar_t *)&fBuffer[fKeylen];
Int_t nin, nout, nbuf;
Int_t noutot = 0;
while (1) {
nin = 9 + ((Int_t)bufcur[3] | ((Int_t)bufcur[4] << 8) | ((Int_t)bufcur[5] << 16));
nbuf = (Int_t)bufcur[6] | ((Int_t)bufcur[7] << 8) | ((Int_t)bufcur[8] << 16);
R__unzip(&nin, bufcur, &nbuf, objbuf, &nout);
if (!nout) break;
noutot += nout;
if (noutot >= fObjlen) break;
bufcur += nin;
objbuf += nout;
}
if (nout) {
tobj->Streamer(*fBufferRef); //does not work with example 2 above
delete [] fBuffer;
} else {
delete [] fBuffer;
delete pobj;
pobj = 0;
tobj = 0;
goto CLEAR;
}
} else {
tobj->Streamer(*fBufferRef);
}
if (gROOT->GetForceStyle()) tobj->UseCurrentStyle();
if (cl == TDirectory::Class()) {
TDirectory *dir = dynamic_cast<TDirectory*>(tobj);
dir->SetName(GetName());
dir->SetTitle(GetTitle());
gDirectory->Append(dir);
}
CLEAR:
delete fBufferRef;
fBufferRef = 0;
fBuffer = 0;
gDirectory = cursav;
return tobj;
}
//______________________________________________________________________________
void *TKey::ReadObjectAny(const TClass* expectedClass)
{
// To read an object (non deriving from TObject) from the file
//
// If expectedClass is not null, we checked that that actual class of
// the object stored is suitable to be stored in a pointer pointing
// to an object of class 'expectedClass'. We also adjust the value
// of the returned address so that it is suitable to be cast (C-Style)
// a a pointer pointing to an object of class 'expectedClass'.
//
// So for example if the class Bottom inherits from Top and the object
// stored is of type Bottom you can safely do:
//
// TClass *TopClass = TClass::GetClass("Top");
// Top *ptr = (Top*) key->ReadObjectAny( TopClass );
// if (ptr==0) printError("the object stored in the key is not of the expected type\n");
//
// The object associated to this key is read from the file into memory
// Once the key structure is read (via Streamer) the class identifier
// of the object is known.
// Using the class identifier we find the TClass object for this class.
// A TClass object contains a full description (i.e. dictionary) of the
// associated class. In particular the TClass object can create a new
// object of the class type it describes. This new object now calls its
// Streamer function to rebuilt itself.
fBufferRef = new TBuffer(TBuffer::kRead, fObjlen+fKeylen);
if (!fBufferRef) {
Error("ReadObj", "Cannot allocate buffer: fObjlen = %d", fObjlen);
return 0;
}
if (!gFile) return 0;
fBufferRef->SetParent(gFile);
if (fObjlen > fNbytes-fKeylen) {
fBuffer = new char[fNbytes];
ReadFile(); //Read object structure from file
memcpy(fBufferRef->Buffer(),fBuffer,fKeylen);
} else {
fBuffer = fBufferRef->Buffer();
ReadFile(); //Read object structure from file
}
// get version of key
fBufferRef->SetBufferOffset(sizeof(fNbytes));
Version_t kvers = fBufferRef->ReadVersion();
fBufferRef->SetBufferOffset(fKeylen);
TDirectory *cursav = gDirectory;
TClass *cl = gROOT->GetClass(fClassName.Data());
if (!cl) {
Error("ReadObjectAny", "Unknown class %s", fClassName.Data());
return 0;
}
Int_t baseOffset = 0;
if (expectedClass) {
// baseOffset will be -1 if cl does not inherit from expectedClass
baseOffset = cl->GetBaseClassOffset(expectedClass);
if (baseOffset == -1) {
return 0;
}
if (cl->GetClassInfo() && !expectedClass->GetClassInfo()) {
//we cannot mix a compiled class with an emulated class in the inheritance
Warning("ReadObjectAny",
"Trying to read an emulated class (%s) to store in a compiled pointer (%s)",
cl->GetName(),expectedClass->GetName());
}
}
// Create an instance of this class
void *pobj = cl->New();
if (!pobj) {
Error("ReadObjectAny", "Cannot create new object of class %s", fClassName.Data());
return 0;
}
if (kvers > 1)
fBufferRef->MapObject(pobj,cl); //register obj in map to handle self reference
if (fObjlen > fNbytes-fKeylen) {
char *objbuf = fBufferRef->Buffer() + fKeylen;
UChar_t *bufcur = (UChar_t *)&fBuffer[fKeylen];
Int_t nin, nout, nbuf;
Int_t noutot = 0;
while (1) {
nin = 9 + ((Int_t)bufcur[3] | ((Int_t)bufcur[4] << 8) | ((Int_t)bufcur[5] << 16));
nbuf = (Int_t)bufcur[6] | ((Int_t)bufcur[7] << 8) | ((Int_t)bufcur[8] << 16);
R__unzip(&nin, bufcur, &nbuf, objbuf, &nout);
if (!nout) break;
noutot += nout;
if (noutot >= fObjlen) break;
bufcur += nin;
objbuf += nout;
}
if (nout) {
cl->Streamer((void*)pobj, *fBufferRef); //read object
delete [] fBuffer;
} else {
delete [] fBuffer;
cl->Destructor(pobj);
pobj = 0;
goto CLEAR;
}
} else {
cl->Streamer((void*)pobj, *fBufferRef); //read object
}
CLEAR:
delete fBufferRef;
fBufferRef = 0;
fBuffer = 0;
gDirectory = cursav;
return ( ((char*)pobj) + baseOffset );
}
//______________________________________________________________________________
Int_t TKey::Read(TObject *obj)
{
//*-*-*-*-*-*-*-*-*-*-*-*-*To read an object from the file*-*-*-*-*-*-*-*-*
//*-* ===============================
// The object associated to this key is read from the file into memory
// Before invoking this function, obj has been created via the
// default constructor.
//
if (!obj) return 0;
fBufferRef = new TBuffer(TBuffer::kRead, fObjlen+fKeylen);
fBufferRef->SetParent(gFile);
if (fVersion > 1)
fBufferRef->MapObject(obj); //register obj in map to handle self reference
if (fObjlen > fNbytes-fKeylen) {
fBuffer = new char[fNbytes];
ReadFile(); //Read object structure from file
memcpy(fBufferRef->Buffer(),fBuffer,fKeylen);
} else {
fBuffer = fBufferRef->Buffer();
ReadFile(); //Read object structure from file
}
fBufferRef->SetBufferOffset(fKeylen);
TDirectory *cursav = gDirectory;
if (fObjlen > fNbytes-fKeylen) {
char *objbuf = fBufferRef->Buffer() + fKeylen;
UChar_t *bufcur = (UChar_t *)&fBuffer[fKeylen];
Int_t nin, nout, nbuf;
Int_t noutot = 0;
while (1) {
nin = 9 + ((Int_t)bufcur[3] | ((Int_t)bufcur[4] << 8) | ((Int_t)bufcur[5] << 16));
nbuf = (Int_t)bufcur[6] | ((Int_t)bufcur[7] << 8) | ((Int_t)bufcur[8] << 16);
R__unzip(&nin, bufcur, &nbuf, objbuf, &nout);
if (!nout) break;
noutot += nout;
if (noutot >= fObjlen) break;
bufcur += nin;
objbuf += nout;
}
if (nout) obj->Streamer(*fBufferRef);
delete [] fBuffer;
} else {
obj->Streamer(*fBufferRef);
}
delete fBufferRef;
fBufferRef = 0;
fBuffer = 0;
gDirectory = cursav;
return fNbytes;
}
//______________________________________________________________________________
void TKey::ReadBuffer(char *&buffer)
{
//*-*-*-*-*-*-*-*-*-*-*-*Decode input buffer-*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* ===================
frombuf(buffer, &fNbytes);
Version_t version;
frombuf(buffer,&version);
fVersion = (Int_t)version;
frombuf(buffer, &fObjlen);
fDatime.ReadBuffer(buffer);
frombuf(buffer, &fKeylen);
frombuf(buffer, &fCycle);
if (fVersion > 1000) {
frombuf(buffer, &fSeekKey);
frombuf(buffer, &fSeekPdir);
} else {
Int_t seekkey,seekdir;
frombuf(buffer, &seekkey); fSeekKey = (Long64_t)seekkey;
frombuf(buffer, &seekdir); fSeekPdir= (Long64_t)seekdir;
}
fClassName.ReadBuffer(buffer);
fName.ReadBuffer(buffer);
fTitle.ReadBuffer(buffer);
if (!gROOT->ReadingObject()) {
if (fSeekPdir != gDirectory->GetSeekDir()) gDirectory->AppendKey(this);
}
}
//______________________________________________________________________________
void TKey::ReadFile()
{
//*-*-*-*-*-*-*-*-*-*-*-*-*Read the key structure from the file-*-*-*-*-*-*
//*-* ====================================
Int_t nsize = fNbytes;
gFile->Seek(fSeekKey);
#if 0
for (Int_t i = 0; i < nsize; i += kMAXFILEBUFFER) {
int nb = kMAXFILEBUFFER;
if (i+nb > nsize) nb = nsize - i;
gFile->ReadBuffer(fBuffer+i,nb);
}
#else
gFile->ReadBuffer(fBuffer,nsize);
#endif
if (gDebug) {
cout << "TKey Reading "<<nsize<< " bytes at address "<<fSeekKey<<endl;
}
}
//______________________________________________________________________________
void TKey::SetParent(const TObject *parent)
{
// Set parent in key buffer
if (fBufferRef) fBufferRef->SetParent((TObject*)parent);
}
//______________________________________________________________________________
Int_t TKey::Sizeof() const
{
//*-*-*-*-*-*-*-*Return the size in bytes of the key header structure*-*-*-*
//*-*-*-*-*-*-*-*====================================================
//Int_t nbytes = sizeof fNbytes; 4
// += sizeof(Version_t); 2
// += sizeof fObjlen; 4
// += sizeof fKeylen; 2
// += sizeof fCycle; 2
// += sizeof fSeekKey; 4 or 8
// += sizeof fSeekPdir; 4 or 8
// = 22
Int_t nbytes = 22; if (fVersion > 1000) nbytes += 8;
nbytes += fDatime.Sizeof();
nbytes += fClassName.Sizeof();
nbytes += fName.Sizeof();
nbytes += fTitle.Sizeof();
return nbytes;
}
//_______________________________________________________________________
void TKey::Streamer(TBuffer &b)
{
//*-*-*-*-*-*-*-*-*Stream a class object*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*
//*-* =========================================
Version_t version;
if (b.IsReading()) {
b >> fNbytes;
b >> version; fVersion = (Int_t)version;
b >> fObjlen;
fDatime.Streamer(b);
b >> fKeylen;
b >> fCycle;
if (fVersion > 1000) {
b >> fSeekKey;
b >> fSeekPdir;
} else {
Int_t seekkey, seekdir;
b >> seekkey; fSeekKey = (Long64_t)seekkey;
b >> seekdir; fSeekPdir= (Long64_t)seekdir;
}
fClassName.Streamer(b);
fName.Streamer(b);
fTitle.Streamer(b);
} else {
b << fNbytes;
version = (Version_t)fVersion;
b << version;
b << fObjlen;
if (fDatime.Get() == 0) fDatime.Set();
fDatime.Streamer(b);
b << fKeylen;
b << fCycle;
if (fVersion > 1000) {
b << fSeekKey;
b << fSeekPdir;
} else {
b << (Int_t)fSeekKey;
b << (Int_t)fSeekPdir;
}
fClassName.Streamer(b);
fName.Streamer(b);
fTitle.Streamer(b);
}
}
//______________________________________________________________________________
Int_t TKey::WriteFile(Int_t cycle)
{
//*-*-*-*-*-*-*-*-*-*-*Write the encoded object supported by this key*-*-*-*
//*-* ==============================================
//
// The function returns the number of bytes committed to the file.
// If a write error occurs, the number of bytes returned is -1.
//
Int_t nsize = fNbytes;
char *buffer = fBuffer;
if (cycle) {
fCycle = cycle;
FillBuffer(buffer);
buffer = fBuffer;
}
if (fLeft > 0) nsize += sizeof(Int_t);
gFile->Seek(fSeekKey);
#if 0
for (Int_t i=0;i<nsize;i+=kMAXFILEBUFFER) {
Int_t nb = kMAXFILEBUFFER;
if (i+nb > nsize) nb = nsize - i;
gFile->WriteBuffer(buffer,nb);
buffer += nb;
}
#else
Bool_t result = gFile->WriteBuffer(buffer,nsize);
#endif
// gFile->Flush(); Flushing takes too much time.
// Let user flush the file when he wants.
if (gDebug) {
cout <<" TKey Writing "<<nsize<< " bytes at address "<<fSeekKey
<<" for ID= " <<GetName()<<" Title= "<<GetTitle()<<endl;
}
DeleteBuffer();
return result==kTRUE ? -1 : nsize;
}
//______________________________________________________________________________
const char *TKey::GetIconName() const
{
// title can keep 32x32 xpm thumbnail/icon of the parent object.
return (!fTitle.IsNull() && fTitle.BeginsWith("/* ") ? fTitle.Data() : 0);
}
//______________________________________________________________________________
const char *TKey::GetTitle() const
{
// returns title (title can contain 32x32 xpm thumbnail/icon)
if (!fTitle.IsNull() && fTitle.BeginsWith("/* ")) { // title contains xpm thumbnail
static TString ret;
int start = fTitle.Index("/*") + 3;
int stop = fTitle.Index("*/") - 1;
ret = fTitle(start, stop - start);
return ret.Data();
}
return fTitle.Data();
}
ROOT page - Class index - Class Hierarchy - Top of the page
This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.