fBIndex(),
fTimer(NULL),
fEventId(),
- fBufferMonStarted(kFALSE)
+ fBufferMonStarted(kFALSE),
+ fThread(NULL)
{
// see header file for class documentation
fEventBuffer = new TObjArray(fBufferSize, 0);
for(Int_t id = 0; id < fBufferSize; id++ ) {
fEventId[id] = -2;
}
+
+ fThread = new TThread(AliEveEventBuffer::BufferThread, (void*) this);
+
}
///___________________________________________________________________________
void AliEveEventBuffer::CreateBufferThread() {
+ cout << "Threadexists: " << fThread->Exists() << endl;
if(GetBusy()) {
cout << "Buffer is busy, no thread created"<< endl;
+
} else {
if ( (CalculateDifference(fBIndex[kTop],fBIndex[kLast]) < fPreBuffer) ) {
SetBusy(kTRUE);
- cout << "CreateBufferThread()"<<endl;
- TThread * fThread = new TThread(AliEveEventBuffer::BufferThread, (void*) this);
+ cout << "StartBufferThread()"<<endl;
fThread->Run();
cout << "Started BufferThread"<<endl;
} else {
}
}
}
+
///___________________________________________________________________________
void * AliEveEventBuffer::BufferThread(void * buffer) {
cout <<"BufferThread : " <<endl;