|
| CgwSession (const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") |
|
| CgwSession (SessionReactor &stack, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") |
|
| Session (const SessionSettings &settings, int marketSegmentId, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") |
|
| Session (SessionReactor &stack, const SessionSettings &settings, int marketSegmentId, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") |
|
| ~Session () |
|
UInt64 | uuid () const noexcept |
|
std::string | id () const |
|
int | marketSegmentId () const noexcept |
|
std::string | customKey () const |
|
bool | negotiated () const |
|
Session & | negotiated (bool negotiated) |
|
Messaging::FTI::Enum | faultToleranceIndicator () const |
|
Session & | faultToleranceIndicator (Messaging::FTI::Enum value) |
|
Session & | connect (const std::string &host, Port port) |
|
Threading::SharedFuture< void > | connectAsync (const std::string &host, Port port) |
|
Session & | disconnect (const std::string &reason="") |
|
Threading::SharedFuture< void > | disconnectAsync (const std::string &reason="") |
|
template<typename SbeMessageType , size_t MaxMessageSize, typename MessageInitializer > |
Session & | send (Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &msg, Messaging::Timestamp sendingTime=UtcWatch::now()) |
|
template<typename SbeMessageType , size_t MaxMessageSize, typename MessageInitializer > |
Session & | send (Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &&msg, Messaging::Timestamp sendingTime=UtcWatch::now()) |
|
template<typename SbeMessageType , size_t MaxMessageSize, typename MessageInitializer > |
Session & | send (MessageBatch< SbeMessageType, MaxMessageSize, MessageInitializer > &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=CmeMaxPacketSize) |
|
Session & | send (MessageBatchCombiner &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=CmeMaxPacketSize) |
|
Session & | sendSequenceMessage (Messaging::KeepAliveLapsed::Enum keepAliveLapsed=Messaging::KeepAliveLapsed::Lapsed) |
|
template<typename SbeMessageType , size_t MaxMessageSize> |
Session & | warmUp (Messaging::MessageHolder< SbeMessageType, MaxMessageSize > &msg, Messaging::Timestamp sendingTime=UtcWatch::now(), int warmupFlags=0) |
|
template<typename SbeMessageType , size_t MaxMessageSize, typename MessageInitializer > |
Session & | warmUp (MessageBatch< SbeMessageType, MaxMessageSize, MessageInitializer > &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=CmeMaxPacketSize, int warmupFlags=0) |
|
Session & | warmUp (MessageBatchCombiner &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=CmeMaxPacketSize, int warmupFlags=0) |
|
Session & | throttle () |
|
size_t | tryThrottle () |
|
Session & | throttlingLimit (size_t messagesCount, size_t intervalInMs=1000) |
|
std::string | remoteHost () const |
|
std::string | remoteIpAddress () const |
|
Port | remotePort () const |
|
std::pair< Port, Port > | localPortRange () const noexcept |
|
Session & | localPortRange (std::pair< Port, Port > portRange) |
|
std::string | localNetworkInterface () const |
|
Session & | localNetworkInterface (const std::string &value) |
|
Port | localPort () const |
|
bool | tcpNoDelayOption () const |
|
Session & | tcpNoDelayOption (bool value) |
|
const SocketOptions & | socketOptions () const |
|
Session & | socketOptions (const SocketOptions &options) |
|
Session & | receivingThreadAffinity (CpuIndex cpuIndex) |
|
Session & | receivingThreadAffinity (const CpuIndexes &cpuIndexes) |
|
const CpuIndexes & | receivingThreadAffinity () const |
|
Session & | sendingThreadAffinity (CpuIndex cpuIndex) |
|
Session & | sendingThreadAffinity (const CpuIndexes &cpuIndexes) |
|
const CpuIndexes & | sendingThreadAffinity () const |
|
int | receivingThreadPriority () const |
|
Session & | receivingThreadPriority (int priority) |
|
int | sendingThreadPriority () const |
|
Session & | sendingThreadPriority (int priority) |
|
int | receivingThreadPolicy () const |
|
Session & | receivingThreadPolicy (int policy) |
|
int | sendingThreadPolicy () const |
|
Session & | sendingThreadPolicy (int policy) |
|
unsigned | receiveSpinningTimeout () const noexcept |
|
Session & | receiveSpinningTimeout (unsigned timeoutInUs) |
|
unsigned | sendSpinningTimeout () const noexcept |
|
Session & | sendSpinningTimeout (unsigned timeoutInUs) |
|
bool | reportNewMessagesWhileWaitingForMissedMessages () const |
|
Session & | reportNewMessagesWhileWaitingForMissedMessages (bool value) |
|
unsigned | messageGrouping () const noexcept |
|
Session & | messageGrouping (unsigned numberOfMessagesToGroup) |
|
SessionStorageType::Enum | storageType () const noexcept |
|
const std::string & | storageId () const noexcept |
|
SeqNumber | outSeqNum () const noexcept |
|
Session & | outSeqNum (SeqNumber nextOutSeqNum) |
|
SeqNumber | inSeqNum () const |
|
Session & | inSeqNum (SeqNumber nextExpectedInSeqNum) |
|
SeqNumber | previousSeqNo () const noexcept |
|
Session & | previousSeqNo (SeqNumber value) |
|
Messaging::UInt64 | previousUuid () const noexcept |
|
Session & | previousUuid (Messaging::UInt64 value) |
|
Session & | reset (bool startOfWeek=false) |
|
SessionStateId::Enum | state () const |
|
Messaging::Timestamp | creationTime () const noexcept |
|
void | flushSessionStorage () |
|
unsigned | reconnectAttempts () const |
|
Session & | reconnectAttempts (unsigned reconnectAttempts) |
|
unsigned | reconnectInterval () const |
|
Session & | reconnectInterval (unsigned seconds) |
|
bool | localTimeUsage () const |
|
Session & | localTimeUsage (bool useLocalTime) |
|
const std::string & | storageDirectory () const |
|
bool | logBeforeSending () const |
|
Session & | logBeforeSending (bool value) |
|
size_t | incomingMessageGapQueueMaximumSize () const |
|
Session & | incomingMessageGapQueueMaximumSize (size_t value) |
|
const Session & | log (const std::string &message) const |
|
std::string | toString () const |
|
Messaging::Timestamp | licenseExpirationDate () const |
|
Messaging::SchemaVersion | messagingVersion () const noexcept |
|
bool | detectMessageGapForPreviousUuid () const |
|
Session & | detectMessageGapForPreviousUuid (bool detectGap) |
|
Handle | socketHandle () |
|
size_t | outboundQueueBytes () |
|
bool | getTcpInfo (TcpInfo &) |
|
Definition at line 590 of file Session.h.