Thu Dec 11 00:44:17 IST 2014

Author: sroycode

src/RpcServer.cc

@@ -109,12 +109,14 @@ void zqrpc::RpcServer::Start(std::size_t noof_threads)
 
 void zqrpc::RpcServer::Close()
 {
+	/** 
 	// delete all methods
 	for (RpcMethodMapT::iterator it = rpc_method_map_.begin(); it != rpc_method_map_.end();) {
 		RpcMethod *rpc_method = it->second;
 		++it;
 		delete rpc_method;
 	}
+	*/
 	// unbind , inprocs cannot be unbound
 	if (started_) {
 		DLOG(INFO) << "server close called, started " << started_ << std::endl;

src/RpcWorker.cc

@@ -113,5 +113,12 @@ void zqrpc::RpcWorker::operator() ()
 	delete response;
 	socket.disconnect(ZQRPC_INPROC_WORKER);
 	socket.close();
+	/**
+	for (RpcMethodMapT::iterator it = rpc_method_map_.begin(); it != rpc_method_map_.end();) {
+		RpcMethod *rpc_method = it->second;
+		++it;
+		delete rpc_method;
+	}
+	*/
 	DLOG(INFO) << boost::this_thread::get_id() << ":end: " << std::endl;
 }