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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC vs.
Revision 1.153 by root, Mon Jan 8 23:36:16 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;
19		19
		20	use Digest::MD5;
20	use Fcntl;	21	use Fcntl;
21	use IO::AIO 2.31 ();	22	use IO::AIO 2.32 ();
22	use YAML::Syck ();	23	use YAML::Syck ();
23	use Time::HiRes;	24	use Time::HiRes;
24		25
25	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
26		27
27	# 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?
28	$YAML::Syck::ImplicitUnicode = 1;	29	$YAML::Syck::ImplicitUnicode = 1;
29		30
30	$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
31		32
32	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload	33	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload
33		34
34	our %COMMAND = ();	35	our %COMMAND = ();
35	our %COMMAND_TIME = ();	36	our %COMMAND_TIME = ();
…		…
46	our %CFG;	47	our %CFG;
47		48
48	our $UPTIME; $UPTIME \|\|= time;	49	our $UPTIME; $UPTIME \|\|= time;
49	our $RUNTIME;	50	our $RUNTIME;
50		51
		52	our %PLAYER; # all users
51	our %MAP; # all maps	53	our %MAP; # all maps
52	our $LINK_MAP; # the special {link} map	54	our $LINK_MAP; # the special {link} map
53	our $FREEZE;	55	our $RANDOM_MAPS = cf::localdir . "/random";
		56	our %EXT_CORO; # coroutines bound to extensions
54		57
55	binmode STDOUT;	58	binmode STDOUT;
56	binmode STDERR;	59	binmode STDERR;
57		60
58	# read virtual server time, if available	61	# read virtual server time, if available
…		…
64		67
65	mkdir cf::localdir;	68	mkdir cf::localdir;
66	mkdir cf::localdir . "/" . cf::playerdir;	69	mkdir cf::localdir . "/" . cf::playerdir;
67	mkdir cf::localdir . "/" . cf::tmpdir;	70	mkdir cf::localdir . "/" . cf::tmpdir;
68	mkdir cf::localdir . "/" . cf::uniquedir;	71	mkdir cf::localdir . "/" . cf::uniquedir;
		72	mkdir $RANDOM_MAPS;
69		73
70	our %EXT_CORO;	74	# a special map that is always available
		75	our $LINK_MAP;
		76	our $EMERGENCY_POSITION;
71		77
72	#############################################################################	78	#############################################################################
73		79
74	=head2 GLOBAL VARIABLES	80	=head2 GLOBAL VARIABLES
75		81
…		…
112	utf8::encode $msg;	118	utf8::encode $msg;
113		119
114	$msg .= "\n"	120	$msg .= "\n"
115	unless $msg =~ /\n$/;	121	unless $msg =~ /\n$/;
116		122
117	LOG llevError, "cfperl: $msg";	123	LOG llevError, $msg;
118	};	124	};
119	}	125	}
120		126
121	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';	127	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';
122	@safe::cf::object::ISA = @cf::object::ISA = 'cf::attachable';	128	@safe::cf::object::ISA = @cf::object::ISA = 'cf::attachable';
…		…
174	sub to_json($) {	180	sub to_json($) {
175	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs	181	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs
176	JSON::Syck::Dump $_[0]	182	JSON::Syck::Dump $_[0]
177	}	183	}
178		184
179	# main coro must never ever "block" except in Event	185	=item cf::lock_wait $string
180	# sync_job ensures this by running the job in a coroutine	186
181	# and waiting in Event while the server is otherwise frozen	187	Wait until the given lock is available. See cf::lock_acquire.
		188
		189	=item my $lock = cf::lock_acquire $string
		190
		191	Wait until the given lock is available and then acquires it and returns
		192	a Coro::guard object. If the guard object gets destroyed (goes out of scope,
		193	for example when the coroutine gets canceled), the lock is automatically
		194	returned.
		195
		196	Lock names should begin with a unique identifier (for example, cf::map::find
		197	uses map_find and cf::map::load uses map_load).
		198
		199	=cut
		200
		201	our %LOCK;
		202
		203	sub lock_wait($) {
		204	my ($key) = @_;
		205
		206	# wait for lock, if any
		207	while ($LOCK{$key}) {
		208	push @{ $LOCK{$key} }, $Coro::current;
		209	Coro::schedule;
		210	}
		211	}
		212
		213	sub lock_acquire($) {
		214	my ($key) = @_;
		215
		216	# wait, to be sure we are not locked
		217	lock_wait $key;
		218
		219	$LOCK{$key} = [];
		220
		221	Coro::guard {
		222	# wake up all waiters, to be on the safe side
		223	$_->ready for @{ delete $LOCK{$key} };
		224	}
		225	}
		226
		227	sub freeze_mainloop {
		228	return unless $TICK_WATCHER->is_active;
		229
		230	my $guard = Coro::guard { $TICK_WATCHER->start };
		231	$TICK_WATCHER->stop;
		232	$guard
		233	}
		234
		235	=item cf::async { BLOCK }
		236
		237	Currently the same as Coro::async_pool, meaning you cannot use
		238	C<on_destroy>, C<join> or other gimmicks on these coroutines. The only
		239	thing you are allowed to do is call C<prio> on it.
		240
		241	=cut
		242
		243	BEGIN { *async = \&Coro::async_pool }
		244
		245	=item cf::sync_job { BLOCK }
		246
		247	The design of crossfire+ requires that the main coro ($Coro::main) is
		248	always able to handle events or runnable, as crossfire+ is only partly
		249	reentrant. Thus "blocking" it by e.g. waiting for I/O is not acceptable.
		250
		251	If it must be done, put the blocking parts into C<sync_job>. This will run
		252	the given BLOCK in another coroutine while waiting for the result. The
		253	server will be frozen during this time, so the block should either finish
		254	fast or be very important.
		255
		256	=cut
		257
