server/ext/00_map_handling.ext

#! perl

# why this is an extension is a good question. next question.

use Fcntl;

use Coro;
use Coro::AIO;

our $emergency_position = $cf::CFG{emergency_position} || ["/world/world_105_115", 5, 37];

our $DEACTIVATE_TIMEOUT =   60; # number of seconds after which maps get deactivated to save cpu
our $SWAP_TIMEOUT       =  600; # number of seconds after which maps inactive get swapped out
our $SCHEDULE_INTERVAL  =    8; # time the map scheduler sleeps between runs
our $SAVE_TIMEOUT       =   60; # save maps every n seconds
our $SAVE_INTERVAL      =  0.4; # save at max. one map every $SAVE_HOLD
our $MAX_RESET          = 7200;

$DEACTIVATE_TIMEOUT = 3;#d#
$SWAP_TIMEOUT = 5;#d#
$SCHEDULE_INTERVAL = 1;

our $SCHEDULER = cf::coro {
   while () {
      Coro::Timer::sleep $SCHEDULE_INTERVAL;

      for my $map (values %cf::MAP) {
         eval {
            next if $map->in_memory != cf::MAP_IN_MEMORY;
            next if $map->players;
            my $last_access = $map->last_access;
            # not yet, because maps might become visible to players nearby
            # we need a tiled meta map for this to work
#         if ($last_access + $DEACTIVATE_TIMEOUT <= $cf::RUNTIME) {
#            $map->deactivate;
#            delete $map->{active};
#         }
            if ($map->should_reset) {
               $map->reset;
            } elsif ($last_access + $SWAP_TIMEOUT <= $cf::RUNTIME) {
               $map->swap_out;
               Coro::Timer::sleep $SAVE_INTERVAL;
            } elsif ($map->{last_save} + $SAVE_TIMEOUT <= $cf::RUNTIME) {
               $map->save;
               Coro::Timer::sleep $SAVE_INTERVAL;
            }
         };
         warn $@ if $@;
         cede;
      }
   }
};
$SCHEDULER->prio (-2);

sub generate_random_map {
   my ($path, $rmp) = @_;

   # mit "rum" bekleckern, nicht
   cf::map::_create_random_map
      $path,
      $rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
      $rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},
      $rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
      $rmp->{exit_on_final_map},
      $rmp->{xsize}, $rmp->{ysize},
      $rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
      $rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
      $rmp->{dungeon_level}, $rmp->{dungeon_depth}, $rmp->{decoroptions}, $rmp->{orientation},
      $rmp->{origin_y}, $rmp->{origin_x}, $rmp->{random_seed}, $rmp->{total_map_hp},
      $rmp->{map_layout_style}, $rmp->{treasureoptions}, $rmp->{symmetry_used},
      (cf::region::find $rmp->{region})
}

sub parse_random_map_params {
   my ($spec) = @_;

   my $rmp = { # defaults
      xsize => 10,
      ysize => 10,
   };

   for (split /\n/, $spec) {
      my ($k, $v) = split /\s+/, $_, 2;

      $rmp->{lc $k} = $v if (length $k) && (length $v);
   }

   $rmp
}

sub prepare_random_map {
   my ($exit) = @_;

   # all this does is basically replace the /! path by
   # a new random map path (?random/...) with a seed
   # that depends on the exit object

   my $rmp = parse_random_map_params $exit->msg;

   if ($exit->map) {
      $rmp->{region}     = $exit->map->region_name;
      $rmp->{origin_map} = $exit->map->path;
      $rmp->{origin_x}   = $exit->x;
      $rmp->{origin_y}   = $exit->y;
   }

   $rmp->{random_seed} ||= $exit->random_seed;

   my $data = cf::to_json $rmp;
   my $md5 = Digest::MD5::md5_hex $data;

   if (my $fh = aio_open "$cf::RANDOM_MAPS/$md5.meta", O_WRONLY | O_CREAT, 0666) {
      aio_write $fh, 0, (length $data), $data, 0;

      $exit->slaying ("?random/$md5");
      $exit->msg (undef);
   }
}

