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

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.252 by root, Wed Apr 18 15:28:18 2007 UTC vs.
Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC

…		…
54	our %EXT_CORO = (); # coroutines bound to extensions	54	our %EXT_CORO = (); # coroutines bound to extensions
55	our %EXT_MAP = (); # pluggable maps	55	our %EXT_MAP = (); # pluggable maps
56		56
57	our $RELOAD; # number of reloads so far	57	our $RELOAD; # number of reloads so far
58	our @EVENT;	58	our @EVENT;
59	our $LIBDIR = datadir . "/ext";	59
		60	our $CONFDIR = confdir;
		61	our $DATADIR = datadir;
		62	our $LIBDIR = "$DATADIR/ext";
		63	our $PODDIR = "$DATADIR/pod";
		64	our $MAPDIR = "$DATADIR/" . mapdir;
		65	our $LOCALDIR = localdir;
		66	our $TMPDIR = "$LOCALDIR/" . tmpdir;
		67	our $UNIQUEDIR = "$LOCALDIR/" . uniquedir;
		68	our $PLAYERDIR = "$LOCALDIR/" . playerdir;
		69	our $RANDOMDIR = "$LOCALDIR/random";
		70	our $BDBDIR = "$LOCALDIR/db";
60		71
61	our $TICK = MAX_TIME * 1e-6; # this is a CONSTANT(!)	72	our $TICK = MAX_TIME * 1e-6; # this is a CONSTANT(!)
62	our $TICK_WATCHER;	73	our $TICK_WATCHER;
63	our $AIO_POLL_WATCHER;	74	our $AIO_POLL_WATCHER;
64	our $NEXT_RUNTIME_WRITE; # when should the runtime file be written	75	our $NEXT_RUNTIME_WRITE; # when should the runtime file be written
…		…
75	our $RUNTIME;	86	our $RUNTIME;
76		87
77	our %PLAYER; # all users	88	our %PLAYER; # all users
78	our %MAP; # all maps	89	our %MAP; # all maps
79	our $LINK_MAP; # the special {link} map, which is always available	90	our $LINK_MAP; # the special {link} map, which is always available
80	our $RANDOM_MAPS = cf::localdir . "/random";
81	our $BDB_ENV_DIR = cf::localdir . "/db";
82		91
83	# used to convert map paths into valid unix filenames by replacing / by ∕	92	# used to convert map paths into valid unix filenames by replacing / by ∕
84	our $PATH_SEP = "∕"; # U+2215, chosen purely for visual reasons	93	our $PATH_SEP = "∕"; # U+2215, chosen purely for visual reasons
85		94
86	binmode STDOUT;	95	binmode STDOUT;
87	binmode STDERR;	96	binmode STDERR;
88		97
89	# read virtual server time, if available	98	# read virtual server time, if available
90	unless ($RUNTIME \|\| !-e cf::localdir . "/runtime") {	99	unless ($RUNTIME \|\| !-e "$LOCALDIR/runtime") {
91	open my $fh, "<", cf::localdir . "/runtime"	100	open my $fh, "<", "$LOCALDIR/runtime"
92	or die "unable to read runtime file: $!";	101	or die "unable to read runtime file: $!";
93	$RUNTIME = <$fh> + 0.;	102	$RUNTIME = <$fh> + 0.;
94	}	103	}
95		104
96	mkdir cf::localdir;	105	mkdir $_
97	mkdir cf::localdir . "/" . cf::playerdir;	106	for $LOCALDIR, $TMPDIR, $UNIQUEDIR, $PLAYERDIR, $RANDOMDIR, $BDBDIR;
98	mkdir cf::localdir . "/" . cf::tmpdir;
99	mkdir cf::localdir . "/" . cf::uniquedir;
100	mkdir $RANDOM_MAPS;
101	mkdir $BDB_ENV_DIR;
102		107
103	our $EMERGENCY_POSITION;	108	our $EMERGENCY_POSITION;
104		109
105	sub cf::map::normalise;	110	sub cf::map::normalise;
106		111
…		…
117	=item $cf::RUNTIME	122	=item $cf::RUNTIME
118		123
119	The time this server has run, starts at 0 and is increased by $cf::TICK on	124	The time this server has run, starts at 0 and is increased by $cf::TICK on
120	every server tick.	125	every server tick.
121		126
122	=item $cf::LIBDIR	127	=item $cf::CONFDIR $cf::DATADIR $cf::LIBDIR $cf::PODDIR
		128	$cf::MAPDIR $cf::LOCALDIR $cf::TMPDIR $cf::UNIQUEDIR
		129	$cf::PLAYERDIR $cf::RANDOMDIR $cf::BDBDIR
