[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.51 by root, Fri Aug 24 00:26:10 2007 UTC

…		…
1	/*	1	/*
2	CrossFire, A Multiplayer game for X-windows	2	* This file is part of Crossfire TRT, the Roguelike Realtime MORPG.
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
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 2 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,
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 GNU General Public License	18	* You should have received a copy of the GNU General Public License
19	along with this program; if not, write to the Free Software	19	* along with this program. If not, see <http://www.gnu.org/licenses/>.
20	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.	20	*
21
22	The author can be reached via e-mail to <crossfire@schmorp.de>	21	* The authors can be reached via e-mail to <crossfire@schmorp.de>
23	*/	22	*/
24		23
25	/**	24	/**
26	* \file	25	* \file
27	* Socket general functions	26	* Socket general functions
28	*	27	*
46	#include <unistd.h>	45	#include <unistd.h>
47	#include <arpa/inet.h>	46	#include <arpa/inet.h>
48		47
49	#include <algorithm>	48	#include <algorithm>
50		49
		50	// use relatively small values, as we do not expect to receive much,
		51	// and we do userspace write buffering
		52	// 8kb limits throughput to roughly 66kb/s
		53	#define SOCKET_RCVBUF 8192
		54	#define SOCKET_SNDBUF 16384
		55
51	sockvec clients;	56	sockvec clients;
52		57
53	/**	58	/**
54	* Initializes a connection. Really, it just sets up the data structure,	59	* Initializes a connection. Really, it just sets up the data structure,
55	* socket setup is handled elsewhere. We do send a version to the	60	* socket setup is handled elsewhere. We do send a version to the
56	* client.	61	* client.
57	*/	62	*/
58	client::client (int fd, const char *peername)	63	client::client (int fd, const char *peername)
59	: fd (fd), host (strdup (peername)),	64	: fd (fd), host (strdup (peername)),
60	socket_ev (this, &client::socket_cb),	65	socket_ev (this, &client::socket_cb),
61	cmd_ev (this, &client::cmd_cb),	66	cmd_ev (this, &client::cmd_cb)
62	cc_inv (this), cc_other (this)
63	{	67	{
64	refcnt_inc (); // the socket is an external reference	68	refcnt_inc (); // the socket is an external reference
		69
		70	mss = 1500 - 52; // 1500 typical ethernet frame, 66 typical tcp header overhead
65		71
66	{	72	{
67	struct linger linger_opt;	73	struct linger linger_opt;
68		74
69	linger_opt.l_onoff = 0;	75	linger_opt.l_onoff = 0;
70	linger_opt.l_linger = 0;	76	linger_opt.l_linger = 0;
71		77
72	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))	78	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))
73	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));	79	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
74	}	80	}
75		81
76	{	82	{
		83	int val;
		84
		85	#ifdef SO_RCVBUF
		86	val = SOCKET_RCVBUF;
		87	if (setsockopt (fd, SOL_SOCKET, SO_RCVBUF, &val, sizeof (val)))
		88	LOG (llevError, "SO_RCVBUF: %s\n", strerror (errno));
		89	#endif
		90
		91	#ifdef SO_SNDBUF
		92	val = SOCKET_SNDBUF;
		93	if (setsockopt (fd, SOL_SOCKET, SO_SNDBUF, &val, sizeof (val)))
		94	LOG (llevError, "SO_SNDBUF: %s\n", strerror (errno));
		95	#endif
		96
		97	#ifdef IP_TOS
77	int val = IPTOS_LOWDELAY;	98	val = IPTOS_LOWDELAY;
78
79	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))	99	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
80	LOG (llevError, "IP_TOS: %s\n", strerror (errno));	100	LOG (llevError, "IP_TOS: %s\n", strerror (errno));
81	}	101	#endif
82		102
83	{	103	#ifdef TCP_NODELAY
84	int val = 1;	104	val = 1;
85
86	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))	105	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
87	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));	106	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));
		107	#endif
		108
		109	// set some very aggressive keepalive parameters
		110	#ifdef TCP_KEEPIDLE
		111	val = 1;
		112	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
		113	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
		114	#endif
		115
		116	#ifdef TCP_KEEPCNT
		117	val = 3;
		118	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
		119	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
		120	#endif
		121
		122	#ifdef TCP_KEEPINTVL
		123	val = 1;
		124	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
		125	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
		126	#endif
		127
		128	// try to find the mss value in use
		129	#ifdef TCP_MAXSEG
		130	socklen_t sl = sizeof (val);
		131	if (!getsockopt (fd, IPPROTO_TCP, TCP_MAXSEG, &val, &sl) && sl == sizeof (val))
		132	mss = val;
		133	#endif
