[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.280 by root, Mon Apr 21 06:35:26 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
		50	#if !__GLIBC__
		51	# define malloc_trim(pad) -1
		52	#endif
		53
47	#include <EXTERN.h>	54	#include <EXTERN.h>
48	#include <perl.h>	55	#include <perl.h>
49	#include <XSUB.h>	56	#include <XSUB.h>
50		57
51	#include "CoroAPI.h"	58	#include "CoroAPI.h"
…		…
56	typedef object_thawer &object_thawer_ref;	63	typedef object_thawer &object_thawer_ref;
57	typedef object_freezer &object_freezer_ref;	64	typedef object_freezer &object_freezer_ref;
58		65
59	typedef std::string std__string;	66	typedef std::string std__string;
60		67
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;	68	static PerlInterpreter *perl;
72		69
73	tstamp NOW, runtime;	70	tstamp NOW, runtime;
		71
		72	static int tick_inhibit;
		73	static int tick_pending;
74		74
75	global gbl_ev;	75	global gbl_ev;
76	static AV cb_global, cb_attachable, cb_object, cb_player, cb_client, cb_type, *cb_map;	76	static AV cb_global, cb_attachable, cb_object, cb_player, cb_client, cb_type, *cb_map;
77	static SV sv_runtime, sv_next_tick;	77	static SV sv_runtime, sv_tick_start, sv_next_tick, sv_now;
78		78
79	bitset<NUM_EVENT_TYPES> ev_want_event;	79	bitset<NUM_EVENT_TYPES> ev_want_event;
80	bitset<NUM_TYPES> ev_want_type;	80	bitset<NUM_TYPES> ev_want_type;
81		81
82	static HV	82	static HV
…		…
438	inline SV *to_sv (living & v) { return to_sv (&v); }	438	inline SV *to_sv (living & v) { return to_sv (&v); }
439		439
440	inline SV *to_sv (const std::string & v) { return newSVpvn (v.data (), v.size ()); }	440	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); }	441	inline SV to_sv (const treasurelist v) { return to_sv (v->name); }
442		442
443	inline SV *to_sv (UUID v)	443	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		444
450	inline void sv_to (SV *sv, shstr &v) { v = SvOK (sv) ? SvPVutf8_nolen (sv) : 0; }	445	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; }	446	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); }	447	inline void sv_to (SV *sv, bool &v) { v = SvIV (sv); }
453	inline void sv_to (SV *sv, signed char &v) { v = SvIV (sv); }	448	inline void sv_to (SV *sv, signed char &v) { v = SvIV (sv); }
…		…
495	v.assign (data, len);	490	v.assign (data, len);
496	}	491	}
497		492
498	inline void sv_to (SV *sv, UUID &v)	493	inline void sv_to (SV *sv, UUID &v)
499	{	494	{
500	unsigned int version;	495	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));	496	croak ("unparsable uuid: %s", SvPV_nolen (sv));
504	}	497	}
505		498
506	inline void sv_to (SV *sv, object::flags_t::reference v) { v = SvTRUE (sv); }	499	inline void sv_to (SV *sv, object::flags_t::reference v) { v = SvTRUE (sv); }
507		500
…		…
601	/////////////////////////////////////////////////////////////////////////////	594	/////////////////////////////////////////////////////////////////////////////
602		595
603	void	596	void
604	cfperl_init ()	597	cfperl_init ()
605	{	598	{
		599	extern char **environ;
		600
606	PERL_SYS_INIT3 (&settings.argc, &settings.argv, 0);	601	PERL_SYS_INIT3 (&settings.argc, &settings.argv, &environ);
607	perl = perl_alloc ();	602	perl = perl_alloc ();
608	perl_construct (perl);	603	perl_construct (perl);
609		604
610	PL_exit_flags \|= PERL_EXIT_DESTRUCT_END;	605	PL_exit_flags \|= PERL_EXIT_DESTRUCT_END;
611		606
612	const char *argv[] = {	607	const char *argv[] = {
613	settings.argv [0],	608	settings.argv [0],
614	"-e"	609	"-e"
615	"use Event; use Coro;" // required for bootstrap	610	"use EV; use Coro;" // required for bootstrap
616	"cf->bootstrap;" // required for datadir :*>	611	"cf->bootstrap;" // required for datadir :*>
617	"unshift @INC, cf::datadir ();"	612	"unshift @INC, cf::datadir ();"
618	"require cf;"	613	"require cf;"
619	};	614	};
620		615
621	if (perl_parse (perl, xs_init, 2, (char )argv, (char )NULL)	616	if (perl_parse (perl, xs_init, 2, (char **)argv, environ)
622	\|\| perl_run (perl))	617	\|\| perl_run (perl))
623	{	618	{
624	printf ("unable to initialize perl-interpreter, aborting.\n");	619	printf ("unable to initialize perl-interpreter, aborting.\n");
625	exit (EXIT_FAILURE);	620	exit (EXIT_FAILURE);
626	}	621	}
…		…
903	}	898	}
904		899
905	/////////////////////////////////////////////////////////////////////////////	900	/////////////////////////////////////////////////////////////////////////////
906	// various c++ => perl glue functions	901	// various c++ => perl glue functions
907		902
		903	void cfperl_tick ()
		904	{
		905	tick_pending = 1;
		906
		907	if (tick_inhibit)
		908	return;
		909
		910	tick_pending = 0;
		911
		912	dSP;
		913
		914	PUSHMARK (SP);
		915	PUTBACK;
		916	call_pv ("cf::tick", G_DISCARD \| G_VOID);
		917
		918	SvNV_set (sv_next_tick, get_next_tick ()); SvNOK_only (sv_next_tick);
		919	}
		920
908	void	921	void
909	cfperl_emergency_save ()	922	cfperl_emergency_save ()
910	{	923	{
911	CALL_BEGIN (0);	924	CALL_BEGIN (0);
912	CALL_CALL ("cf::emergency_save", G_VOID);	925	CALL_CALL ("cf::emergency_save", G_VOID);
…		…
1095	#endif	1108	#endif
1096	}	1109	}
1097		1110
1098	/////////////////////////////////////////////////////////////////////////////	1111	/////////////////////////////////////////////////////////////////////////////
1099		1112
1100	struct EventAPI *watcher_base::GEventAPI;	1113	struct EVAPI *evapi::GEVAPI;
1101	struct CoroAPI *coroapi::GCoroAPI;	1114	struct CoroAPI *coroapi::GCoroAPI;
1102
1103	int coroapi::cede_counter;
1104	tstamp coroapi::next_cede;
1105		1115
1106	void coroapi::do_cede_to_tick ()	1116	void coroapi::do_cede_to_tick ()
1107	{	1117	{
1108	cede_counter = 0;	1118	cede_pending = 0;
1109
1110	cede ();	1119	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	}	1120	}
1131		1121
1132	void	1122	void
1133	coroapi::wait_for_tick ()	1123	coroapi::wait_for_tick ()
1134	{	1124	{
…		…
1143	CALL_BEGIN (0);	1133	CALL_BEGIN (0);
1144	CALL_CALL ("cf::wait_for_tick_begin", G_DISCARD);	1134	CALL_CALL ("cf::wait_for_tick_begin", G_DISCARD);
1145	CALL_END;	1135	CALL_END;
1146	}	1136	}
1147		1137
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	1138	void
1197	iow::poll (int events)	1139	iow::poll (int events)
1198	{	1140	{
1199	if (pe->poll != events)	1141	if (events != this->events)
1200	{	1142	{
		1143	int active = ev_is_active ((ev_io *)this);
1201	if (pe->poll) stop ();	1144	if (active) stop ();
1202	pe->poll = events;	1145	ev_io_set ((ev_io *)this, fd, events);
1203	if (pe->poll) start ();	1146	if (active) start ();
1204	}	1147	}
1205	}	1148	}
1206		1149
1207	void	1150	void
1208	_connect_to_perl ()	1151	_connect_to_perl ()
1209	{	1152	{
1210	stash_cf = gv_stashpv ("cf" , 1);	1153	stash_cf = gv_stashpv ("cf", 1);
1211		1154
1212	stash_cf_object_wrap = gv_stashpv ("cf::object::wrap", 1);	1155	stash_cf_object_wrap = gv_stashpv ("cf::object::wrap", 1);
1213	stash_cf_object_player_wrap = gv_stashpv ("cf::object::player::wrap", 1);	1156	stash_cf_object_player_wrap = gv_stashpv ("cf::object::player::wrap", 1);
1214	stash_cf_player_wrap = gv_stashpv ("cf::player::wrap", 1);	1157	stash_cf_player_wrap = gv_stashpv ("cf::player::wrap", 1);
1215	stash_cf_map_wrap = gv_stashpv ("cf::map::wrap" , 1);	1158	stash_cf_map_wrap = gv_stashpv ("cf::map::wrap" , 1);
…		…
1217	stash_cf_arch_wrap = gv_stashpv ("cf::arch::wrap" , 1);	1160	stash_cf_arch_wrap = gv_stashpv ("cf::arch::wrap" , 1);
1218	stash_cf_party_wrap = gv_stashpv ("cf::party::wrap" , 1);	1161	stash_cf_party_wrap = gv_stashpv ("cf::party::wrap" , 1);
1219	stash_cf_region_wrap = gv_stashpv ("cf::region::wrap", 1);	1162	stash_cf_region_wrap = gv_stashpv ("cf::region::wrap", 1);
1220	stash_cf_living_wrap = gv_stashpv ("cf::living::wrap", 1);	1163	stash_cf_living_wrap = gv_stashpv ("cf::living::wrap", 1);
1221		1164
		1165	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);	1166	sv_runtime = get_sv ("cf::RUNTIME" , 1); SvUPGRADE (sv_runtime , SVt_NV);
		1167	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);	1168	sv_next_tick = get_sv ("cf::NEXT_TICK" , 1); SvUPGRADE (sv_next_tick , SVt_NV);