123		130
124	The perl library directory, where extensions and cf-specific modules can	131	Various directories - "/etc", read-only install directory, perl-library
125	be found. It will be added to C<@INC> automatically.	132	directory, pod-directory, read-only maps directory, "/var", "/var/tmp",
		133	unique-items directory, player file directory, random maps directory and
		134	database environment.
126		135
127	=item $cf::NOW	136	=item $cf::NOW
128		137
129	The time of the last (current) server tick.	138	The time of the last (current) server tick.
130		139
…		…
152	my $msg = join "", @_;	161	my $msg = join "", @_;
153		162
154	$msg .= "\n"	163	$msg .= "\n"
155	unless $msg =~ /\n$/;	164	unless $msg =~ /\n$/;
156		165
157	$msg =~ s/([\x00-\x09\x0b-\x1f])/sprintf "\\x%02x", ord $1/ge;	166	$msg =~ s/([\x00-\x08\x0b-\x1f])/sprintf "\\x%02x", ord $1/ge;
158		167
159	utf8::encode $msg;	168	utf8::encode $msg;
160	LOG llevError, $msg;	169	LOG llevError, $msg;
161	};	170	};
162	}	171	}
…		…
234	returned.	243	returned.
235		244
236	Lock names should begin with a unique identifier (for example, cf::map::find	245	Lock names should begin with a unique identifier (for example, cf::map::find
237	uses map_find and cf::map::load uses map_load).	246	uses map_find and cf::map::load uses map_load).
238		247
		248	=item $locked = cf::lock_active $string
		249
		250	Return true if the lock is currently active, i.e. somebody has locked it.
		251
