Falcon
Loading...
Searching...
No Matches

Public Member Functions

 ISlotOut (IPortOut *parent, const SlotAddress &address)
const SlotAddress & address () const
IPortOut * parent ()
bool connected () const
int nconnected () const
virtual IStreamInfo & streaminfo ()=0
int buffer_size () const

Protected Member Functions

void Connect (ISlotIn *downstream)
int64_t WaitFor (int64_t sequence) const
int64_t WaitFor (int64_t sequence, int64_t time_out) const
virtual AnyType::Data * DataAt (int64_t sequence) const =0
std::vector< RingSequence * > gating_sequences ()

Protected Attributes

RingBatch ring_batch_
bool has_publishable_data_ = false
std::set< ISlotIn * > downstream_slots_
std::unique_ptr< RingBarrier > barrier_ = nullptr
int buffer_size_
IPortOut * parent_
SlotAddress address_

Friends

class ISlotIn
template<typename DATATYPE>
class SlotIn
class IPortOut

The documentation for this class was generated from the following files: