testinter::StreamCache Struct Reference

Public Member Functions
edmtest::ThingCollection	beginLumiProduce (unsigned long long iTransitionID)
ReturnedType	beginLumiProduce (edm::RandomNumberGeneratorState const &iState, unsigned long long iTransitionID, edm::LuminosityBlockIndex iLumi)
edmtest::ThingCollection	beginRunProduce (unsigned long long iTransitionID)
template<typename SERIAL >
auto	doTransition (SERIAL &iDeserializer, edm::Transition iTrans, unsigned long long iTransitionID) -> decltype(iDeserializer.deserialize())
template<typename SERIAL >
auto	doTransition (SERIAL &iDeserializer, edm::Transition iTrans, unsigned long long iTransitionID) -> decltype(iDeserializer.deserialize())
edmtest::ThingCollection	endLumiProduce (unsigned long long iTransitionID)
edmtest::ThingCollection	endRunProduce (unsigned long long iTransitionID)
edmtest::ThingCollection	produce (unsigned long long iTransitionID)
edmtest::IntProduct	produce (unsigned long long iTransitionID, edm::StreamID iStream)
	StreamCache (const std::string &iConfig, int id)
	StreamCache (const std::string &iConfig, int id)
	~StreamCache ()
	~StreamCache ()

Private Types
using	TCDeserializer = ROOTDeserializer< edmtest::ThingCollection, ReadBuffer >
using	TCDeserializer = ROOTDeserializer< ReturnedType, ReadBuffer >
using	TCSerializer = ROOTSerializer< edm::RandomNumberGeneratorState, WriteBuffer >

Private Member Functions
std::string	unique_name (std::string iBase)
std::string	unique_name (std::string iBase)

Private Attributes
TCDeserializer	bl_deserializer_
TCDeserializer	br_deserializer_
ControllerChannel	channel_
TCDeserializer	deserializer_
TCDeserializer	el_deserializer_
TCDeserializer	er_deserializer_
bool	externalFailed_ = false
int	id_
FILE *	pipe_
TCSerializer	randSerializer_
ReadBuffer	readBuffer_
WriteBuffer	writeBuffer_

Detailed Description

Definition at line 19 of file TestInterProcessProd.cc.

Member Typedef Documentation

TCDeserializer [1/2]

using testinter::StreamCache::TCDeserializer = ROOTDeserializer<edmtest::ThingCollection, ReadBuffer>

private

Definition at line 116 of file TestInterProcessProd.cc.

TCDeserializer [2/2]

using testinter::StreamCache::TCDeserializer = ROOTDeserializer<ReturnedType, ReadBuffer>

private

Definition at line 125 of file TestInterProcessRandomProd.cc.

TCSerializer

using testinter::StreamCache::TCSerializer = ROOTSerializer<edm::RandomNumberGeneratorState, WriteBuffer>

private

Definition at line 128 of file TestInterProcessRandomProd.cc.

Constructor & Destructor Documentation

StreamCache() [1/2]

testinter::StreamCache::StreamCache ( const std::string &  iConfig, int  id  )

inline

Definition at line 20 of file TestInterProcessProd.cc.

        : id_{id},
          channel_("testProd", id_, 60),
          readBuffer_{channel_.sharedMemoryName(), channel_.fromWorkerBufferInfo()},
          deserializer_{readBuffer_},
          br_deserializer_{readBuffer_},
          er_deserializer_{readBuffer_},
          bl_deserializer_{readBuffer_},
          el_deserializer_(readBuffer_) {
      //make sure output is flushed before popen does any writing
      fflush(stdout);
      fflush(stderr);

      channel_.setupWorker([&]() {
        using namespace std::string_literals;
        std::cout << id_ << " starting external process" << std::endl;
        pipe_ = popen(("cmsTestInterProcess "s + channel_.sharedMemoryName() + " " + channel_.uniqueID()).c_str(), "w");

        if (nullptr == pipe_) {
          abort();
        }

        {
          auto nlines = std::to_string(std::count(iConfig.begin(), iConfig.end(), '\n'));
          auto result = fwrite(nlines.data(), sizeof(char), nlines.size(), pipe_);
          assert(result == nlines.size());
          result = fwrite(iConfig.data(), sizeof(char), iConfig.size(), pipe_);
          assert(result == iConfig.size());
          fflush(pipe_);
        }
      });
    }

~StreamCache() [1/2]

testinter::StreamCache::~StreamCache ( )

inline

Definition at line 96 of file TestInterProcessProd.cc.

References sistrip::pipe_.

                   {
      channel_.stopWorker();
      pclose(pipe_);
    }

StreamCache() [2/2]

testinter::StreamCache::StreamCache ( const std::string &  iConfig, int  id  )

inline

