#include <swcdb/core/comm/Event.h>
Public Types | |
typedef std::shared_ptr< Event > | Ptr |
Public Member Functions | |
~Event () noexcept | |
SWC_CAN_INLINE void | received () noexcept |
void | decode_buffers () |
SWC_CAN_INLINE bool | expired (int64_t within=0) const noexcept |
int32_t | response_code () const noexcept |
void | print (std::ostream &out) const |
Static Public Member Functions | |
static SWC_CAN_INLINE Ptr | make (int error) |
Public Attributes | |
int64_t | expiry_ms |
StaticBuffer | data |
Primary data buffer. More... | |
StaticBuffer | data_ext |
Extended buffer. More... | |
Header | header |
int | error |
Private Member Functions | |
SWC_CAN_INLINE | Event (int a_error) noexcept |
typedef std::shared_ptr<Event> SWC::Comm::Event::Ptr |
|
inlineexplicitprivatenoexcept |
SWC_CAN_INLINE void SWC::Comm::Event::decode_buffers | ( | ) |
Definition at line 70 of file Event.h.
References SWC::Comm::Header::buffers, data, SWC::Comm::Header::data, data_ext, SWC::Comm::Header::data_ext, SWC::Comm::BufferInfo::decode(), error, SWC::Core::Buffer< T >::free(), header, SWC::LOG_WARN, SWC::Error::OK, print(), SWC::Error::REQUEST_TRUNCATED_PAYLOAD, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
|
inlinenoexcept |
Definition at line 51 of file Event.h.
References expiry_ms, and SWC::Time::now_ms().
|
inlinestatic |
Definition at line 36 of file Event.h.
References error, and Event().
Referenced by SWC::Comm::ConnHandler::Receiver_HeaderPrefix::operator()(), SWC::Comm::ConnHandler::Sender_Ack::operator()(), SWC::FS::FileSystemBroker::send_request(), and SWC::Comm::ConnHandler::write().
void SWC::Comm::Event::print | ( | std::ostream & | out | ) | const |
Definition at line 36 of file Event.cc.
References data, data_ext, error, header, SWC::Comm::Header::print(), SWC::Error::print(), and SWC::Core::Buffer< T >::size.
Referenced by decode_buffers().
|
inlinenoexcept |
Definition at line 43 of file Event.h.
References expiry_ms, header, SWC::Time::now_ms(), and SWC::Comm::Header::timeout_ms.
|
noexcept |
Definition at line 17 of file Event.cc.
References SWC::Core::Buffer< T >::base, SWC::Error::Exception::code(), data, SWC::Serialization::decode_i32(), error, SWC::LOG_ERROR, SWC::Core::Buffer< T >::size, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
StaticBuffer SWC::Comm::Event::data |
Primary data buffer.
Definition at line 60 of file Event.h.
Referenced by decode_buffers(), print(), and response_code().
StaticBuffer SWC::Comm::Event::data_ext |
Extended buffer.
Definition at line 61 of file Event.h.
Referenced by decode_buffers(), and print().
int SWC::Comm::Event::error |
Definition at line 63 of file Event.h.
Referenced by decode_buffers(), make(), print(), and response_code().
int64_t SWC::Comm::Event::expiry_ms |
Definition at line 59 of file Event.h.
Referenced by expired(), and received().
Header SWC::Comm::Event::header |
Definition at line 62 of file Event.h.
Referenced by decode_buffers(), print(), and received().