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

Comparing deliantra/server/socket/init.C (file contents):
Revision 1.36 by pippijn, Sat Jan 20 13:47:17 2007 UTC vs.
Revision 1.45 by root, Fri Apr 27 03:22:29 2007 UTC

…		…
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		230
…		…
230	{	234	{
231	cst_tot.time_start = time (NULL);	235	cst_tot.time_start = time (NULL);
232	cst_lst.time_start = time (NULL);	236	cst_lst.time_start = time (NULL);
233		237
234	LOG (llevDebug, "Initialize new client/server data\n");	238	LOG (llevDebug, "Initialize new client/server data\n");
235
236	read_client_images ();
237	}	239	}
238
239		240
240	/*******************************************************************************	241	/*******************************************************************************
241	*	242	*
242	* Start of functions dealing with freeing of the data.	243	* Start of functions dealing with freeing of the data.
243	*	244	*
…		…
252	}	253	}
253		254
254	client *	255	client *
255	client::create (int fd, const char *peername)	256	client::create (int fd, const char *peername)
256	{	257	{
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);	258	client *ns = new client (dup (fd), peername);
265
266	ns->instantiate (); // effectively a nop right now	259	ns->instantiate (); // effectively a nop right now
267
268	INVOKE_CLIENT (CONNECT, ns);	260	INVOKE_CLIENT (CONNECT, ns);
269
270	return ns;	261	return ns;
271	}
272	}	262	}
273		263

Diff Legend

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

Comparing deliantra/server/socket/init.C (file contents): Revision 1.36 by pippijn, Sat Jan 20 13:47:17 2007 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.36 by pippijn, Sat Jan 20 13:47:17 2007 UTC vs.
Revision 1.45 by root, Fri Apr 27 03:22:29 2007 UTC