FWStorage/StorageFactory/test/threadsafe.cpp - master - githubmirror/cmssw

FWStorage/StorageFactory/test/threadsafe.cpp

37 строк1014 B

Chris Jones

code formatting

10 дек 2025, 20:08

10 дек 2025, 20:081db073a

#include "FWCore/Utilities/interface/Exception.h"
#include "FWStorage/StorageFactory/test/Test.h"
#include "FWStorage/StorageFactory/interface/Storage.h"
#include <boost/thread/thread.hpp>
#include <vector>

static void dump() {
  std::vector<char> buf(10000, '1');
  Storage* s = StorageFactory::get()->open("/dev/null", IOFlags::OpenWrite | IOFlags::OpenAppend);

  for (int i = 0; i < 10000; ++i)
    s->write(&buf[0], buf.size());

  s->close();
  delete s;
}

int main(int, char**) try {
  initTest();

  std::cout << "start StorageFactory thread test\n";

  static const int NUMTHREADS = 10;
  boost::thread_group threads;
  for (int i = 0; i < NUMTHREADS; ++i)
    threads.create_thread(&dump);
  threads.join_all();

  std::cout << StorageAccount::summaryText(true) << std::endl;
  return EXIT_SUCCESS;
} catch (cms::Exception const& e) {
  std::cerr << e.explainSelf() << std::endl;
  return EXIT_FAILURE;
} catch (std::exception const& e) {
  std::cerr << e.what() << std::endl;
  return EXIT_FAILURE;
}