SessionSettings.h

Go to the documentation of this file.

/*
 * Copyright Onix Solutions Limited [OnixS]. All rights reserved.
 *
 * This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law
 * and international copyright treaties.
 *
 * Access to and use of the software is governed by the terms of the applicable OnixS Software
 * Services Agreement (the Agreement) and Customer end user license agreements granting
 * a non-assignable, non-transferable and non-exclusive license to use the software
 * for it's own data processing purposes under the terms defined in the Agreement.
 *
 * Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part
 * of this source code or associated reference material to any other location for further reproduction
 * or redistribution, and any amendments to this copyright notice, are expressly prohibited.
 *
 * Any reproduction or redistribution for sale or hiring of the Software not in accordance with
 * the terms of the Agreement is a violation of copyright law.
 */
 
#pragma once
 
#include <OnixS/B3/BOE/ABI.h>
#include <OnixS/B3/BOE/Messaging.h>
#include <OnixS/B3/BOE/ThreadingModel.h>
 
#include <climits>
#include <set>
#include <string>
#include <vector>
 
namespace OnixS {
namespace B3 {
namespace BOE {

class SessionSettings
{
public:
    ONIXS_B3_BOE_EXPORTED
    SessionSettings();

    ONIXS_B3_BOE_NODISCARD
    Messaging::SessionID sessionId() const ONIXS_B3_BOE_NOTHROW {
        return sessionId_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& sessionId(Messaging::SessionID value);

    ONIXS_B3_BOE_NODISCARD
    Messaging::UInt32 enteringFirm() const ONIXS_B3_BOE_NOTHROW {
        return enteringFirm_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& enteringFirm(Messaging::UInt32 value);

    ONIXS_B3_BOE_NODISCARD
    const std::string & accessKey() const ONIXS_B3_BOE_NOTHROW {
        return accessKey_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& accessKey(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    Messaging::CancelOnDisconnectType::Enum cancelOnDisconnectType() const ONIXS_B3_BOE_NOTHROW {
        return cancelOnDisconnectType_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& cancelOnDisconnectType(Messaging::CancelOnDisconnectType::Enum value);

    ONIXS_B3_BOE_NODISCARD
    const std::string & tradingSystemName() const ONIXS_B3_BOE_NOTHROW {
        return tradingSystemName_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& tradingSystemName(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    const std::string & tradingSystemVersion() const ONIXS_B3_BOE_NOTHROW {
        return tradingSystemVersion_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& tradingSystemVersion(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    ThreadingModel::Enum threadingModel() const ONIXS_B3_BOE_NOTHROW {
        return threadingModel_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& threadingModel(ThreadingModel::Enum value);

    ONIXS_B3_BOE_NODISCARD
    unsigned receiveSpinningTimeout() const ONIXS_B3_BOE_NOTHROW {
        return receiveSpinningTimeout_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& receiveSpinningTimeout(unsigned usecTimeout);

    ONIXS_B3_BOE_NODISCARD
    unsigned sendSpinningTimeout() const ONIXS_B3_BOE_NOTHROW {
        return sendSpinningTimeout_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& sendSpinningTimeout(unsigned usecTimeout);

    ONIXS_B3_BOE_NODISCARD
    unsigned messageGrouping() const ONIXS_B3_BOE_NOTHROW{
        return messageGrouping_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& messageGrouping(unsigned value);

    SessionSettings& resetToDefaults();

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& addLicenseStore(const std::string& value);

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& licenseStore(const std::string & value);

    typedef std::vector<std::string> LicenseStores;

    ONIXS_B3_BOE_NODISCARD
    const LicenseStores& licenseStores() const ONIXS_B3_BOE_NOTHROW {
        return licenseStores_;
    }

    ONIXS_B3_BOE_NODISCARD
    unsigned licenseAlertingDaysBeforeExpiration() const ONIXS_B3_BOE_NOTHROW {
        return licenseAlertingDaysBeforeExpiration_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& licenseAlertingDaysBeforeExpiration(unsigned days) {
        licenseAlertingDaysBeforeExpiration_ = days;
        return *this;
    }

    ONIXS_B3_BOE_EXPORTED ONIXS_B3_BOE_NODISCARD
    const std::string & localNetworkInterface() const ONIXS_B3_BOE_NOTHROW {
        return localNetworkInterface_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& localNetworkInterface(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    const std::string & logFileName() const ONIXS_B3_BOE_NOTHROW {
        return logFileName_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& logFileName(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    const std::string & storageDirectory() const ONIXS_B3_BOE_NOTHROW {
        return storageDirectory_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& storageDirectory(const std::string & value);

    ONIXS_B3_BOE_NODISCARD
    bool localTimeUsage() const ONIXS_B3_BOE_NOTHROW {
        return localTimeUsage_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& localTimeUsage(bool);

    ONIXS_B3_BOE_NODISCARD
    Messaging::UInt64 fileBasedStorageSegmentSize() const ONIXS_B3_BOE_NOTHROW {
        return fileBasedStorageSegmentSize_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& fileBasedStorageSegmentSize(Messaging::UInt64 value);

    ONIXS_B3_BOE_NODISCARD
    unsigned asyncFileBasedStorageQueueMaxSize() const ONIXS_B3_BOE_NOTHROW {
        return asyncFileBasedStorageQueueMaxSize_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& asyncFileBasedStorageQueueMaxSize(unsigned value);

    ONIXS_B3_BOE_NODISCARD
    const CpuIndexes & asyncFileBasedStorageThreadAffinity() const ONIXS_B3_BOE_NOTHROW {
        return asyncFileBasedStorageThreadAffinity_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& asyncFileBasedStorageThreadAffinity(const CpuIndexes & cpuIndexes);

    ONIXS_B3_BOE_NODISCARD
    bool ignoreFileBasedStorageIntegrityErrors() const ONIXS_B3_BOE_NOTHROW {
        return ignoreFileBasedStorageIntegrityErrors_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& ignoreFileBasedStorageIntegrityErrors(bool);

    ONIXS_B3_BOE_NODISCARD
    bool logBeforeSending() const ONIXS_B3_BOE_NOTHROW {
        return logBeforeSending_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& logBeforeSending(bool before);

    ONIXS_B3_BOE_NODISCARD
    unsigned reconnectAttempts() const ONIXS_B3_BOE_NOTHROW {
        return reconnectAttempts_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& reconnectAttempts(unsigned reconnectAttempts);

    ONIXS_B3_BOE_NODISCARD
    unsigned reconnectInterval() const ONIXS_B3_BOE_NOTHROW {
        return reconnectInterval_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& reconnectInterval(unsigned value);

    static const int UseOsDefaultSocketBufferSize = -1;

    ONIXS_B3_BOE_NODISCARD
    int socketReceiveBufferSize() const ONIXS_B3_BOE_NOTHROW {
        return socketReceiveBufferSize_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& socketReceiveBufferSize(int bufferSize);

    ONIXS_B3_BOE_NODISCARD
    unsigned reasonableTransmissionTime() const ONIXS_B3_BOE_NOTHROW {
        return reasonableTransmissionTime_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& reasonableTransmissionTime(unsigned percentage);

    ONIXS_B3_BOE_NODISCARD
    int socketSendBufferSize() const ONIXS_B3_BOE_NOTHROW {
        return socketSendBufferSize_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& socketSendBufferSize(int bufferSize);

    ONIXS_B3_BOE_NODISCARD
    const CpuIndexes & threadPoolAffinity() const ONIXS_B3_BOE_NOTHROW {
        return threadPoolAffinity_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& threadPoolAffinity(const CpuIndexes & cpuIndexes);

    ONIXS_B3_BOE_NODISCARD
    int threadPoolPriority() const ONIXS_B3_BOE_NOTHROW {
        return threadPoolPriority_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& threadPoolPriority(int priority);

    ONIXS_B3_BOE_NODISCARD
    int threadPoolPolicy() const ONIXS_B3_BOE_NOTHROW {
        return threadPoolPolicy_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& threadPoolPolicy(int policy);

    ONIXS_B3_BOE_NODISCARD
    bool tcpNoDelayOption() const ONIXS_B3_BOE_NOTHROW {
        return tcpNoDelayOption_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& tcpNoDelayOption(bool value);

    ONIXS_B3_BOE_NODISCARD
    unsigned threadPoolSize() const ONIXS_B3_BOE_NOTHROW {
        return threadPoolSize_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& threadPoolSize(unsigned numberOfThreads);

    ONIXS_B3_BOE_EXPORTED ONIXS_B3_BOE_NODISCARD
    unsigned keepAliveInterval() const ONIXS_B3_BOE_NOTHROW {
        return keepAliveInterval_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& keepAliveInterval(unsigned milliseconds);

    ONIXS_B3_BOE_EXPORTED ONIXS_B3_BOE_NODISCARD
        unsigned codTimeoutWindow() const ONIXS_B3_BOE_NOTHROW {
        return codTimeoutWindow_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& codTimeoutWindow(unsigned milliseconds);

    ONIXS_B3_BOE_NODISCARD
    bool reportNewMessagesWhileWaitingForMissedMessages() const ONIXS_B3_BOE_NOTHROW {
        return reportNewMessagesWhileWaitingForMissedMessages_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& reportNewMessagesWhileWaitingForMissedMessages(bool report);

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& localPortRange(PortRange range);

    ONIXS_B3_BOE_NODISCARD
    PortRange localPortRange() const ONIXS_B3_BOE_NOTHROW {
        return localPortRange_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& messagingSchemaVersion(Messaging::SchemaVersion schema);

    ONIXS_B3_BOE_NODISCARD
    Messaging::SchemaVersion messagingSchemaVersion() const ONIXS_B3_BOE_NOTHROW {
        return messagingSchemaVersion_;
    }

    ONIXS_B3_BOE_NODISCARD
    bool useSpinLock() const ONIXS_B3_BOE_NOTHROW {
        return useSpinLock_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& useSpinLock(bool value);

    ONIXS_B3_BOE_NODISCARD
    bool enableRxTimestamp() const ONIXS_B3_BOE_NOTHROW {
        return enableRxTimestamp_;
    }

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& enableRxTimestamp(bool value);

    ONIXS_B3_BOE_EXPORTED
    SessionSettings& load(const std::string& configFile);

    ONIXS_B3_BOE_EXPORTED ONIXS_B3_BOE_NODISCARD
    std::string toString() const;

    struct ONIXS_B3_BOE_EXPORTED Default {
        static const Messaging::CancelOnDisconnectType::Enum CancelOnDisconnectType = Messaging::CancelOnDisconnectType::DoNotCancelOnDisconnectOrTerminate;
        static const ThreadingModel::Enum ThreadingModelValue = ThreadingModel::Dedicated;
        static const bool CreateLogFile = true;
        static const int KeepAliveInterval = 30000;
        static const int CodTimeoutWindow = 30000;
        static const bool LogBeforeSending = true;
        static const int SocketSendBufferSize = UseOsDefaultSocketBufferSize;
        static const int SocketReceiveBufferSize = UseOsDefaultSocketBufferSize;
        static const bool TcpNoDelayOption = true;
        static const int ReceiveSpinningTimeout = 0;
        static const int SendSpinningTimeout = 0;
        static const char LicenseStore[] ;
        static const unsigned LicenseAlertingDaysBeforeExpiration = 0;
        static const char LogDir[];
        static const char LogFileName[];
        static const bool LocalTimeUsage = false;
        static const unsigned MessageGrouping = 0;
        static const int ReasonableTransmissionTime = 20;
        static const int ReconnectAttempts = 3;
        static const int ReconnectInterval = 180;
        static const unsigned long long FileBasedStorageSegmentSize = 0;
        static const bool IgnoreFileBasedStorageIntegrityErrors = false;
        static const int ThreadPoolSize = 0;
        static const bool ReportNewMessagesWhileWaitingForMissedMessages = false;
        static const unsigned AsyncFileBasedStorageQueueMaxSize = UINT_MAX;
        static const bool UseSpinLock = false;
        static const bool EnableRxTimestamp = false;
    };

    struct ONIXS_B3_BOE_EXPORTED Key {
        static const char * SessionId;                                      
        static const char * EnteringFirm;                                   
        static const char * AccessKey;                                      
        static const char * CancelOnDisconnectType;                         
        static const char * TradingSystemName;                              
        static const char * TradingSystemVersion;                           
 
        static const char * AsyncFileBasedStorageQueueMaxSize;              
        static const char * AsyncFileBasedStorageThreadAffinity;            
        static const char * ThreadingModel;                                 
        static const char * TcpNoDelayOption;                               
        static const char * MessageGrouping;                                
        static const char * FileBasedStorageSegmentSize;                    
        static const char * IgnoreFileBasedStorageIntegrityErrors;          
        static const char * KeepAliveInterval;                              
        static const char * CodTimeoutWindow;                               
        static const char * LicenseFile;                                    
        static const char * LicenseStore;                                   
        static const char * LicenseAlertingDaysBeforeExpiration;            
        static const char * LocalNetworkInterface;                          
        static const char * LogFileName;                                    
        static const char * LocalTimeUsage;                                 
        static const char * LogBeforeSending;                               
        static const char * ReasonableTransmissionTime;                     
        static const char * ReceiveSpinningTimeout;                         
        static const char * ReconnectAttempts;                              
        static const char * ReconnectInterval;                              
        static const char * SendSpinningTimeout;                            
        static const char * ThreadPoolAffinity;                             
        static const char * ThreadPoolSize;                                 
        static const char * ThreadPoolPriority;                             
        static const char * ThreadPoolPolicy;                               
        static const char * SocketReceiveBufferSize;                        
        static const char * SocketSendBufferSize;                           
        static const char * StorageDirectory;                               
        static const char * ReportNewMessagesWhileWaitingForMissedMessages; 
        static const char * MessagingSchemaVersion;                         
        static const char * LocalPortRange;                                 
        static const char * UseSpinLock;                                    
        static const char * EnableRxTimestamp;                              
    };
 
private:
    void processLicenseStores(const std::string& licenseStore);
 
    std::string accessKey_;
 
    unsigned asyncFileBasedStorageQueueMaxSize_;
 
    CpuIndexes asyncFileBasedStorageThreadAffinity_;
 
    bool createEngineLogFile_;
 
    Messaging::UInt64 fileBasedStorageSegmentSize_;
 
    Messaging::UInt32 enteringFirm_;
 
    Messaging::CancelOnDisconnectType::Enum cancelOnDisconnectType_;
 
    bool ignoreFileBasedStorageIntegrityErrors_;
 
    unsigned keepAliveInterval_;
 
    unsigned codTimeoutWindow_;
 
    unsigned licenseAlertingDaysBeforeExpiration_;
 
    std::string licenseFilePath_;
 
    LicenseStores licenseStores_;
 
    std::string localNetworkInterface_;
 
    bool localTimeUsage_;
 
    bool logBeforeSending_;
 
    std::string logFileName_;
 
    unsigned messageGrouping_;
 
    unsigned reasonableTransmissionTime_;
 
    int receiveSpinningTimeout_;
 
    unsigned reconnectAttempts_;
 
    unsigned reconnectInterval_;
 
    bool reportNewMessagesWhileWaitingForMissedMessages_;
 
    int sendSpinningTimeout_;
 
    Messaging::SessionID sessionId_;
 
    int socketReceiveBufferSize_;
 
    int socketSendBufferSize_;
 
    std::string storageDirectory_;
 
    bool tcpNoDelayOption_;
 
    ThreadingModel::Enum threadingModel_;
 
    CpuIndexes threadPoolAffinity_;
 
    int threadPoolPolicy_;
 
    int threadPoolPriority_;
 
    unsigned threadPoolSize_;
 
    std::string tradingSystemName_;
 
    std::string tradingSystemVersion_;
 
    std::pair<Port, Port> localPortRange_;
 
    Messaging::SchemaVersion messagingSchemaVersion_;
 
    bool useSpinLock_;
 
    bool enableRxTimestamp_;
};
 
}
}
}