All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
Public Member Functions | Private Attributes | List of all members
RootFileHandler Class Reference

#include <src/FileMgr/RootFileHandler.h>

Collaboration diagram for RootFileHandler:
Collaboration graph
[legend]

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;
}

Member Data Documentation

std::string RootFileHandler::m_certDir
private

Definition at line 37 of file RootFileHandler.h.

int RootFileHandler::m_level
private

Definition at line 35 of file RootFileHandler.h.

MsgStream RootFileHandler::m_log
private

Definition at line 34 of file RootFileHandler.h.

bool RootFileHandler::m_ssl_setup
private

Definition at line 38 of file RootFileHandler.h.

std::string RootFileHandler::m_userProxy
private

Definition at line 37 of file RootFileHandler.h.

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