AuroraMiddleware/asio
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix memory leaks in performance test server code.

Browse Source
This commit is contained in:
chris 2004-04-06 07:18:22 +00:00
parent 03b74e9aad
commit 207c789f6a
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
asio/src/tests/performance/server.cpp
View File

@ -55,6 +55,8 @@ public:
void handle_recv(const socket_error& error, size_t length) void handle_recv(const socket_error& error, size_t length)
{ {
--op_count_;
if (!error && length > 0) if (!error && length > 0)
{ {
++unsent_count_; ++unsent_count_;
@ -68,14 +70,15 @@ public:
boost::bind(&session::handle_recv, this, _1, _2))); boost::bind(&session::handle_recv, this, _1, _2)));
} }
} }
else if (--op_count_ == 0)
{ if (op_count_ == 0)
demuxer_.post(boost::bind(&session::destroy, this)); demuxer_.post(boost::bind(&session::destroy, this));
}
} }
void handle_send(const socket_error& error, size_t length, size_t last_length) void handle_send(const socket_error& error, size_t length, size_t last_length)
{ {
--op_count_;
if (!error && last_length > 0) if (!error && last_length > 0)
{ {
--unsent_count_; --unsent_count_;
@ -89,10 +92,9 @@ public:
boost::bind(&session::handle_recv, this, _1, _2))); boost::bind(&session::handle_recv, this, _1, _2)));
} }
} }
else if (--op_count_ == 0)
{ if (op_count_ == 0)
demuxer_.post(boost::bind(&session::destroy, this)); demuxer_.post(boost::bind(&session::destroy, this));
}
} }
static void destroy(session* s) static void destroy(session* s)
@ -137,7 +139,6 @@ public:
new_session = new session(demuxer_, block_size_); new_session = new session(demuxer_, block_size_);
acceptor_.async_accept(new_session->socket(), acceptor_.async_accept(new_session->socket(),
boost::bind(&server::handle_accept, this, new_session, _1)); boost::bind(&server::handle_accept, this, new_session, _1));
} }
else else
{ {