IoDataStreamFactory.cxx

Go to the documentation of this file.

// $Id: IoDataStreamFactory.cxx,v 1.8 2007/08/24 05:37:46 schubert Exp $
//
// messier@huhepl.harvard.edu
#include <string>
#include "Util/UtilString.h"
#include "MessageService/MsgService.h"
#include "IoModules/IoDataStreamFactory.h"
#include "IoModules/IoInputStreamItr.h"
#include "IoModules/IoRerootStreamItr.h"
#include "IoModules/IoDDSStreamItr.h"
#include "IoModules/IoDummyStreamItr.h"
CVSID("$Id: IoDataStreamFactory.cxx,v 1.8 2007/08/24 05:37:46 schubert Exp $");

IoDataStreamItr* 
IoDataStreamFactory::CreateDataStreamItr(const char* source,
                                         const char* format,
                                         unsigned int port,
                                         unsigned int ddsmxretry,
                                         unsigned int ddsretrydelay,
                                         DDS::EClientType ddsclienttype,
                                         string ddsclientname)
{
  IoDataStreamItr* itr = 0;
  std::string fmt(format);
  
  if ( UtilString::ToUpper(fmt) == "INPUT") {
    itr = new IoInputStreamItr(source);
  }
  if ( UtilString::ToUpper(fmt) == "REROOT") {
    itr = new IoRerootStreamItr(source);
  }
  if ( UtilString::ToUpper(fmt) == "DDS") {
    itr = new IoDDSStreamItr(source,port,ddsmxretry,ddsretrydelay,
                             ddsclienttype,ddsclientname);
  }
  if ( UtilString::ToUpper(fmt) == "DUMMY") {
    itr = new IoDummyStreamItr();
  }
  if (itr && itr->IsValid() ) return itr;
  
  MSG("Io",Msg::kWarning) 
      << "Failed to open data stream iterator of format " << format
      << endl;

  if ( itr ) delete itr;

  return 0;
}

---