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

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.34 by root, Sun Jan 7 02:39:15 2007 UTC vs.
Revision 1.48 by root, Sat Jun 9 23:18:17 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	*
46	#include <unistd.h>	46	#include <unistd.h>
47	#include <arpa/inet.h>	47	#include <arpa/inet.h>
48		48
49	#include <algorithm>	49	#include <algorithm>
50		50
		51	// use relatively small values, as we do not expect to receive much,
		52	// and we do userspace write buffering
		53	// 8kb limits throughput to roughly 66kb/s
		54	#define SOCKET_RCVBUF 8192
		55	#define SOCKET_SNDBUF 16384
		56
51	sockvec clients;	57	sockvec clients;
52		58
53	/**	59	/**
54	* Initializes a connection. Really, it just sets up the data structure,	60	* Initializes a connection. Really, it just sets up the data structure,
55	* socket setup is handled elsewhere. We do send a version to the	61	* socket setup is handled elsewhere. We do send a version to the
56	* client.	62	* client.
57	*/	63	*/
58	client::client (int fd, const char *peername)	64	client::client (int fd, const char *peername)
59	: fd (fd), host (strdup (peername)),	65	: fd (fd), host (strdup (peername)),
60	socket_ev (this, &client::socket_cb),	66	socket_ev (this, &client::socket_cb),
61	cmd_ev (this, &client::cmd_cb),	67	cmd_ev (this, &client::cmd_cb)
62	cc_inv (this), cc_other (this)
63	{	68	{
64	refcnt_inc (); // the socket is an external reference	69	refcnt_inc (); // the socket is an external reference
		70
		71	mss = 1500 - 52; // 1500 typical ethernet frame, 66 typical tcp header overhead
65		72
66	{	73	{
67	struct linger linger_opt;	74	struct linger linger_opt;
68		75
69	linger_opt.l_onoff = 0;	76	linger_opt.l_onoff = 0;
70	linger_opt.l_linger = 0;	77	linger_opt.l_linger = 0;
71		78
72	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))	79	if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger)))
73	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));	80	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
74	}	81	}
75		82
76	{	83	{
		84	int val;
		85
		86	#ifdef SO_RCVBUF
		87	val = SOCKET_RCVBUF;
		88	if (setsockopt (fd, SOL_SOCKET, SO_RCVBUF, &val, sizeof (val)))
		89	LOG (llevError, "SO_RCVBUF: %s\n", strerror (errno));
		90	#endif
		91
		92	#ifdef SO_SNDBUF
		93	val = SOCKET_SNDBUF;
		94	if (setsockopt (fd, SOL_SOCKET, SO_SNDBUF, &val, sizeof (val)))
		95	LOG (llevError, "SO_SNDBUF: %s\n", strerror (errno));
		96	#endif
		97
		98	#ifdef IP_TOS
77	int val = IPTOS_LOWDELAY;	99	val = IPTOS_LOWDELAY;
78
79	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))	100	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
80	LOG (llevError, "IP_TOS: %s\n", strerror (errno));	101	LOG (llevError, "IP_TOS: %s\n", strerror (errno));
81	}	102	#endif
82		103
83	{	104	#ifdef TCP_NODELAY
84	int val = 1;	105	val = 1;
85
86	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))	106	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
87	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));	107	LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno));
		108	#endif
		109
		110	// set some very aggressive keepalive parameters
		111	#ifdef TCP_KEEPIDLE
		112	val = 1;
		113	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val)))
		114	LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno));
		115	#endif
		116
		117	#ifdef TCP_KEEPCNT
		118	val = 3;
		119	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val)))
		120	LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno));
		121	#endif
		122
		123	#ifdef TCP_KEEPINTVL
		124	val = 1;
		125	if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val)))
		126	LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno));
		127	#endif
		128
		129	// try to find the mss value in use
		130	#ifdef TCP_MAXSEG
		131	socklen_t sl = sizeof (val);
		132	if (!getsockopt (fd, IPPROTO_TCP, TCP_MAXSEG, &val, &sl) && sl == sizeof (val))
		133	mss = val;
		134	#endif