1224		1169
1225	cb_global = get_av ("cf::CB_GLOBAL", 1);	1170	cb_global = get_av ("cf::CB_GLOBAL", 1);
1226	cb_attachable = get_av ("cf::CB_ATTACHABLE", 1);	1171	cb_attachable = get_av ("cf::CB_ATTACHABLE", 1);
1227	cb_object = get_av ("cf::CB_OBJECT", 1);	1172	cb_object = get_av ("cf::CB_OBJECT", 1);
1228	cb_player = get_av ("cf::CB_PLAYER", 1);	1173	cb_player = get_av ("cf::CB_PLAYER", 1);
…		…
1233		1178
1234	MODULE = cf PACKAGE = cf PREFIX = cf_	1179	MODULE = cf PACKAGE = cf PREFIX = cf_
1235		1180
1236	BOOT:	1181	BOOT:
1237	{	1182	{
1238	I_EVENT_API (PACKAGE); watcher_base::GEventAPI = GEventAPI;	1183	I_EV_API (PACKAGE); evapi::GEVAPI = GEVAPI;
1239	I_CORO_API (PACKAGE); coroapi::GCoroAPI = GCoroAPI;	1184	I_CORO_API (PACKAGE); coroapi::GCoroAPI = GCoroAPI;
1240		1185
1241	_connect_to_perl ();	1186	_connect_to_perl ();
1242		1187
1243	newCONSTSUB (stash_cf, "VERSION", newSVpv (VERSION, sizeof (VERSION) - 1));	1188	newCONSTSUB (stash_cf, "VERSION", newSVpv (VERSION, sizeof (VERSION) - 1));
1244		1189
…		…
1262	const_iv (Map0Cmd) const_iv (Map1Cmd) const_iv (Map1aCmd)	1207	const_iv (Map0Cmd) const_iv (Map1Cmd) const_iv (Map1aCmd)
1263		1208
1264	const_iv (MAP_CLIENT_X) const_iv (MAP_CLIENT_Y)	1209	const_iv (MAP_CLIENT_X) const_iv (MAP_CLIENT_Y)
1265		1210
1266	const_iv (MAX_TIME)	1211	const_iv (MAX_TIME)
		1212	const_iv (MAXSOCKBUF)
1267		1213
1268	const_iv (NUM_BODY_LOCATIONS)	1214	const_iv (NUM_BODY_LOCATIONS)
1269	const_iv (body_range) const_iv (body_shield) const_iv (body_combat)	1215	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)	1216	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)	1217	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)	1362	const_iv (P_NO_CLERIC) const_iv (P_OUT_OF_MAP) const_iv (P_NEW_MAP) const_iv (P_UPTODATE)
1417		1363
1418	const_iv (UP_OBJ_INSERT) const_iv (UP_OBJ_REMOVE) const_iv (UP_OBJ_CHANGE) const_iv (UP_OBJ_FACE)	1364	const_iv (UP_OBJ_INSERT) const_iv (UP_OBJ_REMOVE) const_iv (UP_OBJ_CHANGE) const_iv (UP_OBJ_FACE)
1419		1365
1420	const_iv (INS_NO_MERGE) const_iv (INS_ABOVE_FLOOR_ONLY) const_iv (INS_NO_WALK_ON)	1366	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)	1367	const_iv (INS_ON_TOP) const_iv (INS_BELOW_ORIGINATOR)
1422		1368
1423	const_iv (WILL_APPLY_HANDLE) const_iv (WILL_APPLY_TREASURE) const_iv (WILL_APPLY_EARTHWALL)	1369	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)	1370	const_iv (WILL_APPLY_DOOR) const_iv (WILL_APPLY_FOOD)
1425		1371
1426	const_iv (SAVE_MODE) const_iv (SAVE_DIR_MODE)	1372	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)	1406	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)	1407	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)	1408	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)	1409	const_iv (ATNR_LIFE_STEALING) const_iv (ATNR_DISEASE)
1464		1410
1465	const_iv (MAP_IN_MEMORY) const_iv (MAP_SWAPPED) const_iv (MAP_LOADING) const_iv (MAP_SAVING)	1411	const_iv (MAP_ACTIVE) const_iv (MAP_SWAPPED) const_iv (MAP_LOADING) const_iv (MAP_SAVING)
		1412	const_iv (MAP_INACTIVE)
