1
This commit is contained in:
parent
fee8a03cec
commit
46e42c7228
@ -6,6 +6,7 @@
|
|||||||
|
|
||||||
#include <f8/timer.h>
|
#include <f8/timer.h>
|
||||||
#include <f8/netmsghandler.h>
|
#include <f8/netmsghandler.h>
|
||||||
|
#include <f8/protoutils.h>
|
||||||
|
|
||||||
#include "mastermgr.h"
|
#include "mastermgr.h"
|
||||||
#include "master.h"
|
#include "master.h"
|
||||||
@ -165,10 +166,8 @@ void MasterMgr::RemoveRequest(int socket_handle)
|
|||||||
auto req = GetRequestBySocket(socket_handle);
|
auto req = GetRequestBySocket(socket_handle);
|
||||||
if (req) {
|
if (req) {
|
||||||
if (req->hdr_copy) {
|
if (req->hdr_copy) {
|
||||||
if (req->hdr_copy->buf) {
|
f8::MsgHdr::Destroy(req->hdr_copy);
|
||||||
free((char*)req->hdr_copy->buf);
|
req->hdr_copy = nullptr;
|
||||||
}
|
|
||||||
free(req->hdr_copy);
|
|
||||||
}
|
}
|
||||||
pending_context_hash_.erase(req->context_id);
|
pending_context_hash_.erase(req->context_id);
|
||||||
pending_socket_hash_.erase(socket_handle);
|
pending_socket_hash_.erase(socket_handle);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user