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

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.32 by root, Wed Dec 27 05:32:26 2006 UTC vs.
Revision 1.45 by root, Fri Apr 27 03:22:29 2007 UTC

…		…
1	/*	1	/*
2	CrossFire, A Multiplayer game for X-windows	2	* CrossFire, A Multiplayer game for X-windows
3		3	*
		4	* Copyright (C) 2005, 2006, 2007 Marc Lehmann & Crossfire+ Development Team
4	Copyright (C) 2001 Mark Wedel	5	* Copyright (C) 2001 Mark Wedel
5	Copyright (C) 1992 Frank Tore Johansen	6	* Copyright (C) 1992 Frank Tore Johansen
6		7	*
7	This program is free software; you can redistribute it and/or modify	8	* 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	9	* it under the terms of the GNU General Public License as published by
9	the Free Software Foundation; either version 2 of the License, or	10	* the Free Software Foundation; either version 2 of the License, or
10	(at your option) any later version.	11	* (at your option) any later version.
11		12	*
12	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,
13	but WITHOUT ANY WARRANTY; without even the implied warranty of	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
14	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15	GNU General Public License for more details.	16	* GNU General Public License for more details.
16		17	*
17	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
18	along with this program; if not, write to the Free Software	19	* along with this program; if not, write to the Free Software
19	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.	20	* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20		21	*
21	The author can be reached via e-mail to <crossfire@schmorp.de>	22	* The author can be reached via e-mail to <crossfire@schmorp.de>
22	*/	23	*/
23		24
24	/**	25	/**
25	* \file	26	* \file
26	* Socket general functions	27	* Socket general functions
27	*	28	*
55	* client.	56	* client.
56	*/	57	*/
57	client::client (int fd, const char *peername)	58	client::client (int fd, const char *peername)
58	: fd (fd), host (strdup (peername)),	59	: fd (fd), host (strdup (peername)),
59	socket_ev (this, &client::socket_cb),	60	socket_ev (this, &client::socket_cb),
60	cmd_ev (this, &client::cmd_cb),	61	cmd_ev (this, &client::cmd_cb)
61	cc_inv (this), cc_other (this)
62	{	62	{
		63	refcnt_inc (); // the socket is an external reference
		64
		65	mss = 1500 - 52; // 1500 typical ethernet frame, 66 typical tcp header overhead
		66
63	{	67	{
64	struct linger linger_opt;	68	struct linger linger_opt;
65		69
66	linger_opt.l_onoff = 0;	70	linger_opt.l_onoff = 0;
67	linger_opt.l_linger = 0;	71	linger_opt.l_linger = 0;
68		72
69	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)))
70	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));	74	LOG (llevError, "SO_LINGER: %s\n", strerror (errno));
71	}	75	}
72		76
73	{	77	{
		78	int val;
		79
		80	#ifdef IP_TOS
74	int val = IPTOS_LOWDELAY;	81	val = IPTOS_LOWDELAY;
75
76	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))	82	if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val)))
77	LOG (llevError, "IP_TOS: %s\n", strerror (errno));	83	LOG (llevError, "IP_TOS: %s\n", strerror (errno));
78	}	84	#endif
79		85
80	{	86	#ifdef TCP_NODELAY
81	int val = 1;	87	val = 1;
82
83	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))	88	if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val)))
84	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
85	}	117	}
86
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		118
106	{	119	{
107	int bufsize = 65535; /Supposed absolute upper limit /	120	int bufsize = 65535; /Supposed absolute upper limit /
108	int oldbufsize;	121	int oldbufsize;
109	int buflen = sizeof (int);	122	int buflen = sizeof (int);
…		…
126	mapmode = Map0Cmd;	139	mapmode = Map0Cmd;
127	darkness = 1;	140	darkness = 1;
128	mapx = 11;	141	mapx = 11;
129	mapy = 11;	142	mapy = 11;
130	itemcmd = 1; /* Default is version item1 command */	143	itemcmd = 1; /* Default is version item1 command */
131		144	max_rate = 100000 / (1000000 / MAX_TIME); // ~1mbit is assumed per default
132	faces_sent = salloc0<uint8> (nrofpixmaps);
133		145
134	/* 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
135	* 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
136	* face information.	148	* face information.
137	*/	149	*/
138	faces_sent[0] = NS_FACESENT_FACE;	150	faces_sent[0] = true;
139		151
140	// socket I/O is low priority
141	// we prefer to have the server run instead of handling client requests
142	socket_ev.prio (PE_PRIO_NORMAL + 1);	152	socket_ev.prio (PE_PRIO_NORMAL);
143	socket_ev.fd (fd);	153	socket_ev.fd (fd);
144	socket_ev.poll (PE_R);	154	socket_ev.poll (PE_R);
145		155
146	// command handling is even lower priority
147	// that way no client can monopolise the server
148	cmd_ev.prio (PE_PRIO_NORMAL + 2);	156	cmd_ev.prio (PE_PRIO_NORMAL);
149		157
150	// initialisation done, kick it!	158	// initialisation done, kick it!
151	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);
152	flush ();	160	flush ();
153		161
154	// clients are externally referenced by the socket	162	reset_stats ();
155	refcnt_inc ();
156	clients.push_back (this);
157		163
158	#if 0//TODO	164	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	}	165	}
164		166
165	client::~client ()	167	client::~client ()
166	{	168	{
167	sockvec::iterator i = find (clients.begin (), clients.end (), this);
168	if (i != clients.end ())
169	clients.erase (i);	169	clients.erase (this);
170		170
171	sfree<uint8> (faces_sent, nrofpixmaps);
172	free (stats.range);	171	free (stats.range);
173	free (stats.title);	172	free (stats.title);
174	free (host);	173	free (host);
175	}	174	}
176		175
…		…
181		180
182	if (pl)	181	if (pl)
183	pl->disconnect ();	182	pl->disconnect ();
184		183
185	if (fd >= 0)	184	if (fd >= 0)
		185	{
		186	send_packet ("goodbye");
		187	flush ();
		188
186	close (fd);	189	close (fd);
		190	}
187		191
188	state = ST_DEAD;	192	state = ST_DEAD;
189		193
190	socket_ev.suspend ();	194	socket_ev.suspend ();
191	cmd_ev.suspend ();	195	cmd_ev.suspend ();
192		196
193	// socket now longer references us	197	refcnt_dec (); // socket no longer open
194	refcnt_dec ();	198	}
		199
		200	void
		201	client::reset_stats ()
		202	{
		203	/* we need to clear these to -1 and not zero - otherwise,
		204	* if a player quits and starts a new character, we wont
		205	* send new values to the client, as things like exp start
		206	* at zero.
		207	*/
		208	for (int i = 0; i < NUM_SKILLS; i++)
		209	last_skill_exp[i] = -1;
		210
		211	for (int i = 0; i < NROFATTACKS; i++)
		212	last_resist[i] = -1;
		213
		214	last_weapon_sp = -1;
		215	last_level = -1;
		216	last_stats.exp = -1;
		217	last_weight = (uint32) - 1;
		218	last_flags = 0;
		219	last_weight = 0;
		220	last_weight_limit = 0;
		221	last_path_attuned = 0;
		222	last_path_repelled = 0;
		223	last_path_denied = 0;
		224	last_speed = 0;
		225	last_flags = 0;
		226
		227	static living zero_living;
		228	last_stats = zero_living;
195	}	229	}
196		230
197	/** This sets up the socket and reads all the image information into memory. */	231	/** This sets up the socket and reads all the image information into memory. */
198	void	232	void
199	init_ericserver (void)	233	init_ericserver (void)
200	{	234	{
201	cst_tot.time_start = time (NULL);	235	cst_tot.time_start = time (NULL);
202	cst_lst.time_start = time (NULL);	236	cst_lst.time_start = time (NULL);
203		237
204	LOG (llevDebug, "Initialize new client/server data\n");	238	LOG (llevDebug, "Initialize new client/server data\n");
205
206	read_client_images ();
207	}	239	}
208
209		240
210	/*******************************************************************************	241	/*******************************************************************************
211	*	242	*
212	* Start of functions dealing with freeing of the data.	243	* Start of functions dealing with freeing of the data.
213	*	244	*
…		…
222	}	253	}
223		254
224	client *	255	client *
225	client::create (int fd, const char *peername)	256	client::create (int fd, const char *peername)
226	{	257	{
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);	258	client *ns = new client (dup (fd), peername);
235
236	ns->instantiate (); // effectively a nop right now	259	ns->instantiate (); // effectively a nop right now
237
238	INVOKE_CLIENT (CONNECT, ns);	260	INVOKE_CLIENT (CONNECT, ns);
239
240	return ns;	261	return ns;
241	}
242	}	262	}
243		263

Diff Legend

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

Comparing deliantra/server/socket/init.C (file contents): Revision 1.32 by root, Wed Dec 27 05:32:26 2006 UTC vs. Revision 1.45 by root, Fri Apr 27 03:22:29 2007 UTC

Diff Legend

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.32 by root, Wed Dec 27 05:32:26 2006 UTC vs.
Revision 1.45 by root, Fri Apr 27 03:22:29 2007 UTC