--- deliantra/server/lib/cf.pm	2008/09/30 04:00:35	1.456
+++ deliantra/server/lib/cf.pm	2008/10/01 05:50:19	1.457
@@ -132,6 +132,8 @@
 
 our @POST_INIT;
 
+our $REATTACH_ON_RELOAD; # ste to true to force object reattach on reload (slow)
+
 binmode STDOUT;
 binmode STDERR;
 
@@ -1191,7 +1193,7 @@
             aio_rename "$filename~", $filename;
 
             $filename =~ s%/[^/]+$%%;
-            aio_pathsync $filename;
+            aio_pathsync $filename if $cf::USE_FSYNC;
          } else {
             warn "FATAL: $filename~: $!\n";
          }
@@ -1294,6 +1296,8 @@
    $EXTICMD{$name} = $cb;
 }
 
+use File::Glob ();
+
 cf::player->attach (
    on_command => sub {
       my ($pl, $name, $params) = @_;
@@ -1335,6 +1339,19 @@
    },
 );
 
+# "readahead" all extensions
+sub cache_extensions {
+   my $grp = IO::AIO::aio_group;
+
+   add $grp IO::AIO::aio_readdir $LIBDIR, sub {
+      for (grep /\.ext$/, @{$_[0]}) {
+         add $grp IO::AIO::aio_load "$LIBDIR/$_", my $data;
+      }
+   };
+
+   $grp
+}
+
 sub load_extensions {
    cf::sync_job {
       my %todo;
@@ -3560,39 +3577,49 @@
 sub emergency_save() {
    my $freeze_guard = cf::freeze_mainloop;
 
-   warn "enter emergency perl save\n";
+   warn "emergency_perl_save: enter\n";
 
    cf::sync_job {
+      # this is a trade-off: we want to be very quick here, so
+      # save all maps without fsync, and later call a global sync
+      # (which in turn might be very very slow)
+      local $USE_FSYNC = 0;
+
       # use a peculiar iteration method to avoid tripping on perl
       # refcount bugs in for. also avoids problems with players
       # and maps saved/destroyed asynchronously.
-      warn "begin emergency player save\n";
+      warn "emergency_perl_save: begin player save\n";
       for my $login (keys %cf::PLAYER) {
          my $pl = $cf::PLAYER{$login} or next;
          $pl->valid or next;
          delete $pl->{unclean_save}; # not strictly necessary, but cannot hurt
          $pl->save;
       }
-      warn "end emergency player save\n";
+      warn "emergency_perl_save: end player save\n";
 
-      warn "begin emergency map save\n";
+      warn "emergency_perl_save: begin map save\n";
       for my $path (keys %cf::MAP) {
          my $map = $cf::MAP{$path} or next;
          $map->valid or next;
          $map->save;
       }
-      warn "end emergency map save\n";
+      warn "emergency_perl_save: end map save\n";
 
-      warn "begin emergency database checkpoint\n";
+      warn "emergency_perl_save: begin database checkpoint\n";
       BDB::db_env_txn_checkpoint $DB_ENV;
-      warn "end emergency database checkpoint\n";
+      warn "emergency_perl_save: end database checkpoint\n";
 
-      warn "begin write uuid\n";
+      warn "emergency_perl_save: begin write uuid\n";
       write_uuid_sync 1;
-      warn "end write uuid\n";
+      warn "emergency_perl_save: end write uuid\n";
    };
 
-   warn "leave emergency perl save\n";
+   warn "emergency_perl_save: starting sync()\n";
+   IO::AIO::aio_sync sub {
+      warn "emergency_perl_save: finished sync()\n";
+   };
+
+   warn "emergency_perl_save: leave\n";
 }
 
 sub post_cleanup {
@@ -3640,6 +3667,8 @@
 
    return if $RELOAD++;
 
+   my $t1 = EV::time;
+
    while ($RELOAD) {
       warn "reloading...";
 
@@ -3727,14 +3756,16 @@
          warn "loading extensions";
          cf::load_extensions;
 
-         warn "reattaching attachments to objects/players";
-         _global_reattach; # objects, sockets
-         warn "reattaching attachments to maps";
-         reattach $_ for values %MAP;
-         warn "reattaching attachments to players";
-         reattach $_ for values %PLAYER;
+         if ($REATTACH_ON_RELOAD) {
+            warn "reattaching attachments to objects/players";
+            _global_reattach; # objects, sockets
+            warn "reattaching attachments to maps";
+            reattach $_ for values %MAP;
+            warn "reattaching attachments to players";
+            reattach $_ for values %PLAYER;
+         }
 
-         warn "running post_load";
+         warn "running post_init jobs";
          (pop @POST_INIT)->(1) while @POST_INIT;
 
          warn "leaving sync_job";
@@ -3748,6 +3779,9 @@
       warn "reloaded";
       --$RELOAD;
    }
+
+   $t1 = EV::time - $t1;
+   warn "reload completed in ${t1}s\n";
 };
 
 our $RELOAD_WATCHER; # used only during reload
@@ -3756,9 +3790,13 @@
    # doing reload synchronously and two reloads happen back-to-back,
    # coro crashes during coro_state_free->destroy here.
 
-   $RELOAD_WATCHER ||= EV::timer $TICK * 1.5, 0, sub {
-      do_reload_perl;
-      undef $RELOAD_WATCHER;
+   $RELOAD_WATCHER ||= cf::async {
+      Coro::AIO::aio_wait cache_extensions;
+
+      $RELOAD_WATCHER = EV::timer $TICK * 1.5, 0, sub {
+         do_reload_perl;
+         undef $RELOAD_WATCHER;
+      };
    };
 }