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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.102 by root, Wed Dec 27 15:20:54 2006 UTC vs.
Revision 1.112 by root, Mon Jan 1 13:31:47 2007 UTC

…		…
8	use Storable;	8	use Storable;
9	use Opcode;	9	use Opcode;
10	use Safe;	10	use Safe;
11	use Safe::Hole;	11	use Safe::Hole;
12		12
13	use Coro;	13	use Coro 3.3;
14	use Coro::Event;	14	use Coro::Event;
15	use Coro::Timer;	15	use Coro::Timer;
16	use Coro::Signal;	16	use Coro::Signal;
17	use Coro::Semaphore;	17	use Coro::Semaphore;
		18	use Coro::AIO;
18		19
		20	use Digest::MD5;
		21	use Fcntl;
19	use IO::AIO 2.3;	22	use IO::AIO 2.31 ();
20	use YAML::Syck ();	23	use YAML::Syck ();
21	use Time::HiRes;	24	use Time::HiRes;
22		25
23	use Event; $Event::Eval = 1; # no idea why this is required, but it is	26	use Event; $Event::Eval = 1; # no idea why this is required, but it is
24		27
25	# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?	28	# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?
26	$YAML::Syck::ImplicitUnicode = 1;	29	$YAML::Syck::ImplicitUnicode = 1;
27		30
28	$Coro::main->prio (Coro::PRIO_MIN);	31	$Coro::main->prio (2); # run main coroutine ("the server") with very high priority
29		32
30	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload	33	sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload
31		34
32	our %COMMAND = ();	35	our %COMMAND = ();
33	our %COMMAND_TIME = ();	36	our %COMMAND_TIME = ();
…		…
37	our $LIBDIR = datadir . "/ext";	40	our $LIBDIR = datadir . "/ext";
38		41
39	our $TICK = MAX_TIME * 1e-6;	42	our $TICK = MAX_TIME * 1e-6;
40	our $TICK_WATCHER;	43	our $TICK_WATCHER;
41	our $NEXT_TICK;	44	our $NEXT_TICK;
		45	our $NOW;
42		46
43	our %CFG;	47	our %CFG;
44		48
45	our $UPTIME; $UPTIME \|\|= time;	49	our $UPTIME; $UPTIME \|\|= time;
		50	our $RUNTIME;
		51
		52	our %MAP; # all maps
		53	our $LINK_MAP; # the special {link} map
		54	our $FREEZE;
		55	our $RANDOM_MAPS = cf::localdir . "/random";
		56	our %EXT_CORO;
		57
		58	binmode STDOUT;
		59	binmode STDERR;
		60
		61	# read virtual server time, if available
		62	unless ($RUNTIME \|\| !-e cf::localdir . "/runtime") {
		63	open my $fh, "<", cf::localdir . "/runtime"
		64	or die "unable to read runtime file: $!";
		65	$RUNTIME = <$fh> + 0.;
		66	}
		67
		68	mkdir cf::localdir;
		69	mkdir cf::localdir . "/" . cf::playerdir;
		70	mkdir cf::localdir . "/" . cf::tmpdir;
		71	mkdir cf::localdir . "/" . cf::uniquedir;
		72	mkdir $RANDOM_MAPS;
		73
		74	# a special map that is always available
		75	our $LINK_MAP;
		76
		77	our $EMERGENCY_POSITION = $cf::CFG{emergency_position} \|\| ["/world/world_105_115", 5, 37];
46		78
47	#############################################################################	79	#############################################################################
48		80
49	=head2 GLOBAL VARIABLES	81	=head2 GLOBAL VARIABLES
50		82
51	=over 4	83	=over 4
52		84
53	=item $cf::UPTIME	85	=item $cf::UPTIME
54		86
55	The timestamp of the server start (so not actually an uptime).	87	The timestamp of the server start (so not actually an uptime).
		88
		89	=item $cf::RUNTIME
		90
		91	The time this server has run, starts at 0 and is increased by $cf::TICK on
		92	every server tick.
56		93
57	=item $cf::LIBDIR	94	=item $cf::LIBDIR
58		95
59	The perl library directory, where extensions and cf-specific modules can	96	The perl library directory, where extensions and cf-specific modules can
60	be found. It will be added to C<@INC> automatically.	97	be found. It will be added to C<@INC> automatically.
		98
		99	=item $cf::NOW
		100
		101	The time of the last (current) server tick.
61		102
62	=item $cf::TICK	103	=item $cf::TICK
63		104
64	The interval between server ticks, in seconds.	105	The interval between server ticks, in seconds.
65		106
…		…
73	=cut	114	=cut
74		115
75	BEGIN {	116	BEGIN {
76	*CORE::GLOBAL::warn = sub {	117	*CORE::GLOBAL::warn = sub {
77	my $msg = join "", @_;	118	my $msg = join "", @_;
		119	utf8::encode $msg;
		120
78	$msg .= "\n"	121	$msg .= "\n"
79	unless $msg =~ /\n$/;	122	unless $msg =~ /\n$/;
80		123
81	print STDERR "cfperl: $msg";
82	LOG llevError, "cfperl: $msg";	124	LOG llevError, "cfperl: $msg";
83	};	125	};
84	}	126	}
85		127
86	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';	128	@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';
…		…
139	sub to_json($) {	181	sub to_json($) {
140	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs	182	$JSON::Syck::ImplicitUnicode = 0; # work around JSON::Syck bugs
141	JSON::Syck::Dump $_[0]	183	JSON::Syck::Dump $_[0]
142	}	184	}
143		185
		186	=item cf::sync_job { BLOCK }
		187
		188	The design of crossfire+ requires that the main coro ($Coro::main) is
		189	always able to handle events or runnable, as crossfire+ is only partly
		190	reentrant. Thus "blocking" it by e.g. waiting for I/O is not acceptable.
		191
		192	If it must be done, put the blocking parts into C<sync_job>. This will run
		193	the given BLOCK in another coroutine while waiting for the result. The
		194	server will be frozen during this time, so the block should either finish
		195	fast or be very important.
		196
		197	=cut
		198
		199	sub sync_job(&) {
		200	my ($job) = @_;
		201
		202	if ($Coro::current == $Coro::main) {
		203	# this is the main coro, too bad, we have to block
		204	# till the operation succeeds, freezing the server :/
		205
		206	# TODO: use suspend/resume instead
		207	# (but this is cancel-safe)
		208	local $FREEZE = 1;
		209
		210	my $busy = 1;
		211	my @res;
		212
		213	(Coro::async {
		214	@res = eval { $job->() };
		215	warn $@ if $@;
		216	undef $busy;
		217	})->prio (Coro::PRIO_MAX);
		218
		219	while ($busy) {
		220	Coro::cede_notself;
		221	Event::one_event unless Coro::nready;
		222	}
		223
		224	wantarray ? @res : $res[0]
		225	} else {
		226	# we are in another coroutine, how wonderful, everything just works
		227
		228	$job->()
		229	}
		230	}
		231
		232	=item $coro = cf::coro { BLOCK }
		233
		234	Creates and returns a new coro. This coro is automcatially being canceled
		235	when the extension calling this is being unloaded.
		236
		237	=cut
		238
		239	sub coro(&) {
		240	my $cb = shift;
		241
		242	my $coro; $coro = async {
		243	eval {
		244	$cb->();
		245	};
		246	warn $@ if $@;
		247	};
		248
		249	$coro->on_destroy (sub {
		250	delete $EXT_CORO{$coro+0};
		251	});
		252	$EXT_CORO{$coro+0} = $coro;
		253
		254	$coro
		255	}
		256
		257	sub write_runtime {
		258	my $runtime = cf::localdir . "/runtime";
		259
		260	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644
		261	or return;
		262
		263	my $value = $cf::RUNTIME + 1 + 10; # 10 is the runtime save interval, for a monotonic clock
		264	(aio_write $fh, 0, (length $value), $value, 0) <= 0
		265	and return;
		266
		267	aio_fsync $fh
		268	and return;
		269
		270	close $fh
		271	or return;
		272
		273	aio_rename "$runtime~", $runtime
		274	and return;
		275
		276	1
		277	}
		278
144	=back	279	=back
145		280
146	=cut	281	=cut
		282
		283	#############################################################################
		284
		285	package cf::path;
		286
		287	sub new {
		288	my ($class, $path, $base) = @_;
		289
		290	$path = $path->as_string if ref $path;
		291
		292	my $self = bless { }, $class;
		293
		294	if ($path =~ s{^\?random/}{}) {
		295	Coro::AIO::aio_load "$cf::RANDOM_MAPS/$path.meta", my $data;
		296	$self->{random} = cf::from_json $data;
		297	} else {
		298	if ($path =~ s{^~([^/]+)?}{}) {
		299	$self->{user_rel} = 1;
		300
		301	if (defined $1) {
		302	$self->{user} = $1;
		303	} elsif ($base =~ m{^~([^/]+)/}) {
		304	$self->{user} = $1;
		305	} else {
		306	warn "cannot resolve user-relative path without user <$path,$base>\n";
		307	}
		308	} elsif ($path =~ /^\//) {
		309	# already absolute
		310	} else {
		311	$base =~ s{[^/]+/?$}{};
		312	return $class->new ("$base/$path");
		313	}
		314
		315	for ($path) {
		316	redo if s{/\.?/}{/};
		317	redo if s{/[^/]+/\.\./}{/};
		318	}
		319	}
		320
		321	$self->{path} = $path;
		322
		323	$self
		324	}
		325
		326	# the name / primary key / in-game path
		327	sub as_string {
		328	my ($self) = @_;
		329
		330	$self->{user_rel} ? "~$self->{user}$self->{path}"
		331	: $self->{random} ? "?random/$self->{path}"
		332	: $self->{path}
		333	}
		334
		335	# the displayed name, this is a one way mapping
		336	sub visible_name {
		337	my ($self) = @_;
		338
		339	# if (my $rmp = $self->{random}) {
		340	# # todo: be more intelligent about this
		341	# "?random/$rmp->{origin_map}+$rmp->{origin_x}+$rmp->{origin_y}/$rmp->{dungeon_level}"
		342	# } else {
		343	$self->as_string
		344	# }
		345	}
		346
		347	# escape the /'s in the path
		348	sub _escaped_path {
		349	# ∕ is U+2215
		350	(my $path = $_[0]{path}) =~ s/\//∕/g;
		351	$path
		352	}
		353
		354	# the original (read-only) location
		355	sub load_path {
		356	my ($self) = @_;
		357
		358	sprintf "%s/%s/%s", cf::datadir, cf::mapdir, $self->{path}
		359	}
		360
		361	# the temporary/swap location
		362	sub save_path {
		363	my ($self) = @_;
		364
		365	$self->{user_rel} ? sprintf "%s/%s/%s/%s", cf::localdir, cf::playerdir, $self->{user}, $self->_escaped_path
		366	: $self->{random} ? sprintf "%s/%s", $RANDOM_MAPS, $self->{path}
		367	: sprintf "%s/%s/%s", cf::localdir, cf::tmpdir, $self->_escaped_path
		368	}
		369
		370	# the unique path, might be eq to save_path
		371	sub uniq_path {
		372	my ($self) = @_;
		373
		374	$self->{user_rel} \|\| $self->{random}
		375	? undef
		376	: sprintf "%s/%s/%s", cf::localdir, cf::uniquedir, $self->_escaped_path
		377	}
		378
		379	# return random map parameters, or undef
		380	sub random_map_params {
		381	my ($self) = @_;
		382
		383	$self->{random}
		384	}
		385
		386	# this is somewhat ugly, but style maps do need special treatment
		387	sub is_style_map {
		388	$_[0]{path} =~ m{^/styles/}
		389	}
		390
		391	package cf;
