[ViewVC] Diff of: cvs/deliantra/server/lib/cf.pm

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.109 by root, Sun Dec 31 22:23:12 2006 UTC vs.
Revision 1.142 by root, Fri Jan 5 21:51:42 2007 UTC

…		…
8	use Storable;	8	use Storable;
9	use Opcode;	9	use Opcode;
10	use Safe;	10	use Safe;
11	use Safe::Hole;	11	use Safe::Hole;
12		12
13	use Coro 3.3;	13	use Coro 3.3 ();
14	use Coro::Event;	14	use Coro::Event;
15	use Coro::Timer;	15	use Coro::Timer;
16	use Coro::Signal;	16	use Coro::Signal;
17	use Coro::Semaphore;	17	use Coro::Semaphore;
18	use Coro::AIO;	18	use Coro::AIO;
…		…
26	use Event; $Event::Eval = 1; # no idea why this is required, but it is	26	use Event; $Event::Eval = 1; # no idea why this is required, but it is
27		27
28	# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?	28	# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?
29	$YAML::Syck::ImplicitUnicode = 1;	29	$YAML::Syck::ImplicitUnicode = 1;
30		30
31	$Coro::main->prio (2); # run main coroutine ("the server") with very high priority	31	$Coro::main->prio (Coro::PRIO_MAX); # run main coroutine ("the server") with very high priority
32		32
33	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload	33	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload
34		34
35	our %COMMAND = ();	35	our %COMMAND = ();
36	our %COMMAND_TIME = ();	36	our %COMMAND_TIME = ();
…		…
49	our $UPTIME; $UPTIME \|\|= time;	49	our $UPTIME; $UPTIME \|\|= time;
50	our $RUNTIME;	50	our $RUNTIME;
51		51
52	our %MAP; # all maps	52	our %MAP; # all maps
53	our $LINK_MAP; # the special {link} map	53	our $LINK_MAP; # the special {link} map
54	our $FREEZE;
55	our $RANDOM_MAPS = cf::localdir . "/random";	54	our $RANDOM_MAPS = cf::localdir . "/random";
56	our %EXT_CORO;	55	our %EXT_CORO;
57		56
58	binmode STDOUT;	57	binmode STDOUT;
59	binmode STDERR;	58	binmode STDERR;
…		…
71	mkdir cf::localdir . "/" . cf::uniquedir;	70	mkdir cf::localdir . "/" . cf::uniquedir;
72	mkdir $RANDOM_MAPS;	71	mkdir $RANDOM_MAPS;
73		72
74	# a special map that is always available	73	# a special map that is always available
75	our $LINK_MAP;	74	our $LINK_MAP;
		75	our $EMERGENCY_POSITION;
76		76
77	#############################################################################	77	#############################################################################
78		78
79	=head2 GLOBAL VARIABLES	79	=head2 GLOBAL VARIABLES
80		80
…		…
179	sub to_json($) {	179	sub to_json($) {
180	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs	180	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs
181	JSON::Syck::Dump $_[0]	181	JSON::Syck::Dump $_[0]
182	}	182	}
183		183
		184	=item cf::lock_wait $string
		185
		186	Wait until the given lock is available. See cf::lock_acquire.
		187
		188	=item my $lock = cf::lock_acquire $string
		189
		190	Wait until the given lock is available and then acquires it and returns
		191	a Coro::guard object. If the guard object gets destroyed (goes out of scope,
		192	for example when the coroutine gets canceled), the lock is automatically
		193	returned.
		194
		195	Lock names should begin with a unique identifier (for example, cf::map::find
		196	uses map_find and cf::map::load uses map_load).
		197
		198	=cut
		199
		200	our %LOCK;
		201
		202	sub lock_wait($) {
		203	my ($key) = @_;
		204
		205	# wait for lock, if any
		206	while ($LOCK{$key}) {
		207	push @{ $LOCK{$key} }, $Coro::current;
		208	Coro::schedule;
		209	}
		210	}
		211
		212	sub lock_acquire($) {
		213	my ($key) = @_;
		214
		215	# wait, to be sure we are not locked
		216	lock_wait $key;
		217
		218	$LOCK{$key} = [];
		219
		220	Coro::guard {
		221	# wake up all waiters, to be on the safe side
		222	$_->ready for @{ delete $LOCK{$key} };
		223	}
		224	}
		225
		226	sub freeze_mainloop {
		227	return unless $TICK_WATCHER->is_active;
		228
		229	my $guard = Coro::guard { $TICK_WATCHER->start };
		230	$TICK_WATCHER->stop;
		231	$guard
		232	}
		233
		234	=item cf::async { BLOCK }
		235
		236	Currently the same as Coro::async_pool, meaning you cannot use
		237	C<on_destroy>, C<join> or other gimmicks on these coroutines. The only
		238	thing you are allowed to do is call C<prio> on it.
		239
		240	=cut
		241
		242	BEGIN { *async = \&Coro::async_pool }
		243
