[ViewVC] Contents of: cvs/AnyEvent-MP/eg/chat_server

#!/opt/bin/perl

use common::sense;
use AnyEvent::MP;
use AnyEvent::MP::Global;

initialise_node;

AnyEvent::MP::Global::register $NODE, "eg_chat_server";

my %clients;

sub msg {
   print "relaying: $_[0]\n";
   snd $_, $_[0]
      for values %clients;
}

sub client_connect {
   my ($client, $name) = @_;

   mon $client;
   mon $client, sub {
      delete $clients{$client};
      msg "$name (quits, @_)";
   };

   $clients{$client} = $client;

   msg "$name (joins)";

   rcv $SELF, sub { msg "$name: $_[0]" };
}

warn "server ready.\n";

AE::cv->recv;
Revision:	1.6
Committed:	Mon Aug 17 03:50:28 2009 UTC (14 years, 9 months ago) by root
Branch:	MAIN
Changes since 1.5:	+3 -0 lines
Log Message:	* empty log message *
#	Content
1	#!/opt/bin/perl
2
3	use common::sense;
4	use AnyEvent::MP;
5	use AnyEvent::MP::Global;
6
7	initialise_node;
8
9	AnyEvent::MP::Global::register $NODE, "eg_chat_server";
10
11	my %clients;
12
13	sub msg {
14	print "relaying: $_[0]\n";
15	snd $_, $_[0]
16	for values %clients;
17	}
18
19	sub client_connect {
20	my ($client, $name) = @_;
21
22	mon $client;
23	mon $client, sub {
24	delete $clients{$client};
25	msg "$name (quits, @_)";
26	};
27
28	$clients{$client} = $client;
29
30	msg "$name (joins)";
31
32	rcv $SELF, sub { msg "$name: $_[0]" };
33	}
34
35	warn "server ready.\n";
36
37	AE::cv->recv;