147		392
148	#############################################################################	393	#############################################################################
149		394
150	=head2 ATTACHABLE OBJECTS	395	=head2 ATTACHABLE OBJECTS
151		396
…		…
505	);	750	);
506		751
507	sub object_freezer_save {	752	sub object_freezer_save {
508	my ($filename, $rdata, $objs) = @_;	753	my ($filename, $rdata, $objs) = @_;
509		754
		755	sync_job {
510	if (length $$rdata) {	756	if (length $$rdata) {
511	warn sprintf "saving %s (%d,%d)\n",	757	warn sprintf "saving %s (%d,%d)\n",
512	$filename, length $$rdata, scalar @$objs;	758	$filename, length $$rdata, scalar @$objs;
513		759
514	if (open my $fh, ">:raw", "$filename~") {	760	if (my $fh = aio_open "$filename~", O_WRONLY \| O_CREAT, 0600) {
515	chmod SAVE_MODE, $fh;
516	syswrite $fh, $$rdata;
517	close $fh;
518
519	if (@$objs && open my $fh, ">:raw", "$filename.pst~") {
520	chmod SAVE_MODE, $fh;	761	chmod SAVE_MODE, $fh;
521	syswrite $fh, Storable::nfreeze { version => 1, objs => $objs };	762	aio_write $fh, 0, (length $$rdata), $$rdata, 0;
		763	aio_fsync $fh;
522	close $fh;	764	close $fh;
		765
		766	if (@$objs) {
		767	if (my $fh = aio_open "$filename.pst~", O_WRONLY \| O_CREAT, 0600) {
		768	chmod SAVE_MODE, $fh;
		769	my $data = Storable::nfreeze { version => 1, objs => $objs };
		770	aio_write $fh, 0, (length $data), $data, 0;
		771	aio_fsync $fh;
		772	close $fh;
523	rename "$filename.pst~", "$filename.pst";	773	aio_rename "$filename.pst~", "$filename.pst";
		774	}
		775	} else {
		776	aio_unlink "$filename.pst";
		777	}
		778
		779	aio_rename "$filename~", $filename;
524	} else {	780	} else {
525	unlink "$filename.pst";	781	warn "FATAL: $filename~: $!\n";
526	}	782	}
527
528	rename "$filename~", $filename;
529	} else {	783	} else {
530	warn "FATAL: $filename~: $!\n";
531	}
532	} else {
533	unlink $filename;	784	aio_unlink $filename;
534	unlink "$filename.pst";	785	aio_unlink "$filename.pst";
		786	}
535	}	787	}
536	}	788	}
537		789
538	sub object_freezer_as_string {	790	sub object_freezer_as_string {
539	my ($rdata, $objs) = @_;	791	my ($rdata, $objs) = @_;
…		…
544	}	796	}
545		797
546	sub object_thawer_load {	798	sub object_thawer_load {
547	my ($filename) = @_;	799	my ($filename) = @_;
548		800
549	local $/;	801	my ($data, $av);
550		802
551	my $av;	803	(aio_load $filename, $data) >= 0
		804	or return;
552		805
553	#TODO: use sysread etc.	806	unless (aio_stat "$filename.pst") {
554	if (open my $data, "<:raw:perlio", $filename) {	807	(aio_load "$filename.pst", $av) >= 0
555	$data = <$data>;	808	or return;
556	if (open my $pst, "<:raw:perlio", "$filename.pst") {
557	$av = eval { (Storable::thaw <$pst>)->{objs} };	809	$av = eval { (Storable::thaw <$av>)->{objs} };
558	}	810	}
		811
559	return ($data, $av);	812	return ($data, $av);
560	}
561
562	()
563	}	813	}
564		814
565	#############################################################################	815	#############################################################################
566	# command handling &c	816	# command handling &c
567		817
…		…
788	$self->send ("ext " . to_json \%msg);	1038	$self->send ("ext " . to_json \%msg);
789	}	1039	}
790		1040
791	=back	1041	=back
792		1042
		1043
		1044	=head3 cf::map
		1045
		1046	=over 4
		1047
		1048	=cut
		1049
		1050	package cf::map;
		1051
		1052	use Fcntl;
		1053	use Coro::AIO;
		1054
		1055	our $MAX_RESET = 7200;
		1056	our $DEFAULT_RESET = 3600;
		1057
		1058	sub generate_random_map {
		1059	my ($path, $rmp) = @_;
		1060
		1061	# mit "rum" bekleckern, nicht
		1062	cf::map::_create_random_map
		1063	$path,
		1064	$rmp->{wallstyle}, $rmp->{wall_name}, $rmp->{floorstyle}, $rmp->{monsterstyle},
		1065	$rmp->{treasurestyle}, $rmp->{layoutstyle}, $rmp->{doorstyle}, $rmp->{decorstyle},
		1066	$rmp->{origin_map}, $rmp->{final_map}, $rmp->{exitstyle}, $rmp->{this_map},
		1067	$rmp->{exit_on_final_map},
		1068	$rmp->{xsize}, $rmp->{ysize},
		1069	$rmp->{expand2x}, $rmp->{layoutoptions1}, $rmp->{layoutoptions2}, $rmp->{layoutoptions3},
		1070	$rmp->{symmetry}, $rmp->{difficulty}, $rmp->{difficulty_given}, $rmp->{difficulty_increase},
		1071	$rmp->{dungeon_level}, $rmp->{dungeon_depth}, $rmp->{decoroptions}, $rmp->{orientation},
		1072	$rmp->{origin_y}, $rmp->{origin_x}, $rmp->{random_seed}, $rmp->{total_map_hp},
		1073	$rmp->{map_layout_style}, $rmp->{treasureoptions}, $rmp->{symmetry_used},
		1074	(cf::region::find $rmp->{region})
		1075	}
		1076
		1077	# and all this just because we cannot iterate over
		1078	# all maps in C++...
		1079	sub change_all_map_light {
		1080	my ($change) = @_;
		1081
		1082	$_->change_map_light ($change) for values %cf::MAP;
		1083	}
		1084
		1085	sub try_load_header($) {
		1086	my ($path) = @_;
		1087
		1088	utf8::encode $path;
		1089	aio_open $path, O_RDONLY, 0
		1090	or return;
		1091
		1092	my $map = cf::map::new
		1093	or return;
		1094
		1095	$map->load_header ($path)
		1096	or return;
		1097
		1098	$map->{load_path} = $path;
		1099
		1100	$map
		1101	}
		1102
		1103	sub find_map {
		1104	my ($path, $origin) = @_;
		1105
		1106	#warn "find_map<$path,$origin>\n";#d#
		1107
		1108	$path = new cf::path $path, $origin && $origin->path;
		1109	my $key = $path->as_string;
		1110
		1111	$cf::MAP{$key} \|\| do {
		1112	# do it the slow way
		1113	my $map = try_load_header $path->save_path;
		1114
		1115	if ($map) {
		1116	# safety
		1117	$map->{instantiate_time} = $cf::RUNTIME
		1118	if $map->{instantiate_time} > $cf::RUNTIME;
		1119	} else {
		1120	if (my $rmp = $path->random_map_params) {
		1121	$map = generate_random_map $key, $rmp;
		1122	} else {
		1123	$map = try_load_header $path->load_path;
		1124	}
		1125
		1126	$map or return;
		1127
		1128	$map->{load_original} = 1;
		1129	$map->{instantiate_time} = $cf::RUNTIME;
		1130	$map->instantiate;
		1131
		1132	# per-player maps become, after loading, normal maps
		1133	$map->per_player (0) if $path->{user_rel};
		1134	}
		1135
		1136	$map->path ($key);
		1137	$map->{path} = $path;
		1138	$map->last_access ($cf::RUNTIME);
		1139
		1140	if ($map->should_reset) {
		1141	$map->reset;
		1142	$map = find_map $path;
		1143	}
		1144
		1145	$cf::MAP{$key} = $map
		1146	}
		1147	}
		1148
		1149	sub load {
		1150	my ($self) = @_;
		1151
		1152	return if $self->in_memory != cf::MAP_SWAPPED;
		1153
		1154	$self->in_memory (cf::MAP_LOADING);
		1155
		1156	my $path = $self->{path};
		1157
		1158	$self->alloc;
		1159	$self->load_objects ($self->{load_path}, 1)
		1160	or return;
		1161
		1162	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)
		1163	if delete $self->{load_original};
		1164
		1165	if (my $uniq = $path->uniq_path) {
		1166	utf8::encode $uniq;
		1167	if (aio_open $uniq, O_RDONLY, 0) {
		1168	$self->clear_unique_items;
		1169	$self->load_objects ($uniq, 0);
		1170	}
		1171	}
		1172
		1173	# now do the right thing for maps
		1174	$self->link_multipart_objects;
		1175
		1176	if ($self->{path}->is_style_map) {
		1177	$self->{deny_save} = 1;
		1178	$self->{deny_reset} = 1;
		1179	} else {
		1180	$self->fix_auto_apply;
		1181	$self->decay_objects;
		1182	$self->update_buttons;
		1183	$self->set_darkness_map;
		1184	$self->difficulty ($self->estimate_difficulty)
		1185	unless $self->difficulty;
		1186	$self->activate;
		1187	}
		1188
		1189	$self->in_memory (cf::MAP_IN_MEMORY);
		1190	}
		1191
		1192	sub load_map_sync {
		1193	my ($path, $origin) = @_;
		1194
		1195	#warn "load_map_sync<$path, $origin>\n";#d#
		1196
		1197	cf::sync_job {
		1198	my $map = cf::map::find_map $path, $origin
		1199	or return;
		1200	$map->load;
		1201	$map
		1202	}
		1203	}
		1204
		1205	sub save {
		1206	my ($self) = @_;
		1207
		1208	my $save = $self->{path}->save_path; utf8::encode $save;
		1209	my $uniq = $self->{path}->uniq_path; utf8::encode $uniq;
		1210
		1211	$self->{last_save} = $cf::RUNTIME;
		1212
		1213	return unless $self->dirty;
		1214
		1215	$self->{load_path} = $save;
		1216
		1217	return if $self->{deny_save};
		1218
		1219	if ($uniq) {
		1220	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS);
		1221	$self->save_objects ($uniq, cf::IO_UNIQUES);
		1222	} else {
		1223	$self->save_objects ($save, cf::IO_HEADER \| cf::IO_OBJECTS \| cf::IO_UNIQUES);
		1224	}
		1225	}
		1226
		1227	sub swap_out {
		1228	my ($self) = @_;
		1229
		1230	return if $self->players;
		1231	return if $self->in_memory != cf::MAP_IN_MEMORY;
		1232	return if $self->{deny_save};
		1233
		1234	$self->save;
		1235	$self->clear;
		1236	$self->in_memory (cf::MAP_SWAPPED);
		1237	}
		1238
		1239	sub reset_at {
		1240	my ($self) = @_;
		1241
		1242	# TODO: safety, remove and allow resettable per-player maps
		1243	return 1e100 if $self->{path}{user_rel};
		1244	return 1e100 if $self->{deny_reset};
		1245
		1246	my $time = $self->fixed_resettime ? $self->{instantiate_time} : $self->last_access;
		1247	my $to = $self->reset_timeout \|\| $DEFAULT_RESET;
		1248	$to = $MAX_RESET if $to > $MAX_RESET;
		1249
		1250	$time + $to
		1251	}
		1252
		1253	sub should_reset {
		1254	my ($self) = @_;
		1255
		1256	$self->reset_at <= $cf::RUNTIME
		1257	}
		1258
		1259	sub unlink_save {
		1260	my ($self) = @_;
		1261
		1262	utf8::encode (my $save = $self->{path}->save_path);
		1263	aioreq_pri 3; IO::AIO::aio_unlink $save;
		1264	aioreq_pri 3; IO::AIO::aio_unlink "$save.pst";
		1265	}
		1266
		1267	sub reset {
		1268	my ($self) = @_;
		1269
		1270	return if $self->players;
		1271	return if $self->{path}{user_rel};#d#
		1272
		1273	warn "resetting map ", $self->path;#d#
		1274
		1275	delete $cf::MAP{$self->path};
		1276
		1277	$_->clear_links_to ($self) for values %cf::MAP;
		1278
		1279	$self->unlink_save;
		1280	$self->destroy;
		1281	}
		1282
		1283	sub customise_for {
		1284	my ($map, $ob) = @_;
		1285
		1286	if ($map->per_player) {
		1287	return cf::map::find_map "~" . $ob->name . "/" . $map->{path}{path};
		1288	}
		1289
		1290	$map
		1291	}
		1292
		1293	sub emergency_save {
		1294	local $cf::FREEZE = 1;
		1295
		1296	warn "enter emergency map save\n";
		1297
		1298	cf::sync_job {
		1299	warn "begin emergency map save\n";
		1300	$_->save for values %cf::MAP;
		1301	};
		1302
		1303	warn "end emergency map save\n";
		1304	}
		1305
		1306	package cf;
		1307
		1308	=back
		1309
		1310
