PortInput mimics an Output Block. It wrapps over a Consumer Channel. Provides services like
Public Types | |
using | ApiDataTypeT = T |
using | BaseSyncHelper = SyncPortHelperInput< T > |
using | SpecimenT = typename parameter_traits< T >::SpecimenT |
Public Member Functions | |
dwStatus | bindChannel (ChannelObject *channel) override |
ChannelObject::SyncSignaler & | getSyncSignaler () |
ChannelObject::SyncWaiter & | getSyncWaiter () |
void | getWaitFences (T *frame, dw::core::span< NvSciSyncFence > fences) |
bool | isBound () override |
PortInput () | |
PortInput (OnSetSyncAttrs waiterAttrs, OnSetSyncAttrs signalerAttrs={}) | |
PortInput (SpecimenT &&ref) | |
PortInput (SpecimenT const &ref) | |
PortInput (SpecimenT const &ref, OnSetSyncAttrs waiterAttrs, OnSetSyncAttrs signalerAttrs={}) | |
virtual std::shared_ptr< T > | recv () |
void | setOnDataReady (void *opaque, ChannelObject::PacketPool::OnDataReady onDataReady) |
void | setSignalFences (T *frame, dw::core::span< NvSciSyncFence > fences) |
dwStatus | wait (dwTime_t timeout) |
~PortInput () override=default | |
![]() | |
SyncPortHelperInput () | |
![]() | |
bool | isDataSynced () |
virtual void | parseDataSynced (const ChannelParams ¶ms) |
void | setSyncCount (uint32_t index) |
dwStatus | setSyncRetriever (const CycleCountFetcher &func) |
SyncPortHelper () | |
![]() | |
virtual dwStatus | bindChannel (ChannelObject *channel)=0 |
virtual dwStatus | initialize () |
virtual bool | isBound ()=0 |
![]() | |
virtual | ~PortBase ()=default |
Static Public Attributes | |
static constexpr PortDirection | DIRECTION = PortDirection::INPUT |
Additional Inherited Members | |
![]() | |
T * | extractInternalPacket (GenericData genericData) |
GenericData | getBufferedPacket () |
bool | isPacketBuffered () |
bool | isValidPacketBuffered () |
![]() | |
ChannelPacketTypeID | getNewPacketID (ChannelPacketTypeID packetTypeID) |
void | stampSyncCount (uint32_t &syncCountOut) const |
![]() | |
uint32_t | m_dataOffset |
bool | m_dataSynced |
uint32_t | m_syncCount |
CycleCountFetcher | m_syncCountRetriever |
using dw::framework::PortInput< T >::ApiDataTypeT = T |
using dw::framework::PortInput< T >::BaseSyncHelper = SyncPortHelperInput<T> |
using dw::framework::PortInput< T >::SpecimenT = typename parameter_traits<T>::SpecimenT |
|
inlineexplicit |
|
inlineexplicit |
|
inline |
|
inlineexplicit |
|
inlineexplicit |
|
overridedefault |
|
inlineoverridevirtual |
Implements dw::framework::Port.
Definition at line 318 of file Port.hpp.
References FRWK_LOGE, dw::framework::ChannelObject::getConsumer(), dw::framework::SyncPortHelper::getNewPacketID(), dw::framework::ChannelObject::getParams(), dw::framework::ChannelParams::getReuseEnabled(), dw::framework::Exception::guard(), dw::framework::PortInput< T >::isBound(), dw::framework::SyncPortHelper::isDataSynced(), and dw::framework::SyncPortHelper::parseDataSynced().
|
inline |
Definition at line 474 of file Port.hpp.
References dw::framework::ChannelObject::PacketPool::getSyncSignaler().
|
inline |
Definition at line 495 of file Port.hpp.
References dw::framework::ChannelObject::PacketPool::getSyncWaiter().
|
inline |
Definition at line 504 of file Port.hpp.
References dw::framework::ChannelObject::PacketPool::getSyncWaiter(), dw::framework::ChannelObject::SyncWaiter::getWaitFences(), and dw::framework::SyncPortHelper::isDataSynced().
|
inlineoverridevirtual |
Implements dw::framework::Port.
Definition at line 358 of file Port.hpp.
Referenced by dw::framework::PortInput< T >::bindChannel(), dw::framework::ReadProcessedDataFromChannel< OutputProcessedDataType, InputProcessedDataType >::readNextData(), dw::framework::PortInput< T >::recv(), dw::framework::PortInput< T >::setOnDataReady(), and dw::framework::PortInput< T >::wait().
|
inlinevirtual |
Definition at line 407 of file Port.hpp.
References dw::framework::data, dw::framework::SyncPortHelperInput< T >::extractInternalPacket(), dw::framework::SyncPortHelperInput< T >::getBufferedPacket(), dw::framework::PortInput< T >::isBound(), dw::framework::SyncPortHelper::isDataSynced(), dw::framework::SyncPortHelperInput< T >::isPacketBuffered(), dw::framework::SyncPortHelperInput< T >::isValidPacketBuffered(), dw::framework::ChannelObject::Consumer::recv(), and dw::framework::status.
Referenced by dw::framework::ReadProcessedDataFromChannel< OutputProcessedDataType, InputProcessedDataType >::readNextData().
|
inline |
Definition at line 363 of file Port.hpp.
References dw::framework::PortInput< T >::isBound(), and dw::framework::ChannelObject::PacketPool::setOnDataReady().
|
inline |
Definition at line 483 of file Port.hpp.
References dw::framework::ChannelObject::PacketPool::getSyncSignaler(), dw::framework::SyncPortHelper::isDataSynced(), and dw::framework::ChannelObject::SyncSignaler::setSignalFences().
|
inline |
Definition at line 373 of file Port.hpp.
References dw::framework::PortInput< T >::isBound(), dw::framework::SyncPortHelper::isDataSynced(), dw::framework::SyncPortHelperInput< T >::isPacketBuffered(), dw::framework::SyncPortHelperInput< T >::isValidPacketBuffered(), dw::framework::status, and dw::framework::ChannelObject::PacketPool::wait().
Referenced by dw::framework::ReadProcessedDataFromChannel< OutputProcessedDataType, InputProcessedDataType >::readNextData().
|
staticconstexpr |