GFALDataStreamTool.h

Go to the documentation of this file.

// $Id: GFALDataStreamTool.h,v 1.1.1.1 2007/01/15 12:22:56 hmd Exp $
#ifndef GAUDIGRIDSVC_GFALDATASTREAMTOOL_H 
#define GAUDIGRIDSVC_GFALDATASTREAMTOOL_H 1

// Include files

#include <vector>

// Local
#include "GFALStageBlock.h"

// from Gaudi
#include "GaudiKernel/Service.h"
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/EventSelectorDataStream.h"
#include "GaudiKernel/DataStreamTool.h"



//class DataStreamTool;

class GFALDataStreamTool : virtual public DataStreamTool {
public: 
  
  enum Status {UNKNOWN=0,STGING,DONE};
  
  GFALDataStreamTool( const std::string& type, 
                      const std::string& name,
                      const IInterface* parent);
  
  virtual ~GFALDataStreamTool( ); 

  virtual StatusCode initialize();
  
  virtual StatusCode finalize();
  
  virtual StatusCode addStreams(const StreamSpecs &);

  virtual StatusCode getNextStream( const EventSelectorDataStream* &, size_type & );
  
protected:
  
  StatusCode updateStreams( const std::string & , const std::string & );
  
private:
  
  size_type m_turlCount;
    
  StreamSpecs m_streamTurls;
  
  StatusCode setBlocks();
  
  StatusCode firstBlockStage();
  
  StatusCode nextBlockStage();
  
  StatusCode updateBlockStatus();

  StatusCode updateBlockStatus(GFALStageBlock *);
  
  StatusCode updateStreamTurls();
  
  void addBlock(GFALStageBlock *);
    
  std::vector<GFALStageBlock*> m_blocks ;
  
  std::vector<GFALStageBlock*>::iterator m_blockitr;
  
  long int m_pos;
      
  size_t m_blockindex ;
  size_t m_ntotblocks ;
  size_t m_blocksize ;
  size_t m_initstage ;
  size_t m_readfile ;

  int m_atblock ;
  
  Status m_task;
  
};
#endif // GAUDIGRIDSVC_GFALDATASTREAMTOOL_H