Skip to content

Commit bcc2aad

Browse files
committed
added run number to stats block
1 parent 4aa6a30 commit bcc2aad

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/ReadoutStats.cxx

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,8 @@ void ReadoutStats::reset(bool lightReset)
7575
counters.bufferUsage[i] = -1.0;
7676
}
7777
}
78+
79+
counters.runNumber = undefinedRunNumber;
7880
}
7981

8082
void ReadoutStats::print()

src/ReadoutStats.h

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ struct ReadoutStatsCounters {
3535
std::atomic<uint64_t> bytesReadout;
3636
std::atomic<uint64_t> bytesRecorded;
3737
std::atomic<uint64_t> bytesFairMQ;
38-
std::atomic<double> timestamp;
38+
std::atomic<double> timestamp;
3939
std::atomic<double> bytesReadoutRate;
4040
std::atomic<uint64_t> state;
4141
std::atomic<uint64_t> pagesPendingFairMQ; // number of pages pending in ConsumerFMQ
@@ -52,10 +52,11 @@ struct ReadoutStatsCounters {
5252
std::atomic<uint64_t> ddBytesCopied; // Data Distribution: number of bytes copied (HBF overlapping superpages)
5353
std::atomic<uint64_t> ddMemoryPendingBytes; // Data Distribution: number of bytes pending release in ConsumerFMQ (real memory)
5454
std::atomic<uint64_t> ddPayloadPendingBytes; // Data Distribution: number of bytes pending release in ConsumerFMQ (payload only, not accounting for memory fragmentation overhead)
55+
std::atomic<uint64_t> runNumber; // current run number (valid only in running state)
5556
};
5657

5758
// version number of this struct
58-
const uint32_t ReadoutStatsCountersVersion = 0xA0000003;
59+
const uint32_t ReadoutStatsCountersVersion = 0xA0000004;
5960

6061
// need to be able to easily transmit this struct as a whole
6162
static_assert(std::is_pod<ReadoutStatsCounters>::value);

0 commit comments

Comments
 (0)