182	sub sync_job(&) {	258	sub sync_job(&) {
183	my ($job) = @_;	259	my ($job) = @_;
184		260
185	my $busy = 1;
186	my @res;
187
188	local $FREEZE = 1;
189
190	my $coro = Coro::async {
191	@res = eval { $job->() };
192	warn $@ if $@;
193	undef $busy;
194	};
195
196	if ($Coro::current == $Coro::main) {	261	if ($Coro::current == $Coro::main) {
		262	# this is the main coro, too bad, we have to block
		263	# till the operation succeeds, freezing the server :/
		264
		265	# TODO: use suspend/resume instead
		266	# (but this is cancel-safe)
		267	my $freeze_guard = freeze_mainloop;
		268
		269	my $busy = 1;
		270	my @res;
		271
		272	(async {
		273	@res = eval { $job->() };
		274	warn $@ if $@;
		275	undef $busy;
197	$coro->prio (Coro::PRIO_MAX);	276	})->prio (Coro::PRIO_MAX);
		277
198	while ($busy) {	278	while ($busy) {
199	Coro::cede_notself;	279	Coro::cede or Event::one_event;
200	Event::one_event unless Coro::nready;
201	}	280	}
		281
		282	wantarray ? @res : $res[0]
202	} else {	283	} else {
203	$coro->join;	284	# we are in another coroutine, how wonderful, everything just works
		285
		286	$job->()
204	}	287	}
205
206	wantarray ? @res : $res[0]
207	}	288	}
208		289
209	=item $coro = cf::coro { BLOCK }	290	=item $coro = cf::async_ext { BLOCK }
210		291
211	Creates and returns a new coro. This coro is automcatially being canceled	292	Like async, but this coro is automcatially being canceled when the
212	when the extension calling this is being unloaded.	293	extension calling this is being unloaded.
213		294
214	=cut	295	=cut
215		296
216	sub coro(&) {	297	sub async_ext(&) {
217	my $cb = shift;	298	my $cb = shift;
218		299
219	my $coro; $coro = async {	300	my $coro = &Coro::async ($cb);
220	eval {
221	$cb->();
222	};
223	warn $@ if $@;
224	};
225		301
226	$coro->on_destroy (sub {	302	$coro->on_destroy (sub {
227	delete $EXT_CORO{$coro+0};	303	delete $EXT_CORO{$coro+0};
228	});	304	});
229	$EXT_CORO{$coro+0} = $coro;	305	$EXT_CORO{$coro+0} = $coro;
230		306
231	$coro	307	$coro
232	}	308	}
233		309
		310	sub write_runtime {
		311	my $runtime = cf::localdir . "/runtime";
		312
		313	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644
		314	or return;
		315
		316	my $value = $cf::RUNTIME + 1 + 10; # 10 is the runtime save interval, for a monotonic clock
		317	(aio_write $fh, 0, (length $value), $value, 0) <= 0
		318	and return;
		319
		320	aio_fsync $fh
		321	and return;
		322
		323	close $fh
		324	or return;
		325
		326	aio_rename "$runtime~", $runtime
		327	and return;
		328
		329	1
		330	}
		331
234	=back	332	=back
235		333
236	=cut	334	=cut
		335
		336	#############################################################################
		337
		338	package cf::path;
		339
		340	sub new {
		341	my ($class, $path, $base) = @_;
		342
		343	$path = $path->as_string if ref $path;
		344
		345	my $self = bless { }, $class;
		346
		347	# {... are special paths that are not touched
		348	# ?xxx/... are special absolute paths
		349	# ?random/... random maps
		350	# /! non-realised random map exit
		351	# /... normal maps
		352	# ~/... per-player maps without a specific player (DO NOT USE)
		353	# ~user/... per-player map of a specific user
		354
		355	if ($path =~ /^{/) {
		356	# fine as it is
		357	} elsif ($path =~ s{^\?random/}{}) {
		358	Coro::AIO::aio_load "$cf::RANDOM_MAPS/$path.meta", my $data;
		359	$self->{random} = cf::from_json $data;
		360	} else {
		361	if ($path =~ s{^~([^/]+)?}{}) {
		362	$self->{user_rel} = 1;
		363
		364	if (defined $1) {
		365	$self->{user} = $1;
		366	} elsif ($base =~ m{^~([^/]+)/}) {
		367	$self->{user} = $1;
		368	} else {
		369	warn "cannot resolve user-relative path without user <$path,$base>\n";
		370	}
		371	} elsif ($path =~ /^\//) {
		372	# already absolute
		373	} else {
		374	$base =~ s{[^/]+/?$}{};
		375	return $class->new ("$base/$path");
		376	}
		377
		378	for ($path) {
		379	redo if s{/\.?/}{/};
		380	redo if s{/[^/]+/\.\./}{/};
		381	}
		382	}
		383
		384	$self->{path} = $path;
		385
		386	$self
		387	}
		388
		389	# the name / primary key / in-game path
		390	sub as_string {
		391	my ($self) = @_;
		392
		393	$self->{user_rel} ? "~$self->{user}$self->{path}"
		394	: $self->{random} ? "?random/$self->{path}"
		395	: $self->{path}
		396	}
		397
		398	# the displayed name, this is a one way mapping
		399	sub visible_name {
		400	my ($self) = @_;
		401
		402	# if (my $rmp = $self->{random}) {
		403	# # todo: be more intelligent about this
		404	# "?random/$rmp->{origin_map}+$rmp->{origin_x}+$rmp->{origin_y}/$rmp->{dungeon_level}"
		405	# } else {
		406	$self->as_string
		407	# }
		408	}
		409
		410	# escape the /'s in the path
		411	sub _escaped_path {
		412	# ∕ is U+2215
		413	(my $path = $_[0]{path}) =~ s/\//∕/g;
		414	$path
		415	}
		416
		417	# the original (read-only) location
		418	sub load_path {
		419	my ($self) = @_;
		420
		421	sprintf "%s/%s/%s", cf::datadir, cf::mapdir, $self->{path}
		422	}
		423
		424	# the temporary/swap location
		425	sub save_path {
		426	my ($self) = @_;
		427
		428	$self->{user_rel} ? sprintf "%s/%s/%s/%s", cf::localdir, cf::playerdir, $self->{user}, $self->_escaped_path
		429	: $self->{random} ? sprintf "%s/%s", $RANDOM_MAPS, $self->{path}
		430	: sprintf "%s/%s/%s", cf::localdir, cf::tmpdir, $self->_escaped_path
		431	}
		432
		433	# the unique path, might be eq to save_path
		434	sub uniq_path {
		435	my ($self) = @_;
		436
		437	$self->{user_rel} \|\| $self->{random}
		438	? undef
		439	: sprintf "%s/%s/%s", cf::localdir, cf::uniquedir, $self->_escaped_path
		440	}
		441
		442	# return random map parameters, or undef
		443	sub random_map_params {
		444	my ($self) = @_;
		445
		446	$self->{random}
		447	}
		448
		449	# this is somewhat ugly, but style maps do need special treatment
		450	sub is_style_map {
		451	$_[0]{path} =~ m{^/styles/}
		452	}
		453
		454	package cf;
237		455
238	#############################################################################	456	#############################################################################
239		457
240	=head2 ATTACHABLE OBJECTS	458	=head2 ATTACHABLE OBJECTS
241		459
…		…
649	or return;	867	or return;
650		868
651	unless (aio_stat "$filename.pst") {	869	unless (aio_stat "$filename.pst") {
652	(aio_load "$filename.pst", $av) >= 0	870	(aio_load "$filename.pst", $av) >= 0
653	or return;	871	or return;
654	$av = eval { (Storable::thaw <$av>)->{objs} };	872	$av = eval { (Storable::thaw $av)->{objs} };
655	}	873	}
656		874
		875	warn sprintf "loading %s (%d)\n",
		876	$filename, length $data, scalar @{$av \|\| []};#d#
657	return ($data, $av);	877	return ($data, $av);
658	}	878	}
659		879
660	#############################################################################	880	#############################################################################
661	# command handling &c	881	# command handling &c
…		…
852		1072
853	=head2 CORE EXTENSIONS	1073	=head2 CORE EXTENSIONS
854		1074
855	Functions and methods that extend core crossfire objects.	1075	Functions and methods that extend core crossfire objects.
856		1076
		1077	=cut
		1078
		1079	package cf::player;
		1080
857	=head3 cf::player	1081	=head3 cf::player
858		1082
859	=over 4	1083	=over 4
860		1084
861	=item cf::player::exists $login	1085	=item cf::player::find $login
862		1086
863	Returns true when the given account exists.	1087	Returns the given player object, loading it if necessary (might block).
864		1088
865	=cut	1089	=cut
866		1090
867	sub cf::player::exists($) {	1091	sub playerdir($) {
868	cf::player::find $_[0]	1092	cf::localdir
869	or -f sprintf "%s/%s/%s/%s.pl", cf::localdir, cf::playerdir, ($_[0]) x 2;	1093	. "/"
		1094	. cf::playerdir
		1095	. "/"
		1096	. (ref $_[0] ? $_[0]->ob->name : $_[0])
		1097	}
		1098
		1099	sub path($) {
		1100	my $login = ref $_[0] ? $_[0]->ob->name : $_[0];
		1101
		1102	(playerdir $login) . "/$login.pl"
		1103	}
		1104
		1105	sub find_active($) {
		1106	$cf::PLAYER{$_[0]}
		1107	and $cf::PLAYER{$_[0]}->active
		1108	and $cf::PLAYER{$_[0]}
		1109	}
		1110
		1111	sub exists($) {
		1112	my ($login) = @_;
		1113
		1114	$cf::PLAYER{$login}
		1115	or cf::sync_job { !aio_stat $login }
		1116	}
		1117
		1118	sub find($) {
		1119	return $cf::PLAYER{$_[0]} \|\| do {
		1120	my $login = $_[0];
		1121
		1122	my $guard = cf::lock_acquire "user_find:$login";
		1123
		1124	$cf::PLAYER{$_[0]} \|\| do {
		1125	my $pl = load_pl path $login
		1126	or return;
		1127	$cf::PLAYER{$login} = $pl
		1128	}
		1129	}
		1130	}
		1131
		1132	sub save($) {
		1133	my ($pl) = @_;
		1134
		1135	return if $pl->{deny_save};
		1136
		1137	my $path = path $pl;
		1138	my $guard = cf::lock_acquire "user_save:$path";
		1139
		1140	return if $pl->{deny_save};
		1141
		1142	Coro::AIO::aio_mkdir playerdir $pl, 0770;
		1143	$pl->{last_save} = $cf::RUNTIME;
		1144
		1145	$pl->save_pl ($path);
		1146	Coro::cede;
		1147	}
		1148
		1149	sub new($) {
		1150	my ($login) = @_;
		1151
		1152	my $self = create;
		1153
		1154	$self->ob->name ($login);
		1155	$self->{deny_save} = 1;
		1156
		1157	$cf::PLAYER{$login} = $self;
		1158
		1159	$self
		1160	}
		1161
		1162	sub quit_character {
		1163	my ($pl) = @_;
		1164
		1165	$pl->{deny_save} = 1;
		1166	$pl->password ("*"); # this should lock out the player until we nuked the dir
		1167
		1168	$pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active;
		1169	$pl->deactivate;
		1170	$pl->invoke (cf::EVENT_PLAYER_QUIT);
		1171	$pl->ns->destroy if $pl->ns;
		1172
		1173	my $path = playerdir $pl;
		1174	my $temp = "$path~$cf::RUNTIME~deleting~";
		1175	Coro::AIO::aio_rename $path, $temp;
		1176	delete $cf::PLAYER{$pl->ob->name};
		1177	$pl->destroy;
		1178	IO::AIO::aio_rmtree $temp;
870	}	1179	}
871		1180
872	=item $player->ext_reply ($msgid, $msgtype, %msg)	1181	=item $player->ext_reply ($msgid, $msgtype, %msg)
873		1182
874	Sends an ext reply to the player.	1183	Sends an ext reply to the player.
875		1184
876	=cut	1185	=cut
877		1186
878	sub cf::player::ext_reply($$$%) {	1187	sub ext_reply($$$%) {
879	my ($self, $id, %msg) = @_;	1188	my ($self, $id, %msg) = @_;
880		1189
881	$msg{msgid} = $id;	1190	$msg{msgid} = $id;
882		1191
883	$self->send ("ext " . to_json \%msg);	1192	$self->send ("ext " . cf::to_json \%msg);
884	}	1193	}
		1194
		1195	package cf;
885		1196
886	=back	1197	=back
		1198
		1199
		1200	=head3 cf::map
		1201
		1202	=over 4
		1203
		1204	=cut
		1205
		1206	package cf::map;
		1207
		1208	use Fcntl;
		1209	use Coro::AIO;
		1210
		1211	our $MAX_RESET = 3600;
		1212	our $DEFAULT_RESET = 3000;
		1213
		1214	sub generate_random_map {
		1215	my ($path, $rmp) = @_;
		1216
		1217	# mit "rum" bekleckern, nicht
		1218	cf::map::_create_random_map
		1219	$path,
		1220	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
		1221	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},
		1222	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
		1223	$rmp->{exit_on_final_map},
		1224	$rmp->{xsize}, $rmp->{ysize},
		1225	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
		1226	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
		1227	$rmp->{dungeon_level}, $rmp->{dungeon_depth}, $rmp->{decoroptions}, $rmp->{orientation},
		1228	$rmp->{origin_y}, $rmp->{origin_x}, $rmp->{random_seed}, $rmp->{total_map_hp},
		1229	$rmp->{map_layout_style}, $rmp->{treasureoptions}, $rmp->{symmetry_used},
		1230	(cf::region::find $rmp->{region})
		1231	}
		1232
		1233	# and all this just because we cannot iterate over
		1234	# all maps in C++...
		1235	sub change_all_map_light {
		1236	my ($change) = @_;
		1237
		1238	$_->change_map_light ($change)
		1239	for grep $_->outdoor, values %cf::MAP;
		1240	}
		1241
		1242	sub try_load_header($) {
		1243	my ($path) = @_;
		1244
		1245	utf8::encode $path;
		1246	aio_open $path, O_RDONLY, 0
		1247	or return;
		1248
		1249	my $map = cf::map::new
		1250	or return;
		1251
		1252	# for better error messages only, will be overwritten
		1253	$map->path ($path);
		1254
		1255	$map->load_header ($path)
		1256	or return;
		1257
		1258	$map->{load_path} = $path;
		1259
		1260	$map
		1261	}
		1262
		1263	sub find;
		1264	sub find {
		1265	my ($path, $origin) = @_;
		1266
		1267	#warn "find<$path,$origin>\n";#d#
		1268
		1269	$path = new cf::path $path, $origin && $origin->path;
		1270	my $key = $path->as_string;
		1271
		1272	cf::lock_wait "map_find:$key";
		1273
		1274	$cf::MAP{$key} \|\| do {
		1275	my $guard = cf::lock_acquire "map_find:$key";
		1276
		1277	# do it the slow way
		1278	my $map = try_load_header $path->save_path;
		1279
		1280	Coro::cede;
		1281
		1282	if ($map) {
		1283	$map->last_access ((delete $map->{last_access})
		1284	\|\| $cf::RUNTIME); #d#
		1285	# safety
		1286	$map->{instantiate_time} = $cf::RUNTIME
		1287	if $map->{instantiate_time} > $cf::RUNTIME;
		1288	} else {
		1289	if (my $rmp = $path->random_map_params) {
		1290	$map = generate_random_map $key, $rmp;
		1291	} else {
		1292	$map = try_load_header $path->load_path;
		1293	}
		1294
		1295	$map or return;
		1296
		1297	$map->{load_original} = 1;
		1298	$map->{instantiate_time} = $cf::RUNTIME;
		1299	$map->last_access ($cf::RUNTIME);
		1300	$map->instantiate;
		1301
		1302	# per-player maps become, after loading, normal maps
		1303	$map->per_player (0) if $path->{user_rel};
		1304	}
		1305
		1306	$map->path ($key);
		1307	$map->{path} = $path;
		1308	$map->{last_save} = $cf::RUNTIME;
		1309
		1310	Coro::cede;
		1311
		1312	if ($map->should_reset) {
		1313	$map->reset;
		1314	undef $guard;
		1315	$map = find $path
		1316	or return;
		1317	}
		1318
		1319	$cf::MAP{$key} = $map
		1320	}
		1321	}
		1322
		1323	sub load {
		1324	my ($self) = @_;
		1325
		1326	my $path = $self->{path};
		1327	my $guard = cf::lock_acquire "map_load:" . $path->as_string;
		1328
		1329	return if $self->in_memory != cf::MAP_SWAPPED;
		1330
		1331	$self->in_memory (cf::MAP_LOADING);
		1332
		1333	$self->alloc;
		1334	$self->load_objects ($self->{load_path}, 1)
		1335	or return;
		1336
		1337	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)
		1338	if delete $self->{load_original};
		1339
		1340	if (my $uniq = $path->uniq_path) {
		1341	utf8::encode $uniq;
		1342	if (aio_open $uniq, O_RDONLY, 0) {
		1343	$self->clear_unique_items;
		1344	$self->load_objects ($uniq, 0);
		1345	}
		1346	}
		1347
		1348	Coro::cede;
		1349
		1350	# now do the right thing for maps
		1351	$self->link_multipart_objects;
		1352
		1353	if ($self->{path}->is_style_map) {
		1354	$self->{deny_save} = 1;
		1355	$self->{deny_reset} = 1;
		1356	} else {
		1357	$self->fix_auto_apply;
		1358	$self->decay_objects;
		1359	$self->update_buttons;
		1360	$self->set_darkness_map;
		1361	$self->difficulty ($self->estimate_difficulty)
		1362	unless $self->difficulty;
		1363	$self->activate;
		1364	}
		1365
		1366	Coro::cede;
		1367
		1368	$self->in_memory (cf::MAP_IN_MEMORY);
		1369	}
		1370
		1371	sub find_sync {
		1372	my ($path, $origin) = @_;
		1373
		1374	cf::sync_job { cf::map::find $path, $origin }
		1375	}
		1376
		1377	sub do_load_sync {
		1378	my ($map) = @_;
		1379
		1380	cf::sync_job { $map->load };
		1381	}
		1382
		1383	sub save {
		1384	my ($self) = @_;
		1385
		1386	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1387
		1388	$self->{last_save} = $cf::RUNTIME;
		1389
		1390	return unless $self->dirty;
		1391
		1392	my $save = $self->{path}->save_path; utf8::encode $save;
		1393	my $uniq = $self->{path}->uniq_path; utf8::encode $uniq;
		1394
		1395	$self->{load_path} = $save;
		1396
		1397	return if $self->{deny_save};
		1398
		1399	local $self->{last_access} = $self->last_access;#d#
		1400
		1401	cf::async {
		1402	$_->contr->save for $self->players;
		1403	};
		1404
		1405	if ($uniq) {
		1406	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS);
		1407	$self->save_objects ($uniq, cf::IO_UNIQUES);
		1408	} else {
		1409	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS \| cf::IO_UNIQUES);
		1410	}
		1411	}
		1412
		1413	sub swap_out {
		1414	my ($self) = @_;
		1415
		1416	# save first because save cedes
		1417	$self->save;
		1418
		1419	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1420
		1421	return if $self->players;
		1422	return if $self->in_memory != cf::MAP_IN_MEMORY;
		1423	return if $self->{deny_save};
		1424
		1425	$self->clear;
		1426	$self->in_memory (cf::MAP_SWAPPED);
		1427	}
		1428
		1429	sub reset_at {
		1430	my ($self) = @_;
		1431
		1432	# TODO: safety, remove and allow resettable per-player maps
		1433	return 1e99 if $self->{path}{user_rel};
		1434	return 1e99 if $self->{deny_reset};
		1435
		1436	my $time = $self->fixed_resettime ? $self->{instantiate_time} : $self->last_access;
		1437	my $to = List::Util::min $MAX_RESET, $self->reset_timeout \|\| $DEFAULT_RESET;
		1438
		1439	$time + $to
		1440	}
		1441
		1442	sub should_reset {
		1443	my ($self) = @_;
		1444
		1445	$self->reset_at <= $cf::RUNTIME
		1446	}
		1447
		1448	sub unlink_save {
		1449	my ($self) = @_;
		1450
		1451	utf8::encode (my $save = $self->{path}->save_path);
		1452	aioreq_pri 3; IO::AIO::aio_unlink $save;
		1453	aioreq_pri 3; IO::AIO::aio_unlink "$save.pst";
		1454	}
		1455
		1456	sub rename {
		1457	my ($self, $new_path) = @_;
		1458
		1459	$self->unlink_save;
		1460
		1461	delete $cf::MAP{$self->path};
		1462	$self->{path} = new cf::path $new_path;
		1463	$self->path ($self->{path}->as_string);
		1464	$cf::MAP{$self->path} = $self;
		1465
		1466	$self->save;
		1467	}
		1468
		1469	sub reset {
		1470	my ($self) = @_;
		1471
		1472	my $lock = cf::lock_acquire "map_data:" . $self->path;
		1473
		1474	return if $self->players;
		1475	return if $self->{path}{user_rel};#d#
		1476
		1477	warn "resetting map ", $self->path;#d#
		1478
		1479	delete $cf::MAP{$self->path};
		1480
		1481	$_->clear_links_to ($self) for values %cf::MAP;
		1482
		1483	$self->unlink_save;
		1484	$self->destroy;
		1485	}
		1486
		1487	my $nuke_counter = "aaaa";
		1488
		1489	sub nuke {
		1490	my ($self) = @_;
		1491
		1492	$self->{deny_save} = 1;
		1493	$self->reset_timeout (1);
		1494	$self->rename ("{nuke}/" . ($nuke_counter++));
		1495	$self->reset; # polite request, might not happen
		1496	}
		1497
		1498	sub customise_for {
		1499	my ($map, $ob) = @_;
		1500
		1501	if ($map->per_player) {
		1502	return cf::map::find "~" . $ob->name . "/" . $map->{path}{path};
		1503	}
		1504
		1505	$map
		1506	}
		1507
		1508	sub emergency_save {
		1509	my $freeze_guard = cf::freeze_mainloop;
		1510
		1511	warn "enter emergency perl save\n";
		1512
		1513	cf::sync_job {
		1514	warn "begin emergency player save\n";
		1515	$_->save for values %cf::PLAYER;
		1516	warn "end emergency player save\n";
		1517
		1518	warn "begin emergency map save\n";
		1519	$_->save for values %cf::MAP;
		1520	warn "end emergency map save\n";
		1521	};
		1522
		1523	warn "leave emergency perl save\n";
		1524	}
		1525
		1526	package cf;
		1527
		1528	=back
		1529
887		1530
888	=head3 cf::object::player	1531	=head3 cf::object::player
889		1532
890	=over 4	1533	=over 4
891		1534
…		…
927	(ref $cf::CFG{"may_$access"}	1570	(ref $cf::CFG{"may_$access"}
928	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}	1571	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}
929	: $cf::CFG{"may_$access"})	1572	: $cf::CFG{"may_$access"})
930	}	1573	}
931		1574
		1575	=item $player_object->enter_link
		1576
		1577	Freezes the player and moves him/her to a special map (C<{link}>).
		1578
		1579	The player should be reaosnably safe there for short amounts of time. You
		1580	I<MUST> call C<leave_link> as soon as possible, though.
		1581
		1582	=item $player_object->leave_link ($map, $x, $y)
		1583
		1584	Moves the player out of the specila link map onto the given map. If the
		1585	map is not valid (or omitted), the player will be moved back to the
		1586	location he/she was before the call to C<enter_link>, or, if that fails,
		1587	to the emergency map position.
		1588
		1589	Might block.
		1590
		1591	=cut
		1592
		1593	sub cf::object::player::enter_link {
		1594	my ($self) = @_;
		1595
		1596	$self->deactivate_recursive;
		1597
		1598	return if $self->map == $LINK_MAP;
		1599
		1600	$self->{_link_pos} \|\|= [$self->map->{path}, $self->x, $self->y]
		1601	if $self->map;
		1602
		1603	$self->enter_map ($LINK_MAP, 20, 20);
		1604	}
		1605
		1606	sub cf::object::player::leave_link {
		1607	my ($self, $map, $x, $y) = @_;
		1608
		1609	my $link_pos = delete $self->{_link_pos};
		1610
		1611	unless ($map) {
		1612	# restore original map position
		1613	($map, $x, $y) = @{ $link_pos \|\| [] };
		1614	$map = cf::map::find $map;
		1615
		1616	unless ($map) {
		1617	($map, $x, $y) = @$EMERGENCY_POSITION;
		1618	$map = cf::map::find $map
		1619	or die "FATAL: cannot load emergency map\n";
		1620	}
		1621	}
		1622
		1623	($x, $y) = (-1, -1)
		1624	unless (defined $x) && (defined $y);
		1625
		1626	# use -1 or undef as default coordinates, not 0, 0
		1627	($x, $y) = ($map->enter_x, $map->enter_y)
		1628	if $x <=0 && $y <= 0;
		1629
		1630	$map->load;
		1631
		1632	return unless $self->contr->active;
		1633	$self->activate_recursive;
		1634	$self->enter_map ($map, $x, $y);
		1635	}
		1636
		1637	cf::player->attach (
		1638	on_logout => sub {
		1639	my ($pl) = @_;
		1640
		1641	# abort map switching before logout
		1642	if ($pl->ob->{_link_pos}) {
		1643	cf::sync_job {
		1644	$pl->ob->leave_link
		1645	};
		1646	}
		1647	},
		1648	on_login => sub {
		1649	my ($pl) = @_;
		1650
		1651	# try to abort aborted map switching on player login :)
		1652	# should happen only on crashes
		1653	if ($pl->ob->{_link_pos}) {
		1654	$pl->ob->enter_link;
		1655	(async {
		1656	# we need this sleep as the login has a concurrent enter_exit running
		1657	# and this sleep increases chances of the player not ending up in scorn
		1658	$pl->ob->reply (undef,
		1659	"There was an internal problem at your last logout, "
		1660	. "the server will try to bring you to your intended destination in a second.",
		1661	cf::NDI_RED);
		1662	Coro::Timer::sleep 1;
		1663	$pl->ob->leave_link;
		1664	})->prio (2);
		1665	}
		1666	},
		1667	);
		1668
		1669	=item $player_object->goto ($path, $x, $y)
		1670
		1671	=cut
		1672
		1673	sub cf::object::player::goto {
		1674	my ($self, $path, $x, $y) = @_;
		1675
		1676	$path = new cf::path $path;
		1677	$path ne "/" or Carp::cluck ("oy");#d#
		1678
		1679	$self->enter_link;
		1680
		1681	(async {
		1682	my $map = cf::map::find $path->as_string;
		1683	$map = $map->customise_for ($self) if $map;
		1684
		1685	# warn "entering ", $map->path, " at ($x, $y)\n"
		1686	# if $map;
		1687
		1688	$map or $self->message ("The exit to '" . ($path->visible_name) . "' is closed", cf::NDI_UNIQUE \| cf::NDI_RED);
		1689
		1690	$self->leave_link ($map, $x, $y);
		1691	})->prio (1);
		1692	}
		1693
		1694	=item $player_object->enter_exit ($exit_object)
		1695
		1696	=cut
		1697
		1698	sub parse_random_map_params {
		1699	my ($spec) = @_;
		1700
		1701	my $rmp = { # defaults
		1702	xsize => 10,
		1703	ysize => 10,
		1704	};
		1705
		1706	for (split /\n/, $spec) {
		1707	my ($k, $v) = split /\s+/, $_, 2;
		1708
		1709	$rmp->{lc $k} = $v if (length $k) && (length $v);
		1710	}
		1711
		1712	$rmp
		1713	}
		1714
		1715	sub prepare_random_map {
		1716	my ($exit) = @_;
		1717
		1718	# all this does is basically replace the /! path by
		1719	# a new random map path (?random/...) with a seed
		1720	# that depends on the exit object
		1721
		1722	my $rmp = parse_random_map_params $exit->msg;
		1723
		1724	if ($exit->map) {
		1725	$rmp->{region} = $exit->map->region_name;
		1726	$rmp->{origin_map} = $exit->map->path;
		1727	$rmp->{origin_x} = $exit->x;
		1728	$rmp->{origin_y} = $exit->y;
		1729	}
		1730
		1731	$rmp->{random_seed} \|\|= $exit->random_seed;
		1732
		1733	my $data = cf::to_json $rmp;
		1734	my $md5 = Digest::MD5::md5_hex $data;
		1735
		1736	if (my $fh = aio_open "$cf::RANDOM_MAPS/$md5.meta", O_WRONLY \| O_CREAT, 0666) {
		1737	aio_write $fh, 0, (length $data), $data, 0;
		1738
		1739	$exit->slaying ("?random/$md5");
		1740	$exit->msg (undef);
		1741	}
		1742	}
		1743
		1744	sub cf::object::player::enter_exit {
		1745	my ($self, $exit) = @_;
		1746
		1747	return unless $self->type == cf::PLAYER;
		1748
		1749	$self->enter_link;
		1750
		1751	(async {
		1752	$self->deactivate_recursive; # just to be sure
		1753	unless (eval {
		1754	prepare_random_map $exit
		1755	if $exit->slaying eq "/!";
		1756
		1757	my $path = new cf::path $exit->slaying, $exit->map && $exit->map->path;
		1758	$self->goto ($path, $exit->stats->hp, $exit->stats->sp);
		1759
		1760	1;
		1761	}) {
		1762	$self->message ("Something went wrong deep within the crossfire server. "
		1763	. "I'll try to bring you back to the map you were before. "
		1764	. "Please report this to the dungeon master",
		1765	cf::NDI_UNIQUE \| cf::NDI_RED);
		1766
		1767	warn "ERROR in enter_exit: $@";
		1768	$self->leave_link;
		1769	}
		1770	})->prio (1);
		1771	}
		1772
932	=head3 cf::client	1773	=head3 cf::client
933		1774
934	=over 4	1775	=over 4
935		1776
936	=item $client->send_drawinfo ($text, $flags)	1777	=item $client->send_drawinfo ($text, $flags)
…		…
979	on_reply => sub {	1820	on_reply => sub {
980	my ($ns, $msg) = @_;	1821	my ($ns, $msg) = @_;
981		1822
982	# this weird shuffling is so that direct followup queries	1823	# this weird shuffling is so that direct followup queries
983	# get handled first	1824	# get handled first
984	my $queue = delete $ns->{query_queue};	1825	my $queue = delete $ns->{query_queue}
		1826	or return; # be conservative, not sure how that can happen, but we saw a crash here
985		1827
986	(shift @$queue)->[1]->($msg);	1828	(shift @$queue)->[1]->($msg);
987		1829
988	push @{ $ns->{query_queue} }, @$queue;	1830	push @{ $ns->{query_queue} }, @$queue;
989		1831
…		…
995	}	1837	}
996	}	1838	}
997	},	1839	},
998	);	1840	);
999		1841
1000	=item $client->coro (\&cb)	1842	=item $client->async (\&cb)
1001		1843
1002	Create a new coroutine, running the specified callback. The coroutine will	1844	Create a new coroutine, running the specified callback. The coroutine will
1003	be automatically cancelled when the client gets destroyed (e.g. on logout,	1845	be automatically cancelled when the client gets destroyed (e.g. on logout,
1004	or loss of connection).	1846	or loss of connection).
1005		1847
1006	=cut	1848	=cut
1007		1849
1008	sub cf::client::coro {	1850	sub cf::client::async {
1009	my ($self, $cb) = @_;	1851	my ($self, $cb) = @_;
1010		1852
1011	my $coro; $coro = async {	1853	my $coro = &Coro::async ($cb);
1012	eval {
1013	$cb->();
1014	};
1015	warn $@ if $@;
1016	};
1017		1854
1018	$coro->on_destroy (sub {	1855	$coro->on_destroy (sub {
1019	delete $self->{_coro}{$coro+0};	1856	delete $self->{_coro}{$coro+0};
1020	});	1857	});
1021		1858
…		…
1193		2030
1194	{	2031	{
1195	my $path = cf::localdir . "/database.pst";	2032	my $path = cf::localdir . "/database.pst";
1196		2033
1197	sub db_load() {	2034	sub db_load() {
1198	warn "loading database $path\n";#d# remove later
1199	$DB = stat $path ? Storable::retrieve $path : { };	2035	$DB = stat $path ? Storable::retrieve $path : { };
1200	}	2036	}
1201		2037
1202	my $pid;	2038	my $pid;
1203		2039
1204	sub db_save() {	2040	sub db_save() {
1205	warn "saving database $path\n";#d# remove later
1206	waitpid $pid, 0 if $pid;	2041	waitpid $pid, 0 if $pid;
1207	if (0 == ($pid = fork)) {	2042	if (0 == ($pid = fork)) {
1208	$DB->{_meta}{version} = 1;	2043	$DB->{_meta}{version} = 1;
1209	Storable::nstore $DB, "$path~";	2044	Storable::nstore $DB, "$path~";
1210	rename "$path~", $path;	2045	rename "$path~", $path;
…		…
1258	open my $fh, "<:utf8", cf::confdir . "/config"	2093	open my $fh, "<:utf8", cf::confdir . "/config"
1259	or return;	2094	or return;
1260		2095
1261	local $/;	2096	local $/;
1262	*CFG = YAML::Syck::Load <$fh>;	2097	*CFG = YAML::Syck::Load <$fh>;
		2098
		2099	$EMERGENCY_POSITION = $CFG{emergency_position} \|\| ["/world/world_105_115", 5, 37];
		2100
		2101	$cf::map::MAX_RESET = $CFG{map_max_reset} if exists $CFG{map_max_reset};
		2102	$cf::map::DEFAULT_RESET = $CFG{map_default_reset} if exists $CFG{map_default_reset};
		2103
		2104	if (exists $CFG{mlockall}) {
		2105	eval {
		2106	$CFG{mlockall} ? eval "mlockall()" : eval "munlockall()"
		2107	and die "WARNING: m(un)lockall failed: $!\n";
		2108	};
		2109	warn $@ if $@;
		2110	}
1263	}	2111	}
1264		2112
1265	sub main {	2113	sub main {
		2114	# we must not ever block the main coroutine
		2115	local $Coro::idle = sub {
		2116	Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#
		2117	async { Event::one_event };
		2118	};
		2119
1266	cfg_load;	2120	cfg_load;
1267	db_load;	2121	db_load;
1268	load_extensions;	2122	load_extensions;
1269	Event::loop;	2123	Event::loop;
1270	}	2124	}
1271		2125
1272	#############################################################################	2126	#############################################################################
1273	# initialisation	2127	# initialisation
1274		2128
1275	sub _perl_reload() {	2129	sub reload() {
		2130	# can/must only be called in main
		2131	if ($Coro::current != $Coro::main) {
		2132	warn "can only reload from main coroutine\n";
		2133	return;
		2134	}
		2135
1276	warn "reloading...";	2136	warn "reloading...";
1277		2137
		2138	my $guard = freeze_mainloop;
		2139	cf::emergency_save;
		2140
1278	eval {	2141	eval {
1279	local $FREEZE = 1;	2142	# if anything goes wrong in here, we should simply crash as we already saved
1280
1281	cf::emergency_save;
1282		2143
1283	# cancel all watchers	2144	# cancel all watchers
1284	for (Event::all_watchers) {	2145	for (Event::all_watchers) {
1285	$_->cancel if $_->data & WF_AUTOCANCEL;	2146	$_->cancel if $_->data & WF_AUTOCANCEL;
1286	}	2147	}
…		…
1344	cf::load_extensions;	2205	cf::load_extensions;
1345		2206
1346	# reattach attachments to objects	2207	# reattach attachments to objects
1347	warn "reattach";	2208	warn "reattach";
1348	_global_reattach;	2209	_global_reattach;
		2210	reattach $_ for values %MAP;
1349	};	2211	};
1350	warn $@ if $@;
1351		2212
1352	warn "reloaded";	2213	if ($@) {
		2214	warn $@;
		2215	warn "error while reloading, exiting.";
		2216	exit 1;
		2217	}
		2218
		2219	warn "reloaded successfully";
1353	};	2220	};
1354		2221
1355	sub perl_reload() {	2222	#############################################################################
1356	_perl_reload;	2223
		2224	unless ($LINK_MAP) {
		2225	$LINK_MAP = cf::map::new;
		2226
		2227	$LINK_MAP->width (41);
		2228	$LINK_MAP->height (41);
		2229	$LINK_MAP->alloc;
		2230	$LINK_MAP->path ("{link}");
		2231	$LINK_MAP->{path} = bless { path => "{link}" }, "cf::path";
		2232	$LINK_MAP->in_memory (MAP_IN_MEMORY);
		2233
		2234	# dirty hack because... archetypes are not yet loaded
		2235	Event->timer (
		2236	after => 10,
		2237	cb => sub {
		2238	$_[0]->w->cancel;
		2239
		2240	# provide some exits "home"
		2241	my $exit = cf::object::new "exit";
		2242
		2243	$exit->slaying ($EMERGENCY_POSITION->[0]);
		2244	$exit->stats->hp ($EMERGENCY_POSITION->[1]);
		2245	$exit->stats->sp ($EMERGENCY_POSITION->[2]);
		2246
		2247	$LINK_MAP->insert ($exit->clone, 19, 19);
		2248	$LINK_MAP->insert ($exit->clone, 19, 20);
		2249	$LINK_MAP->insert ($exit->clone, 19, 21);
		2250	$LINK_MAP->insert ($exit->clone, 20, 19);
		2251	$LINK_MAP->insert ($exit->clone, 20, 21);
		2252	$LINK_MAP->insert ($exit->clone, 21, 19);
		2253	$LINK_MAP->insert ($exit->clone, 21, 20);
		2254	$LINK_MAP->insert ($exit->clone, 21, 21);
		2255
		2256	$exit->destroy;
		2257	});
		2258
		2259	$LINK_MAP->{deny_save} = 1;
		2260	$LINK_MAP->{deny_reset} = 1;
		2261
		2262	$cf::MAP{$LINK_MAP->path} = $LINK_MAP;
1357	}	2263	}
1358		2264
1359	register "<global>", __PACKAGE__;	2265	register "<global>", __PACKAGE__;
1360		2266
1361	register_command "perl-reload" => sub {	2267	register_command "reload" => sub {
1362	my ($who, $arg) = @_;	2268	my ($who, $arg) = @_;
1363		2269
1364	if ($who->flag (FLAG_WIZ)) {	2270	if ($who->flag (FLAG_WIZ)) {
		2271	$who->message ("start of reload.");
		2272	reload;
1365	$who->message ("reloading...");	2273	$who->message ("end of reload.");
1366	_perl_reload;
1367	}	2274	}
1368	};	2275	};
1369		2276
1370	unshift @INC, $LIBDIR;	2277	unshift @INC, $LIBDIR;
1371		2278
…		…
1373	reentrant => 0,	2280	reentrant => 0,
1374	prio => 0,	2281	prio => 0,
1375	at => $NEXT_TICK \|\| $TICK,	2282	at => $NEXT_TICK \|\| $TICK,
1376	data => WF_AUTOCANCEL,	2283	data => WF_AUTOCANCEL,
1377	cb => sub {	2284	cb => sub {
1378	unless ($FREEZE) {
1379	cf::server_tick; # one server iteration	2285	cf::server_tick; # one server iteration
1380	$RUNTIME += $TICK;	2286	$RUNTIME += $TICK;
1381	}
1382
1383	$NEXT_TICK += $TICK;	2287	$NEXT_TICK += $TICK;
1384		2288
1385	# if we are delayed by four ticks or more, skip them all	2289	# if we are delayed by four ticks or more, skip them all
1386	$NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;	2290	$NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;
1387		2291
…		…
1390	},	2294	},
1391	);	2295	);
1392		2296
1393	IO::AIO::max_poll_time $TICK * 0.2;	2297	IO::AIO::max_poll_time $TICK * 0.2;
1394		2298
		2299	Event->io (
1395	Event->io (fd => IO::AIO::poll_fileno,	2300	fd => IO::AIO::poll_fileno,
1396	poll => 'r',	2301	poll => 'r',
1397	prio => 5,	2302	prio => 5,
1398	data => WF_AUTOCANCEL,	2303	data => WF_AUTOCANCEL,
1399	cb => \&IO::AIO::poll_cb);	2304	cb => \&IO::AIO::poll_cb,
		2305	);
1400		2306
1401	# we must not ever block the main coroutine	2307	Event->timer (
1402	$Coro::idle = sub {	2308	data => WF_AUTOCANCEL,
1403	#Carp::cluck "FATAL: Coro::idle was called, major BUG\n";#d#	2309	after => 0,
1404	warn "FATAL: Coro::idle was called, major BUG\n";	2310	interval => 10,
		2311	cb => sub {
1405	(Coro::unblock_sub {	2312	(Coro::unblock_sub {
1406	Event::one_event;	2313	write_runtime
		2314	or warn "ERROR: unable to write runtime file: $!";
1407	})->();	2315	})->();
1408	};	2316	},
		2317	);
		2318
		2319	END { cf::emergency_save }
1409		2320
1410	1	2321	1
1411		2322

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC vs. Revision 1.153 by root, Mon Jan 8 23:36:16 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.105 by root, Sun Dec 31 17:17:23 2006 UTC vs.
Revision 1.153 by root, Mon Jan 8 23:36:16 2007 UTC