00001 // @(#)root/proof:$Id: TDSetProxy.cxx 20882 2007-11-19 11:31:26Z rdm $ 00002 // Author: Maarten Ballintijn 12/03/02 00003 00004 /************************************************************************* 00005 * Copyright (C) 1995-2001, Rene Brun and Fons Rademakers. * 00006 * All rights reserved. * 00007 * * 00008 * For the licensing terms see $ROOTSYS/LICENSE. * 00009 * For the list of contributors see $ROOTSYS/README/CREDITS. * 00010 *************************************************************************/ 00011 00012 ////////////////////////////////////////////////////////////////////////// 00013 // // 00014 // TDSetProxy // 00015 // // 00016 // TDSet proxy for use on slaves. // 00017 // // 00018 ////////////////////////////////////////////////////////////////////////// 00019 00020 #include "TDSetProxy.h" 00021 #include "TProofServ.h" 00022 00023 00024 ClassImp(TDSetProxy) 00025 00026 //______________________________________________________________________________ 00027 TDSetProxy::TDSetProxy() 00028 { 00029 // Constructor 00030 00031 fServ = 0; 00032 } 00033 00034 //______________________________________________________________________________ 00035 TDSetProxy::TDSetProxy(const char *type, const char *objname, const char *dir) 00036 : TDSet(type,objname,dir) 00037 { 00038 // Constructor 00039 00040 fServ = 0; 00041 fCurrent = 0; 00042 } 00043 00044 //______________________________________________________________________________ 00045 void TDSetProxy::SetProofServ(TProofServ *serv) 00046 { 00047 // Set the reference TProofServ instance 00048 00049 fServ = serv; 00050 fCurrent = 0; 00051 } 00052 00053 //______________________________________________________________________________ 00054 void TDSetProxy::Reset() 00055 { 00056 // Reset this instance 00057 00058 delete fCurrent; fCurrent = 0; 00059 } 00060 00061 //______________________________________________________________________________ 00062 TDSetElement *TDSetProxy::Next(Long64_t totalEntries) 00063 { 00064 // Get the next packet 00065 00066 fCurrent = fServ->GetNextPacket(totalEntries); 00067 00068 return fCurrent; 00069 }
1.5.1