TDSetProxy.cxx

Go to the documentation of this file.

// @(#)root/proof:$Id$
// Author: Maarten Ballintijn  12/03/02

/*************************************************************************
 * Copyright (C) 1995-2001, Rene Brun and Fons Rademakers.               *
 * All rights reserved.                                                  *
 *                                                                       *
 * For the licensing terms see $ROOTSYS/LICENSE.                         *
 * For the list of contributors see $ROOTSYS/README/CREDITS.             *
 *************************************************************************/

//////////////////////////////////////////////////////////////////////////
//                                                                      //
// TDSetProxy                                                           //
//                                                                      //
// TDSet proxy for use on slaves.                                       //
//                                                                      //
//////////////////////////////////////////////////////////////////////////

#include "TDSetProxy.h"
#include "TProofServ.h"


ClassImp(TDSetProxy)

////////////////////////////////////////////////////////////////////////////////
/// Constructor

TDSetProxy::TDSetProxy()
{
   fServ = 0;
}

////////////////////////////////////////////////////////////////////////////////
/// Constructor

TDSetProxy::TDSetProxy(const char *type, const char *objname, const char *dir)
   : TDSet(type,objname,dir)
{
   fServ = 0;
   fCurrent = 0;
}

////////////////////////////////////////////////////////////////////////////////
/// Set the reference TProofServ instance

void TDSetProxy::SetProofServ(TProofServ *serv)
{
   fServ = serv;
   fCurrent = 0;
}

////////////////////////////////////////////////////////////////////////////////
/// Reset this instance

void TDSetProxy::Reset()
{
   delete fCurrent; fCurrent = 0;
}

////////////////////////////////////////////////////////////////////////////////
/// Get the next packet

TDSetElement *TDSetProxy::Next(Long64_t totalEntries)
{
   fCurrent = fServ->GetNextPacket(totalEntries);

   // Check log file length (before processing the next packet, so we have the
   // chance to keep the latest logs)
   fServ->TruncateLogFile();

   return fCurrent;
}