CMS 3D CMS Logo

List of all members | Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes
TStorageFactoryFile Class Reference

#include <TStorageFactoryFile.h>

Inheritance diagram for TStorageFactoryFile:

Public Member Functions

 ClassDefOverride (TStorageFactoryFile, 0)
 
Bool_t ReadBuffer (char *buf, Int_t len) override
 
Bool_t ReadBuffer (char *buf, Long64_t pos, Int_t len) override
 
Bool_t ReadBufferAsync (Long64_t off, Int_t len) override
 
Bool_t ReadBuffers (char *buf, Long64_t *pos, Int_t *len, Int_t nbuf) override
 
void ResetErrno (void) const override
 
 TStorageFactoryFile (const char *name, Option_t *option, const char *ftitle, Int_t compress, Int_t netopt, Bool_t parallelopen=kFALSE)
 
 TStorageFactoryFile (const char *name, Option_t *option="", const char *ftitle="", Int_t compress=1)
 
Bool_t WriteBuffer (const char *buf, Int_t len) override
 
 ~TStorageFactoryFile (void) override
 

Protected Member Functions

Int_t SysClose (Int_t fd) override
 
Int_t SysOpen (const char *pathname, Int_t flags, UInt_t mode) override
 
Long64_t SysSeek (Int_t fd, Long64_t offset, Int_t whence) override
 
Int_t SysStat (Int_t fd, Long_t *id, Long64_t *size, Long_t *flags, Long_t *modtime) override
 
Int_t SysSync (Int_t fd) override
 

Private Member Functions

void Initialize (const char *name, Option_t *option="")
 
Bool_t ReadBuffersSync (char *buf, Long64_t *pos, Int_t *len, Int_t nbuf)
 
void releaseStorage ()
 
 TStorageFactoryFile (void)
 

Private Attributes

edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
 

Detailed Description

TFile wrapper around #StorageFactory and #Storage.

Definition at line 17 of file TStorageFactoryFile.h.

Constructor & Destructor Documentation

◆ TStorageFactoryFile() [1/3]

TStorageFactoryFile::TStorageFactoryFile ( const char *  name,
Option_t *  option,
const char *  ftitle,
Int_t  compress,
Int_t  netopt,
Bool_t  parallelopen = kFALSE 
)

Definition at line 107 of file TStorageFactoryFile.cc.

References Initialize(), fileinputsource_cfi::option, castor_dqm_sourceclient_file_cfg::path, and edm::threadLocalException::setException().