239	=cut	252	=cut
240		253
241	our %LOCK;	254	our %LOCK;
242		255
243	sub lock_wait($) {	256	sub lock_wait($) {
…		…
260		273
261	Coro::guard {	274	Coro::guard {
262	# wake up all waiters, to be on the safe side	275	# wake up all waiters, to be on the safe side
263	$_->ready for @{ delete $LOCK{$key} };	276	$_->ready for @{ delete $LOCK{$key} };
264	}	277	}
		278	}
		279
		280	sub lock_active($) {
		281	my ($key) = @_;
		282
		283	! ! $LOCK{$key}
265	}	284	}
266		285
267	sub freeze_mainloop {	286	sub freeze_mainloop {
268	return unless $TICK_WATCHER->is_active;	287	return unless $TICK_WATCHER->is_active;
269		288
…		…
350	}	369	}
351		370
352	sub write_runtime {	371	sub write_runtime {
353	my $guard = cf::lock_acquire "write_runtime";	372	my $guard = cf::lock_acquire "write_runtime";
354		373
355	my $runtime = cf::localdir . "/runtime";	374	my $runtime = "$LOCALDIR/runtime";
356		375
357	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644	376	my $fh = aio_open "$runtime~", O_WRONLY \| O_CREAT, 0644
358	or return;	377	or return;
359		378
360	my $value = $cf::RUNTIME + 90 + 10;	379	my $value = $cf::RUNTIME + 90 + 10;
…		…
955	Returns the given player object, loading it if necessary (might block).	974	Returns the given player object, loading it if necessary (might block).
956		975
957	=cut	976	=cut
958		977
959	sub playerdir($) {	978	sub playerdir($) {
960	cf::localdir	979	"$PLAYERDIR/"
961	. "/"
962	. cf::playerdir
963	. "/"
964	. (ref $_[0] ? $_[0]->ob->name : $_[0])	980	. (ref $_[0] ? $_[0]->ob->name : $_[0])
965	}	981	}
966		982
967	sub path($) {	983	sub path($) {
968	my $login = ref $_[0] ? $_[0]->ob->name : $_[0];	984	my $login = ref $_[0] ? $_[0]->ob->name : $_[0];
…		…
1088	while and may block, so not sync_job-capable, ever.	1104	while and may block, so not sync_job-capable, ever.
1089		1105
1090	=cut	1106	=cut
1091		1107
1092	sub list_logins {	1108	sub list_logins {
1093	my $dirs = aio_readdir cf::localdir . "/" . cf::playerdir	1109	my $dirs = aio_readdir $PLAYERDIR
1094	or return [];	1110	or return [];
1095		1111
1096	my @logins;	1112	my @logins;
1097		1113
1098	for my $login (@$dirs) {	1114	for my $login (@$dirs) {
…		…
1336		1352
1337	# the original (read-only) location	1353	# the original (read-only) location
1338	sub load_path {	1354	sub load_path {
1339	my ($self) = @_;	1355	my ($self) = @_;
1340		1356
1341	sprintf "%s/%s/%s.map", cf::datadir, cf::mapdir, $self->{path}	1357	"$MAPDIR/$self->{path}.map"
1342	}	1358	}
1343		1359
1344	# the temporary/swap location	1360	# the temporary/swap location
1345	sub save_path {	1361	sub save_path {
1346	my ($self) = @_;	1362	my ($self) = @_;
1347		1363
1348	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;	1364	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;
1349	sprintf "%s/%s/%s.map", cf::localdir, cf::tmpdir, $path	1365	"$TMPDIR/$path.map"
1350	}	1366	}
1351		1367
1352	# the unique path, undef == no special unique path	1368	# the unique path, undef == no special unique path
1353	sub uniq_path {	1369	sub uniq_path {
1354	my ($self) = @_;	1370	my ($self) = @_;
1355		1371
1356	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;	1372	(my $path = $_[0]{path}) =~ s/\//$PATH_SEP/g;
1357	sprintf "%s/%s/%s", cf::localdir, cf::uniquedir, $path	1373	"$UNIQUEDIR/$path"
1358	}	1374	}
1359		1375
1360	# and all this just because we cannot iterate over	1376	# and all this just because we cannot iterate over
1361	# all maps in C++...	1377	# all maps in C++...
1362	sub change_all_map_light {	1378	sub change_all_map_light {
…		…
1474	my ($self) = @_;	1490	my ($self) = @_;
1475		1491
1476	local $self->{deny_reset} = 1; # loading can take a long time	1492	local $self->{deny_reset} = 1; # loading can take a long time
1477		1493
1478	my $path = $self->{path};	1494	my $path = $self->{path};
		1495
		1496	{
1479	my $guard = cf::lock_acquire "map_load:$path";	1497	my $guard = cf::lock_acquire "map_load:$path";
1480		1498
1481	return if $self->in_memory != cf::MAP_SWAPPED;	1499	return if $self->in_memory != cf::MAP_SWAPPED;
1482		1500
1483	$self->in_memory (cf::MAP_LOADING);	1501	$self->in_memory (cf::MAP_LOADING);
1484		1502
1485	$self->alloc;	1503	$self->alloc;
1486		1504
1487	$self->pre_load;	1505	$self->pre_load;
1488	Coro::cede;
1489
1490	$self->_load_objects ($self->{load_path}, 1)
1491	or return;
1492
1493	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)
1494	if delete $self->{load_original};
1495
1496	if (my $uniq = $self->uniq_path) {
1497	utf8::encode $uniq;
1498	if (aio_open $uniq, O_RDONLY, 0) {
1499	$self->clear_unique_items;
1500	$self->_load_objects ($uniq, 0);
1501	}
1502	}
1503
1504	Coro::cede;
1505	# now do the right thing for maps
1506	$self->link_multipart_objects;
1507	Coro::cede;
1508
1509	unless ($self->{deny_activate}) {
1510	$self->decay_objects;
1511	$self->fix_auto_apply;
1512	$self->update_buttons;
1513	Coro::cede;	1506	Coro::cede;
1514	$self->set_darkness_map;	1507
		1508	$self->_load_objects ($self->{load_path}, 1)
		1509	or return;
		1510
		1511	$self->set_object_flag (cf::FLAG_OBJ_ORIGINAL, 1)
		1512	if delete $self->{load_original};
		1513
		1514	if (my $uniq = $self->uniq_path) {
		1515	utf8::encode $uniq;
		1516	if (aio_open $uniq, O_RDONLY, 0) {
		1517	$self->clear_unique_items;
		1518	$self->_load_objects ($uniq, 0);
		1519	}
		1520	}
		1521
		1522	Coro::cede;
		1523	# now do the right thing for maps
		1524	$self->link_multipart_objects;
1515	$self->difficulty ($self->estimate_difficulty)	1525	$self->difficulty ($self->estimate_difficulty)
1516	unless $self->difficulty;	1526	unless $self->difficulty;
1517	Coro::cede;	1527	Coro::cede;
		1528
		1529	unless ($self->{deny_activate}) {
		1530	$self->decay_objects;
		1531	$self->fix_auto_apply;
		1532	$self->update_buttons;
		1533	Coro::cede;
		1534	$self->set_darkness_map;
		1535	Coro::cede;
1518	$self->activate;	1536	$self->activate;
1519	Coro::cede;	1537	}
		1538
		1539	$self->in_memory (cf::MAP_IN_MEMORY);
		1540
		1541	undef $guard;
1520	}	1542	}
1521		1543
1522	$self->post_load;	1544	$self->post_load;
1523	Coro::cede;
1524
1525	$self->in_memory (cf::MAP_IN_MEMORY);
1526	}	1545	}
1527		1546
1528	sub customise_for {	1547	sub customise_for {
1529	my ($self, $ob) = @_;	1548	my ($self, $ob) = @_;
1530		1549
…		…
1721	instantiated unique items. May block.	1740	instantiated unique items. May block.
1722		1741
1723	=cut	1742	=cut
1724		1743
1725	sub unique_maps() {	1744	sub unique_maps() {
1726	my $files = aio_readdir cf::localdir . "/" . cf::uniquedir	1745	my $files = aio_readdir $UNIQUEDIR
1727	or return;	1746	or return;
1728		1747
1729	my @paths;	1748	my @paths;
1730		1749
1731	for (@$files) {	1750	for (@$files) {
…		…
1987		2006
1988	$rmp->{random_seed} \|\|= $exit->random_seed;	2007	$rmp->{random_seed} \|\|= $exit->random_seed;
1989		2008
1990	my $data = cf::to_json $rmp;	2009	my $data = cf::to_json $rmp;
1991	my $md5 = Digest::MD5::md5_hex $data;	2010	my $md5 = Digest::MD5::md5_hex $data;
1992	my $meta = "$cf::RANDOM_MAPS/$md5.meta";	2011	my $meta = "$RANDOMDIR/$md5.meta";
1993		2012
1994	if (my $fh = aio_open "$meta~", O_WRONLY \| O_CREAT, 0666) {	2013	if (my $fh = aio_open "$meta~", O_WRONLY \| O_CREAT, 0666) {
1995	aio_write $fh, 0, (length $data), $data, 0;	2014	aio_write $fh, 0, (length $data), $data, 0;
1996	undef $fh;	2015	undef $fh;
1997	aio_rename "$meta~", $meta;	2016	aio_rename "$meta~", $meta;
…		…
2373		2392
2374	return db_get cache => "$id/data";	2393	return db_get cache => "$id/data";
2375	}	2394	}
2376	}	2395	}
2377		2396
		2397	my $t1 = Time::HiRes::time;
2378	my $data = $process->(\@data);	2398	my $data = $process->(\@data);
		2399	my $t2 = Time::HiRes::time;
		2400
		2401	warn "cache: '$id' processed in ", $t2 - $t1, "s\n";
2379		2402
2380	db_put cache => "$id/data", $data;	2403	db_put cache => "$id/data", $data;
2381	db_put cache => "$id/md5" , $md5;	2404	db_put cache => "$id/md5" , $md5;
2382	db_put cache => "$id/meta", $meta;	2405	db_put cache => "$id/meta", $meta;
2383		2406
…		…
2485	}	2508	}
2486		2509
2487	1	2510	1
2488	}	2511	}
2489		2512
		2513	sub reload_regions {
		2514	load_resource_file "$MAPDIR/regions"
		2515	or die "unable to load regions file\n";
		2516	}
		2517
2490	sub reload_facedata {	2518	sub reload_facedata {
2491	load_facedata sprintf "%s/facedata", cf::datadir	2519	load_facedata "$DATADIR/facedata"
2492	or die "unable to load facedata\n";	2520	or die "unable to load facedata\n";
2493	}	2521	}
2494		2522
2495	sub reload_regions {
2496	load_resource_file sprintf "%s/%s/regions", cf::datadir, cf::mapdir
2497	or die "unable to load regions file\n";
2498	}
2499
2500	sub reload_archetypes {	2523	sub reload_archetypes {
2501	load_resource_file sprintf "%s/archetypes", cf::datadir	2524	load_resource_file "$DATADIR/archetypes"
2502	or die "unable to load archetypes\n";	2525	or die "unable to load archetypes\n";
2503	}	2526	}
2504		2527
2505	sub reload_treasures {	2528	sub reload_treasures {
2506	load_resource_file sprintf "%s/treasures", cf::datadir	2529	load_resource_file "$DATADIR/treasures"
2507	or die "unable to load treasurelists\n";	2530	or die "unable to load treasurelists\n";
2508	}	2531	}
2509		2532
2510	sub reload_resources {	2533	sub reload_resources {
2511	warn "reloading resource files...\n";	2534	warn "reloading resource files...\n";
…		…
2521	sub init {	2544	sub init {
2522	reload_resources;	2545	reload_resources;
2523	}	2546	}
2524		2547
2525	sub cfg_load {	2548	sub cfg_load {
2526	open my $fh, "<:utf8", cf::confdir . "/config"	2549	open my $fh, "<:utf8", "$CONFDIR/config"
2527	or return;	2550	or return;
2528		2551
2529	local $/;	2552	local $/;
2530	*CFG = YAML::Syck::Load <$fh>;	2553	*CFG = YAML::Syck::Load <$fh>;
2531		2554
…		…
2871		2894
2872	cf::sync_job {	2895	cf::sync_job {
2873	eval {	2896	eval {
2874	BDB::db_env_open	2897	BDB::db_env_open
2875	$DB_ENV,	2898	$DB_ENV,
2876	$BDB_ENV_DIR,	2899	$BDBDIR,
2877	BDB::INIT_LOCK \| BDB::INIT_LOG \| BDB::INIT_MPOOL \| BDB::INIT_TXN	2900	BDB::INIT_LOCK \| BDB::INIT_LOG \| BDB::INIT_MPOOL \| BDB::INIT_TXN
2878	\| BDB::RECOVER \| BDB::REGISTER \| BDB::USE_ENVIRON \| BDB::CREATE,	2901	\| BDB::RECOVER \| BDB::REGISTER \| BDB::USE_ENVIRON \| BDB::CREATE,
2879	0666;	2902	0666;
2880		2903
2881	cf::cleanup "db_env_open($BDB_ENV_DIR): $!" if $!;	2904	cf::cleanup "db_env_open($BDBDIR): $!" if $!;
2882		2905
2883	$DB_ENV->set_flags (BDB::AUTO_COMMIT \| BDB::REGION_INIT \| BDB::TXN_NOSYNC, 1);	2906	$DB_ENV->set_flags (BDB::AUTO_COMMIT \| BDB::REGION_INIT \| BDB::TXN_NOSYNC, 1);
2884	$DB_ENV->set_lk_detect;	2907	$DB_ENV->set_lk_detect;
2885	};	2908	};
2886		2909

Diff Legend

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

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.252 by root, Wed Apr 18 15:28:18 2007 UTC vs. Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.252 by root, Wed Apr 18 15:28:18 2007 UTC vs.
Revision 1.256 by root, Sat Apr 21 16:56:32 2007 UTC