Namespaces
	evtn

	FastMonState

Classes
class	ConcurrencyTracker

struct	ContainableAtomic

class	DirManager

class	EvFBuildingThrottle

class	EvFDaqDirector

class	EvFFEDExcluder

class	EvFFEDSelector

class	ExceptionGenerator

struct	FastMonEncoding

class	FastMonitoringService

class	FastMonitoringThread

class	GlobalEvFOutputEventWriter

class	GlobalEvFOutputJSONDef

class	GlobalEvFOutputJSONWriter

class	GlobalEvFOutputModule

struct	MetaDataCache

class	MicroStateService

Typedefs
typedef edm::global::OutputModule< edm::RunCache< GlobalEvFOutputJSONDef >, edm::LuminosityBlockCache< evf::GlobalEvFOutputEventWriter >, edm::StreamCache< SerializeDataBuffer >, edm::WatchInputFiles, edm::ExternalWork >	GlobalEvFOutputModuleType

Enumerations
enum	MergeType { MergeTypeNULL = 0, MergeTypeDAT = 1, MergeTypePB = 2, MergeTypeJSNDATA = 3 }

Functions
void	__attribute__ ((optimize("O0"))) ExceptionGenerator

unsigned short	compute_crc (unsigned char *buffer, unsigned int bufSize)

unsigned short	compute_crc_64bit (unsigned short crc, unsigned char *p)

unsigned short	compute_crc_8bit (unsigned short crc, unsigned char data)

constexpr edm::ModuleDescription const *	getmBoL ()

constexpr edm::ModuleDescription const *	getmDqm ()

constexpr edm::ModuleDescription const *	getmEoL ()

constexpr edm::ModuleDescription const *	getmEvent ()

constexpr edm::ModuleDescription const *	getmFwk ()

constexpr edm::ModuleDescription const *	getmFwkEoL ()

constexpr edm::ModuleDescription const *	getmFwkOvhMod ()

constexpr edm::ModuleDescription const *	getmFwkOvhSrc ()

constexpr edm::ModuleDescription const *	getmGlobEoL ()

constexpr edm::ModuleDescription const *	getmIdle ()

constexpr edm::ModuleDescription const *	getmIdleSource ()

constexpr edm::ModuleDescription const *	getmIgnore ()

constexpr edm::ModuleDescription const *	getmInput ()

constexpr edm::ModuleDescription const *	getmInvalid ()

Variables
const unsigned short	crc_table [256]

constexpr int	nReservedModules = 128

constexpr int	nSpecialModules = FastMonState::mCOUNT

Detailed Description

fillJson fillJson.h "DQMServices/Components/interface/fillJson.h"

Description: Function used by DQMFileSaver and JsonWritingTimedPoolOutputModule

Usage: <usage>

Typedef Documentation

◆ GlobalEvFOutputModuleType

typedef edm::global::OutputModule<edm::RunCache<GlobalEvFOutputJSONDef>, edm::LuminosityBlockCache<evf::GlobalEvFOutputEventWriter>, edm::StreamCache<SerializeDataBuffer>, edm::WatchInputFiles, edm::ExternalWork> evf::GlobalEvFOutputModuleType

Definition at line 191 of file GlobalEvFOutputModule.cc.

Enumeration Type Documentation

◆ MergeType

enum evf::MergeType

Enumerator
MergeTypeNULL
MergeTypeDAT
MergeTypePB
MergeTypeJSNDATA

Definition at line 57 of file EvFDaqDirector.h.

57 { MergeTypeNULL = 0, MergeTypeDAT = 1, MergeTypePB = 2, MergeTypeJSNDATA = 3 };

evf::MergeTypeNULL

Definition: EvFDaqDirector.h:57

evf::MergeTypeDAT

Definition: EvFDaqDirector.h:57

evf::MergeTypeJSNDATA

Definition: EvFDaqDirector.h:57

evf::MergeTypePB

Definition: EvFDaqDirector.h:57

Function Documentation

◆ attribute()

void evf::__attribute__ ( (optimize("O0")) )

Definition at line 142 of file ExceptionGenerator.cc.

