POE/Component/LookupClient.pm

## ------------------------------------------------------------------------
##  $Id: WebCache.pm,v 1.3 2003/06/25 23:37:04 joko Exp $
## ------------------------------------------------------------------------
##  $Log: WebCache.pm,v $
## ------------------------------------------------------------------------


package POE::Component::LookupClient;

use strict;
use warnings;

use POE qw( Session Component::IKC::Client );
use Data::Dumper;


sub new {
  my $classname = shift;
  my @args = @_;
  
  my $self = {};
  bless $self, $classname;

  $self->{options} = { @args };

  #my $event_handler = lookupd->new();
  POE::Session->create( 
    object_states => [
      $self => [qw( _start _stop boot_intercom )]
    ]
  );

}

# This is not a POE method. It's a plain OO one.
sub debug {
  my $self = shift;
  my $msg = shift;
  $msg ||= '';
  print STDERR __PACKAGE__ . ": " . $msg, "\n";
}

# Controller's event handlers

sub _start {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("_start");
  
  #$kernel->alias_set("controller");

  #$kernel->post( controller => 'start_daemon' );
  #$kernel->yield( 'boot_storage' );
  $kernel->yield( 'boot_intercom' );
  #$_[HEAP]->{subsession} = POE::Session->create( inline_states => { _start => sub { print "WORKER!", "\n"; } } );
  #$_[HEAP]->{subsession}->yield(

};

sub _stop {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("_stop");
};