1466		1413
1467	const_iv (KLASS_ATTACHABLE) const_iv (KLASS_GLOBAL) const_iv (KLASS_OBJECT)	1414	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)	1415	const_iv (KLASS_CLIENT) const_iv (KLASS_PLAYER) const_iv (KLASS_MAP)
1469		1416
1470	const_iv (VERSION_CS) const_iv (VERSION_SC)	1417	const_iv (VERSION_CS) const_iv (VERSION_SC)
…		…
1575	}	1522	}
1576		1523
1577	SvCUR_set (data_sv, dst - SvPVX (data_sv));	1524	SvCUR_set (data_sv, dst - SvPVX (data_sv));
1578	}	1525	}
1579		1526
		1527	void evthread_start (int aiofd)
		1528
1580	void _post_tick ()	1529	void cede_to_tick ()
1581	CODE:	1530	CODE:
1582	coroapi::next_cede = SvNV (sv_next_tick) - TICK * (1. - 1. / CEDES_PER_TICK);	1531	coroapi::cede_to_tick ();
1583		1532
1584	NV till_cede ()	1533	NV till_tick ()
1585	CODE:	1534	CODE:
1586	RETVAL = coroapi::next_cede - now ();	1535	RETVAL = SvNVX (sv_next_tick) - now ();
1587	OUTPUT:	1536	OUTPUT:
1588	RETVAL	1537	RETVAL
1589		1538
1590	NV till_tick ()	1539	int tick_inhibit ()
1591	CODE:	1540	CODE:
1592	RETVAL = SvNV (sv_next_tick) - now ();	1541	RETVAL = tick_inhibit;
1593	OUTPUT:	1542	OUTPUT:
1594	RETVAL	1543	RETVAL
		1544
		1545	void tick_inhibit_inc ()
		1546	CODE:
		1547	++tick_inhibit;
		1548
		1549	void tick_inhibit_dec ()
		1550	CODE:
		1551	if (!--tick_inhibit)
		1552	if (tick_pending)
		1553	{
		1554	ev_async_send (EV_DEFAULT, &tick_watcher);
		1555	coroapi::cede ();
		1556	}
		1557
		1558	void server_tick ()
		1559	CODE:
		1560	{
		1561	NOW = ev_now (EV_DEFAULT);
		1562	SvNV_set (sv_now, NOW); SvNOK_only (sv_now);
		1563	SvNV_set (sv_tick_start, NOW); SvNOK_only (sv_tick_start);
		1564	runtime = SvNVX (sv_runtime);
		1565
		1566	server_tick ();
		1567
		1568	NOW = ev_time ();
		1569	SvNV_set (sv_now, NOW); SvNOK_only (sv_now);
		1570	runtime += TICK;
		1571	SvNV_set (sv_runtime, runtime); SvNOK_only (sv_runtime);
		1572	}