References data, Exception, beamvalidation::exit(), ALCARECOEcalPhiSym_cff::float, free(), dqmiolumiharvest::j, CrabHelper::log, malloc(), WZElectronSkims53X_cff::max, SiStripPI::mean, pi, isotrackNtupler::scale, mathSSE::sqrt(), suppress, and relativeConstraints::value.

                                                                                                             {
     float dummy = 0.;
     unsigned int iterations = 0;
     if (actionRequired_) {
       int *pi = nullptr;  //null-pointer used with actionId_ 8 and 12 to intentionally cause segfault
       int ind = 0;
       int step = 1;
       switch (actionId_) {
         case 0:
           ::usleep(intqualifier_ * 1000);
           break;
         case 1:
           ::sleep(0xFFFFFFF);
           break;
         case 2:
           throw cms::Exception(qualifier_) << "This exception was generated by the ExceptionGenerator";
           break;
         case 3:
           exit(-1);
           break;
         case 4:
           abort();
           break;
         case 5:
           throw qualifier_;
           break;
         case 6:
           while (true) {
             ind += step;
             if (ind > 1000000)
               step = -1;
             if (ind == 0)
               step = 1;
           }
           break;
         case 7:
           edm::LogError("TestErrorMessage") << qualifier_;
           break;
         case 8:
           [[clang::suppress]] *pi =
               0;  //intentionally caused segfault by assigning null pointer (this produces static-checker warning)
           break;
         case 9:
           for (unsigned int j = 0; j < intqualifier_ * 1000 * 100; j++) {
             dummy += sqrt(log(float(j + 1))) / float(j * j);
           }
           break;
         case 10:
           iterations = 100 * static_cast<unsigned int>(timingHisto_->GetRandom() * intqualifier_ * 17. + 0.5);
           for (unsigned int j = 0; j < iterations; j++) {
             dummy += sqrt(log(float(j + 1))) / float(j * j);
           }
           break;
         case 11: {
           iterations = static_cast<unsigned int>(timingHisto_->GetRandom() * intqualifier_ * 12. + 0.5);
           TRandom3 random(iterations);
           const size_t dataSize = 32 * 500;  // 124kB
           std::vector<double> data(dataSize);
           random.RndmArray(dataSize, &data[0]);
 
           for (unsigned int j = 0; j < iterations; j++) {
             const size_t index = static_cast<size_t>(random.Rndm() * dataSize + 0.5);
             const double value = data[index];
             dummy += sqrt(log(value + 1)) / (value * value);
             if (random.Rndm() < 0.1)
               data[index] = dummy;
           }
         } break;
         case 12: {
           timeval tv_now;
           gettimeofday(&tv_now, nullptr);
           if ((unsigned)(tv_now.tv_sec - tv_start_.tv_sec) > intqualifier_) {
             [[clang::suppress]] *pi =
                 0;  //intentionally caused segfault by assigning null pointer (this produces static-checker warning)
           }
         } break;
         case 13: {
           void *vp = malloc(1024);
 #pragma GCC diagnostic push
 #pragma GCC diagnostic ignored "-Wstringop-overflow"
           memset((char *)vp - 32 + intqualifier_, 0, 1024);
 #pragma GCC diagnostic pop
           free(vp);
         } break;
         case 14: {
           float mean = 60.;  // timingHisto_->GetMean();
           float scale = intqualifier_ / mean;
           float off = intqualifier_ * (1. - qualifier2_);
           scale = scale * qualifier2_;  // scale factor (1 default)
           iterations = static_cast<unsigned int>(max(1., off + timingHisto_->GetRandom() * scale));
           //std::cout << " off " << off << " scale " << scale << " " << iterations << std::endl;
           ::usleep(iterations * 1000);
         } break;
         case 15: {
           float mean = 60.;  // timingHisto_->GetMean();
           float scale = intqualifier_ / mean;
           float off = intqualifier_ * (1. - qualifier2_);
           scale = scale * qualifier2_;  // scale factor (1 default)
           iterations = static_cast<unsigned int>(max(1., off + timingHisto_->GetRandom() * scale));
           iterations *= 100000;
           for (unsigned int j = 0; j < iterations; j++) {
             dummy += sqrt(log(float(j + 1))) / float(j * j);
           }
         } break;
         case 16: {
           throw cms::Exception("FastMonitoringService") << "Random exception!";
         } break;
 
         default:
           break;
       }
     }
   }

◆ compute_crc()

unsigned short evf::compute_crc	(	unsigned char *	buffer,
		unsigned int	bufSize
	)

inline

Definition at line 46 of file CRC16.h.

References cms::cuda::assert(), edmScanValgrind::buffer, compute_crc_64bit(), and mps_fire::i.

Referenced by CSCDigiToRaw::createFedBuffers(), ESDataFormatterV1_1::DigiToRaw(), ESDataFormatterV4::DigiToRaw(), l1t::AMCDumpToRaw::formatRaw(), l1t::MP7BufferDumpToRaw::formatRaw(), CastorPacker::pack(), CastorCtdcPacker::pack(), HcalPacker::pack(), L1GTEvmDigiToRaw::packTrailer(), L1GTDigiToRaw::packTrailer(), DTDigiToRawModule::produce(), CSCTFPacker::produce(), RPCTwinMuxDigiToRaw::produce(), HGCalSlinkEmulator::produce(), GctDigiToRaw::produce(), HcalDigiToRawuHTR::produce(), l1t::L1TDigiToRaw::produce(), and omtf::OmtfPacker::produce().

                                                                                   {
   assert(0 == bufSize % 8);
   unsigned short crc(0xffff);
   bufSize /= 8;
   for (unsigned int i = 0; i < bufSize; i++)
     crc = evf::compute_crc_64bit(crc, &buffer[i * 8]);
   return crc;
 }

◆ compute_crc_64bit()

unsigned short evf::compute_crc_64bit	(	unsigned short	crc,
		unsigned char *	p
	)

inline

Definition at line 61 of file CRC16.h.

References compute_crc_8bit(), mps_fire::i, and mps_fire::result.

Referenced by compute_crc().

                                                                                    {
   unsigned short result(crc);
   for (int i = 7; i >= 0; i--)
     result = evf::compute_crc_8bit(result, p64[i]);
   return result;
 }

◆ compute_crc_8bit()

unsigned short evf::compute_crc_8bit	(	unsigned short	crc,
		unsigned char	data
	)

inline

Definition at line 56 of file CRC16.h.

References crc_table, and data.

Referenced by sistrip::calculateFEDBufferCRC(), RPCAMCRawToDigi::compute_crc16_64bit(), compute_crc_64bit(), and RPCTwinMuxRawToDigi::compute_crc_64bit().

                                                                                   {
   return (evf::crc_table[((crc >> 8) ^ data) & 0xFF] ^ (crc << 8));
 }

◆ getmBoL()

constexpr edm::ModuleDescription const* evf::getmBoL ( )

Definition at line 71 of file FastMonitoringService.cc.

References evf::FastMonState::mBoL.

Referenced by evf::FastMonitoringService::preStreamBeginLumi().

                                                   {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mBoL];
   }

◆ getmDqm()

constexpr edm::ModuleDescription const* evf::getmDqm ( )

Definition at line 68 of file FastMonitoringService.cc.

References evf::FastMonState::mDqm.

                                                   {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mDqm];
   }

◆ getmEoL()

constexpr edm::ModuleDescription const* evf::getmEoL ( )

Definition at line 74 of file FastMonitoringService.cc.

References evf::FastMonState::mEoL.

Referenced by evf::FastMonitoringService::doSnapshot(), and evf::FastMonitoringService::preStreamEndLumi().

                                                   {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mEoL];
   }

◆ getmEvent()

constexpr edm::ModuleDescription const* evf::getmEvent ( )

Definition at line 86 of file FastMonitoringService.cc.

References evf::FastMonState::mEvent.

Referenced by evf::FastMonitoringService::preEvent().

                                                     {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mEvent];
   }

◆ getmFwk()

constexpr edm::ModuleDescription const* evf::getmFwk ( )

Definition at line 80 of file FastMonitoringService.cc.

References evf::FastMonState::mFwk.

Referenced by evf::FastMonitoringService::doSnapshot().

                                                   {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mFwk];
   }

◆ getmFwkEoL()

constexpr edm::ModuleDescription const* evf::getmFwkEoL ( )

Definition at line 62 of file FastMonitoringService.cc.

References evf::FastMonState::mFwkEoL.

Referenced by evf::FastMonitoringService::doSnapshot(), and evf::FastMonitoringService::postStreamEndLumi().

                                                      {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mFwkEoL];
   }