sub boot_intercom {

  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("boot_intercom");

  # Client component - encapsulates some session(s) and/or wheel(s)?
  
  my $host = "localhost";
  #create_ikc_client( host => $host, port => 30, name => 'Client', on_connect => $self->{options}->{on_connect} );
  create_ikc_client( 
    host => $host, 
    port => 30, 
    name => 'Client', 
    on_connect => sub { $self->build(); },
    subscribe => [qw( poe://LookupService/ServiceRegistrar/ )],
  );

};

sub build {
  my $self = shift;
  #print "BUILD", "\n";
  # create sessions that depend on the foreign kernel.
  POE::Component::LookupClient::Session->new();
}


package POE::Component::LookupClient::Session;

use strict;
use warnings;

use POE qw( Session );
use Data::Dumper;


sub new {
  my $classname = shift;
  my @args = @_;
  
  my $self = {};
  bless $self, $classname;

  $self->{options} = { @args };

  POE::Session->create( 
    object_states => [
      $self => [qw( _start _stop response register_lease renew_lease )]
    ]
  );

}


# This is not a POE method. It's a plain OO one.
sub debug {
  my $self = shift;
  my $msg = shift;
  $msg ||= '';
  print STDERR __PACKAGE__ . ": " . $msg, "\n";
}

# Controller's event handlers

sub _start {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("_start");

  #$kernel->alias_set('');
  #$kernel->post();
  
  # set up communication channel for asynchronous responses
  $kernel->alias_set('DeviceClient');
  $kernel->post('IKC', 'publish', 'DeviceClient', [qw( response )]);
  
  # try to register on startup
  $kernel->yield('register_lease');
  
};

sub _stop {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("_stop");
};

# Main response dispatcher, this should dispatch to local states programmatically.
sub response {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  #$self->debug("response");
  
  my $payload = $_[ARG0];
  $payload ||= '';
  
  # If registration succeeded, start the renewal cycle.
  if ($payload eq 'REG_OK') {
    $self->debug("Starting lease loop.");
    $kernel->yield( 'renew_lease' );

  } elsif ($payload eq 'LEASE_OK') {
    $self->debug("Received 'LEASE_OK'.");
    #$kernel->yield( 'renew_lease' );

  # 1. otherwise dump anything sent to us for debugging purposes
  # 2. destroy lease in any case on unknown payload
  } else {
    #print Dumper($payload);
    $heap->{'destroy lease'} = 1;
  
  }
  
};

sub register_lease {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  $self->debug("register_lease");
  my $ONE_arg = "Hello World!";
  
  # V1 - without subscription
  #$kernel->post('IKC', 'post', "poe://LookupService/ServiceRegistrar/register_lease", $ONE_arg);
  # V2 - with subscription
  $kernel->post( "poe://LookupService/ServiceRegistrar", "register_lease", $ONE_arg);
}

sub renew_lease {
  my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
  
  if ($heap->{'destroy lease'}) {
    $heap->{'destroy lease'} = 0;
    $self->debug("destroyed lease");
    return;
  }
  
  $self->debug("renew_lease");
  
  my $ONE_arg = '';
  #$kernel->post('IKC', 'post', "poe://LookupService/ServiceRegistrar/renew_lease", $ONE_arg);
  # V1 - without subscription
  $kernel->post('IKC', 'call', "poe://LookupService/ServiceRegistrar/renew_lease", $ONE_arg, 'poe:response');
  # V2 - with subscription
  #my $resp = $kernel->call( "poe://LookupService/ServiceRegistrar", "renew_lease", $ONE_arg);
  #print $resp, "\n";
  
  # and again...
  $kernel->delay('renew_lease', 15);
}

1;
__END__
1	## ------------------------------------------------------------------------
2	## $Id: WebCache.pm,v 1.3 2003/06/25 23:37:04 joko Exp $
3	## ------------------------------------------------------------------------
4	## $Log: WebCache.pm,v $
5	## ------------------------------------------------------------------------
6
7
8	package POE::Component::LookupClient;
9
10	use strict;
11	use warnings;
12
13	use POE qw( Session Component::IKC::Client );
14	use Data::Dumper;
15
16
17	sub new {
18	my $classname = shift;
19	my @args = @_;
20
21	my $self = {};
22	bless $self, $classname;
23
24	$self->{options} = { @args };
25
26	#my $event_handler = lookupd->new();
27	POE::Session->create(
28	object_states => [
29	$self => [qw( _start _stop boot_intercom )]
30	]
31	);
32
33	}
34
35	# This is not a POE method. It's a plain OO one.
36	sub debug {
37	my $self = shift;
38	my $msg = shift;
39	$msg \|\|= '';
40	print STDERR __PACKAGE__ . ": " . $msg, "\n";
41	}
42
43	# Controller's event handlers
44
45	sub _start {
46	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
47	$self->debug("_start");
48
49	#$kernel->alias_set("controller");
50
51	#$kernel->post( controller => 'start_daemon' );
52	#$kernel->yield( 'boot_storage' );
53	$kernel->yield( 'boot_intercom' );
54	#$_[HEAP]->{subsession} = POE::Session->create( inline_states => { _start => sub { print "WORKER!", "\n"; } } );
55	#$_[HEAP]->{subsession}->yield(
56
57	};
58
59	sub _stop {
60	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
61	$self->debug("_stop");
62	};
63
64	sub boot_intercom {
65
66	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
67	$self->debug("boot_intercom");
68
69	# Client component - encapsulates some session(s) and/or wheel(s)?
70
71	my $host = "localhost";
72	#create_ikc_client( host => $host, port => 30, name => 'Client', on_connect => $self->{options}->{on_connect} );
73	create_ikc_client(
74	host => $host,
75	port => 30,
76	name => 'Client',
77	on_connect => sub { $self->build(); },
78	subscribe => [qw( poe://LookupService/ServiceRegistrar/ )],
79	);
80
81	};
82
83	sub build {
84	my $self = shift;
85	#print "BUILD", "\n";
86	# create sessions that depend on the foreign kernel.
87	POE::Component::LookupClient::Session->new();
88	}
89
90
91
92	package POE::Component::LookupClient::Session;
93
94	use strict;
95	use warnings;
96
97	use POE qw( Session );
98	use Data::Dumper;
99
100
101	sub new {
102	my $classname = shift;
103	my @args = @_;
104
105	my $self = {};
106	bless $self, $classname;
107
108	$self->{options} = { @args };
109
110	POE::Session->create(
111	object_states => [
112	$self => [qw( _start _stop response register_lease renew_lease )]
113	]
114	);
115
116	}
117
118
119	# This is not a POE method. It's a plain OO one.
120	sub debug {
121	my $self = shift;
122	my $msg = shift;
123	$msg \|\|= '';
124	print STDERR __PACKAGE__ . ": " . $msg, "\n";
125	}
126
127	# Controller's event handlers
128
129	sub _start {
130	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
131	$self->debug("_start");
132
133	#$kernel->alias_set('');
134	#$kernel->post();
135
136	# set up communication channel for asynchronous responses
137	$kernel->alias_set('DeviceClient');
138	$kernel->post('IKC', 'publish', 'DeviceClient', [qw( response )]);
139
140	# try to register on startup
141	$kernel->yield('register_lease');
142
143	};
144
145	sub _stop {
146	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
147	$self->debug("_stop");
148	};
149
150	# Main response dispatcher, this should dispatch to local states programmatically.
151	sub response {
152	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
153	#$self->debug("response");
154
155	my $payload = $_[ARG0];
156	$payload \|\|= '';
157
158	# If registration succeeded, start the renewal cycle.
159	if ($payload eq 'REG_OK') {
160	$self->debug("Starting lease loop.");
161	$kernel->yield( 'renew_lease' );
162
163	} elsif ($payload eq 'LEASE_OK') {
164	$self->debug("Received 'LEASE_OK'.");
165	#$kernel->yield( 'renew_lease' );
166
167	# 1. otherwise dump anything sent to us for debugging purposes
168	# 2. destroy lease in any case on unknown payload
169	} else {
170	#print Dumper($payload);
171	$heap->{'destroy lease'} = 1;
172
173	}
174
175	};
176
177	sub register_lease {
178	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
179	$self->debug("register_lease");
180	my $ONE_arg = "Hello World!";
181
182	# V1 - without subscription
183	#$kernel->post('IKC', 'post', "poe://LookupService/ServiceRegistrar/register_lease", $ONE_arg);
184	# V2 - with subscription
185	$kernel->post( "poe://LookupService/ServiceRegistrar", "register_lease", $ONE_arg);
186	}
187
188	sub renew_lease {
189	my ( $self, $kernel, $heap ) = @_[ OBJECT, KERNEL, HEAP ];
190
191	if ($heap->{'destroy lease'}) {
192	$heap->{'destroy lease'} = 0;
193	$self->debug("destroyed lease");
194	return;
195	}
196
197	$self->debug("renew_lease");
198
199	my $ONE_arg = '';
200	#$kernel->post('IKC', 'post', "poe://LookupService/ServiceRegistrar/renew_lease", $ONE_arg);
201	# V1 - without subscription
202	$kernel->post('IKC', 'call', "poe://LookupService/ServiceRegistrar/renew_lease", $ONE_arg, 'poe:response');
203	# V2 - with subscription
204	#my $resp = $kernel->call( "poe://LookupService/ServiceRegistrar", "renew_lease", $ONE_arg);
205	#print $resp, "\n";
206
207	# and again...
208	$kernel->delay('renew_lease', 15);
209	}
210
211	1;
212	__END__
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26