88	}	135	}
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		136
109	{	137	{
110	int bufsize = 65535; /Supposed absolute upper limit /	138	int bufsize = 65535; /Supposed absolute upper limit /
111	int oldbufsize;	139	int oldbufsize;
112	int buflen = sizeof (int);	140	int buflen = sizeof (int);
…		…
129	mapmode = Map0Cmd;	157	mapmode = Map0Cmd;
130	darkness = 1;	158	darkness = 1;
131	mapx = 11;	159	mapx = 11;
132	mapy = 11;	160	mapy = 11;
133	itemcmd = 1; /* Default is version item1 command */	161	itemcmd = 1; /* Default is version item1 command */
134		162	max_rate = 100000 / (1000000 / MAX_TIME); // ~1mbit is assumed per default
135	faces_sent = salloc0<uint8> (nrofpixmaps);
136		163
137	/* Do this so we don't send a face command for the client for	164	/* 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	165	* this face. Face 0 is sent to the client to say clear
139	* face information.	166	* face information.
140	*/	167	*/
141	faces_sent[0] = NS_FACESENT_FACE;	168	faces_sent[0] = true;
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
		180	reset_stats ();
		181
157	clients.insert (this);	182	clients.insert (this);
158	}	183	}
159		184
160	client::~client ()	185	client::~client ()
161	{	186	{
162	clients.erase (this);	187	clients.erase (this);
163		188
164	sfree<uint8> (faces_sent, nrofpixmaps);
165	free (stats.range);	189	free (stats.range);
166	free (stats.title);	190	free (stats.title);
167	free (host);	191	free (host);
168	}	192	}
169		193
…		…
189	cmd_ev.suspend ();	213	cmd_ev.suspend ();
190		214
191	refcnt_dec (); // socket no longer open	215	refcnt_dec (); // socket no longer open
192	}	216	}
193		217
194	/** This sets up the socket and reads all the image information into memory. */
195	void	218	void
196	init_ericserver (void)	219	client::reset_stats ()
197	{	220	{
198	cst_tot.time_start = time (NULL);	221	/* we need to clear these to -1 and not zero - otherwise,
199	cst_lst.time_start = time (NULL);	222	* if a player quits and starts a new character, we wont
		223	* send new values to the client, as things like exp start
		224	* at zero.
		225	*/
		226	for (int i = 0; i < NUM_SKILLS; i++)
		227	last_skill_exp[i] = -1;
200		228
201	LOG (llevDebug, "Initialize new client/server data\n");	229	for (int i = 0; i < NROFATTACKS; i++)
		230	last_resist[i] = -1;
202		231
203	read_client_images ();	232	last_weapon_sp = -1;
204	}	233	last_level = -1;
		234	last_stats.exp = -1;
		235	last_weight = (uint32) - 1;
		236	last_flags = 0;
		237	last_weight = 0;
		238	last_weight_limit = 0;
		239	last_path_attuned = 0;
		240	last_path_repelled = 0;
		241	last_path_denied = 0;
		242	last_speed = 0;
		243	last_flags = 0;
205		244
		245	static living zero_living;
		246	last_stats = zero_living;
		247	}
206		248
207	/*******************************************************************************	249	/*******************************************************************************
208	*	250	*
209	* Start of functions dealing with freeing of the data.	251	* Start of functions dealing with freeing of the data.
210	*	252	*
…		…
219	}	261	}
220		262
221	client *	263	client *
222	client::create (int fd, const char *peername)	264	client::create (int fd, const char *peername)
223	{	265	{
224	if (checkbanned (NULL, peername))
225	{
226	LOG (llevInfo, "Banned host tried to connect: [%s]\n", peername);
227	return 0;
228	}
229	else
230	{
231	client *ns = new client (dup (fd), peername);	266	client *ns = new client (dup (fd), peername);
232
233	ns->instantiate (); // effectively a nop right now	267	ns->instantiate (); // effectively a nop right now
234
235	INVOKE_CLIENT (CONNECT, ns);	268	INVOKE_CLIENT (CONNECT, ns);
236
237	return ns;	269	return ns;
238	}
239	}	270	}
240		271

Diff Legend

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

Comparing deliantra/server/socket/init.C (file contents): Revision 1.34 by root, Sun Jan 7 02:39:15 2007 UTC vs. Revision 1.48 by root, Sat Jun 9 23:18:17 2007 UTC

Diff Legend

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.34 by root, Sun Jan 7 02:39:15 2007 UTC vs.
Revision 1.48 by root, Sat Jun 9 23:18:17 2007 UTC