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

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.31 by root, Mon Dec 25 11:25:50 2006 UTC vs.
Revision 1.66 by root, Thu Apr 8 19:31:22 2010 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 (C) 2001 Mark Wedel	4	* Copyright (©) 2005,2006,2007,2008,2009,2010 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
5	Copyright (C) 1992 Frank Tore Johansen	5	*
6		6	* Deliantra is free software: you can redistribute it and/or modify it under
7	This program is free software; you can redistribute it and/or modify
8	it under the terms of the GNU General Public License as published by	7	* 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	8	* Free Software Foundation, either version 3 of the License, or (at your
10	(at your option) any later version.	9	* option) any later version.
11		10	*
12	This program is distributed in the hope that it will be useful,	11	* This program is distributed in the hope that it will be useful,
13	but WITHOUT ANY WARRANTY; without even the implied warranty of	12	* but WITHOUT ANY WARRANTY; without even the implied warranty of
14	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15	GNU General Public License for more details.	14	* GNU General Public License for more details.
16		15	*
17	You should have received a copy of the GNU General Public License	16	* 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	17	* and the GNU General Public License along with this program. If not, see
19	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.	18	* <http://www.gnu.org/licenses/>.
20		19	*
21	The author can be reached via e-mail to <crossfire@schmorp.de>	20	* The authors can be reached via e-mail to <support@deliantra.net>
22	*/	21	*/
23		22
24	/**	23	/*
25	* \file
26	* Socket general functions	24	* Socket general functions
27	*
28	* \date 2003-12-02
29	*
30	* Mainly deals with initialization and higher level socket
31	* maintenance (checking for lost connections and if data has arrived.)
32	* The reading of data is handled in ericserver.c
33	*/	25	*/
34		26
35	#include <global.h>	27	#include <global.h>
36	#include <sproto.h>	28	#include <sproto.h>
37	#include <sys/types.h>	29	#include <sys/types.h>
45	#include <unistd.h>	37	#include <unistd.h>
46	#include <arpa/inet.h>	38	#include <arpa/inet.h>
47		39
48	#include <algorithm>	40	#include <algorithm>
49		41
		42	// use relatively small values, as we do not expect to receive much,
		43	// and we do userspace write buffering
		44	// 8kb limits throughput to roughly 66kb/s
		45	#define SOCKET_RCVBUF 8192
		46	#define SOCKET_SNDBUF 16384
		47
50	sockvec clients;	48	sockvec clients;
51		49
52	/**	50	/**
53	* Initializes a connection. Really, it just sets up the data structure,	51	* Initializes a connection. Really, it just sets up the data structure,
54	* socket setup is handled elsewhere. We do send a version to the	52	* socket setup is handled elsewhere. We do send a version to the
55	* client.	53	* client.
56	*/	54	*/
57	client::client (int fd, const char *peername)	55	client::client (int fd, const char *peername)
58	: fd (fd), host (strdup (peername)),	56	: fd (fd), host (strdup (peername)),
59	socket_ev (this, &client::socket_cb),	57	socket_ev (this, &client::socket_cb)
60	cmd_ev (this, &client::cmd_cb),
61	cc_inv (this), cc_other (this)
62	{	58	{
		59	refcnt_inc (); // the socket is an external reference
		60
		61	mss = 1500 - 52; // 1500 typical ethernet frame, 66 typical tcp header overhead
		62
		63	socket_timeout = 16.;
		64
63	{	65	{
64	struct linger linger_opt;	66	struct linger linger_opt;
65		67
66	linger_opt.l_onoff = 0;	68	linger_opt.l_onoff = 0;
67	linger_opt.l_linger = 0;	69	linger_opt.l_linger = 0;
68		70
69	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))	71	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))
70	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));	72	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
71	}	73	}
72		74
73	{	75	{
		76	int val;
		77
		78	#ifdef SO_RCVBUF
		79	val = SOCKET_RCVBUF;
		80	if (setsockopt (fd, SOL_SOCKET, SO_RCVBUF, &val, sizeof (val)))
		81	LOG (llevError, "SO_RCVBUF: %s\n", strerror (errno));
		82	#endif
		83
		84	#ifdef SO_SNDBUF
		85	val = SOCKET_SNDBUF;
		86	if (setsockopt (fd, SOL_SOCKET, SO_SNDBUF, &val, sizeof (val)))
		87	LOG (llevError, "SO_SNDBUF: %s\n", strerror (errno));
		88	#endif
		89
		90	#ifdef IP_TOS
74	int val = IPTOS_LOWDELAY;	91	val = IPTOS_LOWDELAY;
75
76	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))	92	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
77	LOG (llevError, "IP_TOS: %s\n", strerror (errno));	93	LOG (llevError, "IP_TOS: %s\n", strerror (errno));
78	}	94	#endif
79		95
80	{	96	#ifdef TCP_NODELAY
81	int val = 1;	97	val = 1;
82
83	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))	98	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
84	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));	99	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));
		100	#endif
		101
		102	// set some very aggressive keepalive parameters
		103	#ifdef TCP_KEEPIDLE
		104	val = 1;
		105	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
		106	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
		107	#endif
		108
		109	#ifdef TCP_KEEPCNT
		110	val = 3;
		111	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
		112	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
		113	#endif
		114
		115	#ifdef TCP_KEEPINTVL
		116	val = 1;
		117	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
		118	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
		119	#endif
		120
		121	// try to find the mss value in use
		122	#ifdef TCP_MAXSEG
		123	socklen_t sl = sizeof (val);
		124	if (!getsockopt (fd, IPPROTO_TCP, TCP_MAXSEG, &val, &sl) && sl == sizeof (val))
		125	mss = val;
		126	#endif
85	}	127	}
86		128
87	#ifdef __linux__
88	{
89	int val;
90
91	// set some very aggressive keepalive parameters
92	val = 10;
93	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
94	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
95
96	val = 5;
97	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
98	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
99
100	val = 1;
101	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
102	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
103	}
104	#endif
105
106	{
107	int bufsize = 65535; /Supposed absolute upper limit /
108	int oldbufsize;
109	int buflen = sizeof (int);
110
111	if (fcntl (fd, F_SETFL, O_NONBLOCK) == -1)	129	if (fcntl (fd, F_SETFL, O_NONBLOCK) == -1)
112	LOG (llevError, "InitConnection: Error on fcntl.\n");	130	LOG (llevError, "InitConnection: Error on fcntl.\n");
113
114	if (getsockopt (fd, SOL_SOCKET, SO_SNDBUF, (char ) &oldbufsize, (socklen_t ) & buflen) == -1)
115	oldbufsize = 0;
116
117	if (oldbufsize < bufsize)
118	if (setsockopt (fd, SOL_SOCKET, SO_SNDBUF, (char *) &bufsize, sizeof (&bufsize)))
119	LOG (llevError, "InitConnection: setsockopt unable to set output buf size to %d\n", bufsize);
120
121	buflen = sizeof (oldbufsize);
122	getsockopt (fd, SOL_SOCKET, SO_SNDBUF, (char ) &oldbufsize, (socklen_t ) & buflen);
123	}
124		131
125	state = ST_SETUP;	132	state = ST_SETUP;
126	mapmode = Map0Cmd;	133	mapmode = Map1aCmd;
127	darkness = 1;
128	mapx = 11;	134	mapx = 11;
129	mapy = 11;	135	mapy = 11;
130	itemcmd = 1; /* Default is version item1 command */	136	itemcmd = 1; /* Default is version item1 command */
131		137	max_rate = 200000 / (1000000 / MAX_TIME); // ~2mbit is assumed per default
132	faces_sent = salloc0<uint8> (nrofpixmaps);
133		138
134	/* Do this so we don't send a face command for the client for	139	/* Do this so we don't send a face command for the client for
135	* this face. Face 0 is sent to the client to say clear	140	* this face. Face 0 is sent to the client to say clear
136	* face information.	141	* face information.
137	*/	142	*/
138	faces_sent[0] = NS_FACESENT_FACE;	143	faces_sent[0] = true;
		144	fx_want [FT_FACE] = true; // all clients must support image faces
139		145
140	// socket I/O is low priority	146	socket_ev.set (fd, EV_READ);
141	// we prefer to have the server run instead of handling client requests	147	socket_ev.prio (2); // one higher than the ticker priority
142	socket_ev.prio (PE_PRIO_NORMAL + 1);
143	socket_ev.fd (fd);	148	socket_ev.start ();
144	socket_ev.poll (PE_R);
145
146	// command handling is even lower priority
147	// that way no client can monopolise the server
148	cmd_ev.prio (PE_PRIO_NORMAL + 2);
149		149
150	// initialisation done, kick it!	150	// initialisation done, kick it!
151	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);	151	INVOKE_CLIENT (CONNECT, this);
		152
152	flush ();	153	flush ();
153		154
154	// clients are externally referenced by the socket	155	reset_stats ();
155	refcnt_inc ();
156	clients.push_back (this);
157		156
158	#if 0//TODO	157	clients.insert (this);
159	socket_info.nconns++;
160	if (socket_info.nconns > cst_tot.max_conn) cst_tot.max_conn = socket_info.nconns;
161	if (socket_info.nconns > cst_lst.max_conn) cst_lst.max_conn = socket_info.nconns;
162	#endif
163	}	158	}
164		159
165	client::~client ()	160	client::~client ()
166	{	161	{
167	sfree<uint8> (faces_sent, nrofpixmaps);	162	clients.erase (this);
		163
		164	mapinfo_queue_clear ();
168	free (stats.range);	165	free (stats.range);
169	free (stats.title);	166	free (stats.title);
170	free (host);	167	free (host);
171	}	168	}
172		169
173	void	170	void
174	client::do_destroy ()	171	client::do_destroy ()
175	{	172	{
		173	INVOKE_CLIENT (CLIENT_DESTROY, this);
176	attachable::do_destroy ();	174	attachable::do_destroy ();
177
178	sockvec::iterator i = find (clients.begin (), clients.end (), this);
179	if (i != clients.end ())
180	clients.erase (i);
181		175
182	if (pl)	176	if (pl)
183	pl->disconnect ();	177	pl->disconnect ();
184		178
185	if (fd >= 0)	179	if (fd >= 0)
		180	{
		181	send_packet ("goodbye");
		182	flush ();
		183
186	close (fd);	184	close (fd);
		185	}
187		186
188	state = ST_DEAD;	187	state = ST_DEAD;
189		188
190	socket_ev.suspend ();	189	socket_ev.stop ();
191	cmd_ev.suspend ();
192		190
193	// socket now longer references us	191	refcnt_dec (); // socket no longer open
194	refcnt_dec ();
195	}	192	}
196		193
197	/** This sets up the socket and reads all the image information into memory. */
198	void	194	void
199	init_ericserver (void)	195	client::reset_stats ()
200	{	196	{
201	cst_tot.time_start = time (NULL);	197	/* we need to clear these to -1 and not zero - otherwise,
202	cst_lst.time_start = time (NULL);	198	* if a player quits and starts a new character, we wont
		199	* send new values to the client, as things like exp start
		200	* at zero.
		201	*/
		202	for (int i = 0; i < NUM_SKILLS; i++)
		203	last_skill_exp[i] = -1;
203		204
204	LOG (llevDebug, "Initialize new client/server data\n");	205	for (int i = 0; i < NROFATTACKS; i++)
		206	last_resist[i] = -1;
205		207
206	read_client_images ();	208	last_weapon_sp = -1;
207	}	209	last_level = -1;
		210	last_stats.exp = -1;
		211	last_flags = 0;
		212	last_weight = -1;
		213	last_weight_limit = 0;
		214	last_path_attuned = 0;
		215	last_path_repelled = 0;
		216	last_path_denied = 0;
		217	last_speed = 0;
		218	last_flags = 0;
208		219
209		220	static living zero_living;
210	/*******************************************************************************	221	last_stats = zero_living;
211	*
212	* Start of functions dealing with freeing of the data.
213	*
214	******************************************************************************/
215
216	/** Free's all the memory that ericserver allocates. */
217	void
218	free_all_newserver (void)
219	{
220	LOG (llevDebug, "Freeing all new client/server information.\n");
221	free_socket_images ();
222	}	222	}
223		223
224	client *	224	client *
225	client::create (int fd, const char *peername)	225	client::create (int fd, const char *peername)
226	{	226	{
227	if (checkbanned (NULL, peername))
228	{
229	LOG (llevInfo, "Banned host tried to connect: [%s]\n", peername);
230	return 0;
231	}
232	else
233	{
234	client *ns = new client (dup (fd), peername);	227	client *ns = new client (dup (fd), peername);
235		228
236	ns->instantiate (); // effectively a nop right now	229	ns->instantiate (); // effectively a nop right now
237		230
238	INVOKE_CLIENT (CONNECT, ns);
239
240	return ns;	231	return ns;
241	}
242	}	232	}
243		233

Diff Legend

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

Comparing deliantra/server/socket/init.C (file contents): Revision 1.31 by root, Mon Dec 25 11:25:50 2006 UTC vs. Revision 1.66 by root, Thu Apr 8 19:31:22 2010 UTC

Diff Legend

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.31 by root, Mon Dec 25 11:25:50 2006 UTC vs.
Revision 1.66 by root, Thu Apr 8 19:31:22 2010 UTC