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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.104 by root, Sat Dec 30 16:56:16 2006 UTC vs.
Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC

 use Coro 3.3;
 use Coro::Event;
 use Coro::Timer;
 use Coro::Signal;
 use Coro::Semaphore;
+use Coro::AIO;
+use Fcntl;
-use IO::AIO 2.3;
+use IO::AIO 2.31 ();
 use YAML::Syck ();
 use Time::HiRes;
 use Event; $Event::Eval = 1; # no idea why this is required, but it is
 sub to_json($) {
    $JSON::Syck::ImplicitUnicode = 0;  # work around JSON::Syck bugs
    JSON::Syck::Dump $_[0]
 }
+# main coro must never ever "block" except in Event
+# sync_job ensures this by running the job in a coroutine
+# and waiting in Event while the server is otherwise frozen
+sub sync_job(&) {
+   my ($job) = @_;
+   my $busy = 1;
+   my @res;
+   local $FREEZE = 1;
+   my $coro = Coro::async {
+      @res = eval { $job->() };
+      warn $@ if $@;
+      undef $busy;
+   };
+   if ($Coro::current == $Coro::main) {
+      $coro->prio (Coro::PRIO_MAX);
+      while ($busy) {
+         Coro::cede_notself;
+         Event::one_event unless Coro::nready;
+      }
+   } else {
+      $coro->join;
+   }
+   wantarray ? @res : $res[0]
+}
 =item $coro = cf::coro { BLOCK }
 Creates and returns a new coro. This coro is automcatially being canceled
 when the extension calling this is being unloaded.
 );
 sub object_freezer_save {
    my ($filename, $rdata, $objs) = @_;
+   sync_job {
-   if (length $$rdata) {
+      if (length $$rdata) {
-      warn sprintf "saving %s (%d,%d)\n",
+         warn sprintf "saving %s (%d,%d)\n",
-         $filename, length $$rdata, scalar @$objs;
+            $filename, length $$rdata, scalar @$objs;
-      if (open my $fh, ">:raw", "$filename~") {
+         if (my $fh = aio_open "$filename~", O_WRONLY | O_CREAT, 0600) {
-         chmod SAVE_MODE, $fh;
-         syswrite $fh, $$rdata;
-         close $fh;
-         if (@$objs && open my $fh, ">:raw", "$filename.pst~") {
             chmod SAVE_MODE, $fh;
-            syswrite $fh, Storable::nfreeze { version => 1, objs => $objs };
+            aio_write $fh, 0, (length $$rdata), $$rdata, 0;
+            aio_fsync $fh;
             close $fh;
+            if (@$objs) {
+               if (my $fh = aio_open "$filename.pst~", O_WRONLY | O_CREAT, 0600) {
+                  chmod SAVE_MODE, $fh;
+                  my $data = Storable::nfreeze { version => 1, objs => $objs };
+                  aio_write $fh, 0, (length $data), $data, 0;
+                  aio_fsync $fh;
+                  close $fh;
-            rename "$filename.pst~", "$filename.pst";
+                  aio_rename "$filename.pst~", "$filename.pst";
+               }
+            } else {
+               aio_unlink "$filename.pst";
+            }
+            aio_rename "$filename~", $filename;
          } else {
-            unlink "$filename.pst";
+            warn "FATAL: $filename~: $!\n";
          }
-         rename "$filename~", $filename;
       } else {
-         warn "FATAL: $filename~: $!\n";
-      }
-   } else {
-      unlink $filename;
+         aio_unlink $filename;
-      unlink "$filename.pst";
+         aio_unlink "$filename.pst";
+      }
    }
 }
 sub object_freezer_as_string {
    my ($rdata, $objs) = @_;
 }
 sub object_thawer_load {
    my ($filename) = @_;
-   local $/;
+   my ($data, $av);
-   my $av;
+   (aio_load $filename, $data) >= 0
+      or return;
-   #TODO: use sysread etc.
+   unless (aio_stat "$filename.pst") {
-   if (open my $data, "<:raw:perlio", $filename) {
+      (aio_load "$filename.pst", $av) >= 0
-      $data = <$data>;
+         or return;
-      if (open my $pst, "<:raw:perlio", "$filename.pst") {
-         $av = eval { (Storable::thaw <$pst>)->{objs} };
+      $av = eval { (Storable::thaw <$av>)->{objs} };
-      }
+   }
-      return ($data, $av);
+   return ($data, $av);
-   }
-   ()
 }
 #############################################################################
 # command handling &c

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.104 by root, Sat Dec 30 16:56:16 2006 UTC vs. Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.104 by root, Sat Dec 30 16:56:16 2006 UTC vs.
Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC