[ViewVC] Diff of: cvs/deliantra/server/server/cfperl.xs

Comparing deliantra/server/server/cfperl.xs (file contents):
Revision 1.257 by root, Sun Sep 30 16:24:31 2007 UTC vs.
Revision 1.277 by root, Sat Apr 19 21:10:29 2008 UTC

…		…
1	/*	1	/*
2	* This file is part of Crossfire TRT, the Roguelike Realtime MORPG.	2	* This file is part of Deliantra, the Roguelike Realtime MMORPG.
3	*	3	*
4	* Copyright (©) 2006,2007 Marc Alexander Lehmann / Robin Redeker / the Crossfire TRT team	4	* Copyright (©) 2006,2007,2008 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
5	* Copyright (©) 2001-2005,2007 by Chachkoff Yann	5	* Copyright (©) 2001-2005,2007 by Chachkoff Yann
6	* Copyright (©) 2006,2007 by Marc Lehmann <cf@schmorp.de>	6	* Copyright (©) 2006,2007 by Marc Lehmann <cf@schmorp.de>
7	*	7	*
8	* Crossfire TRT is free software: you can redistribute it and/or modify	8	* Deliantra is free software: you can redistribute it and/or modify
9	* it under the terms of the GNU General Public License as published by	9	* it under the terms of the GNU General Public License as published by
10	* the Free Software Foundation, either version 3 of the License, or	10	* the Free Software Foundation, either version 3 of the License, or
11	* (at your option) any later version.	11	* (at your option) any later version.
12	*	12	*
13	* This program is distributed in the hope that it will be useful,	13	* This program is distributed in the hope that it will be useful,
16	* GNU General Public License for more details.	16	* GNU General Public License for more details.
17	*	17	*
18	* You should have received a copy of the GNU General Public License	18	* You should have received a copy of the GNU General Public License
19	* along with this program. If not, see <http://www.gnu.org/licenses/>.	19	* along with this program. If not, see <http://www.gnu.org/licenses/>.
20	*	20	*
21	* The authors can be reached via e-mail to <crossfire@schmorp.de>	21	* The authors can be reached via e-mail to <support@deliantra.net>
22	*/	22	*/
23		23
24	#include "autoconf.h"	24	#include "autoconf.h"
25		25
26	#define PLUGIN_NAME "perl"	26	#define PLUGIN_NAME "perl"
27	#define PLUGIN_VERSION "cfperl 0.5"	27	#define PLUGIN_VERSION "cfperl 0.5"
28
29	#define CEDES_PER_TICK 5
30		28
31	#if HAVE_EXECINFO_H	29	#if HAVE_EXECINFO_H
32	# include <execinfo.h>	30	# include <execinfo.h>
33	#endif	31	#endif
34		32
35	#include <cstdarg>	33	#include <cstdarg>
36		34
37	#include "global.h"	35	#include "global.h"
38	#include "loader.h"	36	#include "loader.h"
39	#include "../random_maps/random_map.h"	37	#include "../random_maps/random_map.h"
		38	#include "evthread.h"
40	#include <sproto.h>	39	#include "sproto.h"
41		40
42	#include <unistd.h>	41	#include <unistd.h>
43	#if _POSIX_MEMLOCK	42	#if _POSIX_MEMLOCK
44	# include <sys/mman.h>	43	# include <sys/mman.h>
45	#endif	44	#endif
46		45
		46	#if HAVE_MALLOC_H
		47	# include <malloc.h>
		48	#endif
		49
47	#include <EXTERN.h>	50	#include <EXTERN.h>
48	#include <perl.h>	51	#include <perl.h>
49	#include <XSUB.h>	52	#include <XSUB.h>
50		53
51	#include "CoroAPI.h"	54	#include "CoroAPI.h"
…		…
56	typedef object_thawer &object_thawer_ref;	59	typedef object_thawer &object_thawer_ref;
57	typedef object_freezer &object_freezer_ref;	60	typedef object_freezer &object_freezer_ref;
58		61
59	typedef std::string std__string;	62	typedef std::string std__string;
60		63
61	#if IVSIZE >= 8
62	typedef IV val64;
63	# define newSVval64 newSViv
64	# define SvVAL64 SvIV
65	#else
66	typedef double val64;
67	# define newSVval64 newSVnv
68	# define SvVAL64 SvNV
69	#endif
70
71	static PerlInterpreter *perl;	64	static PerlInterpreter *perl;
72		65
73	tstamp NOW, runtime;	66	tstamp NOW, runtime;
		67
		68	static int tick_inhibit;
		69	static int tick_pending;
