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

Change dgram client to print performance stats.

Browse Source
This commit is contained in:
chris 2003-11-11 06:15:49 +00:00
parent ccf6304d8f
commit 9776718099
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
asio/src/tests/dgram_echo_client_test.cpp
View File

@ -10,9 +10,13 @@ class dgram_handler
public:
dgram_handler(demuxer& d)
: demuxer_(d),
timer_(d, timer::from_now, timeout),
socket_(d, inet_address_v4(32123)),
count_(0)
count_(0),
stop_(false)
{
timer_.async_wait(boost::bind(&dgram_handler::handle_timeout, this));
inet_address_v4 destination(32124, "localhost");
char msg[] = "Hello, World!\n";
memcpy(data_, msg, sizeof(msg));
@ -20,9 +24,21 @@ public:
boost::bind(&dgram_handler::handle_sendto, this, _1, _2));
}
~dgram_handler()
{
std::cout << count_ << " round trips\n";
std::cout << (count_ / timeout) << " round trips per second\n";
}
void handle_timeout()
{
stop_ = true;
socket_.close();
}
void handle_sendto(const socket_error& error, size_t length)
{
if (!error)
if (!error && !stop_)
{
socket_.async_recvfrom(data_, max_length, sender_address_,
boost::bind(&dgram_handler::handle_recvfrom, this, _1, _2));
@ -31,8 +47,9 @@ public:
void handle_recvfrom(const socket_error& error, size_t length)
{
if (!error && length > 0 && ++count_ < 10000)
if (!error && length > 0 && !stop_)
{
++count_;
socket_.async_sendto(data_, length, sender_address_,
boost::bind(&dgram_handler::handle_sendto, this, _1, _2));
}
@ -40,11 +57,14 @@ public:
private:
demuxer& demuxer_;
enum { timeout = 10 };
timer timer_;
dgram_socket socket_;
inet_address_v4 sender_address_;
enum { max_length = 512 };
char data_[max_length];
int count_;
bool stop_;
};
int main()