CatapultServer  v0.5.0.1 (Elephant)
BufferedPacketIo.h
Go to the documentation of this file.
1 
21 #pragma once
22 #include "IoTypes.h"
23 
24 namespace catapult { namespace ionet { class PacketIo; } }
25 
26 namespace catapult { namespace ionet {
27 
29  std::shared_ptr<PacketIo> CreateBufferedPacketIo(const std::shared_ptr<PacketIo>& pIo, boost::asio::io_context::strand& strand);
30 }}
BufferedPacketIo.h
m_handler
THandler m_handler
Definition: BufferedPacketIo.cpp:111
CATAPULT_LOG
#define CATAPULT_LOG(SEV)
Writes a log entry to the default logger with SEV severity.
Definition: Logging.h:340
m_strand
boost::asio::io_context::strand & m_strand
Definition: BufferedPacketIo.cpp:137
m_pIo
std::shared_ptr< PacketIo > m_pIo
Definition: BufferedPacketIo.cpp:171
m_queue
RequestQueue & m_queue
Definition: BufferedPacketIo.cpp:112
m_pWriteOperation
std::unique_ptr< QueuedWriteOperation > m_pWriteOperation
Definition: BufferedPacketIo.cpp:173
m_wrapper
TCallbackWrapper & m_wrapper
Definition: BufferedPacketIo.cpp:116
m_pReadOperation
std::unique_ptr< QueuedReadOperation > m_pReadOperation
Definition: BufferedPacketIo.cpp:174
catapult::ionet::CreateBufferedPacketIo
std::shared_ptr< PacketIo > CreateBufferedPacketIo(const std::shared_ptr< PacketIo > &pIo, boost::asio::io_context::strand &strand)
Adds buffering to pIo using strand for synchronization.
Definition: BufferedPacketIo.cpp:178
m_requests
std::deque< std::pair< TRequest, TCallback > > m_requests
Definition: BufferedPacketIo.cpp:117
m_payload
PacketPayload m_payload
Definition: BufferedPacketIo.cpp:44
m_io
PacketIo & m_io
Definition: BufferedPacketIo.cpp:43
catapult
Definition: AddressExtractionExtension.cpp:28
Logging.h
IoTypes.h
PacketIo.h