1595		1573
1596	NV floor (NV x)	1574	NV floor (NV x)
1597		1575
1598	NV ceil (NV x)	1576	NV ceil (NV x)
1599		1577
…		…
1619	CODE:	1597	CODE:
1620	RETVAL = lerp (value, min_in, max_in, min_out, max_out);	1598	RETVAL = lerp (value, min_in, max_in, min_out, max_out);
1621	OUTPUT:	1599	OUTPUT:
1622	RETVAL	1600	RETVAL
1623		1601
1624	void cede_to_tick ()	1602	void weaken (...)
1625	CODE:	1603	PROTOTYPE: @
1626	coroapi::cede_to_tick ();	1604	CODE:
1627		1605	while (items > 0)
1628	void server_tick ()	1606	sv_rvweaken (ST (--items));
1629	CODE:
1630	NOW = now ();
1631	runtime = SvNVx (sv_runtime);
1632	server_tick ();
1633		1607
1634	void	1608	void
1635	log_backtrace (utf8_string msg)	1609	log_backtrace (utf8_string msg)
1636		1610
1637	void	1611	void
…		…
1676		1650
1677	void abort ()	1651	void abort ()
1678		1652
1679	void reset_signals ()	1653	void reset_signals ()
1680		1654
1681	void fork_abort (octet_string cause = "cf::fork_abort")	1655	void fork_abort (const_octet_string cause = "cf::fork_abort")
1682		1656
1683	void cleanup (octet_string cause, bool make_core = false)	1657	void cleanup (const_octet_string cause, bool make_core = false)
1684		1658
1685	void emergency_save ()	1659	void emergency_save ()
1686		1660
1687	void _exit (int status = EXIT_SUCCESS)	1661	void _exit (int status = EXIT_SUCCESS)
1688		1662
1689	UV sv_2watcher (SV *w)
1690	CODE:
1691	RETVAL = (UV)GEventAPI->sv_2watcher (w);
1692	OUTPUT:
1693	RETVAL
1694
1695	#if _POSIX_MEMLOCK	1663	#if _POSIX_MEMLOCK
1696		1664
1697	int mlockall (int flags = MCL_CURRENT \| MCL_FUTURE)	1665	int mlockall (int flags = MCL_CURRENT \| MCL_FUTURE)
		1666	INIT:
		1667	#if __GLIBC__
		1668	mallopt (M_PERTURB, 0xee); // bug-workaround for linux glibc+mlockall+calloc
		1669	#endif
