Apollo 10.0
自动驾驶开放平台
|
#include <intra_reader.h>
Public 类型 | |
using | MessagePtr = std::shared_ptr< MessageT > |
using | Callback = std::function< void(const std::shared_ptr< MessageT > &)> |
using | Iterator = typename std::list< std::shared_ptr< MessageT > >::const_iterator |
![]() | |
using | BlockerPtr = std::unique_ptr< blocker::Blocker< MessageT > > |
using | ReceiverPtr = std::shared_ptr< transport::Receiver< MessageT > > |
using | ChangeConnection = typename service_discovery::Manager::ChangeConnection |
using | Iterator = typename std::list< std::shared_ptr< MessageT > >::const_iterator |
Public 成员函数 | |
IntraReader (const proto::RoleAttributes &attr, const Callback &callback) | |
virtual | ~IntraReader () |
bool | Init () override |
Init the Reader object | |
void | Shutdown () override |
Shutdown the Reader object | |
void | ClearData () override |
Clear local data | |
void | Observe () override |
Get stored data | |
bool | Empty () const override |
Query whether the Reader has data to be handled | |
bool | HasReceived () const override |
Query whether we have received data since last clear | |
void | Enqueue (const std::shared_ptr< MessageT > &msg) override |
Push msg to Blocker's PublishQueue | |
void | SetHistoryDepth (const uint32_t &depth) override |
Set Blocker's PublishQueue 's capacity to depth | |
uint32_t | GetHistoryDepth () const override |
Get Blocker's PublishQueue 's capacity | |
std::shared_ptr< MessageT > | GetLatestObserved () const override |
Get the latest message we Observe | |
std::shared_ptr< MessageT > | GetOldestObserved () const override |
Get the oldest message we Observe | |
Iterator | Begin () const override |
Get the begin iterator of ObserveQueue , used to traverse | |
Iterator | End () const override |
Get the end iterator of ObserveQueue , used to traverse | |
![]() | |
Reader (const proto::RoleAttributes &role_attr, const CallbackFunc< MessageT > &reader_func=nullptr, uint32_t pending_queue_size=DEFAULT_PENDING_QUEUE_SIZE) | |
Constructor a Reader object. | |
virtual | ~Reader () |
bool | Init () override |
Init Reader | |
void | Shutdown () override |
Shutdown Reader | |
void | Observe () override |
Get All data that Blocker stores | |
void | ClearData () override |
Clear Blocker 's data | |
bool | HasReceived () const override |
Query whether we have received data since last clear | |
bool | Empty () const override |
Query whether the Reader has data to be handled | |
double | GetDelaySec () const override |
Get time interval of since last receive message | |
uint32_t | PendingQueueSize () const override |
Get pending_queue_size configuration | |
bool | HasWriter () override |
Is there is at least one writer publish the channel that we subscribes? | |
void | GetWriters (std::vector< proto::RoleAttributes > *writers) override |
Get all writers pushlish the channel we subscribes | |
![]() | |
ReaderBase (const proto::RoleAttributes &role_attr) | |
virtual | ~ReaderBase () |
const std::string & | GetChannelName () const |
Get Reader's Channel name | |
uint64_t | ChannelId () const |
Get Reader's Channel id | |
const proto::QosProfile & | QosProfile () const |
Get qos profile. | |
bool | IsInit () const |
Query whether the Reader is initialized | |
额外继承的成员函数 | |
![]() | |
double | latest_recv_time_sec_ = -1.0 |
double | second_to_lastest_recv_time_sec_ = -1.0 |
uint32_t | pending_queue_size_ |
![]() | |
proto::RoleAttributes | role_attr_ |
std::atomic< bool > | init_ |
在文件 intra_reader.h 第 34 行定义.
using apollo::cyber::blocker::IntraReader< MessageT >::Callback = std::function<void(const std::shared_ptr<MessageT>&)> |
在文件 intra_reader.h 第 37 行定义.
using apollo::cyber::blocker::IntraReader< MessageT >::Iterator = typename std::list<std::shared_ptr<MessageT> >::const_iterator |
在文件 intra_reader.h 第 38 行定义.
using apollo::cyber::blocker::IntraReader< MessageT >::MessagePtr = std::shared_ptr<MessageT> |
在文件 intra_reader.h 第 36 行定义.
apollo::cyber::blocker::IntraReader< MessageT >::IntraReader | ( | const proto::RoleAttributes & | attr, |
const Callback & | callback | ||
) |
在文件 intra_reader.h 第 67 行定义.
|
virtual |
在文件 intra_reader.h 第 72 行定义.
|
overridevirtual |
Get the begin iterator of ObserveQueue
, used to traverse
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 182 行定义.
|
overridevirtual |
Clear local data
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 98 行定义.
|
overridevirtual |
Query whether the Reader has data to be handled
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 117 行定义.
|
overridevirtual |
Get the end iterator of ObserveQueue
, used to traverse
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 190 行定义.
|
overridevirtual |
Push msg
to Blocker's PublishQueue
msg | message ptr to be pushed |
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 137 行定义.
|
overridevirtual |
Get Blocker's PublishQueue
's capacity
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 152 行定义.
|
overridevirtual |
Get the latest message we Observe
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 162 行定义.
|
overridevirtual |
Get the oldest message we Observe
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 172 行定义.
|
overridevirtual |
Query whether we have received data since last clear
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 127 行定义.
|
overridevirtual |
Init the Reader object
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 77 行定义.
|
overridevirtual |
Get stored data
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 108 行定义.
|
overridevirtual |
Set Blocker's PublishQueue
's capacity to depth
depth | the value you want to set |
重载 apollo::cyber::Reader< MessageT > .
在文件 intra_reader.h 第 143 行定义.
|
overridevirtual |
Shutdown the Reader object
实现了 apollo::cyber::ReaderBase.
在文件 intra_reader.h 第 89 行定义.