◆ getmFwkOvhMod()

constexpr edm::ModuleDescription const* evf::getmFwkOvhMod ( )

Definition at line 59 of file FastMonitoringService.cc.

References evf::FastMonState::mFwkOvhMod.

Referenced by evf::FastMonitoringService::postModuleEvent(), and evf::FastMonitoringService::postModuleEventAcquire().

                                                         {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mFwkOvhMod];
   }

◆ getmFwkOvhSrc()

constexpr edm::ModuleDescription const* evf::getmFwkOvhSrc ( )

Definition at line 56 of file FastMonitoringService.cc.

References evf::FastMonState::mFwkOvhSrc.

Referenced by evf::FastMonitoringService::postSourceEvent().

                                                         {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mFwkOvhSrc];
   }

◆ getmGlobEoL()

constexpr edm::ModuleDescription const* evf::getmGlobEoL ( )

Definition at line 77 of file FastMonitoringService.cc.

References evf::FastMonState::mGlobEoL.

                                                       {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mGlobEoL];
   }

◆ getmIdle()

constexpr edm::ModuleDescription const* evf::getmIdle ( )

Definition at line 53 of file FastMonitoringService.cc.

References evf::FastMonState::mIdle.

Referenced by evf::FastMonitoringService::doSnapshot(), evf::FastMonitoringService::postEvent(), evf::FastMonitoringService::postModuleEvent(), evf::FastMonitoringService::postModuleEventAcquire(), evf::FastMonitoringService::postSourceEvent(), evf::FastMonitoringService::postStreamBeginLumi(), and evf::FastMonitoringService::preGlobalBeginLumi().

                                                    {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mIdle];
   }

◆ getmIdleSource()

constexpr edm::ModuleDescription const* evf::getmIdleSource ( )

Definition at line 83 of file FastMonitoringService.cc.

References evf::FastMonState::mIdleSource.

                                                          {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mIdleSource];
   }

◆ getmIgnore()

constexpr edm::ModuleDescription const* evf::getmIgnore ( )

Definition at line 89 of file FastMonitoringService.cc.

References evf::FastMonState::mIgnore.

                                                      {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mIgnore];
   }

◆ getmInput()

constexpr edm::ModuleDescription const* evf::getmInput ( )

Definition at line 65 of file FastMonitoringService.cc.

References evf::FastMonState::mInput.

Referenced by evf::FastMonitoringService::preSourceEvent().

                                                     {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mInput];
   }

◆ getmInvalid()

constexpr edm::ModuleDescription const* evf::getmInvalid ( )

Definition at line 50 of file FastMonitoringService.cc.

References evf::FastMonState::mInvalid.

Referenced by evf::FastMonitoringService::preBeginJob(), and evf::FastMonitoringService::preGlobalBeginLumi().

                                                       {
     return &FastMonitoringService::specialMicroStateNames[FastMonState::mInvalid];
   }

Variable Documentation

◆ crc_table

const unsigned short evf::crc_table[256]

Initial value:

= {
      0x0000, 0x8005, 0x800F, 0x000A, 0x801B, 0x001E, 0x0014, 0x8011, 0x8033, 0x0036, 0x003C, 0x8039, 0x0028, 0x802D,
      0x8027, 0x0022, 0x8063, 0x0066, 0x006C, 0x8069, 0x0078, 0x807D, 0x8077, 0x0072, 0x0050, 0x8055, 0x805F, 0x005A,
      0x804B, 0x004E, 0x0044, 0x8041, 0x80C3, 0x00C6, 0x00CC, 0x80C9, 0x00D8, 0x80DD, 0x80D7, 0x00D2, 0x00F0, 0x80F5,
      0x80FF, 0x00FA, 0x80EB, 0x00EE, 0x00E4, 0x80E1, 0x00A0, 0x80A5, 0x80AF, 0x00AA, 0x80BB, 0x00BE, 0x00B4, 0x80B1,
      0x8093, 0x0096, 0x009C, 0x8099, 0x0088, 0x808D, 0x8087, 0x0082, 0x8183, 0x0186, 0x018C, 0x8189, 0x0198, 0x819D,
      0x8197, 0x0192, 0x01B0, 0x81B5, 0x81BF, 0x01BA, 0x81AB, 0x01AE, 0x01A4, 0x81A1, 0x01E0, 0x81E5, 0x81EF, 0x01EA,
      0x81FB, 0x01FE, 0x01F4, 0x81F1, 0x81D3, 0x01D6, 0x01DC, 0x81D9, 0x01C8, 0x81CD, 0x81C7, 0x01C2, 0x0140, 0x8145,
      0x814F, 0x014A, 0x815B, 0x015E, 0x0154, 0x8151, 0x8173, 0x0176, 0x017C, 0x8179, 0x0168, 0x816D, 0x8167, 0x0162,
      0x8123, 0x0126, 0x012C, 0x8129, 0x0138, 0x813D, 0x8137, 0x0132, 0x0110, 0x8115, 0x811F, 0x011A, 0x810B, 0x010E,
      0x0104, 0x8101, 0x8303, 0x0306, 0x030C, 0x8309, 0x0318, 0x831D, 0x8317, 0x0312, 0x0330, 0x8335, 0x833F, 0x033A,
      0x832B, 0x032E, 0x0324, 0x8321, 0x0360, 0x8365, 0x836F, 0x036A, 0x837B, 0x037E, 0x0374, 0x8371, 0x8353, 0x0356,
      0x035C, 0x8359, 0x0348, 0x834D, 0x8347, 0x0342, 0x03C0, 0x83C5, 0x83CF, 0x03CA, 0x83DB, 0x03DE, 0x03D4, 0x83D1,
      0x83F3, 0x03F6, 0x03FC, 0x83F9, 0x03E8, 0x83ED, 0x83E7, 0x03E2, 0x83A3, 0x03A6, 0x03AC, 0x83A9, 0x03B8, 0x83BD,
      0x83B7, 0x03B2, 0x0390, 0x8395, 0x839F, 0x039A, 0x838B, 0x038E, 0x0384, 0x8381, 0x0280, 0x8285, 0x828F, 0x028A,
      0x829B, 0x029E, 0x0294, 0x8291, 0x82B3, 0x02B6, 0x02BC, 0x82B9, 0x02A8, 0x82AD, 0x82A7, 0x02A2, 0x82E3, 0x02E6,
      0x02EC, 0x82E9, 0x02F8, 0x82FD, 0x82F7, 0x02F2, 0x02D0, 0x82D5, 0x82DF, 0x02DA, 0x82CB, 0x02CE, 0x02C4, 0x82C1,
      0x8243, 0x0246, 0x024C, 0x8249, 0x0258, 0x825D, 0x8257, 0x0252, 0x0270, 0x8275, 0x827F, 0x027A, 0x826B, 0x026E,
      0x0264, 0x8261, 0x0220, 0x8225, 0x822F, 0x022A, 0x823B, 0x023E, 0x0234, 0x8231, 0x8213, 0x0216, 0x021C, 0x8219,
      0x0208, 0x820D, 0x8207, 0x0202}

Definition at line 16 of file CRC16.h.

Referenced by compute_crc_8bit().

◆ nReservedModules

constexpr int evf::nReservedModules = 128

Definition at line 162 of file FastMonitoringService.h.

Referenced by evf::FastMonitoringService::makeModuleLegendaJson().

◆ nSpecialModules

constexpr int evf::nSpecialModules = FastMonState::mCOUNT

Definition at line 160 of file FastMonitoringService.h.

Referenced by evf::FastMonitoringService::makeModuleLegendaJson().

Namespaces

Classes

Typedefs

Enumerations

Functions

Variables

Detailed Description

Typedef Documentation

◆ GlobalEvFOutputModuleType

Enumeration Type Documentation

◆ MergeType

Function Documentation

◆ __attribute__()

◆ compute_crc()

◆ compute_crc_64bit()

◆ compute_crc_8bit()

◆ getmBoL()

◆ getmDqm()

◆ getmEoL()

◆ getmEvent()

◆ getmFwk()

◆ getmFwkEoL()

◆ getmFwkOvhMod()

◆ getmFwkOvhSrc()

◆ getmGlobEoL()

◆ getmIdle()

◆ getmIdleSource()

◆ getmIgnore()

◆ getmInput()

◆ getmInvalid()

Variable Documentation

◆ crc_table

◆ nReservedModules

◆ nSpecialModules

◆ attribute()