184	=item cf::sync_job { BLOCK }	244	=item cf::sync_job { BLOCK }
185		245
186	The design of crossfire+ requires that the main coro ($Coro::main) is	246	The design of crossfire+ requires that the main coro ($Coro::main) is
187	always able to handle events or runnable, as crossfire+ is only partly	247	always able to handle events or runnable, as crossfire+ is only partly
188	reentrant. Thus "blocking" it by e.g. waiting for I/O is not acceptable.	248	reentrant. Thus "blocking" it by e.g. waiting for I/O is not acceptable.
…		…
195	=cut	255	=cut
196		256
197	sub sync_job(&) {	257	sub sync_job(&) {
198	my ($job) = @_;	258	my ($job) = @_;
199		259
200	my $busy = 1;
201	my @res;
202
203	# TODO: use suspend/resume instead
204	local $FREEZE = 1;
205
206	my $coro = Coro::async {
207	@res = eval { $job->() };
208	warn $@ if $@;
209	undef $busy;
210	};
211
212	if ($Coro::current == $Coro::main) {	260	if ($Coro::current == $Coro::main) {
		261	# this is the main coro, too bad, we have to block
		262	# till the operation succeeds, freezing the server :/
		263
		264	# TODO: use suspend/resume instead
		265	# (but this is cancel-safe)
		266	my $freeze_guard = freeze_mainloop;
		267
		268	my $busy = 1;
		269	my @res;
		270
		271	(async {
		272	@res = eval { $job->() };
		273	warn $@ if $@;
		274	undef $busy;
213	$coro->prio (Coro::PRIO_MAX);	275	})->prio (Coro::PRIO_MAX);
		276
214	while ($busy) {	277	while ($busy) {
215	Coro::cede_notself;	278	Coro::cede or Event::one_event;
216	Event::one_event unless Coro::nready;
217	}	279	}
		280
		281	wantarray ? @res : $res[0]
218	} else {	282	} else {
219	$coro->join;	283	# we are in another coroutine, how wonderful, everything just works
		284
		285	$job->()
220	}	286	}
221
222	wantarray ? @res : $res[0]
223	}	287	}
224		288
225	=item $coro = cf::coro { BLOCK }	289	=item $coro = cf::async_ext { BLOCK }
226		290
227	Creates and returns a new coro. This coro is automcatially being canceled	291	Like async, but this coro is automcatially being canceled when the
228	when the extension calling this is being unloaded.	292	extension calling this is being unloaded.
229		293
230	=cut	294	=cut
231		295
232	sub coro(&) {	296	sub async_ext(&) {
233	my $cb = shift;	297	my $cb = shift;
234		298
235	my $coro; $coro = async {	299	my $coro = &Coro::async ($cb);
236	eval {
237	$cb->();
238	};
239	warn $@ if $@;
240	};
241		300
242	$coro->on_destroy (sub {	301	$coro->on_destroy (sub {
243	delete $EXT_CORO{$coro+0};	302	delete $EXT_CORO{$coro+0};
244	});	303	});
245	$EXT_CORO{$coro+0} = $coro;	304	$EXT_CORO{$coro+0} = $coro;
…		…
251	my $runtime = cf::localdir . "/runtime";	310	my $runtime = cf::localdir . "/runtime";
252		311
253	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644	312	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644
254	or return;	313	or return;
255		314
256	my $value = $cf::RUNTIME;	315	my $value = $cf::RUNTIME + 1 + 10; # 10 is the runtime save interval, for a monotonic clock
257	(aio_write $fh, 0, (length $value), $value, 0) <= 0	316	(aio_write $fh, 0, (length $value), $value, 0) <= 0
258	and return;	317	and return;
259		318
260	aio_fsync $fh	319	aio_fsync $fh
261	and return;	320	and return;
…		…
278	package cf::path;	337	package cf::path;
279		338
280	sub new {	339	sub new {
281	my ($class, $path, $base) = @_;	340	my ($class, $path, $base) = @_;
282		341
		342	$path = $path->as_string if ref $path;
		343
283	my $self = bless { }, $class;	344	my $self = bless { }, $class;
284		345
		346	# {... are special paths that are not touched
		347	# ?xxx/... are special absolute paths
		348	# ?random/... random maps
		349	# /! non-realised random map exit
		350	# /... normal maps
		351	# ~/... per-player maps without a specific player (DO NOT USE)
		352	# ~user/... per-player map of a specific user
		353
		354	if ($path =~ /^{/) {
		355	# fine as it is
285	if ($path =~ s{^\?random/}{}) {	356	} elsif ($path =~ s{^\?random/}{}) {
286	Coro::AIO::aio_load "$cf::RANDOM_MAPS/$path.meta", my $data;	357	Coro::AIO::aio_load "$cf::RANDOM_MAPS/$path.meta", my $data;
287	$self->{random} = cf::from_json $data;	358	$self->{random} = cf::from_json $data;
288	} else {	359	} else {
289	if ($path =~ s{^~([^/]+)?}{}) {	360	if ($path =~ s{^~([^/]+)?}{}) {
290	$self->{user_rel} = 1;	361	$self->{user_rel} = 1;
…		…
795	or return;	866	or return;
796		867
797	unless (aio_stat "$filename.pst") {	868	unless (aio_stat "$filename.pst") {
798	(aio_load "$filename.pst", $av) >= 0	869	(aio_load "$filename.pst", $av) >= 0
799	or return;	870	or return;
800	$av = eval { (Storable::thaw <$av>)->{objs} };	871	$av = eval { (Storable::thaw $av)->{objs} };
801	}	872	}
802		873
		874	warn sprintf "loading %s (%d)\n",
		875	$filename, length $data, scalar @{$av \|\| []};#d#
803	return ($data, $av);	876	return ($data, $av);
804	}	877	}
805		878
806	#############################################################################	879	#############################################################################
807	# command handling &c	880	# command handling &c
…		…
1029	$self->send ("ext " . to_json \%msg);	1102	$self->send ("ext " . to_json \%msg);
1030	}	1103	}
1031		1104
1032	=back	1105	=back
1033		1106
		1107
		1108	=head3 cf::map
		1109
		1110	=over 4
		1111
		1112	=cut
		1113
		1114	package cf::map;
		1115
		1116	use Fcntl;
		1117	use Coro::AIO;
		1118
		1119	our $MAX_RESET = 3600;
		1120	our $DEFAULT_RESET = 3000;
		1121
		1122	sub generate_random_map {
		1123	my ($path, $rmp) = @_;
		1124
		1125	# mit "rum" bekleckern, nicht
		1126	cf::map::_create_random_map
		1127	$path,
		1128	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
		1129	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},
		1130	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
		1131	$rmp->{exit_on_final_map},
		1132	$rmp->{xsize}, $rmp->{ysize},
		1133	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
		1134	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
		1135	$rmp->{dungeon_level}, $rmp->{dungeon_depth}, $rmp->{decoroptions}, $rmp->{orientation},
		1136	$rmp->{origin_y}, $rmp->{origin_x}, $rmp->{random_seed}, $rmp->{total_map_hp},
		1137	$rmp->{map_layout_style}, $rmp->{treasureoptions}, $rmp->{symmetry_used},
		1138	(cf::region::find $rmp->{region})
		1139	}
		1140
		1141	# and all this just because we cannot iterate over
		1142	# all maps in C++...
		1143	sub change_all_map_light {
		1144	my ($change) = @_;
		1145
		1146	$_->change_map_light ($change)
		1147	for grep $_->outdoor, values %cf::MAP;
		1148	}
		1149
		1150	sub try_load_header($) {
		1151	my ($path) = @_;
		1152
		1153	utf8::encode $path;
		1154	aio_open $path, O_RDONLY, 0
		1155	or return;
		1156
		1157	my $map = cf::map::new
		1158	or return;
		1159
		1160	# for better error messages only, will be overwritten
		1161	$map->path ($path);
		1162
		1163	$map->load_header ($path)
		1164	or return;
		1165
		1166	$map->{load_path} = $path;
		1167
		1168	$map
		1169	}
		1170
		1171	sub find;
		1172	sub find {
		1173	my ($path, $origin) = @_;
		1174
		1175	#warn "find<$path,$origin>\n";#d#
		1176
		1177	$path = new cf::path $path, $origin && $origin->path;
		1178	my $key = $path->as_string;
		1179
		1180	cf::lock_wait "map_find:$key";
		1181
		1182	$cf::MAP{$key} \|\| do {
		1183	my $guard = cf::lock_acquire "map_find:$key";
		1184
		1185	# do it the slow way
		1186	my $map = try_load_header $path->save_path;
		1187
		1188	Coro::cede;
		1189
		1190	if ($map) {
		1191	$map->last_access ((delete $map->{last_access})
		1192	\|\| $cf::RUNTIME); #d#
		1193	# safety
		1194	$map->{instantiate_time} = $cf::RUNTIME
		1195	if $map->{instantiate_time} > $cf::RUNTIME;
		1196	} else {
		1197	if (my $rmp = $path->random_map_params) {
		1198	$map = generate_random_map $key, $rmp;
		1199	} else {
		1200	$map = try_load_header $path->load_path;
		1201	}
		1202
		1203	$map or return;
		1204
		1205	$map->{load_original} = 1;
		1206	$map->{instantiate_time} = $cf::RUNTIME;
		1207	$map->last_access ($cf::RUNTIME);
		1208	$map->instantiate;
		1209
		1210	# per-player maps become, after loading, normal maps
		1211	$map->per_player (0) if $path->{user_rel};
		1212	}
		1213
		1214	$map->path ($key);
		1215	$map->{path} = $path;
		1216	$map->{last_save} = $cf::RUNTIME;
		1217
		1218	Coro::cede;
		1219
		1220	if ($map->should_reset) {
		1221	$map->reset;
		1222	undef $guard;
		1223	$map = find $path
		1224	or return;
		1225	}
		1226
		1227	$cf::MAP{$key} = $map
		1228	}
		1229	}
		1230
		1231	sub load {
		1232	my ($self) = @_;
		1233
		1234	my $path = $self->{path};
		1235	my $guard = cf::lock_acquire "map_load:" . $path->as_string;
		1236
		1237	return if $self->in_memory != cf::MAP_SWAPPED;
		1238
		1239	$self->in_memory (cf::MAP_LOADING);
		1240
		1241	$self->alloc;
		1242	$self->load_objects ($self->{load_path}, 1)
		1243	or return;
		1244
		1245	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)
		1246	if delete $self->{load_original};
		1247
		1248	if (my $uniq = $path->uniq_path) {
		1249	utf8::encode $uniq;
		1250	if (aio_open $uniq, O_RDONLY, 0) {
		1251	$self->clear_unique_items;
		1252	$self->load_objects ($uniq, 0);
		1253	}
		1254	}
		1255
		1256	Coro::cede;
		1257
		1258	# now do the right thing for maps
		1259	$self->link_multipart_objects;
		1260
		1261	if ($self->{path}->is_style_map) {
		1262	$self->{deny_save} = 1;
		1263	$self->{deny_reset} = 1;
		1264	} else {
		1265	$self->fix_auto_apply;
		1266	$self->decay_objects;
		1267	$self->update_buttons;
		1268	$self->set_darkness_map;
		1269	$self->difficulty ($self->estimate_difficulty)
		1270	unless $self->difficulty;
		1271	$self->activate;
		1272	}
		1273
		1274	Coro::cede;
		1275
		1276	$self->in_memory (cf::MAP_IN_MEMORY);
		1277	}
		1278
		1279	sub find_sync {
		1280	my ($path, $origin) = @_;
		1281
		1282	cf::sync_job { cf::map::find $path, $origin }
		1283	}
		1284
		1285	sub do_load_sync {
		1286	my ($map) = @_;
		1287
		1288	cf::sync_job { $map->load };
		1289	}
		1290
		1291	sub save {
		1292	my ($self) = @_;
		1293
		1294	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1295
		1296	$self->{last_save} = $cf::RUNTIME;
		1297
		1298	return unless $self->dirty;
		1299
		1300	my $save = $self->{path}->save_path; utf8::encode $save;
		1301	my $uniq = $self->{path}->uniq_path; utf8::encode $uniq;
		1302
		1303	$self->{load_path} = $save;
		1304
		1305	return if $self->{deny_save};
		1306
		1307	local $self->{last_access} = $self->last_access;#d#
		1308
		1309	if ($uniq) {
		1310	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS);
		1311	$self->save_objects ($uniq, cf::IO_UNIQUES);
		1312	} else {
		1313	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS \| cf::IO_UNIQUES);
		1314	}
		1315	}
		1316
		1317	sub swap_out {
		1318	my ($self) = @_;
		1319
		1320	# save first because save cedes
		1321	$self->save;
		1322
		1323	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1324
		1325	return if $self->players;
		1326	return if $self->in_memory != cf::MAP_IN_MEMORY;
		1327	return if $self->{deny_save};
		1328
		1329	$self->clear;
		1330	$self->in_memory (cf::MAP_SWAPPED);
		1331	}
		1332
		1333	sub reset_at {
		1334	my ($self) = @_;
		1335
		1336	# TODO: safety, remove and allow resettable per-player maps
		1337	return 1e99 if $self->{path}{user_rel};
		1338	return 1e99 if $self->{deny_reset};
		1339
		1340	my $time = $self->fixed_resettime ? $self->{instantiate_time} : $self->last_access;
		1341	my $to = List::Util::min $MAX_RESET, $self->reset_timeout \|\| $DEFAULT_RESET;
		1342
		1343	$time + $to
		1344	}
		1345
		1346	sub should_reset {
		1347	my ($self) = @_;
		1348
		1349	$self->reset_at <= $cf::RUNTIME
		1350	}
		1351
		1352	sub unlink_save {
		1353	my ($self) = @_;
		1354
		1355	utf8::encode (my $save = $self->{path}->save_path);
		1356	aioreq_pri 3; IO::AIO::aio_unlink $save;
		1357	aioreq_pri 3; IO::AIO::aio_unlink "$save.pst";
		1358	}
		1359
		1360	sub rename {
		1361	my ($self, $new_path) = @_;
		1362
		1363	$self->unlink_save;
		1364
		1365	delete $cf::MAP{$self->path};
		1366	$self->{path} = new cf::path $new_path;
		1367	$self->path ($self->{path}->as_string);
		1368	$cf::MAP{$self->path} = $self;
		1369
		1370	$self->save;
		1371	}
		1372
		1373	sub reset {
		1374	my ($self) = @_;
		1375
		1376	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1377
		1378	return if $self->players;
		1379	return if $self->{path}{user_rel};#d#
		1380
		1381	warn "resetting map ", $self->path;#d#
		1382
		1383	delete $cf::MAP{$self->path};
		1384
		1385	$_->clear_links_to ($self) for values %cf::MAP;
		1386
		1387	$self->unlink_save;
		1388	$self->destroy;
		1389	}
		1390
		1391	my $nuke_counter = "aaaa";
		1392
		1393	sub nuke {
		1394	my ($self) = @_;
		1395
		1396	$self->{deny_save} = 1;
		1397	$self->reset_timeout (1);
		1398	$self->rename ("{nuke}/" . ($nuke_counter++));
		1399	$self->reset; # polite request, might not happen
		1400	}
		1401
		1402	sub customise_for {
		1403	my ($map, $ob) = @_;
		1404
		1405	if ($map->per_player) {
		1406	return cf::map::find "~" . $ob->name . "/" . $map->{path}{path};
		1407	}
		1408
		1409	$map
		1410	}
		1411
		1412	sub emergency_save {
		1413	my $freeze_guard = cf::freeze_mainloop;
		1414
		1415	warn "enter emergency map save\n";
		1416
		1417	cf::sync_job {
		1418	warn "begin emergency map save\n";
		1419	$_->save for values %cf::MAP;
		1420	};
		1421
		1422	warn "end emergency map save\n";
		1423	}
		1424
		1425	package cf;
		1426
		1427	=back
		1428
		1429
1034	=head3 cf::object::player	1430	=head3 cf::object::player
1035		1431
1036	=over 4	1432	=over 4
1037		1433
1038	=item $player_object->reply ($npc, $msg[, $flags])	1434	=item $player_object->reply ($npc, $msg[, $flags])
…		…
1073	(ref $cf::CFG{"may_$access"}	1469	(ref $cf::CFG{"may_$access"}
1074	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}	1470	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}
1075	: $cf::CFG{"may_$access"})	1471	: $cf::CFG{"may_$access"})
1076	}	1472	}
1077		1473
		1474	=item $player_object->enter_link
		1475
		1476	Freezes the player and moves him/her to a special map (C<{link}>).
		1477
		1478	The player should be reaosnably safe there for short amounts of time. You
		1479	I<MUST> call C<leave_link> as soon as possible, though.
		1480
		1481	=item $player_object->leave_link ($map, $x, $y)
		1482
		1483	Moves the player out of the specila link map onto the given map. If the
		1484	map is not valid (or omitted), the player will be moved back to the
		1485	location he/she was before the call to C<enter_link>, or, if that fails,
		1486	to the emergency map position.
		1487
		1488	Might block.
		1489
		1490	=cut
		1491
		1492	sub cf::object::player::enter_link {
		1493	my ($self) = @_;
		1494
		1495	$self->deactivate_recursive;
		1496
		1497	return if $self->map == $LINK_MAP;
		1498
		1499	$self->{_link_pos} \|\|= [$self->map->{path}, $self->x, $self->y]
		1500	if $self->map;
		1501
		1502	$self->enter_map ($LINK_MAP, 20, 20);
		1503	}
		1504
		1505	sub cf::object::player::leave_link {
		1506	my ($self, $map, $x, $y) = @_;
		1507
		1508	my $link_pos = delete $self->{_link_pos};
		1509
		1510	unless ($map) {
		1511	# restore original map position
		1512	($map, $x, $y) = @{ $link_pos \|\| [] };
		1513	$map = cf::map::find $map;
		1514
		1515	unless ($map) {
		1516	($map, $x, $y) = @$EMERGENCY_POSITION;
		1517	$map = cf::map::find $map
		1518	or die "FATAL: cannot load emergency map\n";
		1519	}
		1520	}
		1521
		1522	($x, $y) = (-1, -1)
		1523	unless (defined $x) && (defined $y);
		1524
		1525	# use -1 or undef as default coordinates, not 0, 0
		1526	($x, $y) = ($map->enter_x, $map->enter_y)
		1527	if $x <=0 && $y <= 0;
		1528
		1529	$map->load;
		1530
		1531	$self->activate_recursive;
		1532	$self->enter_map ($map, $x, $y);
		1533	}
		1534
		1535	cf::player->attach (
		1536	on_logout => sub {
		1537	my ($pl) = @_;
		1538
		1539	# abort map switching before logout
		1540	if ($pl->ob->{_link_pos}) {
		1541	cf::sync_job {
		1542	$pl->ob->leave_link
		1543	};
		1544	}
		1545	},
		1546	on_login => sub {
		1547	my ($pl) = @_;
		1548
		1549	# try to abort aborted map switching on player login :)
		1550	# should happen only on crashes
		1551	if ($pl->ob->{_link_pos}) {
		1552
		1553	$pl->ob->enter_link;
		1554	(async {
		1555	# we need this sleep as the login has a concurrent enter_exit running
		1556	# and this sleep increases chances of the player not ending up in scorn
		1557	$pl->ob->reply (undef,
		1558	"There was an internal problem at your last logout, "
		1559	. "the server will try to bring you to your intended destination in a second.",
		1560	cf::NDI_RED);
		1561	Coro::Timer::sleep 1;
		1562	$pl->ob->leave_link;
		1563	})->prio (2);
		1564	}
		1565	},
		1566	);
		1567
		1568	=item $player_object->goto ($path, $x, $y)
		1569
		1570	=cut
		1571
		1572	sub cf::object::player::goto {
		1573	my ($self, $path, $x, $y) = @_;
		1574
		1575	$self->enter_link;
		1576
		1577	(async {
		1578	$path = new cf::path $path;
		1579
		1580	my $map = cf::map::find $path->as_string;
		1581	$map = $map->customise_for ($self) if $map;
		1582
		1583	# warn "entering ", $map->path, " at ($x, $y)\n"
		1584	# if $map;
		1585
		1586	$map or $self->message ("The exit is closed", cf::NDI_UNIQUE \| cf::NDI_RED);
		1587
		1588	$self->leave_link ($map, $x, $y);
		1589	})->prio (1);
		1590	}
		1591
		1592	=item $player_object->enter_exit ($exit_object)
		1593
		1594	=cut
		1595
		1596	sub parse_random_map_params {
		1597	my ($spec) = @_;
		1598
		1599	my $rmp = { # defaults
		1600	xsize => 10,
		1601	ysize => 10,
		1602	};
		1603
		1604	for (split /\n/, $spec) {
		1605	my ($k, $v) = split /\s+/, $_, 2;
		1606
		1607	$rmp->{lc $k} = $v if (length $k) && (length $v);
		1608	}
		1609
		1610	$rmp
		1611	}
		1612
		1613	sub prepare_random_map {
		1614	my ($exit) = @_;
		1615
		1616	# all this does is basically replace the /! path by
		1617	# a new random map path (?random/...) with a seed
		1618	# that depends on the exit object
		1619
		1620	my $rmp = parse_random_map_params $exit->msg;
		1621
		1622	if ($exit->map) {
		1623	$rmp->{region} = $exit->map->region_name;
		1624	$rmp->{origin_map} = $exit->map->path;
		1625	$rmp->{origin_x} = $exit->x;
		1626	$rmp->{origin_y} = $exit->y;
		1627	}
		1628
		1629	$rmp->{random_seed} \|\|= $exit->random_seed;
		1630
		1631	my $data = cf::to_json $rmp;
		1632	my $md5 = Digest::MD5::md5_hex $data;
		1633
		1634	if (my $fh = aio_open "$cf::RANDOM_MAPS/$md5.meta", O_WRONLY \| O_CREAT, 0666) {
		1635	aio_write $fh, 0, (length $data), $data, 0;
		1636
		1637	$exit->slaying ("?random/$md5");
		1638	$exit->msg (undef);
		1639	}
		1640	}
		1641
		1642	sub cf::object::player::enter_exit {
		1643	my ($self, $exit) = @_;
		1644
		1645	return unless $self->type == cf::PLAYER;
		1646
		1647	$self->enter_link;
		1648
		1649	(async {
		1650	$self->deactivate_recursive; # just to be sure
		1651	unless (eval {
		1652	prepare_random_map $exit
		1653	if $exit->slaying eq "/!";
		1654
		1655	my $path = new cf::path $exit->slaying, $exit->map && $exit->map->path;
		1656	$self->goto ($path, $exit->stats->hp, $exit->stats->sp);
		1657
		1658	1;
		1659	}) {
		1660	$self->message ("Something went wrong deep within the crossfire server. "
		1661	. "I'll try to bring you back to the map you were before. "
		1662	. "Please report this to the dungeon master",
		1663	cf::NDI_UNIQUE \| cf::NDI_RED);
		1664
		1665	warn "ERROR in enter_exit: $@";
		1666	$self->leave_link;
		1667	}
		1668	})->prio (1);
		1669	}
		1670
