AnyEvent/eg/ae2.pl

# $Id: tcp-poe-raw.pl,v 1.1 2009/01/17 11:29:06 dk 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 = AnyEvent->condvar;

   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.1
Committed:	Tue Jun 23 12:21:34 2009 UTC (17 years, 3 months ago) by root
Content type:	text/plain
Branch:	MAIN
CVS Tags:	rel-4_45, rel-4_82, rel-4_42, rel-4_412, rel-4_83, rel-4_86, rel-4_81, rel-4_881, rel-4_88, rel-0_85, rel-4_91, rel-4_8, rel-4_9
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.1	# $Id: tcp-poe-raw.pl,v 1.1 2009/01/17 11:29:06 dk 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 = AnyEvent->condvar;
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;