session_manager.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <mutex>
#include <unordered_map>
#include <functional>
#include "fix/session.hpp"
#include "fix/application.hpp"
 
namespace fix40 {
 
struct SessionIDHash {
    std::size_t operator()(const SessionID& id) const {
        return std::hash<std::string>()(id.senderCompID) ^
               (std::hash<std::string>()(id.targetCompID) << 1);
    }
};
 
class SessionManager {
public:
    SessionManager() = default;
 
    ~SessionManager() = default;
 
    // 禁止拷贝
    SessionManager(const SessionManager&) = delete;
    SessionManager& operator=(const SessionManager&) = delete;
 
    void registerSession(std::shared_ptr<Session> session);
 
    bool unregisterSession(const SessionID& sessionID);
 
    std::shared_ptr<Session> findSession(const SessionID& sessionID) const;
 
    bool sendMessage(const SessionID& sessionID, FixMessage& msg);
 
    size_t getSessionCount() const;
 
    bool hasSession(const SessionID& sessionID) const;
 
    void forEachSession(std::function<void(const SessionID&, std::shared_ptr<Session>)> callback) const;
 
private:
    mutable std::mutex mutex_;  
    std::unordered_map<SessionID, std::shared_ptr<Session>, SessionIDHash> sessions_;
};
 
} // namespace fix40