|
@@ -36,14 +36,14 @@ Error_manager Notify_excutor::notify_request(message::Notify_request_msg& reques
|
|
|
message.reset(base_msg,request.SerializeAsString());
|
|
|
|
|
|
//发送请求
|
|
|
- m_response_table[request.command_key()]=message::Notify_response_msg();
|
|
|
code= Message_communicator::get_instance_pointer()->send_msg(&message);
|
|
|
if(code!=SUCCESS)
|
|
|
{
|
|
|
m_response_table.erase(request.command_key());
|
|
|
return code;
|
|
|
}
|
|
|
-
|
|
|
+ return SUCCESS;
|
|
|
+ m_response_table[request.command_key()]=message::Notify_response_msg();
|
|
|
//循环查询请求是否被处理
|
|
|
auto start_time=std::chrono::system_clock::now();
|
|
|
double time=0;
|