--- deliantra/server/ext/map-scheduler.ext 2007/06/11 21:38:13 1.37 +++ deliantra/server/ext/map-scheduler.ext 2007/09/19 21:57:26 1.43 @@ -12,6 +12,7 @@ our $SWAP_LOAD2 = $cf::CFG{swap_load2} || .4; # swap as fast as possible at this load cf::async_ext { + $Coro::current->{desc} = "startup map scanner"; $Coro::current->prio (Coro::PRIO_MIN); # load the header of swapped-out maps. @@ -20,14 +21,14 @@ Coro::Timer::sleep 0.25; for my $path (@{ cf::map::tmp_maps or [] }, @{ cf::map::random_maps or [] }) { + cf::cede_to_tick; cf::map::find $path; - cf::wait_for_tick; Coro::cede; } # 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 @@ -42,7 +43,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"; @@ -53,9 +53,12 @@ }; our $SCHEDULER = cf::async_ext { + $Coro::current->{desc} = "map scheduler"; + 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 @@ -77,14 +80,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 } } };