AnyEvent/eg/ae2.pl

# $Id: ae2.pl,v 1.1 2009-06-23 12:21:34 root Exp $
# An echo client-server benchmark.

use warnings;
use strict;

use Time::HiRes qw(time);
use AnyEvent;
use AnyEvent::Impl::Perl;
use AnyEvent::Socket;

my $CYCLES = 500;
my $port   = 11212;

tcp_server undef, $port, sub {
   my ($fh) = @_
      or die "tcp_server: $!";

   my $hdl = new AnyEvent::Handle fh => $fh;

   $hdl->push_read (line => sub {
      $hdl->push_write ("$_[1]\n");
      undef $hdl;
   });
};

my $t = time;

for my $connections (1..$CYCLES) {
   my $cv = AE::cv;

   tcp_connect "127.0.0.1", $port, sub {
      my ($fh) = @_
         or die "tcp_connect: $!";

      my $hdl = new AnyEvent::Handle fh => $fh;

      $hdl->push_write ("can write $connections\n");
      $hdl->push_read (line => sub {
         undef $hdl;
         $cv->send;
      });
   };

   $cv->recv;
};

$t = time - $t;
printf "%.3f sec\n", $t;
exit;
Revision:	1.2
Committed:	Thu Aug 6 14:00:36 2009 UTC (14 years, 9 months ago) by root
Content type:	text/plain
Branch:	MAIN
CVS Tags:	rel-5_28, rel-5_29, rel-7_0, rel-5_21, rel-6_0, rel-6_1, rel-5_24, rel-5_26, rel-5_27, rel-5_12, rel-5_1, rel-5_0, rel-5_3, rel-5_2, rel-6_14, rel-5_22, rel-6_11, rel-6_12, rel-6_13, rel-5_261, rel-7_04, rel-7_05, rel-7_07, rel-7_01, rel-7_02, rel-7_03, rel-5_201, rel-5_202, rel-7_08, rel-7_09, rel-5_11, rel-5_23, rel-5_31, rel-5_01, rel-6_02, rel-6_01, rel-5_111, rel-5_112, rel-5_271, rel-7_16, rel-7_15, rel-7_14, rel-7_13, rel-7_12, rel-7_11, rel-5_251, HEAD
Changes since 1.1:	+2 -2 lines
Log Message:	* empty log message *
#	Content
1	# $Id: ae2.pl,v 1.1 2009-06-23 12:21:34 root Exp $
2	# An echo client-server benchmark.
3
4	use warnings;
5	use strict;
6
7	use Time::HiRes qw(time);
8	use AnyEvent;
9	use AnyEvent::Impl::Perl;
10	use AnyEvent::Socket;
11
12	my $CYCLES = 500;
13	my $port = 11212;
14
15	tcp_server undef, $port, sub {
16	my ($fh) = @_
17	or die "tcp_server: $!";
18
19	my $hdl = new AnyEvent::Handle fh => $fh;
20
21	$hdl->push_read (line => sub {
22	$hdl->push_write ("$_[1]\n");
23	undef $hdl;
24	});
25	};
26
27	my $t = time;
28
29	for my $connections (1..$CYCLES) {
30	my $cv = AE::cv;
31
32	tcp_connect "127.0.0.1", $port, sub {
33	my ($fh) = @_
34	or die "tcp_connect: $!";
35
36	my $hdl = new AnyEvent::Handle fh => $fh;
37
38	$hdl->push_write ("can write $connections\n");
39	$hdl->push_read (line => sub {
40	undef $hdl;
41	$cv->send;
42	});
43	};
44
45	$cv->recv;
46	};
47
48	$t = time - $t;
49	printf "%.3f sec\n", $t;
50	exit;