1698		1670
1699	int munlockall ()	1671	int munlockall ()
1700		1672
1701	#endif	1673	#endif
		1674
		1675	int
		1676	malloc_trim (IV pad = 0)
		1677
		1678	void
		1679	mallinfo ()
		1680	PPCODE:
		1681	{
		1682	#if __GLIBC__
		1683	struct mallinfo mai = mallinfo ();
		1684	EXTEND (SP, 10*2);
		1685	PUSHs (sv_2mortal (newSVpv ("arena" , 0))); PUSHs (sv_2mortal (newSViv (mai.arena)));
		1686	PUSHs (sv_2mortal (newSVpv ("ordblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.ordblks)));
		1687	PUSHs (sv_2mortal (newSVpv ("smblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.smblks)));
		1688	PUSHs (sv_2mortal (newSVpv ("hblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.hblks)));
		1689	PUSHs (sv_2mortal (newSVpv ("hblkhd" , 0))); PUSHs (sv_2mortal (newSViv (mai.hblkhd)));
		1690	PUSHs (sv_2mortal (newSVpv ("usmblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.usmblks)));
		1691	PUSHs (sv_2mortal (newSVpv ("fsmblks" , 0))); PUSHs (sv_2mortal (newSViv (mai.fsmblks)));
		1692	PUSHs (sv_2mortal (newSVpv ("uordblks", 0))); PUSHs (sv_2mortal (newSViv (mai.uordblks)));
		1693	PUSHs (sv_2mortal (newSVpv ("fordblks", 0))); PUSHs (sv_2mortal (newSViv (mai.fordblks)));
		1694	PUSHs (sv_2mortal (newSVpv ("keepcost", 0))); PUSHs (sv_2mortal (newSViv (mai.keepcost)));
		1695	#endif
		1696	EXTEND (SP, 2*2);
		1697	PUSHs (sv_2mortal (newSVpv ("slice_alloc", 0))); PUSHs (sv_2mortal (newSVuv (slice_alloc)));
		1698	PUSHs (sv_2mortal (newSVpv ("shstr_alloc", 0))); PUSHs (sv_2mortal (newSVuv (shstr_alloc)));
		1699	}
1702		1700
1703	int find_animation (utf8_string text)	1701	int find_animation (utf8_string text)
1704	PROTOTYPE: $	1702	PROTOTYPE: $
1705		1703
1706	int random_roll (int min, int max, object *op, int goodbad);	1704	int random_roll (int min, int max, object *op, int goodbad);
…		…
1744	RETVAL = newSVpv (resist_plus[atnr], 0);	1742	RETVAL = newSVpv (resist_plus[atnr], 0);
1745	else	1743	else
1746	XSRETURN_UNDEF;	1744	XSRETURN_UNDEF;
1747	OUTPUT: RETVAL	1745	OUTPUT: RETVAL
1748		1746
		1747	UUID
		1748	uuid_cur ()
		1749	CODE:
		1750	RETVAL = UUID::cur;
		1751	OUTPUT:
		1752	RETVAL
		1753
		1754	UUID
		1755	uuid_gen ()
		1756	CODE:
		1757	RETVAL = UUID::gen ();
		1758	OUTPUT:
		1759	RETVAL
		1760
		1761	val64
		1762	uuid_seq (UUID uuid)
		1763	CODE:
		1764	RETVAL = uuid.seq;
		1765	OUTPUT:
		1766	RETVAL
		1767
		1768	UUID
		1769	uuid_str (val64 seq)
		1770	CODE:
		1771	RETVAL.seq = seq;
		1772	OUTPUT:
		1773	RETVAL
		1774
		1775	void
		1776	coin_names ()
		1777	PPCODE:
		1778	EXTEND (SP, NUM_COINS);
		1779	for (int i = 0; i < NUM_COINS; ++i)
		1780	PUSHs (sv_2mortal (newSVpv (coins [i], 0)));
		1781
		1782	void
		1783	coin_archetypes ()
		1784	PPCODE:
		1785	EXTEND (SP, NUM_COINS);
		1786	for (int i = 0; i < NUM_COINS; ++i)
		1787	PUSHs (sv_2mortal (to_sv (archetype::find (coins [i]))));
		1788
1749	bool	1789	bool
1750	load_resource_file (octet_string filename)	1790	load_resource_file_ (octet_string filename)
1751		1791
1752	MODULE = cf PACKAGE = cf::attachable	1792	MODULE = cf PACKAGE = cf::attachable
1753		1793
1754	int	1794	int
1755	valid (SV *obj)	1795	valid (SV *obj)
…		…
2039	base_name (object *op, int plural = op->nrof > 1)	2079	base_name (object *op, int plural = op->nrof > 1)
2040	CODE:	2080	CODE:
2041	RETVAL = query_base_name (op, plural);	2081	RETVAL = query_base_name (op, plural);
2042	OUTPUT: RETVAL	2082	OUTPUT: RETVAL
2043		2083
2044	object decrease_ob_nr (object op, unsigned long i)
2045
2046	# return the tail of an object, excluding itself	2084	# return the tail of an object, excluding itself
2047	void	2085	void
2048	tail (object *op)	2086	tail (object *op)
2049	PPCODE:	2087	PPCODE:
2050	while ((op = op->more))	2088	while ((op = op->more))
…		…
2117	CODE:	2155	CODE:
2118	{	2156	{
2119	STRLEN len;	2157	STRLEN len;
2120	char *buf = SvPVbyte (packet, len);	2158	char *buf = SvPVbyte (packet, len);
2121		2159
		2160	if (len > MAXSOCKBUF)
		2161	pl->failmsg ("[packet too long for client]");
2122	if (pl->ns)	2162	else if (pl->ns)
2123	pl->ns->send_packet (buf, len);	2163	pl->ns->send_packet (buf, len);
2124	}	2164	}
2125		2165
2126	int	2166	int
2127	listening (player *pl, int new_value = -1)	2167	listening (player *pl, int new_value = -1)
…		…
2579	CODE:	2619	CODE:
2580	{	2620	{
2581	STRLEN len;	2621	STRLEN len;
2582	char *buf = SvPVbyte (packet, len);	2622	char *buf = SvPVbyte (packet, len);
2583		2623
		2624	if (len > MAXSOCKBUF)
		2625	{
		2626	// ugly
		2627	if (THIS->pl)
		2628	THIS->pl->failmsg ("[packet too long for client]");
		2629	}
		2630	else
2584	THIS->send_packet (buf, len);	2631	THIS->send_packet (buf, len);
2585	}	2632	}
2586		2633
2587	faceidx	2634	faceidx
2588	client::need_face (utf8_string name, int pri = 0)	2635	client::need_face (utf8_string name, int pri = 0)
2589	CODE:	2636	CODE:
…		…
2688	}	2735	}
2689	}	2736	}
2690		2737
2691	int get_data_size (faceidx idx, int faceset = 0)	2738	int get_data_size (faceidx idx, int faceset = 0)
2692	CODE:	2739	CODE:
2693	facedata *d = face_data (idx, faceset); assert (d);	2740	facedata *d = face_data (idx, faceset);
		2741	if (!d) XSRETURN_UNDEF;
2694	RETVAL = d->data.size ();	2742	RETVAL = d->data.size ();
2695	OUTPUT:	2743	OUTPUT:
2696	RETVAL	2744	RETVAL
2697		2745
2698	SV *get_chksum (faceidx idx, int faceset = 0)	2746	SV *get_chksum (faceidx idx, int faceset = 0)
2699	CODE:	2747	CODE:
2700	facedata *d = face_data (idx, faceset); assert (d);	2748	facedata *d = face_data (idx, faceset);
		2749	if (!d) XSRETURN_UNDEF;
2701	RETVAL = newSVpvn ((char *)d->chksum, CHKSUM_SIZE);	2750	RETVAL = newSVpvn ((char *)d->chksum, CHKSUM_SIZE);
		2751	OUTPUT:
		2752	RETVAL
		2753
		2754	SV *get_data (faceidx idx, int faceset = 0)
		2755	CODE:
		2756	facedata *d = face_data (idx, faceset);
		2757	if (!d) XSRETURN_UNDEF;
		2758	RETVAL = newSVpvn (d->data.data (), d->data.length ());
2702	OUTPUT:	2759	OUTPUT:
2703	RETVAL	2760	RETVAL
2704		2761
2705	void invalidate (faceidx idx)	2762	void invalidate (faceidx idx)
2706	CODE:	2763	CODE:
…		…
2798	extract_tags (object_thawer *self)	2855	extract_tags (object_thawer *self)
2799	PPCODE:	2856	PPCODE:
2800	while (self->kw != KW_EOF)	2857	while (self->kw != KW_EOF)
2801	{	2858	{
2802	PUTBACK;	2859	PUTBACK;
2803	coroapi::cede_to_tick_every (5000);	2860	coroapi::cede_to_tick ();
2804	SPAGAIN;	2861	SPAGAIN;
2805		2862
2806	if (self->kw == KW_tag)	2863	if (self->kw == KW_tag)
2807	XPUSHs (sv_2mortal (newSVpv_utf8 (self->get_str ())));	2864	XPUSHs (sv_2mortal (newSVpv_utf8 (self->get_str ())));
2808		2865

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.280 by root, Mon Apr 21 06:35:26 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.280 by root, Mon Apr 21 06:35:26 2008 UTC