[ViewVC] Diff of: cvs/deliantra/server/server/main.C

Comparing deliantra/server/server/main.C (file contents):
Revision 1.64 by root, Sat Dec 30 18:45:29 2006 UTC vs.
Revision 1.179 by root, Sat Nov 17 23:33:18 2018 UTC

…		…
1	/*	1	/*
2	CrossFire, A Multiplayer game for X-windows	2	* This file is part of Deliantra, the Roguelike Realtime MMORPG.
3		3	*
		4	* Copyright (©) 2005,2006,2007,2008,2009,2010,2011,2012,2013,2014,2015,2016 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
4	Copyright (C) 2001-2003 Mark Wedel & Crossfire Development Team	5	* Copyright (©) 2001-2003 Mark Wedel & Crossfire Development Team
5	Copyright (C) 1992 Frank Tore Johansen	6	* Copyright (©) 1992 Frank Tore Johansen
6		7	*
7	This program is free software; you can redistribute it and/or modify	8	* Deliantra is free software: you can redistribute it and/or modify it under
8	it under the terms of the GNU General Public License as published by	9	* the terms of the Affero GNU General Public License as published by the
9	the Free Software Foundation; either version 2 of the License, or	10	* Free Software Foundation, either version 3 of the License, or (at your
10	(at your option) any later version.	11	* option) any later version.
11		12	*
12	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,
13	but WITHOUT ANY WARRANTY; without even the implied warranty of	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
14	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15	GNU General Public License for more details.	16	* GNU General Public License for more details.
16		17	*
17	You should have received a copy of the GNU General Public License	18	* You should have received a copy of the Affero GNU General Public License
18	along with this program; if not, write to the Free Software	19	* and the GNU General Public License along with this program. If not, see
19	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.	20	* <http://www.gnu.org/licenses/>.
20		21	*
21	The authors can be reached via e-mail at <crossfire@schmorp.de>	22	* The authors can be reached via e-mail to <support@deliantra.net>
22	*/	23	*/
23		24
24	#include <global.h>	25	#include <global.h>
25	#include <object.h>	26	#include <object.h>
26	#include <tod.h>	27	#include <tod.h>
27		28
28	#ifdef HAVE_DES_H
29	# include <des.h>
30	#else
31	# ifdef HAVE_CRYPT_H
32	# include <crypt.h>
33	# endif
34	#endif
35
36	#include <sproto.h>	29	#include <sproto.h>
37	#include <time.h>	30	#include <time.h>
38		31
39	#include <../random_maps/random_map.h>	32	#include <glib.h>
40	#include <../random_maps/rproto.h>	33
		34	#include <rmg.h>
		35	#include <rproto.h>
