diff --git a/PSS_ASIO/Message/ModuleLogic.cpp b/PSS_ASIO/Message/ModuleLogic.cpp index a15ef1d..103f867 100644 --- a/PSS_ASIO/Message/ModuleLogic.cpp +++ b/PSS_ASIO/Message/ModuleLogic.cpp @@ -411,6 +411,8 @@ int CWorkThreadLogic::assignation_thread_module_logic(const uint32 connect_id, c //测试连接自检 uint32 check_timeout = 120; run_check_task(check_timeout); + + send_io_buffer(); #endif return 0; } @@ -499,7 +501,7 @@ void CWorkThreadLogic::do_work_thread_module_logic(shared_ptr session, } } -void CWorkThreadLogic::send_io_buffer(uint32 connect_id, std::shared_ptr session, std::shared_ptr format_packet) +void CWorkThreadLogic::send_io_buffer(uint32 connect_id, std::shared_ptr session, std::shared_ptr format_packet) const { if (io_send_time_check_ > 0) { diff --git a/PSS_ASIO/Message/ModuleLogic.h b/PSS_ASIO/Message/ModuleLogic.h index 6a18bd6..4527e41 100644 --- a/PSS_ASIO/Message/ModuleLogic.h +++ b/PSS_ASIO/Message/ModuleLogic.h @@ -162,7 +162,7 @@ class CWorkThreadLogic int do_io_bridge_data(uint32 connect_id, uint32 io_bridge_connect_id_, CSessionBuffer& session_recv_buffer, std::size_t length, shared_ptr session); private: - void send_io_buffer(uint32 connect_id, std::shared_ptr session, std::shared_ptr format_packet); + void send_io_buffer(uint32 connect_id, std::shared_ptr session, std::shared_ptr format_packet) const; void do_work_thread_timeout(uint16 work_thread_id, uint16 last_dispose_command_id, int work_thread_timeout); using hashmappluginworkthread = unordered_map>;