RootFileHandler Class Reference

#include <RootFileHandler.h>

Collaboration diagram for RootFileHandler:

Public Member Functions
	RootFileHandler (IMessageSvc *, const std::string &userProxy, const std::string &certDir)

Io::open_t	openRootFile (const std::string &n, const Io::IoFlags &f, const std::string &desc, Io::Fd &fd, void *&ptr)

Io::close_t	closeRootFile (void *ptr)

Io::reopen_t	reopenRootFile (void *, const Io::IoFlags &)

bool	setupSSL ()

Private Attributes
MsgStream	m_log

int	m_level

std::string	m_userProxy

std::string	m_certDir

bool	m_ssl_setup

Detailed Description

Definition at line 17 of file RootFileHandler.h.

Constructor & Destructor Documentation

RootFileHandler::RootFileHandler	(	IMessageSvc *	msg,
		const std::string &	userProxy,
		const std::string &	certDir
	)

Definition at line 13 of file RootFileHandler.cpp.

                                     :
  m_log(msg,"RootFileHandler"), m_userProxy(p), m_certDir(c), 
  m_ssl_setup(false) {
  // Protect against multiple instances of TROOT
  if ( 0 == gROOT )   {
    static TROOT root("root","ROOT I/O");
  }
  m_level = msg->outputLevel("RootFileHandler");

}

Member Function Documentation

Io::close_t RootFileHandler::closeRootFile ( void * ptr )

Definition at line 150 of file RootFileHandler.cpp.

                                        {
  if (m_log.level() <= MSG::DEBUG)
    m_log << MSG::DEBUG << "closeRootFile(ptr:" << ptr << ")"
      << endmsg;
  if (ptr == 0) {
    m_log << MSG::ERROR << "Unable to close file: ptr == 0"
      << endmsg;
    return -1;
  }
  TFile* tf = (TFile*) ptr;
  try {
    tf->Close();
  } catch (const std::exception& Exception) {
    m_log << MSG::ERROR << "exception caught while trying to close root"
     << " file" << Exception.what()
      << endmsg;
    return -1;
  } catch (...) {
    m_log << MSG::ERROR << "Problems closing ROOT file  \"" << tf->GetName()
      << "\"" << endmsg;
    return -1;
  }
  return 0;
}

Io::open_t RootFileHandler::openRootFile	(	const std::string &	n,
		const Io::IoFlags &	f,
		const std::string &	desc,
		Io::Fd &	fd,
		void *&	ptr
	)

Definition at line 30 of file RootFileHandler.cpp.

                                                      {
  m_log.setLevel(m_level);
  if (m_log.level() <= MSG::DEBUG)
    m_log << MSG::DEBUG << "openRootFile(\"" << n << "\"," 
      << f << "," << desc << ")" 
      << endmsg;
  
  ptr = 0;
  fd = -1;
  std::string opt;
  if (f == Io::READ) {
    opt = "READ";
  } else if ( f == (Io::WRITE | Io::CREATE | Io::EXCL) ) {
    opt = "NEW";
  } else if ( f == (Io::WRITE | Io::CREATE ) ) {
    opt = "RECREATE";
  } else if ( (f | Io::APPEND) != 0 ) {
    opt = "UPDATE";
  } else {
    m_log << MSG::ERROR << "Don't know how to handle IoFlag " 
      << f << endmsg;
    return 1;
  }
  TFile *tf(0);
  if (n.find("https://") != std::string::npos ||
      n.find("HTTPS://") != std::string::npos ||
      n.find("http://") != std::string::npos  ||
      n.find("HTTP://") != std::string::npos ) {
    if ( !f.isRead() ) {
      m_log << MSG::ERROR << "can only open web files in READ mode. "
        << "requested mode is: " << f
        << endmsg;
      return 1;
    }
    if (!m_ssl_setup && (n.find("https://") != std::string::npos ||
             n.find("HTTPS://") != std::string::npos )) {
      if (!setupSSL()) {
    m_log << MSG::ERROR 
          << "Unable to setup TSSLSocket for ROOT TWebFile access over https"
          << endmsg;
      }
    }
    try {
      tf = new TWebFile(n.c_str());
    } catch (const std::exception& Exception) {
      m_log << MSG::ERROR << "exception caught while trying to open root"
        << " file for reading: " << Exception.what() << std::endl
        << "  -> file probably corrupt." << endmsg;
      return 1;
    } catch (...) {
      m_log << MSG::ERROR << "Problems opening input file  \"" << n
        << "\": probably corrupt" << endmsg;
      return 1;
    }
    if (tf != 0 && tf->IsZombie()) {
      m_log << MSG::ERROR << "Problems opening input file  \"" << n
        << "\": file does not exist or in not accessible" << endmsg;
      delete tf;
      tf = 0;
      return 1;
    }
  } else {
    
    try {
      tf = TFile::Open(n.c_str(),opt.c_str());
    } catch (const std::exception& Exception) {
      m_log << MSG::ERROR << "exception caught while trying to open root"
        << " file for reading: " << Exception.what() << std::endl
        << "  -> file probably corrupt." << endmsg;
      return 1;
    } catch (...) {
      m_log << MSG::ERROR << "Problems opening input file  \"" << n
        << "\": probably corrupt" << endmsg;
      return 1;
    }
    
  }
  if (tf == 0 || !tf->IsOpen()) {
    m_log << MSG::ERROR << "Unable to open ROOT file \"" << n
      << "\" with options \"" << opt << "\"" << endmsg;
    delete tf;
    tf = 0;
    return 1;
  }
  fd = tf->GetFd();
  ptr = (void*) tf;
  if (m_log.level() <= MSG::DEBUG) 
    m_log << MSG::DEBUG << "opened TFile " << (void*) ptr << " Fd: " << fd
      << endmsg;
  
  return 0;
}

Io::reopen_t RootFileHandler::reopenRootFile	(	void *	,
		const Io::IoFlags &
	)

Definition at line 185 of file RootFileHandler.cpp.

                                                       {
  m_log << MSG::ERROR << "reopen not implemented" << endmsg;
  return -1;
}

bool RootFileHandler::setupSSL ( )

Definition at line 196 of file RootFileHandler.cpp.

                          {
  if (m_log.level() <= MSG::DEBUG)
    m_log << MSG::DEBUG << "setupSSL"
      << endmsg;
  // don't set anything up
  if (m_userProxy == "NONE" || m_certDir == "NONE") {
    m_ssl_setup = true;
    return true;    
  }
  // get stuff from $X509_USER_PROXY and $X509_CERT_DIR env vars
  if (m_userProxy == "X509") {
    if (!System::getEnv("X509_USER_PROXY", m_userProxy)) {
      m_log << MSG::ERROR << "env var X509_USER_PROXY not set" << endmsg;
      return false;
    }
  }
  if (m_certDir == "X509") {
    if (!System::getEnv("X509_CERT_DIR", m_certDir)) {
      m_log << MSG::ERROR << "env var X509_CERT_DIR not set" << endmsg;
      return false;
    }
  }
  if (m_log.level() <= MSG::DEBUG)
    m_log << MSG::DEBUG << "userProxy: " << m_userProxy
      << "  certDir: " << m_certDir
      << endmsg;
  TSSLSocket::SetUpSSL(m_userProxy.c_str(), m_certDir.c_str(), 
               m_userProxy.c_str(), m_userProxy.c_str());
  m_ssl_setup = true;
  return true;
}

Gaudi Framework, version v24r2

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation