HandlerSettings.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 <set>
#include <vector>

#include <OnixS/SgxTitan/Trading/OUCH/ABI.h>
#include <OnixS/SgxTitan/Trading/OUCH/LogSettings.h>
#include <OnixS/SgxTitan/Trading/OUCH/Defines.h>
#include <OnixS/SgxTitan/Trading/OUCH/Enumerations.h>


ONIXS_SGXTITAN_OUCH_NAMESPACE_BEGIN

/// Connection retries settings.
///
struct ConnectionRetries
{
    /// Default constructor.
    ///
    ConnectionRetries () : number (0), intervalSec (0) {}

    /// Constructor.
    ///
    ConnectionRetries (
            unsigned int inNumber, unsigned int inIntervalSec) : number (inNumber), intervalSec (inIntervalSec) {}

    /// Number of attempts to restore the telecommunication link.
    /// -1 - unlimited
    /// 0 - never (default)
    /// >0 - the number of attempts
    unsigned int number;

    /// The time interval between attempts to restore the telecommunication link (in seconds).
    ///
    /// @note The default value is 0 (zero).
    unsigned int intervalSec;
};

/// Serializes object into string.
ONIXS_SGXTITAN_OUCH_API void toStr(std::string&, const ConnectionRetries&);

/// Serializes object into string.
inline std::string toStr(const ConnectionRetries& value)
{
    std::string str;

    toStr(str, value);

    return str;
}

/// Logical processors that a thread is allowed to run on (first logical CPU has index 0).
///
typedef std::set<size_t> CpuIndexes;

/// Handler settings.
///
struct HandlerSettings
{
    /// Initialize default instance.
    ///
    HandlerSettings()
        : logDirectory("logs")
        , logFileNamePrefix("SgxTitanOuchTradingHandler")
        , logSettings(LogSettings::Default)
        , logLevel(LogLevel::Info)
        , receiveTimeoutMs(1000)
        , sendTimeoutMs(1000)
        , auditTrailFileMaxSize(1024 * 1024 * 1024)
    {}

    /// Path to the license directory.
    ///
    /// @note The default value is empty string (means current directory).
    std::string licenseDirectory;

    /// Log files are stored in this directory.
    ///
    /// @note The default value is "logs".
    std::string logDirectory;

    /// Template of log file name without extension.
    ///
    /// @note The default value is "SgxTitanOuchTradingHandler".
    std::string logFileNamePrefix;

    /// Combine LogSettings enum values to configure the logger.
    ///
    /// @note The default value is LogSettings::Default.
    LogSettings::Enum logSettings;

    /// Log verbosity.
    ///
    /// @note The default value is LogLevel::Info.
    LogLevel::Enum logLevel;

    /// Receive timeout in milliseconds.
    ///
    /// @note The default value is 1 seconds (1000 ms).
    unsigned int receiveTimeoutMs;

    /// Send timeout in milliseconds.
    ///
    /// @note The default value is 1 seconds (1000 ms).
    unsigned int sendTimeoutMs;

    /// CPU affinity of the receiving thread.
    ///
    CpuIndexes receivingThreadAffinity;

    /// CPU affinity of the sending thread.
    ///
    CpuIndexes sendingThreadAffinity;

    /// Connection retries configuration settings.
    ///
    /// @see ConnectionRetries.
    ConnectionRetries connectionRetries;

    /// Audit Trail files are stored in this directory.
    ///
    /// @note The default value is empty string.
    std::string auditTrailDirectory;

    /// Template of Audit Trail file name without extension.
    ///
    /// Creates Audit Trail file that contains all messages that Handler sent or received (in the chronological order).
    ///
    /// @note The default value is empty string (means no audit trail files required).
    std::string auditTrailFile;

    /// CPU affinity of the audit trail thread.
    ///
    CpuIndexes auditTrailThreadAffinity;

    /// Max size for audit trail file in megabytes, another file will be created if the size is exceeded.
    ///
    /// @note The default value is 1024 Mb.
    size_t auditTrailFileMaxSize;
};

/// Serializes object into string.
ONIXS_SGXTITAN_OUCH_API void toStr(std::string&, const HandlerSettings&);

/// Serializes object into string.
inline std::string toStr(const HandlerSettings& value)
{
    std::string str;

    toStr(str, value);

    return str;
}


///
struct LogonSettings
{
    /// Requested Session
    std::string session;

    /// Username.
    std::string userName;

    /// Password.
    std::string password;

    /// Specifies the next sequence number the client wants to receive upon
    /// connection, or 0 to start receiving the most recently generated message
    UInt64 sequenceNumber;

    /// Consturctor
    LogonSettings()
        : sequenceNumber(0)
    {}
};

/// Serializes object into string.
ONIXS_SGXTITAN_OUCH_API void toStr(std::string&, const LogonSettings&);

/// Serializes object into string.
inline std::string toStr(const LogonSettings& value)
{
    std::string str;

    toStr(str, value);

    return str;
}


ONIXS_SGXTITAN_OUCH_NAMESPACE_END