1078	=head3 cf::client	1671	=head3 cf::client
1079		1672
1080	=over 4	1673	=over 4
1081		1674
1082	=item $client->send_drawinfo ($text, $flags)	1675	=item $client->send_drawinfo ($text, $flags)
…		…
1125	on_reply => sub {	1718	on_reply => sub {
1126	my ($ns, $msg) = @_;	1719	my ($ns, $msg) = @_;
1127		1720
1128	# this weird shuffling is so that direct followup queries	1721	# this weird shuffling is so that direct followup queries
1129	# get handled first	1722	# get handled first
1130	my $queue = delete $ns->{query_queue};	1723	my $queue = delete $ns->{query_queue}
		1724	or return; # be conservative, not sure how that can happen, but we saw a crash here
1131		1725
1132	(shift @$queue)->[1]->($msg);	1726	(shift @$queue)->[1]->($msg);
1133		1727
1134	push @{ $ns->{query_queue} }, @$queue;	1728	push @{ $ns->{query_queue} }, @$queue;
1135		1729
…		…
1141	}	1735	}
1142	}	1736	}
1143	},	1737	},
1144	);	1738	);
1145		1739
1146	=item $client->coro (\&cb)	1740	=item $client->async (\&cb)
1147		1741
1148	Create a new coroutine, running the specified callback. The coroutine will	1742	Create a new coroutine, running the specified callback. The coroutine will
1149	be automatically cancelled when the client gets destroyed (e.g. on logout,	1743	be automatically cancelled when the client gets destroyed (e.g. on logout,
1150	or loss of connection).	1744	or loss of connection).
1151		1745
1152	=cut	1746	=cut
1153		1747
1154	sub cf::client::coro {	1748	sub cf::client::async {
1155	my ($self, $cb) = @_;	1749	my ($self, $cb) = @_;
1156		1750
1157	my $coro; $coro = async {	1751	my $coro = &Coro::async ($cb);
1158	eval {
1159	$cb->();
1160	};
1161	warn $@ if $@;
1162	};
1163		1752
1164	$coro->on_destroy (sub {	1753	$coro->on_destroy (sub {
1165	delete $self->{_coro}{$coro+0};	1754	delete $self->{_coro}{$coro+0};
1166	});	1755	});
1167		1756
…		…
1339		1928
1340	{	1929	{
1341	my $path = cf::localdir . "/database.pst";	1930	my $path = cf::localdir . "/database.pst";
1342		1931
1343	sub db_load() {	1932	sub db_load() {
1344	warn "loading database $path\n";#d# remove later
1345	$DB = stat $path ? Storable::retrieve $path : { };	1933	$DB = stat $path ? Storable::retrieve $path : { };
1346	}	1934	}
1347		1935
1348	my $pid;	1936	my $pid;
1349		1937
1350	sub db_save() {	1938	sub db_save() {
1351	warn "saving database $path\n";#d# remove later
1352	waitpid $pid, 0 if $pid;	1939	waitpid $pid, 0 if $pid;
1353	if (0 == ($pid = fork)) {	1940	if (0 == ($pid = fork)) {
1354	$DB->{_meta}{version} = 1;	1941	$DB->{_meta}{version} = 1;
1355	Storable::nstore $DB, "$path~";	1942	Storable::nstore $DB, "$path~";
1356	rename "$path~", $path;	1943	rename "$path~", $path;
…		…
1404	open my $fh, "<:utf8", cf::confdir . "/config"	1991	open my $fh, "<:utf8", cf::confdir . "/config"
1405	or return;	1992	or return;
1406		1993
1407	local $/;	1994	local $/;
1408	*CFG = YAML::Syck::Load <$fh>;	1995	*CFG = YAML::Syck::Load <$fh>;
		1996
		1997	$EMERGENCY_POSITION = $CFG{emergency_position} \|\| ["/world/world_105_115", 5, 37];
		1998
		1999	$cf::map::MAX_RESET = $CFG{map_max_reset} if exists $CFG{map_max_reset};
		2000	$cf::map::DEFAULT_RESET = $CFG{map_default_reset} if exists $CFG{map_default_reset};
		2001
		2002	if (exists $CFG{mlockall}) {
		2003	eval {
		2004	$CFG{mlockall} ? &mlockall : &munlockall
		2005	and die "WARNING: m(un)lockall failed: $!\n";
		2006	};
		2007	warn $@ if $@;
		2008	}
1409	}	2009	}
1410		2010
1411	sub main {	2011	sub main {
1412	# we must not ever block the main coroutine	2012	# we must not ever block the main coroutine
1413	local $Coro::idle = sub {	2013	local $Coro::idle = sub {
1414	Carp::cluck "FATAL: Coro::idle was called, major BUG\n";#d#	2014	Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#
1415	(Coro::unblock_sub {
1416	Event::one_event;	2015	async { Event::one_event };
1417	})->();
1418	};	2016	};
1419		2017
1420	cfg_load;	2018	cfg_load;
1421	db_load;	2019	db_load;
1422	load_extensions;	2020	load_extensions;
…		…
1424	}	2022	}
1425		2023
1426	#############################################################################	2024	#############################################################################
1427	# initialisation	2025	# initialisation
1428		2026
1429	sub perl_reload() {	2027	sub reload() {
1430	# can/must only be called in main	2028	# can/must only be called in main
1431	if ($Coro::current != $Coro::main) {	2029	if ($Coro::current != $Coro::main) {
1432	warn "can only reload from main coroutine\n";	2030	warn "can only reload from main coroutine\n";
1433	return;	2031	return;
1434	}	2032	}
1435		2033
1436	warn "reloading...";	2034	warn "reloading...";
1437		2035
1438	local $FREEZE = 1;	2036	my $guard = freeze_mainloop;
1439	cf::emergency_save;	2037	cf::emergency_save;
1440		2038
1441	eval {	2039	eval {
1442	# if anything goes wrong in here, we should simply crash as we already saved	2040	# if anything goes wrong in here, we should simply crash as we already saved
1443		2041
…		…
1527	$LINK_MAP->height (41);	2125	$LINK_MAP->height (41);
1528	$LINK_MAP->alloc;	2126	$LINK_MAP->alloc;
1529	$LINK_MAP->path ("{link}");	2127	$LINK_MAP->path ("{link}");
1530	$LINK_MAP->{path} = bless { path => "{link}" }, "cf::path";	2128	$LINK_MAP->{path} = bless { path => "{link}" }, "cf::path";
1531	$LINK_MAP->in_memory (MAP_IN_MEMORY);	2129	$LINK_MAP->in_memory (MAP_IN_MEMORY);
		2130
		2131	# dirty hack because... archetypes are not yet loaded
		2132	Event->timer (
		2133	after => 10,
		2134	cb => sub {
		2135	$_[0]->w->cancel;
		2136
		2137	# provide some exits "home"
		2138	my $exit = cf::object::new "exit";
		2139
		2140	$exit->slaying ($EMERGENCY_POSITION->[0]);
		2141	$exit->stats->hp ($EMERGENCY_POSITION->[1]);
		2142	$exit->stats->sp ($EMERGENCY_POSITION->[2]);
		2143
		2144	$LINK_MAP->insert ($exit->clone, 19, 19);
		2145	$LINK_MAP->insert ($exit->clone, 19, 20);
		2146	$LINK_MAP->insert ($exit->clone, 19, 21);
		2147	$LINK_MAP->insert ($exit->clone, 20, 19);
		2148	$LINK_MAP->insert ($exit->clone, 20, 21);
		2149	$LINK_MAP->insert ($exit->clone, 21, 19);
		2150	$LINK_MAP->insert ($exit->clone, 21, 20);
		2151	$LINK_MAP->insert ($exit->clone, 21, 21);
		2152
		2153	$exit->destroy;
		2154	});
		2155
		2156	$LINK_MAP->{deny_save} = 1;
		2157	$LINK_MAP->{deny_reset} = 1;
		2158
		2159	$cf::MAP{$LINK_MAP->path} = $LINK_MAP;
1532	}	2160	}
1533		2161
1534	register "<global>", __PACKAGE__;	2162	register "<global>", __PACKAGE__;
1535		2163
1536	register_command "perl-reload" => sub {	2164	register_command "reload" => sub {
1537	my ($who, $arg) = @_;	2165	my ($who, $arg) = @_;
1538		2166
1539	if ($who->flag (FLAG_WIZ)) {	2167	if ($who->flag (FLAG_WIZ)) {
1540	$who->message ("start of reload.");	2168	$who->message ("start of reload.");
1541	perl_reload;	2169	reload;
1542	$who->message ("end of reload.");	2170	$who->message ("end of reload.");
1543	}	2171	}
1544	};	2172	};
1545		2173
1546	unshift @INC, $LIBDIR;	2174	unshift @INC, $LIBDIR;
…		…
1549	reentrant => 0,	2177	reentrant => 0,
1550	prio => 0,	2178	prio => 0,
1551	at => $NEXT_TICK \|\| $TICK,	2179	at => $NEXT_TICK \|\| $TICK,
1552	data => WF_AUTOCANCEL,	2180	data => WF_AUTOCANCEL,
1553	cb => sub {	2181	cb => sub {
1554	unless ($FREEZE) {
1555	cf::server_tick; # one server iteration	2182	cf::server_tick; # one server iteration
1556	$RUNTIME += $TICK;	2183	$RUNTIME += $TICK;
1557	}
1558
1559	$NEXT_TICK += $TICK;	2184	$NEXT_TICK += $TICK;
1560		2185
1561	# if we are delayed by four ticks or more, skip them all	2186	# if we are delayed by four ticks or more, skip them all
1562	$NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;	2187	$NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;
1563		2188
…		…
1586	or warn "ERROR: unable to write runtime file: $!";	2211	or warn "ERROR: unable to write runtime file: $!";
1587	})->();	2212	})->();
1588	},	2213	},
1589	);	2214	);
1590		2215
		2216	END { cf::emergency_save }
		2217
1591	1	2218	1
1592		2219

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.109 by root, Sun Dec 31 22:23:12 2006 UTC vs. Revision 1.142 by root, Fri Jan 5 21:51:42 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.109 by root, Sun Dec 31 22:23:12 2006 UTC vs.
Revision 1.142 by root, Fri Jan 5 21:51:42 2007 UTC