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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC vs.
Revision 1.265 by root, Fri May 11 08:00:00 2007 UTC

 our $LINK_MAP; # the special {link} map, which is always available
 # used to convert map paths into valid unix filenames by replacing / by ∕
 our $PATH_SEP = "∕"; # U+2215, chosen purely for visual reasons
+our $LOAD;       # a number between 0 (idle) and 1 (too many objects)
+our $LOADAVG;    # same thing, but with alpha-smoothing
+our $tick_start; # for load detecting purposes
 binmode STDOUT;
 binmode STDERR;
 # read virtual server time, if available
 unless ($RUNTIME || !-e "$LOCALDIR/runtime") {
 The time of the last (current) server tick.
 =item $cf::TICK
 The interval between server ticks, in seconds.
+=item $cf::LOADAVG
+The current CPU load on the server (alpha-smoothed), as a value between 0
+(none) and 1 (overloaded), indicating how much time is spent on processing
+objects per tick. Healthy values are < 0.5.
+=item $cf::LOAD
+The raw value load value from the last tick.
 =item %cf::CFG
 Configuration for the server, loaded from C</etc/crossfire/config>, or
 from wherever your confdir points to.
 sub sync_job(&) {
    my ($job) = @_;
    if ($Coro::current == $Coro::main) {
+      my $time = Event::time;
       # this is the main coro, too bad, we have to block
       # till the operation succeeds, freezing the server :/
       # TODO: use suspend/resume instead
       # (but this is cancel-safe)
       while ($busy) {
          Coro::cede or Event::one_event;
       }
+      $time = Event::time - $time;
+      LOG llevError | logBacktrace, "long sync job\n"
+         if $time > $TICK * 0.5;
+      $tick_start += $time; # do not account sync jobs to server load
       wantarray ? @res : $res[0]
    } else {
       # we are in another coroutine, how wonderful, everything just works
       $job->()
    $coro
 }
 sub write_runtime {
+   my $runtime = "$LOCALDIR/runtime";
+   # first touch the runtime file to show we are still running:
+   # the fsync below can take a very very long time.
+   if (my $fh = aio_open $runtime, O_WRONLY, 0) {
+      utime undef, undef, $fh;
+   }
    my $guard = cf::lock_acquire "write_runtime";
-   my $runtime = "$LOCALDIR/runtime";
    my $fh = aio_open "$runtime~", O_WRONLY | O_CREAT, 0644
       or return;
    my $value = $cf::RUNTIME + 90 + 10;
    # always fsync - this file is important
    aio_fsync $fh
       and return;
+   # touch it again to show we are up-to-date
+   utime undef, undef, $fh;
    close $fh
       or return;
    aio_rename "$runtime~", $runtime
       and return;
+   warn "runtime file written.\n";#d#
    1
 }
 =item cf::datalog type => key => value, ...
          Coro::cede;
          $self->activate;
       }
       $self->in_memory (cf::MAP_IN_MEMORY);
-      undef $guard;
    }
    $self->post_load;
 }
       die $$res unless "ARRAY" eq ref $res;
       return wantarray ? @$res : $res->[-1];
    } else {
+      reset_signals;
       local $SIG{__WARN__};
+      local $SIG{__DIE__};
       eval {
-         local $SIG{__DIE__};
          close $fh1;
          my @res = eval { $cb->(@args) };
          syswrite $fh2, Coro::Storable::freeze +($@ ? \"$@" : \@res);
       };
          Carp::cluck "major BUG: server tick called outside of main coro, skipping it"
             unless ++$bug_warning > 10;
          return;
       }
-      $NOW = Event::time;
+      $NOW = $tick_start = Event::time;
       cf::server_tick; # one server iteration
       $RUNTIME   += $TICK;
       $NEXT_TICK += $TICK;
       }
 #      my $AFTER = Event::time;
 #      warn $AFTER - $NOW;#d#
+      if (my $sig = shift @WAIT_FOR_TICK_BEGIN) {
+         $sig->send;
+      }
+      while (my $sig = shift @WAIT_FOR_TICK) {
+         $sig->send;
+      }
+      $NOW = Event::time;
       # if we are delayed by four ticks or more, skip them all
-      $NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;
+      $NEXT_TICK = $NOW if $NOW >= $NEXT_TICK + $TICK * 4;
       $TICK_WATCHER->at ($NEXT_TICK);
       $TICK_WATCHER->start;
-      if (my $sig = shift @WAIT_FOR_TICK_BEGIN) {
+      $LOAD = ($NOW - $tick_start) / $TICK;
-         $sig->send;
+      $LOADAVG = $LOADAVG * 0.75 + $LOAD * 0.25;
-      }
-      while (my $sig = shift @WAIT_FOR_TICK) {
-         $sig->send;
-      }
       _post_tick;
    },
 );
 {
    BDB::max_poll_time $TICK * 0.1;
       prio      => 6,
       cb        => \&IO::AIO::poll_cb,
    );
 }
+my $_log_backtrace;
+sub _log_backtrace {
+   my ($msg, @addr) = @_;
+   $msg =~ s/\n//;
+   # limit the # of concurrent backtraces
+   if ($_log_backtrace < 2) {
+      ++$_log_backtrace;
+      async {
+         my @bt = fork_call {
+            @addr = map { sprintf "%x", $_ } @addr;
+            my $self = (-f "/proc/$$/exe") ? "/proc/$$/exe" : $^X;
+            open my $fh, "exec addr2line -C -f -i -e \Q$self\E @addr 2>&1 |"
+               or die "addr2line: $!";
+            my @funcs;
+            my @res = <$fh>;
+            chomp for @res;
+            while (@res) {
+               my ($func, $line) = splice @res, 0, 2, ();
+               push @funcs, "[$func] $line";
+            }
+            @funcs
+         };
+         LOG llevInfo, "[ABT] $msg\n";
+         LOG llevInfo, "[ABT] $_\n" for @bt;
+         --$_log_backtrace;
+      };
+   } else {
+      LOG llevInfo, "[ABT] $msg\n";
+      LOG llevInfo, "[ABT] [suppressed]\n";
+   }
+}
 # load additional modules
 use cf::pod;
 END { cf::emergency_save }

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC vs. Revision 1.265 by root, Fri May 11 08:00:00 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC vs.
Revision 1.265 by root, Fri May 11 08:00:00 2007 UTC