ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/ext/dm-support.ext
Revision: 1.5
Committed: Wed Apr 18 14:24:09 2007 UTC (17 years, 2 months ago) by root
Branch: MAIN
Changes since 1.4: +1 -0 lines
Log Message:
- implement two new helper functions:
  cf::cache => load and process a file, caching the result in the db
  cf::fork_call => execute a given sub asynchronously (e.g. for cpu jobs)
- make use of it in ext/map-world.ext, greatly speeding up worldmap
  loading.
- preliminary garbage added to cf::pod.

File Contents

# Content
1 #! perl
2
3 use IO::Socket;
4 use Storable qw/nfreeze thaw/;
5
6 my %global; # for use by eval'ed commands
7
8 sub tcp_serve($) {
9 my ($fh) = @_;
10
11 select $fh;
12
13 binmode $fh, ":raw:perlio:utf8";
14
15 my $buf;
16 my ($a, $b, $c, $d, $e, $f, $g, $h, $i, $j, $k, $l, $m, $n, $o, $p, $q, $r, $s, $t, $u, $v, $w, $x, $y, $z);
17 my (%l, @l); # for use by shell users
18
19 print <<EOF;
20 Welcome!
21 Remember that everything entered here will be in the main coro context within cf::!
22 You can freely use \$a .. \$z and \@l and \%l
23
24 Useful commands (note the '&'):
25
26 reload_perl &
27 reload_regions &
28 reload_facedata &
29 reload_treasures &
30 reload_archetypes &
31 ext::map_world::reload &
32 EOF
33 print "\n> ";
34
35 Event->io (fd => $fh, poll => 'r', data => 0, cb => sub {
36 if (defined (my $cmd = <$fh>)) {
37 $cmd =~ s/\s+$//;
38
39 if ($cmd =~ /^\s*exit\b/i) {
40 print "will not exit() server.\n";
41 } else {
42 my $sub = sub {
43 package cf;
44 select $fh;
45
46 # compile first, the execute, as Coro does not support switching in eval string
47 my $cb = eval "sub { $cmd }";
48
49 my $t1 = Time::HiRes::time;
50 my @res = $@ ? () : eval { $cb->() };
51 my $t2 = Time::HiRes::time;
52
53 print "\n",
54 "command: '$cmd'\n",
55 "execution time: ", $t2 - $t1, "\n";
56 warn "evaluation error: $@" if $@;
57 print "evaluation error: $@\n" if $@;
58 print "result:\n", cf::dumpval @res > 1 ? \@res : $res[0] if @res;
59 print "\n> ";
60 };
61
62 if ($cmd =~ s/\s*&$//) {
63 Coro::async_pool { $sub->() };
64 } else {
65 $sub->();
66 }
67 }
68
69 print "\n> ";
70 } else {
71 $_[0]->w->cancel;
72 }
73 });
74 }
75
76 # now a shell listening on a tcp-port - let the firewall decide access rights
77 if ($cf::CFG{perl_shell}) {
78 if (my $listen = new IO::Socket::INET LocalAddr => $cf::CFG{perl_shell}, Listen => 1, ReuseAddr => 1) {
79 Event->io (fd => $listen, poll => 'r', data => cf::WF_AUTOCANCEL, cb => sub { tcp_serve $listen->accept });
80 }
81 }