connection.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <string>
#include <string_view>
#include <functional>
#include <atomic>
#include "fix/fix_frame_decoder.hpp"
 
namespace fix40 {
 
// 前置声明
class Session;
class Reactor;
class ThreadPool;
 
class Connection : public std::enable_shared_from_this<Connection> {
public:
    static constexpr size_t kMaxReadBufferSize = 1 * 1024 * 1024;
 
    Connection(int fd, Reactor* reactor, std::shared_ptr<Session> session,
               ThreadPool* thread_pool, size_t thread_index);
 
    ~Connection();
 
    void handle_read();
 
    void handle_write();
    
    void send(std::string_view data);
 
    void dispatch(std::function<void()> task);
 
    void shutdown();
 
    void close_fd();
 
    int fd() const { return fd_; }
 
    size_t thread_index() const { return thread_index_; }
 
    std::shared_ptr<Session> session() const { return session_; }
 
private:
    void do_send(const std::string& data);
 
    const int fd_;                        
    Reactor* reactor_;                    
    std::shared_ptr<Session> session_;    
    ThreadPool* thread_pool_;             
    const size_t thread_index_;           
    std::atomic<bool> is_closed_{false};  
 
    FixFrameDecoder frame_decoder_;       
    std::string write_buffer_;            
    // 注意：移除了 write_mutex_，因为同一连接的所有操作都在同一线程
};
 
} // namespace fix40