--- deliantra/server/ext/map-scheduler.ext 2007/06/10 04:24:50 1.36 +++ deliantra/server/ext/map-scheduler.ext 2007/07/23 17:53:55 1.38 @@ -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. @@ -20,14 +20,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 +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"; @@ -53,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 @@ -81,10 +82,8 @@ 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; } } };