--- deliantra/server/ext/map-scheduler.ext 2007/06/11 21:38:13 1.37 +++ deliantra/server/ext/map-scheduler.ext 2007/07/28 13:13:36 1.39 @@ -11,6 +11,9 @@ our $SWAP_LOAD1 = $cf::CFG{swap_load1} || .1; # start aggressively swapping at this load our $SWAP_LOAD2 = $cf::CFG{swap_load2} || .4; # swap as fast as possible at this load +warn "load1 ", $SWAP_LOAD1;#d# +warn "load2 ", $SWAP_LOAD2;#d# + cf::async_ext { $Coro::current->prio (Coro::PRIO_MIN); @@ -20,14 +23,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 +45,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 +55,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 @@ -81,10 +85,9 @@ 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 } } };