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

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.35 by root, Mon Jan 8 18:18:36 2007 UTC vs.
Revision 1.47 by root, Sat Jun 9 22:54:03 2007 UTC

…		…
1	/*	1	/*
2	CrossFire, A Multiplayer game for X-windows	2	* This file is part of Crossfire TRT, the Multiplayer Online Role Playing Game.
3		3	*
4	Copyright (C) 2005, 2006, 2007 Marc Lehmann & Crossfire+ Development Team	4	* Copyright (©) 2005,2006,2007 Marc Alexander Lehmann / Robin Redeker / the Crossfire TRT team
5	Copyright (C) 2001 Mark Wedel	5	* Copyright (©) 2001,2007 Mark Wedel
6	Copyright (C) 1992 Frank Tore Johansen	6	* Copyright (©) 1992,2007 Frank Tore Johansen
7		7	*
8	This program is free software; you can redistribute it and/or modify	8	* Crossfire TRT is free software; you can redistribute it and/or modify it
9	it under the terms of the GNU General Public License as published by	9	* under the terms of the GNU General Public License as published by the Free
10	the Free Software Foundation; either version 2 of the License, or	10	* Software Foundation; either version 2 of the License, or (at your option)
11	(at your option) any later version.	11	* 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, but
14	but WITHOUT ANY WARRANTY; without even the implied warranty of	14	* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
15	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	15	* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
16	GNU General Public License for more details.	16	* 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 along
19	along with this program; if not, write to the Free Software	19	* with Crossfire TRT; if not, write to the Free Software Foundation, Inc. 51
20	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.	20	* Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
21		21	*
22	The author can be reached via e-mail to <crossfire@schmorp.de>	22	* The authors can be reached via e-mail to <crossfire@schmorp.de>
23	*/	23	*/
24		24
25	/**	25	/**
26	* \file	26	* \file
27	* Socket general functions	27	* Socket general functions
28	*	28	*
56	* client.	56	* client.
57	*/	57	*/
58	client::client (int fd, const char *peername)	58	client::client (int fd, const char *peername)
59	: fd (fd), host (strdup (peername)),	59	: fd (fd), host (strdup (peername)),
60	socket_ev (this, &client::socket_cb),	60	socket_ev (this, &client::socket_cb),
61	cmd_ev (this, &client::cmd_cb),	61	cmd_ev (this, &client::cmd_cb)
62	cc_inv (this), cc_other (this)
63	{	62	{
64	refcnt_inc (); // the socket is an external reference	63	refcnt_inc (); // the socket is an external reference
		64
		65	mss = 1500 - 52; // 1500 typical ethernet frame, 66 typical tcp header overhead
65		66
66	{	67	{
67	struct linger linger_opt;	68	struct linger linger_opt;
68		69
69	linger_opt.l_onoff = 0;	70	linger_opt.l_onoff = 0;
70	linger_opt.l_linger = 0;	71	linger_opt.l_linger = 0;
71		72
72	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))	73	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))
73	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));	74	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
74	}	75	}
75		76
76	{	77	{
		78	int val;
		79
		80	#ifdef IP_TOS
77	int val = IPTOS_LOWDELAY;	81	val = IPTOS_LOWDELAY;
78
79	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))	82	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
80	LOG (llevError, "IP_TOS: %s\n", strerror (errno));	83	LOG (llevError, "IP_TOS: %s\n", strerror (errno));
81	}	84	#endif
82		85
83	{	86	#ifdef TCP_NODELAY
84	int val = 1;	87	val = 1;
85
86	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))	88	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
87	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));	89	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));
		90	#endif
		91
		92	// set some very aggressive keepalive parameters
		93	#ifdef TCP_KEEPIDLE
		94	val = 1;
		95	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
		96	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
		97	#endif
		98
		99	#ifdef TCP_KEEPCNT
		100	val = 3;
		101	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
		102	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
		103	#endif
		104
		105	#ifdef TCP_KEEPINTVL
		106	val = 1;
		107	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
		108	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
		109	#endif
		110
		111	// try to find the mss value in use
		112	#ifdef TCP_MAXSEG
		113	socklen_t sl = sizeof (val);
		114	if (!getsockopt (fd, IPPROTO_TCP, TCP_MAXSEG, &val, &sl) && sl == sizeof (val))
		115	mss = val;
		116	#endif
88	}	117	}
89
90	#ifdef __linux__
91	{
92	int val;
93
94	// set some very aggressive keepalive parameters
95	val = 10;
96	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
97	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
98
99	val = 5;
100	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
101	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
102
103	val = 1;
104	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
105	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
106	}
107	#endif
108		118
109	{	119	{
110	int bufsize = 65535; /Supposed absolute upper limit /	120	int bufsize = 65535; /Supposed absolute upper limit /
111	int oldbufsize;	121	int oldbufsize;
112	int buflen = sizeof (int);	122	int buflen = sizeof (int);
…		…
129	mapmode = Map0Cmd;	139	mapmode = Map0Cmd;
130	darkness = 1;	140	darkness = 1;
131	mapx = 11;	141	mapx = 11;
132	mapy = 11;	142	mapy = 11;
133	itemcmd = 1; /* Default is version item1 command */	143	itemcmd = 1; /* Default is version item1 command */
134		144	max_rate = 100000 / (1000000 / MAX_TIME); // ~1mbit is assumed per default
135	faces_sent = salloc0<uint8> (nrofpixmaps);
136		145
137	/* Do this so we don't send a face command for the client for	146	/* Do this so we don't send a face command for the client for
138	* this face. Face 0 is sent to the client to say clear	147	* this face. Face 0 is sent to the client to say clear
139	* face information.	148	* face information.
140	*/	149	*/
141	faces_sent[0] = NS_FACESENT_FACE;	150	faces_sent[0] = true;
142		151
143	// socket I/O is low priority
144	// we prefer to have the server run instead of handling client requests
145	socket_ev.prio (PE_PRIO_NORMAL + 1);	152	socket_ev.prio (PE_PRIO_NORMAL);
146	socket_ev.fd (fd);	153	socket_ev.fd (fd);
147	socket_ev.poll (PE_R);	154	socket_ev.poll (PE_R);
148		155
149	// command handling is even lower priority
150	// that way no client can monopolise the server
151	cmd_ev.prio (PE_PRIO_NORMAL + 2);	156	cmd_ev.prio (PE_PRIO_NORMAL);
152		157
153	// initialisation done, kick it!	158	// initialisation done, kick it!
154	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);	159	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);
155	flush ();	160	flush ();
156		161
…		…
161		166
162	client::~client ()	167	client::~client ()
163	{	168	{
164	clients.erase (this);	169	clients.erase (this);
165		170
166	sfree<uint8> (faces_sent, nrofpixmaps);
167	free (stats.range);	171	free (stats.range);
168	free (stats.title);	172	free (stats.title);
169	free (host);	173	free (host);
170	}	174	}
171		175
…		…
216	last_weight_limit = 0;	220	last_weight_limit = 0;
217	last_path_attuned = 0;	221	last_path_attuned = 0;
218	last_path_repelled = 0;	222	last_path_repelled = 0;
219	last_path_denied = 0;	223	last_path_denied = 0;
220	last_speed = 0;	224	last_speed = 0;
221	flags = 0;	225	last_flags = 0;
222		226
223	static living zero_living;	227	static living zero_living;
224	last_stats = zero_living;	228	last_stats = zero_living;
225	}	229	}
226
227	/** This sets up the socket and reads all the image information into memory. */
228	void
229	init_ericserver (void)
230	{
231	cst_tot.time_start = time (NULL);
232	cst_lst.time_start = time (NULL);
233
234	LOG (llevDebug, "Initialize new client/server data\n");
235
236	read_client_images ();
237	}
238
239		230
240	/*******************************************************************************	231	/*******************************************************************************
241	*	232	*
242	* Start of functions dealing with freeing of the data.	233	* Start of functions dealing with freeing of the data.
243	*	234	*
…		…
252	}	243	}
253		244
254	client *	245	client *
255	client::create (int fd, const char *peername)	246	client::create (int fd, const char *peername)
256	{	247	{
257	if (checkbanned (NULL, peername))
258	{
259	LOG (llevInfo, "Banned host tried to connect: [%s]\n", peername);
260	return 0;
261	}
262	else
263	{
264	client *ns = new client (dup (fd), peername);	248	client *ns = new client (dup (fd), peername);
265
266	ns->instantiate (); // effectively a nop right now	249	ns->instantiate (); // effectively a nop right now
267
268	INVOKE_CLIENT (CONNECT, ns);	250	INVOKE_CLIENT (CONNECT, ns);
269
270	return ns;	251	return ns;
271	}
272	}	252	}
273		253

Diff Legend

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

Comparing deliantra/server/socket/init.C (file contents): Revision 1.35 by root, Mon Jan 8 18:18:36 2007 UTC vs. Revision 1.47 by root, Sat Jun 9 22:54:03 2007 UTC

Diff Legend

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.35 by root, Mon Jan 8 18:18:36 2007 UTC vs.
Revision 1.47 by root, Sat Jun 9 22:54:03 2007 UTC