[ViewVC] Annotation 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 *
#	User	Rev	Content
1	root	1.2	#!/opt/bin/perl
2
3	root	1.4	use common::sense;
4	elmex	1.1	use AnyEvent::MP;
5	root	1.6	use AnyEvent::MP::Global;
6	elmex	1.1
7	root	1.4	initialise_node;
8	elmex	1.3
9	root	1.6	AnyEvent::MP::Global::register $NODE, "eg_chat_server";
10
11	root	1.4	my %clients;
12	root	1.2
13	root	1.4	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	elmex	1.1
28	root	1.4	$clients{$client} = $client;
29	elmex	1.1
30	root	1.4	msg "$name (joins)";
31	elmex	1.3
32	root	1.5	rcv $SELF, sub { msg "$name: $_[0]" };
33	root	1.4	}
34	elmex	1.1
35	root	1.4	warn "server ready.\n";
36	elmex	1.1
37	root	1.4	AE::cv->recv;