CMS 3D CMS Logo
IgTools » IgProf » src

IgProfFileDesc.cc File Reference

#include "IgTools/IgProf/src/IgProf.h"
#include "IgTools/IgProf/src/IgProfTrace.h"
#include "IgTools/IgHook/interface/IgHook.h"
#include "IgTools/IgHook/interface/IgHookTrace.h"
#include <cstdlib>
#include <cstring>
#include <cstdio>
#include <cerrno>
#include <sys/socket.h>
#include <pthread.h>

Go to the source code of this file.

Functions

static void __attribute__ ((noinline)) add(int fd)
 Record file descriptor.
static int doaccept (IgHook::SafeData< igprof_doaccept_t > &hook, int fd, struct sockaddr *addr, socklen_t *len)
static int doclose (IgHook::SafeData< igprof_doclose_t > &hook, int fd)
static int dodup (IgHook::SafeData< igprof_dodup_t > &hook, int fd)
static int dodup2 (IgHook::SafeData< igprof_dodup2_t > &hook, int fd, int newfd)
static int doopen (IgHook::SafeData< igprof_doopen_t > &hook, const char *fn, int flags, int mode)
static int doopen64 (IgHook::SafeData< igprof_doopen64_t > &hook, const char *fn, int flags, int mode)
static int dosocket (IgHook::SafeData< igprof_dosocket_t > &hook, int domain, int type, int proto)
const char int int libc so int
libc so int int int libc so 		IGPROF_DUAL_HOOK (3, int, doaccept, _main, _libc,(int fd, sockaddr *addr, socklen_t *len),(fd, addr, len),"accept", 0,"libc.so.6") static IgProfTrace
const char int int libc so int
libc so 		IGPROF_DUAL_HOOK (2, int, dodup2, _main, _libc,(int fd, int newfd),(fd, newfd),"dup2", 0,"libc.so.6") IGPROF_DUAL_HOOK(3
const char int int libc so IGPROF_DUAL_HOOK (1, int, doclose, _main, _libc,(int fd),(fd),"close", 0,"libc.so.6") IGPROF_DUAL_HOOK(1
 IGPROF_DUAL_HOOK (3, int, doopen, _main, _libc,(const char *fn, int flags, int mode),(fn, flags, mode),"open", 0,"libc.so.6") IGPROF_DUAL_HOOK(3
static void initialize (void)
 Initialise file descriptor profiling.
static void remove (int fd)
 Remove knowledge about the file descriptor.

Variables

const char int int __open64
 _libc
 _main
static bool autoboot = (initialize(), true)
const char int int libc so dodup
const char int int libc so int
libc so int 		domain
 doopen64
const char int int libc so int
libc so 		dosocket
const char int int libc so int dup
const char int int libc so int fd
const char int flags
const char * fn
 int
const char int int mode
const char int int libc so int
libc so int int int 		proto
static bool s_count_live = 0
static bool s_count_used = 0
static IgProfTrace::CounterDef s_ct_live = { "FD_LIVE", IgProfTrace::TICK_PEAK, -1 }
static bool s_initialized = false
static int s_moduleid = -1
const char int int libc so int
libc so int int int 		socket
const char int int libc so int
libc so int int 		type

Function Documentation

static void __attribute__ ( (noinline)   )  [static]

Record file descriptor.

Increments counters in the tree.

Definition at line 45 of file IgProfFileDesc.cc.

References IgProfTrace::ACQUIRE, IgProfTrace::Record::amount, IgProf::buffer(), IgProfTrace::COUNT, IgProfTrace::Record::def, python::tagInventory::entries, IgProfTrace::MAX_DEPTH, IgProfTrace::push(), IgProfTrace::Record::resource, IgHookTrace::stacktrace(), IgProfTrace::Record::ticks, and IgProfTrace::Record::type.

00047 {
00048   IgProfTrace *buf = IgProf::buffer(s_moduleid);
00049   if (! buf)
00050     return;
00051 
00052   void                  *addresses[IgProfTrace::MAX_DEPTH];
00053   int                   depth = IgHookTrace::stacktrace(addresses, IgProfTrace::MAX_DEPTH);
00054   IgProfTrace::Record   entries [2];
00055   int                   nentries = 0;
00056 
00057   if (s_count_used)
00058   {
00059     entries[nentries].type = IgProfTrace::COUNT;
00060     entries[nentries].def = &s_ct_used;
00061     entries[nentries].amount = 1;
00062     entries[nentries].ticks = 1;
00063     nentries++;
00064   }
00065 
00066   if (s_count_live)
00067   {
00068     entries[nentries].type = IgProfTrace::COUNT | IgProfTrace::ACQUIRE;
00069     entries[nentries].def = &s_ct_live;
00070     entries[nentries].amount = 1;
00071     entries[nentries].ticks = 1;
00072     entries[nentries].resource = fd;
00073     nentries++;
00074   }
00075 
00076   // Drop two bottom frames, four top ones (stacktrace, me, two for hook).
00077   buf->push(addresses+4, depth-5, entries, nentries);
00078 }

static int doaccept ( IgHook::SafeData< igprof_doaccept_t > &  hook,
int  fd,
struct sockaddr *  addr,
socklen_t *  len 
) [static]

Definition at line 291 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00293 {
00294   bool enabled = IgProf::disable(false);
00295   int result = (*hook.chain)(fd, addr, len);
00296   int err = errno;
00297 
00298   if (enabled && result != -1)
00299     add(result);
00300 
00301   errno = err;
00302   IgProf::enable(false);
00303   return result;
00304 }

static int doclose ( IgHook::SafeData< igprof_doclose_t > &  hook,
int  fd 
) [static]

Definition at line 226 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00227 {
00228   IgProf::disable(false);
00229   int result = (*hook.chain)(fd);
00230   int err = errno;
00231 
00232   if (result != -1)
00233     remove(fd);
00234 
00235   errno = err;
00236   IgProf::enable(false);
00237   return result;
00238 }

static int dodup ( IgHook::SafeData< igprof_dodup_t > &  hook,
int  fd 
) [static]

Definition at line 242 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00243 {
00244   bool enabled = IgProf::disable(false);
00245   int result = (*hook.chain)(fd);
00246   int err = errno;
00247 
00248   if (enabled && result != -1)
00249     add(result);
00250 
00251   errno = err;
00252   IgProf::enable(false);
00253   return result;
00254 }

static int dodup2 ( IgHook::SafeData< igprof_dodup2_t > &  hook,
int  fd,
int  newfd 
) [static]

Definition at line 257 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00258 {
00259   bool enabled = IgProf::disable(false);
00260   int result = (*hook.chain)(fd, newfd);
00261   int err = errno;
00262 
00263   if (result != -1)
00264   {
00265     remove(fd);
00266     if (enabled)
00267       add(newfd);
00268   }
00269 
00270   errno = err;
00271   IgProf::enable(false);
00272   return result;
00273 }

static int doopen ( IgHook::SafeData< igprof_doopen_t > &  hook,
const char *  fn,
int  flags,
int  mode 
) [static]

Definition at line 196 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00197 {
00198   bool enabled = IgProf::disable(false);
00199   int result = (*hook.chain)(fn, flags, mode);
00200   int err = errno;
00201 
00202   if (enabled && result != -1)
00203     add(result);
00204 
00205   errno = err;
00206   IgProf::enable(false);
00207   return result;
00208 }

static int doopen64 ( IgHook::SafeData< igprof_doopen64_t > &  hook,
const char *  fn,
int  flags,
int  mode 
) [static]

Definition at line 211 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00212 {
00213   bool enabled = IgProf::disable(false);
00214   int result = (*hook.chain)(fn, flags, mode);
00215   int err = errno;
00216 
00217   if (enabled && result != -1)
00218     add(result);
00219 
00220   errno = err;
00221   IgProf::enable(false);
00222   return result;
00223 }

static int dosocket ( IgHook::SafeData< igprof_dosocket_t > &  hook,
int  domain,
int  type,
int  proto 
) [static]

Definition at line 276 of file IgProfFileDesc.cc.

References IgHook::SafeData< Func >::chain, IgProf::disable(), IgProf::enable(), err, and HLT_VtxMuL3::result.

00277 {
00278   bool enabled = IgProf::disable(false);
00279   int result = (*hook.chain)(domain, type, proto);
00280   int err = errno;
00281 
00282   if (enabled && result != -1)
00283     add(result);
00284 
00285   errno = err;
00286   IgProf::enable(false);
00287   return result;
00288 }

const char int int libc so int libc so int int int libc so IGPROF_DUAL_HOOK ( 3  ,
int  ,
doaccept  ,
_main  ,
_libc  ,
(int fd, sockaddr *addr, socklen_t *len)  ,
(fd, addr, len)  ,
"accept"  ,
0  ,
"libc.so.6"   
)

Type constraints

Definition at line 32 of file IgProfFileDesc.cc.

References IgProfTrace::TICK.

00037                                                   { "FD_USED", IgProfTrace::TICK, -1 };

const char int int libc so int libc so IGPROF_DUAL_HOOK ( 2  ,
int  ,
dodup2  ,
_main  ,
_libc  ,
(int fd, int newfd)  ,
(fd, newfd)  ,
"dup2"  ,
0  ,
"libc.so.6"   
)

Type constraints

const char int int libc so IGPROF_DUAL_HOOK ( 1  ,
int  ,
doclose  ,
_main  ,
_libc  ,
(int fd)  ,
(fd)  ,
"close"  ,
0  ,
"libc.so.6"   
)

Type constraints

IGPROF_DUAL_HOOK ( 3  ,
int  ,
doopen  ,
_main  ,
_libc  ,
(const char *fn, int flags, int mode)  ,
(fn, flags, mode)  ,
"open"  ,
0  ,
"libc.so.6"   
)

static void initialize ( void   )  [static]

Initialise file descriptor profiling.

Traps various system calls to keep track of usage, and if requested, leaks.

Definition at line 102 of file IgProfFileDesc.cc.

References IgProf::debug(), IgProf::disable(), IgProf::enable(), IgHook::hook(), IgProf::initialize(), Config::options, IgProf::options(), and bookConverter::opts.

Referenced by evf::FUResourceTable::FUResourceTable().

00103 {
00104   if (s_initialized) return;
00105   s_initialized = true;
00106 
00107   const char    *options = IgProf::options();
00108   bool          enable = false;
00109   bool          opts = false;
00110 
00111   while (options && *options)
00112   {
00113     while (*options == ' ' || *options == ',')
00114       ++options;
00115 
00116     if (! strncmp(options, "fd", 2))
00117     {
00118       enable = true;
00119       options += 2;
00120       while (*options)
00121       {
00122         if (! strncmp(options, ":used", 5))
00123         {
00124           s_count_used = 1;
00125           options += 5;
00126           opts = true;
00127         }
00128         else if (! strncmp(options, ":live", 5))
00129         {
00130           s_count_live = 1;
00131           options += 5;
00132           opts = true;
00133         }
00134         else if (! strncmp(options, ":all", 4))
00135         {
00136           s_count_used = 1;
00137           s_count_live = 1;
00138           options += 4;
00139           opts = true;
00140         }
00141         else
00142           break;
00143       }
00144     }
00145     else
00146       options++;
00147 
00148     while (*options && *options != ',' && *options != ' ')
00149       options++;
00150   }
00151 
00152   if (! enable)
00153     return;
00154 
00155   if (! IgProf::initialize(&s_moduleid, 0, false))
00156     return;
00157 
00158   IgProf::disable(true);
00159   if (!opts)
00160   {
00161     IgProf::debug("FD: defaulting to total descriptor counting\n");
00162     s_count_used = 1;
00163   }
00164   else
00165   {
00166     if (s_count_used)
00167       IgProf::debug("FD: enabling usage counting\n");
00168     if (s_count_live)
00169       IgProf::debug("FD: enabling live counting\n");
00170   }
00171 
00172 
00173   IgHook::hook(doopen_hook_main.raw);
00174   IgHook::hook(doopen64_hook_main.raw);
00175   IgHook::hook(doclose_hook_main.raw);
00176   IgHook::hook(dodup_hook_main.raw);
00177   IgHook::hook(dodup2_hook_main.raw);
00178   IgHook::hook(dosocket_hook_main.raw);
00179   IgHook::hook(doaccept_hook_main.raw);
00180 #if __linux
00181   if (doopen_hook_main.raw.chain)   IgHook::hook(doopen_hook_libc.raw);
00182   if (doopen64_hook_main.raw.chain) IgHook::hook(doopen64_hook_libc.raw);
00183   if (doclose_hook_main.raw.chain)  IgHook::hook(doclose_hook_libc.raw);
00184   if (dodup_hook_main.raw.chain)    IgHook::hook(dodup_hook_libc.raw);
00185   if (dodup2_hook_main.raw.chain)   IgHook::hook(dodup2_hook_libc.raw);
00186   if (dosocket_hook_main.raw.chain) IgHook::hook(dosocket_hook_libc.raw);
00187   if (doaccept_hook_main.raw.chain) IgHook::hook(doaccept_hook_libc.raw);
00188 #endif
00189   IgProf::debug("File descriptor profiler enabled\n");
00190   IgProf::enable(true);
00191 }

static void remove ( int  fd  )  [static]

Remove knowledge about the file descriptor.

If we are tracking leaks, removes the descriptor from the live map and subtracts from the live descriptor counters.

Definition at line 84 of file IgProfFileDesc.cc.

References IgProf::buffer(), fd, IgProfTrace::push(), and IgProfTrace::RELEASE.

Referenced by edm::MadGraphProducer::beginRun(), own_ptr< std::ifstream >::operator=(), lhef::processSLHA(), own_ptr< std::ifstream >::reset(), and XMLDocument::~XMLDocument().

00085 {
00086   if (s_count_live)
00087   {
00088     IgProfTrace *buf = IgProf::buffer(s_moduleid);
00089     if (! buf)
00090       return;
00091 
00092     IgProfTrace::Record entry
00093       = { IgProfTrace::RELEASE, &s_ct_live, 0, 0, fd };
00094     buf->push(0, 0, &entry, 1);
00095   }
00096 }

Variable Documentation

const char int int __open64

Definition at line 17 of file IgProfFileDesc.cc.

void size_t size_t libc so void size_t size_t libc so void _libc

Definition at line 17 of file IgProfFileDesc.cc.

const char int int libc so int libc so _main

Definition at line 17 of file IgProfFileDesc.cc.

bool autoboot = (initialize(), true) [static]

Definition at line 307 of file IgProfFileDesc.cc.

const char int int libc so dodup

Definition at line 23 of file IgProfFileDesc.cc.

const char int int libc so int libc so int int int domain

Definition at line 29 of file IgProfFileDesc.cc.

doopen64

Definition at line 17 of file IgProfFileDesc.cc.

const char int int libc so int libc so dosocket

Definition at line 29 of file IgProfFileDesc.cc.

const char int int libc so int dup

Definition at line 23 of file IgProfFileDesc.cc.

Referenced by File::duplicate(), and File::sysduplicate().

void void size_t int int int __off_t fd

Definition at line 23 of file IgProfFileDesc.cc.

Referenced by edm::EventStreamService::closeTimedOutFiles(), CosmicGenFilterHelix::createHistsEnd(), CosmicGenFilterHelix::createHistsStart(), EcalTBDaqRFIOFile::EcalTBDaqRFIOFile(), edm::EventStreamService::generateFileRecord(), edm::FRDStreamService::generateFileRecord(), IgSoFieldPlaneMap::generatePrimitives(), edm::EventStreamService::getOutputService(), edm::FRDStreamService::getOutputService(), LocalCacheFile::LocalCacheFile(), remove(), Ig3DBaseBrowser::repSeekTo(), edm::EventStreamService::stop(), and edm::FRDStreamService::stop().

void void size_t int int int __off_t flags

Definition at line 17 of file IgProfFileDesc.cc.

const char int int fn

Definition at line 17 of file IgProfFileDesc.cc.

Referenced by MonitorElement::copyFunctions(), L1MuGMTConfig::dumpLUTs(), IgSoMaterialMap::IgSoMaterialMap(), CSCThrTurnOnFcn::operator()(), VisCuTkMap2D::save(), IgMatEdMainWidget::saveSoMaterials(), edm::EventSelector::selectionDecision(), LRHelpFunctions::setObsFitParameters(), CmsTrackerDiskBuilder::sortNS(), and HDRShower::thetaFunction().

const char int int libc so int libc so int

Definition at line 17 of file IgProfFileDesc.cc.

const char int int mode

Definition at line 17 of file IgProfFileDesc.cc.

const char int int libc so int libc so int int int proto

Definition at line 29 of file IgProfFileDesc.cc.

Referenced by DDHCalEndcapAlgo::constructGeneralVolume(), cond::FrontierProxy::getRealConnectString(), edm::service::SiteLocalConfigService::lookupCalibConnect(), and SeedGeneratorFromProtoTracksEDProducer::produce().

bool s_count_live = 0 [static]

Definition at line 40 of file IgProfFileDesc.cc.

bool s_count_used = 0 [static]

Definition at line 39 of file IgProfFileDesc.cc.

IgProfTrace::CounterDef s_ct_live = { "FD_LIVE", IgProfTrace::TICK_PEAK, -1 } [static]

Definition at line 38 of file IgProfFileDesc.cc.

bool s_initialized = false [static]

Definition at line 41 of file IgProfFileDesc.cc.

int s_moduleid = -1 [static]

Definition at line 42 of file IgProfFileDesc.cc.

const char int int libc so int libc so int int int socket

Definition at line 29 of file IgProfFileDesc.cc.

Referenced by HCAL_HLX::TCPReceiver::Connect(), DTCtcp::DTCtcp(), IgStudioWebService::initSession(), IgServerSocket::newConnection(), and IgServerSocket::socketClosed().

const char int int libc so int libc so int int int type

Definition at line 29 of file IgProfFileDesc.cc.

Generated on Tue Jun 9 17:53:54 2009 for CMSSW by  doxygen 1.5.4