1
This commit is contained in:
parent
4c31f2a711
commit
059071f824
@ -110,7 +110,15 @@ void MasterMgr::RequestTargetServer(f8::MsgHdr& hdr,
|
|||||||
pending_socket_hash_[hdr.socket_handle] = curr_context_id_;
|
pending_socket_hash_[hdr.socket_handle] = curr_context_id_;
|
||||||
assert(pending_request_hash_.find(curr_context_id_) == pending_request_hash_.end());
|
assert(pending_request_hash_.find(curr_context_id_) == pending_request_hash_.end());
|
||||||
pending_request_hash_[curr_context_id_] = new_hdr;
|
pending_request_hash_[curr_context_id_] = new_hdr;
|
||||||
#if 0
|
#if 1
|
||||||
|
f8::Timer::Instance()->SetTimeout
|
||||||
|
(1000 * 10,
|
||||||
|
[] (int event, const a8::Args* args)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
);
|
||||||
|
#else
|
||||||
auto timer_func =
|
auto timer_func =
|
||||||
[] (const a8::XParams& param)
|
[] (const a8::XParams& param)
|
||||||
{
|
{
|
||||||
|
Loading…
x
Reference in New Issue
Block a user