# and all this just because we cannot iterate over
# all maps in C++...
sub cf::map::change_all_map_light {
   my ($change) = @_;

   $_->change_map_light ($change) for values %cf::MAP;
}

sub try_load_header($) {
   my ($path) = @_;

   utf8::encode $path;
   aio_open $path, O_RDONLY, 0
      or return;

   my $map = cf::map::new
      or return;

   $map->load_header ($path)
     or return;

   $map->{load_path} = $path;
   use Data::Dumper; warn Dumper $map;#d#

   $map
}

sub cf::map::find_map {
   my ($path, $origin) = @_;

   #warn "find_map<$path,$origin>\n";#d#

   $path = ref $path ? $path : new cf::path $path, $origin && $origin->path;
   my $key = $path->as_string;

   $cf::MAP{$key} || do {
      # do it the slow way
      my $map = try_load_header $path->save_path;

      if ($map) {
         # safety
         $map->{reset_time} = $cf::RUNTIME + $MAX_RESET
            if $map->{reset_time} > $cf::RUNTIME + $MAX_RESET;
      } else {
         if (my $rmp = $path->random_map_params) {
            $map = generate_random_map $key, $rmp;
         } else {
            $map = try_load_header $path->load_path;
         }

         $map or return;

         $map->{reset_time} = $cf::RUNTIME + ($map->reset_timeout || 3600);
         $map->instantiate;

         # per-player maps become, after loading, normal maps
         $map->per_player (0) if $path->{user_rel};
      }

      $map->path ($key);
      $map->{path} = $path;
      $map->last_access ($cf::RUNTIME);

      $map->reset if $map->should_reset;

      $cf::MAP{$key} = $map
   }
}

sub cf::map::load {
   my ($self) = @_;

   return if $self->in_memory != cf::MAP_SWAPPED;

   $self->in_memory (cf::MAP_LOADING);

   my $path = $self->{path};

   $self->alloc;
   $self->load_objects ($self->{load_path}, 1)
      or return;

   if (my $uniq = $path->uniq_path) {
      utf8::encode $uniq;
      if (aio_open $uniq, O_RDONLY, 0) {
         $self->clear_unique_items;
         $self->load_objects ($uniq, 0);
      }
   }

   # now do the right thing for maps
   $self->link_multipart_objects;

   unless ($self->{path}->is_style_map) {
      $self->fix_auto_apply;
      $self->decay_objects;
      $self->update_buttons;
      $self->set_darkness_map;
      $self->difficulty ($self->estimate_difficulty)
         unless $self->difficulty;
      $self->activate;
   }

   $self->in_memory (cf::MAP_IN_MEMORY);
}

sub cf::map::load_map_sync {
   my ($path, $origin) = @_;

   #warn "load_map_sync<$path, $origin>\n";#d#

   cf::sync_job {
      my $map = cf::map::find_map $path, $origin
         or return;
      $map->load;
      $map
   }
}

sub cf::map::save {
   my ($self) = @_;

   my $save = $self->{path}->save_path; utf8::encode $save;
   my $uniq = $self->{path}->uniq_path; utf8::encode $uniq;

   $self->{last_save} = $cf::RUNTIME;

   return unless $self->dirty;

   $self->{load_path} = $save;

   return if $self->{path}->is_style_map;

   warn "saving map ", $self->path;

   if ($uniq) {
      $self->save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS);
      $self->save_objects ($uniq, cf::IO_UNIQUES);
   } else {
      $self->save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS | cf::IO_UNIQUES);
   }
}

sub cf::map::swap_out {
   my ($self) = @_;

   return if $self->players;
   return if $self->in_memory != cf::MAP_IN_MEMORY;

   $self->save;
   $self->clear;
   $self->in_memory (cf::MAP_SWAPPED);
}