793	=head3 cf::object::player	1311	=head3 cf::object::player
794		1312
795	=over 4	1313	=over 4
796		1314
797	=item $player_object->reply ($npc, $msg[, $flags])	1315	=item $player_object->reply ($npc, $msg[, $flags])
…		…
830		1348
831	$self->flag (cf::FLAG_WIZ) \|\|	1349	$self->flag (cf::FLAG_WIZ) \|\|
832	(ref $cf::CFG{"may_$access"}	1350	(ref $cf::CFG{"may_$access"}
833	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}	1351	? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}
834	: $cf::CFG{"may_$access"})	1352	: $cf::CFG{"may_$access"})
		1353	}
		1354
		1355	sub cf::object::player::enter_link {
		1356	my ($self) = @_;
		1357
		1358	return if $self->map == $LINK_MAP;
		1359
		1360	$self->{_link_pos} = [$self->map->{path}, $self->x, $self->y]
		1361	if $self->map;
		1362
		1363	$self->enter_map ($LINK_MAP, 20, 20);
		1364	$self->deactivate_recursive;
		1365	}
		1366
		1367	sub cf::object::player::leave_link {
		1368	my ($self, $map, $x, $y) = @_;
		1369
		1370	my $link_pos = delete $self->{_link_pos};
		1371
		1372	unless ($map) {
		1373	$self->message ("The exit is closed", cf::NDI_UNIQUE \| cf::NDI_RED);
		1374
		1375	# restore original map position
		1376	($map, $x, $y) = @{ $link_pos \|\| [] };
		1377	$map = cf::map::find_map $map;
		1378
		1379	unless ($map) {
		1380	($map, $x, $y) = @$EMERGENCY_POSITION;
		1381	$map = cf::map::find_map $map
		1382	or die "FATAL: cannot load emergency map\n";
		1383	}
		1384	}
		1385
		1386	($x, $y) = (-1, -1)
		1387	unless (defined $x) && (defined $y);
		1388
		1389	# use -1 or undef as default coordinates, not 0, 0
		1390	($x, $y) = ($map->enter_x, $map->enter_y)
		1391	if $x <=0 && $y <= 0;
		1392
		1393	$map->load;
		1394
		1395	$self->activate_recursive;
		1396	$self->enter_map ($map, $x, $y);
		1397	}
		1398
		1399	=item $player_object->goto_map ($map, $x, $y)
		1400
		1401	=cut
		1402
		1403	sub cf::object::player::goto_map {
		1404	my ($self, $path, $x, $y) = @_;
		1405
		1406	$self->enter_link;
		1407
		1408	(Coro::async {
		1409	$path = new cf::path $path;
		1410
		1411	my $map = cf::map::find_map $path->as_string;
		1412	$map = $map->customise_for ($self) if $map;
		1413
		1414	warn "entering ", $map->path, " at ($x, $y)\n"
		1415	if $map;
		1416
		1417	$self->leave_link ($map, $x, $y);
		1418	})->prio (1);
		1419	}
		1420
		1421	=item $player_object->enter_exit ($exit_object)
		1422
		1423	=cut
		1424
		1425	sub parse_random_map_params {
		1426	my ($spec) = @_;
		1427
		1428	my $rmp = { # defaults
		1429	xsize => 10,
		1430	ysize => 10,
		1431	};
		1432
		1433	for (split /\n/, $spec) {
		1434	my ($k, $v) = split /\s+/, $_, 2;
		1435
		1436	$rmp->{lc $k} = $v if (length $k) && (length $v);
		1437	}
		1438
		1439	$rmp
		1440	}
		1441
		1442	sub prepare_random_map {
		1443	my ($exit) = @_;
		1444
		1445	# all this does is basically replace the /! path by
		1446	# a new random map path (?random/...) with a seed
		1447	# that depends on the exit object
		1448
		1449	my $rmp = parse_random_map_params $exit->msg;
		1450
		1451	if ($exit->map) {
		1452	$rmp->{region} = $exit->map->region_name;
		1453	$rmp->{origin_map} = $exit->map->path;
		1454	$rmp->{origin_x} = $exit->x;
		1455	$rmp->{origin_y} = $exit->y;
		1456	}
		1457
		1458	$rmp->{random_seed} \|\|= $exit->random_seed;
		1459
		1460	my $data = cf::to_json $rmp;
		1461	my $md5 = Digest::MD5::md5_hex $data;
		1462
		1463	if (my $fh = aio_open "$cf::RANDOM_MAPS/$md5.meta", O_WRONLY \| O_CREAT, 0666) {
		1464	aio_write $fh, 0, (length $data), $data, 0;
		1465
		1466	$exit->slaying ("?random/$md5");
		1467	$exit->msg (undef);
		1468	}
		1469	}
		1470
		1471	sub cf::object::player::enter_exit {
		1472	my ($self, $exit) = @_;
		1473
		1474	return unless $self->type == cf::PLAYER;
		1475
		1476	$self->enter_link;
		1477
		1478	(Coro::async {
		1479	unless (eval {
		1480
		1481	prepare_random_map $exit
		1482	if $exit->slaying eq "/!";
		1483
		1484	my $path = new cf::path $exit->slaying, $exit->map && $exit->map->path;
		1485	$self->goto_map ($path, $exit->stats->hp, $exit->stats->sp);
		1486
		1487	1;
		1488	}) {
		1489	$self->message ("Something went wrong deep within the crossfire server. "
		1490	. "I'll try to bring you back to the map you were before. "
		1491	. "Please report this to the dungeon master",
		1492	cf::NDI_UNIQUE \| cf::NDI_RED);
		1493
		1494	warn "ERROR in enter_exit: $@";
		1495	$self->leave_link;
		1496	}
		1497	})->prio (1);
835	}	1498	}
836		1499
837	=head3 cf::client	1500	=head3 cf::client
838		1501
839	=over 4	1502	=over 4
…		…
916	my $coro; $coro = async {	1579	my $coro; $coro = async {
917	eval {	1580	eval {
918	$cb->();	1581	$cb->();
919	};	1582	};
920	warn $@ if $@;	1583	warn $@ if $@;
		1584	};
		1585
		1586	$coro->on_destroy (sub {
921	delete $self->{_coro}{$coro+0};	1587	delete $self->{_coro}{$coro+0};
922	};	1588	});
923		1589
924	$self->{_coro}{$coro+0} = $coro;	1590	$self->{_coro}{$coro+0} = $coro;
		1591
		1592	$coro
