[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.49 by root, Sun Jul 1 05:00:20 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;
142		168
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);	169	socket_ev.prio (PE_PRIO_NORMAL);
146	socket_ev.fd (fd);	170	socket_ev.fd (fd);
147	socket_ev.poll (PE_R);	171	socket_ev.poll (PE_R);
148		172
149	// command handling is even lower priority
150	// that way no client can monopolise the server
151	cmd_ev.prio (PE_PRIO_NORMAL + 2);	173	cmd_ev.prio (PE_PRIO_NORMAL);
152		174
153	// initialisation done, kick it!	175	// initialisation done, kick it!
154	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);	176	send_packet_printf ("version %d %d %s\n", VERSION_CS, VERSION_SC, VERSION_INFO);
155	flush ();	177	flush ();
156		178
		179	reset_stats ();
		180
157	clients.insert (this);	181	clients.insert (this);
158	}	182	}
159		183
160	client::~client ()	184	client::~client ()
161	{	185	{
162	clients.erase (this);	186	clients.erase (this);
163		187
164	sfree<uint8> (faces_sent, nrofpixmaps);
165	free (stats.range);	188	free (stats.range);
166	free (stats.title);	189	free (stats.title);
167	free (host);	190	free (host);
168	}	191	}
169		192
…		…
189	cmd_ev.suspend ();	212	cmd_ev.suspend ();
190		213
191	refcnt_dec (); // socket no longer open	214	refcnt_dec (); // socket no longer open
192	}	215	}
193		216
194	/** This sets up the socket and reads all the image information into memory. */
195	void	217	void
196	init_ericserver (void)	218	client::reset_stats ()
197	{	219	{
198	cst_tot.time_start = time (NULL);	220	/* we need to clear these to -1 and not zero - otherwise,
199	cst_lst.time_start = time (NULL);	221	* if a player quits and starts a new character, we wont
		222	* send new values to the client, as things like exp start
		223	* at zero.
		224	*/
		225	for (int i = 0; i < NUM_SKILLS; i++)
		226	last_skill_exp[i] = -1;
200		227
201	LOG (llevDebug, "Initialize new client/server data\n");	228	for (int i = 0; i < NROFATTACKS; i++)
		229	last_resist[i] = -1;
202		230
203	read_client_images ();	231	last_weapon_sp = -1;
204	}	232	last_level = -1;
		233	last_stats.exp = -1;
		234	last_weight = (uint32) - 1;
		235	last_flags = 0;
		236	last_weight = 0;
		237	last_weight_limit = 0;
		238	last_path_attuned = 0;
		239	last_path_repelled = 0;
		240	last_path_denied = 0;
		241	last_speed = 0;
		242	last_flags = 0;
205		243
		244	static living zero_living;
		245	last_stats = zero_living;
		246	}
206		247
207	/*******************************************************************************	248	/*******************************************************************************
208	*	249	*
209	* Start of functions dealing with freeing of the data.	250	* Start of functions dealing with freeing of the data.
210	*	251	*
…		…
219	}	260	}
220		261
221	client *	262	client *
222	client::create (int fd, const char *peername)	263	client::create (int fd, const char *peername)
223	{	264	{
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);	265	client *ns = new client (dup (fd), peername);
232
233	ns->instantiate (); // effectively a nop right now	266	ns->instantiate (); // effectively a nop right now
234
235	INVOKE_CLIENT (CONNECT, ns);	267	INVOKE_CLIENT (CONNECT, ns);
236
237	return ns;	268	return ns;
238	}
239	}	269	}
240		270

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.49 by root, Sun Jul 1 05:00:20 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.49 by root, Sun Jul 1 05:00:20 2007 UTC