[poe-commits] poe/t 01_sessions.t,1.24,1.25
Brought to you by:
rcaputo
From: <rc...@us...> - 2003-11-10 23:21:06
|
Update of /cvsroot/poe/poe/t In directory sc8-pr-cvs1:/tmp/cvs-serv13224/t Modified Files: 01_sessions.t Log Message: Applied Dan McCormicks's callback() patch. Index: 01_sessions.t =================================================================== RCS file: /cvsroot/poe/poe/t/01_sessions.t,v retrieving revision 1.24 retrieving revision 1.25 diff -C2 -d -r1.24 -r1.25 *** 01_sessions.t 9 Jul 2003 18:20:40 -0000 1.24 --- 01_sessions.t 10 Nov 2003 23:20:55 -0000 1.25 *************** *** 13,17 **** sub POE::Kernel::TRACE_FILENAME () { "./test-output.err" } ! test_setup(29); use POE; --- 13,17 ---- sub POE::Kernel::TRACE_FILENAME () { "./test-output.err" } ! test_setup(30); use POE; *************** *** 179,182 **** --- 179,186 ---- $_[HEAP]->{response} = 0; }, + sync_query => + sub { + $_[ARG0]->( ++$_[HEAP]->{response} ); + }, query => sub { *************** *** 190,193 **** --- 194,198 ---- my $postback_test = 1; + my $callback_test = 1; POE::Session->create *************** *** 200,213 **** query => sub { ! $_[KERNEL]->post( server => ! query => ! $_[SESSION]->postback( response => ! ++$_[HEAP]->{cookie} ! ) ! ); }, response => sub { ! $postback_test = 0 if $_[ARG0]->[0] != $_[ARG1]->[0]; if ($_[HEAP]->{cookie} < 5) { $_[KERNEL]->yield( 'query' ); --- 205,230 ---- query => sub { ! $_[KERNEL]->post( ! server => ! query => $_[SESSION]->postback(response => ++$_[HEAP]->{cookie}) ! ); ! $_[HEAP]->{sync_called_back} = 0; ! $_[KERNEL]->call( ! server => ! sync_query => ! $_[SESSION]->callback(sync_response => ++$_[HEAP]->{cookie}) ! ); ! $callback_test = 0 unless $_[HEAP]->{sync_called_back}; ! }, ! sync_response => ! sub { ! my ($req, $rsp) = ($_[ARG0]->[0], $_[ARG1]->[0] + 1); ! $callback_test = 0 unless $req == $rsp; ! $_[HEAP]->{sync_called_back} = 1; }, response => sub { ! my ($req, $rsp) = ($_[ARG0]->[0], $_[ARG1]->[0] - 1); ! $postback_test = 0 unless $req == $rsp; if ($_[HEAP]->{cookie} < 5) { $_[KERNEL]->yield( 'query' ); *************** *** 420,436 **** print "ok 13\n"; # Were the various get_active_session() calls correct? print 'not ' unless $get_active_session_within; ! print "ok 14\n"; print 'not ' unless $get_active_session_before; ! print "ok 15\n"; print 'not ' unless $get_active_session_after; ! print "ok 16\n"; # Was the get_heap() call correct? print 'not ' unless $get_active_session_heap; ! print "ok 17\n"; # Gratuitous tests to appease the coverage gods. --- 437,456 ---- print "ok 13\n"; + print 'not ' unless $callback_test; + print "ok 14\n"; + # Were the various get_active_session() calls correct? print 'not ' unless $get_active_session_within; ! print "ok 15\n"; print 'not ' unless $get_active_session_before; ! print "ok 16\n"; print 'not ' unless $get_active_session_after; ! print "ok 17\n"; # Was the get_heap() call correct? print 'not ' unless $get_active_session_heap; ! print "ok 18\n"; # Gratuitous tests to appease the coverage gods. *************** *** 440,458 **** ARG7 == ARG6+1 and ARG8 == ARG7+1 and ARG9 == ARG8+1 ); ! print "ok 18\n"; print 'not ' unless $sender_count == $machine_count * $event_count; ! print "ok 19\n"; print 'not ' unless $default_count == ($machine_count * $event_count) / 2; ! print "ok 20\n"; print 'not ' unless $got_heap_count == $machine_count / 2; ! print "ok 21\n"; # Object/package sessions. for (0..7) { print 'not ' unless $objpack[$_] == $event_count; ! print 'ok ', $_ + 22, "\n"; } --- 460,478 ---- ARG7 == ARG6+1 and ARG8 == ARG7+1 and ARG9 == ARG8+1 ); ! print "ok 19\n"; print 'not ' unless $sender_count == $machine_count * $event_count; ! print "ok 20\n"; print 'not ' unless $default_count == ($machine_count * $event_count) / 2; ! print "ok 21\n"; print 'not ' unless $got_heap_count == $machine_count / 2; ! print "ok 22\n"; # Object/package sessions. for (0..7) { print 'not ' unless $objpack[$_] == $event_count; ! print 'ok ', $_ + 23, "\n"; } |