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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.615 by root, Sat Feb 23 22:37:39 2013 UTC vs.
Revision 1.622 by root, Wed Nov 23 06:05:33 2016 UTC

 use JSON::XS 2.01 ();
 use BDB ();
 use Data::Dumper;
 use Fcntl;
 use YAML::XS ();
+use CBOR::XS ();
 use IO::AIO ();
 use Compress::LZF;
 use Digest::MD5 ();
 AnyEvent::detect;
 =item $cf::RUNTIME
 The time this server has run, starts at 0 and is increased by $cf::TICK on
 every server tick.
-=item $cf::CONFDIR $cf::DATADIR $cf::LIBDIR  $cf::PODDIR
+=item $cf::CONFDIR $cf::DATADIR $cf::LIBDIR $cf::PODDIR
 $cf::MAPDIR $cf::LOCALDIR $cf::TMPDIR $cf::UNIQUEDIR
 $cf::PLAYERDIR $cf::RANDOMDIR $cf::BDBDIR
 Various directories - "/etc", read-only install directory, perl-library
 directory, pod-directory, read-only maps directory, "/var", "/var/tmp",
 sub decode_yaml($) {
    fork_call { YAML::XS::Load $_[0] } @_
 }
+=item $scalar = cf::decode_cbor $scalar
+Same as CBOR::XS::decode_cbor, but takes server ticks into account, so
+blocks. For small amounts of data, C<CBOR::XS::decode_cbor> is the better
+alternative.
+=cut
+sub decode_cbor($) {
+   # we assume 10mb/s minimum decoding speed (on a ~2ghz machine)
+   cf::get_slot +(length $_[0]) / 10_000_000, 0, "decode_cbor";
+   CBOR::XS::decode_cbor $_[0]
+}
 =item $scalar = cf::unlzf $scalar
 Same as Compress::LZF::compress, but takes server ticks into account, so
 blocks.
    }
 }
 =item cf::lock_wait $string
 Wait until the given lock is available. See cf::lock_acquire.
 =item my $lock = cf::lock_acquire $string
 Wait until the given lock is available and then acquires it and returns
 a L<Guard> object. If the guard object gets destroyed (goes out of scope,
 BEGIN { *async = \&Coro::async_pool }
 =item cf::sync_job { BLOCK }
 The design of Deliantra requires that the main coroutine ($Coro::main)
-is always able to handle events or runnable, as Deliantra is only
+is always able to handle events or is runnable, as Deliantra is only
 partly reentrant. Thus "blocking" it by e.g. waiting for I/O is not
 acceptable.
 If it must be done, put the blocking parts into C<sync_job>. This will run
 the given BLOCK in another coroutine while waiting for the result. The
       while ($busy) {
          if (Coro::nready) {
             Coro::cede_notself;
          } else {
-            EV::loop EV::LOOP_ONESHOT;
+            EV::run EV::RUN_ONCE;
          }
       }
       my $time = AE::time - $time;
    $MAP_PREFETCHER ||= cf::async {
       $Coro::current->{desc} = "map prefetcher";
       while (%MAP_PREFETCH) {
-         while (my ($k, $v) = each %MAP_PREFETCH) {
+         for my $k (keys %MAP_PREFETCH) {
             if (my $map = find $k) {
-               $map->load if $v;
+               $map->load if $MAP_PREFETCH{$k};
             }
             delete $MAP_PREFETCH{$k};
          }
       }
    seek $fh, 0, 0;
    print $fh $$;
 }
 sub main_loop {
-   trace "EV::loop starting\n";
+   trace "EV::run starting\n";
    if (1) {
-      EV::loop;
+      EV::run;
    }
-   trace "EV::loop returned\n";
+   trace "EV::run returned\n";
    goto &main_loop unless $REALLY_UNLOOP;
 }
 sub main {
    cf::init_globals; # initialise logging
    # we must not ever block the main coroutine
    $Coro::idle = sub {
       Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#
       (async {
          $Coro::current->{desc} = "IDLE BUG HANDLER";
-         EV::loop EV::LOOP_ONESHOT;
+         EV::run EV::RUN_ONCE;
       })->prio (Coro::PRIO_MAX);
    };
    evthread_start IO::AIO::poll_fileno;

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.615 by root, Sat Feb 23 22:37:39 2013 UTC vs. Revision 1.622 by root, Wed Nov 23 06:05:33 2016 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.615 by root, Sat Feb 23 22:37:39 2013 UTC vs.
Revision 1.622 by root, Wed Nov 23 06:05:33 2016 UTC