925	}	1593	}
926		1594
927	cf::client->attach (	1595	cf::client->attach (
928	on_destroy => sub {	1596	on_destroy => sub {
929	my ($ns) = @_;	1597	my ($ns) = @_;
…		…
1161	local $/;	1829	local $/;
1162	*CFG = YAML::Syck::Load <$fh>;	1830	*CFG = YAML::Syck::Load <$fh>;
1163	}	1831	}
1164		1832
1165	sub main {	1833	sub main {
		1834	# we must not ever block the main coroutine
		1835	local $Coro::idle = sub {
		1836	Carp::cluck "FATAL: Coro::idle was called, major BUG\n";#d#
		1837	(Coro::unblock_sub {
		1838	Event::one_event;
		1839	})->();
		1840	};
		1841
1166	cfg_load;	1842	cfg_load;
1167	db_load;	1843	db_load;
1168	load_extensions;	1844	load_extensions;
1169	Event::loop;	1845	Event::loop;
1170	}	1846	}
1171		1847
1172	#############################################################################	1848	#############################################################################
1173	# initialisation	1849	# initialisation
1174		1850
1175	sub _perl_reload(&) {	1851	sub reload() {
1176	my ($msg) = @_;	1852	# can/must only be called in main
		1853	if ($Coro::current != $Coro::main) {
		1854	warn "can only reload from main coroutine\n";
		1855	return;
		1856	}
1177		1857
1178	$msg->("reloading...");	1858	warn "reloading...";
		1859
		1860	local $FREEZE = 1;
		1861	cf::emergency_save;
1179		1862
1180	eval {	1863	eval {
		1864	# if anything goes wrong in here, we should simply crash as we already saved
		1865
1181	# cancel all watchers	1866	# cancel all watchers
1182	for (Event::all_watchers) {	1867	for (Event::all_watchers) {
1183	$_->cancel if $_->data & WF_AUTOCANCEL;	1868	$_->cancel if $_->data & WF_AUTOCANCEL;
1184	}	1869	}
1185		1870
		1871	# cancel all extension coros
		1872	$_->cancel for values %EXT_CORO;
		1873	%EXT_CORO = ();
		1874
1186	# unload all extensions	1875	# unload all extensions
1187	for (@exts) {	1876	for (@exts) {
1188	$msg->("unloading <$_>");	1877	warn "unloading <$_>";
1189	unload_extension $_;	1878	unload_extension $_;
1190	}	1879	}
1191		1880
1192	# unload all modules loaded from $LIBDIR	1881	# unload all modules loaded from $LIBDIR
1193	while (my ($k, $v) = each %INC) {	1882	while (my ($k, $v) = each %INC) {
1194	next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;	1883	next unless $v =~ /^\Q$LIBDIR\E\/.*\.pm$/;
1195		1884
1196	$msg->("removing <$k>");	1885	warn "removing <$k>";
1197	delete $INC{$k};	1886	delete $INC{$k};
1198		1887
1199	$k =~ s/\.pm$//;	1888	$k =~ s/\.pm$//;
1200	$k =~ s/\//::/g;	1889	$k =~ s/\//::/g;
1201		1890
…		…
1206	Symbol::delete_package $k;	1895	Symbol::delete_package $k;
1207	}	1896	}
1208		1897
1209	# sync database to disk	1898	# sync database to disk
1210	cf::db_sync;	1899	cf::db_sync;
		1900	IO::AIO::flush;
1211		1901
1212	# get rid of safe::, as good as possible	1902	# get rid of safe::, as good as possible
1213	Symbol::delete_package "safe::$_"	1903	Symbol::delete_package "safe::$_"
1214	for qw(cf::object cf::object::player cf::player cf::map cf::party cf::region);	1904	for qw(cf::attachable cf::object cf::object::player cf::client cf::player cf::map cf::party cf::region);
1215		1905
1216	# remove register_script_function callbacks	1906	# remove register_script_function callbacks
1217	# TODO	1907	# TODO
1218		1908
1219	# unload cf.pm "a bit"	1909	# unload cf.pm "a bit"
…		…
1222	# don't, removes xs symbols, too,	1912	# don't, removes xs symbols, too,
1223	# and global variables created in xs	1913	# and global variables created in xs
1224	#Symbol::delete_package __PACKAGE__;	1914	#Symbol::delete_package __PACKAGE__;
1225		1915
1226	# reload cf.pm	1916	# reload cf.pm
1227	$msg->("reloading cf.pm");	1917	warn "reloading cf.pm";
1228	require cf;	1918	require cf;
1229	cf::_connect_to_perl; # nominally unnecessary, but cannot hurt	1919	cf::_connect_to_perl; # nominally unnecessary, but cannot hurt
1230		1920
1231	# load config and database again	1921	# load config and database again
1232	cf::cfg_load;	1922	cf::cfg_load;
1233	cf::db_load;	1923	cf::db_load;
1234		1924
1235	# load extensions	1925	# load extensions
1236	$msg->("load extensions");	1926	warn "load extensions";
1237	cf::load_extensions;	1927	cf::load_extensions;
1238		1928
1239	# reattach attachments to objects	1929	# reattach attachments to objects
1240	$msg->("reattach");	1930	warn "reattach";
1241	_global_reattach;	1931	_global_reattach;
1242	};	1932	};
1243	$msg->($@) if $@;
1244		1933
1245	$msg->("reloaded");	1934	if ($@) {
		1935	warn $@;
		1936	warn "error while reloading, exiting.";
		1937	exit 1;
		1938	}
		1939
		1940	warn "reloaded successfully";
1246	};	1941	};
1247		1942
1248	sub perl_reload() {	1943	#############################################################################
1249	_perl_reload {	1944
1250	warn $_[0];	1945	unless ($LINK_MAP) {
1251	print "$_[0]\n";	1946	$LINK_MAP = cf::map::new;
1252	};	1947
		1948	$LINK_MAP->width (41);
		1949	$LINK_MAP->height (41);
		1950	$LINK_MAP->alloc;
		1951	$LINK_MAP->path ("{link}");
		1952	$LINK_MAP->{path} = bless { path => "{link}" }, "cf::path";
		1953	$LINK_MAP->in_memory (MAP_IN_MEMORY);
		1954
		1955	# dirty hack because... archetypes are not yet loaded
		1956	Event->timer (
		1957	after => 2,
		1958	cb => sub {
		1959	$_[0]->w->cancel;
		1960
		1961	# provide some exits "home"
		1962	my $exit = cf::object::new "exit";
		1963
		1964	$exit->slaying ($EMERGENCY_POSITION->[0]);
		1965	$exit->stats->hp ($EMERGENCY_POSITION->[1]);
		1966	$exit->stats->sp ($EMERGENCY_POSITION->[2]);
		1967
		1968	$LINK_MAP->insert ($exit->clone, 19, 19);
		1969	$LINK_MAP->insert ($exit->clone, 19, 20);
		1970	$LINK_MAP->insert ($exit->clone, 19, 21);
		1971	$LINK_MAP->insert ($exit->clone, 20, 19);
		1972	$LINK_MAP->insert ($exit->clone, 20, 21);
		1973	$LINK_MAP->insert ($exit->clone, 21, 19);
		1974	$LINK_MAP->insert ($exit->clone, 21, 20);
		1975	$LINK_MAP->insert ($exit->clone, 21, 21);
		1976
		1977	$exit->destroy;
		1978	});
		1979
		1980	$LINK_MAP->{deny_save} = 1;
		1981	$LINK_MAP->{deny_reset} = 1;
		1982
		1983	$cf::MAP{$LINK_MAP->path} = $LINK_MAP;
1253	}	1984	}
1254		1985
1255	register "<global>", __PACKAGE__;	1986	register "<global>", __PACKAGE__;
1256		1987
1257	register_command "perl-reload" => sub {	1988	register_command "reload" => sub {
1258	my ($who, $arg) = @_;	1989	my ($who, $arg) = @_;
1259		1990
1260	if ($who->flag (FLAG_WIZ)) {	1991	if ($who->flag (FLAG_WIZ)) {
1261	_perl_reload {	1992	$who->message ("start of reload.");
1262	warn $_[0];	1993	reload;
1263	$who->message ($_[0]);	1994	$who->message ("end of reload.");
1264	};
1265	}	1995	}
1266	};	1996	};
1267		1997
1268	unshift @INC, $LIBDIR;	1998	unshift @INC, $LIBDIR;
1269		1999
1270	$TICK_WATCHER = Event->timer (	2000	$TICK_WATCHER = Event->timer (
		2001	reentrant => 0,
1271	prio => 0,	2002	prio => 0,
1272	at => $NEXT_TICK \|\| 1,	2003	at => $NEXT_TICK \|\| $TICK,
1273	data => WF_AUTOCANCEL,	2004	data => WF_AUTOCANCEL,
1274	cb => sub {	2005	cb => sub {
		2006	unless ($FREEZE) {
1275	cf::server_tick; # one server iteration	2007	cf::server_tick; # one server iteration
		2008	$RUNTIME += $TICK;
		2009	}
1276		2010
1277	my $NOW = Event::time;
1278	$NEXT_TICK += $TICK;	2011	$NEXT_TICK += $TICK;
1279		2012
1280	# if we are delayed by four ticks or more, skip them all	2013	# if we are delayed by four ticks or more, skip them all
1281	$NEXT_TICK = $NOW if $NOW >= $NEXT_TICK + $TICK * 4;	2014	$NEXT_TICK = Event::time if Event::time >= $NEXT_TICK + $TICK * 4;
1282		2015
1283	$TICK_WATCHER->at ($NEXT_TICK);	2016	$TICK_WATCHER->at ($NEXT_TICK);
1284	$TICK_WATCHER->start;	2017	$TICK_WATCHER->start;
1285	},	2018	},
1286	);	2019	);
1287		2020
1288	IO::AIO::max_poll_time $TICK * 0.2;	2021	IO::AIO::max_poll_time $TICK * 0.2;
1289		2022
		2023	Event->io (
1290	Event->io (fd => IO::AIO::poll_fileno,	2024	fd => IO::AIO::poll_fileno,
1291	poll => 'r',	2025	poll => 'r',
1292	prio => 5,	2026	prio => 5,
1293	data => WF_AUTOCANCEL,	2027	data => WF_AUTOCANCEL,
1294	cb => \&IO::AIO::poll_cb);	2028	cb => \&IO::AIO::poll_cb,
		2029	);
		2030
		2031	Event->timer (
		2032	data => WF_AUTOCANCEL,
		2033	after => 0,
		2034	interval => 10,
		2035	cb => sub {
		2036	(Coro::unblock_sub {
		2037	write_runtime
		2038	or warn "ERROR: unable to write runtime file: $!";
		2039	})->();
		2040	},
		2041	);
1295		2042
1296	1	2043	1
1297		2044

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.102 by root, Wed Dec 27 15:20:54 2006 UTC vs. Revision 1.112 by root, Mon Jan 1 13:31:47 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.102 by root, Wed Dec 27 15:20:54 2006 UTC vs.
Revision 1.112 by root, Mon Jan 1 13:31:47 2007 UTC