This is the complete list of members for CgwSession, including all inherited members.
breakConnection() | Session | |
breakConnectionAsync() | Session | |
CgwSession(const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") | CgwSession | |
CgwSession(SessionReactor &stack, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") | CgwSession | |
CmeMaxPacketSize | Session | static |
connect(const std::string &host, Port port) | Session | |
connectAsync(const std::string &host, Port port) | Session | |
creationTime() const noexcept | Session | |
customKey() const | Session | |
detectMessageGapForPreviousUuid() const | Session | |
detectMessageGapForPreviousUuid(bool detectGap) | Session | |
disconnect(const std::string &reason="") | Session | |
disconnectAsync(const std::string &reason="") | Session | |
faultToleranceIndicator() const | Session | |
faultToleranceIndicator(Messaging::FTI::Enum value) | Session | |
flushSessionStorage() | Session | |
getTcpInfo(TcpInfo &) | Session | |
id() const | Session | |
incomingMessageGapQueueMaximumSize() const | Session | |
incomingMessageGapQueueMaximumSize(size_t value) | Session | |
inSeqNum() const | Session | |
inSeqNum(SeqNumber nextExpectedInSeqNum) | Session | |
InvalidSocketHandle | Session | static |
licenseExpirationDate() const | Session | |
localNetworkInterface() const | Session | |
localNetworkInterface(const std::string &value) | Session | |
localPort() const | Session | |
localPortRange() const noexcept | Session | |
localPortRange(std::pair< Port, Port > portRange) | Session | |
localTimeUsage() const | Session | |
localTimeUsage(bool useLocalTime) | Session | |
log(const std::string &message) const | Session | |
logBeforeSending() const | Session | |
logBeforeSending(bool value) | Session | |
messageGrouping() const noexcept | Session | |
messageGrouping(unsigned numberOfMessagesToGroup) | Session | |
messagingVersion() const noexcept | Session | |
negotiated() const | Session | |
negotiated(bool negotiated) | Session | |
outboundQueueBytes() | Session | |
outSeqNum() const noexcept | Session | |
outSeqNum(SeqNumber nextOutSeqNum) | Session | |
previousSeqNo() const noexcept | Session | |
previousSeqNo(SeqNumber value) | Session | |
previousUuid() const noexcept | Session | |
previousUuid(Messaging::UInt64 value) | Session | |
receiveSpinningTimeout() const noexcept | Session | |
receiveSpinningTimeout(unsigned timeoutInUs) | Session | |
receivingThreadAffinity(CpuIndex cpuIndex) | Session | |
receivingThreadAffinity(const CpuIndexes &cpuIndexes) | Session | |
receivingThreadAffinity() const | Session | |
receivingThreadPolicy() const | Session | |
receivingThreadPolicy(int policy) | Session | |
receivingThreadPriority() const | Session | |
receivingThreadPriority(int priority) | Session | |
reconnectAttempts() const | Session | |
reconnectAttempts(unsigned reconnectAttempts) | Session | |
reconnectInterval() const | Session | |
reconnectInterval(unsigned seconds) | Session | |
remoteHost() const | Session | |
remoteIpAddress() const | Session | |
remotePort() const | Session | |
reportNewMessagesWhileWaitingForMissedMessages() const | Session | |
reportNewMessagesWhileWaitingForMissedMessages(bool value) | Session | |
reset(bool startOfWeek=false) | Session | |
send(Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &msg, Messaging::Timestamp sendingTime=UtcWatch::now()) | Session | |
send(Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &&msg, Messaging::Timestamp sendingTime=UtcWatch::now()) | 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 | |
sendingThreadAffinity(CpuIndex cpuIndex) | Session | |
sendingThreadAffinity(const CpuIndexes &cpuIndexes) | Session | |
sendingThreadAffinity() const | Session | |
sendingThreadPolicy() const | Session | |
sendingThreadPolicy(int policy) | Session | |
sendingThreadPriority() const | Session | |
sendingThreadPriority(int priority) | Session | |
sendSequenceMessage(Messaging::KeepAliveLapsed::Enum keepAliveLapsed=Messaging::KeepAliveLapsed::Lapsed) | Session | |
sendSpinningTimeout() const noexcept | Session | |
sendSpinningTimeout(unsigned timeoutInUs) | Session | |
Session(const SessionSettings &settings, int marketSegmentId, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, UInt64 uuid=UndefinedUuid, const std::string &customKey="") | Session | |
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 | |
socketHandle() | Session | |
socketOptions() const | Session | |
socketOptions(const SocketOptions &options) | Session | |
state() const | Session | |
storageDirectory() const | Session | |
storageId() const noexcept | Session | |
storageType() const noexcept | Session | |
tcpNoDelayOption() const | Session | |
tcpNoDelayOption(bool value) | Session | |
throttle() | Session | |
throttlingLimit(size_t messagesCount, size_t intervalInMs=1000) | Session | |
toString() const | Session | |
tryThrottle() | Session | |
UndefinedAffinity | Session | static |
UndefinedUuid | Session | static |
uuid() const noexcept | Session | |
version() noexcept | Session | static |
warmUp(Messaging::MessageHolder< SbeMessageType, MaxMessageSize > &msg, Messaging::Timestamp sendingTime=UtcWatch::now(), int warmupFlags=0) | 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 | |
~Session() | Session |