--- deliantra/server/ext/map-scheduler.ext	2007/06/10 04:05:47	1.35
+++ deliantra/server/ext/map-scheduler.ext	2007/08/24 01:12:11	1.41
@@ -1,4 +1,4 @@
-#! perl # MANDATORY
+#! perl # mandatory
 
 # this extension swaps out maps and resets them, in essence managing
 # the reset/swap policy of the server.
@@ -19,17 +19,15 @@
    # because old files will get cleaned up on reset time
    Coro::Timer::sleep 0.25;
 
-   for my $map (@{ cf::map::tmp_maps or [] }) {
-      cf::map::find $map;
-      cf::wait_for_tick; Coro::cede;
+   for my $path (@{ cf::map::tmp_maps or [] }, @{ cf::map::random_maps or [] }) {
+      cf::cede_to_tick;
+      cf::map::find $path;
    }
 
-   #TODO: should also preload random maps...
-
    # now hunt for resettable per-player maps
    for my $login (@{ cf::player::list_logins or [] }) {
       for my $path (@{ cf::player::maps $login or [] }) {
-         Coro::cede;
+         cf::cede_to_tick;
 
          $path =~ /^~[^\/]+(\/.*)$/
             or next; # doh
@@ -44,7 +42,6 @@
          next if $base->{deny_reset};
 
          my $map = cf::map::find $path;
-         cf::wait_for_tick;
 
          if ($map->{deny_reset}) {
             warn "found noreset map with resettable base map, resetting: $path\n";
@@ -55,9 +52,11 @@
 };
 
 our $SCHEDULER = cf::async_ext {
+   my $timer = Coro::Event->timer (after => 1);
+
    while () {
-      Coro::Event::do_timer (after => $SCHEDULE_INTERVAL)
-         unless $cf::LOADAVG > $SWAP_LOAD2;
+      $timer->interval ($SCHEDULE_INTERVAL);
+      $timer->next unless $cf::LOADAVG > $SWAP_LOAD2;
 
       # this weird form of iteration over values is used because
       # the hash changes underneath us frequently, and for
@@ -79,14 +78,14 @@
             if ($map->should_reset) {
                $map->reset;
             } elsif ($map->in_memory == cf::MAP_IN_MEMORY) {
-               my $max_idle = cf::clamp +(cf::lerp $cf::LOADAVG, $SWAP_LOAD1, $SWAP_LOAD2, $SWAP_TIMEOUT, 0), 0, $SWAP_TIMEOUT;
+               my $max_idle = cf::clamp +(cf::lerp $cf::LOADAVG, $SWAP_LOAD1, $SWAP_LOAD2, $SWAP_TIMEOUT, $cf::TICK * 1.5),
+                                        $cf::TICK * 1.5, $SWAP_TIMEOUT;
 
                if ($map->last_access + $max_idle <= $cf::RUNTIME && !$map->players) {
                   $map->swap_out;
-                  cf::wait_for_tick unless $cf::LOADAVG > $SWAP_LOAD2;
                } elsif ($map->{last_save} + $SAVE_TIMEOUT <= $cf::RUNTIME) {
                   $map->save;
-                  cf::wait_for_tick unless $cf::LOADAVG > $SWAP_LOAD2;
+                  $map->{last_save} -= rand; # randomise map save times a bit
                }
             }
          };