Definition at line 32 of file TestInterProcessRandomProd.cc.

        : id_{id},
          channel_("testProd", id_, 60),
          readBuffer_{channel_.sharedMemoryName(), channel_.fromWorkerBufferInfo()},
          writeBuffer_{std::string("Rand") + channel_.sharedMemoryName(), channel_.toWorkerBufferInfo()},
          deserializer_{readBuffer_},
          bl_deserializer_{readBuffer_},
          randSerializer_{writeBuffer_} {
      //make sure output is flushed before popen does any writing
      fflush(stdout);
      fflush(stderr);

      channel_.setupWorker([&]() {
        using namespace std::string_literals;
        std::cout << id_ << " starting external process" << std::endl;
        pipe_ = popen(("cmsTestInterProcessRandom "s + channel_.sharedMemoryName() + " " + channel_.uniqueID()).c_str(),
                      "w");

        if (nullptr == pipe_) {
          abort();
        }

        {
          auto nlines = std::to_string(std::count(iConfig.begin(), iConfig.end(), '\n'));
          auto result = fwrite(nlines.data(), sizeof(char), nlines.size(), pipe_);
          assert(result == nlines.size());
          result = fwrite(iConfig.data(), sizeof(char), iConfig.size(), pipe_);
          assert(result == iConfig.size());
          fflush(pipe_);
        }
      });
    }

~StreamCache() [2/2]

testinter::StreamCache::~StreamCache ( )

inline

Definition at line 104 of file TestInterProcessRandomProd.cc.

References sistrip::pipe_.

                   {
      channel_.stopWorker();
      pclose(pipe_);
    }

Member Function Documentation

beginLumiProduce() [1/2]

edmtest::ThingCollection testinter::StreamCache::beginLumiProduce ( unsigned long long  iTransitionID )

inline

Definition at line 85 of file TestInterProcessProd.cc.

References edm::BeginLuminosityBlock.

                                                                              {
      return doTransition(bl_deserializer_, edm::Transition::BeginLuminosityBlock, iTransitionID);
    }

beginLumiProduce() [2/2]

ReturnedType testinter::StreamCache::beginLumiProduce ( edm::RandomNumberGeneratorState const &  iState, unsigned long long  iTransitionID, edm::LuminosityBlockIndex  iLumi  )

inline

Definition at line 95 of file TestInterProcessRandomProd.cc.

References edm::BeginLuminosityBlock, and relval_steps::gen().

                                                                 {
      edm::Service<edm::RandomNumberGenerator> gen;
      //NOTE: root serialize requires a `void*` not a `void const*` even though it doesn't modify the object
      randSerializer_.serialize(const_cast<edm::RandomNumberGeneratorState&>(iState));
      return doTransition(bl_deserializer_, edm::Transition::BeginLuminosityBlock, iTransitionID);
    }

beginRunProduce()

edmtest::ThingCollection testinter::StreamCache::beginRunProduce ( unsigned long long  iTransitionID )

inline

Definition at line 74 of file TestInterProcessProd.cc.

References edm::BeginRun.

Referenced by TestInterProcessProd::globalBeginRunProduce().

                                                                             {
      return doTransition(br_deserializer_, edm::Transition::BeginRun, iTransitionID);
    }

doTransition() [1/2]

template<typename SERIAL >

auto testinter::StreamCache::doTransition ( SERIAL &  iDeserializer, edm::Transition  iTrans, unsigned long long  iTransitionID  ) -> decltype(iDeserializer.deserialize())

inline

Definition at line 54 of file TestInterProcessProd.cc.

References gather_cfg::cout, Exception, edm::errors::ExternalFailure, and relativeConstraints::value.

                                                 {
      decltype(iDeserializer.deserialize()) value;
      if (not channel_.doTransition(
              [&value, this]() {
                value = deserializer_.deserialize();
                std::cout << id_ << " from shared memory " << value.size() << std::endl;
              },
              iTrans,
              iTransitionID)) {
        std::cout << id_ << " FAILED waiting for external process" << std::endl;
        externalFailed_ = true;
        throw edm::Exception(edm::errors::ExternalFailure);
      }
      return value;
    }

doTransition() [2/2]

template<typename SERIAL >

auto testinter::StreamCache::doTransition ( SERIAL &  iDeserializer, edm::Transition  iTrans, unsigned long long  iTransitionID  ) -> decltype(iDeserializer.deserialize())

inline

Definition at line 66 of file TestInterProcessRandomProd.cc.

References gather_cfg::cout, Exception, edm::errors::ExternalFailure, and relativeConstraints::value.

                                                 {
      decltype(iDeserializer.deserialize()) value;
      if (not channel_.doTransition(
              [&value, this]() {
                value = deserializer_.deserialize();
                std::cout << id_ << " from shared memory " << value.first.value << std::endl;
              },
              iTrans,
              iTransitionID)) {
        std::cout << id_ << " FAILED waiting for external process" << std::endl;
        externalFailed_ = true;
        throw edm::Exception(edm::errors::ExternalFailure);
      }
      return value;
    }

endLumiProduce()

edmtest::ThingCollection testinter::StreamCache::endLumiProduce ( unsigned long long  iTransitionID )

inline

Definition at line 89 of file TestInterProcessProd.cc.

References edm::EndLuminosityBlock.

                                                                            {
      if (not externalFailed_) {
        return doTransition(el_deserializer_, edm::Transition::EndLuminosityBlock, iTransitionID);
      }
      return edmtest::ThingCollection();
    }

endRunProduce()

edmtest::ThingCollection testinter::StreamCache::endRunProduce ( unsigned long long  iTransitionID )

inline

Definition at line 78 of file TestInterProcessProd.cc.

References edm::EndRun.

                                                                           {
      if (not externalFailed_) {
        return doTransition(er_deserializer_, edm::Transition::EndRun, iTransitionID);
      }
      return edmtest::ThingCollection();
    }

produce() [1/2]

edmtest::ThingCollection testinter::StreamCache::produce ( unsigned long long  iTransitionID )

inline

Definition at line 70 of file TestInterProcessProd.cc.

References edm::Event.

                                                                     {
      return doTransition(deserializer_, edm::Transition::Event, iTransitionID);
    }

produce() [2/2]

edmtest::IntProduct testinter::StreamCache::produce ( unsigned long long  iTransitionID, edm::StreamID  iStream  )

inline

Definition at line 82 of file TestInterProcessRandomProd.cc.

References edm::Event, relval_steps::gen(), and findQualityFiles::v.

                                                                                     {
      edm::Service<edm::RandomNumberGenerator> gen;
      auto& engine = gen->getEngine(iStream);
      edm::RandomNumberGeneratorState state{engine.put(), engine.getSeed()};
      randSerializer_.serialize(state);
      auto v = doTransition(deserializer_, edm::Transition::Event, iTransitionID);
      if (v.second.state_[0] != CLHEP::engineIDulong<CLHEP::RanecuEngine>()) {
        engine.setSeed(v.second.seed_, 0);
      }
      engine.get(v.second.state_);
      return v.first;
    }

unique_name() [1/2]

std::string testinter::StreamCache::unique_name ( std::string  iBase )

inlineprivate

Definition at line 102 of file TestInterProcessProd.cc.

References cond::impl::to_string().

                                           {
      auto pid = getpid();
      iBase += std::to_string(pid);
      iBase += "_";
      iBase += std::to_string(id_);

      return iBase;
    }

unique_name() [2/2]

std::string testinter::StreamCache::unique_name ( std::string  iBase )

inlineprivate

Definition at line 110 of file TestInterProcessRandomProd.cc.

References cond::impl::to_string().

                                           {
      auto pid = getpid();
      iBase += std::to_string(pid);
      iBase += "_";
      iBase += std::to_string(id_);

      return iBase;
    }

Member Data Documentation

bl_deserializer_

TCDeserializer testinter::StreamCache::bl_deserializer_

private

Definition at line 120 of file TestInterProcessProd.cc.

br_deserializer_

TCDeserializer testinter::StreamCache::br_deserializer_

private

Definition at line 118 of file TestInterProcessProd.cc.

channel_

ControllerChannel testinter::StreamCache::channel_

private

Definition at line 113 of file TestInterProcessProd.cc.

deserializer_

TCDeserializer testinter::StreamCache::deserializer_

private

Definition at line 117 of file TestInterProcessProd.cc.

el_deserializer_

TCDeserializer testinter::StreamCache::el_deserializer_

private

Definition at line 121 of file TestInterProcessProd.cc.

er_deserializer_

TCDeserializer testinter::StreamCache::er_deserializer_

private

Definition at line 119 of file TestInterProcessProd.cc.

externalFailed_

bool testinter::StreamCache::externalFailed_ = false

private

Definition at line 122 of file TestInterProcessProd.cc.

id_

int testinter::StreamCache::id_

private

Definition at line 111 of file TestInterProcessProd.cc.

pipe_

FILE * testinter::StreamCache::pipe_

private

Definition at line 112 of file TestInterProcessProd.cc.

randSerializer_

TCSerializer testinter::StreamCache::randSerializer_

private

Definition at line 129 of file TestInterProcessRandomProd.cc.

readBuffer_

ReadBuffer testinter::StreamCache::readBuffer_

private

Definition at line 114 of file TestInterProcessProd.cc.

writeBuffer_

WriteBuffer testinter::StreamCache::writeBuffer_

private

Definition at line 123 of file TestInterProcessRandomProd.cc.