NonBlockingMonotonicSeqQueue.hpp File Reference

#include <Exceptions/RuntimeException.hpp>
#include <Sequencing/ChunkCollector.hpp>
#include <Sequencing/SequenceData.hpp>
#include <Util/Common.hpp>
#include <Util/Logger/Logger.hpp>
#include <algorithm>
#include <array>
#include <atomic>
#include <cassert>
#include <folly/SharedMutex.h>
#include <folly/Synchronized.h>
#include <list>
#include <memory>

Include dependency graph for NonBlockingMonotonicSeqQueue.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Sequencing::NonBlockingMonotonicSeqQueue< T, BlockSize >
	This class implements a non blocking monotonic sequence queue, which is mainly used as a foundation for an efficient watermark processor. This queue receives values of type T with an associated sequence number and returns the value with the highest sequence number in strictly monotonic increasing order. More...

Namespaces
	NES
	This exception represents a network error.
	NES::Sequencing