41	#include "path.h"	36	#include "path.h"
42
43	static char days[7][4] = {
44	"Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"
45	};
46		37
47	void	38	void
48	version (object *op)	39	version (object *op)
49	{	40	{
50	if (op != NULL)
51	clear_win_info (op);
52
53	new_draw_info_format (NDI_UNIQUE, 0, op, "This is Crossfire v%s", VERSION);	41	new_draw_info_format (NDI_UNIQUE, 0, op, "This is Deliantra v%s", VERSION);
54
55	/* If in a socket, don't print out the list of authors. It confuses the
56	* crossclient program.
57	*/
58	if (op == NULL)
59	return;
60
61	new_draw_info (NDI_UNIQUE, 0, op, "Authors and contributors to this program:");
62	new_draw_info (NDI_UNIQUE, 0, op, "Marc A. Lehmann <pcg@goof.com>");
63	new_draw_info (NDI_UNIQUE, 0, op, "Robin Redeker <elmex@x-paste.de>");
64	new_draw_info (NDI_UNIQUE, 0, op, "Pippijn van Steenhoven <pip88nl@gmail.com>");
65	new_draw_info (NDI_UNIQUE, 0, op, "Mark Wedel <mwedel@sonic.net>");
66	new_draw_info (NDI_UNIQUE, 0, op, "Frank Tore Johansen <frankj@ifi.uio.no>");
67	new_draw_info (NDI_UNIQUE, 0, op, "Kjetil Torgrim Homme <kjetilho@ifi.uio.no>");
68	new_draw_info (NDI_UNIQUE, 0, op, "Tyler Van Gorder <tvangod@ecst.csuchico.edu>");
69	new_draw_info (NDI_UNIQUE, 0, op, "Tony Elmroth <elmroth@cd.chalmers.se>");
70	new_draw_info (NDI_UNIQUE, 0, op, "Dougal Scott <dougal.scott@fcit.monasu.edu.au>");
71	new_draw_info (NDI_UNIQUE, 0, op, "William <wchuang@athena.mit.edu>");
72	new_draw_info (NDI_UNIQUE, 0, op, "Geoff Bailey <ftww@cs.su.oz.au>");
73	new_draw_info (NDI_UNIQUE, 0, op, "Kjetil Wiekhorst Jxrgensen <jorgens@flipper.pvv.unit.no>");
74	new_draw_info (NDI_UNIQUE, 0, op, "Cameron Blackwood <c.blackwood@rdt.monash.edu.au>");
75	new_draw_info (NDI_UNIQUE, 0, op, "Joseph L. Traub <jtraub+@cmu.edu>");
76	new_draw_info (NDI_UNIQUE, 0, op, "Rupert G. Goldie <rgg@aaii.oz.au>");
77	new_draw_info (NDI_UNIQUE, 0, op, "Eric A. Anderson <eanders+@cmu.edu>");
78	new_draw_info (NDI_UNIQUE, 0, op, "Rickard Eneqvist <eneq@Prag.DoCS.UU.SE>");
79	new_draw_info (NDI_UNIQUE, 0, op, "Jarkko Sonninen <Jarkko.Sonninen@lut.fi>");
80	new_draw_info (NDI_UNIQUE, 0, op, "Karl Holland <kholland@sunlab.cit.cornell.du>");
81	new_draw_info (NDI_UNIQUE, 0, op, "Mikael Lundgren <vick@bern.docs.uu.se>");
82	new_draw_info (NDI_UNIQUE, 0, op, "Mikael Olsson <mol@meryl.csd.uu.se>");
83	new_draw_info (NDI_UNIQUE, 0, op, "Tero Haatanen <Tero.Haatanen@lut.fi>");
84	new_draw_info (NDI_UNIQUE, 0, op, "Lasse Ylitalo <ylitalo@student.docs.uu.se>");
85	new_draw_info (NDI_UNIQUE, 0, op, "Niilo Neuvo <anipa@guru.magic.fi>");
86	new_draw_info (NDI_UNIQUE, 0, op, "Markku J{rvinen <mta@modeemi.cs.tut.fi>");
87	new_draw_info (NDI_UNIQUE, 0, op, "Sylvain Meunier <meunier@inf.enst.fr>");
88	new_draw_info (NDI_UNIQUE, 0, op, "Jason Fosback <jfosback@darmok.uoregon.edu>");
89	new_draw_info (NDI_UNIQUE, 0, op, "Carl Edman <cedman@capitalist.princeton.edu>");
90	new_draw_info (NDI_UNIQUE, 0, op, "Charles Henrich <henrich@crh.cl.msu.edu>");
91	new_draw_info (NDI_UNIQUE, 0, op, "Gregor Schmid <schmid@fb3-s7.math.tu-berlin.de>");
92	new_draw_info (NDI_UNIQUE, 0, op, "Raphael Quinet <quinet@montefiore.ulg.ac.be>");
93	new_draw_info (NDI_UNIQUE, 0, op, "Jari Vanhala <jam@modeemi.cs.tut.fi>");
94	new_draw_info (NDI_UNIQUE, 0, op, "Tero Kivinen <kivinen@joker.cs.hut.fi>");
95	new_draw_info (NDI_UNIQUE, 0, op, "Peter Mardahl <peterm@soda.berkeley.edu>");
96	new_draw_info (NDI_UNIQUE, 0, op, "Matthew Zeher <matt@cs.odu.edu>");
97	new_draw_info (NDI_UNIQUE, 0, op, "Scott R. Turner <srt@sun-dimas.aero.org>");
98	new_draw_info (NDI_UNIQUE, 0, op, "Ben Fennema <huma@netcom.com>");
99	new_draw_info (NDI_UNIQUE, 0, op, "Nick Williams <njw@cs.city.ac.uk>");
100	new_draw_info (NDI_UNIQUE, 0, op, "Laurent Wacrenier <Wacren@Gin.ObsPM.Fr>");
101	new_draw_info (NDI_UNIQUE, 0, op, "Brian Thomas <thomas@astro.psu.edu>");
102	new_draw_info (NDI_UNIQUE, 0, op, "John Steven Moerk <jsm@axon.ksc.nasa.gov>");
103	new_draw_info (NDI_UNIQUE, 0, op, "Delbecq David <david.delbecq@mailandnews.com>");
104	new_draw_info (NDI_UNIQUE, 0, op, "Chachkoff Yann <yann.chachkoff@mailandnews.com>\n");
105
106	new_draw_info (NDI_UNIQUE, 0, op, "Images and art:");
107	new_draw_info (NDI_UNIQUE, 0, op, "Peter Gardner");
108	new_draw_info (NDI_UNIQUE, 0, op, "David Gervais <david_eg@mail.com>");
109	new_draw_info (NDI_UNIQUE, 0, op, "Mitsuhiro Itakura <ita@gold.koma.jaeri.go.jp>");
110	new_draw_info (NDI_UNIQUE, 0, op, "Hansjoerg Malthaner <hansjoerg.malthaner@danet.de>");
111	new_draw_info (NDI_UNIQUE, 0, op, "Mårten Woxberg <maxmc@telia.com>");
112	new_draw_info (NDI_UNIQUE, 0, op, "And many more!");
113	}	42	}
114		43
115	/* This is a basic little function to put the player back to his	44	/* This is a basic little function to put the player back to his
116	* savebed. We do some error checking - its possible that the	45	* savebed.
117	* savebed map may no longer exist, so we make sure the player
118	* goes someplace.
119	*/	46	*/
120	void	47	void
121	enter_player_savebed (object *op)	48	enter_player_savebed (object *op)
122	{	49	{
123	object *tmp = object::create ();	50	op->player_goto (op->contr->savebed_map, op->contr->bed_x, op->contr->bed_y);
124	EXIT_PATH (tmp) = op->contr->savebed_map;
125	EXIT_X (tmp) = op->contr->bed_x;
126	EXIT_Y (tmp) = op->contr->bed_y;
127	op->enter_exit (tmp);
128	tmp->destroy ();
129	}	51	}
130		52
131	/*	53	/*
132	* enter_map(): Moves the player and pets from current map (if any) to	54	* enter_map(): Moves the player and pets from current map (if any) to
133	* new map. map, x, y must be set. map is the map we are moving the	55	* new map. map, x, y must be set. map is the map we are moving the
134	* player to - it could be the map he just came from if the load failed for	56	* player to - it could be the map he just came from if the load failed for
135	* whatever reason. If default map coordinates are to be used, then	57	* whatever reason. If default map coordinates are to be used, then
136	* the function that calls this should figure them out.	58	* the function that calls this should figure them out.
137	*/	59	*/
138	void	60	bool
139	object::enter_map (maptile *newmap, int x, int y)	61	object::enter_map (maptile *newmap, int x, int y)
140	{	62	{
141	if (!newmap->load ())	63	if (destroyed () \|\| !newmap \|\| !newmap->linkable ())
142	return;	64	return false;
143		65
144	if (out_of_map (newmap, x, y))	66	if (out_of_map (newmap, x, y))
145	{	67	{
146	LOG (llevError, "enter_map: supplied coordinates are not within the map! (%s: %d, %d)\n", &newmap->path, x, y);	68	LOG (llevError, "enter_map: supplied coordinates are not within the map! (%s: %d, %d)\n", &newmap->path, x, y);
147	x = newmap->enter_x;	69	x = newmap->enter_x;
149	if (out_of_map (newmap, x, y))	71	if (out_of_map (newmap, x, y))
150	{	72	{
151	LOG (llevError, "enter_map: map %s provides invalid default enter location (%d, %d) > (%d, %d)\n",	73	LOG (llevError, "enter_map: map %s provides invalid default enter location (%d, %d) > (%d, %d)\n",
152	&newmap->path, x, y, newmap->width, newmap->height);	74	&newmap->path, x, y, newmap->width, newmap->height);
153	new_draw_info (NDI_UNIQUE, 0, this, "The exit is closed");	75	new_draw_info (NDI_UNIQUE, 0, this, "The exit is closed");
154	return;	76	return false;
155	}	77	}
156	}	78	}
		79
		80	if (contr && map != newmap && map)
		81	if (INVOKE_MAP (LEAVE, map, ARG_PLAYER (contr)))
		82	return false;
		83
		84	// remove, so stupid blocked does not trigger a failure
		85	remove ();
157		86
158	/* try to find a spot for the player */	87	/* try to find a spot for the player */
159	if (ob_blocked (this, newmap, x, y))	88	if (blocked (newmap, x, y))
160	{ /* First choice blocked */	89	{ /* First choice blocked */
161	/* We try to find a spot for the player, starting closest in.	90	/* We try to find a spot for the player, starting closest in.
162	* We could use find_first_free_spot, but that doesn't randomize it at all,	91	* We could use find_first_free_spot, but that doesn't randomize it at all,
163	* So for example, if the north space is free, you would always end up there even	92	* So for example, if the north space is free, you would always end up there even
164	* if other spaces around are available.	93	* if other spaces around are available.
165	* Note that for the second and third calls, we could start at a position other	94	* Note that for the second and third calls, we could start at a position other
166	* than one, but then we could end up on the other side of walls and so forth.	95	* than one, but then we could end up on the other side of walls and so forth.
167	*/	96	*/
168	int i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE1 + 1);	97	int i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE1 + 1);
169		98
170	if (i == -1)	99	if (i < 0)
171	{	100	{
172	i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE2 + 1);	101	i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE2 + 1);
173	if (i == -1)	102	if (i < 0)
174	i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE);	103	i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE);
175	}	104	}
176		105
177	if (i != -1)	106	if (i >= 0)
		107	{
		108	maptile *m = newmap;
		109	sint16 nx = x + DIRX (i);
		110	sint16 ny = y + DIRY (i);
		111
		112	if (xy_normalise (m, nx, ny))
178	{	113	{
179	x += freearr_x[i];	114	newmap = m;
180	y += freearr_y[i];	115	x = nx;
		116	y = ny;
		117	}
181	}	118	}
182	else	119	else
183	/* not much we can do in this case. */	120	/* not much we can do in this case. */
184	LOG (llevInfo, "enter_map: Could not find free spot for player - will dump on top of object (%s: %d, %d)\n", &newmap->path, x, y);	121	LOG (llevInfo, "enter_map: Could not find free spot for player - will dump on top of object (%s: %d, %d)\n", &newmap->path, x, y);
185	}	122	}
186		123
187	if (map)	124	if (contr && map != newmap)
188	if (INVOKE_MAP (LEAVE, map, ARG_PLAYER (contr)))	125	{
189	return;
190
191	if (INVOKE_PLAYER (MAP_CHANGE, contr, ARG_MAP (newmap), ARG_INT (x), ARG_INT (y)))	126	if (INVOKE_PLAYER (MAP_CHANGE, contr, ARG_MAP (newmap), ARG_INT (x), ARG_INT (y)))
192	return;	127	return false;
193		128
194	if (INVOKE_MAP (ENTER, newmap, ARG_PLAYER (contr), ARG_INT (x), ARG_INT (y)))	129	if (INVOKE_MAP (ENTER, newmap, ARG_PLAYER (contr), ARG_INT (x), ARG_INT (y)))
195	return;	130	return false;
		131	}
