Method InitRoutines

phxsqlproxy/worker_thread.h:40–52

    template<class T>
    void InitRoutines(GroupStatusCache * group_status_cache) {
        io_routine_mgr_ = new IORoutineMgr(config_, worker_config_);

        connection_dispatcher_ = new ConnectionDispatcher(io_routine_mgr_);

        int routine_count = worker_config_->io_routine_count_;
        for (int i = 0; i < routine_count; ++i) {
            T * io_routine = new T(io_routine_mgr_, group_status_cache);
            io_routines_.push_back(io_routine);
        }

        monitor_routine_ = new MonitorRoutine(config_, io_routine_mgr_);
    }

    void run();