[ViewVC] Diff of: cvs/cf.schmorp.de/server/lib/cf.pm

Comparing cf.schmorp.de/server/lib/cf.pm (file contents):
Revision 1.139 by root, Fri Jan 5 19:12:03 2007 UTC vs.
Revision 1.146 by root, Sun Jan 7 23:10:43 2007 UTC

 use Coro::Semaphore;
 use Coro::AIO;
 use Digest::MD5;
 use Fcntl;
-use IO::AIO 2.31 ();
+use IO::AIO 2.32 ();
 use YAML::Syck ();
 use Time::HiRes;
 use Event; $Event::Eval = 1; # no idea why this is required, but it is
 our %CFG;
 our $UPTIME; $UPTIME ||= time;
 our $RUNTIME;
+our %PLAYER; # all users
-our %MAP; # all maps
+our %MAP;    # all maps
 our $LINK_MAP; # the special {link} map
 our $RANDOM_MAPS = cf::localdir . "/random";
-our %EXT_CORO;
+our %EXT_CORO; # coroutines bound to extensions
 binmode STDOUT;
 binmode STDERR;
 # read virtual server time, if available
       utf8::encode $msg;
       $msg .= "\n"
          unless $msg =~ /\n$/;
-      LOG llevError, "cfperl: $msg";
+      LOG llevError, $msg;
    };
 }
 @safe::cf::global::ISA         = @cf::global::ISA         = 'cf::attachable';
 @safe::cf::object::ISA         = @cf::object::ISA         = 'cf::attachable';
    my $guard = Coro::guard { $TICK_WATCHER->start };
    $TICK_WATCHER->stop;
    $guard
 }
+=item cf::async { BLOCK }
+Currently the same as Coro::async_pool, meaning you cannot use
+C<on_destroy>, C<join> or other gimmicks on these coroutines. The only
+thing you are allowed to do is call C<prio> on it.
+=cut
+BEGIN { *async = \&Coro::async_pool }
 =item cf::sync_job { BLOCK }
 The design of crossfire+ requires that the main coro ($Coro::main) is
 always able to handle events or runnable, as crossfire+ is only partly
 reentrant. Thus "blocking" it by e.g. waiting for I/O is not acceptable.
       my $freeze_guard = freeze_mainloop;
       my $busy = 1;
       my @res;
-      (Coro::async_pool {
+      (async {
          @res = eval { $job->() };
          warn $@ if $@;
          undef $busy;
       })->prio (Coro::PRIO_MAX);
       while ($busy) {
-         unless (Coro::cede) {
+         Coro::cede or Event::one_event;
-            Coro::nready ? Event::one_event 0 : Event::one_event;
-            Coro::cede_notself unless Coro::cede;
-         }
       }
       wantarray ? @res : $res[0]
    } else {
       # we are in another coroutine, how wonderful, everything just works
       $job->()
    }
 }
-=item $coro = cf::coro { BLOCK }
+=item $coro = cf::async_ext { BLOCK }
-Creates (and readies) and returns a new coro. This coro is automcatially
+Like async, but this coro is automcatially being canceled when the
-being canceled when the extension calling this is being unloaded.
+extension calling this is being unloaded.
 =cut
