FARGOS/VISTA Object Management Environment Core  ..
FARGOS/VISTA Object Management Environment Core Table of Contents
OrderedInput.hpp File Reference

Implements high-performance ordered input from multiple data streams. More...

#include <queue>
#include <vector>
#include <set>
#include <utils/logging/logging_api.hpp>
#include <utils/io/io_processor.hpp>

Go to the source code of this file.

Classes

class  OrderedInputBlock
 Input block record for use with OrderedMultipleInputFilter. More...
 
struct  OrderedInputSource::InputBlockReturn
 Return result from getNextInputBlock(). More...
 
class  OrderedInputPriorityQueue
 Encapsulation class for a priority queue. More...
 
struct  OrderedInputPriorityQueue::ltOrderedInputBlockPtr
 Less-than operator for OrderedInputBlock pointers. More...
 
class  OrderedInputSourceProxy
 Proxy class to allow state to be associated with an existing OrderedInputSource, while appearing to be the original OrderedInputSource. More...
 
class  OrderedInputSourceProxyWithReordering
 Class that extends OrderedInputSourceProxy with the ability to tolerate a certain number of out-of-order messages that are provided by the source. More...
 
class  OrderedMultipleInputFilter
 Streaming filter that consumes input data from multiple sources and outputs blocks in sorted order. More...
 

Macros

#define FORCE_ORDERED_INPUT_BLOCK_AS_FINAL   0
 Disable all virtualization support in OrderedInputBlock. More...
 
#define ORDERED_INPUT_BLOCK_FINAL
 Set to final if ORDERED_INPUT_BLOCK_AS_FINAL is set to 1. More...
 
#define ORDERED_INPUT_BLOCK_VIRTUAL   virtual
 Set to virtual if ORDERED_INPUT_BLOCK_AS_FINAL is set to 0. More...
 
#define _TRACK_RANGE_PROCESSED   1
 

Detailed Description

Implements high-performance ordered input from multiple data streams.

These facilities support simulation environments that consume time or sequence-ordered records from multiple sources. Data can come from files, sockets, memory-mapped regions, or be generated on the fly.

Macro Definition Documentation

◆ _TRACK_RANGE_PROCESSED

#define _TRACK_RANGE_PROCESSED   1
Generated: Tue Jul 28 2020 16:03:26
Support Information