88	}	134	}
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		135
109	{	136	{
110	int bufsize = 65535; /Supposed absolute upper limit /	137	int bufsize = 65535; /Supposed absolute upper limit /
111	int oldbufsize;	138	int oldbufsize;
112	int buflen = sizeof (int);	139	int buflen = sizeof (int);
…		…
129	mapmode = Map0Cmd;	156	mapmode = Map0Cmd;
130	darkness = 1;	157	darkness = 1;
131	mapx = 11;	158	mapx = 11;
132	mapy = 11;	159	mapy = 11;
133	itemcmd = 1; /* Default is version item1 command */	160	itemcmd = 1; /* Default is version item1 command */
134		161	max_rate = 100000 / (1000000 / MAX_TIME); // ~1mbit is assumed per default
135	faces_sent = salloc0<uint8> (nrofpixmaps);
136		162
137	/* Do this so we don't send a face command for the client for	163	/* 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	164	* this face. Face 0 is sent to the client to say clear
139	* face information.	165	* face information.
140	*/	166	*/
141	faces_sent[0] = NS_FACESENT_FACE;	167	faces_sent[0] = true;
		168	fx_want [FT_FACE] = true; // all clients must support image faces
142		169
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);	170	socket_ev.prio (PE_PRIO_NORMAL);
146	socket_ev.fd (fd);	171	socket_ev.fd (fd);
147	socket_ev.poll (PE_R);	172	socket_ev.poll (PE_R);
148		173
149	// command handling is even lower priority
150	// that way no client can monopolise the server
151	cmd_ev.prio (PE_PRIO_NORMAL + 2);	174	cmd_ev.prio (PE_PRIO_NORMAL);
152		175
153	// initialisation done, kick it!	176	// initialisation done, kick it!
154	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);	177	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);
155	flush ();	178	flush ();
156		179
…		…
161		184
162	client::~client ()	185	client::~client ()
163	{	186	{
164	clients.erase (this);	187	clients.erase (this);
165		188
166	sfree<uint8> (faces_sent, nrofpixmaps);	189	mapinfo_queue_clear ();
167	free (stats.range);	190	free (stats.range);
168	free (stats.title);	191	free (stats.title);
169	free (host);	192	free (host);
170	}	193	}
171		194
…		…
216	last_weight_limit = 0;	239	last_weight_limit = 0;
217	last_path_attuned = 0;	240	last_path_attuned = 0;
218	last_path_repelled = 0;	241	last_path_repelled = 0;
219	last_path_denied = 0;	242	last_path_denied = 0;
220	last_speed = 0;	243	last_speed = 0;
221	flags = 0;	244	last_flags = 0;
222		245
223	static living zero_living;	246	static living zero_living;
224	last_stats = zero_living;	247	last_stats = zero_living;
225	}	248	}
226		249
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
240	/*******************************************************************************
241	*
242	* Start of functions dealing with freeing of the data.
243	*
244	******************************************************************************/
245
246	/** Free's all the memory that ericserver allocates. */
247	void
248	free_all_newserver (void)
249	{
250	LOG (llevDebug, "Freeing all new client/server information.\n");
251	free_socket_images ();
252	}
253
254	client *	250	client *
255	client::create (int fd, const char *peername)	251	client::create (int fd, const char *peername)
256	{	252	{
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);	253	client *ns = new client (dup (fd), peername);
265
266	ns->instantiate (); // effectively a nop right now	254	ns->instantiate (); // effectively a nop right now
267
268	INVOKE_CLIENT (CONNECT, ns);	255	INVOKE_CLIENT (CONNECT, ns);
269
270	return ns;	256	return ns;
271	}
272	}	257	}
273		258

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.51 by root, Fri Aug 24 00:26:10 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.51 by root, Fri Aug 24 00:26:10 2007 UTC