server.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <unordered_map>
#include <string>
#include <mutex>
#include <csignal>
 
namespace fix40 {
 
// 前置声明
class Reactor;
class ThreadPool;
class TimingWheel;
class Connection;
class Application;
 
class FixServer {
public:
    FixServer(int port, int num_threads, Application* app = nullptr);
 
    ~FixServer();
 
    void start();
 
private:
    void on_new_connection(int fd);
 
    void on_connection_close(int fd);
 
    static void signal_handler(int signum);
 
    const int port_;    
    int listen_fd_;     
 
    std::unique_ptr<Reactor> reactor_;         
    std::unique_ptr<ThreadPool> worker_pool_;  
    std::unique_ptr<TimingWheel> timing_wheel_; 
 
    std::unordered_map<int, std::shared_ptr<Connection>> connections_;
    std::mutex connections_mutex_; 
 
    static volatile std::sig_atomic_t last_signal_; 
    static volatile std::sig_atomic_t signal_write_fd_; 
 
    int signal_pipe_[2] = {-1, -1}; 
 
    Application* application_ = nullptr;  
};
 
} // namespace fix40