sub cf::map::should_reset {
   my ($map) = @_;

   # TODO: safety, remove and allow resettable per-player maps
   return if $map->{path}{user_rel};#d#
   #return unless $map->reset_timeout;

   my $time = $map->fixed_resettime ? $map->{reset_time} : $map->last_access;

   $time < $cf::RUNTIME
}

sub cf::map::reset {
   my ($self) = @_;

   return if $self->players;
   return if $self->{path}{user_rel};#d#

   warn "resetting map ", $self->path;#d#
   return;#d#

   utf8::encode (my $save = $self->{path}->save_path);
   aioreq_pri 3; IO::AIO::aio_unlink $save;
   aioreq_pri 3; IO::AIO::aio_unlink "$save.pst";

   $self->clear;
   $self->in_memory (cf::MAP_SWAPPED);
   utf8::encode ($self->{load_path} = $self->{path}->load_path);
}

sub cf::object::player::enter_exit {
   my ($ob, $exit) = @_;

   return unless $ob->type == cf::PLAYER;

   my ($oldmap, $oldx, $oldy) = ($ob->map, $ob->x, $ob->y);

   $ob->enter_map ($LINK_MAP, 20, 20);
   $ob->deactivate_recursive;

   (Coro::async {
      my ($map, $x, $y);
      unless (eval {

         prepare_random_map $exit
            if $exit->slaying eq "/!";

         my $path = new cf::path $exit->slaying, $exit->map && $exit->map->path;

         $map = cf::map::find_map $path->as_string;
         $map = $map->customise_for ($ob) if $map;
         ($x, $y) = ($exit->stats->hp, $exit->stats->sp);

         unless ($map) {
            $ob->message ("The exit is closed", cf::NDI_UNIQUE | cf::NDI_RED);

            # restore original map position
            ($map, $x, $y) = ($oldmap, $oldx, $oldy);

            unless ($map) {
               $map = cf::map::find_map $emergency_position->[0]
                  or die "FATAL: cannot load emergency map\n";
               $x = $emergency_position->[1];
               $y = $emergency_position->[2];
            }
         }

         # use -1, -1 as default coordinates, not 0, 0
         ($x, $y) = ($map->enter_x, $map->enter_y)
            if $x <=0 && $y <= 0;

         warn "entering ", $map->path, " at ($x, $y)\n";#d#
         $map->load;
         1;
      }) {
         ($map, $x, $y) = ($oldmap, $oldx, $oldy);

         $ob->message ("Something went wrong deep within the crossfire server. "
                     . "I'll try to bring you back to the map you were before. "
                     . "Please report this to the dungeon master",
                       cf::NDI_UNIQUE | cf::NDI_RED);

         warn "ERROR in enter_exit: $@";
      }
      $ob->activate_recursive;
      $ob->enter_map ($map, $x, $y);
   })->prio (1);
}

sub cf::map::customise_for {
   my ($map, $ob) = @_;

   if ($map->per_player) {
      return cf::map::find_map "~" . $ob->name . "/" . $map->{path}{path};
   }

   $map
}

sub cf::map::emergency_save {
   local $cf::FREEZE = 1;

   warn "enter emergency map save\n";

   cf::sync_job {
      warn "begin emergency map save\n";
      $_->save for values %cf::MAP;
   };

   warn "end emergency map save\n";
}