196		132
197	/* If it is a player login, he has yet to be inserted anyplace.
198	* otherwise, we need to deal with removing the player here.
199	*/
200	remove ();
201
202	this->x = x;
203	this->y = y;
204	map = newmap;
205
206	insert_ob_in_map (this, map, 0, INS_NO_WALK_ON);
207
208	newmap->timeout = 0;
209	enemy = NULL;	133	enemy = 0;
210		134
		135	newmap->activate (); // workaround for activate activating everyhing on the map, includign the palyer on the {link} map
		136	//newmap->insert (this, x, y);
		137	newmap->insert (this, x, y, 0, INS_NO_AUTO_EXIT);
		138	prefetch_surrounding_maps ();
		139
		140	if (map == newmap) // see if we actually arrived there - insert might trigger a teleport
		141	{
211	if (contr)	142	if (contr)
212	{	143	{
213	strcpy (contr->maplevel, newmap->path);	144	contr->maplevel = newmap->path;
214	contr->count = 0;	145	contr->count = 0;
215	}
216		146
217	/* Update any golems */	147	/* Update any golems */
218	if (type == PLAYER && contr->ranges[range_golem])	148	if (object *golem = contr->golem)
219	{
220	int i = find_free_spot (contr->ranges[range_golem], newmap,
221	x, y, 1, SIZEOFFREE);
222
223	contr->ranges[range_golem]->remove ();
224
225	if (i == -1)
226	{
227	remove_friendly_object (contr->ranges[range_golem]);
228	contr->ranges[range_golem]->destroy ();
229	contr->ranges[range_golem] = 0;
230	}
231	else
232	{
233	for (object *tmp = contr->ranges[range_golem]; tmp != NULL; tmp = tmp->more)
234	{	149	{
235	tmp->x = x + freearr_x[i] + (tmp->arch == NULL ? 0 : tmp->arch->clone.x);	150	int i = find_free_spot (golem, newmap, x, y, 1, SIZEOFFREE);
236	tmp->y = y + freearr_y[i] + (tmp->arch == NULL ? 0 : tmp->arch->clone.y);	151
237	tmp->map = newmap;	152	if (i < 0)
		153	golem->drop_and_destroy ();
		154	else
		155	{
		156	newmap->insert (golem, x + DIRX (i), y + DIRY (i));
		157	golem->direction = find_dir_2 (golem->x - x, golem->y - y);
		158	}
238	}	159	}
239
240	insert_ob_in_map (contr->ranges[range_golem], newmap, NULL, 0);
241	contr->ranges[range_golem]->direction =
242	find_dir_2 (x - contr->ranges[range_golem]->x, y - contr->ranges[range_golem]->y);
243	}	160	}
244	}
245		161
246	direction = 0;
247
248	/* since the players map is already loaded, we don't need to worry	162	/* since the players map is already loaded, we don't need to worry
249	* about pending objects.	163	* about pending objects.
250	*/	164	*/
251	remove_all_pets (newmap);	165	move_all_pets ();
		166
		167	return true;
		168	}
		169
		170	return false;
