RootFileHandler Class Reference

#include <src/FileMgr/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 = false

Detailed Description

Definition at line 27 of file RootFileHandler.h.

Constructor & Destructor Documentation

RootFileHandler()

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

Definition at line 25 of file RootFileHandler.cpp.

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

Member Function Documentation

closeRootFile()

Io::close_t RootFileHandler::closeRootFile

(

void *

ptr

)

Definition at line 129 of file RootFileHandler.cpp.

                                                    {

  if ( m_log.level() <= MSG::DEBUG ) m_log << MSG::DEBUG << "closeRootFile(ptr:" << ptr << ")" << endmsg;

  if ( !ptr ) {
    m_log << MSG::ERROR << "Unable to close file: ptr == 0" << endmsg;
    return -1;
  }

  TFile* tf = static_cast<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;
}

openRootFile()

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 34 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 = nullptr;
  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;
  }

  std::unique_ptr<TFile> tf;

  if ( ba::starts_with( n, "https://", ba::is_iequal{} ) || ba::starts_with( n, "http://", ba::is_iequal{} ) ) {

    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 && ba::starts_with( n, "https://", ba::is_iequal{} ) ) {

      if ( !setupSSL() ) {
        m_log << MSG::ERROR << "Unable to setup TSSLSocket for ROOT TWebFile access over https" << endmsg;
      }
    }

    try {
      tf.reset( 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 && tf->IsZombie() ) {
      m_log << MSG::ERROR << "Problems opening input file  \"" << n << "\": file does not exist or in not accessible"
            << endmsg;
      tf.reset();
      return 1;
    }

  } else {

    try {
      tf.reset( 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 || !tf->IsOpen() ) {
    m_log << MSG::ERROR << "Unable to open ROOT file \"" << n << "\" with options \"" << opt << "\"" << endmsg;

    tf.reset();
    return 1;
  }

  fd = tf->GetFd();

  ptr = tf.release();

  if ( m_log.level() <= MSG::DEBUG ) m_log << MSG::DEBUG << "opened TFile " << ptr << " Fd: " << fd << endmsg;

  return 0;
}

reopenRootFile()

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

Definition at line 156 of file RootFileHandler.cpp.

                                                                    {

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

setupSSL()

bool RootFileHandler::setupSSL

(

)

Definition at line 164 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;
}

Member Data Documentation

m_certDir

std::string RootFileHandler::m_certDir

private

Definition at line 44 of file RootFileHandler.h.

m_level

int RootFileHandler::m_level

private

Definition at line 42 of file RootFileHandler.h.

m_log

MsgStream RootFileHandler::m_log

private

Definition at line 41 of file RootFileHandler.h.

m_ssl_setup

bool RootFileHandler::m_ssl_setup = false

private

Definition at line 45 of file RootFileHandler.h.

m_userProxy

std::string RootFileHandler::m_userProxy

private

Definition at line 44 of file RootFileHandler.h.

---

The documentation for this class was generated from the following files:

• GaudiSvc/src/FileMgr/RootFileHandler.h
• GaudiSvc/src/FileMgr/RootFileHandler.cpp