--- deliantra/server/ext/dm-support.ext 2007/10/18 02:56:13 1.15 +++ deliantra/server/ext/dm-support.ext 2010/04/12 05:27:10 1.26 @@ -31,11 +31,14 @@ ext::books::reload & ext::map_tags::reload & ext::map_world::reload & -print JSON::XS->new->pretty->encode({cf::mallinfo}) +# ext::map_scheduler::loadall & # debugging only! +cf::object::create_count, cf::object::destroy_count, cf::object::free_count, cf::object::object_count +while (EV::TIMEOUT & Coro::EV::timed_io_once \$fh, EV::READ, 1) { Coro::Debug::command "ps" } & +({cf::mallinfo}) EOF print $fh "\n> "; - Event->io (fd => $fh, poll => 'r', data => 0, cb => sub { + my $iow; $iow = AE::io $fh, 0, sub { if (defined (my $cmd = <$fh>)) { $cmd =~ s/\s+$//; @@ -50,8 +53,8 @@ package cf; select $fh; - # compile first, the execute, as Coro does not support switching in eval string - my $cb = eval "sub { $cmd }"; + # compile first, then execute, as Coro does not support switching in eval string + my $cb = eval "sub { $cmd \n}"; my $t1 = Time::HiRes::time; my @res = $@ ? () : eval { $cb->() }; @@ -80,15 +83,17 @@ print $fh "\n> "; } else { - $_[0]->w->cancel; + undef $iow; } - }); + }; } +our $LISTENER; + # now a shell listening on a tcp-port - let the firewall decide access rights if ($cf::CFG{perl_shell}) { - if (my $listen = new IO::Socket::INET LocalAddr => $cf::CFG{perl_shell}, Listen => 1, ReuseAddr => 1) { - Event->io (fd => $listen, poll => 'r', data => cf::WF_AUTOCANCEL, cb => sub { tcp_serve $listen->accept }); + if (my $listen = new IO::Socket::INET LocalAddr => $cf::CFG{perl_shell}, Listen => 1, ReuseAddr => 1, Blocking => 0) { + $LISTENER = AE::io $listen, 0, sub { tcp_serve $listen->accept }; } }