252	}	171	}
253		172
254	/* process_players1 and process_players2 do all the player related stuff.	173	/* process_players1 and process_players2 do all the player related stuff.
255	* I moved it out of process events and process_map. This was to some	174	* I moved it out of process events and process_map. This was to some
256	* extent for debugging as well as to get a better idea of the time used	175	* extent for debugging as well as to get a better idea of the time used
…		…
259	* is needed after the players have been updated.	178	* is needed after the players have been updated.
260	*/	179	*/
261	static void	180	static void
262	process_players1 ()	181	process_players1 ()
263	{	182	{
264	int flag;
265
266	/* Basically, we keep looping until all the players have done their actions. */	183	/* Basically, we keep looping until all the players have done their actions. */
267	for (flag = 1; flag != 0;)	184	for (int flag = 1; flag != 0;)
268	{	185	{
269	flag = 0;	186	flag = 0;
270	for_all_players (pl)	187	for_all_players (pl)
271	{	188	{
272	pl->refcnt_chk ();	189	pl->refcnt_chk ();
273		190
274	if (!pl->ob \|\| !pl->ns)	191	if (expect_false (!pl->ob \|\| !pl->ns \|\| !pl->ob->active))
275	continue;	192	continue;
276		193
277	if (pl->ob->speed_left > 0)
278	if (handle_newcs_player (pl->ob))	194	if (handle_newcs_player (pl->ob))
279	flag = 1;	195	flag = 1;
280
281	/* If the player is not actively playing, don't make a
282	* backup save - nothing to save anyway. Plus, the
283	* map may not longer be valid. This can happen when the
284	* player quits - they exist for purposes of tracking on the map,
285	* but don't actually reside on any actual map.
286	*/
287	if (QUERY_FLAG (pl->ob, FLAG_REMOVED))
288	continue;
289
290	#ifdef AUTOSAVE
291	/* check for ST_PLAYING state so that we don't try to save off when
292	* the player is logging in.
293	*/
294	if ((pl->last_save_tick + AUTOSAVE) < (uint32) pticks && pl->ns->state == ST_PLAYING)
295	{
296	pl->ob->contr->save ();
297	pl->last_save_tick = pticks;
298	}	196	}
299	#endif	197	}
300	} /* end of for loop for all the players */
301	} /* for flag */
302		198
303	for_all_players (pl)	199	for_all_players (pl)
304	{	200	{
305	if (!pl->ob \|\| !pl->ns)	201	object *ob = pl->ob;
		202
		203	// process_objects destroys the speed_left value
		204	pl->speed_left_save = ob->speed_left;
		205
		206	if (expect_false (!ob \|\| !pl->ns \|\| !ob->active))
306	continue;	207	continue;
307		208
308	if (settings.casting_time)
309	{
310	if (pl->ob->casting_time > 0)
311	{
312	pl->ob->casting_time--;
313	pl->ob->start_holding = 1;
314	}
315
316	/* set spell_state so we can update the range in stats field */
317	if ((pl->ob->casting_time == 0) && (pl->ob->start_holding == 1))
318	pl->ob->start_holding = 0;
319	}
320
321	do_some_living (pl->ob);	209	do_some_living (ob);
322	}	210	}
323	}	211	}
324		212
325	static void	213	static void
326	process_players2 ()	214	process_players2 ()
327	{	215	{
328	/* Then check if any players should use weapon-speed instead of speed */	216	/* Then check if any players should use weapon-speed instead of speed */
329	for_all_players (pl)	217	for_all_players (pl)
330	{	218	{
331	/* The code that did weapon_sp handling here was out of place -	219	// restore speed_left value saved by process_players1
332	* this isn't called until after the player has finished there
333	* actions, and is thus out of place. All we do here is bounds
334	* checking.
335	*/
336	if (pl->has_hit)
337	{
338	if (pl->ob->speed_left > pl->weapon_sp)
339	pl->ob->speed_left = pl->weapon_sp;
340
341	/* This needs to be here - if the player is running, we need to
342	* clear this each tick, but new commands are not being received
343	* so execute_newserver_command() is never called
344	*/
345	pl->has_hit = 0;
346	}
347	else if (pl->ob->speed_left > pl->ob->speed)
348	pl->ob->speed_left = pl->ob->speed;	220	pl->ob->speed_left = pl->speed_left_save;
349	}
350	}
351		221
352	void	222	pl->weapon_sp_left = min (pl->weapon_sp, pl->weapon_sp_left + pl->weapon_sp);
		223	pl->ob->speed_left = min (pl->ob->speed, pl->ob->speed_left + pl->ob->speed);
		224	}
		225	}
		226
		227	static void
353	process_events ()	228	process_events ()
354	{	229	{
355	object *op;
356
357	static object_ptr marker_;
358
359	if (!marker_)
360	marker_ = object::create ();
361
362	object *marker = marker_;
363
364	process_players1 ();	230	process_players1 ();
365		231
366	marker->active_next = active_objects;	232	for_all_actives (op)
367
368	if (marker->active_next)
369	marker->active_next->active_prev = marker;
370
371	marker->active_prev = 0;
372	active_objects = marker;
373
374	while (marker->active_next)
375	{	233	{
376	op = marker->active_next;	234	// try to prefetch some stuff we expect to need
		235	// obviously, it should be grouped into the same cacheline.
		236	// preliminary results indicate that this gives halves the speed
		237	// used for the inner loop
		238	if (_i < actives.size ()) // HACK, rely on _i :/
		239	{
		240	object *next = actives [_i + 1];
377		241
378	/* Move marker forward - swap op and marker */	242	ecb_prefetch (&next->flag , 0, 1);
379	op->active_prev = marker->active_prev;	243	ecb_prefetch (&next->speed , 0, 1);
380		244	ecb_prefetch (&next->anim_speed, 0, 1);
381	if (op->active_prev)	245	ecb_prefetch (&next->contr , 0, 1);
382	op->active_prev->active_next = op;	246	}
383	else
384	active_objects = op;
385
386	marker->active_next = op->active_next;
387
388	if (marker->active_next)
389	marker->active_next->active_prev = marker;
390
391	marker->active_prev = op;
392	op->active_next = marker;
393		247
394	/* Now process op */	248	/* Now process op */
395	if (QUERY_FLAG (op, FLAG_FREED))	249	if (expect_false (op->flag [FLAG_FREED]))
396	{	250	{
397	LOG (llevError, "BUG: process_events(): Free object on list\n");	251	LOG (llevError, "BUG: process_events(): Free object on list (%s)\n", op->debug_desc ());
398	op->set_speed (0);	252	op->set_speed (0);
399	continue;	253	continue;
400	}	254	}
401		255
402	/* I've seen occasional crashes due to this - the object is removed,	256	if (expect_false (!op->has_active_speed ()))
403	* and thus the map it points to (last map it was on) may be bogus
404	* The real bug is to try to find out the cause of this - someone
405	* is probably calling remove_ob without either an insert_ob or
406	* free_object afterwards, leaving an object dangling. But I'd
407	* rather log this and continue on instead of crashing.
408	* Don't remove players - when a player quits, the object is in
409	* sort of a limbo, of removed, but something we want to keep
410	* around.
411	*/
412	if (QUERY_FLAG (op, FLAG_REMOVED) && op->type != PLAYER && op->map && op->map->in_memory != MAP_IN_MEMORY)
413	{
414	LOG (llevError, "BUG: process_events(): Removed object on list\n");
415	char *dump = dump_object (op);
416	LOG (llevError, dump);
417	free (dump);
418	op->destroy ();
419	continue;
420	}	257	{
421
422	if (!op->speed)
423	{
424	LOG (llevError, "BUG: process_events(): Object %s has no speed, "	258	LOG (llevError, "BUG: process_events(): Object %s has no speed (%f), "
425	"but is on active list\n", &op->arch->name);	259	"but is on active list\n", op->debug_desc (), op->speed);
426	op->set_speed (0);	260	op->set_speed (0);
427	continue;	261	continue;
428	}	262	}
429		263
430	if (op->map == NULL && op->env == NULL && op->name && op->type != MAP)	264	if (expect_false (op->flag [FLAG_REMOVED]))
431	{	265	{
432	LOG (llevError, "BUG: process_events(): Object without map or "	266	LOG (llevError, "BUG: process_events(): removed object is on active list: %s\n",
433	"inventory is on active list: %s (%d)\n", &op->name, op->count);	267	op->debug_desc ());
434	op->set_speed (0);	268	op->set_speed (0);
435	continue;	269	continue;
436	}	270	}
437		271
438	/* Animate the object. Bug or feature that anim_speed	272	/* Animate the object. Bug or feature that anim_speed
439	* is based on ticks, and not the creatures speed?	273	* is based on ticks, and not the creatures speed?
440	*/	274	*/
441	if (op->anim_speed && op->last_anim >= op->anim_speed)	275	if (op->anim_speed && op->last_anim >= op->anim_speed)
442	{	276	{
443	if ((op->type == PLAYER))
444	animate_object (op, op->facing);
445	else
446	animate_object (op, op->direction);	277	animate_object (op, op->contr ? op->facing : op->direction);
447
448	op->last_anim = 1;	278	op->last_anim = 1;
449	}	279	}
450	else	280	else
451	op->last_anim++;	281	++op->last_anim;
452		282
453	if (op->speed_left > 0)	283	if (expect_false (op->speed_left > 0.f))
454	{
455	#if 0
456	/* I've seen occasional crashes in move_symptom() with it
457	* crashing because op is removed - add some debugging to
458	* track if it is removed at this point.
459	* This unfortunately is a bit too verbose it seems - not sure
460	* why - I think what happens is a map is freed or something and
461	* some objects get 'lost' - removed never to be reclaimed.
462	* removed objects generally shouldn't exist.
463	*/
464	if (QUERY_FLAG (op, FLAG_REMOVED))
465	{	284	{
466	LOG (llevDebug, "process_events: calling process_object with removed object %s\n", op->name ? op->name : "null");
467	}
468	#endif
469	--op->speed_left;	285	--op->speed_left;
470	process_object (op);	286	process_object (op);
471
472	if (op->destroyed ())
473	continue;
474	}	287	}
475		288
476	if (settings.casting_time == TRUE && op->casting_time > 0)	289	// this will destroy the speed_left value for players, but
477	op->casting_time--;	290	// process_players1 and ..2 save/restore the real value,
478		291	// so we can avoid a costly test here.
479	if (op->speed_left <= 0)	292	op->speed_left = min (op->speed, op->speed_left + op->speed);
480	op->speed_left += FABS (op->speed);
481	}	293	}
482
483	/* Remove marker object from active list */
484	if (marker->active_prev != NULL)
485	marker->active_prev->active_next = NULL;
486	else
487	active_objects = NULL;
488		294
489	process_players2 ();	295	process_players2 ();
490	}	296	}
491		297
492	/* clean up everything before exiting */	298	/* clean up everything before exiting */
493	void	299	void
494	emergency_save ()	300	emergency_save ()
495	{	301	{
496	LOG (llevDebug, "emergency save begin.\n");	302	LOG (llevInfo, "emergency_save: enter\n");
497		303
498	LOG (llevDebug, "saving players.\n");	304	LOG (llevInfo, "emergency_save: saving book archive\n");
499	for_all_players (pl)
500	pl->save (1);
501
502	// for_all_players (pl)
503	// if (pl->ob)
504	// pl->ob->remove ();
505
506	LOG (llevDebug, "saving maps.\n");
507	maptile::emergency_save ();
508
509	LOG (llevDebug, "saving book archive.\n");
510	write_book_archive ();	305	write_book_archive ();
511		306
		307	cfperl_emergency_save ();
		308
512	LOG (llevDebug, "emergency save done.\n");	309	LOG (llevInfo, "emergency_save: leave\n");
		310	}
		311
		312	// send all clients some informational text
		313	static void
		314	cleanup_inform (const char *cause, bool make_core)
		315	{
		316	int flags = NDI_REPLY \| NDI_UNIQUE \| NDI_ALL \| (make_core ? NDI_RED : NDI_GREEN);
		317
		318	new_draw_info_format (flags, 0, 0, "The server will now shutdown.");
		319	new_draw_info_format (flags, 0, 0, "Cause for this shutdown: %s", cause);
		320
		321	if (make_core)
		322	new_draw_info_format (flags, 0, 0, "This is considered a crash, but all maps and players have been saved.");
		323	else
		324	new_draw_info_format (flags, 0, 0, "This is considered to be a clean shutdown, and all maps and players will be saved now.");
		325
		326	new_draw_info_format (flags, 0, 0, "%s", CLEANUP_MESSAGE);
		327
		328	client::flush_sockets ();
513	}	329	}
514		330
515	/* clean up everything before exiting */	331	/* clean up everything before exiting */
516	void	332	void
517	cleanup (bool make_core)	333	cleanup (const char *cause, bool make_core)
518	{	334	{
		335	if (make_core)
		336	fork_abort (cause);
		337
		338	LOG (make_core ? llevError : llevInfo, "cleanup cause: %s\n", cause);
		339
		340	if (!make_core)
		341	cleanup_inform (cause, make_core);
		342
519	LOG (llevDebug, "cleanup begin.\n");	343	LOG (llevDebug, "cleanup begin.\n");
520		344
		345	if (init_done && !in_cleanup)
		346	{
521	in_cleanup = true;	347	in_cleanup = true;
522
523	if (init_done)
524	emergency_save ();	348	emergency_save ();
		349	}
		350	else
		351	in_cleanup = true;
525		352
526	LOG (llevDebug, "running cleanup handlers.\n");	353	LOG (llevDebug, "running cleanup handlers.\n");
527	INVOKE_GLOBAL (CLEANUP);	354	INVOKE_GLOBAL (CLEANUP);
528		355
529	LOG (llevDebug, "cleanup done.\n");	356	LOG (llevDebug, "cleanup done.\n");
530		357
		358	log_cleanup ();
		359
531	if (make_core)	360	if (make_core)
532	abort ();	361	cleanup_inform (cause, make_core);
533	else	362	else
534	_exit (0);
535	}
536
537	void
538	leave (player *pl, int draw_exit)
539	{
540	if (pl)
541	{
542	if (pl->ob->type != DEAD_OBJECT)
543	{
544	/* If a hidden dm dropped connection do not create
545	* inconsistencies by showing that they have left the game
546	*/
547	if (!(QUERY_FLAG (pl->ob, FLAG_WIZ) && pl->ob->contr->hidden)
548	&& draw_exit)
549	{
550	if (pl->ob->map)
551	{
552	INVOKE_PLAYER (LOGOUT, pl);
553	LOG (llevInfo, "LOGOUT: Player named %s from ip %s\n", &pl->ob->name, pl->ns->host);
554	}
555
556	char buf[MAX_BUF];
557
558	sprintf (buf, "%s left the game.", &pl->ob->name);
559	new_draw_info (NDI_UNIQUE \| NDI_ALL \| NDI_DK_ORANGE, 5, 0, buf);
560	}
561
562	pl->ob->remove ();
563	pl->ob->type = DEAD_OBJECT; /* To avoid problems with inventory window */
564	}
565
566	/* We do this so that the socket handling routine can do the final
567	* cleanup. We also leave that loop to actually handle the freeing
568	* of the data.
569	*/
570	if (pl->ns)
571	pl->ns->destroy ();
572
573	}	363	{
574	}	364	new_draw_info_format (NDI_REPLY \| NDI_UNIQUE \| NDI_ALL \| NDI_GREEN, 0, 0, "Maps and players successfully saved, exiting.");
575		365	new_draw_info_format (NDI_REPLY \| NDI_UNIQUE \| NDI_ALL \| NDI_GREEN, 0, 0, "And again: " CLEANUP_MESSAGE);
576	int	366	client::flush_sockets ();
577	forbid_play (void)
578	{
579	#if !defined(_IBMR2) && !defined(___IBMR2) && defined(PERM_FILE)
580	char buf[MAX_BUF], day[MAX_BUF];
581	FILE *fp;
582	time_t clock;
583	struct tm *tm;
584	int i, start, stop, forbit = 0, comp;
585
586	clock = time (NULL);
587	tm = (struct tm *) localtime (&clock);
588
589	sprintf (buf, "%s/%s", settings.confdir, PERM_FILE);
590	if ((fp = open_and_uncompress (buf, 0, &comp)) == NULL)
591	return 0;
592
593	while (fgets (buf, MAX_BUF, fp))
594	{	367	}
595	if (buf[0] == '#')
596	continue;
597	if (!strncmp (buf, "msg", 3))
598	{
599	if (forbit)
600	while (fgets (buf, MAX_BUF, fp)) /* print message */
601	fputs (buf, logfile);
602	break;
603		368
604	}	369	cfperl_cleanup (make_core);
605	else if (sscanf (buf, "%s %d%*c%d\n", day, &start, &stop) != 3)	370	_exit (make_core);
606	{
607	LOG (llevDebug, "Warning: Incomplete line in permission file ignored.\n");
608	continue;
609	}
610
611	for (i = 0; i < 7; i++)
612	{
613	if (!strncmp (buf, days[i], 3) && (tm->tm_wday == i) && (tm->tm_hour >= start) && (tm->tm_hour < stop))
614	forbit = 1;
615	}
616	}
617
618	close_and_delete (fp, comp);
619
620	return forbit;
621	#else
622	return 0;
623	#endif
624	}	371	}
625		372
626	/*	373	/*
627	* do_specials() is a collection of functions to call from time to time.	374	* do_specials() is a collection of functions to call from time to time.
628	* Modified 2000-1-14 MSW to use the global pticks count to determine how	375	* Modified 2000-1-14 MSW to use the global server_tick count to determine how
629	* often to do things. This will allow us to spred them out more often.	376	* often to do things. This will allow us to spred them out more often.
630	* I use prime numbers for the factor count - in that way, it is less likely	377	* I use prime numbers for the factor count - in that way, it is less likely
631	* these actions will fall on the same tick (compared to say using 500/2500/15000	378	* these actions will fall on the same tick (compared to say using 500/2500/15000
632	* which would mean on that 15,000 tick count a whole bunch of stuff gets	379	* which would mean on that 15,000 tick count a whole bunch of stuff gets
633	* done). Of course, there can still be times where multiple specials are	380	* done). Of course, there can still be times where multiple specials are
634	* done on the same tick, but that will happen very infrequently	381	* done on the same tick, but that will happen very infrequently
635	*	382	*
636	* I also think this code makes it easier to see how often we really are	383	* I also think this code makes it easier to see how often we really are
637	* doing the various things.	384	* doing the various things.
638	*/	385	*/
		386	static void
		387	do_specials ()
		388	{
		389	shstr::gc ();
		390	archetype::gc ();
639		391
640	extern unsigned long todtick;	392	if (expect_false (!(server_tick % TICKS_PER_HOUR)))
		393	maptile::adjust_daylight ();
		394
		395	if (expect_false (!(server_tick % 2503)))
		396	fix_weight (); /* Hack to fix weightproblems caused by bugs */
		397
		398	if (expect_false (!(server_tick % 5003)))
		399	write_book_archive ();
		400
		401	if (expect_false (!(server_tick % 5009)))
		402	clean_friendly_list ();
		403
		404	if (expect_false (!(server_tick % 5011)))
		405	obsolete_parties ();
		406
		407	if (expect_false (!(server_tick % 12503)))
		408	fix_luck ();
		409	}
641		410
642	void	411	void
643	do_specials (void)	412	one_tick ()
644	{
645	if (!(pticks % PTICKS_PER_CLOCK))
646	tick_the_clock ();
647
648	if (!(pticks % 7))
649	shstr::gc ();
650
651	if (!(pticks % 2503))
652	fix_weight (); /* Hack to fix weightproblems caused by bugs */
653
654	if (!(pticks % 5003))
655	write_book_archive ();
656
657	if (!(pticks % 5009))
658	clean_friendly_list ();
659
660	if (!(pticks % 5011))
661	obsolete_parties ();
662
663	if (!(pticks % 12503))
664	fix_luck ();
665	}
666
667	void
668	server_tick ()
669	{	413	{
670	// first do the user visible stuff	414	// first do the user visible stuff
671	doeric_server ();
672	INVOKE_GLOBAL (CLOCK);	415	INVOKE_GLOBAL (CLOCK);
673	process_events (); /* "do" something with objects with speed */	416	process_events (); // "do" something with objects with speed
674	flush_sockets ();	417	client::clock (); // draw client maps etc.
675		418
676	// then do some bookkeeping, should not really be here	419	// then do some bookkeeping, should not really be here
677	do_specials (); /* Routines called from time to time. */	420	do_specials (); /* Routines called from time to time. */
678	attachable::check_mortals ();	421	attachable::check_mortals ();
679		422
680	++pticks;	423	// now that we aggressively reuse id's, this is very unlikely to happen...
		424	if (object::object_count >= RESTART_COUNT)
		425	cleanup ("running out of protocol ID values - need full restart");
681	}	426	}
682		427
		428	// normal main
683	int	429	int
684	main (int argc, char **argv)	430	main (int argc, char **argv)
685	{	431	{
686	settings.argc = argc;	432	settings.argc = argc;
687	settings.argv = argv;	433	settings.argv = argv;
688		434
		435	rndm.seed (time (0));
		436
		437	// temporary(?) testing hack
		438	if (argc >= 2 && !strcmp (argv [1], "--noise"))
		439	{
		440	void noise_test ();
		441	noise_test ();
		442	exit (0);
		443	}
		444
		445	#if 0
		446	// code sometiems used for timing benchmarks
		447	random_number_generator<freeciv_random_generator> rng;
		448	rng.seed(0);
		449	for (int i = 0; i < 10; ++i)
		450	printf ("%08x\n", rng.get_u32());
		451	for (int i = 0; i < 1000000; ++i)
		452	volatile int r = rng.get_u32 ();
		453	cstamp s = stamp ();
		454	for (int i = 0; i < 1000000; ++i)
		455	volatile int r = rng.next ();
		456	printf ("c %d\n", (int)measure (s));
		457	exit (0);
		458	#endif
		459
689	init (argc, argv);	460	init (argc, argv);
690
691	initPlugins ();
692		461
693	for (;;)	462	for (;;)
694	cfperl_main ();	463	cfperl_main ();
695
696	cleanup (true);
697	}	464	}
698		465

Diff Legend

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

Comparing deliantra/server/server/main.C (file contents): Revision 1.64 by root, Sat Dec 30 18:45:29 2006 UTC vs. Revision 1.179 by root, Sat Nov 17 23:33:18 2018 UTC

Diff Legend

Comparing deliantra/server/server/main.C (file contents):
Revision 1.64 by root, Sat Dec 30 18:45:29 2006 UTC vs.
Revision 1.179 by root, Sat Nov 17 23:33:18 2018 UTC