113  : TFile(path, "NET", ftitle, compress), // Pass "NET" to prevent local access in base class
114  storage_() {
115  try {
117  } catch (...) {
118  edm::threadLocalException::setException(std::current_exception()); // capture
119  }
120 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
void setException(std::exception_ptr e)
void Initialize(const char *name, Option_t *option="")

◆ TStorageFactoryFile() [2/3]

TStorageFactoryFile::TStorageFactoryFile ( const char *  name,
Option_t *  option = "",
const char *  ftitle = "",
Int_t  compress = 1 
)

Definition at line 122 of file TStorageFactoryFile.cc.

References Initialize(), fileinputsource_cfi::option, castor_dqm_sourceclient_file_cfg::path, and edm::threadLocalException::setException().

126  : TFile(path, "NET", ftitle, compress), // Pass "NET" to prevent local access in base class
127  storage_() {
128  try {
130  } catch (...) {
131  edm::threadLocalException::setException(std::current_exception()); // capture
132  }
133 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
void setException(std::exception_ptr e)
void Initialize(const char *name, Option_t *option="")

◆ ~TStorageFactoryFile()

TStorageFactoryFile::~TStorageFactoryFile ( void  )
override

Definition at line 217 of file TStorageFactoryFile.cc.

217 { Close(); }

◆ TStorageFactoryFile() [3/3]

TStorageFactoryFile::TStorageFactoryFile ( void  )
private

Definition at line 98 of file TStorageFactoryFile.cc.

References DDDCmsTrackerContruction::construct(), s_statsCtor, dqmMemoryStats::stats, and storageCounter().

98  : storage_() {
100  stats.tick(0);
101 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
static StorageAccount::Counter * s_statsCtor
std::unique_ptr< GeometricDet > construct(DDCompactView const &cpv, std::vector< int > const &detidShifts)

Member Function Documentation

◆ ClassDefOverride()

TStorageFactoryFile::ClassDefOverride ( TStorageFactoryFile  ,
 
)

◆ Initialize()

void TStorageFactoryFile::Initialize ( const char *  name,
Option_t *  option = "" 
)
private

Definition at line 135 of file TStorageFactoryFile.cc.

References cms::cuda::assert(), DDDCmsTrackerContruction::construct(), beamerCreator::create(), MillePedeFileConverter_cfg::e, Exception, get, edm::Service< T >::isAvailable(), edm::errors::NotFound, edm::storage::IOFlags::OpenCreate, edm::storage::IOFlags::OpenRead, edm::storage::IOFlags::OpenWrap, edm::storage::IOFlags::OpenWrite, fileinputsource_cfi::option, castor_dqm_sourceclient_file_cfg::path, fileinputsource_cfi::read, s_statsCtor, edm::storage::StatisticsSenderService::setSize(), dqmMemoryStats::stats, storage_, storageCounter(), and update.

Referenced by TStorageFactoryFile().

135  {
137 
138  // Enable AsyncReading.
139  // This was the default for 5.27, but turned off by default for 5.32.
140  // In our testing, AsyncReading is the fastest mechanism available.
141  // In 5.32, the AsyncPrefetching mechanism is preferred, but has been a
142  // performance hit in our "average case" tests.
143  gEnv->SetValue("TFile.AsyncReading", 1);
144 
145  // Parse options; at the moment we only accept read!
146  fOption = option;
147  fOption.ToUpper();
148 
149  if (fOption == "NEW")
150  fOption = "CREATE";
151 
152  Bool_t create = (fOption == "CREATE");
153  Bool_t recreate = (fOption == "RECREATE");
154  Bool_t update = (fOption == "UPDATE");
155  Bool_t read = (fOption == "READ") || (fOption == "READWRAP");
156  Bool_t readwrap = (fOption == "READWRAP");
157 
158  if (!create && !recreate && !update && !read) {
159  read = true;
160  fOption = "READ";
161  }
162 
163  if (recreate) {
164  if (!gSystem->AccessPathName(path, kFileExists))
165  gSystem->Unlink(path);
166 
167  recreate = false;
168  create = true;
169  fOption = "CREATE";
170  }
171  assert(!recreate);
172 
173  if (update && gSystem->AccessPathName(path, kFileExists)) {
174  update = kFALSE;
175  create = kTRUE;
176  }
177 
178  assert(read || update || create);
179 
180  int openFlags = IOFlags::OpenRead;
181  if (!read)
182  openFlags |= IOFlags::OpenWrite;
183  if (create)
184  openFlags |= IOFlags::OpenCreate;
185  //if (recreate) openFlags |= IOFlags::OpenCreate | IOFlags::OpenTruncate;
186  if (readwrap)
187  openFlags |= IOFlags::OpenWrap;
188 
189  // Open storage
190  if (!(storage_ = StorageFactory::get()->open(path, openFlags))) {
191  MakeZombie();
192  gDirectory = gROOT;
193  throw cms::Exception("TStorageFactoryFile::TStorageFactoryFile()") << "Cannot open file '" << path << "'";
194  }
195 
196  // Record the statistics.
197  try {
199  if (statsService.isAvailable()) {
200  statsService->setSize(path, storage_->size());
201  }
202  } catch (edm::Exception const &e) {
203  if (e.categoryCode() != edm::errors::NotFound) {
204  throw;
205  }
206  }
207 
208  fRealName = path;
209  fD = 0; // sorry, meaningless
210  fWritable = read ? kFALSE : kTRUE;
211 
212  Init(create);
213 
214  stats.tick(0);
215 }
void setSize(const std::string &urlOrLfn, size_t size)
def create(alignables, pedeDump, additionalData, outputFile, config)
assert(be >=bs)
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
static StorageAccount::Counter * s_statsCtor
#define update(a, b)
bool isAvailable() const
Definition: Service.h:40
#define get
std::unique_ptr< GeometricDet > construct(DDCompactView const &cpv, std::vector< int > const &detidShifts)

◆ ReadBuffer() [1/2]

Bool_t TStorageFactoryFile::ReadBuffer ( char *  buf,
Int_t  len 
)
override

Definition at line 230 of file TStorageFactoryFile.cc.

References visDQMUpload::buf, c, dqmiodumpmetadata::n, fileinputsource_cfi::read, s_statsCPrefetch, s_statsCRead, s_statsRead, s_statsXRead, dqmMemoryStats::stats, storage_, storageCounter(), and edm::storage::StorageAccount::Stamp::tick().

Referenced by ReadBuffer().

230  {
231  // Check that it's valid to access this file.
232  if (IsZombie()) {
233  Error("ReadBuffer", "Cannot read from a zombie file");
234  return kTRUE;
235  }
236 
237  if (!IsOpen()) {
238  Error("ReadBuffer", "Cannot read from a file that is not open");
239  return kTRUE;
240  }
241 
242  // Read specified byte range from the storage. Returns kTRUE in
243  // case of error. Note that ROOT uses this function recursively
244  // to fill the cache; we use a flag to make sure our accounting
245  // is reflected in a comprehensible manner. The "read" counter
246  // will include both, "readc" indicates how much read from the
247  // cache, "readu" indicates how much we failed to read from the
248  // cache (excluding those recursive reads), and "readx" counts
249  // the amount actually passed to read from the storage object.
251 
252  // If we have a cache, read from there first. This returns 0
253  // if the block hasn't been prefetched, 1 if it was in cache,
254  // and 2 if there was an error.
255  if (TFileCacheRead *c = GetCacheRead()) {
256  Long64_t here = GetRelOffset();
257  Bool_t async = c->IsAsyncReading();
258 
259  StorageAccount::Stamp cstats(async
260  ? storageCounter(s_statsCPrefetch, StorageAccount::Operation::readPrefetchToCache)
261  : storageCounter(s_statsCRead, StorageAccount::Operation::readViaCache));
262 
263  Int_t st = ReadBufferViaCache(async ? nullptr : buf, len);
264 
265  if (st == 2) {
266  Error("ReadBuffer",
267  "ReadBufferViaCache failed. Asked to read nBytes: %d from offset: %lld with file size: %lld",
268  len,
269  here,
270  GetSize());
271  return kTRUE;
272  }
273 
274  if (st == 1) {
275  if (async) {
276  cstats.tick(len);
277  Seek(here);
278  } else {
279  cstats.tick(len);
280  stats.tick(len);
281  return kFALSE;
282  }
283  }
284  }
285 
286  // FIXME: Re-enable read-ahead if the data wasn't in cache.
287  // if (! st) storage_->caching(true, -1, s_readahead);
288 
289  // A real read
290  StorageAccount::Stamp xstats(storageCounter(s_statsXRead, StorageAccount::Operation::readActual));
291  IOSize n = storage_->xread(buf, len);
292  xstats.tick(n);
293  stats.tick(n);
294  if (n < static_cast<IOSize>(len)) {
295  Error("ReadBuffer",
296  "read from Storage::xread returned %ld. Asked to read n bytes: %d from offset: %lld with file size: %lld",
297  n,
298  len,
299  GetRelOffset(),
300  GetSize());
301  }
302  return n ? kFALSE : kTRUE;
303 }
edm::ErrorSummaryEntry Error
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
static StorageAccount::Counter * s_statsRead
static StorageAccount::Counter * s_statsXRead
size_t IOSize
Definition: IOTypes.h:15
static StorageAccount::Counter * s_statsCPrefetch
static StorageAccount::Counter * s_statsCRead

◆ ReadBuffer() [2/2]

Bool_t TStorageFactoryFile::ReadBuffer ( char *  buf,
Long64_t  pos,
Int_t  len 
)
override

Definition at line 223 of file TStorageFactoryFile.cc.

References visDQMUpload::buf, and ReadBuffer().

223  {
224  // This function needs to be optimized to minimize seeks.
225  // See TFile::ReadBuffer(char *buf, Long64_t pos, Int_t len) in ROOT 5.27.06.
226  Seek(pos);
227  return ReadBuffer(buf, len);
228 }
Bool_t ReadBuffer(char *buf, Int_t len) override

◆ ReadBufferAsync()

Bool_t TStorageFactoryFile::ReadBufferAsync ( Long64_t  off,
Int_t  len 
)
override

Definition at line 305 of file TStorageFactoryFile.cc.

References f, get, edm::storage::PREFETCH_PROBE_LENGTH, s_statsARead, dqmMemoryStats::stats, storage_, and storageCounter().

305  {
306  // Check that it's valid to access this file.
307  if (IsZombie()) {
308  Error("ReadBufferAsync", "Cannot read from a zombie file");
309  return kTRUE;
310  }
311 
312  if (!IsOpen()) {
313  Error("ReadBufferAsync", "Cannot read from a file that is not open");
314  return kTRUE;
315  }
316 
317  StorageAccount::Stamp stats(storageCounter(s_statsARead, StorageAccount::Operation::readAsync));
318 
319  // If asynchronous reading is disabled, bail out now, regardless
320  // whether the underlying storage supports prefetching. If it is
321  // forced on, pretend it's on, even if the storage doesn't support
322  // it, as this turns off the caching in ROOT's side.
324 
325  // Verify that we never using async reads in app-only mode
326  if (f->cacheHint() == StorageFactory::CACHE_HINT_APPLICATION)
327  return kTRUE;
328 
329  // Let the I/O method indicate if it can do client-side prefetch.
330  // If it does, then for example TTreeCache will drop its own cache
331  // and will use the client-side cache of the actual I/O layer.
332  // If len is zero ROOT is probing for prefetch support.
333  if (len) {
334  // FIXME: Synchronise caching.
335  // storage_->caching(true, -1, 0);
336  ;
337  }
338 
339  IOPosBuffer iov(off, (void *)nullptr, len ? len : PREFETCH_PROBE_LENGTH);
340  if (storage_->prefetch(&iov, 1)) {
341  stats.tick(len);
342  return kFALSE;
343  }
344 
345  // Always ask ROOT to use async reads in storage-only mode,
346  // regardless of whether the storage system supports it.
347  if (f->cacheHint() == StorageFactory::CACHE_HINT_STORAGE)
348  return kFALSE;
349 
350  // Prefetching not available right now.
351  return kTRUE;
352 }
edm::ErrorSummaryEntry Error
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter * s_statsARead
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
constexpr int PREFETCH_PROBE_LENGTH
Definition: Storage.h:18
double f[11][100]
#define get

◆ ReadBuffers()

Bool_t TStorageFactoryFile::ReadBuffers ( char *  buf,
Long64_t *  pos,
Int_t *  len,
Int_t  nbuf 
)
override

Definition at line 421 of file TStorageFactoryFile.cc.

References visDQMUpload::buf, mps_fire::i, ReadBuffersSync(), s_statsARead, storage_, storageCounter(), summarizeEdmComparisonLogfiles::success, edm::storage::StorageAccount::Stamp::tick(), and dqmMemoryStats::total.

421  {
422  // Check that it's valid to access this file.
423  if (IsZombie()) {
424  Error("ReadBuffers", "Cannot read from a zombie file");
425  return kTRUE;
426  }
427 
428  if (!IsOpen()) {
429  Error("ReadBuffers", "Cannot read from a file that is not open");
430  return kTRUE;
431  }
432 
433  // For synchronous reads, we have special logic to optimize the I/O requests
434  // from ROOT before handing it to the storage.
435  if (buf) {
436  return ReadBuffersSync(buf, pos, len, nbuf);
437  }
438  // For an async read, we assume the storage system is smart enough to do the
439  // optimization itself.
440 
441  // Read from underlying storage.
442  void *const nobuf = nullptr;
443  Int_t total = 0;
444  std::vector<IOPosBuffer> iov;
445  iov.reserve(nbuf);
446  for (Int_t i = 0; i < nbuf; ++i) {
447  iov.emplace_back(pos[i], nobuf, len[i]);
448  total += len[i];
449  }
450 
451  // Null buffer means asynchronous reads into I/O system's cache.
452  bool success;
453  StorageAccount::Stamp astats(storageCounter(s_statsARead, StorageAccount::Operation::readAsync));
454  // Synchronise low-level cache with the supposed cache in TFile.
455  // storage_->caching(true, -1, 0);
456  success = storage_->prefetch(iov.data(), nbuf);
457  astats.tick(total);
458 
459  // If it didn't suceeed, pass down to the base class.
460  if (not success) {
461  if (TFile::ReadBuffers(buf, pos, len, nbuf)) {
462  Error("ReadBuffers", "call to TFile::ReadBuffers failed after prefetch already failed.");
463  return kTRUE;
464  }
465  }
466  return kFALSE;
467 }
edm::ErrorSummaryEntry Error
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter * s_statsARead
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
Bool_t ReadBuffersSync(char *buf, Long64_t *pos, Int_t *len, Int_t nbuf)

◆ ReadBuffersSync()

Bool_t TStorageFactoryFile::ReadBuffersSync ( char *  buf,
Long64_t *  pos,
Int_t *  len,
Int_t  nbuf 
)
private

Most storage systems are not prepared for the onslaught of small reads that ROOT will perform, even if they implement a vectored read interface.

Typically, on the server side, the loop is unrolled and the reads are issued sequentially - giving the OS no hint that you're about to read a very close-by byte in the near future. Normally, OS read-ahead takes care of such situations; because the storage server has so many clients, and ROOT reads look random to the OS, the read-ahead becomes disabled.

Hence, this function will repack the application-layer request into an optimized storage-layer request. The resulting request to the storage layer typically has a slightly larger number of bytes, but far less individual reads.

On average, the server's disks see a smaller number of overall reads, the number of bytes transferred over the network increases modestly (around 10%), and the single application request becomes one-to-two I/O transactions. A clear win for all cases except high-latency WAN.

Definition at line 354 of file TStorageFactoryFile.cc.

References cms::cuda::assert(), visDQMUpload::buf, ReadRepacker::bufferUsed(), mps_fire::i, ReadRepacker::iov(), ReadRepacker::pack(), ReadRepacker::realBytesProcessed(), mps_fire::result, s_statsXRead, storage_, storageCounter(), edm::storage::StorageAccount::Stamp::tick(), and ReadRepacker::unpack().

Referenced by ReadBuffers().

354  {
375  Int_t remaining = nbuf; // Number of read requests left to process.
376  Int_t pack_count; // Number of read requests processed by this iteration.
377 
378  IOSize remaining_buffer_size = 0;
379  // Calculate the remaining buffer size for the ROOT-owned buffer by adding
380  // the size of the various requests.
381  for (Int_t i = 0; i < nbuf; i++)
382  remaining_buffer_size += len[i];
383 
384  char *current_buffer = buf;
385  Long64_t *current_pos = pos;
386  Int_t *current_len = len;
387 
388  ReadRepacker repacker;
389 
390  while (remaining > 0) {
391  pack_count = repacker.pack(
392  static_cast<long long int *>(current_pos), current_len, remaining, current_buffer, remaining_buffer_size);
393 
394  int real_bytes_processed = repacker.realBytesProcessed();
395  IOSize io_buffer_used = repacker.bufferUsed();
396 
397  // Issue readv, then unpack buffers.
398  StorageAccount::Stamp xstats(storageCounter(s_statsXRead, StorageAccount::Operation::readActual));
399  std::vector<IOPosBuffer> &iov = repacker.iov();
400  IOSize result = storage_->readv(&iov[0], iov.size());
401  if (result != io_buffer_used) {
402  Error(
403  "ReadBuffersSync", "Storage::readv returned different size result=%ld expected=%ld", result, io_buffer_used);
404  return kTRUE;
405  }
406  xstats.tick(io_buffer_used);
407  repacker.unpack(current_buffer);
408 
409  // Update the location of the unused part of the input buffer.
410  remaining_buffer_size -= real_bytes_processed;
411  current_buffer += real_bytes_processed;
412 
413  current_pos += pack_count;
414  current_len += pack_count;
415  remaining -= pack_count;
416  }
417  assert(remaining_buffer_size == 0);
418  return kFALSE;
419 }
edm::ErrorSummaryEntry Error
assert(be >=bs)
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
int pack(long long int *pos, int *len, int nbuf, char *buf, IOSize buffer_size)
Definition: ReadRepacker.cc:21
void unpack(char *buf)
static StorageAccount::Counter * s_statsXRead
size_t IOSize
Definition: IOTypes.h:15
std::vector< IOPosBuffer > & iov()
Definition: ReadRepacker.h:47
IOSize bufferUsed() const
Definition: ReadRepacker.h:49
IOSize realBytesProcessed() const
Definition: ReadRepacker.h:54

◆ releaseStorage()

void TStorageFactoryFile::releaseStorage ( )
inlineprivate

Definition at line 58 of file TStorageFactoryFile.h.

References edm::get_underlying_safe(), and storage_.

Referenced by SysClose().

58 { get_underlying_safe(storage_).release(); }
constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_

◆ ResetErrno()

void TStorageFactoryFile::ResetErrno ( void  ) const
override

Definition at line 598 of file TStorageFactoryFile.cc.

598 { TSystem::ResetErrno(); }

◆ SysClose()

Int_t TStorageFactoryFile::SysClose ( Int_t  fd)
overrideprotected

Definition at line 559 of file TStorageFactoryFile.cc.

References releaseStorage(), s_statsClose, dqmMemoryStats::stats, storage_, and storageCounter().

559  {
560  StorageAccount::Stamp stats(storageCounter(s_statsClose, StorageAccount::Operation::close));
561 
562  if (storage_) {
563  storage_->close();
564  releaseStorage();
565  }
566 
567  stats.tick();
568  return 0;
569 }
static StorageAccount::Counter * s_statsClose
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)

◆ SysOpen()

Int_t TStorageFactoryFile::SysOpen ( const char *  pathname,
Int_t  flags,
UInt_t  mode 
)
overrideprotected

Definition at line 526 of file TStorageFactoryFile.cc.

References Exception, HLT_2022v12_cff::flags, get, O_NONBLOCK, edm::storage::IOFlags::OpenAppend, edm::storage::IOFlags::OpenCreate, edm::storage::IOFlags::OpenExclusive, edm::storage::IOFlags::OpenNonBlock, edm::storage::IOFlags::OpenRead, edm::storage::IOFlags::OpenTruncate, edm::storage::IOFlags::OpenWrite, BTVHLTOfflineSource_cfi::pathname, s_statsOpen, dqmMemoryStats::stats, storage_, and storageCounter().

526  {
527  StorageAccount::Stamp stats(storageCounter(s_statsOpen, StorageAccount::Operation::open));
528 
529  if (storage_) {
530  storage_->close();
531  }
532 
533  int openFlags = IOFlags::OpenRead;
534  if (flags & O_WRONLY)
535  openFlags = IOFlags::OpenWrite;
536  else if (flags & O_RDWR)
537  openFlags |= IOFlags::OpenWrite;
538  if (flags & O_CREAT)
539  openFlags |= IOFlags::OpenCreate;
540  if (flags & O_APPEND)
541  openFlags |= IOFlags::OpenAppend;
542  if (flags & O_EXCL)
543  openFlags |= IOFlags::OpenExclusive;
544  if (flags & O_TRUNC)
545  openFlags |= IOFlags::OpenTruncate;
546  if (flags & O_NONBLOCK)
547  openFlags |= IOFlags::OpenNonBlock;
548 
549  if (!(storage_ = StorageFactory::get()->open(pathname, openFlags))) {
550  MakeZombie();
551  gDirectory = gROOT;
552  throw cms::Exception("TStorageFactoryFile::SysOpen()") << "Cannot open file '" << pathname << "'";
553  }
554 
555  stats.tick();
556  return 0;
557 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
#define O_NONBLOCK
Definition: SysFile.h:23
#define get
static StorageAccount::Counter * s_statsOpen

◆ SysSeek()

Long64_t TStorageFactoryFile::SysSeek ( Int_t  fd,
Long64_t  offset,
Int_t  whence 
)
overrideprotected

Definition at line 571 of file TStorageFactoryFile.cc.

References hltrates_dqm_sourceclient-live_cfg::offset, RefreshWebPage::rel, s_statsSeek, L1DTConfigBti_cff::SET, dqmMemoryStats::stats, storage_, and storageCounter().

571  {
572  StorageAccount::Stamp stats(storageCounter(s_statsSeek, StorageAccount::Operation::seek));
573  Storage::Relative rel = (whence == SEEK_SET ? Storage::SET : whence == SEEK_CUR ? Storage::CURRENT : Storage::END);
574 
575  offset = storage_->position(offset, rel);
576  stats.tick();
577  return offset;
578 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
static StorageAccount::Counter * s_statsSeek

◆ SysStat()

Int_t TStorageFactoryFile::SysStat ( Int_t  fd,
Long_t *  id,
Long64_t *  size,
Long_t *  flags,
Long_t *  modtime 
)
overrideprotected

Definition at line 587 of file TStorageFactoryFile.cc.

References HLT_2022v12_cff::flags, s_statsStat, findQualityFiles::size, edm_modernize_messagelogger::stat, dqmMemoryStats::stats, storage_, and storageCounter().

587  {
589  // FIXME: Most of this is unsupported or makes no sense with Storage
590  *id = ::Hash(fRealName);
591  *size = storage_->size();
592  *flags = 0;
593  *modtime = 0;
594  stats.tick();
595  return 0;
596 }
size
Write out results.
static StorageAccount::Counter * s_statsStat
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
std::string Hash
Definition: Types.h:43

◆ SysSync()

Int_t TStorageFactoryFile::SysSync ( Int_t  fd)
overrideprotected

Definition at line 580 of file TStorageFactoryFile.cc.

References s_statsFlush, dqmMemoryStats::stats, storage_, and storageCounter().

580  {
581  StorageAccount::Stamp stats(storageCounter(s_statsFlush, StorageAccount::Operation::flush));
582  storage_->flush();
583  stats.tick();
584  return 0;
585 }
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
static StorageAccount::Counter * s_statsFlush

◆ WriteBuffer()

Bool_t TStorageFactoryFile::WriteBuffer ( const char *  buf,
Int_t  len 
)
override

Definition at line 469 of file TStorageFactoryFile.cc.

References visDQMUpload::buf, dqmiodumpmetadata::n, s_statsCWrite, s_statsWrite, s_statsXWrite, dqmMemoryStats::stats, storage_, storageCounter(), edm::storage::StorageAccount::Stamp::tick(), and writeEcalDQMStatus::write.

469  {
470  // Check that it's valid to access this file.
471  if (IsZombie()) {
472  Error("WriteBuffer", "Cannot write to a zombie file");
473  return kTRUE;
474  }
475 
476  if (!IsOpen()) {
477  Error("WriteBuffer", "Cannot write to a file that is not open");
478  return kTRUE;
479  }
480 
481  if (!fWritable) {
482  Error("WriteBuffer", "File is not writable");
483  return kTRUE;
484  }
485 
487  StorageAccount::Stamp cstats(storageCounter(s_statsCWrite, StorageAccount::Operation::writeViaCache));
488 
489  // Try first writing via a cache, and if that's not possible, directly.
490  Int_t st;
491  switch ((st = WriteBufferViaCache(buf, len))) {
492  case 0:
493  // Actual write.
494  {
495  StorageAccount::Stamp xstats(storageCounter(s_statsXWrite, StorageAccount::Operation::writeActual));
496  IOSize n = storage_->xwrite(buf, len);
497  xstats.tick(n);
498  stats.tick(n);
499 
500  // FIXME: What if it's a short write?
501  return n > 0 ? kFALSE : kTRUE;
502  }
503 
504  case 1:
505  cstats.tick(len);
506  stats.tick(len);
507  return kFALSE;
508 
509  case 2:
510  default:
511  Error("WriteBuffer", "Error writing to cache");
512  return kTRUE;
513  }
514 }
edm::ErrorSummaryEntry Error
static StorageAccount::Counter * s_statsWrite
static StorageAccount::Counter * s_statsXWrite
edm::propagate_const< std::unique_ptr< edm::storage::Storage > > storage_
static StorageAccount::Counter & storageCounter(StorageAccount::Counter *&c, StorageAccount::Operation operation)
size_t IOSize
Definition: IOTypes.h:15
static StorageAccount::Counter * s_statsCWrite

Member Data Documentation

◆ storage_

edm::propagate_const<std::unique_ptr<edm::storage::Storage> > TStorageFactoryFile::storage_
private