74		70
75	global gbl_ev;	71	global gbl_ev;
76	static AV cb_global, cb_attachable, cb_object, cb_player, cb_client, cb_type, *cb_map;	72	static AV cb_global, cb_attachable, cb_object, cb_player, cb_client, cb_type, *cb_map;
77	static SV sv_runtime, sv_next_tick;	73	static SV sv_runtime, sv_tick_start, sv_next_tick, sv_now;
78		74
79	bitset<NUM_EVENT_TYPES> ev_want_event;	75	bitset<NUM_EVENT_TYPES> ev_want_event;
80	bitset<NUM_TYPES> ev_want_type;	76	bitset<NUM_TYPES> ev_want_type;
81		77
82	static HV	78	static HV
…		…
438	inline SV *to_sv (living & v) { return to_sv (&v); }	434	inline SV *to_sv (living & v) { return to_sv (&v); }
439		435
440	inline SV *to_sv (const std::string & v) { return newSVpvn (v.data (), v.size ()); }	436	inline SV *to_sv (const std::string & v) { return newSVpvn (v.data (), v.size ()); }
441	inline SV to_sv (const treasurelist v) { return to_sv (v->name); }	437	inline SV to_sv (const treasurelist v) { return to_sv (v->name); }
442		438
443	inline SV *to_sv (UUID v)	439	inline SV *to_sv (UUID v) { return newSVpv (v.c_str (), 0); }
444	{
445	char buf[128];
446	snprintf (buf, 128, "<1.%" PRIx64 ">", v.seq);
447	return newSVpv (buf, 0);
448	}
449		440
450	inline void sv_to (SV *sv, shstr &v) { v = SvOK (sv) ? SvPVutf8_nolen (sv) : 0; }	441	inline void sv_to (SV *sv, shstr &v) { v = SvOK (sv) ? SvPVutf8_nolen (sv) : 0; }
451	inline void sv_to (SV sv, char &v) { free (v); v = SvOK (sv) ? strdup (SvPV_nolen (sv)) : 0; }	442	inline void sv_to (SV sv, char &v) { free (v); v = SvOK (sv) ? strdup (SvPV_nolen (sv)) : 0; }
452	inline void sv_to (SV *sv, bool &v) { v = SvIV (sv); }	443	inline void sv_to (SV *sv, bool &v) { v = SvIV (sv); }
453	inline void sv_to (SV *sv, signed char &v) { v = SvIV (sv); }	444	inline void sv_to (SV *sv, signed char &v) { v = SvIV (sv); }
…		…
495	v.assign (data, len);	486	v.assign (data, len);
496	}	487	}
497		488
498	inline void sv_to (SV *sv, UUID &v)	489	inline void sv_to (SV *sv, UUID &v)
499	{	490	{
500	unsigned int version;	491	if (!v.parse (SvPV_nolen (sv)))
501
502	if (2 != sscanf (SvPV_nolen (sv), "<%d.%" SCNx64 ">", &version, &v.seq) \|\| 1 != version)
503	croak ("unparsable uuid: %s", SvPV_nolen (sv));	492	croak ("unparsable uuid: %s", SvPV_nolen (sv));
504	}	493	}
505		494
506	inline void sv_to (SV *sv, object::flags_t::reference v) { v = SvTRUE (sv); }	495	inline void sv_to (SV *sv, object::flags_t::reference v) { v = SvTRUE (sv); }
507		496
…		…
601	/////////////////////////////////////////////////////////////////////////////	590	/////////////////////////////////////////////////////////////////////////////
602		591
603	void	592	void
604	cfperl_init ()	593	cfperl_init ()
605	{	594	{
		595	extern char **environ;
		596
606	PERL_SYS_INIT3 (&settings.argc, &settings.argv, 0);	597	PERL_SYS_INIT3 (&settings.argc, &settings.argv, &environ);
607	perl = perl_alloc ();	598	perl = perl_alloc ();
608	perl_construct (perl);	599	perl_construct (perl);
609		600
610	PL_exit_flags \|= PERL_EXIT_DESTRUCT_END;	601	PL_exit_flags \|= PERL_EXIT_DESTRUCT_END;
611		602
612	const char *argv[] = {	603	const char *argv[] = {
613	settings.argv [0],	604	settings.argv [0],
614	"-e"	605	"-e"
615	"use Event; use Coro;" // required for bootstrap	606	"use EV; use Coro;" // required for bootstrap
616	"cf->bootstrap;" // required for datadir :*>	607	"cf->bootstrap;" // required for datadir :*>
617	"unshift @INC, cf::datadir ();"	608	"unshift @INC, cf::datadir ();"
618	"require cf;"	609	"require cf;"
619	};	610	};
620		611
621	if (perl_parse (perl, xs_init, 2, (char )argv, (char )NULL)	612	if (perl_parse (perl, xs_init, 2, (char **)argv, environ)
622	\|\| perl_run (perl))	613	\|\| perl_run (perl))
623	{	614	{
624	printf ("unable to initialize perl-interpreter, aborting.\n");	615	printf ("unable to initialize perl-interpreter, aborting.\n");
625	exit (EXIT_FAILURE);	616	exit (EXIT_FAILURE);
626	}	617	}
…		…
903	}	894	}
904		895
905	/////////////////////////////////////////////////////////////////////////////	896	/////////////////////////////////////////////////////////////////////////////
906	// various c++ => perl glue functions	897	// various c++ => perl glue functions
907		898
		899	void cfperl_tick ()
		900	{
		901	tick_pending = 1;
		902
		903	if (tick_inhibit)
		904	return;
		905
		906	tick_pending = 0;
		907
		908	dSP;
		909
		910	PUSHMARK (SP);
		911	PUTBACK;
		912	call_pv ("cf::tick", G_DISCARD \| G_VOID);
		913
		914	SvNV_set (sv_next_tick, get_next_tick ()); SvNOK_only (sv_next_tick);
		915	}
		916