Revision:	1.15
Committed:	Mon Jan 1 11:21:54 2007 UTC (17 years, 4 months ago) by root
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.14:	+0 -0 lines
State:	*FILE REMOVED*
Log Message:	- integrated most of the map/exit handling into cf.pm (it grows too large, should be split 'somehow', but thats not easy) - moved the swap/reste scheduler into an extension - imrpoved exit/sync logic
#	Content
1	#! perl
2
3	# why this is an extension is a good question. next question.
4
5	use Fcntl;
6
7	use Coro;
8	use Coro::AIO;
9
10	our $emergency_position = $cf::CFG{emergency_position} \|\| ["/world/world_105_115", 5, 37];
11
12	our $DEACTIVATE_TIMEOUT = 60; # number of seconds after which maps get deactivated to save cpu
13	our $SWAP_TIMEOUT = 600; # number of seconds after which maps inactive get swapped out
14	our $SCHEDULE_INTERVAL = 8; # time the map scheduler sleeps between runs
15	our $SAVE_TIMEOUT = 60; # save maps every n seconds
16	our $SAVE_INTERVAL = 0.4; # save at max. one map every $SAVE_HOLD
17	our $MAX_RESET = 7200;
18
19	$DEACTIVATE_TIMEOUT = 3;#d#
20	$SWAP_TIMEOUT = 5;#d#
21	$SCHEDULE_INTERVAL = 1;
22
23	our $SCHEDULER = cf::coro {
24	while () {
25	Coro::Timer::sleep $SCHEDULE_INTERVAL;
26
27	for my $map (values %cf::MAP) {
28	eval {
29	next if $map->in_memory != cf::MAP_IN_MEMORY;
30	next if $map->players;
31	my $last_access = $map->last_access;
32	# not yet, because maps might become visible to players nearby
33	# we need a tiled meta map for this to work
34	# if ($last_access + $DEACTIVATE_TIMEOUT <= $cf::RUNTIME) {
35	# $map->deactivate;
36	# delete $map->{active};
37	# }
38	if ($map->should_reset) {
39	$map->reset;
40	} elsif ($last_access + $SWAP_TIMEOUT <= $cf::RUNTIME) {
41	$map->swap_out;
42	Coro::Timer::sleep $SAVE_INTERVAL;
43	} elsif ($map->{last_save} + $SAVE_TIMEOUT <= $cf::RUNTIME) {
44	$map->save;
45	Coro::Timer::sleep $SAVE_INTERVAL;
46	}
47	};
48	warn $@ if $@;
49	cede;
50	}
51	}
52	};
53	$SCHEDULER->prio (-2);
54
55	sub generate_random_map {
56	my ($path, $rmp) = @_;
57
58	# mit "rum" bekleckern, nicht
59	cf::map::_create_random_map
60	$path,
61	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
62	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},
63	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
64	$rmp->{exit_on_final_map},
65	$rmp->{xsize}, $rmp->{ysize},
66	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
67	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
68	$rmp->{dungeon_level}, $rmp->{dungeon_depth}, $rmp->{decoroptions}, $rmp->{orientation},
69	$rmp->{origin_y}, $rmp->{origin_x}, $rmp->{random_seed}, $rmp->{total_map_hp},
70	$rmp->{map_layout_style}, $rmp->{treasureoptions}, $rmp->{symmetry_used},
71	(cf::region::find $rmp->{region})
72	}
73
74	sub parse_random_map_params {
75	my ($spec) = @_;
76
77	my $rmp = { # defaults
78	xsize => 10,
79	ysize => 10,
80	};
81
82	for (split /\n/, $spec) {
83	my ($k, $v) = split /\s+/, $_, 2;
84
85	$rmp->{lc $k} = $v if (length $k) && (length $v);
86	}
87
88	$rmp
89	}
90
91	sub prepare_random_map {
92	my ($exit) = @_;
93
94	# all this does is basically replace the /! path by
95	# a new random map path (?random/...) with a seed
96	# that depends on the exit object
97
98	my $rmp = parse_random_map_params $exit->msg;
99
100	if ($exit->map) {
101	$rmp->{region} = $exit->map->region_name;
102	$rmp->{origin_map} = $exit->map->path;
103	$rmp->{origin_x} = $exit->x;
104	$rmp->{origin_y} = $exit->y;
105	}
106
107	$rmp->{random_seed} \|\|= $exit->random_seed;
108
109	my $data = cf::to_json $rmp;
110	my $md5 = Digest::MD5::md5_hex $data;
111
112	if (my $fh = aio_open "$cf::RANDOM_MAPS/$md5.meta", O_WRONLY \| O_CREAT, 0666) {
113	aio_write $fh, 0, (length $data), $data, 0;
114
115	$exit->slaying ("?random/$md5");
116	$exit->msg (undef);
117	}
118	}
119
120	# and all this just because we cannot iterate over
121	# all maps in C++...
122	sub cf::map::change_all_map_light {
123	my ($change) = @_;
124
125	$_->change_map_light ($change) for values %cf::MAP;
126	}
127
128	sub try_load_header($) {
129	my ($path) = @_;
130
131	utf8::encode $path;
132	aio_open $path, O_RDONLY, 0
133	or return;
134
135	my $map = cf::map::new
136	or return;
137
138	$map->load_header ($path)
139	or return;
140
141	$map->{load_path} = $path;
142	use Data::Dumper; warn Dumper $map;#d#
143
144	$map
145	}
146
147	sub cf::map::find_map {
148	my ($path, $origin) = @_;
149
150	#warn "find_map<$path,$origin>\n";#d#
151
152	$path = ref $path ? $path : new cf::path $path, $origin && $origin->path;
153	my $key = $path->as_string;
154
155	$cf::MAP{$key} \|\| do {
156	# do it the slow way
157	my $map = try_load_header $path->save_path;
158
159	if ($map) {
160	# safety
161	$map->{reset_time} = $cf::RUNTIME + $MAX_RESET
162	if $map->{reset_time} > $cf::RUNTIME + $MAX_RESET;
163	} else {
164	if (my $rmp = $path->random_map_params) {
165	$map = generate_random_map $key, $rmp;
166	} else {
167	$map = try_load_header $path->load_path;
168	}
169
170	$map or return;
171
172	$map->{reset_time} = $cf::RUNTIME + ($map->reset_timeout \|\| 3600);
173	$map->instantiate;
174
175	# per-player maps become, after loading, normal maps
176	$map->per_player (0) if $path->{user_rel};
177	}
178
179	$map->path ($key);
180	$map->{path} = $path;
181	$map->last_access ($cf::RUNTIME);
182
183	$map->reset if $map->should_reset;
184
185	$cf::MAP{$key} = $map
186	}
187	}
188
189	sub cf::map::load {
190	my ($self) = @_;
191
192	return if $self->in_memory != cf::MAP_SWAPPED;
193
194	$self->in_memory (cf::MAP_LOADING);
195
196	my $path = $self->{path};
197
198	$self->alloc;
199	$self->load_objects ($self->{load_path}, 1)
200	or return;
201
202	if (my $uniq = $path->uniq_path) {
203	utf8::encode $uniq;
204	if (aio_open $uniq, O_RDONLY, 0) {
205	$self->clear_unique_items;
206	$self->load_objects ($uniq, 0);
207	}
208	}
209
210	# now do the right thing for maps
211	$self->link_multipart_objects;
212
213	unless ($self->{path}->is_style_map) {
214	$self->fix_auto_apply;
215	$self->decay_objects;
216	$self->update_buttons;
217	$self->set_darkness_map;
218	$self->difficulty ($self->estimate_difficulty)
219	unless $self->difficulty;
220	$self->activate;
221	}
222
223	$self->in_memory (cf::MAP_IN_MEMORY);
224	}
225
226	sub cf::map::load_map_sync {
227	my ($path, $origin) = @_;
228
229	#warn "load_map_sync<$path, $origin>\n";#d#
230
231	cf::sync_job {
232	my $map = cf::map::find_map $path, $origin
233	or return;
234	$map->load;
235	$map
236	}
237	}
238
239	sub cf::map::save {
240	my ($self) = @_;
241
242	my $save = $self->{path}->save_path; utf8::encode $save;
243	my $uniq = $self->{path}->uniq_path; utf8::encode $uniq;
244
245	$self->{last_save} = $cf::RUNTIME;
246
247	return unless $self->dirty;
248
249	$self->{load_path} = $save;
250
251	return if $self->{path}->is_style_map;
252
253	warn "saving map ", $self->path;
254
255	if ($uniq) {
256	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS);
257	$self->save_objects ($uniq, cf::IO_UNIQUES);
258	} else {
259	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS \| cf::IO_UNIQUES);
260	}
261	}
262
263	sub cf::map::swap_out {
264	my ($self) = @_;
265
266	return if $self->players;
267	return if $self->in_memory != cf::MAP_IN_MEMORY;
268
269	$self->save;
270	$self->clear;
271	$self->in_memory (cf::MAP_SWAPPED);
272	}
273
274	sub cf::map::should_reset {
275	my ($map) = @_;
276
277	# TODO: safety, remove and allow resettable per-player maps
278	return if $map->{path}{user_rel};#d#
279	#return unless $map->reset_timeout;
280
281	my $time = $map->fixed_resettime ? $map->{reset_time} : $map->last_access;
282
283	$time < $cf::RUNTIME
284	}
285
286	sub cf::map::reset {
287	my ($self) = @_;
288
289	return if $self->players;
290	return if $self->{path}{user_rel};#d#
291
292	warn "resetting map ", $self->path;#d#
293	return;#d#
294
295	utf8::encode (my $save = $self->{path}->save_path);
296	aioreq_pri 3; IO::AIO::aio_unlink $save;
297	aioreq_pri 3; IO::AIO::aio_unlink "$save.pst";
298
299	$self->clear;
300	$self->in_memory (cf::MAP_SWAPPED);
301	utf8::encode ($self->{load_path} = $self->{path}->load_path);
302	}
303
304	sub cf::object::player::enter_exit {
305	my ($ob, $exit) = @_;
306
307	return unless $ob->type == cf::PLAYER;
308
309	my ($oldmap, $oldx, $oldy) = ($ob->map, $ob->x, $ob->y);
310
311	$ob->enter_map ($LINK_MAP, 20, 20);
312	$ob->deactivate_recursive;
313
314	(Coro::async {
315	my ($map, $x, $y);
316	unless (eval {
317
318	prepare_random_map $exit
319	if $exit->slaying eq "/!";
320
321	my $path = new cf::path $exit->slaying, $exit->map && $exit->map->path;
322
323	$map = cf::map::find_map $path->as_string;
324	$map = $map->customise_for ($ob) if $map;
325	($x, $y) = ($exit->stats->hp, $exit->stats->sp);
326
327	unless ($map) {
328	$ob->message ("The exit is closed", cf::NDI_UNIQUE \| cf::NDI_RED);
329
330	# restore original map position
331	($map, $x, $y) = ($oldmap, $oldx, $oldy);
332
333	unless ($map) {
334	$map = cf::map::find_map $emergency_position->[0]
335	or die "FATAL: cannot load emergency map\n";
336	$x = $emergency_position->[1];
337	$y = $emergency_position->[2];
338	}
339	}
340
341	# use -1, -1 as default coordinates, not 0, 0
342	($x, $y) = ($map->enter_x, $map->enter_y)
343	if $x <=0 && $y <= 0;
344
345	warn "entering ", $map->path, " at ($x, $y)\n";#d#
346	$map->load;
347	1;
348	}) {
349	($map, $x, $y) = ($oldmap, $oldx, $oldy);
350
351	$ob->message ("Something went wrong deep within the crossfire server. "
352	. "I'll try to bring you back to the map you were before. "
353	. "Please report this to the dungeon master",
354	cf::NDI_UNIQUE \| cf::NDI_RED);
355
356	warn "ERROR in enter_exit: $@";
357	}
358	$ob->activate_recursive;
359	$ob->enter_map ($map, $x, $y);
360	})->prio (1);
361	}
362
363	sub cf::map::customise_for {
364	my ($map, $ob) = @_;
365
366	if ($map->per_player) {
367	return cf::map::find_map "~" . $ob->name . "/" . $map->{path}{path};
368	}
369
370	$map
371	}
372
373	sub cf::map::emergency_save {
374	local $cf::FREEZE = 1;
375
376	warn "enter emergency map save\n";
377
378	cf::sync_job {
379	warn "begin emergency map save\n";
380	$_->save for values %cf::MAP;
381	};
382
383	warn "end emergency map save\n";
384	}
385