We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent acd8428 commit fe66ff5Copy full SHA for fe66ff5
1 file changed
include/ipfixprobe/outputPlugin/outputStorage/mqOutputStorage.hpp
@@ -264,13 +264,13 @@ class MQOutputStorage : public OutputStorage<ElementType> {
264
std::atomic<bool> m_writerFinished {false};
265
266
struct State {
267
+ uint64_t written;
268
std::span<ElementType*> readBuffer;
269
std::span<ElementType*> writeBuffer;
270
boost::container::static_vector<
271
CacheAlligned<std::atomic<uint64_t>>,
272
OutputStorage<ElementType>::MAX_READERS_COUNT>
273
readerGroupPositions;
- uint64_t written;
274
275
State& operator=(const State& other) noexcept
276
{
0 commit comments