908	void	917	void
909	cfperl_emergency_save ()	918	cfperl_emergency_save ()
910	{	919	{
911	CALL_BEGIN (0);	920	CALL_BEGIN (0);
912	CALL_CALL ("cf::emergency_save", G_VOID);	921	CALL_CALL ("cf::emergency_save", G_VOID);
…		…
1095	#endif	1104	#endif
1096	}	1105	}
1097		1106
1098	/////////////////////////////////////////////////////////////////////////////	1107	/////////////////////////////////////////////////////////////////////////////
1099		1108
1100	struct EventAPI *watcher_base::GEventAPI;	1109	struct EVAPI *evapi::GEVAPI;
1101	struct CoroAPI *coroapi::GCoroAPI;	1110	struct CoroAPI *coroapi::GCoroAPI;
1102
1103	int coroapi::cede_counter;
1104	tstamp coroapi::next_cede;
1105		1111
1106	void coroapi::do_cede_to_tick ()	1112	void coroapi::do_cede_to_tick ()
1107	{	1113	{
1108	cede_counter = 0;	1114	cede_pending = 0;
1109
1110	cede ();	1115	cede ();
1111
1112	next_cede += (TICK / CEDES_PER_TICK) * 0.99;
1113	if (next_cede > SvNV (sv_next_tick) - 0.02)
1114	next_cede = SvNV (sv_next_tick);
1115	}
1116
1117	void coroapi::do_cede_every ()
1118	{
1119	cede_counter = 0;
1120
1121	if (coroapi::nready ())
1122	coroapi::cede ();
1123	}
1124
1125	void coroapi::do_cede_to_tick_every ()
1126	{
1127	cede_counter = 0;
1128
1129	cede_to_tick ();
1130	}	1116	}
1131		1117
1132	void	1118	void
1133	coroapi::wait_for_tick ()	1119	coroapi::wait_for_tick ()
1134	{	1120	{
…		…
1143	CALL_BEGIN (0);	1129	CALL_BEGIN (0);
1144	CALL_CALL ("cf::wait_for_tick_begin", G_DISCARD);	1130	CALL_CALL ("cf::wait_for_tick_begin", G_DISCARD);
1145	CALL_END;	1131	CALL_END;
1146	}	1132	}
1147		1133
1148	static void
1149	iw_dispatch (pe_event *ev)
1150	{
1151	iw w = (iw )ev->ext_data;
1152	w->call (*w);
1153	}
1154
1155	void
1156	iw::alloc ()
1157	{
1158	pe = GEventAPI->new_idle (0, 0);
1159
1160	WaREENTRANT_off (pe);
1161	pe->base.callback = (void *)iw_dispatch;
1162	pe->base.ext_data = (void *)this;
1163	}
1164
1165	static void iow_dispatch (pe_event *ev)
1166	{
1167	iow w = (iow )ev->ext_data;
1168	w->call (w, ((pe_ioevent )ev)->got);
1169	}
1170
1171	void
1172	iow::alloc ()
1173	{
1174	pe = GEventAPI->new_io (0, 0);
1175
1176	WaREENTRANT_off (pe);
1177	pe->base.callback = (void *)iow_dispatch;
1178	pe->base.ext_data = (void *)this;
1179
1180	pe->fd = -1;
1181	pe->poll = 0;
1182	}
1183
1184	void
1185	iow::fd (int fd)
1186	{
1187	pe->fd = fd;
1188	}
1189
1190	int
1191	iow::poll ()
1192	{
1193	return pe->poll;
1194	}
1195
1196	void	1134	void
1197	iow::poll (int events)	1135	iow::poll (int events)
1198	{	1136	{
1199	if (pe->poll != events)	1137	if (events != this->events)
1200	{	1138	{
		1139	int active = ev_is_active ((ev_io *)this);
1201	if (pe->poll) stop ();	1140	if (active) stop ();
1202	pe->poll = events;	1141	ev_io_set ((ev_io *)this, fd, events);
1203	if (pe->poll) start ();	1142	if (active) start ();
1204	}	1143	}
1205	}	1144	}
1206		1145
1207	void	1146	void
1208	_connect_to_perl ()	1147	_connect_to_perl ()
1209	{	1148	{
1210	stash_cf = gv_stashpv ("cf" , 1);	1149	stash_cf = gv_stashpv ("cf", 1);
1211		1150
1212	stash_cf_object_wrap = gv_stashpv ("cf::object::wrap", 1);	1151	stash_cf_object_wrap = gv_stashpv ("cf::object::wrap", 1);
1213	stash_cf_object_player_wrap = gv_stashpv ("cf::object::player::wrap", 1);	1152	stash_cf_object_player_wrap = gv_stashpv ("cf::object::player::wrap", 1);
1214	stash_cf_player_wrap = gv_stashpv ("cf::player::wrap", 1);	1153	stash_cf_player_wrap = gv_stashpv ("cf::player::wrap", 1);
1215	stash_cf_map_wrap = gv_stashpv ("cf::map::wrap" , 1);	1154	stash_cf_map_wrap = gv_stashpv ("cf::map::wrap" , 1);
…		…
1217	stash_cf_arch_wrap = gv_stashpv ("cf::arch::wrap" , 1);	1156	stash_cf_arch_wrap = gv_stashpv ("cf::arch::wrap" , 1);
1218	stash_cf_party_wrap = gv_stashpv ("cf::party::wrap" , 1);	1157	stash_cf_party_wrap = gv_stashpv ("cf::party::wrap" , 1);
1219	stash_cf_region_wrap = gv_stashpv ("cf::region::wrap", 1);	1158	stash_cf_region_wrap = gv_stashpv ("cf::region::wrap", 1);
1220	stash_cf_living_wrap = gv_stashpv ("cf::living::wrap", 1);	1159	stash_cf_living_wrap = gv_stashpv ("cf::living::wrap", 1);
1221		1160
		1161	sv_now = get_sv ("cf::NOW" , 1); SvUPGRADE (sv_now , SVt_NV);
1222	sv_runtime = get_sv ("cf::RUNTIME" , 1); sv_upgrade (sv_runtime , SVt_NV);	1162	sv_runtime = get_sv ("cf::RUNTIME" , 1); SvUPGRADE (sv_runtime , SVt_NV);
		1163	sv_tick_start = get_sv ("cf::TICK_START", 1); SvUPGRADE (sv_tick_start, SVt_NV);
1223	sv_next_tick = get_sv ("cf::NEXT_TICK", 1); sv_upgrade (sv_next_tick, SVt_NV);	1164	sv_next_tick = get_sv ("cf::NEXT_TICK" , 1); SvUPGRADE (sv_next_tick , SVt_NV);
1224		1165
1225	cb_global = get_av ("cf::CB_GLOBAL", 1);	1166	cb_global = get_av ("cf::CB_GLOBAL", 1);
1226	cb_attachable = get_av ("cf::CB_ATTACHABLE", 1);	1167	cb_attachable = get_av ("cf::CB_ATTACHABLE", 1);
1227	cb_object = get_av ("cf::CB_OBJECT", 1);	1168	cb_object = get_av ("cf::CB_OBJECT", 1);
1228	cb_player = get_av ("cf::CB_PLAYER", 1);	1169	cb_player = get_av ("cf::CB_PLAYER", 1);
…		…
1233		1174
1234	MODULE = cf PACKAGE = cf PREFIX = cf_	1175	MODULE = cf PACKAGE = cf PREFIX = cf_
1235		1176
1236	BOOT:	1177	BOOT:
1237	{	1178	{
1238	I_EVENT_API (PACKAGE); watcher_base::GEventAPI = GEventAPI;	1179	I_EV_API (PACKAGE); evapi::GEVAPI = GEVAPI;
1239	I_CORO_API (PACKAGE); coroapi::GCoroAPI = GCoroAPI;	1180	I_CORO_API (PACKAGE); coroapi::GCoroAPI = GCoroAPI;
1240		1181
1241	_connect_to_perl ();	1182	_connect_to_perl ();
1242		1183
1243	newCONSTSUB (stash_cf, "VERSION", newSVpv (VERSION, sizeof (VERSION) - 1));	1184	newCONSTSUB (stash_cf, "VERSION", newSVpv (VERSION, sizeof (VERSION) - 1));
1244		1185
…		…
1262	const_iv (Map0Cmd) const_iv (Map1Cmd) const_iv (Map1aCmd)	1203	const_iv (Map0Cmd) const_iv (Map1Cmd) const_iv (Map1aCmd)
1263		1204
1264	const_iv (MAP_CLIENT_X) const_iv (MAP_CLIENT_Y)	1205	const_iv (MAP_CLIENT_X) const_iv (MAP_CLIENT_Y)
1265		1206
1266	const_iv (MAX_TIME)	1207	const_iv (MAX_TIME)
		1208	const_iv (MAXSOCKBUF)
1267		1209
1268	const_iv (NUM_BODY_LOCATIONS)	1210	const_iv (NUM_BODY_LOCATIONS)
1269	const_iv (body_range) const_iv (body_shield) const_iv (body_combat)	1211	const_iv (body_range) const_iv (body_shield) const_iv (body_combat)
1270	const_iv (body_arm) const_iv (body_torso) const_iv (body_head)	1212	const_iv (body_arm) const_iv (body_torso) const_iv (body_head)
1271	const_iv (body_neck) const_iv (body_skill) const_iv (body_finger)	1213	const_iv (body_neck) const_iv (body_skill) const_iv (body_finger)
…		…
1416	const_iv (P_NO_CLERIC) const_iv (P_OUT_OF_MAP) const_iv (P_NEW_MAP) const_iv (P_UPTODATE)	1358	const_iv (P_NO_CLERIC) const_iv (P_OUT_OF_MAP) const_iv (P_NEW_MAP) const_iv (P_UPTODATE)
1417		1359
1418	const_iv (UP_OBJ_INSERT) const_iv (UP_OBJ_REMOVE) const_iv (UP_OBJ_CHANGE) const_iv (UP_OBJ_FACE)	1360	const_iv (UP_OBJ_INSERT) const_iv (UP_OBJ_REMOVE) const_iv (UP_OBJ_CHANGE) const_iv (UP_OBJ_FACE)
1419		1361
1420	const_iv (INS_NO_MERGE) const_iv (INS_ABOVE_FLOOR_ONLY) const_iv (INS_NO_WALK_ON)	1362	const_iv (INS_NO_MERGE) const_iv (INS_ABOVE_FLOOR_ONLY) const_iv (INS_NO_WALK_ON)
1421	const_iv (INS_ON_TOP) const_iv (INS_BELOW_ORIGINATOR) const_iv (INS_MAP_LOAD)	1363	const_iv (INS_ON_TOP) const_iv (INS_BELOW_ORIGINATOR)
1422		1364
1423	const_iv (WILL_APPLY_HANDLE) const_iv (WILL_APPLY_TREASURE) const_iv (WILL_APPLY_EARTHWALL)	1365	const_iv (WILL_APPLY_HANDLE) const_iv (WILL_APPLY_TREASURE) const_iv (WILL_APPLY_EARTHWALL)
1424	const_iv (WILL_APPLY_DOOR) const_iv (WILL_APPLY_FOOD)	1366	const_iv (WILL_APPLY_DOOR) const_iv (WILL_APPLY_FOOD)
1425		1367
1426	const_iv (SAVE_MODE) const_iv (SAVE_DIR_MODE)	1368	const_iv (SAVE_MODE) const_iv (SAVE_DIR_MODE)
…		…
1460	const_iv (ATNR_PARALYZE) const_iv (ATNR_TURN_UNDEAD) const_iv (ATNR_FEAR) const_iv (ATNR_CANCELLATION)	1402	const_iv (ATNR_PARALYZE) const_iv (ATNR_TURN_UNDEAD) const_iv (ATNR_FEAR) const_iv (ATNR_CANCELLATION)
1461	const_iv (ATNR_DEPLETE) const_iv (ATNR_DEATH) const_iv (ATNR_CHAOS) const_iv (ATNR_COUNTERSPELL)	1403	const_iv (ATNR_DEPLETE) const_iv (ATNR_DEATH) const_iv (ATNR_CHAOS) const_iv (ATNR_COUNTERSPELL)
1462	const_iv (ATNR_GODPOWER) const_iv (ATNR_HOLYWORD) const_iv (ATNR_BLIND) const_iv (ATNR_INTERNAL)	1404	const_iv (ATNR_GODPOWER) const_iv (ATNR_HOLYWORD) const_iv (ATNR_BLIND) const_iv (ATNR_INTERNAL)
1463	const_iv (ATNR_LIFE_STEALING) const_iv (ATNR_DISEASE)	1405	const_iv (ATNR_LIFE_STEALING) const_iv (ATNR_DISEASE)
1464		1406
1465	const_iv (MAP_IN_MEMORY) const_iv (MAP_SWAPPED) const_iv (MAP_LOADING) const_iv (MAP_SAVING)	1407	const_iv (MAP_ACTIVE) const_iv (MAP_SWAPPED) const_iv (MAP_LOADING) const_iv (MAP_SAVING)
		1408	const_iv (MAP_INACTIVE)
1466		1409
1467	const_iv (KLASS_ATTACHABLE) const_iv (KLASS_GLOBAL) const_iv (KLASS_OBJECT)	1410	const_iv (KLASS_ATTACHABLE) const_iv (KLASS_GLOBAL) const_iv (KLASS_OBJECT)
1468	const_iv (KLASS_CLIENT) const_iv (KLASS_PLAYER) const_iv (KLASS_MAP)	1411	const_iv (KLASS_CLIENT) const_iv (KLASS_PLAYER) const_iv (KLASS_MAP)
1469		1412
1470	const_iv (VERSION_CS) const_iv (VERSION_SC)	1413	const_iv (VERSION_CS) const_iv (VERSION_SC)
…		…
1575	}	1518	}
1576		1519
1577	SvCUR_set (data_sv, dst - SvPVX (data_sv));	1520	SvCUR_set (data_sv, dst - SvPVX (data_sv));
1578	}	1521	}
1579		1522
		1523	void evthread_start (int aiofd)
		1524
1580	void _post_tick ()	1525	void cede_to_tick ()
1581	CODE:	1526	CODE:
1582	coroapi::next_cede = SvNV (sv_next_tick) - TICK * (1. - 1. / CEDES_PER_TICK);	1527	coroapi::cede_to_tick ();
1583		1528
1584	NV till_cede ()	1529	NV till_tick ()
1585	CODE:	1530	CODE:
1586	RETVAL = coroapi::next_cede - now ();	1531	RETVAL = SvNVX (sv_next_tick) - now ();
1587	OUTPUT:	1532	OUTPUT:
1588	RETVAL	1533	RETVAL
1589		1534
1590	NV till_tick ()	1535	int tick_inhibit ()
1591	CODE:	1536	CODE:
1592	RETVAL = SvNV (sv_next_tick) - now ();	1537	RETVAL = tick_inhibit;
1593	OUTPUT:	1538	OUTPUT:
1594	RETVAL	1539	RETVAL
		1540
		1541	void tick_inhibit_inc ()
		1542	CODE:
		1543	++tick_inhibit;
		1544
		1545	void tick_inhibit_dec ()
		1546	CODE:
		1547	if (!--tick_inhibit)
		1548	if (tick_pending)
		1549	{
		1550	ev_async_send (EV_DEFAULT, &tick_watcher);
		1551	coroapi::cede ();
		1552	}
		1553
		1554	void server_tick ()
		1555	CODE:
		1556	{
		1557	NOW = ev_now (EV_DEFAULT);
		1558	SvNV_set (sv_now, NOW); SvNOK_only (sv_now);
		1559	SvNV_set (sv_tick_start, NOW); SvNOK_only (sv_tick_start);
		1560	runtime = SvNVX (sv_runtime);
		1561
		1562	server_tick ();
		1563
		1564	NOW = ev_time ();
		1565	SvNV_set (sv_now, NOW); SvNOK_only (sv_now);
		1566	runtime += TICK;
		1567	SvNV_set (sv_runtime, runtime); SvNOK_only (sv_runtime);
		1568	}
1595		1569
1596	NV floor (NV x)	1570	NV floor (NV x)
1597		1571
1598	NV ceil (NV x)	1572	NV ceil (NV x)
1599		1573
…		…
1619	CODE:	1593	CODE:
1620	RETVAL = lerp (value, min_in, max_in, min_out, max_out);	1594	RETVAL = lerp (value, min_in, max_in, min_out, max_out);
1621	OUTPUT:	1595	OUTPUT:
1622	RETVAL	1596	RETVAL
1623		1597
1624	void cede_to_tick ()	1598	void weaken (...)
1625	CODE:	1599	PROTOTYPE: @
1626	coroapi::cede_to_tick ();	1600	CODE:
1627		1601	while (items > 0)
1628	void server_tick ()	1602	sv_rvweaken (ST (--items));
1629	CODE:
1630	NOW = now ();
1631	runtime = SvNVx (sv_runtime);
1632	server_tick ();
1633		1603
1634	void	1604	void
1635	log_backtrace (utf8_string msg)	1605	log_backtrace (utf8_string msg)
1636		1606
1637	void	1607	void
…		…
1642	octet_string path_combine (octet_string base, octet_string path)	1612	octet_string path_combine (octet_string base, octet_string path)
1643	PROTOTYPE: $$	1613	PROTOTYPE: $$
1644		1614
1645	octet_string path_combine_and_normalize (octet_string base, octet_string path)	1615	octet_string path_combine_and_normalize (octet_string base, octet_string path)
1646	PROTOTYPE: $$	1616	PROTOTYPE: $$
		1617
		1618	void
		1619	mallinfo ()
		1620	PPCODE:
		1621	{
		1622	#if __GLIBC__
		1623	struct mallinfo mai = mallinfo ();
		1624	EXTEND (SP, 10*2);
		1625	PUSHs (sv_2mortal (newSVpv ("arena" , 0))); PUSHs (sv_2mortal (newSViv (mai.arena)));
		1626	PUSHs (sv_2mortal (newSVpv ("ordblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.ordblks)));
		1627	PUSHs (sv_2mortal (newSVpv ("smblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.smblks)));
		1628	PUSHs (sv_2mortal (newSVpv ("hblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.hblks)));
		1629	PUSHs (sv_2mortal (newSVpv ("hblkhd" , 0))); PUSHs (sv_2mortal (newSViv (mai.hblkhd)));
		1630	PUSHs (sv_2mortal (newSVpv ("usmblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.usmblks)));
		1631	PUSHs (sv_2mortal (newSVpv ("fsmblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.fsmblks)));
		1632	PUSHs (sv_2mortal (newSVpv ("uordblks", 0))); PUSHs (sv_2mortal (newSViv (mai.uordblks)));
		1633	PUSHs (sv_2mortal (newSVpv ("fordblks", 0))); PUSHs (sv_2mortal (newSViv (mai.fordblks)));
		1634	PUSHs (sv_2mortal (newSVpv ("keepcost", 0))); PUSHs (sv_2mortal (newSViv (mai.keepcost)));
		1635	#endif
		1636	EXTEND (SP, 2*2);
		1637	PUSHs (sv_2mortal (newSVpv ("slice_alloc", 0))); PUSHs (sv_2mortal (newSVuv (slice_alloc)));
		1638	PUSHs (sv_2mortal (newSVpv ("shstr_alloc", 0))); PUSHs (sv_2mortal (newSVuv (shstr_alloc)));
		1639	}
1647		1640
1648	void	1641	void
1649	sub_generation_inc ()	1642	sub_generation_inc ()
1650	CODE:	1643	CODE:
1651	PL_sub_generation++;	1644	PL_sub_generation++;
…		…
1676		1669
1677	void abort ()	1670	void abort ()
1678		1671
1679	void reset_signals ()	1672	void reset_signals ()
1680		1673
1681	void fork_abort (octet_string cause = "cf::fork_abort")	1674	void fork_abort (const_octet_string cause = "cf::fork_abort")
1682		1675
1683	void cleanup (octet_string cause, bool make_core = false)	1676	void cleanup (const_octet_string cause, bool make_core = false)
1684		1677
1685	void emergency_save ()	1678	void emergency_save ()
1686		1679
1687	void _exit (int status = EXIT_SUCCESS)	1680	void _exit (int status = EXIT_SUCCESS)
1688		1681
1689	UV sv_2watcher (SV *w)
1690	CODE:
1691	RETVAL = (UV)GEventAPI->sv_2watcher (w);
1692	OUTPUT:
1693	RETVAL
1694
1695	#if _POSIX_MEMLOCK	1682	#if _POSIX_MEMLOCK
1696		1683
1697	int mlockall (int flags = MCL_CURRENT \| MCL_FUTURE)	1684	int mlockall (int flags = MCL_CURRENT \| MCL_FUTURE)
		1685	INIT:
		1686	#ifdef __linux
		1687	mallopt (M_PERTURB, 0xaa); // bug-workaround for linux glibc+mlockall+calloc
		1688	#endif
1698		1689
1699	int munlockall ()	1690	int munlockall ()
1700		1691
1701	#endif	1692	#endif
1702		1693
…		…
1744	RETVAL = newSVpv (resist_plus[atnr], 0);	1735	RETVAL = newSVpv (resist_plus[atnr], 0);
1745	else	1736	else
1746	XSRETURN_UNDEF;	1737	XSRETURN_UNDEF;
1747	OUTPUT: RETVAL	1738	OUTPUT: RETVAL
1748		1739
		1740	UUID
		1741	uuid_cur ()
		1742	CODE:
		1743	RETVAL = UUID::cur;
		1744	OUTPUT:
		1745	RETVAL
		1746
		1747	UUID
		1748	uuid_gen ()
		1749	CODE:
		1750	RETVAL = UUID::gen ();
		1751	OUTPUT:
		1752	RETVAL
		1753
		1754	val64
		1755	uuid_seq (UUID uuid)
		1756	CODE:
		1757	RETVAL = uuid.seq;
		1758	OUTPUT:
		1759	RETVAL
		1760
		1761	UUID
		1762	uuid_str (val64 seq)
		1763	CODE:
		1764	RETVAL.seq = seq;
		1765	OUTPUT:
		1766	RETVAL
		1767
		1768	void
		1769	coin_names ()
		1770	PPCODE:
		1771	EXTEND (SP, NUM_COINS);
		1772	for (int i = 0; i < NUM_COINS; ++i)
		1773	PUSHs (sv_2mortal (newSVpv (coins [i], 0)));
		1774
		1775	void
		1776	coin_archetypes ()
		1777	PPCODE:
		1778	EXTEND (SP, NUM_COINS);
		1779	for (int i = 0; i < NUM_COINS; ++i)
		1780	PUSHs (sv_2mortal (to_sv (archetype::find (coins [i]))));
		1781
1749	bool	1782	bool
1750	load_resource_file (octet_string filename)	1783	load_resource_file (octet_string filename)
1751		1784
1752	MODULE = cf PACKAGE = cf::attachable	1785	MODULE = cf PACKAGE = cf::attachable
1753		1786
…		…
2117	CODE:	2150	CODE:
2118	{	2151	{
2119	STRLEN len;	2152	STRLEN len;
2120	char *buf = SvPVbyte (packet, len);	2153	char *buf = SvPVbyte (packet, len);
2121		2154
		2155	if (len > MAXSOCKBUF)
		2156	pl->failmsg ("[packet too long for client]");
2122	if (pl->ns)	2157	else if (pl->ns)
2123	pl->ns->send_packet (buf, len);	2158	pl->ns->send_packet (buf, len);
2124	}	2159	}
2125		2160
2126	int	2161	int
2127	listening (player *pl, int new_value = -1)	2162	listening (player *pl, int new_value = -1)
…		…
2579	CODE:	2614	CODE:
2580	{	2615	{
2581	STRLEN len;	2616	STRLEN len;
2582	char *buf = SvPVbyte (packet, len);	2617	char *buf = SvPVbyte (packet, len);
2583		2618
		2619	if (len > MAXSOCKBUF)
		2620	{
		2621	// ugly
		2622	if (THIS->pl)
		2623	THIS->pl->failmsg ("[packet too long for client]");
		2624	}
		2625	else
2584	THIS->send_packet (buf, len);	2626	THIS->send_packet (buf, len);
2585	}	2627	}
2586		2628
2587	faceidx	2629	faceidx
2588	client::need_face (utf8_string name, int pri = 0)	2630	client::need_face (utf8_string name, int pri = 0)
2589	CODE:	2631	CODE:
…		…
2688	}	2730	}
2689	}	2731	}
2690		2732
2691	int get_data_size (faceidx idx, int faceset = 0)	2733	int get_data_size (faceidx idx, int faceset = 0)
2692	CODE:	2734	CODE:
2693	facedata *d = face_data (idx, faceset); assert (d);	2735	facedata *d = face_data (idx, faceset);
		2736	if (!d) XSRETURN_UNDEF;
2694	RETVAL = d->data.size ();	2737	RETVAL = d->data.size ();
2695	OUTPUT:	2738	OUTPUT:
2696	RETVAL	2739	RETVAL
2697		2740
2698	SV *get_chksum (faceidx idx, int faceset = 0)	2741	SV *get_chksum (faceidx idx, int faceset = 0)
2699	CODE:	2742	CODE:
2700	facedata *d = face_data (idx, faceset); assert (d);	2743	facedata *d = face_data (idx, faceset);
		2744	if (!d) XSRETURN_UNDEF;
2701	RETVAL = newSVpvn ((char *)d->chksum, CHKSUM_SIZE);	2745	RETVAL = newSVpvn ((char *)d->chksum, CHKSUM_SIZE);
		2746	OUTPUT:
		2747	RETVAL
		2748
		2749	SV *get_data (faceidx idx, int faceset = 0)
		2750	CODE:
		2751	facedata *d = face_data (idx, faceset);
		2752	if (!d) XSRETURN_UNDEF;
		2753	RETVAL = newSVpvn (d->data.data (), d->data.length ());
2702	OUTPUT:	2754	OUTPUT:
2703	RETVAL	2755	RETVAL
2704		2756
2705	void invalidate (faceidx idx)	2757	void invalidate (faceidx idx)
2706	CODE:	2758	CODE:
…		…
2798	extract_tags (object_thawer *self)	2850	extract_tags (object_thawer *self)
2799	PPCODE:	2851	PPCODE:
2800	while (self->kw != KW_EOF)	2852	while (self->kw != KW_EOF)
2801	{	2853	{
2802	PUTBACK;	2854	PUTBACK;
2803	coroapi::cede_to_tick_every (5000);	2855	coroapi::cede_to_tick ();
2804	SPAGAIN;	2856	SPAGAIN;
2805		2857
2806	if (self->kw == KW_tag)	2858	if (self->kw == KW_tag)
2807	XPUSHs (sv_2mortal (newSVpv_utf8 (self->get_str ())));	2859	XPUSHs (sv_2mortal (newSVpv_utf8 (self->get_str ())));
2808		2860

Diff Legend

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

Comparing deliantra/server/server/cfperl.xs (file contents): Revision 1.257 by root, Sun Sep 30 16:24:31 2007 UTC vs. Revision 1.277 by root, Sat Apr 19 21:10:29 2008 UTC

Diff Legend

Comparing deliantra/server/server/cfperl.xs (file contents):
Revision 1.257 by root, Sun Sep 30 16:24:31 2007 UTC vs.
Revision 1.277 by root, Sat Apr 19 21:10:29 2008 UTC