ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/lib/cf.pm
(Generate patch)

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.434 by root, Thu May 29 03:27:37 2008 UTC vs.
Revision 1.444 by root, Mon Sep 8 11:27:25 2008 UTC

… …
19# The authors can be reached via e-mail to <support@deliantra.net> 19# The authors can be reached via e-mail to <support@deliantra.net>
20# 20#
21 21
22package cf; 22package cf;
23 23
24use 5.10.0;
24use utf8; 25use utf8;
25use strict; 26use strict "vars", "subs";
26 27
27use Symbol; 28use Symbol;
28use List::Util; 29use List::Util;
29use Socket; 30use Socket;
30use EV; 31use EV;
… …
34use Storable (); 35use Storable ();
35 36
36use Coro (); 37use Coro ();
37use Coro::State; 38use Coro::State;
38use Coro::Handle; 39use Coro::Handle;
40use Coro::EV;
39use Coro::AnyEvent; 41use Coro::AnyEvent;
40use Coro::Timer; 42use Coro::Timer;
41use Coro::Signal; 43use Coro::Signal;
42use Coro::Semaphore; 44use Coro::Semaphore;
43use Coro::AnyEvent; 45use Coro::AnyEvent;
44use Coro::AIO; 46use Coro::AIO;
45use Coro::BDB; 47use Coro::BDB 1.6;
46use Coro::Storable; 48use Coro::Storable;
47use Coro::Util (); 49use Coro::Util ();
48 50
49use JSON::XS 2.01 (); 51use JSON::XS 2.01 ();
50use BDB (); 52use BDB ();
… …
56use Time::HiRes; 58use Time::HiRes;
57use Compress::LZF; 59use Compress::LZF;
58use Digest::MD5 (); 60use Digest::MD5 ();
59 61
60AnyEvent::detect; 62AnyEvent::detect;
61
62IO::AIO::max_poll_reqs 1;#d#
63 63
64# configure various modules to our taste 64# configure various modules to our taste
65# 65#
66$Storable::canonical = 1; # reduce rsync transfers 66$Storable::canonical = 1; # reduce rsync transfers
67Coro::State::cctx_stacksize 256000; # 1-2MB stack, for deep recursions in maze generator 67Coro::State::cctx_stacksize 256000; # 1-2MB stack, for deep recursions in maze generator
… …
245for my $pkg (qw( 245for my $pkg (qw(
246 cf::global cf::attachable 246 cf::global cf::attachable
247 cf::object cf::object::player 247 cf::object cf::object::player
248 cf::client cf::player 248 cf::client cf::player
249 cf::arch cf::living 249 cf::arch cf::living
250 cf::map cf::mapspace
250 cf::map cf::party cf::region 251 cf::party cf::region
251)) { 252)) {
252 no strict 'refs';
253 @{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg; 253 @{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg;
254} 254}
255 255
256$EV::DIED = sub { 256$EV::DIED = sub {
257 warn "error in event callback: @_"; 257 warn "error in event callback: @_";
… …
1088 1088
1089sub reattach { 1089sub reattach {
1090 # basically do the same as instantiate, without calling instantiate 1090 # basically do the same as instantiate, without calling instantiate
1091 my ($obj) = @_; 1091 my ($obj) = @_;
1092 1092
1093 # no longer needed after getting rid of delete_package?
1093 bless $obj, ref $obj; # re-bless in case extensions have been reloaded 1094 #bless $obj, ref $obj; # re-bless in case extensions have been reloaded
1094 1095
1095 my $registry = $obj->registry; 1096 my $registry = $obj->registry;
1096 1097
1097 @$registry = (); 1098 @$registry = ();
1098 1099
… …
1334 1335
1335 $ext{meta} = { map { (split /=/, $_, 2)[0, 1] } split /\s+/, $1 } 1336 $ext{meta} = { map { (split /=/, $_, 2)[0, 1] } split /\s+/, $1 }
1336 if $source =~ /\A#!.*?perl.*?#\s*(.*)$/m; 1337 if $source =~ /\A#!.*?perl.*?#\s*(.*)$/m;
1337 1338
1338 $ext{source} = 1339 $ext{source} =
1339 "package $pkg; use strict; use utf8;\n" 1340 "package $pkg; use 5.10.0; use strict 'vars', 'subs'; use utf8;\n"
1340 . "#line 1 \"$path\"\n{\n" 1341 . "#line 1 \"$path\"\n{\n"
1341 . $source 1342 . $source
1342 . "\n};\n1"; 1343 . "\n};\n1";
1343 1344
1344 $todo{$base} = \%ext; 1345 $todo{$base} = \%ext;
… …
1522 my ($pl) = @_; 1523 my ($pl) = @_;
1523 1524
1524 my $name = $pl->ob->name; 1525 my $name = $pl->ob->name;
1525 1526
1526 $pl->{deny_save} = 1; 1527 $pl->{deny_save} = 1;
1527 $pl->password ("*"); # this should lock out the player until we nuked the dir 1528 $pl->password ("*"); # this should lock out the player until we have nuked the dir
1528 1529
1529 $pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active; 1530 $pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active;
1530 $pl->deactivate; 1531 $pl->deactivate;
1531 my $killer = cf::arch::get "killer_quit"; $pl->killer ($killer); $killer->destroy; 1532 my $killer = cf::arch::get "killer_quit"; $pl->killer ($killer); $killer->destroy;
1532 $pl->ob->check_score; 1533 $pl->ob->check_score;
… …
1621} 1622}
1622 1623
1623=item $protocol_xml = $player->expand_cfpod ($crossfire_pod) 1624=item $protocol_xml = $player->expand_cfpod ($crossfire_pod)
1624 1625
1625Expand crossfire pod fragments into protocol xml. 1626Expand crossfire pod fragments into protocol xml.
1626
1627=cut
1628
1629use re 'eval';
1630
1631my $group;
1632my $interior; $interior = qr{
1633 # match a pod interior sequence sans C<< >>
1634 (?:
1635 \ (.*?)\ (?{ $group = $^N })
1636 | < (??{$interior}) >
1637 )
1638}x;
1639
1640sub expand_cfpod {
1641 my ($self, $pod) = @_;
1642
1643 my $xml;
1644
1645 while () {
1646 if ($pod =~ /\G( (?: [^BCGHITU]+ | .(?!<) )+ )/xgcs) {
1647 $group = $1;
1648
1649 $group =~ s/&/&amp;/g;
1650 $group =~ s/</&lt;/g;
1651
1652 $xml .= $group;
1653 } elsif ($pod =~ m%\G
1654 ([BCGHITU])
1655 <
1656 (?:
1657 ([^<>]*) (?{ $group = $^N })
1658 | < $interior >
1659 )
1660 >
1661 %gcsx
1662 ) {
1663 my ($code, $data) = ($1, $group);
1664
1665 if ($code eq "B") {
1666 $xml .= "<b>" . expand_cfpod ($self, $data) . "</b>";
1667 } elsif ($code eq "I") {
1668 $xml .= "<i>" . expand_cfpod ($self, $data) . "</i>";
1669 } elsif ($code eq "U") {
1670 $xml .= "<u>" . expand_cfpod ($self, $data) . "</u>";
1671 } elsif ($code eq "C") {
1672 $xml .= "<tt>" . expand_cfpod ($self, $data) . "</tt>";
1673 } elsif ($code eq "T") {
1674 $xml .= "<big><b>" . expand_cfpod ($self, $data) . "</b></big>";
1675 } elsif ($code eq "G") {
1676 my ($male, $female) = split /\|/, $data;
1677 $data = $self->gender ? $female : $male;
1678 $xml .= expand_cfpod ($self, $data);
1679 } elsif ($code eq "H") {
1680 $xml .= ("<fg name=\"lightblue\">[" . expand_cfpod ($self, $data) . " (Use hintmode to suppress hints)]</fg>",
1681 "<fg name=\"lightblue\">[Hint suppressed, see hintmode]</fg>",
1682 "")
1683 [$self->{hintmode}];
1684 } else {
1685 $xml .= "error processing '$code($data)' directive";
1686 }
1687 } else {
1688 if ($pod =~ /\G(.+)/) {
1689 warn "parse error while expanding $pod (at $1)";
1690 }
1691 last;
1692 }
1693 }
1694
1695 for ($xml) {
1696 # create single paragraphs (very hackish)
1697 s/(?<=\S)\n(?=\w)/ /g;
1698
1699 # compress some whitespace
1700 s/\s+\n/\n/g; # ws line-ends
1701 s/\n\n+/\n/g; # double lines
1702 s/^\n+//; # beginning lines
1703 s/\n+$//; # ending lines
1704 }
1705
1706 $xml
1707}
1708
1709no re 'eval';
1710
1711sub hintmode {
1712 $_[0]{hintmode} = $_[1] if @_ > 1;
1713 $_[0]{hintmode}
1714}
1715 1627
1716=item $player->ext_reply ($msgid, @msg) 1628=item $player->ext_reply ($msgid, @msg)
1717 1629
1718Sends an ext reply to the player. 1630Sends an ext reply to the player.
1719 1631
… …
2088 my $f = new_from_file cf::object::thawer $self->{load_path}; 2000 my $f = new_from_file cf::object::thawer $self->{load_path};
2089 $f->skip_block; 2001 $f->skip_block;
2090 $self->_load_objects ($f) 2002 $self->_load_objects ($f)
2091 or return; 2003 or return;
2092 2004
2093 $self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1) 2005 $self->post_load_original
2094 if delete $self->{load_original}; 2006 if delete $self->{load_original};
2095 2007
2096 if (my $uniq = $self->uniq_path) { 2008 if (my $uniq = $self->uniq_path) {
2097 utf8::encode $uniq; 2009 utf8::encode $uniq;
2098 unless (aio_stat $uniq) { 2010 unless (aio_stat $uniq) {
… …
2615Moves the player to the given map-path and coordinates by first freezing 2527Moves the player to the given map-path and coordinates by first freezing
2616her, loading and preparing them map, calling the provided $check callback 2528her, loading and preparing them map, calling the provided $check callback
2617that has to return the map if sucecssful, and then unfreezes the player on 2529that has to return the map if sucecssful, and then unfreezes the player on
2618the new (success) or old (failed) map position. In either case, $done will 2530the new (success) or old (failed) map position. In either case, $done will
2619be called at the end of this process. 2531be called at the end of this process.
2532
2533Note that $check will be called with a potentially non-loaded map, so if
2534it needs a loaded map it has to call C<< ->load >>.
2620 2535
2621=cut 2536=cut
2622 2537
2623our $GOTOGEN; 2538our $GOTOGEN;
2624 2539
… …
2901 if ($self->can_msg) { 2816 if ($self->can_msg) {
2902 # default colour, mask it out 2817 # default colour, mask it out
2903 $color &= ~(cf::NDI_COLOR_MASK | cf::NDI_DEF) 2818 $color &= ~(cf::NDI_COLOR_MASK | cf::NDI_DEF)
2904 if $color & cf::NDI_DEF; 2819 if $color & cf::NDI_DEF;
2905 2820
2906 $self->send_packet ("msg " . $self->{json_coder}->encode ( 2821 my $pkt = "msg "
2822 . $self->{json_coder}->encode (
2907 [$color & cf::NDI_CLIENT_MASK, $channel, $msg, @extra])); 2823 [$color & cf::NDI_CLIENT_MASK, $channel, $msg, @extra]
2824 );
2825
2826 # try lzf for large packets
2827 $pkt = "lzf " . Compress::LZF::compress $pkt
2828 if 1024 <= length $pkt and $self->{can_lzf};
2829
2830 # split very large packets
2831 if (8192 < length $pkt and $self->{can_lzf}) {
2832 $self->send_packet ("frag $_") for unpack "(a8192)*", $pkt;
2833 $pkt = "frag";
2834 }
2835
2836 $self->send_packet ($pkt);
2908 } else { 2837 } else {
2909 if ($color >= 0) { 2838 if ($color >= 0) {
2910 # replace some tags by gcfclient-compatible ones 2839 # replace some tags by gcfclient-compatible ones
2911 for ($msg) { 2840 for ($msg) {
2912 1 while 2841 1 while
… …
3127=cut 3056=cut
3128 3057
3129for ( 3058for (
3130 ["cf::object" => qw(contr pay_amount pay_player map force_find force_add x y 3059 ["cf::object" => qw(contr pay_amount pay_player map force_find force_add x y
3131 insert remove inv nrof name archname title slaying race 3060 insert remove inv nrof name archname title slaying race
3132 decrease split destroy)], 3061 decrease split destroy change_exp)],
3133 ["cf::object::player" => qw(player)], 3062 ["cf::object::player" => qw(player)],
3134 ["cf::player" => qw(peaceful)], 3063 ["cf::player" => qw(peaceful)],
3135 ["cf::map" => qw(trigger)], 3064 ["cf::map" => qw(trigger)],
3136) { 3065) {
3137 no strict 'refs'; 3066 no strict 'refs';
… …
3397 warn "finished reloading resource files\n"; 3326 warn "finished reloading resource files\n";
3398} 3327}
3399 3328
3400sub init { 3329sub init {
3401 my $guard = freeze_mainloop; 3330 my $guard = freeze_mainloop;
3331
3332 evthread_start IO::AIO::poll_fileno;
3402 3333
3403 reload_resources; 3334 reload_resources;
3404} 3335}
3405 3336
3406sub reload_config { 3337sub reload_config {
… …
3583 3514
3584 warn Carp::longmess "post_cleanup backtrace" 3515 warn Carp::longmess "post_cleanup backtrace"
3585 if $make_core; 3516 if $make_core;
3586} 3517}
3587 3518
3519# a safer delete_package, copied from Symbol
3520sub clear_package($) {
3521 my $pkg = shift;
3522
3523 # expand to full symbol table name if needed
3524 unless ($pkg =~ /^main::.*::$/) {
3525 $pkg = "main$pkg" if $pkg =~ /^::/;
3526 $pkg = "main::$pkg" unless $pkg =~ /^main::/;
3527 $pkg .= '::' unless $pkg =~ /::$/;
3528 }
3529
3530 my($stem, $leaf) = $pkg =~ m/(.*::)(\w+::)$/;
3531 my $stem_symtab = *{$stem}{HASH};
3532
3533 defined $stem_symtab and exists $stem_symtab->{$leaf}
3534 or return;
3535
3536 # clear all symbols
3537 my $leaf_symtab = *{$stem_symtab->{$leaf}}{HASH};
3538 for my $name (keys %$leaf_symtab) {
3539 _gv_clear *{"$pkg$name"};
3540# use PApp::Util; PApp::Util::sv_dump *{"$pkg$name"};
3541 }
3542 warn "cleared package #$pkg\n";#d#
3543}
3544
3545our $RELOAD; # how many times to reload
3546
3588sub do_reload_perl() { 3547sub do_reload_perl() {
3589 # can/must only be called in main 3548 # can/must only be called in main
3590 if ($Coro::current != $Coro::main) { 3549 if ($Coro::current != $Coro::main) {
3591 warn "can only reload from main coroutine"; 3550 warn "can only reload from main coroutine";
3592 return; 3551 return;
3593 } 3552 }
3594 3553
3554 return if $RELOAD++;
3555
3556 while ($RELOAD) {
3595 warn "reloading..."; 3557 warn "reloading...";
3596 3558
3597 warn "entering sync_job"; 3559 warn "entering sync_job";
3598 3560
3599 cf::sync_job { 3561 cf::sync_job {
3600 cf::write_runtime_sync; # external watchdog should not bark 3562 cf::write_runtime_sync; # external watchdog should not bark
3601 cf::emergency_save; 3563 cf::emergency_save;
3602 cf::write_runtime_sync; # external watchdog should not bark 3564 cf::write_runtime_sync; # external watchdog should not bark
3603 3565
3604 warn "syncing database to disk"; 3566 warn "syncing database to disk";
3605 BDB::db_env_txn_checkpoint $DB_ENV; 3567 BDB::db_env_txn_checkpoint $DB_ENV;
3606 3568
3607 # if anything goes wrong in here, we should simply crash as we already saved 3569 # if anything goes wrong in here, we should simply crash as we already saved
3608 3570
3609 warn "flushing outstanding aio requests"; 3571 warn "flushing outstanding aio requests";
3610 for (;;) {
3611 BDB::flush;
3612 IO::AIO::flush;
3613 Coro::cede_notself;
3614 last unless IO::AIO::nreqs || BDB::nreqs; 3572 while (IO::AIO::nreqs || BDB::nreqs) {
3615 warn "iterate..."; 3573 Coro::EV::timer_once 0.01; # let the sync_job do it's thing
3616 }
3617
3618 ++$RELOAD;
3619
3620 warn "cancelling all extension coros";
3621 $_->cancel for values %EXT_CORO;
3622 %EXT_CORO = ();
3623
3624 warn "removing commands";
3625 %COMMAND = ();
3626
3627 warn "removing ext/exti commands";
3628 %EXTCMD = ();
3629 %EXTICMD = ();
3630
3631 warn "unloading/nuking all extensions";
3632 for my $pkg (@EXTS) {
3633 warn "... unloading $pkg";
3634
3635 if (my $cb = $pkg->can ("unload")) {
3636 eval {
3637 $cb->($pkg);
3638 1
3639 } or warn "$pkg unloaded, but with errors: $@";
3640 } 3574 }
3641 3575
3642 warn "... nuking $pkg"; 3576 warn "cancelling all extension coros";
3643 Symbol::delete_package $pkg; 3577 $_->cancel for values %EXT_CORO;
3644 } 3578 %EXT_CORO = ();
3645 3579
3646 warn "unloading all perl modules loaded from $LIBDIR"; 3580 warn "removing commands";
3647 while (my ($k, $v) = each %INC) { 3581 %COMMAND = ();
3648 next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;
3649 3582
3583 warn "removing ext/exti commands";
3584 %EXTCMD = ();
3585 %EXTICMD = ();
3586
3587 warn "unloading/nuking all extensions";
3588 for my $pkg (@EXTS) {
3650 warn "... unloading $k"; 3589 warn "... unloading $pkg";
3651 delete $INC{$k};
3652 3590
3653 $k =~ s/\.pm$//;
3654 $k =~ s/\//::/g;
3655
3656 if (my $cb = $k->can ("unload_module")) { 3591 if (my $cb = $pkg->can ("unload")) {
3592 eval {
3657 $cb->(); 3593 $cb->($pkg);
3594 1
3595 } or warn "$pkg unloaded, but with errors: $@";
3596 }
3597
3598 warn "... clearing $pkg";
3599 clear_package $pkg;
3658 } 3600 }
3659 3601
3660 Symbol::delete_package $k; 3602 warn "unloading all perl modules loaded from $LIBDIR";
3603 while (my ($k, $v) = each %INC) {
3604 next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;
3605
3606 warn "... unloading $k";
3607 delete $INC{$k};
3608
3609 $k =~ s/\.pm$//;
3610 $k =~ s/\//::/g;
3611
3612 if (my $cb = $k->can ("unload_module")) {
3613 $cb->();
3614 }
3615
3616 clear_package $k;
3661 } 3617 }
3662 3618
3663 warn "getting rid of safe::, as good as possible"; 3619 warn "getting rid of safe::, as good as possible";
3664 Symbol::delete_package "safe::$_" 3620 clear_package "safe::$_"
3665 for qw(cf::attachable cf::object cf::object::player cf::client cf::player cf::map cf::party cf::region); 3621 for qw(cf::attachable cf::object cf::object::player cf::client cf::player cf::map cf::party cf::region);
3666 3622
3667 warn "unloading cf.pm \"a bit\""; 3623 warn "unloading cf.pm \"a bit\"";
3668 delete $INC{"cf.pm"}; 3624 delete $INC{"cf.pm"};
3669 delete $INC{"cf/pod.pm"}; 3625 delete $INC{"cf/pod.pm"};
3670 3626
3671 # don't, removes xs symbols, too, 3627 # don't, removes xs symbols, too,
3672 # and global variables created in xs 3628 # and global variables created in xs
3673 #Symbol::delete_package __PACKAGE__; 3629 #clear_package __PACKAGE__;
3674 3630
3675 warn "unload completed, starting to reload now"; 3631 warn "unload completed, starting to reload now";
3676 3632
3677 warn "reloading cf.pm"; 3633 warn "reloading cf.pm";
3678 require cf; 3634 require cf;
3679 cf::_connect_to_perl; # nominally unnecessary, but cannot hurt 3635 cf::_connect_to_perl; # nominally unnecessary, but cannot hurt
3680 3636
3681 warn "loading config and database again"; 3637 warn "loading config and database again";
3682 cf::reload_config; 3638 cf::reload_config;
3683 3639
3684 warn "loading extensions"; 3640 warn "loading extensions";
3685 cf::load_extensions; 3641 cf::load_extensions;
3686 3642
3687 warn "reattaching attachments to objects/players"; 3643 warn "reattaching attachments to objects/players";
3688 _global_reattach; # objects, sockets 3644 _global_reattach; # objects, sockets
3689 warn "reattaching attachments to maps"; 3645 warn "reattaching attachments to maps";
3690 reattach $_ for values %MAP; 3646 reattach $_ for values %MAP;
3691 warn "reattaching attachments to players"; 3647 warn "reattaching attachments to players";
3692 reattach $_ for values %PLAYER; 3648 reattach $_ for values %PLAYER;
3693 3649
3694 warn "leaving sync_job"; 3650 warn "leaving sync_job";
3695 3651
3696 1 3652 1
3697 } or do { 3653 } or do {
3698 warn $@; 3654 warn $@;
3699 cf::cleanup "error while reloading, exiting."; 3655 cf::cleanup "error while reloading, exiting.";
3700 }; 3656 };
3701 3657
3702 warn "reloaded"; 3658 warn "reloaded";
3659 --$RELOAD;
3660 }
3703}; 3661};
3704 3662
3705our $RELOAD_WATCHER; # used only during reload 3663our $RELOAD_WATCHER; # used only during reload
3706 3664
3707sub reload_perl() { 3665sub reload_perl() {
… …
3793 BDB::max_poll_reqs $TICK * 0.1; 3751 BDB::max_poll_reqs $TICK * 0.1;
3794 $AnyEvent::BDB::WATCHER->priority (1); 3752 $AnyEvent::BDB::WATCHER->priority (1);
3795 3753
3796 unless ($DB_ENV) { 3754 unless ($DB_ENV) {
3797 $DB_ENV = BDB::db_env_create; 3755 $DB_ENV = BDB::db_env_create;
3798 $DB_ENV->set_flags (BDB::AUTO_COMMIT | BDB::REGION_INIT | BDB::TXN_NOSYNC 3756 $DB_ENV->set_flags (BDB::AUTO_COMMIT | BDB::REGION_INIT);
3799 | BDB::LOG_AUTOREMOVE, 1); 3757 $DB_ENV->set_flags (&BDB::LOG_AUTOREMOVE ) if BDB::VERSION v0, v4.7;
3758 $DB_ENV->log_set_config (&BDB::LOG_AUTO_REMOVE) if BDB::VERSION v4.7;
3800 $DB_ENV->set_timeout (30, BDB::SET_TXN_TIMEOUT); 3759 $DB_ENV->set_timeout (30, BDB::SET_TXN_TIMEOUT);
3801 $DB_ENV->set_timeout (30, BDB::SET_LOCK_TIMEOUT); 3760 $DB_ENV->set_timeout (30, BDB::SET_LOCK_TIMEOUT);
3802 3761
3803 cf::sync_job { 3762 cf::sync_job {
3804 eval { 3763 eval {
… …
3830{ 3789{
3831 # configure IO::AIO 3790 # configure IO::AIO
3832 3791
3833 IO::AIO::min_parallel 8; 3792 IO::AIO::min_parallel 8;
3834 IO::AIO::max_poll_time $TICK * 0.1; 3793 IO::AIO::max_poll_time $TICK * 0.1;
3835 #undef $AnyEvent::AIO::WATCHER; 3794 undef $AnyEvent::AIO::WATCHER;
3836} 3795}
3837 3796
3838my $_log_backtrace; 3797my $_log_backtrace;
3839 3798
3840sub _log_backtrace { 3799sub _log_backtrace {
… …
3878# load additional modules 3837# load additional modules
3879use cf::pod; 3838use cf::pod;
3880 3839
3881END { cf::emergency_save } 3840END { cf::emergency_save }
3882 3841
3883evthread_start IO::AIO::poll_fileno;
3884
38851 38421
3886 3843

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines