ViewVC Help

View File | Revision Log | Show Annotations | Download File

/cvs/deliantra/server/lib/cf.pm

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.361 by root, Sun Sep 9 12:52:48 2007 UTC vs.
Revision 1.531 by root, Wed Apr 28 21:07:41 2010 UTC

		1	#
		2	# This file is part of Deliantra, the Roguelike Realtime MMORPG.
		3	#
		4	# Copyright (©) 2006,2007,2008,2009,2010 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
		5	#
		6	# Deliantra is free software: you can redistribute it and/or modify it under
		7	# the terms of the Affero GNU General Public License as published by the
		8	# Free Software Foundation, either version 3 of the License, or (at your
		9	# option) any later version.
		10	#
		11	# This program is distributed in the hope that it will be useful,
		12	# but WITHOUT ANY WARRANTY; without even the implied warranty of
		13	# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
		14	# GNU General Public License for more details.
		15	#
		16	# You should have received a copy of the Affero GNU General Public License
		17	# and the GNU General Public License along with this program. If not, see
		18	# <http://www.gnu.org/licenses/>.
		19	#
		20	# The authors can be reached via e-mail to <support@deliantra.net>
		21	#
		22
1	package cf;	23	package cf;
2		24
		25	use 5.10.0;
3	use utf8;	26	use utf8;
4	use strict;	27	use strict qw(vars subs);
5		28
6	use Symbol;	29	use Symbol;
7	use List::Util;	30	use List::Util;
8	use Socket;	31	use Socket;
9	use Storable;	32	use EV;
10	use Event;
11	use Opcode;	33	use Opcode;
12	use Safe;	34	use Safe;
13	use Safe::Hole;	35	use Safe::Hole;
		36	use Storable ();
		37	use Carp ();
14		38
		39	use Guard ();
15	use Coro 3.64 ();	40	use Coro ();
16	use Coro::State;	41	use Coro::State;
17	use Coro::Handle;	42	use Coro::Handle;
		43	use Coro::EV;
18	use Coro::Event;	44	use Coro::AnyEvent;
19	use Coro::Timer;	45	use Coro::Timer;
20	use Coro::Signal;	46	use Coro::Signal;
21	use Coro::Semaphore;	47	use Coro::Semaphore;
		48	use Coro::SemaphoreSet;
		49	use Coro::AnyEvent;
22	use Coro::AIO;	50	use Coro::AIO;
		51	use Coro::BDB 1.6;
23	use Coro::Storable;	52	use Coro::Storable;
24	use Coro::Util ();	53	use Coro::Util ();
25		54
26	use JSON::XS ();	55	use JSON::XS 2.01 ();
27	use BDB ();	56	use BDB ();
28	use Data::Dumper;	57	use Data::Dumper;
29	use Digest::MD5;
30	use Fcntl;	58	use Fcntl;
31	use YAML::Syck ();	59	use YAML::XS ();
32	use IO::AIO 2.32 ();	60	use IO::AIO ();
33	use Time::HiRes;	61	use Time::HiRes;
34	use Compress::LZF;	62	use Compress::LZF;
35	use Digest::MD5 ();	63	use Digest::MD5 ();
		64
		65	AnyEvent::detect;
36		66
37	# configure various modules to our taste	67	# configure various modules to our taste
38	#	68	#
39	$Storable::canonical = 1; # reduce rsync transfers	69	$Storable::canonical = 1; # reduce rsync transfers
40	Coro::State::cctx_stacksize 256000; # 1-2MB stack, for deep recursions in maze generator	70	Coro::State::cctx_stacksize 256000; # 1-2MB stack, for deep recursions in maze generator
		71
		72	$Coro::main->prio (Coro::PRIO_MAX); # run main coroutine ("the server") with very high priority
		73
		74	# make sure c-lzf reinitialises itself
		75	Compress::LZF::set_serializer "Storable", "Storable::net_mstore", "Storable::mretrieve";
41	Compress::LZF::sfreeze_cr { }; # prime Compress::LZF so it does not use require later	76	Compress::LZF::sfreeze_cr { }; # prime Compress::LZF so it does not use require later
42		77
43	$Event::Eval = 1; # no idea why this is required, but it is	78	# strictly for debugging
44		79	$SIG{QUIT} = sub { Carp::cluck "SIGQUIT" };
45	# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?
46	$YAML::Syck::ImplicitUnicode = 1;
47
48	$Coro::main->prio (Coro::PRIO_MAX); # run main coroutine ("the server") with very high priority
49		80
50	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload	81	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload
51		82
52	our %COMMAND = ();	83	our %COMMAND = ();
53	our %COMMAND_TIME = ();	84	our %COMMAND_TIME = ();
…		…
56	our %EXTCMD = ();	87	our %EXTCMD = ();
57	our %EXTICMD = ();	88	our %EXTICMD = ();
58	our %EXT_CORO = (); # coroutines bound to extensions	89	our %EXT_CORO = (); # coroutines bound to extensions
59	our %EXT_MAP = (); # pluggable maps	90	our %EXT_MAP = (); # pluggable maps
60		91
61	our $RELOAD; # number of reloads so far	92	our $RELOAD; # number of reloads so far, non-zero while in reload
62	our @EVENT;	93	our @EVENT;
		94	our @REFLECT; # set by XS
		95	our %REFLECT; # set by us
63		96
64	our $CONFDIR = confdir;	97	our $CONFDIR = confdir;
65	our $DATADIR = datadir;	98	our $DATADIR = datadir;
66	our $LIBDIR = "$DATADIR/ext";	99	our $LIBDIR = "$DATADIR/ext";
67	our $PODDIR = "$DATADIR/pod";	100	our $PODDIR = "$DATADIR/pod";
68	our $MAPDIR = "$DATADIR/" . mapdir;	101	our $MAPDIR = "$DATADIR/" . mapdir;
69	our $LOCALDIR = localdir;	102	our $LOCALDIR = localdir;
70	our $TMPDIR = "$LOCALDIR/" . tmpdir;	103	our $TMPDIR = "$LOCALDIR/" . tmpdir;
71	our $UNIQUEDIR = "$LOCALDIR/" . uniquedir;	104	our $UNIQUEDIR = "$LOCALDIR/" . uniquedir;
72	our $PLAYERDIR = "$LOCALDIR/" . playerdir;	105	our $PLAYERDIR = "$LOCALDIR/" . playerdir;
73	our $RANDOMDIR = "$LOCALDIR/random";	106	our $RANDOMDIR = "$LOCALDIR/random";
74	our $BDBDIR = "$LOCALDIR/db";	107	our $BDBDIR = "$LOCALDIR/db";
		108	our $PIDFILE = "$LOCALDIR/pid";
		109	our $RUNTIMEFILE = "$LOCALDIR/runtime";
		110
		111	our %RESOURCE; # unused
		112
		113	our $OUTPUT_RATE_MIN = 3000;
		114	our $OUTPUT_RATE_MAX = 1000000;
		115
		116	our $MAX_LINKS = 32; # how many chained exits to follow
		117	our $VERBOSE_IO = 1;
75		118
76	our $TICK = MAX_TIME * 1e-6; # this is a CONSTANT(!)	119	our $TICK = MAX_TIME * 1e-6; # this is a CONSTANT(!)
77	our $TICK_WATCHER;
78	our $AIO_POLL_WATCHER;
79	our $NEXT_RUNTIME_WRITE; # when should the runtime file be written	120	our $NEXT_RUNTIME_WRITE; # when should the runtime file be written
80	our $NEXT_TICK;	121	our $NEXT_TICK;
81	our $NOW;
82	our $USE_FSYNC = 1; # use fsync to write maps - default off	122	our $USE_FSYNC = 1; # use fsync to write maps - default on
83		123
		124	our $BDB_DEADLOCK_WATCHER;
		125	our $BDB_CHECKPOINT_WATCHER;
84	our $BDB_POLL_WATCHER;	126	our $BDB_TRICKLE_WATCHER;
85	our $DB_ENV;	127	our $DB_ENV;
		128
		129	our @EXTRA_MODULES = qw(pod match mapscript);
86		130
87	our %CFG;	131	our %CFG;
88		132
89	our $UPTIME; $UPTIME ||= time;	133	our $UPTIME; $UPTIME ||= time;
90	our $RUNTIME;	134	our $RUNTIME;
		135	our $NOW;
91		136
92	our (%PLAYER, %PLAYER_LOADING); # all users	137	our (%PLAYER, %PLAYER_LOADING); # all users
93	our (%MAP, %MAP_LOADING ); # all maps	138	our (%MAP, %MAP_LOADING ); # all maps
94	our $LINK_MAP; # the special {link} map, which is always available	139	our $LINK_MAP; # the special {link} map, which is always available
95		140
96	# used to convert map paths into valid unix filenames by replacing / by ∕	141	# used to convert map paths into valid unix filenames by replacing / by ∕
97	our $PATH_SEP = "∕"; # U+2215, chosen purely for visual reasons	142	our $PATH_SEP = "∕"; # U+2215, chosen purely for visual reasons
98		143
99	our $LOAD; # a number between 0 (idle) and 1 (too many objects)	144	our $LOAD; # a number between 0 (idle) and 1 (too many objects)
100	our $LOADAVG; # same thing, but with alpha-smoothing	145	our $LOADAVG; # same thing, but with alpha-smoothing
		146	our $JITTER; # average jitter
101	our $tick_start; # for load detecting purposes	147	our $TICK_START; # for load detecting purposes
		148
		149	our @POST_INIT;
		150
		151	our $REATTACH_ON_RELOAD; # set to true to force object reattach on reload (slow)
		152	our $REALLY_UNLOOP; # never set to true, please :)
102		153
103	binmode STDOUT;	154	binmode STDOUT;
104	binmode STDERR;	155	binmode STDERR;
105		156
106	# read virtual server time, if available	157	# read virtual server time, if available
107	unless ($RUNTIME || !-e "$LOCALDIR/runtime") {	158	unless ($RUNTIME || !-e $RUNTIMEFILE) {
108	open my $fh, "<", "$LOCALDIR/runtime"	159	open my $fh, "<", $RUNTIMEFILE
109	or die "unable to read runtime file: $!";	160	or die "unable to read $RUNTIMEFILE file: $!";
110	$RUNTIME = <$fh> + 0.;	161	$RUNTIME = <$fh> + 0.;
111	}	162	}
		163
		164	eval "sub TICK() { $TICK } 1" or die;
112		165
113	mkdir $_	166	mkdir $_
114	for $LOCALDIR, $TMPDIR, $UNIQUEDIR, $PLAYERDIR, $RANDOMDIR, $BDBDIR;	167	for $LOCALDIR, $TMPDIR, $UNIQUEDIR, $PLAYERDIR, $RANDOMDIR, $BDBDIR;
115		168
116	our $EMERGENCY_POSITION;	169	our $EMERGENCY_POSITION;
117		170
118	sub cf::map::normalise;	171	sub cf::map::normalise;
		172
		173	sub in_main() {
		174	$Coro::current == $Coro::main
		175	}
		176
		177	#############################################################################
		178
		179	%REFLECT = ();
		180	for (@REFLECT) {
		181	my $reflect = JSON::XS::decode_json $_;
		182	$REFLECT{$reflect->{class}} = $reflect;
		183	}
		184
		185	# this is decidedly evil
		186	$REFLECT{object}{flags} = { map +($_ => undef), grep $_, map /^FLAG_([A-Z0-9_]+)$/ && lc $1, keys %{"cf::"} };
119		187
120	#############################################################################	188	#############################################################################
121		189
122	=head2 GLOBAL VARIABLES	190	=head2 GLOBAL VARIABLES
123		191
…		…
159		227
160	The raw value load value from the last tick.	228	The raw value load value from the last tick.
161		229
162	=item %cf::CFG	230	=item %cf::CFG
163		231
164	Configuration for the server, loaded from C</etc/crossfire/config>, or	232	Configuration for the server, loaded from C</etc/deliantra-server/config>, or
165	from wherever your confdir points to.	233	from wherever your confdir points to.
166		234
167	=item cf::wait_for_tick, cf::wait_for_tick_begin	235	=item cf::wait_for_tick, cf::wait_for_tick_begin
168		236
169	These are functions that inhibit the current coroutine one tick. cf::wait_for_tick_begin only	237	These are functions that inhibit the current coroutine one tick. cf::wait_for_tick_begin only
170	returns directly I<after> the tick processing (and consequently, can only wake one process	238	returns directly I<after> the tick processing (and consequently, can only wake one process
171	per tick), while cf::wait_for_tick wakes up all waiters after tick processing.	239	per tick), while cf::wait_for_tick wakes up all waiters after tick processing.
172		240
173	=item @cf::INVOKE_RESULTS	241	=item @cf::INVOKE_RESULTS
174		242
175	This array contains the results of the last C<invoke ()> call. When	243	This array contains the results of the last C<invoke ()> call. When
176	C<cf::override> is called C<@cf::INVOKE_RESULTS> is set to the parameters of	244	C<cf::override> is called C<@cf::INVOKE_RESULTS> is set to the parameters of
177	that call.	245	that call.
178		246
		247	=item %cf::REFLECT
		248
		249	Contains, for each (C++) class name, a hash reference with information
		250	about object members (methods, scalars, arrays and flags) and other
		251	metadata, which is useful for introspection.
		252
179	=back	253	=back
180		254
181	=cut	255	=cut
182		256
183	BEGIN {	257	$Coro::State::WARNHOOK = sub {
184	*CORE::GLOBAL::warn = sub {
185	my $msg = join "", @_;	258	my $msg = join "", @_;
186		259
187	$msg .= "\n"	260	$msg .= "\n"
188	unless $msg =~ /\n$/;	261	unless $msg =~ /\n$/;
189		262
190	$msg =~ s/([\x00-\x08\x0b-\x1f])/sprintf "\\x%02x", ord $1/ge;	263	$msg =~ s/([\x00-\x08\x0b-\x1f])/sprintf "\\x%02x", ord $1/ge;
191		264
192	utf8::encode $msg;
193	LOG llevError, $msg;	265	LOG llevError, $msg;
194	};	266	};
195	}	267
		268	$Coro::State::DIEHOOK = sub {
		269	return unless $^S eq 0; # "eq", not "=="
		270
		271	warn Carp::longmess $_[0];
		272
		273	if (in_main) {#d#
		274	warn "DIEHOOK called in main context, Coro bug?\n";#d#
		275	return;#d#
		276	}#d#
		277
		278	# kill coroutine otherwise
		279	Coro::terminate
		280	};
196		281
197	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';	282	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';
198	@safe::cf::object::ISA = @cf::object::ISA = 'cf::attachable';	283	@safe::cf::object::ISA = @cf::object::ISA = 'cf::attachable';
199	@safe::cf::player::ISA = @cf::player::ISA = 'cf::attachable';	284	@safe::cf::player::ISA = @cf::player::ISA = 'cf::attachable';
200	@safe::cf::client::ISA = @cf::client::ISA = 'cf::attachable';	285	@safe::cf::client::ISA = @cf::client::ISA = 'cf::attachable';
…		…
207	for my $pkg (qw(	292	for my $pkg (qw(
208	cf::global cf::attachable	293	cf::global cf::attachable
209	cf::object cf::object::player	294	cf::object cf::object::player
210	cf::client cf::player	295	cf::client cf::player
211	cf::arch cf::living	296	cf::arch cf::living
		297	cf::map cf::mapspace
212	cf::map cf::party cf::region	298	cf::party cf::region
213	)) {	299	)) {
214	no strict 'refs';
215	@{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg;	300	@{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg;
216	}	301	}
217		302
218	$Event::DIED = sub {	303	$EV::DIED = sub {
219	warn "error in event callback: @_";	304	Carp::cluck "error in event callback: @_";
220	};	305	};
221		306
222	#############################################################################	307	#############################################################################
223		308
224	=head2 UTILITY FUNCTIONS	309	=head2 UTILITY FUNCTIONS
…		…
246	$d =~ s/([\x00-\x07\x09\x0b\x0c\x0e-\x1f])/sprintf "\\x%02x", ord($1)/ge;	331	$d =~ s/([\x00-\x07\x09\x0b\x0c\x0e-\x1f])/sprintf "\\x%02x", ord($1)/ge;
247	$d	332	$d
248	} || "[unable to dump $_[0]: '$@']";	333	} || "[unable to dump $_[0]: '$@']";
249	}	334	}
250		335
251	=item $ref = cf::from_json $json	336	=item $ref = cf::decode_json $json
252		337
253	Converts a JSON string into the corresponding perl data structure.	338	Converts a JSON string into the corresponding perl data structure.
254		339
255	=item $json = cf::to_json $ref	340	=item $json = cf::encode_json $ref
256		341
257	Converts a perl data structure into its JSON representation.	342	Converts a perl data structure into its JSON representation.
258		343
259	=cut	344	=cut
260		345
261	our $json_coder = JSON::XS->new->utf8->max_size (1e6); # accept ~1mb max	346	our $json_coder = JSON::XS->new->utf8->max_size (1e6); # accept ~1mb max
262		347
263	sub to_json ($) { $json_coder->encode ($_[0]) }	348	sub encode_json($) { $json_coder->encode ($_[0]) }
264	sub from_json ($) { $json_coder->decode ($_[0]) }	349	sub decode_json($) { $json_coder->decode ($_[0]) }
		350
		351	=item cf::post_init { BLOCK }
		352
		353	Execute the given codeblock, I<after> all extensions have been (re-)loaded,
		354	but I<before> the server starts ticking again.
		355
		356	The cdoeblock will have a single boolean argument to indicate whether this
		357	is a reload or not.
		358
		359	=cut
		360
		361	sub post_init(&) {
		362	push @POST_INIT, shift;
		363	}
265		364
266	=item cf::lock_wait $string	365	=item cf::lock_wait $string
267		366
268	Wait until the given lock is available. See cf::lock_acquire.	367	Wait until the given lock is available. See cf::lock_acquire.
269		368
270	=item my $lock = cf::lock_acquire $string	369	=item my $lock = cf::lock_acquire $string
271		370
272	Wait until the given lock is available and then acquires it and returns	371	Wait until the given lock is available and then acquires it and returns
273	a Coro::guard object. If the guard object gets destroyed (goes out of scope,	372	a L<Guard> object. If the guard object gets destroyed (goes out of scope,
274	for example when the coroutine gets canceled), the lock is automatically	373	for example when the coroutine gets canceled), the lock is automatically
275	returned.	374	returned.
276		375
277	Locks are *not* recursive, locking from the same coro twice results in a	376	Locks are *not* recursive, locking from the same coro twice results in a
278	deadlocked coro.	377	deadlocked coro.
…		…
284		383
285	Return true if the lock is currently active, i.e. somebody has locked it.	384	Return true if the lock is currently active, i.e. somebody has locked it.
286		385
287	=cut	386	=cut
288		387
289	our %LOCK;	388	our $LOCKS = new Coro::SemaphoreSet;
290	our %LOCKER;#d#
291		389
292	sub lock_wait($) {	390	sub lock_wait($) {
293	my ($key) = @_;	391	$LOCKS->wait ($_[0]);
294
295	if ($LOCKER{$key} == $Coro::current) {#d#
296	Carp::cluck "lock_wait($key) for already-acquired lock";#d#
297	return;#d#
298	}#d#
299
300	# wait for lock, if any
301	while ($LOCK{$key}) {
302	push @{ $LOCK{$key} }, $Coro::current;
303	Coro::schedule;
304	}
305	}	392	}
306		393
307	sub lock_acquire($) {	394	sub lock_acquire($) {
308	my ($key) = @_;	395	$LOCKS->guard ($_[0])
309
310	# wait, to be sure we are not locked
311	lock_wait $key;
312
313	$LOCK{$key} = [];
314	$LOCKER{$key} = $Coro::current;#d#
315
316	Coro::guard {
317	delete $LOCKER{$key};#d#
318	# wake up all waiters, to be on the safe side
319	$_->ready for @{ delete $LOCK{$key} };
320	}
321	}	396	}
322		397
323	sub lock_active($) {	398	sub lock_active($) {
324	my ($key) = @_;	399	$LOCKS->count ($_[0]) < 1
325
326	! ! $LOCK{$key}
327	}	400	}
328		401
329	sub freeze_mainloop {	402	sub freeze_mainloop {
330	return unless $TICK_WATCHER->is_active;	403	tick_inhibit_inc;
331		404
332	my $guard = Coro::guard {	405	&Guard::guard (\&tick_inhibit_dec);
333	$TICK_WATCHER->start;	406	}
334	};	407
335	$TICK_WATCHER->stop;	408	=item cf::periodic $interval, $cb
336	$guard	409
		410	Like EV::periodic, but randomly selects a starting point so that the actions
		411	get spread over time.
		412
		413	=cut
		414
		415	sub periodic($$) {
		416	my ($interval, $cb) = @_;
		417
		418	my $start = rand List::Util::min 180, $interval;
		419
		420	EV::periodic $start, $interval, 0, $cb
337	}	421	}
338		422
339	=item cf::get_slot $time[, $priority[, $name]]	423	=item cf::get_slot $time[, $priority[, $name]]
340		424
341	Allocate $time seconds of blocking CPU time at priority C<$priority>:	425	Allocate $time seconds of blocking CPU time at priority C<$priority>:
…		…
349		433
350	=cut	434	=cut
351		435
352	our @SLOT_QUEUE;	436	our @SLOT_QUEUE;
353	our $SLOT_QUEUE;	437	our $SLOT_QUEUE;
		438	our $SLOT_DECAY = 0.9;
354		439
355	$SLOT_QUEUE->cancel if $SLOT_QUEUE;	440	$SLOT_QUEUE->cancel if $SLOT_QUEUE;
356	$SLOT_QUEUE = Coro::async {	441	$SLOT_QUEUE = Coro::async {
		442	$Coro::current->desc ("timeslot manager");
		443
357	my $signal = new Coro::Signal;	444	my $signal = new Coro::Signal;
		445	my $busy;
358		446
359	while () {	447	while () {
360	next_job:	448	next_job:
		449
361	my $avail = cf::till_tick;	450	my $avail = cf::till_tick;
362	if ($avail > 0.01) {	451
363	for (0 .. $#SLOT_QUEUE) {	452	for (0 .. $#SLOT_QUEUE) {
364	if ($SLOT_QUEUE[$_][0] < $avail) {	453	if ($SLOT_QUEUE[$_][0] <= $avail) {
		454	$busy = 0;
365	my $job = splice @SLOT_QUEUE, $_, 1, ();	455	my $job = splice @SLOT_QUEUE, $_, 1, ();
366	$job->[2]->send;	456	$job->[2]->send;
367	Coro::cede;	457	Coro::cede;
368	goto next_job;	458	goto next_job;
369	}	459	} else {
		460	$SLOT_QUEUE[$_][0] *= $SLOT_DECAY;
370	}	461	}
371	}	462	}
372		463
373	if (@SLOT_QUEUE) {	464	if (@SLOT_QUEUE) {
374	# we do not use wait_For_tick() as it returns immediately when tick is inactive	465	# we do not use wait_for_tick() as it returns immediately when tick is inactive
375	push @cf::WAIT_FOR_TICK, $signal;	466	push @cf::WAIT_FOR_TICK, $signal;
376	$signal->wait;	467	$signal->wait;
377	} else {	468	} else {
		469	$busy = 0;
378	Coro::schedule;	470	Coro::schedule;
379	}	471	}
380	}	472	}
381	};	473	};
382		474
383	sub get_slot($;$$) {	475	sub get_slot($;$$) {
		476	return if tick_inhibit || $Coro::current == $Coro::main;
		477
384	my ($time, $pri, $name) = @_;	478	my ($time, $pri, $name) = @_;
385		479
386	$time = $TICK * .6 if $time > $TICK * .6;	480	$time = clamp $time, 0.01, $TICK * .6;
		481
387	my $sig = new Coro::Signal;	482	my $sig = new Coro::Signal;
388		483
389	push @SLOT_QUEUE, [$time, $pri, $sig, $name];	484	push @SLOT_QUEUE, [$time, $pri, $sig, $name];
390	@SLOT_QUEUE = sort { $b->[1] <=> $a->[1] } @SLOT_QUEUE;	485	@SLOT_QUEUE = sort { $b->[1] <=> $a->[1] } @SLOT_QUEUE;
391	$SLOT_QUEUE->ready;	486	$SLOT_QUEUE->ready;
…		…
402		497
403	BEGIN { *async = \&Coro::async_pool }	498	BEGIN { *async = \&Coro::async_pool }
404		499
405	=item cf::sync_job { BLOCK }	500	=item cf::sync_job { BLOCK }
406		501
407	The design of Crossfire TRT requires that the main coroutine ($Coro::main)	502	The design of Deliantra requires that the main coroutine ($Coro::main)
408	is always able to handle events or runnable, as Crossfire TRT is only	503	is always able to handle events or runnable, as Deliantra is only
409	partly reentrant. Thus "blocking" it by e.g. waiting for I/O is not	504	partly reentrant. Thus "blocking" it by e.g. waiting for I/O is not
410	acceptable.	505	acceptable.
411		506
412	If it must be done, put the blocking parts into C<sync_job>. This will run	507	If it must be done, put the blocking parts into C<sync_job>. This will run
413	the given BLOCK in another coroutine while waiting for the result. The	508	the given BLOCK in another coroutine while waiting for the result. The
…		…
418		513
419	sub sync_job(&) {	514	sub sync_job(&) {
420	my ($job) = @_;	515	my ($job) = @_;
421		516
422	if ($Coro::current == $Coro::main) {	517	if ($Coro::current == $Coro::main) {
423	my $time = Event::time;	518	my $time = AE::time;
424		519
425	# this is the main coro, too bad, we have to block	520	# this is the main coro, too bad, we have to block
426	# till the operation succeeds, freezing the server :/	521	# till the operation succeeds, freezing the server :/
427		522
428	# TODO: use suspend/resume instead	523	LOG llevError, Carp::longmess "sync job";#d#
429	# (but this is cancel-safe)	524
430	my $freeze_guard = freeze_mainloop;	525	my $freeze_guard = freeze_mainloop;
431		526
432	my $busy = 1;	527	my $busy = 1;
433	my @res;	528	my @res;
434		529
435	(async {	530	(async {
		531	$Coro::current->desc ("sync job coro");
436	@res = eval { $job->() };	532	@res = eval { $job->() };
437	warn $@ if $@;	533	warn $@ if $@;
438	undef $busy;	534	undef $busy;
439	})->prio (Coro::PRIO_MAX);	535	})->prio (Coro::PRIO_MAX);
440		536
441	while ($busy) {	537	while ($busy) {
442	Coro::cede or Event::one_event;	538	if (Coro::nready) {
		539	Coro::cede_notself;
		540	} else {
		541	EV::loop EV::LOOP_ONESHOT;
443	}	542	}
		543	}
444		544
445	$time = Event::time - $time;	545	my $time = AE::time - $time;
446		546
447	LOG llevError | logBacktrace, Carp::longmess "long sync job"
448	if $time > $TICK * 0.5 && $TICK_WATCHER->is_active;
449
450	$tick_start += $time; # do not account sync jobs to server load	547	$TICK_START += $time; # do not account sync jobs to server load
451		548
452	wantarray ? @res : $res[0]	549	wantarray ? @res : $res[0]
453	} else {	550	} else {
454	# we are in another coroutine, how wonderful, everything just works	551	# we are in another coroutine, how wonderful, everything just works
455		552
…		…
480	=item fork_call { }, $args	577	=item fork_call { }, $args
481		578
482	Executes the given code block with the given arguments in a seperate	579	Executes the given code block with the given arguments in a seperate
483	process, returning the results. Everything must be serialisable with	580	process, returning the results. Everything must be serialisable with
484	Coro::Storable. May, of course, block. Note that the executed sub may	581	Coro::Storable. May, of course, block. Note that the executed sub may
485	never block itself or use any form of Event handling.	582	never block itself or use any form of event handling.
486		583
487	=cut	584	=cut
488		585
489	sub fork_call(&@) {	586	sub fork_call(&@) {
490	my ($cb, @args) = @_;	587	my ($cb, @args) = @_;
…		…
499	}, @args;	596	}, @args;
500		597
501	wantarray ? @res : $res[-1]	598	wantarray ? @res : $res[-1]
502	}	599	}
503		600
		601	sub objinfo {
		602	(
		603	"counter value" => cf::object::object_count,
		604	"objects created" => cf::object::create_count,
		605	"objects destroyed" => cf::object::destroy_count,
		606	"freelist size" => cf::object::free_count,
		607	"allocated objects" => cf::object::objects_size,
		608	"active objects" => cf::object::actives_size,
		609	)
		610	}
		611
		612	=item $coin = coin_from_name $name
		613
		614	=cut
		615
		616	our %coin_alias = (
		617	"silver" => "silvercoin",
		618	"silvercoin" => "silvercoin",
		619	"silvercoins" => "silvercoin",
		620	"gold" => "goldcoin",
		621	"goldcoin" => "goldcoin",
		622	"goldcoins" => "goldcoin",
		623	"platinum" => "platinacoin",
		624	"platinumcoin" => "platinacoin",
		625	"platinumcoins" => "platinacoin",
		626	"platina" => "platinacoin",
		627	"platinacoin" => "platinacoin",
		628	"platinacoins" => "platinacoin",
		629	"royalty" => "royalty",
		630	"royalties" => "royalty",
		631	);
		632
		633	sub coin_from_name($) {
		634	$coin_alias{$_[0]}
		635	? cf::arch::find $coin_alias{$_[0]}
		636	: undef
		637	}
		638
504	=item $value = cf::db_get $family => $key	639	=item $value = cf::db_get $family => $key
505		640
506	Returns a single value from the environment database.	641	Returns a single value from the environment database.
507		642
508	=item cf::db_put $family => $key => $value	643	=item cf::db_put $family => $key => $value
509		644
510	Stores the given C<$value> in the family. It can currently store binary	645	Stores the given C<$value> in the family. It can currently store binary
511	data only (use Compress::LZF::sfreeze_cr/sthaw to convert to/from binary).	646	data only (use Compress::LZF::sfreeze_cr/sthaw to convert to/from binary).
512		647
		648	=item $db = cf::db_table "name"
		649
		650	Create and/or open a new database table. The string must not be "db" and must be unique
		651	within each server.
		652
513	=cut	653	=cut
		654
		655	sub db_table($) {
		656	my ($name) = @_;
		657	my $db = BDB::db_create $DB_ENV;
		658
		659	eval {
		660	$db->set_flags (BDB::CHKSUM);
		661
		662	utf8::encode $name;
		663	BDB::db_open $db, undef, $name, undef, BDB::BTREE,
		664	BDB::CREATE | BDB::AUTO_COMMIT, 0666;
		665	cf::cleanup "db_open(db): $!" if $!;
		666	};
		667	cf::cleanup "db_open(db): $@" if $@;
		668
		669	$db
		670	}
514		671
515	our $DB;	672	our $DB;
516		673
517	sub db_init {	674	sub db_init {
518	unless ($DB) {
519	$DB = BDB::db_create $DB_ENV;
520
521	cf::sync_job {	675	cf::sync_job {
522	eval {	676	$DB ||= db_table "db";
523	$DB->set_flags (BDB::CHKSUM);
524
525	BDB::db_open $DB, undef, "db", undef, BDB::BTREE,
526	BDB::CREATE | BDB::AUTO_COMMIT, 0666;
527	cf::cleanup "db_open(db): $!" if $!;
528	};
529	cf::cleanup "db_open(db): $@" if $@;
530	};
531	}	677	};
532	}	678	}
533		679
534	sub db_get($$) {	680	sub db_get($$) {
535	my $key = "$_[0]/$_[1]";	681	my $key = "$_[0]/$_[1]";
536		682
…		…
634		780
635	#############################################################################	781	#############################################################################
636		782
637	=head2 ATTACHABLE OBJECTS	783	=head2 ATTACHABLE OBJECTS
638		784
639	Many objects in crossfire are so-called attachable objects. That means you can	785	Many objects in deliantra are so-called attachable objects. That means you can
640	attach callbacks/event handlers (a collection of which is called an "attachment")	786	attach callbacks/event handlers (a collection of which is called an "attachment")
641	to it. All such attachable objects support the following methods.	787	to it. All such attachable objects support the following methods.
642		788
643	In the following description, CLASS can be any of C<global>, C<object>	789	In the following description, CLASS can be any of C<global>, C<object>
644	C<player>, C<client> or C<map> (i.e. the attachable objects in	790	C<player>, C<client> or C<map> (i.e. the attachable objects in
645	Crossfire TRT).	791	Deliantra).
646		792
647	=over 4	793	=over 4
648		794
649	=item $attachable->attach ($attachment, key => $value...)	795	=item $attachable->attach ($attachment, key => $value...)
650		796
…		…
694	=item cf::CLASS::attachment $name, ...	840	=item cf::CLASS::attachment $name, ...
695		841
696	Register an attachment by C<$name> through which attachable objects of the	842	Register an attachment by C<$name> through which attachable objects of the
697	given CLASS can refer to this attachment.	843	given CLASS can refer to this attachment.
698		844
699	Some classes such as crossfire maps and objects can specify attachments	845	Some classes such as deliantra maps and objects can specify attachments
700	that are attached at load/instantiate time, thus the need for a name.	846	that are attached at load/instantiate time, thus the need for a name.
701		847
702	These calls expect any number of the following handler/hook descriptions:	848	These calls expect any number of the following handler/hook descriptions:
703		849
704	=over 4	850	=over 4
…		…
932	}	1078	}
933		1079
934	0	1080	0
935	}	1081	}
936		1082
937	=item $bool = cf::global::invoke (EVENT_CLASS_XXX, ...)	1083	=item $bool = cf::global->invoke (EVENT_CLASS_XXX, ...)
938		1084
939	=item $bool = $attachable->invoke (EVENT_CLASS_XXX, ...)	1085	=item $bool = $attachable->invoke (EVENT_CLASS_XXX, ...)
940		1086
941	Generate an object-specific event with the given arguments.	1087	Generate an object-specific event with the given arguments.
942		1088
…		…
948		1094
949	=cut	1095	=cut
950		1096
951	#############################################################################	1097	#############################################################################
952	# object support	1098	# object support
953	#
954		1099
		1100	sub _object_equal($$);
		1101	sub _object_equal($$) {
		1102	my ($a, $b) = @_;
		1103
		1104	return 0 unless (ref $a) eq (ref $b);
		1105
		1106	if ("HASH" eq ref $a) {
		1107	my @ka = keys %$a;
		1108	my @kb = keys %$b;
		1109
		1110	return 0 if @ka != @kb;
		1111
		1112	for (0 .. $#ka) {
		1113	return 0 unless $ka[$_] eq $kb[$_];
		1114	return 0 unless _object_equal $a->{$ka[$_]}, $b->{$kb[$_]};
		1115	}
		1116
		1117	} elsif ("ARRAY" eq ref $a) {
		1118
		1119	return 0 if @$a != @$b;
		1120
		1121	for (0 .. $#$a) {
		1122	return 0 unless _object_equal $a->[$_], $b->[$_];
		1123	}
		1124
		1125	} elsif ($a ne $b) {
		1126	return 0;
		1127	}
		1128
		1129	1
		1130	}
		1131
		1132	our $SLOW_MERGES;#d#
955	sub _can_merge {	1133	sub _can_merge {
956	my ($ob1, $ob2) = @_;	1134	my ($ob1, $ob2) = @_;
957		1135
958	local $Storable::canonical = 1;	1136	++$SLOW_MERGES;#d#
959	my $fob1 = Storable::freeze $ob1;
960	my $fob2 = Storable::freeze $ob2;
961		1137
962	$fob1 eq $fob2	1138	# we do the slow way here
		1139	return _object_equal $ob1, $ob2
963	}	1140	}
964		1141
965	sub reattach {	1142	sub reattach {
966	# basically do the same as instantiate, without calling instantiate	1143	# basically do the same as instantiate, without calling instantiate
967	my ($obj) = @_;	1144	my ($obj) = @_;
968		1145
		1146	# no longer needed after getting rid of delete_package?
969	bless $obj, ref $obj; # re-bless in case extensions have been reloaded	1147	#bless $obj, ref $obj; # re-bless in case extensions have been reloaded
970		1148
971	my $registry = $obj->registry;	1149	my $registry = $obj->registry;
972		1150
973	@$registry = ();	1151	@$registry = ();
974		1152
…		…
989	cf::attachable->attach (	1167	cf::attachable->attach (
990	prio => -1000000,	1168	prio => -1000000,
991	on_instantiate => sub {	1169	on_instantiate => sub {
992	my ($obj, $data) = @_;	1170	my ($obj, $data) = @_;
993		1171
994	$data = from_json $data;	1172	$data = decode_json $data;
995		1173
996	for (@$data) {	1174	for (@$data) {
997	my ($name, $args) = @$_;	1175	my ($name, $args) = @$_;
998		1176
999	$obj->attach ($name, %{$args || {} });	1177	$obj->attach ($name, %{$args || {} });
…		…
1013	);	1191	);
1014		1192
1015	sub object_freezer_save {	1193	sub object_freezer_save {
1016	my ($filename, $rdata, $objs) = @_;	1194	my ($filename, $rdata, $objs) = @_;
1017		1195
1018	my $guard = cf::lock_acquire "io";
1019
1020	sync_job {	1196	sync_job {
1021	if (length $$rdata) {	1197	if (length $$rdata) {
		1198	utf8::decode (my $decname = $filename);
1022	warn sprintf "saving %s (%d,%d)\n",	1199	warn sprintf "saving %s (%d,%d)\n",
1023	$filename, length $$rdata, scalar @$objs;	1200	$decname, length $$rdata, scalar @$objs
		1201	if $VERBOSE_IO;
1024		1202
1025	if (my $fh = aio_open "$filename~", O_WRONLY | O_CREAT, 0600) {	1203	if (my $fh = aio_open "$filename~", O_WRONLY | O_CREAT, 0600) {
1026	chmod SAVE_MODE, $fh;	1204	aio_chmod $fh, SAVE_MODE;
1027	aio_write $fh, 0, (length $$rdata), $$rdata, 0;	1205	aio_write $fh, 0, (length $$rdata), $$rdata, 0;
1028	aio_fsync $fh if $cf::USE_FSYNC;	1206	if ($cf::USE_FSYNC) {
		1207	aio_sync_file_range $fh, 0, 0, IO::AIO::SYNC_FILE_RANGE_WAIT_BEFORE | IO::AIO::SYNC_FILE_RANGE_WRITE | IO::AIO::SYNC_FILE_RANGE_WAIT_AFTER;
		1208	aio_fsync $fh;
		1209	}
1029	close $fh;	1210	aio_close $fh;
1030		1211
1031	if (@$objs) {	1212	if (@$objs) {
1032	if (my $fh = aio_open "$filename.pst~", O_WRONLY | O_CREAT, 0600) {	1213	if (my $fh = aio_open "$filename.pst~", O_WRONLY | O_CREAT, 0600) {
1033	chmod SAVE_MODE, $fh;	1214	aio_chmod $fh, SAVE_MODE;
1034	my $data = Storable::nfreeze { version => 1, objs => $objs };	1215	my $data = Coro::Storable::nfreeze { version => 1, objs => $objs };
1035	aio_write $fh, 0, (length $data), $data, 0;	1216	aio_write $fh, 0, (length $data), $data, 0;
1036	aio_fsync $fh if $cf::USE_FSYNC;	1217	if ($cf::USE_FSYNC) {
		1218	aio_sync_file_range $fh, 0, 0, IO::AIO::SYNC_FILE_RANGE_WAIT_BEFORE | IO::AIO::SYNC_FILE_RANGE_WRITE | IO::AIO::SYNC_FILE_RANGE_WAIT_AFTER;
		1219	aio_fsync $fh;
		1220	}
1037	close $fh;	1221	aio_close $fh;
1038	aio_rename "$filename.pst~", "$filename.pst";	1222	aio_rename "$filename.pst~", "$filename.pst";
1039	}	1223	}
1040	} else {	1224	} else {
1041	aio_unlink "$filename.pst";	1225	aio_unlink "$filename.pst";
1042	}	1226	}
1043		1227
1044	aio_rename "$filename~", $filename;	1228	aio_rename "$filename~", $filename;
		1229
		1230	$filename =~ s%/[^/]+$%%;
		1231	aio_pathsync $filename if $cf::USE_FSYNC;
1045	} else {	1232	} else {
1046	warn "FATAL: $filename~: $!\n";	1233	warn "unable to save objects: $filename~: $!\n";
1047	}	1234	}
1048	} else {	1235	} else {
1049	aio_unlink $filename;	1236	aio_unlink $filename;
1050	aio_unlink "$filename.pst";	1237	aio_unlink "$filename.pst";
1051	}	1238	}
1052	};	1239	};
1053
1054	undef $guard;
1055	}	1240	}
1056		1241
1057	sub object_freezer_as_string {	1242	sub object_freezer_as_string {
1058	my ($rdata, $objs) = @_;	1243	my ($rdata, $objs) = @_;
1059		1244
…		…
1064		1249
1065	sub object_thawer_load {	1250	sub object_thawer_load {
1066	my ($filename) = @_;	1251	my ($filename) = @_;
1067		1252
1068	my ($data, $av);	1253	my ($data, $av);
1069
1070	my $guard = cf::lock_acquire "io";
1071		1254
1072	(aio_load $filename, $data) >= 0	1255	(aio_load $filename, $data) >= 0
1073	or return;	1256	or return;
1074		1257
1075	unless (aio_stat "$filename.pst") {	1258	unless (aio_stat "$filename.pst") {
1076	(aio_load "$filename.pst", $av) >= 0	1259	(aio_load "$filename.pst", $av) >= 0
1077	or return;	1260	or return;
1078		1261
1079	undef $guard;
1080	$av = eval { (Storable::thaw $av)->{objs} };	1262	my $st = eval { Coro::Storable::thaw $av };
		1263	$av = $st->{objs};
1081	}	1264	}
1082		1265
		1266	utf8::decode (my $decname = $filename);
1083	warn sprintf "loading %s (%d)\n",	1267	warn sprintf "loading %s (%d,%d)\n",
1084	$filename, length $data, scalar @{$av || []};	1268	$decname, length $data, scalar @{$av || []}
		1269	if $VERBOSE_IO;
1085		1270
1086	($data, $av)	1271	($data, $av)
1087	}	1272	}
1088		1273
1089	=head2 COMMAND CALLBACKS	1274	=head2 COMMAND CALLBACKS
…		…
1145	my ($name, $cb) = @_;	1330	my ($name, $cb) = @_;
1146		1331
1147	$EXTICMD{$name} = $cb;	1332	$EXTICMD{$name} = $cb;
1148	}	1333	}
1149		1334
		1335	use File::Glob ();
		1336
1150	cf::player->attach (	1337	cf::player->attach (
1151	on_command => sub {	1338	on_unknown_command => sub {
1152	my ($pl, $name, $params) = @_;	1339	my ($pl, $name, $params) = @_;
1153		1340
1154	my $cb = $COMMAND{$name}	1341	my $cb = $COMMAND{$name}
1155	or return;	1342	or return;
1156		1343
…		…
1186		1373
1187	cf::override;	1374	cf::override;
1188	},	1375	},
1189	);	1376	);
1190		1377
		1378	# "readahead" all extensions
		1379	sub cache_extensions {
		1380	my $grp = IO::AIO::aio_group;
		1381
		1382	add $grp IO::AIO::aio_readdirx $LIBDIR, IO::AIO::READDIR_STAT_ORDER, sub {
		1383	for (grep /\.ext$/, @{$_[0]}) {
		1384	add $grp IO::AIO::aio_load "$LIBDIR/$_", my $data;
		1385	}
		1386	};
		1387
		1388	$grp
		1389	}
		1390
1191	sub load_extensions {	1391	sub load_extensions {
1192	cf::sync_job {	1392	cf::sync_job {
1193	my %todo;	1393	my %todo;
1194		1394
1195	for my $path (<$LIBDIR/*.ext>) {	1395	for my $path (<$LIBDIR/*.ext>) {
…		…
1214		1414
1215	$ext{meta} = { map { (split /=/, $_, 2)[0, 1] } split /\s+/, $1 }	1415	$ext{meta} = { map { (split /=/, $_, 2)[0, 1] } split /\s+/, $1 }
1216	if $source =~ /\A#!.*?perl.*?#\s*(.*)$/m;	1416	if $source =~ /\A#!.*?perl.*?#\s*(.*)$/m;
1217		1417
1218	$ext{source} =	1418	$ext{source} =
1219	"package $pkg; use strict; use utf8;\n"	1419	"package $pkg; use 5.10.0; use strict 'vars', 'subs'; use utf8;\n"
1220	. "#line 1 \"$path\"\n{\n"	1420	. "#line 1 \"$path\"\n{\n"
1221	. $source	1421	. $source
1222	. "\n};\n1";	1422	. "\n};\n1";
1223		1423
1224	$todo{$base} = \%ext;	1424	$todo{$base} = \%ext;
1225	}	1425	}
1226		1426
		1427	my $pass = 0;
1227	my %done;	1428	my %done;
1228	while (%todo) {	1429	while (%todo) {
1229	my $progress;	1430	my $progress;
1230		1431
		1432	++$pass;
		1433
		1434	ext:
1231	while (my ($k, $v) = each %todo) {	1435	while (my ($k, $v) = each %todo) {
1232	for (split /,\s*/, $v->{meta}{depends}) {	1436	for (split /,\s*/, $v->{meta}{depends}) {
1233	goto skip	1437	next ext
1234	unless exists $done{$_};	1438	unless exists $done{$_};
1235	}	1439	}
1236		1440
1237	warn "... loading '$k' into '$v->{pkg}'\n";	1441	warn "... pass $pass, loading '$k' into '$v->{pkg}'\n";
1238		1442
1239	unless (eval $v->{source}) {	1443	my $active = eval $v->{source};
		1444
		1445	if (length $@) {
1240	my $msg = $@ ? "$v->{path}: $@\n"	1446	warn "$v->{path}: $@\n";
1241	: "$v->{base}: extension inactive.\n";
1242		1447
		1448	cf::cleanup "mandatory extension '$k' failed to load, exiting."
1243	if (exists $v->{meta}{mandatory}) {	1449	if exists $v->{meta}{mandatory};
1244	warn $msg;	1450
1245	warn "mandatory extension failed to load, exiting.\n";	1451	warn "$v->{base}: optional extension cannot be loaded, skipping.\n";
1246	exit 1;	1452	delete $todo{$k};
1247	}	1453	} else {
1248		1454	$done{$k} = delete $todo{$k};
1249	warn $msg;	1455	push @EXTS, $v->{pkg};
		1456	$progress = 1;
		1457
		1458	warn "$v->{base}: extension inactive.\n"
		1459	unless $active;
1250	}	1460	}
1251
1252	$done{$k} = delete $todo{$k};
1253	push @EXTS, $v->{pkg};
1254	$progress = 1;
1255	}	1461	}
1256		1462
1257	skip:	1463	unless ($progress) {
1258	die "cannot load " . (join ", ", keys %todo) . ": unable to resolve dependencies\n"	1464	warn "cannot load " . (join ", ", keys %todo) . ": unable to resolve dependencies\n";
1259	unless $progress;	1465
		1466	while (my ($k, $v) = each %todo) {
		1467	cf::cleanup "mandatory extension '$k' has unresolved dependencies, exiting."
		1468	if exists $v->{meta}{mandatory};
		1469	}
		1470	}
1260	}	1471	}
1261	};	1472	};
1262	}	1473	}
1263		1474
1264	#############################################################################	1475	#############################################################################
1265		1476
1266	=back	1477	=back
1267		1478
1268	=head2 CORE EXTENSIONS	1479	=head2 CORE EXTENSIONS
1269		1480
1270	Functions and methods that extend core crossfire objects.	1481	Functions and methods that extend core deliantra objects.
1271		1482
1272	=cut	1483	=cut
1273		1484
1274	package cf::player;	1485	package cf::player;
1275		1486
…		…
1318		1529
1319	sub exists($) {	1530	sub exists($) {
1320	my ($login) = @_;	1531	my ($login) = @_;
1321		1532
1322	$cf::PLAYER{$login}	1533	$cf::PLAYER{$login}
1323	or cf::sync_job { !aio_stat path $login }	1534	or !aio_stat path $login
1324	}	1535	}
1325		1536
1326	sub find($) {	1537	sub find($) {
1327	return $cf::PLAYER{$_[0]} || do {	1538	return $cf::PLAYER{$_[0]} || do {
1328	my $login = $_[0];	1539	my $login = $_[0];
…		…
1338	aio_unlink +(playerdir $login) . "/$login.pl";	1549	aio_unlink +(playerdir $login) . "/$login.pl";
1339		1550
1340	my $f = new_from_file cf::object::thawer path $login	1551	my $f = new_from_file cf::object::thawer path $login
1341	or return;	1552	or return;
1342		1553
1343	$f->next;
1344	my $pl = cf::player::load_pl $f	1554	my $pl = cf::player::load_pl $f
1345	or return;	1555	or return;
		1556
1346	local $cf::PLAYER_LOADING{$login} = $pl;	1557	local $cf::PLAYER_LOADING{$login} = $pl;
1347	$f->resolve_delayed_derefs;	1558	$f->resolve_delayed_derefs;
1348	$cf::PLAYER{$login} = $pl	1559	$cf::PLAYER{$login} = $pl
1349	}	1560	}
1350	}	1561	}
1351	}	1562	}
1352		1563
		1564	cf::player->attach (
		1565	on_load => sub {
		1566	my ($pl, $path) = @_;
		1567
		1568	# restore slots saved in save, below
		1569	my $slots = delete $pl->{_slots};
		1570
		1571	$pl->ob->current_weapon ($slots->[0]);
		1572	$pl->combat_ob ($slots->[1]);
		1573	$pl->ranged_ob ($slots->[2]);
		1574	},
		1575	);
		1576
1353	sub save($) {	1577	sub save($) {
1354	my ($pl) = @_;	1578	my ($pl) = @_;
1355		1579
1356	return if $pl->{deny_save};	1580	return if $pl->{deny_save};
1357		1581
…		…
1360		1584
1361	return if $pl->{deny_save};	1585	return if $pl->{deny_save};
1362		1586
1363	aio_mkdir playerdir $pl, 0770;	1587	aio_mkdir playerdir $pl, 0770;
1364	$pl->{last_save} = $cf::RUNTIME;	1588	$pl->{last_save} = $cf::RUNTIME;
		1589
		1590	cf::get_slot 0.01;
		1591
		1592	# save slots, to be restored later
		1593	local $pl->{_slots} = [$pl->ob->current_weapon, $pl->combat_ob, $pl->ranged_ob];
1365		1594
1366	$pl->save_pl ($path);	1595	$pl->save_pl ($path);
1367	cf::cede_to_tick;	1596	cf::cede_to_tick;
1368	}	1597	}
1369		1598
…		…
1401	my ($pl) = @_;	1630	my ($pl) = @_;
1402		1631
1403	my $name = $pl->ob->name;	1632	my $name = $pl->ob->name;
1404		1633
1405	$pl->{deny_save} = 1;	1634	$pl->{deny_save} = 1;
1406	$pl->password ("*"); # this should lock out the player until we nuked the dir	1635	$pl->password ("*"); # this should lock out the player until we have nuked the dir
1407		1636
1408	$pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active;	1637	$pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1) if $pl->active;
1409	$pl->deactivate;	1638	$pl->deactivate;
		1639	my $killer = cf::arch::get "killer_quit"; $pl->killer ($killer); $killer->destroy;
1410	$pl->invoke (cf::EVENT_PLAYER_QUIT);	1640	$pl->invoke (cf::EVENT_PLAYER_QUIT);
1411	$pl->ns->destroy if $pl->ns;	1641	$pl->ns->destroy if $pl->ns;
1412		1642
1413	my $path = playerdir $pl;	1643	my $path = playerdir $pl;
1414	my $temp = "$path~$cf::RUNTIME~deleting~";	1644	my $temp = "$path~$cf::RUNTIME~deleting~";
…		…
1453		1683
1454	for my $login (@$dirs) {	1684	for my $login (@$dirs) {
1455	my $path = path $login;	1685	my $path = path $login;
1456		1686
1457	# a .pst is a dead give-away for a valid player	1687	# a .pst is a dead give-away for a valid player
1458	unless (-e "$path.pst") {	1688	# if no pst file found, open and chekc for blocked users
		1689	if (aio_stat "$path.pst") {
1459	my $fh = aio_open $path, Fcntl::O_RDONLY, 0 or next;	1690	my $fh = aio_open $path, Fcntl::O_RDONLY, 0 or next;
1460	aio_read $fh, 0, 512, my $buf, 0 or next;	1691	aio_read $fh, 0, 512, my $buf, 0 or next;
1461	$buf !~ /^password -------------$/m or next; # official not-valid tag	1692	$buf !~ /^password -------------$/m or next; # official not-valid tag
1462	}	1693	}
1463		1694
…		…
1467		1698
1468	\@logins	1699	\@logins
1469	}	1700	}
1470		1701
1471	=item $player->maps	1702	=item $player->maps
		1703
		1704	=item cf::player::maps $login
1472		1705
1473	Returns an arrayref of map paths that are private for this	1706	Returns an arrayref of map paths that are private for this
1474	player. May block.	1707	player. May block.
1475		1708
1476	=cut	1709	=cut
…		…
1494	}	1727	}
1495		1728
1496	\@paths	1729	\@paths
1497	}	1730	}
1498		1731
1499	=item $protocol_xml = $player->expand_cfpod ($crossfire_pod)	1732	=item $protocol_xml = $player->expand_cfpod ($cfpod)
1500		1733
1501	Expand crossfire pod fragments into protocol xml.	1734	Expand deliantra pod fragments into protocol xml.
1502
1503	=cut
1504
1505	sub expand_cfpod {
1506	((my $self), (local $_)) = @_;
1507
1508	# escape & and <
1509	s/&/&amp;/g;
1510	s/(?<![BIUGHT])</&lt;/g;
1511
1512	# this is buggy, it needs to properly take care of nested <'s
1513
1514	1 while
1515	# replace B<>, I<>, U<> etc.
1516	s/B<([^\>]*)>/<b>$1<\/b>/
1517	|| s/I<([^\>]*)>/<i>$1<\/i>/
1518	|| s/U<([^\>]*)>/<u>$1<\/u>/
1519	|| s/T<([^\>]*)>/<big><b>$1<\/b><\/big>/
1520	# replace G<male|female> tags
1521	|| s{G<([^>|]*)\|([^>]*)>}{
1522	$self->gender ? $2 : $1
1523	}ge
1524	# replace H<hint text>
1525	|| s{H<([^\>]*)>}
1526	{
1527	("<fg name=\"lightblue\">[$1 (Use hintmode to suppress hints)]</fg>",
1528	"<fg name=\"lightblue\">[Hint suppressed, see hintmode]</fg>",
1529	"")
1530	[$self->{hintmode}]
1531	}ge;
1532
1533	# create single paragraphs (very hackish)
1534	s/(?<=\S)\n(?=\w)/ /g;
1535
1536	# compress some whitespace
1537	s/\s+\n/\n/g; # ws line-ends
1538	s/\n\n+/\n/g; # double lines
1539	s/^\n+//; # beginning lines
1540	s/\n+$//; # ending lines
1541
1542	$_
1543	}
1544
1545	sub hintmode {
1546	$_[0]{hintmode} = $_[1] if @_ > 1;
1547	$_[0]{hintmode}
1548	}
1549		1735
1550	=item $player->ext_reply ($msgid, @msg)	1736	=item $player->ext_reply ($msgid, @msg)
1551		1737
1552	Sends an ext reply to the player.	1738	Sends an ext reply to the player.
1553		1739
…		…
1585		1771
1586	=cut	1772	=cut
1587		1773
1588	sub find_by_path($) {	1774	sub find_by_path($) {
1589	my ($path) = @_;	1775	my ($path) = @_;
		1776
		1777	$path =~ s/^~[^\/]*//; # skip ~login
1590		1778
1591	my ($match, $specificity);	1779	my ($match, $specificity);
1592		1780
1593	for my $region (list) {	1781	for my $region (list) {
1594	if ($region->{match} && $path =~ $region->{match}) {	1782	if ($region->{match} && $path =~ $region->{match}) {
…		…
1620	our $MAX_RESET = 3600;	1808	our $MAX_RESET = 3600;
1621	our $DEFAULT_RESET = 3000;	1809	our $DEFAULT_RESET = 3000;
1622		1810
1623	sub generate_random_map {	1811	sub generate_random_map {
1624	my ($self, $rmp) = @_;	1812	my ($self, $rmp) = @_;
		1813
		1814	my $lock = cf::lock_acquire "generate_random_map"; # the random map generator is NOT reentrant ATM
		1815
1625	# mit "rum" bekleckern, nicht	1816	# mit "rum" bekleckern, nicht
1626	$self->_create_random_map (	1817	$self->_create_random_map (
1627	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},	1818	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
1628	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},	1819	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle}, $rmp->{miningstyle},
1629	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},	1820	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
1630	$rmp->{exit_on_final_map},	1821	$rmp->{exit_on_final_map},
1631	$rmp->{xsize}, $rmp->{ysize},	1822	$rmp->{xsize}, $rmp->{ysize},
1632	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},	1823	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
1633	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},	1824	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
…		…
1655		1846
1656	$EXT_MAP{$pkg} = [$prio, qr<$regex>];	1847	$EXT_MAP{$pkg} = [$prio, qr<$regex>];
1657	}	1848	}
1658		1849
1659	# also paths starting with '/'	1850	# also paths starting with '/'
1660	$EXT_MAP{"cf::map"} = [0, qr{^(?=/)}];	1851	$EXT_MAP{"cf::map::wrap"} = [0, qr{^(?=/)}];
1661		1852
1662	sub thawer_merge {	1853	sub thawer_merge {
1663	my ($self, $merge) = @_;	1854	my ($self, $merge) = @_;
1664		1855
1665	# we have to keep some variables in memory intact	1856	# we have to keep some variables in memory intact
…		…
1751		1942
1752	# the temporary/swap location	1943	# the temporary/swap location
1753	sub save_path {	1944	sub save_path {
1754	my ($self) = @_;	1945	my ($self) = @_;
1755		1946
1756	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;	1947	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/go;
1757	"$TMPDIR/$path.map"	1948	"$TMPDIR/$path.map"
1758	}	1949	}
1759		1950
1760	# the unique path, undef == no special unique path	1951	# the unique path, undef == no special unique path
1761	sub uniq_path {	1952	sub uniq_path {
1762	my ($self) = @_;	1953	my ($self) = @_;
1763		1954
1764	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;	1955	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/go;
1765	"$UNIQUEDIR/$path"	1956	"$UNIQUEDIR/$path"
1766	}
1767
1768	# and all this just because we cannot iterate over
1769	# all maps in C++...
1770	sub change_all_map_light {
1771	my ($change) = @_;
1772
1773	$_->change_map_light ($change)
1774	for grep $_->outdoor, values %cf::MAP;
1775	}	1957	}
1776		1958
1777	sub decay_objects {	1959	sub decay_objects {
1778	my ($self) = @_;	1960	my ($self) = @_;
1779		1961
…		…
1863	sub find {	2045	sub find {
1864	my ($path, $origin) = @_;	2046	my ($path, $origin) = @_;
1865		2047
1866	$path = normalise $path, $origin && $origin->path;	2048	$path = normalise $path, $origin && $origin->path;
1867		2049
1868	cf::lock_wait "map_data:$path";#d#remove	2050	my $guard1 = cf::lock_acquire "map_data:$path";#d#remove
1869	cf::lock_wait "map_find:$path";	2051	my $guard2 = cf::lock_acquire "map_find:$path";
1870		2052
1871	$cf::MAP{$path} || do {	2053	$cf::MAP{$path} || do {
1872	my $guard1 = cf::lock_acquire "map_find:$path";
1873	my $guard2 = cf::lock_acquire "map_data:$path"; # just for the fun of it
1874
1875	my $map = new_from_path cf::map $path	2054	my $map = new_from_path cf::map $path
1876	or return;	2055	or return;
1877		2056
1878	$map->{last_save} = $cf::RUNTIME;	2057	$map->{last_save} = $cf::RUNTIME;
1879		2058
…		…
1881	or return;	2060	or return;
1882		2061
1883	if ($map->should_reset) {#d#TODO# disabled, crashy (locking issue?)	2062	if ($map->should_reset) {#d#TODO# disabled, crashy (locking issue?)
1884	# doing this can freeze the server in a sync job, obviously	2063	# doing this can freeze the server in a sync job, obviously
1885	#$cf::WAIT_FOR_TICK->wait;	2064	#$cf::WAIT_FOR_TICK->wait;
		2065	undef $guard2;
1886	undef $guard1;	2066	undef $guard1;
1887	undef $guard2;
1888	$map->reset;	2067	$map->reset;
1889	return find $path;	2068	return find $path;
1890	}	2069	}
1891		2070
1892	$cf::MAP{$path} = $map	2071	$cf::MAP{$path} = $map
1893	}	2072	}
1894	}	2073	}
1895		2074
1896	sub pre_load { }	2075	sub pre_load { }
1897	sub post_load { }	2076	#sub post_load { } # XS
1898		2077
1899	sub load {	2078	sub load {
1900	my ($self) = @_;	2079	my ($self) = @_;
1901		2080
1902	local $self->{deny_reset} = 1; # loading can take a long time	2081	local $self->{deny_reset} = 1; # loading can take a long time
…		…
1919	my $f = new_from_file cf::object::thawer $self->{load_path};	2098	my $f = new_from_file cf::object::thawer $self->{load_path};
1920	$f->skip_block;	2099	$f->skip_block;
1921	$self->_load_objects ($f)	2100	$self->_load_objects ($f)
1922	or return;	2101	or return;
1923		2102
1924	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)	2103	$self->post_load_original
1925	if delete $self->{load_original};	2104	if delete $self->{load_original};
1926		2105
1927	if (my $uniq = $self->uniq_path) {	2106	if (my $uniq = $self->uniq_path) {
1928	utf8::encode $uniq;	2107	utf8::encode $uniq;
1929	unless (aio_stat $uniq) {	2108	unless (aio_stat $uniq) {
…		…
1947	unless ($self->{deny_activate}) {	2126	unless ($self->{deny_activate}) {
1948	$self->decay_objects;	2127	$self->decay_objects;
1949	$self->fix_auto_apply;	2128	$self->fix_auto_apply;
1950	$self->update_buttons;	2129	$self->update_buttons;
1951	cf::cede_to_tick;	2130	cf::cede_to_tick;
1952	$self->set_darkness_map;
1953	cf::cede_to_tick;
1954	$self->activate;	2131	$self->activate;
1955	}	2132	}
1956		2133
1957	$self->{last_save} = $cf::RUNTIME;	2134	$self->{last_save} = $cf::RUNTIME;
1958	$self->last_access ($cf::RUNTIME);	2135	$self->last_access ($cf::RUNTIME);
1959		2136
1960	$self->in_memory (cf::MAP_IN_MEMORY);	2137	$self->in_memory (cf::MAP_ACTIVE);
1961	}	2138	}
1962		2139
1963	$self->post_load;	2140	$self->post_load;
1964	}	2141	}
1965		2142
		2143	# customize the map for a given player, i.e.
		2144	# return the _real_ map. used by e.g. per-player
		2145	# maps to change the path to ~playername/mappath
1966	sub customise_for {	2146	sub customise_for {
1967	my ($self, $ob) = @_;	2147	my ($self, $ob) = @_;
1968		2148
1969	return find "~" . $ob->name . "/" . $self->{path}	2149	return find "~" . $ob->name . "/" . $self->{path}
1970	if $self->per_player;	2150	if $self->per_player;
…		…
1986	or next;	2166	or next;
1987	$neigh = find $neigh, $map	2167	$neigh = find $neigh, $map
1988	or next;	2168	or next;
1989	$neigh->load;	2169	$neigh->load;
1990		2170
		2171	# now find the diagonal neighbours
1991	push @neigh,	2172	push @neigh,
1992	[$neigh->tile_path (($_ + 3) % 4), $neigh],	2173	[$neigh->tile_path (($_ + 3) % 4), $neigh],
1993	[$neigh->tile_path (($_ + 1) % 4), $neigh];	2174	[$neigh->tile_path (($_ + 1) % 4), $neigh];
1994	}	2175	}
1995		2176
…		…
2023	my ($path, $origin, $load) = @_;	2204	my ($path, $origin, $load) = @_;
2024		2205
2025	$path = normalise $path, $origin && $origin->{path};	2206	$path = normalise $path, $origin && $origin->{path};
2026		2207
2027	if (my $map = $cf::MAP{$path}) {	2208	if (my $map = $cf::MAP{$path}) {
2028	return $map if !$load || $map->in_memory == cf::MAP_IN_MEMORY;	2209	return $map if !$load || $map->in_memory == cf::MAP_ACTIVE;
2029	}	2210	}
2030		2211
2031	$MAP_PREFETCH{$path} |= $load;	2212	$MAP_PREFETCH{$path} |= $load;
2032		2213
2033	$MAP_PREFETCHER ||= cf::async {	2214	$MAP_PREFETCHER ||= cf::async {
		2215	$Coro::current->{desc} = "map prefetcher";
		2216
2034	while (%MAP_PREFETCH) {	2217	while (%MAP_PREFETCH) {
2035	while (my ($k, $v) = each %MAP_PREFETCH) {	2218	while (my ($k, $v) = each %MAP_PREFETCH) {
2036	if (my $map = find $k) {	2219	if (my $map = find $k) {
2037	$map->load if $v;	2220	$map->load if $v;
2038	}	2221	}
…		…
2045	$MAP_PREFETCHER->prio (6);	2228	$MAP_PREFETCHER->prio (6);
2046		2229
2047	()	2230	()
2048	}	2231	}
2049		2232
		2233	# common code, used by both ->save and ->swapout
2050	sub save {	2234	sub _save {
2051	my ($self) = @_;	2235	my ($self) = @_;
2052
2053	my $lock = cf::lock_acquire "map_data:$self->{path}";
2054		2236
2055	$self->{last_save} = $cf::RUNTIME;	2237	$self->{last_save} = $cf::RUNTIME;
2056		2238
2057	return unless $self->dirty;	2239	return unless $self->dirty;
2058		2240
…		…
2064	return if $self->{deny_save};	2246	return if $self->{deny_save};
2065		2247
2066	local $self->{last_access} = $self->last_access;#d#	2248	local $self->{last_access} = $self->last_access;#d#
2067		2249
2068	cf::async {	2250	cf::async {
		2251	$Coro::current->{desc} = "map player save";
2069	$_->contr->save for $self->players;	2252	$_->contr->save for $self->players;
2070	};	2253	};
		2254
		2255	cf::get_slot 0.02;
2071		2256
2072	if ($uniq) {	2257	if ($uniq) {
2073	$self->_save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS);	2258	$self->_save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS);
2074	$self->_save_objects ($uniq, cf::IO_UNIQUES);	2259	$self->_save_objects ($uniq, cf::IO_UNIQUES);
2075	} else {	2260	} else {
2076	$self->_save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS | cf::IO_UNIQUES);	2261	$self->_save_objects ($save, cf::IO_HEADER | cf::IO_OBJECTS | cf::IO_UNIQUES);
2077	}	2262	}
2078	}	2263	}
2079		2264
		2265	sub save {
		2266	my ($self) = @_;
		2267
		2268	my $lock = cf::lock_acquire "map_data:$self->{path}";
		2269
		2270	$self->_save;
		2271	}
		2272
2080	sub swap_out {	2273	sub swap_out {
2081	my ($self) = @_;	2274	my ($self) = @_;
2082		2275
2083	# save first because save cedes
2084	$self->save;
2085
2086	my $lock = cf::lock_acquire "map_data:$self->{path}";	2276	my $lock = cf::lock_acquire "map_data:$self->{path}";
2087		2277
		2278	return if $self->in_memory != cf::MAP_ACTIVE;
		2279	return if $self->{deny_save};
2088	return if $self->players;	2280	return if $self->players;
2089	return if $self->in_memory != cf::MAP_IN_MEMORY;
2090	return if $self->{deny_save};
2091		2281
		2282	# first deactivate the map and "unlink" it from the core
		2283	$self->deactivate;
		2284	$_->clear_links_to ($self) for values %cf::MAP;
2092	$self->in_memory (cf::MAP_SWAPPED);	2285	$self->in_memory (cf::MAP_SWAPPED);
		2286
		2287	# then atomically save
		2288	$self->_save;
		2289
		2290	# then free the map
		2291	$self->clear;
		2292	}
		2293
		2294	sub reset_at {
		2295	my ($self) = @_;
		2296
		2297	# TODO: safety, remove and allow resettable per-player maps
		2298	return 1e99 if $self->{deny_reset};
		2299
		2300	my $time = $self->fixed_resettime ? $self->{instantiate_time} : $self->last_access;
		2301	my $to = List::Util::min $MAX_RESET, $self->reset_timeout || $DEFAULT_RESET;
		2302
		2303	$time + $to
		2304	}
		2305
		2306	sub should_reset {
		2307	my ($self) = @_;
		2308
		2309	$self->reset_at <= $cf::RUNTIME
		2310	}
		2311
		2312	sub reset {
		2313	my ($self) = @_;
		2314
		2315	my $lock = cf::lock_acquire "map_data:$self->{path}";
		2316
		2317	return if $self->players;
		2318
		2319	warn "resetting map ", $self->path, "\n";
		2320
		2321	$self->in_memory (cf::MAP_SWAPPED);
		2322
		2323	# need to save uniques path
		2324	unless ($self->{deny_save}) {
		2325	my $uniq = $self->uniq_path; utf8::encode $uniq;
		2326
		2327	$self->_save_objects ($uniq, cf::IO_UNIQUES)
		2328	if $uniq;
		2329	}
		2330
		2331	delete $cf::MAP{$self->path};
2093		2332
2094	$self->deactivate;	2333	$self->deactivate;
2095	$_->clear_links_to ($self) for values %cf::MAP;	2334	$_->clear_links_to ($self) for values %cf::MAP;
2096	$self->clear;	2335	$self->clear;
2097	}
2098
2099	sub reset_at {
2100	my ($self) = @_;
2101
2102	# TODO: safety, remove and allow resettable per-player maps
2103	return 1e99 if $self->{deny_reset};
2104
2105	my $time = $self->fixed_resettime ? $self->{instantiate_time} : $self->last_access;
2106	my $to = List::Util::min $MAX_RESET, $self->reset_timeout || $DEFAULT_RESET;
2107
2108	$time + $to
2109	}
2110
2111	sub should_reset {
2112	my ($self) = @_;
2113
2114	$self->reset_at <= $cf::RUNTIME
2115	}
2116
2117	sub reset {
2118	my ($self) = @_;
2119
2120	my $lock = cf::lock_acquire "map_data:$self->{path}";
2121
2122	return if $self->players;
2123
2124	warn "resetting map ", $self->path;
2125
2126	$self->in_memory (cf::MAP_SWAPPED);
2127
2128	# need to save uniques path
2129	unless ($self->{deny_save}) {
2130	my $uniq = $self->uniq_path; utf8::encode $uniq;
2131
2132	$self->_save_objects ($uniq, cf::IO_UNIQUES)
2133	if $uniq;
2134	}
2135
2136	delete $cf::MAP{$self->path};
2137
2138	$self->deactivate;
2139	$_->clear_links_to ($self) for values %cf::MAP;
2140	$self->clear;
2141		2336
2142	$self->unlink_save;	2337	$self->unlink_save;
2143	$self->destroy;	2338	$self->destroy;
2144	}	2339	}
2145		2340
…		…
2153		2348
2154	delete $cf::MAP{$self->path};	2349	delete $cf::MAP{$self->path};
2155		2350
2156	$self->unlink_save;	2351	$self->unlink_save;
2157		2352
2158	bless $self, "cf::map";	2353	bless $self, "cf::map::wrap";
2159	delete $self->{deny_reset};	2354	delete $self->{deny_reset};
2160	$self->{deny_save} = 1;	2355	$self->{deny_save} = 1;
2161	$self->reset_timeout (1);	2356	$self->reset_timeout (1);
2162	$self->path ($self->{path} = "{nuke}/" . ($nuke_counter++));	2357	$self->path ($self->{path} = "{nuke}/" . ($nuke_counter++));
2163		2358
…		…
2212		2407
2213	sub unique_maps() {	2408	sub unique_maps() {
2214	[	2409	[
2215	map {	2410	map {
2216	utf8::decode $_;	2411	utf8::decode $_;
2217	/\.map$/	2412	s/\.map$//; # TODO future compatibility hack
		2413	/\.pst$/ || !/^$PATH_SEP/o # TODO unique maps apparebntly lack the .map suffix :/
		2414	? ()
2218	? normalise $_	2415	: normalise $_
2219	: ()
2220	} @{ aio_readdir $UNIQUEDIR or [] }	2416	} @{ aio_readdir $UNIQUEDIR or [] }
2221	]	2417	]
2222	}	2418	}
2223		2419
2224	package cf;	2420	=item cf::map::static_maps
		2421
		2422	Returns an arrayref if paths of all static maps (all preinstalled F<.map>
		2423	file in the shared directory excluding F</styles> and F</editor>). May
		2424	block.
		2425
		2426	=cut
		2427
		2428	sub static_maps() {
		2429	my @dirs = "";
		2430	my @maps;
		2431
		2432	while (@dirs) {
		2433	my $dir = shift @dirs;
		2434
		2435	next if $dir eq "/styles" || $dir eq "/editor";
		2436
		2437	my ($dirs, $files) = Coro::AIO::aio_scandir "$MAPDIR$dir", 2
		2438	or return;
		2439
		2440	for (@$files) {
		2441	s/\.map$// or next;
		2442	utf8::decode $_;
		2443	push @maps, "$dir/$_";
		2444	}
		2445
		2446	push @dirs, map "$dir/$_", @$dirs;
		2447	}
		2448
		2449	\@maps
		2450	}
2225		2451
2226	=back	2452	=back
2227		2453
2228	=head3 cf::object	2454	=head3 cf::object
2229		2455
…		…
2233		2459
2234	=over 4	2460	=over 4
2235		2461
2236	=item $ob->inv_recursive	2462	=item $ob->inv_recursive
2237		2463
2238	Returns the inventory of the object _and_ their inventories, recursively.	2464	Returns the inventory of the object I<and> their inventories, recursively,
		2465	but I<not> the object itself.
2239		2466
2240	=cut	2467	=cut
2241		2468
2242	sub inv_recursive_;	2469	sub inv_recursive_;
2243	sub inv_recursive_ {	2470	sub inv_recursive_ {
…		…
2248	inv_recursive_ inv $_[0]	2475	inv_recursive_ inv $_[0]
2249	}	2476	}
2250		2477
2251	=item $ref = $ob->ref	2478	=item $ref = $ob->ref
2252		2479
2253	creates and returns a persistent reference to an objetc that can be stored as a string.	2480	Creates and returns a persistent reference to an object that can be stored as a string.
2254		2481
2255	=item $ob = cf::object::deref ($refstring)	2482	=item $ob = cf::object::deref ($refstring)
2256		2483
2257	returns the objetc referenced by refstring. may return undef when it cnanot find the object,	2484	returns the objetc referenced by refstring. may return undef when it cnanot find the object,
2258	even if the object actually exists. May block.	2485	even if the object actually exists. May block.
…		…
2260	=cut	2487	=cut
2261		2488
2262	sub deref {	2489	sub deref {
2263	my ($ref) = @_;	2490	my ($ref) = @_;
2264		2491
2265	# temporary compatibility#TODO#remove
2266	$ref =~ s{^<}{player/<};
2267
2268	if ($ref =~ m{^player\/(<1\.\d+>)/(.*)$}) {	2492	if ($ref =~ m{^player\/(<1\.[0-9a-f]+>)/(.*)$}) {
2269	my ($uuid, $name) = ($1, $2);	2493	my ($uuid, $name) = ($1, $2);
2270	my $pl = $cf::PLAYER_LOADING{$name} || cf::player::find $name	2494	my $pl = $cf::PLAYER_LOADING{$name} || cf::player::find $name
2271	or return;	2495	or return;
2272	$pl->ob->uuid eq $uuid	2496	$pl->ob->uuid eq $uuid
2273	or return;	2497	or return;
…		…
2293	can be C<undef>. Does the right thing when the player is currently in a	2517	can be C<undef>. Does the right thing when the player is currently in a
2294	dialogue with the given NPC character.	2518	dialogue with the given NPC character.
2295		2519
2296	=cut	2520	=cut
2297		2521
		2522	our $SAY_CHANNEL = {
		2523	id => "say",
		2524	title => "Map",
		2525	reply => "say ",
		2526	tooltip => "Things said to and replied from NPCs near you and other players on the same map only.",
		2527	};
		2528
		2529	our $CHAT_CHANNEL = {
		2530	id => "chat",
		2531	title => "Chat",
		2532	reply => "chat ",
		2533	tooltip => "Player chat and shouts, global to the server.",
		2534	};
		2535
2298	# rough implementation of a future "reply" method that works	2536	# rough implementation of a future "reply" method that works
2299	# with dialog boxes.	2537	# with dialog boxes.
2300	#TODO: the first argument must go, split into a $npc->reply_to ( method	2538	#TODO: the first argument must go, split into a $npc->reply_to ( method
2301	sub cf::object::player::reply($$$;$) {	2539	sub cf::object::player::reply($$$;$) {
2302	my ($self, $npc, $msg, $flags) = @_;	2540	my ($self, $npc, $msg, $flags) = @_;
…		…
2313	my $dialog = $pl->{npc_dialog};	2551	my $dialog = $pl->{npc_dialog};
2314	$dialog->{pl}->ext_msg ($dialog->{id}, update => msg => $dialog->{pl}->expand_cfpod ($msg));	2552	$dialog->{pl}->ext_msg ($dialog->{id}, update => msg => $dialog->{pl}->expand_cfpod ($msg));
2315		2553
2316	} else {	2554	} else {
2317	$msg = $npc->name . " says: $msg" if $npc;	2555	$msg = $npc->name . " says: $msg" if $npc;
2318	$self->message ($msg, $flags);	2556	$self->send_msg ($SAY_CHANNEL => $msg, $flags);
2319	}	2557	}
2320	}	2558	}
2321	}	2559	}
2322		2560
2323	=item $object->send_msg ($channel, $msg, $color, [extra...])	2561	=item $object->send_msg ($channel, $msg, $color, [extra...])
…		…
2348		2586
2349	=item $player_object->enter_link	2587	=item $player_object->enter_link
2350		2588
2351	Freezes the player and moves him/her to a special map (C<{link}>).	2589	Freezes the player and moves him/her to a special map (C<{link}>).
2352		2590
2353	The player should be reasonably safe there for short amounts of time. You	2591	The player should be reasonably safe there for short amounts of time (e.g.
2354	I<MUST> call C<leave_link> as soon as possible, though.	2592	for loading a map). You I<MUST> call C<leave_link> as soon as possible,
		2593	though, as the player cannot control the character while it is on the link
		2594	map.
2355		2595
2356	Will never block.	2596	Will never block.
2357		2597
2358	=item $player_object->leave_link ($map, $x, $y)	2598	=item $player_object->leave_link ($map, $x, $y)
2359		2599
…		…
2379	sub cf::object::player::enter_link {	2619	sub cf::object::player::enter_link {
2380	my ($self) = @_;	2620	my ($self) = @_;
2381		2621
2382	$self->deactivate_recursive;	2622	$self->deactivate_recursive;
2383		2623
		2624	++$self->{_link_recursion};
		2625
2384	return if UNIVERSAL::isa $self->map, "ext::map_link";	2626	return if UNIVERSAL::isa $self->map, "ext::map_link";
2385		2627
2386	$self->{_link_pos} ||= [$self->map->{path}, $self->x, $self->y]	2628	$self->{_link_pos} ||= [$self->map->{path}, $self->x, $self->y]
2387	if $self->map && $self->map->{path} ne "{link}";	2629	if $self->map && $self->map->{path} ne "{link}";
2388		2630
2389	$self->enter_map ($LINK_MAP || link_map, 10, 10);	2631	$self->enter_map ($LINK_MAP || link_map, 3, 3);
2390	}	2632	}
2391		2633
2392	sub cf::object::player::leave_link {	2634	sub cf::object::player::leave_link {
2393	my ($self, $map, $x, $y) = @_;	2635	my ($self, $map, $x, $y) = @_;
2394		2636
…		…
2411	($x, $y) = (-1, -1)	2653	($x, $y) = (-1, -1)
2412	unless (defined $x) && (defined $y);	2654	unless (defined $x) && (defined $y);
2413		2655
2414	# use -1 or undef as default coordinates, not 0, 0	2656	# use -1 or undef as default coordinates, not 0, 0
2415	($x, $y) = ($map->enter_x, $map->enter_y)	2657	($x, $y) = ($map->enter_x, $map->enter_y)
2416	if $x <=0 && $y <= 0;	2658	if $x <= 0 && $y <= 0;
2417		2659
2418	$map->load;	2660	$map->load;
2419	$map->load_neighbours;	2661	$map->load_neighbours;
2420		2662
2421	return unless $self->contr->active;	2663	return unless $self->contr->active;
2422	$self->activate_recursive;
2423		2664
2424	local $self->{_prev_pos} = $link_pos; # ugly hack for rent.ext	2665	local $self->{_prev_pos} = $link_pos; # ugly hack for rent.ext
2425	$self->enter_map ($map, $x, $y);	2666	if ($self->enter_map ($map, $x, $y)) {
2426	}	2667	# entering was successful
		2668	delete $self->{_link_recursion};
		2669	# only activate afterwards, to support waiting in hooks
		2670	$self->activate_recursive;
		2671	}
2427		2672
		2673	}
		2674
2428	=item $player_object->goto ($path, $x, $y[, $check->($map)[, $done->()]])	2675	=item $player_object->goto ($path, $x, $y[, $check->($map, $x, $y, $player)[, $done->($player)]])
2429		2676
2430	Moves the player to the given map-path and coordinates by first freezing	2677	Moves the player to the given map-path and coordinates by first freezing
2431	her, loading and preparing them map, calling the provided $check callback	2678	her, loading and preparing them map, calling the provided $check callback
2432	that has to return the map if sucecssful, and then unfreezes the player on	2679	that has to return the map if sucecssful, and then unfreezes the player on
2433	the new (success) or old (failed) map position. In either case, $done will	2680	the new (success) or old (failed) map position. In either case, $done will
2434	be called at the end of this process.	2681	be called at the end of this process.
2435		2682
		2683	Note that $check will be called with a potentially non-loaded map, so if
		2684	it needs a loaded map it has to call C<< ->load >>.
		2685
2436	=cut	2686	=cut
2437		2687
2438	our $GOTOGEN;	2688	our $GOTOGEN;
2439		2689
2440	sub cf::object::player::goto {	2690	sub cf::object::player::goto {
2441	my ($self, $path, $x, $y, $check, $done) = @_;	2691	my ($self, $path, $x, $y, $check, $done) = @_;
2442		2692
		2693	if ($self->{_link_recursion} >= $MAX_LINKS) {
		2694	warn "FATAL: link recursion exceeded, ", $self->name, " goto $path $x $y, redirecting.";
		2695	$self->failmsg ("Something went wrong inside the server - please contact an administrator!");
		2696	($path, $x, $y) = @$EMERGENCY_POSITION;
		2697	}
		2698
2443	# do generation counting so two concurrent goto's will be executed in-order	2699	# do generation counting so two concurrent goto's will be executed in-order
2444	my $gen = $self->{_goto_generation} = ++$GOTOGEN;	2700	my $gen = $self->{_goto_generation} = ++$GOTOGEN;
2445		2701
2446	$self->enter_link;	2702	$self->enter_link;
2447		2703
2448	(async {	2704	(async {
		2705	$Coro::current->{desc} = "player::goto $path $x $y";
		2706
		2707	# *tag paths override both path and x|y
		2708	if ($path =~ /^\*(.*)$/) {
		2709	if (my @obs = grep $_->map, ext::map_tags::find $1) {
		2710	my $ob = $obs[rand @obs];
		2711
		2712	# see if we actually can go there
		2713	if (@obs = grep !$self->blocked ($_->map, $_->x, $_->y), $ob, $ob->tail) {
		2714	$ob = $obs[rand @obs];
		2715	} else {
		2716	$self->message ("Wow, it's pretty crowded in there.", cf::NDI_UNIQUE | cf::NDI_RED);
		2717	}
		2718	# else put us there anyways for now #d#
		2719
		2720	($path, $x, $y) = ($ob->map, $ob->x, $ob->y);
		2721	} else {
		2722	($path, $x, $y) = (undef, undef, undef);
		2723	}
		2724	}
		2725
2449	my $map = eval {	2726	my $map = eval {
2450	my $map = cf::map::find $path;	2727	my $map = defined $path ? cf::map::find $path : undef;
2451		2728
2452	if ($map) {	2729	if ($map) {
2453	$map = $map->customise_for ($self);	2730	$map = $map->customise_for ($self);
2454	$map = $check->($map) if $check && $map;	2731	$map = $check->($map, $x, $y, $self) if $check && $map;
2455	} else {	2732	} else {
2456	$self->message ("The exit to '$path' is closed", cf::NDI_UNIQUE | cf::NDI_RED);	2733	$self->message ("The exit to '$path' is closed.", cf::NDI_UNIQUE | cf::NDI_RED);
2457	}	2734	}
2458		2735
2459	$map	2736	$map
2460	};	2737	};
2461		2738
…		…
2467	if ($gen == $self->{_goto_generation}) {	2744	if ($gen == $self->{_goto_generation}) {
2468	delete $self->{_goto_generation};	2745	delete $self->{_goto_generation};
2469	$self->leave_link ($map, $x, $y);	2746	$self->leave_link ($map, $x, $y);
2470	}	2747	}
2471		2748
2472	$done->() if $done;	2749	$done->($self) if $done;
2473	})->prio (1);	2750	})->prio (1);
2474	}	2751	}
2475		2752
2476	=item $player_object->enter_exit ($exit_object)	2753	=item $player_object->enter_exit ($exit_object)
2477		2754
…		…
2497	}	2774	}
2498		2775
2499	sub prepare_random_map {	2776	sub prepare_random_map {
2500	my ($exit) = @_;	2777	my ($exit) = @_;
2501		2778
2502	my $guard = cf::lock_acquire "exit_prepare:$exit";
2503
2504	# all this does is basically replace the /! path by	2779	# all this does is basically replace the /! path by
2505	# a new random map path (?random/...) with a seed	2780	# a new random map path (?random/...) with a seed
2506	# that depends on the exit object	2781	# that depends on the exit object
2507		2782
2508	my $rmp = parse_random_map_params $exit->msg;	2783	my $rmp = parse_random_map_params $exit->msg;
…		…
2510	if ($exit->map) {	2785	if ($exit->map) {
2511	$rmp->{region} = $exit->region->name;	2786	$rmp->{region} = $exit->region->name;
2512	$rmp->{origin_map} = $exit->map->path;	2787	$rmp->{origin_map} = $exit->map->path;
2513	$rmp->{origin_x} = $exit->x;	2788	$rmp->{origin_x} = $exit->x;
2514	$rmp->{origin_y} = $exit->y;	2789	$rmp->{origin_y} = $exit->y;
		2790
		2791	$exit->map->touch;
2515	}	2792	}
2516		2793
2517	$rmp->{random_seed} ||= $exit->random_seed;	2794	$rmp->{random_seed} ||= $exit->random_seed;
2518		2795
2519	my $data = cf::to_json $rmp;	2796	my $data = JSON::XS->new->utf8->pretty->canonical->encode ($rmp);
2520	my $md5 = Digest::MD5::md5_hex $data;	2797	my $md5 = Digest::MD5::md5_hex $data;
2521	my $meta = "$RANDOMDIR/$md5.meta";	2798	my $meta = "$RANDOMDIR/$md5.meta";
2522		2799
2523	if (my $fh = aio_open "$meta~", O_WRONLY | O_CREAT, 0666) {	2800	if (my $fh = aio_open "$meta~", O_WRONLY | O_CREAT, 0666) {
2524	aio_write $fh, 0, (length $data), $data, 0;	2801	aio_write $fh, 0, (length $data), $data, 0;
2525	undef $fh;	2802	undef $fh;
2526	aio_rename "$meta~", $meta;	2803	aio_rename "$meta~", $meta;
2527		2804
		2805	my $slaying = "?random/$md5";
		2806
		2807	if ($exit->valid) {
2528	$exit->slaying ("?random/$md5");	2808	$exit->slaying ("?random/$md5");
2529	$exit->msg (undef);	2809	$exit->msg (undef);
		2810	}
2530	}	2811	}
2531	}	2812	}
2532		2813
2533	sub cf::object::player::enter_exit {	2814	sub cf::object::player::enter_exit {
2534	my ($self, $exit) = @_;	2815	my ($self, $exit) = @_;
2535		2816
2536	return unless $self->type == cf::PLAYER;	2817	return unless $self->type == cf::PLAYER;
2537		2818
2538	if ($exit->slaying eq "/!") {
2539	#TODO: this should de-fi-ni-te-ly not be a sync-job
2540	# the problem is that $exit might not survive long enough
2541	# so it needs to be done right now, right here
2542	cf::sync_job { prepare_random_map $exit };
2543	}
2544
2545	my $slaying = cf::map::normalise $exit->slaying, $exit->map && $exit->map->path;
2546	my $hp = $exit->stats->hp;
2547	my $sp = $exit->stats->sp;
2548
2549	$self->enter_link;	2819	$self->enter_link;
2550		2820
2551	# if exit is damned, update players death & WoR home-position
2552	$self->contr->savebed ($slaying, $hp, $sp)
2553	if $exit->flag (FLAG_DAMNED);
2554
2555	(async {	2821	(async {
2556	$self->deactivate_recursive; # just to be sure	2822	$Coro::current->{desc} = "enter_exit";
		2823
2557	unless (eval {	2824	unless (eval {
		2825	$self->deactivate_recursive; # just to be sure
		2826
		2827	# random map handling
		2828	{
		2829	my $guard = cf::lock_acquire "exit_prepare:$exit";
		2830
		2831	prepare_random_map $exit
		2832	if $exit->slaying eq "/!";
		2833	}
		2834
		2835	my $map = cf::map::normalise $exit->slaying, $exit->map && $exit->map->path;
		2836	my $x = $exit->stats->hp;
		2837	my $y = $exit->stats->sp;
		2838
2558	$self->goto ($slaying, $hp, $sp);	2839	$self->goto ($map, $x, $y);
2559		2840
		2841	# if exit is damned, update players death & WoR home-position
		2842	$self->contr->savebed ($map, $x, $y)
		2843	if $exit->flag (cf::FLAG_DAMNED);
		2844
2560	1;	2845	1
2561	}) {	2846	}) {
2562	$self->message ("Something went wrong deep within the crossfire server. "	2847	$self->message ("Something went wrong deep within the deliantra server. "
2563	. "I'll try to bring you back to the map you were before. "	2848	. "I'll try to bring you back to the map you were before. "
2564	. "Please report this to the dungeon master!",	2849	. "Please report this to the dungeon master!",
2565	cf::NDI_UNIQUE | cf::NDI_RED);	2850	cf::NDI_UNIQUE | cf::NDI_RED);
2566		2851
2567	warn "ERROR in enter_exit: $@";	2852	warn "ERROR in enter_exit: $@";
…		…
2584	sub cf::client::send_drawinfo {	2869	sub cf::client::send_drawinfo {
2585	my ($self, $text, $flags) = @_;	2870	my ($self, $text, $flags) = @_;
2586		2871
2587	utf8::encode $text;	2872	utf8::encode $text;
2588	$self->send_packet (sprintf "drawinfo %d %s", $flags || cf::NDI_BLACK, $text);	2873	$self->send_packet (sprintf "drawinfo %d %s", $flags || cf::NDI_BLACK, $text);
		2874	}
		2875
		2876	=item $client->send_big_packet ($pkt)
		2877
		2878	Like C<send_packet>, but tries to compress large packets, and fragments
		2879	them as required.
		2880
		2881	=cut
		2882
		2883	our $MAXFRAGSIZE = cf::MAXSOCKBUF - 64;
		2884
		2885	sub cf::client::send_big_packet {
		2886	my ($self, $pkt) = @_;
		2887
		2888	# try lzf for large packets
		2889	$pkt = "lzf " . Compress::LZF::compress $pkt
		2890	if 1024 <= length $pkt and $self->{can_lzf};
		2891
		2892	# split very large packets
		2893	if ($MAXFRAGSIZE < length $pkt and $self->{can_lzf}) {
		2894	$self->send_packet ("frag $_") for unpack "(a$MAXFRAGSIZE)*", $pkt;
		2895	$pkt = "frag";
		2896	}
		2897
		2898	$self->send_packet ($pkt);
2589	}	2899	}
2590		2900
2591	=item $client->send_msg ($channel, $msg, $color, [extra...])	2901	=item $client->send_msg ($channel, $msg, $color, [extra...])
2592		2902
2593	Send a drawinfo or msg packet to the client, formatting the msg for the	2903	Send a drawinfo or msg packet to the client, formatting the msg for the
…		…
2595	the message, with C<log> being the default. If C<$color> is negative, suppress	2905	the message, with C<log> being the default. If C<$color> is negative, suppress
2596	the message unless the client supports the msg packet.	2906	the message unless the client supports the msg packet.
2597		2907
2598	=cut	2908	=cut
2599		2909
		2910	# non-persistent channels (usually the info channel)
2600	our %CHANNEL = (	2911	our %CHANNEL = (
		2912	"c/motd" => {
		2913	id => "infobox",
		2914	title => "MOTD",
		2915	reply => undef,
		2916	tooltip => "The message of the day",
		2917	},
2601	"c/identify" => {	2918	"c/identify" => {
2602	id => "identify",	2919	id => "infobox",
2603	title => "Identify",	2920	title => "Identify",
2604	reply => undef,	2921	reply => undef,
2605	tooltip => "Items recently identified",	2922	tooltip => "Items recently identified",
2606	},	2923	},
2607	"c/examine" => {	2924	"c/examine" => {
2608	id => "examine",	2925	id => "infobox",
2609	title => "Examine",	2926	title => "Examine",
2610	reply => undef,	2927	reply => undef,
2611	tooltip => "Signs and other items you examined",	2928	tooltip => "Signs and other items you examined",
2612	},	2929	},
		2930	"c/shopinfo" => {
		2931	id => "infobox",
		2932	title => "Shop Info",
		2933	reply => undef,
		2934	tooltip => "What your bargaining skill tells you about the shop",
		2935	},
		2936	"c/book" => {
		2937	id => "infobox",
		2938	title => "Book",
		2939	reply => undef,
		2940	tooltip => "The contents of a note or book",
		2941	},
		2942	"c/lookat" => {
		2943	id => "infobox",
		2944	title => "Look",
		2945	reply => undef,
		2946	tooltip => "What you saw there",
		2947	},
		2948	"c/who" => {
		2949	id => "infobox",
		2950	title => "Players",
		2951	reply => undef,
		2952	tooltip => "Shows players who are currently online",
		2953	},
		2954	"c/body" => {
		2955	id => "infobox",
		2956	title => "Body Parts",
		2957	reply => undef,
		2958	tooltip => "Shows which body parts you posess and are available",
		2959	},
		2960	"c/statistics" => {
		2961	id => "infobox",
		2962	title => "Statistics",
		2963	reply => undef,
		2964	tooltip => "Shows your primary statistics",
		2965	},
		2966	"c/skills" => {
		2967	id => "infobox",
		2968	title => "Skills",
		2969	reply => undef,
		2970	tooltip => "Shows your experience per skill and item power",
		2971	},
		2972	"c/shopitems" => {
		2973	id => "infobox",
		2974	title => "Shop Items",
		2975	reply => undef,
		2976	tooltip => "Shows the items currently for sale in this shop",
		2977	},
		2978	"c/resistances" => {
		2979	id => "infobox",
		2980	title => "Resistances",
		2981	reply => undef,
		2982	tooltip => "Shows your resistances",
		2983	},
		2984	"c/pets" => {
		2985	id => "infobox",
		2986	title => "Pets",
		2987	reply => undef,
		2988	tooltip => "Shows information abotu your pets/a specific pet",
		2989	},
		2990	"c/perceiveself" => {
		2991	id => "infobox",
		2992	title => "Perceive Self",
		2993	reply => undef,
		2994	tooltip => "You gained detailed knowledge about yourself",
		2995	},
		2996	"c/uptime" => {
		2997	id => "infobox",
		2998	title => "Uptime",
		2999	reply => undef,
		3000	tooltip => "How long the server has been running since last restart",
		3001	},
		3002	"c/mapinfo" => {
		3003	id => "infobox",
		3004	title => "Map Info",
		3005	reply => undef,
		3006	tooltip => "Information related to the maps",
		3007	},
		3008	"c/party" => {
		3009	id => "party",
		3010	title => "Party",
		3011	reply => "gsay ",
		3012	tooltip => "Messages and chat related to your party",
		3013	},
		3014	"c/death" => {
		3015	id => "death",
		3016	title => "Death",
		3017	reply => undef,
		3018	tooltip => "Reason for and more info about your most recent death",
		3019	},
		3020	"c/say" => $SAY_CHANNEL,
		3021	"c/chat" => $CHAT_CHANNEL,
2613	);	3022	);
2614		3023
2615	sub cf::client::send_msg {	3024	sub cf::client::send_msg {
2616	my ($self, $channel, $msg, $color, @extra) = @_;	3025	my ($self, $channel, $msg, $color, @extra) = @_;
2617		3026
2618	$msg = $self->pl->expand_cfpod ($msg);	3027	$msg = $self->pl->expand_cfpod ($msg)
		3028	unless $color & cf::NDI_VERBATIM;
2619		3029
2620	$color &= cf::NDI_CLIENT_MASK; # just in case...	3030	$color &= cf::NDI_CLIENT_MASK; # just in case...
2621		3031
2622	# check predefined channels, for the benefit of C	3032	# check predefined channels, for the benefit of C
2623	$channel = $CHANNEL{$channel} if $CHANNEL{$channel};	3033	if ($CHANNEL{$channel}) {
		3034	$channel = $CHANNEL{$channel};
2624		3035
		3036	$self->ext_msg (channel_info => $channel);
		3037	$channel = $channel->{id};
		3038
2625	if (ref $channel) {	3039	} elsif (ref $channel) {
2626	# send meta info to client, if not yet sent	3040	# send meta info to client, if not yet sent
2627	unless (exists $self->{channel}{$channel->{id}}) {	3041	unless (exists $self->{channel}{$channel->{id}}) {
2628	$self->{channel}{$channel->{id}} = $channel;	3042	$self->{channel}{$channel->{id}} = $channel;
2629	$self->ext_msg (channel_info => $channel)	3043	$self->ext_msg (channel_info => $channel);
2630	if $self->can_msg;
2631	}	3044	}
2632		3045
2633	$channel = $channel->{id};	3046	$channel = $channel->{id};
2634	}	3047	}
2635		3048
2636	return unless @extra || length $msg;	3049	return unless @extra || length $msg;
2637		3050
2638	if ($self->can_msg) {
2639	# default colour, mask it out	3051	# default colour, mask it out
2640	$color &= ~(cf::NDI_COLOR_MASK | cf::NDI_DEF)	3052	$color &= ~(cf::NDI_COLOR_MASK | cf::NDI_DEF)
2641	if $color & cf::NDI_DEF;	3053	if $color & cf::NDI_DEF;
2642		3054
2643	$self->send_packet ("msg " . $self->{json_coder}->encode (	3055	my $pkt = "msg "
		3056	. $self->{json_coder}->encode (
2644	[$color & cf::NDI_CLIENT_MASK, $channel, $msg, @extra]));	3057	[$color & cf::NDI_CLIENT_MASK, $channel, $msg, @extra]
2645	} else {	3058	);
2646	if ($color >= 0) {
2647	# replace some tags by gcfclient-compatible ones
2648	for ($msg) {
2649	1 while
2650	s/<b>([^<]*)<\/b>/[b]${1}[\/b]/
2651	|| s/<i>([^<]*)<\/i>/[i]${1}[\/i]/
2652	|| s/<u>([^<]*)<\/u>/[ul]${1}[\/ul]/
2653	|| s/<tt>([^<]*)<\/tt>/[fixed]${1}[\/fixed]/
2654	|| s/<fg name=\"([^"]+)\">([^<]*)<\/fg>/[color=$1]${2}[\/color]/;
2655	}
2656		3059
2657	$color &= cf::NDI_COLOR_MASK;	3060	$self->send_big_packet ($pkt);
2658
2659	utf8::encode $msg;
2660
2661	if (0 && $msg =~ /\[/) {
2662	# COMMAND/INFO
2663	$self->send_packet ("drawextinfo $color 10 8 $msg")
2664	} else {
2665	$msg =~ s/\[\/?(?:b|i|u|fixed|color)[^\]]*\]//g;
2666	$self->send_packet ("drawinfo $color $msg")
2667	}
2668	}
2669	}
2670	}	3061	}
2671		3062
2672	=item $client->ext_msg ($type, @msg)	3063	=item $client->ext_msg ($type, @msg)
2673		3064
2674	Sends an ext event to the client.	3065	Sends an ext event to the client.
…		…
2677		3068
2678	sub cf::client::ext_msg($$@) {	3069	sub cf::client::ext_msg($$@) {
2679	my ($self, $type, @msg) = @_;	3070	my ($self, $type, @msg) = @_;
2680		3071
2681	if ($self->extcmd == 2) {	3072	if ($self->extcmd == 2) {
2682	$self->send_packet ("ext " . $self->{json_coder}->encode ([$type, @msg]));	3073	$self->send_big_packet ("ext " . $self->{json_coder}->encode ([$type, @msg]));
2683	} elsif ($self->extcmd == 1) { # TODO: remove	3074	} elsif ($self->extcmd == 1) { # TODO: remove
2684	push @msg, msgtype => "event_$type";	3075	push @msg, msgtype => "event_$type";
2685	$self->send_packet ("ext " . $self->{json_coder}->encode ({@msg}));	3076	$self->send_big_packet ("ext " . $self->{json_coder}->encode ({@msg}));
2686	}	3077	}
2687	}	3078	}
2688		3079
2689	=item $client->ext_reply ($msgid, @msg)	3080	=item $client->ext_reply ($msgid, @msg)
2690		3081
…		…
2694		3085
2695	sub cf::client::ext_reply($$@) {	3086	sub cf::client::ext_reply($$@) {
2696	my ($self, $id, @msg) = @_;	3087	my ($self, $id, @msg) = @_;
2697		3088
2698	if ($self->extcmd == 2) {	3089	if ($self->extcmd == 2) {
2699	$self->send_packet ("ext " . $self->{json_coder}->encode (["reply-$id", @msg]));	3090	$self->send_big_packet ("ext " . $self->{json_coder}->encode (["reply-$id", @msg]));
2700	} elsif ($self->extcmd == 1) {	3091	} elsif ($self->extcmd == 1) {
2701	#TODO: version 1, remove	3092	#TODO: version 1, remove
2702	unshift @msg, msgtype => "reply", msgid => $id;	3093	unshift @msg, msgtype => "reply", msgid => $id;
2703	$self->send_packet ("ext " . $self->{json_coder}->encode ({@msg}));	3094	$self->send_big_packet ("ext " . $self->{json_coder}->encode ({@msg}));
2704	}	3095	}
2705	}	3096	}
2706		3097
2707	=item $success = $client->query ($flags, "text", \&cb)	3098	=item $success = $client->query ($flags, "text", \&cb)
2708		3099
…		…
2809		3200
2810	$coro	3201	$coro
2811	}	3202	}
2812		3203
2813	cf::client->attach (	3204	cf::client->attach (
2814	on_destroy => sub {	3205	on_client_destroy => sub {
2815	my ($ns) = @_;	3206	my ($ns) = @_;
2816		3207
2817	$_->cancel for values %{ (delete $ns->{_coro}) || {} };	3208	$_->cancel for values %{ (delete $ns->{_coro}) || {} };
2818	},	3209	},
2819	);	3210	);
…		…
2835	our $safe_hole = new Safe::Hole;	3226	our $safe_hole = new Safe::Hole;
2836		3227
2837	$SIG{FPE} = 'IGNORE';	3228	$SIG{FPE} = 'IGNORE';
2838		3229
2839	$safe->permit_only (Opcode::opset qw(	3230	$safe->permit_only (Opcode::opset qw(
2840	:base_core :base_mem :base_orig :base_math	3231	:base_core :base_mem :base_orig :base_math :base_loop
2841	grepstart grepwhile mapstart mapwhile	3232	grepstart grepwhile mapstart mapwhile
2842	sort time	3233	sort time
2843	));	3234	));
2844		3235
2845	# here we export the classes and methods available to script code	3236	# here we export the classes and methods available to script code
…		…
2847	=pod	3238	=pod
2848		3239
2849	The following functions and methods are available within a safe environment:	3240	The following functions and methods are available within a safe environment:
2850		3241
2851	cf::object	3242	cf::object
2852	contr pay_amount pay_player map x y force_find force_add	3243	contr pay_amount pay_player map x y force_find force_add destroy
2853	insert remove name archname title slaying race decrease_ob_nr	3244	insert remove name archname title slaying race decrease split
		3245	value
2854		3246
2855	cf::object::player	3247	cf::object::player
2856	player	3248	player
2857		3249
2858	cf::player	3250	cf::player
…		…
2863		3255
2864	=cut	3256	=cut
2865		3257
2866	for (	3258	for (
2867	["cf::object" => qw(contr pay_amount pay_player map force_find force_add x y	3259	["cf::object" => qw(contr pay_amount pay_player map force_find force_add x y
2868	insert remove inv name archname title slaying race	3260	insert remove inv nrof name archname title slaying race
2869	decrease_ob_nr)],	3261	decrease split destroy change_exp value msg lore send_msg)],
2870	["cf::object::player" => qw(player)],	3262	["cf::object::player" => qw(player)],
2871	["cf::player" => qw(peaceful)],	3263	["cf::player" => qw(peaceful send_msg)],
2872	["cf::map" => qw(trigger)],	3264	["cf::map" => qw(trigger)],
2873	) {	3265	) {
2874	no strict 'refs';	3266	no strict 'refs';
2875	my ($pkg, @funs) = @$_;	3267	my ($pkg, @funs) = @$_;
2876	*{"safe::$pkg\::$_"} = $safe_hole->wrap (\&{"$pkg\::$_"})	3268	*{"safe::$pkg\::$_"} = $safe_hole->wrap (\&{"$pkg\::$_"})
…		…
2894		3286
2895	my $qcode = $code;	3287	my $qcode = $code;
2896	$qcode =~ s/"/‟/g; # not allowed in #line filenames	3288	$qcode =~ s/"/‟/g; # not allowed in #line filenames
2897	$qcode =~ s/\n/\\n/g;	3289	$qcode =~ s/\n/\\n/g;
2898		3290
		3291	%vars = (_dummy => 0) unless %vars;
		3292
		3293	my @res;
2899	local $_;	3294	local $_;
2900	local @safe::cf::_safe_eval_args = values %vars;
2901		3295
2902	my $eval =	3296	my $eval =
2903	"do {\n"	3297	"do {\n"
2904	. "my (" . (join ",", map "\$$_", keys %vars) . ") = \@cf::_safe_eval_args;\n"	3298	. "my (" . (join ",", map "\$$_", keys %vars) . ") = \@cf::_safe_eval_args;\n"
2905	. "#line 0 \"{$qcode}\"\n"	3299	. "#line 0 \"{$qcode}\"\n"
2906	. $code	3300	. $code
2907	. "\n}"	3301	. "\n}"
2908	;	3302	;
2909		3303
		3304	if ($CFG{safe_eval}) {
2910	sub_generation_inc;	3305	sub_generation_inc;
		3306	local @safe::cf::_safe_eval_args = values %vars;
2911	my @res = wantarray ? $safe->reval ($eval) : scalar $safe->reval ($eval);	3307	@res = wantarray ? $safe->reval ($eval) : scalar $safe->reval ($eval);
2912	sub_generation_inc;	3308	sub_generation_inc;
		3309	} else {
		3310	local @cf::_safe_eval_args = values %vars;
		3311	@res = wantarray ? eval eval : scalar eval $eval;
		3312	}
2913		3313
2914	if ($@) {	3314	if ($@) {
2915	warn "$@";	3315	warn "$@";
2916	warn "while executing safe code '$code'\n";	3316	warn "while executing safe code '$code'\n";
2917	warn "with arguments " . (join " ", %vars) . "\n";	3317	warn "with arguments " . (join " ", %vars) . "\n";
…		…
2936	=cut	3336	=cut
2937		3337
2938	sub register_script_function {	3338	sub register_script_function {
2939	my ($fun, $cb) = @_;	3339	my ($fun, $cb) = @_;
2940		3340
2941	no strict 'refs';	3341	$fun = "safe::$fun" if $CFG{safe_eval};
2942	*{"safe::$fun"} = $safe_hole->wrap ($cb);	3342	*$fun = $safe_hole->wrap ($cb);
2943	}	3343	}
2944		3344
2945	=back	3345	=back
2946		3346
2947	=cut	3347	=cut
…		…
2968		3368
2969	$facedata->{version} == 2	3369	$facedata->{version} == 2
2970	or cf::cleanup "$path: version mismatch, cannot proceed.";	3370	or cf::cleanup "$path: version mismatch, cannot proceed.";
2971		3371
2972	# patch in the exptable	3372	# patch in the exptable
		3373	my $exp_table = $enc->encode ([map cf::level_to_min_exp $_, 1 .. cf::settings->max_level]);
2973	$facedata->{resource}{"res/exp_table"} = {	3374	$facedata->{resource}{"res/exp_table"} = {
2974	type => FT_RSRC,	3375	type => FT_RSRC,
2975	data => $enc->encode ([map cf::level_to_min_exp $_, 1 .. cf::settings->max_level]),	3376	data => $exp_table,
		3377	hash => (Digest::MD5::md5 $exp_table),
2976	};	3378	};
2977	cf::cede_to_tick;	3379	cf::cede_to_tick;
2978		3380
2979	{	3381	{
2980	my $faces = $facedata->{faceinfo};	3382	my $faces = $facedata->{faceinfo};
2981		3383
2982	while (my ($face, $info) = each %$faces) {	3384	while (my ($face, $info) = each %$faces) {
2983	my $idx = (cf::face::find $face) || cf::face::alloc $face;	3385	my $idx = (cf::face::find $face) || cf::face::alloc $face;
		3386
2984	cf::face::set_visibility $idx, $info->{visibility};	3387	cf::face::set_visibility $idx, $info->{visibility};
2985	cf::face::set_magicmap $idx, $info->{magicmap};	3388	cf::face::set_magicmap $idx, $info->{magicmap};
2986	cf::face::set_data $idx, 0, $info->{data32}, Digest::MD5::md5 $info->{data32};	3389	cf::face::set_data $idx, 0, $info->{data32}, $info->{hash32};
2987	cf::face::set_data $idx, 1, $info->{data64}, Digest::MD5::md5 $info->{data64};	3390	cf::face::set_data $idx, 1, $info->{data64}, $info->{hash64};
2988		3391
2989	cf::cede_to_tick;	3392	cf::cede_to_tick;
2990	}	3393	}
2991		3394
2992	while (my ($face, $info) = each %$faces) {	3395	while (my ($face, $info) = each %$faces) {
2993	next unless $info->{smooth};	3396	next unless $info->{smooth};
		3397
2994	my $idx = cf::face::find $face	3398	my $idx = cf::face::find $face
2995	or next;	3399	or next;
		3400
2996	if (my $smooth = cf::face::find $info->{smooth}) {	3401	if (my $smooth = cf::face::find $info->{smooth}) {
2997	cf::face::set_smooth $idx, $smooth;	3402	cf::face::set_smooth $idx, $smooth;
2998	cf::face::set_smoothlevel $idx, $info->{smoothlevel};	3403	cf::face::set_smoothlevel $idx, $info->{smoothlevel};
2999	} else {	3404	} else {
3000	warn "smooth face '$info->{smooth}' not found for face '$face'";	3405	warn "smooth face '$info->{smooth}' not found for face '$face'";
…		…
3014		3419
3015	cf::anim::invalidate_all; # d'oh	3420	cf::anim::invalidate_all; # d'oh
3016	}	3421	}
3017		3422
3018	{	3423	{
3019	# TODO: for gcfclient pleasure, we should give resources
3020	# that gcfclient doesn't grok a >10000 face index.
3021	my $res = $facedata->{resource};	3424	my $res = $facedata->{resource};
3022		3425
3023	my $soundconf = delete $res->{"res/sound.conf"};
3024
3025	while (my ($name, $info) = each %$res) {	3426	while (my ($name, $info) = each %$res) {
		3427	if (defined $info->{type}) {
3026	my $idx = (cf::face::find $name) || cf::face::alloc $name;	3428	my $idx = (cf::face::find $name) || cf::face::alloc $name;
3027	my $data;
3028		3429
3029	if ($info->{type} & 1) {	3430	cf::face::set_data $idx, 0, $info->{data}, $info->{hash};
3030	# prepend meta info	3431	cf::face::set_type $idx, $info->{type};
3031
3032	my $meta = $enc->encode ({
3033	name => $name,
3034	%{ $info->{meta} || {} },
3035	});
3036
3037	$data = pack "(w/a*)*", $meta, $info->{data};
3038	} else {	3432	} else {
3039	$data = $info->{data};	3433	$RESOURCE{$name} = $info; # unused
3040	}	3434	}
3041		3435
3042	cf::face::set_data $idx, 0, $data, Digest::MD5::md5 $data;
3043	cf::face::set_type $idx, $info->{type};
3044
3045	cf::cede_to_tick;	3436	cf::cede_to_tick;
3046	}	3437	}
3047
3048	if ($soundconf) {
3049	$soundconf = $enc->decode (delete $soundconf->{data});
3050
3051	for (0 .. SOUND_CAST_SPELL_0 - 1) {
3052	my $sound = $soundconf->{compat}[$_]
3053	or next;
3054
3055	my $face = cf::face::find "sound/$sound->[1]";
3056	cf::sound::set $sound->[0] => $face;
3057	cf::sound::old_sound_index $_, $face; # gcfclient-compat
3058	}
3059
3060	while (my ($k, $v) = each %{$soundconf->{event}}) {
3061	my $face = cf::face::find "sound/$v";
3062	cf::sound::set $k => $face;
3063	}
3064	}
3065	}	3438	}
		3439
		3440	cf::global->invoke (EVENT_GLOBAL_RESOURCE_UPDATE);
3066		3441
3067	1	3442	1
3068	}	3443	}
3069		3444
3070	register_exticmd fx_want => sub {	3445	register_exticmd fx_want => sub {
…		…
3072		3447
3073	while (my ($k, $v) = each %$want) {	3448	while (my ($k, $v) = each %$want) {
3074	$ns->fx_want ($k, $v);	3449	$ns->fx_want ($k, $v);
3075	}	3450	}
3076	};	3451	};
		3452
		3453	sub load_resource_file($) {
		3454	my $guard = lock_acquire "load_resource_file";
		3455
		3456	my $status = load_resource_file_ $_[0];
		3457	get_slot 0.1, 100;
		3458	cf::arch::commit_load;
		3459
		3460	$status
		3461	}
3077		3462
3078	sub reload_regions {	3463	sub reload_regions {
3079	# HACK to clear player env face cache, we need some signal framework	3464	# HACK to clear player env face cache, we need some signal framework
3080	# for this (global event?)	3465	# for this (global event?)
3081	%ext::player_env::MUSIC_FACE_CACHE = ();	3466	%ext::player_env::MUSIC_FACE_CACHE = ();
…		…
3095	}	3480	}
3096		3481
3097	sub reload_archetypes {	3482	sub reload_archetypes {
3098	load_resource_file "$DATADIR/archetypes"	3483	load_resource_file "$DATADIR/archetypes"
3099	or die "unable to load archetypes\n";	3484	or die "unable to load archetypes\n";
3100	#d# NEED to laod twice to resolve forward references
3101	# this really needs to be done in an extra post-pass
3102	# (which needs to be synchronous, so solve it differently)
3103	load_resource_file "$DATADIR/archetypes"
3104	or die "unable to load archetypes\n";
3105	}	3485	}
3106		3486
3107	sub reload_treasures {	3487	sub reload_treasures {
3108	load_resource_file "$DATADIR/treasures"	3488	load_resource_file "$DATADIR/treasures"
3109	or die "unable to load treasurelists\n";	3489	or die "unable to load treasurelists\n";
3110	}	3490	}
3111		3491
		3492	sub reload_sound {
		3493	warn "loading sound config from $DATADIR/sound\n";
		3494
		3495	0 < Coro::AIO::aio_load "$DATADIR/sound", my $data
		3496	or die "$DATADIR/sound $!";
		3497
		3498	my $soundconf = JSON::XS->new->utf8->relaxed->decode ($data);
		3499
		3500	for (0 .. SOUND_CAST_SPELL_0 - 1) {
		3501	my $sound = $soundconf->{compat}[$_]
		3502	or next;
		3503
		3504	my $face = cf::face::find "sound/$sound->[1]";
		3505	cf::sound::set $sound->[0] => $face;
		3506	cf::sound::old_sound_index $_, $face; # gcfclient-compat
		3507	}
		3508
		3509	while (my ($k, $v) = each %{$soundconf->{event}}) {
		3510	my $face = cf::face::find "sound/$v";
		3511	cf::sound::set $k => $face;
		3512	}
		3513	}
		3514
3112	sub reload_resources {	3515	sub reload_resources {
3113	warn "reloading resource files...\n";	3516	warn "reloading resource files...\n";
3114		3517
		3518	reload_facedata;
		3519	reload_sound;
		3520	reload_archetypes;
3115	reload_regions;	3521	reload_regions;
3116	reload_facedata;
3117	#reload_archetypes;#d#
3118	reload_archetypes;
3119	reload_treasures;	3522	reload_treasures;
3120		3523
3121	warn "finished reloading resource files\n";	3524	warn "finished reloading resource files\n";
3122	}	3525	}
3123		3526
3124	sub init {
3125	reload_resources;
3126	}
3127
3128	sub reload_config {	3527	sub reload_config {
		3528	warn "reloading config file...\n";
		3529
3129	open my $fh, "<:utf8", "$CONFDIR/config"	3530	open my $fh, "<:utf8", "$CONFDIR/config"
3130	or return;	3531	or return;
3131		3532
3132	local $/;	3533	local $/;
3133	*CFG = YAML::Syck::Load <$fh>;	3534	*CFG = YAML::XS::Load scalar <$fh>;
3134		3535
3135	$EMERGENCY_POSITION = $CFG{emergency_position} || ["/world/world_105_115", 5, 37];	3536	$EMERGENCY_POSITION = $CFG{emergency_position} || ["/world/world_104_115", 49, 38];
3136		3537
3137	$cf::map::MAX_RESET = $CFG{map_max_reset} if exists $CFG{map_max_reset};	3538	$cf::map::MAX_RESET = $CFG{map_max_reset} if exists $CFG{map_max_reset};
3138	$cf::map::DEFAULT_RESET = $CFG{map_default_reset} if exists $CFG{map_default_reset};	3539	$cf::map::DEFAULT_RESET = $CFG{map_default_reset} if exists $CFG{map_default_reset};
3139		3540
3140	if (exists $CFG{mlockall}) {	3541	if (exists $CFG{mlockall}) {
…		…
3142	$CFG{mlockall} ? eval "mlockall()" : eval "munlockall()"	3543	$CFG{mlockall} ? eval "mlockall()" : eval "munlockall()"
3143	and die "WARNING: m(un)lockall failed: $!\n";	3544	and die "WARNING: m(un)lockall failed: $!\n";
3144	};	3545	};
3145	warn $@ if $@;	3546	warn $@ if $@;
3146	}	3547	}
		3548
		3549	warn "finished reloading resource files\n";
		3550	}
		3551
		3552	sub pidfile() {
		3553	sysopen my $fh, $PIDFILE, O_RDWR | O_CREAT
		3554	or die "$PIDFILE: $!";
		3555	flock $fh, &Fcntl::LOCK_EX
		3556	or die "$PIDFILE: flock: $!";
		3557	$fh
		3558	}
		3559
		3560	# make sure only one server instance is running at any one time
		3561	sub atomic {
		3562	my $fh = pidfile;
		3563
		3564	my $pid = <$fh>;
		3565	kill 9, $pid if $pid > 0;
		3566
		3567	seek $fh, 0, 0;
		3568	print $fh $$;
		3569	}
		3570
		3571	sub main_loop {
		3572	warn "EV::loop starting\n";
		3573	if (1) {
		3574	EV::loop;
		3575	}
		3576	warn "EV::loop returned\n";
		3577	goto &main_loop unless $REALLY_UNLOOP;
3147	}	3578	}
3148		3579
3149	sub main {	3580	sub main {
		3581	cf::init_globals; # initialise logging
		3582
		3583	LOG llevInfo, "Welcome to Deliantra, v" . VERSION;
		3584	LOG llevInfo, "Copyright (C) 2005-2008 Marc Alexander Lehmann / Robin Redeker / the Deliantra team.";
		3585	LOG llevInfo, "Copyright (C) 1994 Mark Wedel.";
		3586	LOG llevInfo, "Copyright (C) 1992 Frank Tore Johansen.";
		3587
		3588	$Coro::current->prio (Coro::PRIO_MAX); # give the main loop max. priority
		3589
3150	# we must not ever block the main coroutine	3590	# we must not ever block the main coroutine
3151	local $Coro::idle = sub {	3591	local $Coro::idle = sub {
3152	Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#	3592	Carp::cluck "FATAL: Coro::idle was called, major BUG, use cf::sync_job!\n";#d#
3153	(async {	3593	(async {
3154	Event::one_event;	3594	$Coro::current->{desc} = "IDLE BUG HANDLER";
		3595	EV::loop EV::LOOP_ONESHOT;
3155	})->prio (Coro::PRIO_MAX);	3596	})->prio (Coro::PRIO_MAX);
3156	};	3597	};
3157		3598
		3599	evthread_start IO::AIO::poll_fileno;
		3600
		3601	cf::sync_job {
		3602	cf::init_experience;
		3603	cf::init_anim;
		3604	cf::init_attackmess;
		3605	cf::init_dynamic;
		3606
		3607	cf::load_settings;
		3608	cf::load_materials;
		3609
		3610	reload_resources;
3158	reload_config;	3611	reload_config;
3159	db_init;	3612	db_init;
		3613
		3614	cf::init_uuid;
		3615	cf::init_signals;
		3616	cf::init_skills;
		3617
		3618	cf::init_beforeplay;
		3619
		3620	atomic;
		3621
3160	load_extensions;	3622	load_extensions;
3161		3623
3162	$TICK_WATCHER->start;	3624	utime time, time, $RUNTIMEFILE;
3163	Event::loop;	3625
		3626	# no (long-running) fork's whatsoever before this point(!)
		3627	use POSIX ();
		3628	POSIX::close delete $ENV{LOCKUTIL_LOCK_FD} if exists $ENV{LOCKUTIL_LOCK_FD};
		3629
		3630	(pop @POST_INIT)->(0) while @POST_INIT;
		3631	};
		3632
		3633	cf::object::thawer::errors_are_fatal 0;
		3634	warn "parse errors in files are no longer fatal from this point on.\n";
		3635
		3636	main_loop;
3164	}	3637	}
3165		3638
3166	#############################################################################	3639	#############################################################################
3167	# initialisation and cleanup	3640	# initialisation and cleanup
3168		3641
3169	# install some emergency cleanup handlers	3642	# install some emergency cleanup handlers
3170	BEGIN {	3643	BEGIN {
		3644	our %SIGWATCHER = ();
3171	for my $signal (qw(INT HUP TERM)) {	3645	for my $signal (qw(INT HUP TERM)) {
3172	Event->signal (	3646	$SIGWATCHER{$signal} = AE::signal $signal, sub {
3173	reentrant => 0,
3174	data => WF_AUTOCANCEL,
3175	signal => $signal,
3176	prio => 0,
3177	cb => sub {
3178	cf::cleanup "SIG$signal";	3647	cf::cleanup "SIG$signal";
3179	},
3180	);	3648	};
3181	}	3649	}
3182	}	3650	}
3183		3651
3184	sub write_runtime {	3652	sub write_runtime_sync {
3185	my $runtime = "$LOCALDIR/runtime";	3653	my $t0 = AE::time;
3186		3654
3187	# first touch the runtime file to show we are still running:	3655	# first touch the runtime file to show we are still running:
3188	# the fsync below can take a very very long time.	3656	# the fsync below can take a very very long time.
3189		3657
3190	IO::AIO::aio_utime $runtime, undef, undef;	3658	IO::AIO::aio_utime $RUNTIMEFILE, undef, undef;
3191		3659
3192	my $guard = cf::lock_acquire "write_runtime";	3660	my $guard = cf::lock_acquire "write_runtime";
3193		3661
3194	my $fh = aio_open "$runtime~", O_WRONLY | O_CREAT, 0644	3662	my $fh = aio_open "$RUNTIMEFILE~", O_WRONLY | O_CREAT | O_TRUNC, 0644
3195	or return;	3663	or return;
3196		3664
3197	my $value = $cf::RUNTIME + 90 + 10;	3665	my $value = $cf::RUNTIME + 90 + 10;
3198	# 10 is the runtime save interval, for a monotonic clock	3666	# 10 is the runtime save interval, for a monotonic clock
3199	# 60 allows for the watchdog to kill the server.	3667	# 60 allows for the watchdog to kill the server.
…		…
3209	aio_utime $fh, undef, undef;	3677	aio_utime $fh, undef, undef;
3210		3678
3211	close $fh	3679	close $fh
3212	or return;	3680	or return;
3213		3681
3214	aio_rename "$runtime~", $runtime	3682	aio_rename "$RUNTIMEFILE~", $RUNTIMEFILE
3215	and return;	3683	and return;
3216		3684
3217	warn "runtime file written.\n";	3685	warn sprintf "runtime file written (%gs).\n", AE::time - $t0;
3218		3686
3219	1	3687	1
		3688	}
		3689
		3690	our $uuid_lock;
		3691	our $uuid_skip;
		3692
		3693	sub write_uuid_sync($) {
		3694	$uuid_skip ||= $_[0];
		3695
		3696	return if $uuid_lock;
		3697	local $uuid_lock = 1;
		3698
		3699	my $uuid = "$LOCALDIR/uuid";
		3700
		3701	my $fh = aio_open "$uuid~", O_WRONLY | O_CREAT, 0644
		3702	or return;
		3703
		3704	my $value = uuid_seq uuid_cur;
		3705
		3706	unless ($value) {
		3707	warn "cowardly refusing to write zero uuid value!\n";
		3708	return;
		3709	}
		3710
		3711	my $value = uuid_str $value + $uuid_skip;
		3712	$uuid_skip = 0;
		3713
		3714	(aio_write $fh, 0, (length $value), $value, 0) <= 0
		3715	and return;
		3716
		3717	# always fsync - this file is important
		3718	aio_fsync $fh
		3719	and return;
		3720
		3721	close $fh
		3722	or return;
		3723
		3724	aio_rename "$uuid~", $uuid
		3725	and return;
		3726
		3727	warn "uuid file written ($value).\n";
		3728
		3729	1
		3730
		3731	}
		3732
		3733	sub write_uuid($$) {
		3734	my ($skip, $sync) = @_;
		3735
		3736	$sync ? write_uuid_sync $skip
		3737	: async { write_uuid_sync $skip };
3220	}	3738	}
3221		3739
3222	sub emergency_save() {	3740	sub emergency_save() {
3223	my $freeze_guard = cf::freeze_mainloop;	3741	my $freeze_guard = cf::freeze_mainloop;
3224		3742
3225	warn "enter emergency perl save\n";	3743	warn "emergency_perl_save: enter\n";
3226		3744
3227	cf::sync_job {	3745	cf::sync_job {
		3746	# this is a trade-off: we want to be very quick here, so
		3747	# save all maps without fsync, and later call a global sync
		3748	# (which in turn might be very very slow)
		3749	local $USE_FSYNC = 0;
		3750
3228	# use a peculiar iteration method to avoid tripping on perl	3751	# use a peculiar iteration method to avoid tripping on perl
3229	# refcount bugs in for. also avoids problems with players	3752	# refcount bugs in for. also avoids problems with players
3230	# and maps saved/destroyed asynchronously.	3753	# and maps saved/destroyed asynchronously.
3231	warn "begin emergency player save\n";	3754	warn "emergency_perl_save: begin player save\n";
3232	for my $login (keys %cf::PLAYER) {	3755	for my $login (keys %cf::PLAYER) {
3233	my $pl = $cf::PLAYER{$login} or next;	3756	my $pl = $cf::PLAYER{$login} or next;
3234	$pl->valid or next;	3757	$pl->valid or next;
		3758	delete $pl->{unclean_save}; # not strictly necessary, but cannot hurt
3235	$pl->save;	3759	$pl->save;
3236	}	3760	}
3237	warn "end emergency player save\n";	3761	warn "emergency_perl_save: end player save\n";
3238		3762
3239	warn "begin emergency map save\n";	3763	warn "emergency_perl_save: begin map save\n";
3240	for my $path (keys %cf::MAP) {	3764	for my $path (keys %cf::MAP) {
3241	my $map = $cf::MAP{$path} or next;	3765	my $map = $cf::MAP{$path} or next;
3242	$map->valid or next;	3766	$map->valid or next;
3243	$map->save;	3767	$map->save;
3244	}	3768	}
3245	warn "end emergency map save\n";	3769	warn "emergency_perl_save: end map save\n";
3246		3770
3247	warn "begin emergency database checkpoint\n";	3771	warn "emergency_perl_save: begin database checkpoint\n";
3248	BDB::db_env_txn_checkpoint $DB_ENV;	3772	BDB::db_env_txn_checkpoint $DB_ENV;
3249	warn "end emergency database checkpoint\n";	3773	warn "emergency_perl_save: end database checkpoint\n";
		3774
		3775	warn "emergency_perl_save: begin write uuid\n";
		3776	write_uuid_sync 1;
		3777	warn "emergency_perl_save: end write uuid\n";
3250	};	3778	};
3251		3779
		3780	warn "emergency_perl_save: starting sync()\n";
		3781	IO::AIO::aio_sync sub {
		3782	warn "emergency_perl_save: finished sync()\n";
		3783	};
		3784
3252	warn "leave emergency perl save\n";	3785	warn "emergency_perl_save: leave\n";
3253	}	3786	}
3254		3787
3255	sub post_cleanup {	3788	sub post_cleanup {
3256	my ($make_core) = @_;	3789	my ($make_core) = @_;
3257		3790
3258	warn Carp::longmess "post_cleanup backtrace"	3791	warn Carp::longmess "post_cleanup backtrace"
3259	if $make_core;	3792	if $make_core;
		3793
		3794	my $fh = pidfile;
		3795	unlink $PIDFILE if <$fh> == $$;
		3796	}
		3797
		3798	# a safer delete_package, copied from Symbol
		3799	sub clear_package($) {
		3800	my $pkg = shift;
		3801
		3802	# expand to full symbol table name if needed
		3803	unless ($pkg =~ /^main::.*::$/) {
		3804	$pkg = "main$pkg" if $pkg =~ /^::/;
		3805	$pkg = "main::$pkg" unless $pkg =~ /^main::/;
		3806	$pkg .= '::' unless $pkg =~ /::$/;
		3807	}
		3808
		3809	my($stem, $leaf) = $pkg =~ m/(.*::)(\w+::)$/;
		3810	my $stem_symtab = *{$stem}{HASH};
		3811
		3812	defined $stem_symtab and exists $stem_symtab->{$leaf}
		3813	or return;
		3814
		3815	# clear all symbols
		3816	my $leaf_symtab = *{$stem_symtab->{$leaf}}{HASH};
		3817	for my $name (keys %$leaf_symtab) {
		3818	_gv_clear *{"$pkg$name"};
		3819	# use PApp::Util; PApp::Util::sv_dump *{"$pkg$name"};
		3820	}
3260	}	3821	}
3261		3822
3262	sub do_reload_perl() {	3823	sub do_reload_perl() {
3263	# can/must only be called in main	3824	# can/must only be called in main
3264	if ($Coro::current != $Coro::main) {	3825	if (in_main) {
3265	warn "can only reload from main coroutine";	3826	warn "can only reload from main coroutine";
3266	return;	3827	return;
3267	}	3828	}
3268		3829
		3830	return if $RELOAD++;
		3831
		3832	my $t1 = AE::time;
		3833
		3834	while ($RELOAD) {
3269	warn "reloading...";	3835	warn "reloading...";
3270		3836
3271	warn "entering sync_job";	3837	warn "entering sync_job";
3272		3838
3273	cf::sync_job {	3839	cf::sync_job {
3274	cf::write_runtime; # external watchdog should not bark	3840	cf::write_runtime_sync; # external watchdog should not bark
3275	cf::emergency_save;	3841	cf::emergency_save;
3276	cf::write_runtime; # external watchdog should not bark	3842	cf::write_runtime_sync; # external watchdog should not bark
3277		3843
3278	warn "syncing database to disk";	3844	warn "syncing database to disk";
3279	BDB::db_env_txn_checkpoint $DB_ENV;	3845	BDB::db_env_txn_checkpoint $DB_ENV;
3280		3846
3281	# if anything goes wrong in here, we should simply crash as we already saved	3847	# if anything goes wrong in here, we should simply crash as we already saved
3282		3848
3283	warn "cancelling all WF_AUTOCANCEL watchers";
3284	for (Event::all_watchers) {
3285	$_->cancel if $_->data & WF_AUTOCANCEL;
3286	}
3287
3288	warn "flushing outstanding aio requests";	3849	warn "flushing outstanding aio requests";
3289	for (;;) {
3290	BDB::flush;
3291	IO::AIO::flush;
3292	Coro::cede;
3293	last unless IO::AIO::nreqs || BDB::nreqs;	3850	while (IO::AIO::nreqs || BDB::nreqs) {
3294	warn "iterate...";	3851	Coro::EV::timer_once 0.01; # let the sync_job do it's thing
3295	}
3296
3297	++$RELOAD;
3298
3299	warn "cancelling all extension coros";
3300	$_->cancel for values %EXT_CORO;
3301	%EXT_CORO = ();
3302
3303	warn "removing commands";
3304	%COMMAND = ();
3305
3306	warn "removing ext/exti commands";
3307	%EXTCMD = ();
3308	%EXTICMD = ();
3309
3310	warn "unloading/nuking all extensions";
3311	for my $pkg (@EXTS) {
3312	warn "... unloading $pkg";
3313
3314	if (my $cb = $pkg->can ("unload")) {
3315	eval {
3316	$cb->($pkg);
3317	1
3318	} or warn "$pkg unloaded, but with errors: $@";
3319	}	3852	}
3320		3853
3321	warn "... nuking $pkg";	3854	warn "cancelling all extension coros";
3322	Symbol::delete_package $pkg;	3855	$_->cancel for values %EXT_CORO;
3323	}	3856	%EXT_CORO = ();
3324		3857
3325	warn "unloading all perl modules loaded from $LIBDIR";	3858	warn "removing commands";
3326	while (my ($k, $v) = each %INC) {	3859	%COMMAND = ();
3327	next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;
3328		3860
		3861	warn "removing ext/exti commands";
		3862	%EXTCMD = ();
		3863	%EXTICMD = ();
		3864
		3865	warn "unloading/nuking all extensions";
		3866	for my $pkg (@EXTS) {
3329	warn "... unloading $k";	3867	warn "... unloading $pkg";
3330	delete $INC{$k};
3331		3868
3332	$k =~ s/\.pm$//;
3333	$k =~ s/\//::/g;
3334
3335	if (my $cb = $k->can ("unload_module")) {	3869	if (my $cb = $pkg->can ("unload")) {
		3870	eval {
3336	$cb->();	3871	$cb->($pkg);
		3872	1
		3873	} or warn "$pkg unloaded, but with errors: $@";
		3874	}
		3875
		3876	warn "... clearing $pkg";
		3877	clear_package $pkg;
3337	}	3878	}
3338		3879
3339	Symbol::delete_package $k;	3880	warn "unloading all perl modules loaded from $LIBDIR";
		3881	while (my ($k, $v) = each %INC) {
		3882	next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;
		3883
		3884	warn "... unloading $k";
		3885	delete $INC{$k};
		3886
		3887	$k =~ s/\.pm$//;
		3888	$k =~ s/\//::/g;
		3889
		3890	if (my $cb = $k->can ("unload_module")) {
		3891	$cb->();
		3892	}
		3893
		3894	clear_package $k;
3340	}	3895	}
3341		3896
3342	warn "getting rid of safe::, as good as possible";	3897	warn "getting rid of safe::, as good as possible";
3343	Symbol::delete_package "safe::$_"	3898	clear_package "safe::$_"
3344	for qw(cf::attachable cf::object cf::object::player cf::client cf::player cf::map cf::party cf::region);	3899	for qw(cf::attachable cf::object cf::object::player cf::client cf::player cf::map cf::party cf::region);
3345		3900
3346	warn "unloading cf.pm \"a bit\"";	3901	warn "unloading cf.pm \"a bit\"";
3347	delete $INC{"cf.pm"};	3902	delete $INC{"cf.pm"};
3348	delete $INC{"cf/pod.pm"};	3903	delete $INC{"cf/$_.pm"} for @EXTRA_MODULES;
3349		3904
3350	# don't, removes xs symbols, too,	3905	# don't, removes xs symbols, too,
3351	# and global variables created in xs	3906	# and global variables created in xs
3352	#Symbol::delete_package __PACKAGE__;	3907	#clear_package __PACKAGE__;
3353		3908
3354	warn "unload completed, starting to reload now";	3909	warn "unload completed, starting to reload now";
3355		3910
3356	warn "reloading cf.pm";	3911	warn "reloading cf.pm";
3357	require cf;	3912	require cf;
3358	cf::_connect_to_perl; # nominally unnecessary, but cannot hurt	3913	cf::_connect_to_perl_1;
3359		3914
3360	warn "loading config and database again";	3915	warn "loading config and database again";
3361	cf::reload_config;	3916	cf::reload_config;
3362		3917
3363	warn "loading extensions";	3918	warn "loading extensions";
3364	cf::load_extensions;	3919	cf::load_extensions;
3365		3920
		3921	if ($REATTACH_ON_RELOAD) {
3366	warn "reattaching attachments to objects/players";	3922	warn "reattaching attachments to objects/players";
3367	_global_reattach; # objects, sockets	3923	_global_reattach; # objects, sockets
3368	warn "reattaching attachments to maps";	3924	warn "reattaching attachments to maps";
3369	reattach $_ for values %MAP;	3925	reattach $_ for values %MAP;
3370	warn "reattaching attachments to players";	3926	warn "reattaching attachments to players";
3371	reattach $_ for values %PLAYER;	3927	reattach $_ for values %PLAYER;
		3928	}
3372		3929
		3930	warn "running post_init jobs";
		3931	(pop @POST_INIT)->(1) while @POST_INIT;
		3932
3373	warn "leaving sync_job";	3933	warn "leaving sync_job";
3374		3934
3375	1	3935	1
3376	} or do {	3936	} or do {
3377	warn $@;	3937	warn $@;
3378	warn "error while reloading, exiting.";	3938	cf::cleanup "error while reloading, exiting.";
3379	exit 1;
3380	};	3939	};
3381		3940
3382	warn "reloaded";	3941	warn "reloaded";
		3942	--$RELOAD;
		3943	}
		3944
		3945	$t1 = AE::time - $t1;
		3946	warn "reload completed in ${t1}s\n";
3383	};	3947	};
3384		3948
3385	our $RELOAD_WATCHER; # used only during reload	3949	our $RELOAD_WATCHER; # used only during reload
3386		3950
3387	sub reload_perl() {	3951	sub reload_perl() {
3388	# doing reload synchronously and two reloads happen back-to-back,	3952	# doing reload synchronously and two reloads happen back-to-back,
3389	# coro crashes during coro_state_free->destroy here.	3953	# coro crashes during coro_state_free->destroy here.
3390		3954
3391	$RELOAD_WATCHER ||= Event->timer (	3955	$RELOAD_WATCHER ||= cf::async {
3392	reentrant => 0,	3956	Coro::AIO::aio_wait cache_extensions;
3393	after => 0,	3957
3394	data => WF_AUTOCANCEL,	3958	$RELOAD_WATCHER = AE::timer $TICK * 1.5, 0, sub {
3395	cb => sub {
3396	do_reload_perl;	3959	do_reload_perl;
3397	undef $RELOAD_WATCHER;	3960	undef $RELOAD_WATCHER;
3398	},	3961	};
3399	);	3962	};
3400	}	3963	}
3401		3964
3402	register_command "reload" => sub {	3965	register_command "reload" => sub {
3403	my ($who, $arg) = @_;	3966	my ($who, $arg) = @_;
3404		3967
3405	if ($who->flag (FLAG_WIZ)) {	3968	if ($who->flag (FLAG_WIZ)) {
3406	$who->message ("reloading server.");	3969	$who->message ("reloading server.");
		3970	async {
		3971	$Coro::current->{desc} = "perl_reload";
3407	async { reload_perl };	3972	reload_perl;
		3973	};
3408	}	3974	}
3409	};	3975	};
3410		3976
3411	unshift @INC, $LIBDIR;	3977	unshift @INC, $LIBDIR;
3412		3978
…		…
3414		3980
3415	our @WAIT_FOR_TICK;	3981	our @WAIT_FOR_TICK;
3416	our @WAIT_FOR_TICK_BEGIN;	3982	our @WAIT_FOR_TICK_BEGIN;
3417		3983
3418	sub wait_for_tick {	3984	sub wait_for_tick {
3419	return unless $TICK_WATCHER->is_active;
3420	return if $Coro::current == $Coro::main;	3985	return Coro::cede if tick_inhibit || $Coro::current == $Coro::main;
3421		3986
3422	my $signal = new Coro::Signal;	3987	my $signal = new Coro::Signal;
3423	push @WAIT_FOR_TICK, $signal;	3988	push @WAIT_FOR_TICK, $signal;
3424	$signal->wait;	3989	$signal->wait;
3425	}	3990	}
3426		3991
3427	sub wait_for_tick_begin {	3992	sub wait_for_tick_begin {
3428	return unless $TICK_WATCHER->is_active;
3429	return if $Coro::current == $Coro::main;	3993	return Coro::cede if tick_inhibit || $Coro::current == $Coro::main;
3430		3994
3431	my $signal = new Coro::Signal;	3995	my $signal = new Coro::Signal;
3432	push @WAIT_FOR_TICK_BEGIN, $signal;	3996	push @WAIT_FOR_TICK_BEGIN, $signal;
3433	$signal->wait;	3997	$signal->wait;
3434	}	3998	}
3435		3999
3436	my $min = 1e6;#d#	4000	sub tick {
3437	my $avg = 10;
3438	$TICK_WATCHER = Event->timer (
3439	reentrant => 0,
3440	parked => 1,
3441	prio => 0,
3442	at => $NEXT_TICK || $TICK,
3443	data => WF_AUTOCANCEL,
3444	cb => sub {
3445	if ($Coro::current != $Coro::main) {	4001	if ($Coro::current != $Coro::main) {
3446	Carp::cluck "major BUG: server tick called outside of main coro, skipping it"	4002	Carp::cluck "major BUG: server tick called outside of main coro, skipping it"
3447	unless ++$bug_warning > 10;	4003	unless ++$bug_warning > 10;
3448	return;	4004	return;
3449	}	4005	}
3450		4006
3451	$NOW = $tick_start = Event::time;
3452
3453	cf::server_tick; # one server iteration	4007	cf::server_tick; # one server iteration
3454		4008
3455	0 && sync_job {#d#	4009	#for(1..3e6){} AE::now_update; $NOW=AE::now; # generate load #d#
3456	for(1..10) {
3457	my $t = Event::time;
3458	my $map = my $map = new_from_path cf::map "/tmp/x.map"
3459	or die;
3460		4010
3461	$map->width (50);	4011	if ($NOW >= $NEXT_RUNTIME_WRITE) {
3462	$map->height (50);	4012	$NEXT_RUNTIME_WRITE = List::Util::max $NEXT_RUNTIME_WRITE + 10, $NOW + 5.;
3463	$map->alloc;	4013	Coro::async_pool {
3464	$map->_load_objects ("/tmp/x.map", 1); #TODO: does not work	4014	$Coro::current->{desc} = "runtime saver";
3465	my $t = Event::time - $t;	4015	write_runtime_sync
3466		4016	or warn "ERROR: unable to write runtime file: $!";
3467	#next unless $t < 0.0013;#d#
3468	if ($t < $min) {
3469	$min = $t;
3470	}
3471	$avg = $avg * 0.99 + $t * 0.01;
3472	}
3473	warn "XXXXXXXXXXXXXXXXXX min $min avg $avg\n";#d#
3474	exit 0;
3475	# 2007-05-22 02:33:04.569 min 0.00112509727478027 avg 0.0012259249572477
3476	};	4017	};
		4018	}
3477		4019
3478	$RUNTIME += $TICK;
3479	$NEXT_TICK += $TICK;
3480
3481	if ($NOW >= $NEXT_RUNTIME_WRITE) {
3482	$NEXT_RUNTIME_WRITE = $NOW + 10;
3483	Coro::async_pool {
3484	write_runtime
3485	or warn "ERROR: unable to write runtime file: $!";
3486	};
3487	}
3488
3489	# my $AFTER = Event::time;
3490	# warn $AFTER - $NOW;#d#
3491
3492	if (my $sig = shift @WAIT_FOR_TICK_BEGIN) {	4020	if (my $sig = shift @WAIT_FOR_TICK_BEGIN) {
3493	$sig->send;	4021	$sig->send;
3494	}	4022	}
3495	while (my $sig = shift @WAIT_FOR_TICK) {	4023	while (my $sig = shift @WAIT_FOR_TICK) {
3496	$sig->send;	4024	$sig->send;
3497	}	4025	}
3498		4026
3499	$NOW = Event::time;	4027	$LOAD = ($NOW - $TICK_START) / $TICK;
3500
3501	# if we are delayed by four ticks or more, skip them all
3502	$NEXT_TICK = $NOW if $NOW >= $NEXT_TICK + $TICK * 4;
3503
3504	$TICK_WATCHER->at ($NEXT_TICK);
3505	$TICK_WATCHER->start;
3506
3507	$LOAD = ($NOW - $tick_start) / $TICK;
3508	$LOADAVG = $LOADAVG * 0.75 + $LOAD * 0.25;	4028	$LOADAVG = $LOADAVG * 0.75 + $LOAD * 0.25;
3509		4029
3510	_post_tick;	4030	if (0) {
3511		4031	if ($NEXT_TICK) {
3512		4032	my $jitter = $TICK_START - $NEXT_TICK;
		4033	$JITTER = $JITTER * 0.75 + $jitter * 0.25;
		4034	warn "jitter $JITTER\n";#d#
		4035	}
3513	},	4036	}
3514	);	4037	}
3515		4038
3516	{	4039	{
3517	BDB::max_poll_time $TICK * 0.1;	4040	# configure BDB
3518	$BDB_POLL_WATCHER = Event->io (	4041
3519	reentrant => 0,
3520	fd => BDB::poll_fileno,
3521	poll => 'r',
3522	prio => 0,
3523	data => WF_AUTOCANCEL,
3524	cb => \&BDB::poll_cb,
3525	);
3526	BDB::min_parallel 8;	4042	BDB::min_parallel 16;
3527		4043	BDB::max_poll_reqs $TICK * 0.1;
3528	BDB::set_sync_prepare {	4044	$AnyEvent::BDB::WATCHER->priority (1);
3529	my $status;
3530	my $current = $Coro::current;
3531	(
3532	sub {
3533	$status = $!;
3534	$current->ready; undef $current;
3535	},
3536	sub {
3537	Coro::schedule while defined $current;
3538	$! = $status;
3539	},
3540	)
3541	};
3542		4045
3543	unless ($DB_ENV) {	4046	unless ($DB_ENV) {
3544	$DB_ENV = BDB::db_env_create;	4047	$DB_ENV = BDB::db_env_create;
		4048	$DB_ENV->set_flags (BDB::AUTO_COMMIT | BDB::REGION_INIT);
		4049	$DB_ENV->set_flags (&BDB::LOG_AUTOREMOVE ) if BDB::VERSION v0, v4.7;
		4050	$DB_ENV->log_set_config (&BDB::LOG_AUTO_REMOVE) if BDB::VERSION v4.7;
		4051	$DB_ENV->set_timeout (30, BDB::SET_TXN_TIMEOUT);
		4052	$DB_ENV->set_timeout (30, BDB::SET_LOCK_TIMEOUT);
3545		4053
3546	cf::sync_job {	4054	cf::sync_job {
3547	eval {	4055	eval {
3548	BDB::db_env_open	4056	BDB::db_env_open
3549	$DB_ENV,	4057	$DB_ENV,
…		…
3551	BDB::INIT_LOCK | BDB::INIT_LOG | BDB::INIT_MPOOL | BDB::INIT_TXN	4059	BDB::INIT_LOCK | BDB::INIT_LOG | BDB::INIT_MPOOL | BDB::INIT_TXN
3552	| BDB::RECOVER | BDB::REGISTER | BDB::USE_ENVIRON | BDB::CREATE,	4060	| BDB::RECOVER | BDB::REGISTER | BDB::USE_ENVIRON | BDB::CREATE,
3553	0666;	4061	0666;
3554		4062
3555	cf::cleanup "db_env_open($BDBDIR): $!" if $!;	4063	cf::cleanup "db_env_open($BDBDIR): $!" if $!;
3556
3557	$DB_ENV->set_flags (BDB::AUTO_COMMIT | BDB::REGION_INIT | BDB::TXN_NOSYNC, 1);
3558	$DB_ENV->set_lk_detect;
3559	};	4064	};
3560		4065
3561	cf::cleanup "db_env_open(db): $@" if $@;	4066	cf::cleanup "db_env_open(db): $@" if $@;
3562	};	4067	};
3563	}	4068	}
		4069
		4070	$BDB_DEADLOCK_WATCHER = EV::periodic 0, 3, 0, sub {
		4071	BDB::db_env_lock_detect $DB_ENV, 0, BDB::LOCK_DEFAULT, 0, sub { };
		4072	};
		4073	$BDB_CHECKPOINT_WATCHER = EV::periodic 0, 60, 0, sub {
		4074	BDB::db_env_txn_checkpoint $DB_ENV, 0, 0, 0, sub { };
		4075	};
		4076	$BDB_TRICKLE_WATCHER = EV::periodic 0, 10, 0, sub {
		4077	BDB::db_env_memp_trickle $DB_ENV, 20, 0, sub { };
		4078	};
3564	}	4079	}
3565		4080
3566	{	4081	{
		4082	# configure IO::AIO
		4083
3567	IO::AIO::min_parallel 8;	4084	IO::AIO::min_parallel 8;
3568
3569	undef $Coro::AIO::WATCHER;
3570	IO::AIO::max_poll_time $TICK * 0.1;	4085	IO::AIO::max_poll_time $TICK * 0.1;
3571	$AIO_POLL_WATCHER = Event->io (	4086	undef $AnyEvent::AIO::WATCHER;
3572	reentrant => 0,
3573	data => WF_AUTOCANCEL,
3574	fd => IO::AIO::poll_fileno,
3575	poll => 'r',
3576	prio => 6,
3577	cb => \&IO::AIO::poll_cb,
3578	);
3579	}	4087	}
3580		4088
3581	my $_log_backtrace;	4089	my $_log_backtrace;
3582		4090
3583	sub _log_backtrace {	4091	sub _log_backtrace {
…		…
3586	$msg =~ s/\n//;	4094	$msg =~ s/\n//;
3587		4095
3588	# limit the # of concurrent backtraces	4096	# limit the # of concurrent backtraces
3589	if ($_log_backtrace < 2) {	4097	if ($_log_backtrace < 2) {
3590	++$_log_backtrace;	4098	++$_log_backtrace;
		4099	my $perl_bt = Carp::longmess $msg;
3591	async {	4100	async {
		4101	$Coro::current->{desc} = "abt $msg";
		4102
3592	my @bt = fork_call {	4103	my @bt = fork_call {
3593	@addr = map { sprintf "%x", $_ } @addr;	4104	@addr = map { sprintf "%x", $_ } @addr;
3594	my $self = (-f "/proc/$$/exe") ? "/proc/$$/exe" : $^X;	4105	my $self = (-f "/proc/$$/exe") ? "/proc/$$/exe" : $^X;
3595	open my $fh, "exec addr2line -C -f -i -e \Q$self\E @addr 2>&1 |"	4106	open my $fh, "exec addr2line -C -f -i -e \Q$self\E @addr 2>&1 |"
3596	or die "addr2line: $!";	4107	or die "addr2line: $!";
…		…
3604	}	4115	}
3605		4116
3606	@funcs	4117	@funcs
3607	};	4118	};
3608		4119
3609	LOG llevInfo, "[ABT] $msg\n";	4120	LOG llevInfo, "[ABT] $perl_bt\n";
		4121	LOG llevInfo, "[ABT] --- C backtrace follows ---\n";
3610	LOG llevInfo, "[ABT] $_\n" for @bt;	4122	LOG llevInfo, "[ABT] $_\n" for @bt;
3611	--$_log_backtrace;	4123	--$_log_backtrace;
3612	};	4124	};
3613	} else {	4125	} else {
3614	LOG llevInfo, "[ABT] $msg\n";	4126	LOG llevInfo, "[ABT] $msg\n";
3615	LOG llevInfo, "[ABT] [suppressed]\n";	4127	LOG llevInfo, "[ABT] [suppressed]\n";
3616	}	4128	}
3617	}	4129	}
3618		4130
3619	# load additional modules	4131	# load additional modules
3620	use cf::pod;	4132	require "cf/$_.pm" for @EXTRA_MODULES;
		4133	cf::_connect_to_perl_2;
3621		4134
3622	END { cf::emergency_save }	4135	END { cf::emergency_save }
3623		4136
3624	1	4137	1
3625		4138

Diff Legend

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