HandlerImpl.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 <queue>

#include <logging/LogFacility.h>
#include <licensing/LicenseChecker.h>

#include <OnixS/HandlerCore/HandlerLogger.h>

#include <OnixS/ItchCore/SoupBinTCP/ReconnectableSession.h>

#include <OnixS/SgxTitan/Trading/OUCH/HandlerStateListener.h>
#include <OnixS/SgxTitan/Trading/OUCH/Handler.h>
#include <OnixS/SgxTitan/Trading/OUCH/HandlerSettings.h>

#include "Utils.h"


namespace OnixS   {
namespace SgxTitan {
namespace Trading {
namespace Ouch {

class OutgoingMessage;

namespace Implementation {

class ListenerHolder;

class AuditTrailDumper;
    

class HandlerImpl :
        public Licensing::LicenseChecker,
        public OnixS::Logging::LogFacility,
        private OnixS::ItchCore::SoupBinTCP::ReconnectableSessionListener
{
    typedef Logging::LogFacility base;

public:
    explicit HandlerImpl (const HandlerSettings & settings);
    virtual ~HandlerImpl ();

    HandlerState::Enum getState ();

    template <typename TMsg>
    void log (const TMsg & msg) { logger_->log (msg); }

    template <typename TMsg>
    void forceLog (const TMsg & msg) { logger_->getLogger().forceLog (msg); }

    void commonLog (int logLevel, const char * msg, size_t length);

    ListenerHolder* listenerHolder () { return listenerHolder_.get(); }

    void connect (const LogonSettings& logonSettings,
          const std::string& hostName,
          UInt16 port,
          const std::string& localNetworkInterface);

    void disconnect ();
    void disconnectAsync ();

    void send (const OutgoingMessage& message, bool warmupMode = false);


    UInt64 nextExpectedSequenceNumber() const;
    std::string sessionId() const;

private:
    void runAuditTrail();
    void checkState(HandlerState::Enum expectedState) const;

    void onError(OnixS::ItchCore::SoupBinTCP::ReconnectableSession&, const std::string&) final;
    void onWarning(OnixS::ItchCore::SoupBinTCP::ReconnectableSession&, const std::string&) final;
    void onStateChange(OnixS::ItchCore::SoupBinTCP::ReconnectableSession&,
                               OnixS::ItchCore::SoupBinTCP::ReconnectableSessionState::Enum oldState,
                               OnixS::ItchCore::SoupBinTCP::ReconnectableSessionState::Enum newState) final;
    void onData(OnixS::ItchCore::SoupBinTCP::ReconnectableSession&, const void* data, UInt16 size) final;
    
    void processData(const void* dataPtr, UInt16 messageLength);

    std::string os();

private:
    HandlerSettings const settings_;

    boost::scoped_ptr<OnixS::HandlerCore::Common::HandlerLogger> const logger_;
    boost::scoped_ptr<ListenerHolder>  const listenerHolder_;
    boost::scoped_ptr<AuditTrailDumper> auditTrailDumper_;
    
    mutable HandlerCore::MarketData::FE::AtomicState<HandlerState::Enum> externalState_;
    boost::scoped_ptr<OnixS::ItchCore::SoupBinTCP::ReconnectableSession> session_;


    typedef OnixS::Concurrency::RecursiveMutex Mutex;
    typedef OnixS::Concurrency::Guard<OnixS::Concurrency::Mutex> Guard;

    mutable Mutex sessionLock_;

};

} // namespace Implementation


struct Handler::Impl : public Implementation::HandlerImpl
{
typedef Implementation::HandlerImpl base;

public:
    explicit Impl(const HandlerSettings & settings)
    : base(settings)
    {}
};

ONIXS_SGXTITAN_OUCH_NAMESPACE_END