-sub coro(&) {
+sub async_ext(&) {
    my $cb = shift;
-   my $coro = &Coro::async_pool ($cb);
+   my $coro = &Coro::async ($cb);
    $coro->on_destroy (sub {
       delete $EXT_CORO{$coro+0};
    });
    $EXT_CORO{$coro+0} = $coro;
 =head2 CORE EXTENSIONS
 Functions and methods that extend core crossfire objects.
+=cut
+package cf::player;
 =head3 cf::player
 =over 4
-=item cf::player::exists $login
+=item cf::player::find $login
-Returns true when the given account exists.
+Returns the given player object, loading it if necessary (might block).
 =cut
-sub cf::player::exists($) {
+sub playerdir($) {
-   cf::player::find $_[0]
+   cf::localdir
-      or -f sprintf "%s/%s/%s/%s.pl", cf::localdir, cf::playerdir, ($_[0]) x 2;
+     . "/"
+     . cf::playerdir
+     . "/"
+     . (ref $_[0] ? $_[0]->ob->name : $_[0])
+}
+sub path($) {
+   my $login = ref $_[0] ? $_[0]->ob->name : $_[0];
+   (playerdir $login) . "/$login.pl"
+}
+sub find_active($) {
+   $cf::PLAYER{$_[0]}
+      and $cf::PLAYER{$_[0]}->active
+      and $cf::PLAYER{$_[0]}
+}
+sub exists($) {
+   my ($login) = @_;
+   $cf::PLAYER{$login}
+      or cf::sync_job { !aio_stat $login }
+}
+sub find($) {
+   return $cf::PLAYER{$_[0]} || do {
+      my $login = $_[0];
+      my $guard = cf::lock_acquire "user_find:$login";
+      $cf::PLAYER{$login} ||= (load_pl path $login or return);
+   };
+}
+sub save($) {
+   my ($pl) = @_;
+   return if $pl->{deny_save};
+   my $path = path $pl;
+   my $guard = cf::lock_acquire "user_save:$path";
+   return if $pl->{deny_save};
+   IO::AIO::aio_mkdir playerdir $pl, 0770;
+   $pl->{last_save} = $cf::RUNTIME;
+   Coro::cede;
+   $pl->save_pl ($path);
+   Coro::cede;
+}
+sub new($) {
+   my ($login) = @_;
+   my $self = create;
+   $self->ob->name ($login);
+   $self->{deny_save} = 1;
+   $cf::PLAYER{$login} = $self;
+   $self
+}
+sub quit_character {
+   my ($pl) = @_;
+   $pl->{deny_save} = 1;
+   $pl->password ("*"); # this should lock out the player until we nuked the dir
+   $pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active;
+   $pl->deactivate;
+   $pl->invoke (cf::EVENT_PLAYER_QUIT);
+   $pl->ns->destroy if $pl->ns;
+   my $path = playerdir $pl;
+   my $temp = "$path~$cf::RUNTIME~deleting~";
+   IO::AIO::aio_rename $path, $temp, sub {
+      delete $cf::PLAYER{$pl->ob->name};
+      $pl->destroy;
+      IO::AIO::aio_rmtree $temp;
+   };
 }
 =item $player->ext_reply ($msgid, $msgtype, %msg)
 Sends an ext reply to the player.
 =cut
-sub cf::player::ext_reply($$$%) {
+sub ext_reply($$$%) {
    my ($self, $id, %msg) = @_;
    $msg{msgid} = $id;
-   $self->send ("ext " . to_json \%msg);
+   $self->send ("ext " . cf::to_json \%msg);
 }
+package cf;
 =back
 =head3 cf::map
 }
 sub find_sync {
    my ($path, $origin) = @_;
-   cf::sync_job {
+   cf::sync_job { cf::map::find $path, $origin }
-      my $map = cf::map::find $path, $origin;
-      $map
-   }
 }
 sub do_load_sync {
    my ($map) = @_;
    $self->{load_path} = $save;
    return if $self->{deny_save};
    local $self->{last_access} = $self->last_access;#d#
+   cf::async {
+      $_->contr->save for $self->players;
+   };
    if ($uniq) {
       $self->save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS);
       $self->save_objects ($uniq, cf::IO_UNIQUES);
    } else {
 }
 sub emergency_save {
    my $freeze_guard = cf::freeze_mainloop;
-   warn "enter emergency map save\n";
+   warn "enter emergency perl save\n";
    cf::sync_job {
+      warn "begin emergency player save\n";
+      $_->save for values %cf::PLAYER;
+      warn "end emergency player save\n";
       warn "begin emergency map save\n";
       $_->save for values %cf::MAP;
+      warn "end emergency map save\n";
    };
-   warn "end emergency map save\n";
+   warn "leave emergency perl save\n";
 }
 package cf;
 =back
    ($x, $y) = ($map->enter_x, $map->enter_y)
       if $x <=0 && $y <= 0;
    $map->load;
+   return unless $self->contr->active;
    $self->activate_recursive;
    $self->enter_map ($map, $x, $y);
 }
 cf::player->attach (
       my ($pl) = @_;
       # try to abort aborted map switching on player login :)
       # should happen only on crashes
       if ($pl->ob->{_link_pos}) {
          $pl->ob->enter_link;
-         (Coro::async_pool {
+         (async {
             # we need this sleep as the login has a concurrent enter_exit running
             # and this sleep increases chances of the player not ending up in scorn
+            $pl->ob->reply (undef,
+                            "There was an internal problem at your last logout, "
+                          . "the server will try to bring you to your intended destination in a second.",
+                            cf::NDI_RED);
             Coro::Timer::sleep 1;
             $pl->ob->leave_link;
          })->prio (2);
       }
    },
 sub cf::object::player::goto {
    my ($self, $path, $x, $y) = @_;
    $self->enter_link;
-   (Coro::async_pool {
+   (async {
       $path = new cf::path $path;
       my $map = cf::map::find $path->as_string;
       $map = $map->customise_for ($self) if $map;
    return unless $self->type == cf::PLAYER;
    $self->enter_link;
-   (Coro::async_pool {
+   (async {
       $self->deactivate_recursive; # just to be sure
       unless (eval {
          prepare_random_map $exit
             if $exit->slaying eq "/!";
          }
       }
    },
 );
-=item $client->coro (\&cb)
+=item $client->async (\&cb)
 Create a new coroutine, running the specified callback. The coroutine will
 be automatically cancelled when the client gets destroyed (e.g. on logout,
 or loss of connection).
 =cut
-sub cf::client::coro {
+sub cf::client::async {
    my ($self, $cb) = @_;
-   my $coro = &Coro::async_pool ($cb);
+   my $coro = &Coro::async ($cb);
    $coro->on_destroy (sub {
       delete $self->{_coro}{$coro+0};
    });
 sub main {
    # we must not ever block the main coroutine
    local $Coro::idle = sub {
       Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#
-      Coro::async_pool { Event::one_event };
+      async { Event::one_event };
    };
    cfg_load;
    db_load;
    load_extensions;
       cf::load_extensions;
       # reattach attachments to objects
       warn "reattach";
       _global_reattach;
+      reattach $_ for values %MAP;
    };
    if ($@) {
       warn $@;
       warn "error while reloading, exiting.";
    $LINK_MAP->{path} = bless { path => "{link}" }, "cf::path";
    $LINK_MAP->in_memory (MAP_IN_MEMORY);
    # dirty hack because... archetypes are not yet loaded
    Event->timer (
-      after => 2,
+      after => 10,
       cb    => sub {
          $_[0]->w->cancel;
          # provide some exits "home"
          my $exit = cf::object::new "exit";

Diff Legend

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

Comparing cf.schmorp.de/server/lib/cf.pm (file contents): Revision 1.139 by root, Fri Jan 5 19:12:03 2007 UTC vs. Revision 1.146 by root, Sun Jan 7 23:10:43 2007 UTC

Diff Legend

Comparing cf.schmorp.de/server/lib/cf.pm (file contents):
Revision 1.139 by root, Fri Jan 5 19:12:03 2007 UTC vs.
Revision 1.146 by root, Sun Jan 7 23:10:43 2007 UTC