ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/server/main.C
(Generate patch)

Comparing deliantra/server/server/main.C (file contents):
Revision 1.152 by root, Sun Apr 18 12:50:07 2010 UTC vs.
Revision 1.176 by root, Wed Nov 16 23:42:02 2016 UTC

1/* 1/*
2 * This file is part of Deliantra, the Roguelike Realtime MMORPG. 2 * This file is part of Deliantra, the Roguelike Realtime MMORPG.
3 * 3 *
4 * Copyright (©) 2005,2006,2007,2008,2009,2010 Marc Alexander Lehmann / Robin Redeker / the Deliantra team 4 * Copyright (©) 2005,2006,2007,2008,2009,2010,2011,2012,2013,2014,2015,2016 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
5 * Copyright (©) 2001-2003 Mark Wedel & Crossfire Development Team 5 * Copyright (©) 2001-2003 Mark Wedel & Crossfire Development Team
6 * Copyright (©) 1992 Frank Tore Johansen 6 * Copyright (©) 1992 Frank Tore Johansen
7 * 7 *
8 * Deliantra is free software: you can redistribute it and/or modify it under 8 * Deliantra is free software: you can redistribute it and/or modify it under
9 * the terms of the Affero GNU General Public License as published by the 9 * the terms of the Affero GNU General Public License as published by the
10 * Free Software Foundation, either version 3 of the License, or (at your 10 * Free Software Foundation, either version 3 of the License, or (at your
11 * option) any later version. 11 * 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,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of 14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
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 Affero GNU General Public License 18 * You should have received a copy of the Affero GNU General Public License
19 * and the GNU General Public License along with this program. If not, see 19 * and the GNU General Public License along with this program. If not, see
20 * <http://www.gnu.org/licenses/>. 20 * <http://www.gnu.org/licenses/>.
21 * 21 *
22 * The authors can be reached via e-mail to <support@deliantra.net> 22 * The authors can be reached via e-mail to <support@deliantra.net>
23 */ 23 */
24 24
25#include <global.h> 25#include <global.h>
26#include <object.h> 26#include <object.h>
29#include <sproto.h> 29#include <sproto.h>
30#include <time.h> 30#include <time.h>
31 31
32#include <glib.h> 32#include <glib.h>
33 33
34#include <../random_maps/random_map.h> 34#include <rmg.h>
35#include <../random_maps/rproto.h> 35#include <rproto.h>
36#include "path.h" 36#include "path.h"
37 37
38void 38void
39version (object *op) 39version (object *op)
40{ 40{
41 new_draw_info_format (NDI_UNIQUE, 0, op, "This is Deliantra v%s", VERSION); 41 new_draw_info_format (NDI_UNIQUE, 0, op, "This is Deliantra v%s", VERSION);
42} 42}
43 43
44/* 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
45 * savebed. We do some error checking - its possible that the 45 * savebed.
46 * savebed map may no longer exist, so we make sure the player
47 * goes someplace.
48 */ 46 */
49void 47void
50enter_player_savebed (object *op) 48enter_player_savebed (object *op)
51{ 49{
52 op->player_goto (op->contr->savebed_map, op->contr->bed_x, op->contr->bed_y); 50 op->player_goto (op->contr->savebed_map, op->contr->bed_x, op->contr->bed_y);
57 * 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
58 * 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
59 * whatever reason. If default map coordinates are to be used, then 57 * whatever reason. If default map coordinates are to be used, then
60 * the function that calls this should figure them out. 58 * the function that calls this should figure them out.
61 */ 59 */
62void 60bool
63object::enter_map (maptile *newmap, int x, int y) 61object::enter_map (maptile *newmap, int x, int y)
64{ 62{
65 if (destroyed () || !newmap || newmap->in_memory != MAP_ACTIVE) 63 if (destroyed () || !newmap || !newmap->linkable ())
66 return; 64 return false;
67 65
68 if (out_of_map (newmap, x, y)) 66 if (out_of_map (newmap, x, y))
69 { 67 {
70 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);
71 x = newmap->enter_x; 69 x = newmap->enter_x;
73 if (out_of_map (newmap, x, y)) 71 if (out_of_map (newmap, x, y))
74 { 72 {
75 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",
76 &newmap->path, x, y, newmap->width, newmap->height); 74 &newmap->path, x, y, newmap->width, newmap->height);
77 new_draw_info (NDI_UNIQUE, 0, this, "The exit is closed"); 75 new_draw_info (NDI_UNIQUE, 0, this, "The exit is closed");
78 return; 76 return false;
79 } 77 }
80 } 78 }
81 79
82 if (contr && map != newmap && map) 80 if (contr && map != newmap && map)
83 if (INVOKE_MAP (LEAVE, map, ARG_PLAYER (contr))) 81 if (INVOKE_MAP (LEAVE, map, ARG_PLAYER (contr)))
84 return; 82 return false;
85 83
86 // remove, so stupid ob_locked does not trigger a failure 84 // remove, so stupid blocked does not trigger a failure
87 remove (); 85 remove ();
88 86
89 /* try to find a spot for the player */ 87 /* try to find a spot for the player */
90 if (blocked (newmap, x, y)) 88 if (blocked (newmap, x, y))
91 { /* First choice blocked */ 89 { /* First choice blocked */
96 * 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
97 * 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.
98 */ 96 */
99 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);
100 98
101 if (i == -1) 99 if (i < 0)
102 { 100 {
103 i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE2 + 1); 101 i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE2 + 1);
104 if (i == -1) 102 if (i < 0)
105 i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE); 103 i = find_free_spot (this, newmap, x, y, 1, SIZEOFFREE);
106 } 104 }
107 105
108 if (i != -1) 106 if (i >= 0)
107 {
108 maptile *m = newmap;
109 sint16 nx = x + freearr_x[i];
110 sint16 ny = y + freearr_y[i];
111
112 if (xy_normalise (m, nx, ny))
109 { 113 {
110 x += freearr_x[i]; 114 newmap = m;
111 y += freearr_y[i]; 115 x = nx;
116 y = ny;
117 }
112 } 118 }
113 else 119 else
114 /* not much we can do in this case. */ 120 /* not much we can do in this case. */
115 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);
116 } 122 }
117 123
118 if (contr && map != newmap) 124 if (contr && map != newmap)
119 { 125 {
120 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)))
121 return; 127 return false;
122 128
123 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)))
124 return; 130 return false;
125 } 131 }
126
127 this->x = x;
128 this->y = y;
129 map = newmap;
130
131 insert_ob_in_map (this, map, 0, INS_NO_WALK_ON);
132 132
133 enemy = 0; 133 enemy = 0;
134 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 {
135 if (contr) 142 if (contr)
136 { 143 {
137 contr->maplevel = newmap->path; 144 contr->maplevel = newmap->path;
138 contr->count = 0; 145 contr->count = 0;
139 }
140 146
141 /* Update any golems */ 147 /* Update any golems */
142 if (type == PLAYER)
143 if (object *golem = contr->golem) 148 if (object *golem = contr->golem)
144 { 149 {
145 int i = find_free_spot (golem, newmap, x, y, 1, SIZEOFFREE); 150 int i = find_free_spot (golem, newmap, x, y, 1, SIZEOFFREE);
146 151
147 if (i < 0) 152 if (i < 0)
148 golem->drop_and_destroy (); 153 golem->drop_and_destroy ();
149 else 154 else
150 { 155 {
151 newmap->insert (golem, x + freearr_x[i], y + freearr_y[i]); 156 newmap->insert (golem, x + freearr_x[i], y + freearr_y[i]);
152 golem->direction = find_dir_2 (golem->x - x, golem->y - y); 157 golem->direction = find_dir_2 (golem->x - x, golem->y - y);
158 }
153 } 159 }
154 } 160 }
155 161
156 /* 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
157 * about pending objects. 163 * about pending objects.
158 */ 164 */
159 remove_all_pets (newmap); 165 move_all_pets ();
166
167 return true;
168 }
169
170 return false;
160} 171}
161 172
162/* process_players1 and process_players2 do all the player related stuff. 173/* process_players1 and process_players2 do all the player related stuff.
163 * 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
164 * 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
235 } 246 }
236 247
237 /* Now process op */ 248 /* Now process op */
238 if (expect_false (op->flag [FLAG_FREED])) 249 if (expect_false (op->flag [FLAG_FREED]))
239 { 250 {
240 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 ());
241 op->set_speed (0); 252 op->set_speed (0);
242 continue; 253 continue;
243 } 254 }
244 255
245 if (expect_false (!op->has_active_speed ())) 256 if (expect_false (!op->has_active_speed ()))
286 297
287/* clean up everything before exiting */ 298/* clean up everything before exiting */
288void 299void
289emergency_save () 300emergency_save ()
290{ 301{
291 LOG (llevDebug, "emergency save begin.\n"); 302 LOG (llevInfo, "emergency_save: enter\n");
303
304 LOG (llevInfo, "emergency_save: saving book archive\n");
305 write_book_archive ();
292 306
293 cfperl_emergency_save (); 307 cfperl_emergency_save ();
294 308
295 LOG (llevDebug, "saving book archive.\n");
296 write_book_archive ();
297
298 LOG (llevDebug, "emergency save done.\n"); 309 LOG (llevInfo, "emergency_save: leave\n");
299} 310}
300 311
301// send all clients some informational text 312// send all clients some informational text
302static void 313static void
303cleanup_inform (const char *cause, bool make_core) 314cleanup_inform (const char *cause, bool make_core)
322cleanup (const char *cause, bool make_core) 333cleanup (const char *cause, bool make_core)
323{ 334{
324 if (make_core) 335 if (make_core)
325 fork_abort (cause); 336 fork_abort (cause);
326 337
327 LOG (llevError, "cleanup cause: %s\n", cause); 338 LOG (make_core ? llevError : llevInfo, "cleanup cause: %s\n", cause);
328 339
329 if (!make_core) 340 if (!make_core)
330 cleanup_inform (cause, make_core); 341 cleanup_inform (cause, make_core);
331 342
332 LOG (llevDebug, "cleanup begin.\n"); 343 LOG (llevDebug, "cleanup begin.\n");
359 _exit (make_core); 370 _exit (make_core);
360} 371}
361 372
362/* 373/*
363 * 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.
364 * 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
365 * 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.
366 * 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
367 * 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
368 * 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
369 * 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
376do_specials () 387do_specials ()
377{ 388{
378 shstr::gc (); 389 shstr::gc ();
379 archetype::gc (); 390 archetype::gc ();
380 391
381 if (expect_false (!(pticks % TICKS_PER_HOUR))) 392 if (expect_false (!(server_tick % TICKS_PER_HOUR)))
382 maptile::adjust_daylight (); 393 maptile::adjust_daylight ();
383 394
384 if (expect_false (!(pticks % 2503))) 395 if (expect_false (!(server_tick % 2503)))
385 fix_weight (); /* Hack to fix weightproblems caused by bugs */ 396 fix_weight (); /* Hack to fix weightproblems caused by bugs */
386 397
387 if (expect_false (!(pticks % 5003))) 398 if (expect_false (!(server_tick % 5003)))
388 write_book_archive (); 399 write_book_archive ();
389 400
390 if (expect_false (!(pticks % 5009))) 401 if (expect_false (!(server_tick % 5009)))
391 clean_friendly_list (); 402 clean_friendly_list ();
392 403
393 if (expect_false (!(pticks % 5011))) 404 if (expect_false (!(server_tick % 5011)))
394 obsolete_parties (); 405 obsolete_parties ();
395 406
396 if (expect_false (!(pticks % 12503))) 407 if (expect_false (!(server_tick % 12503)))
397 fix_luck (); 408 fix_luck ();
398} 409}
399 410
400void 411void
401server_tick () 412one_tick ()
402{ 413{
403 // first do the user visible stuff 414 // first do the user visible stuff
404 INVOKE_GLOBAL (CLOCK); 415 INVOKE_GLOBAL (CLOCK);
405 process_events (); // "do" something with objects with speed 416 process_events (); // "do" something with objects with speed
406 client::clock (); // draw client maps etc. 417 client::clock (); // draw client maps etc.
407 418
408 // then do some bookkeeping, should not really be here 419 // then do some bookkeeping, should not really be here
409 do_specials (); /* Routines called from time to time. */ 420 do_specials (); /* Routines called from time to time. */
410 attachable::check_mortals (); 421 attachable::check_mortals ();
411 422
412 ++pticks; 423 // now that we aggressively reuse id's, this is very unlikely to happen...
413
414 if (object::object_count >= RESTART_COUNT) 424 if (object::object_count >= RESTART_COUNT)
415 cleanup ("running out of protocol ID values - need full restart"); 425 cleanup ("running out of protocol ID values - need full restart");
416} 426}
417 427
418// normal main 428// normal main
419int 429int
420main (int argc, char **argv) 430main (int argc, char **argv)
421{ 431{
422 settings.argc = argc; 432 settings.argc = argc;
423 settings.argv = argv; 433 settings.argv = argv;
424 434
425 rndm.seed (time (0)); 435 rndm.seed (time (0));
426 g_thread_init (0); // for the slice allocator only 436 g_thread_init (0); // for the slice allocator only
427 437
438 // temporary(?) testing hack
439 if (argc >= 2 && !strcmp (argv [1], "--noise"))
440 {
441 void noise_test ();
442 noise_test ();
443 exit (0);
444 }
445
446#if 0
447 // code sometiems used for timing benchmarks
448 random_number_generator<freeciv_random_generator> rng;
449 rng.seed(0);
450 for (int i = 0; i < 10; ++i)
451 printf ("%08x\n", rng.get_u32());
452 for (int i = 0; i < 1000000; ++i)
453 volatile int r = rng.get_u32 ();
454 cstamp s = stamp ();
455 for (int i = 0; i < 1000000; ++i)
456 volatile int r = rng.next ();
457 printf ("c %d\n", (int)measure (s));
458 exit (0);
459#endif
460
428 init (argc, argv); 461 init (argc, argv);
429 462
430 for (;;) 463 for (;;)
431 cfperl_main (); 464 cfperl_main ();
432} 465}

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines