fixed bumpmapping! now looks correct
[divverent/darkplaces.git] / net_master.c
1 /*
2 Copyright (C) 2002 Mathieu Olivier
3
4 This program is free software; you can redistribute it and/or
5 modify it under the terms of the GNU General Public License
6 as published by the Free Software Foundation; either version 2
7 of the License, or (at your option) any later version.
8
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
12
13 See the GNU General Public License for more details.
14
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
18
19 */
20 // net_master.c
21
22 #include "quakedef.h"
23
24
25 cvar_t sv_public = {0, "sv_public", "0"};
26 cvar_t sv_heartbeatperiod = {CVAR_SAVE, "sv_heartbeatperiod", "180"};
27
28 cvar_t sv_masters [] =
29 {
30         {CVAR_SAVE, "sv_master1", ""},
31         {CVAR_SAVE, "sv_master2", ""},
32         {CVAR_SAVE, "sv_master3", ""},
33         {CVAR_SAVE, "sv_master4", ""},
34         {0, "sv_masterextra1", "rick.cube-sol.net"},
35         {0, "sv_masterextra2", "198.88.152.4"},
36         {0, "sv_masterextra3", "68.102.242.12"}
37 };
38
39 static double nextheartbeattime = 0;
40
41
42 /*
43 ====================
44 Master_AllowHeartbeat
45
46 Allow (or not) NET_Heartbeat to proceed depending on various factors
47 ====================
48 */
49 qboolean Master_AllowHeartbeat (int priority)
50 {
51         // LordHavoc: make advertising optional
52         if (!sv_public.integer)
53                 return false;
54         // LordHavoc: don't advertise singleplayer games
55         if (svs.maxclients < 2)
56                 return false;
57         // if it's a state change (client connected), limit next heartbeat to no
58         // more than 30 sec in the future
59         if (priority == 1 && nextheartbeattime > realtime + 30.0)
60                 nextheartbeattime = realtime + 30.0;
61         if (priority <= 1 && realtime < nextheartbeattime)
62                 return false;
63         // limit heartbeatperiod to 30 to 270 second range,
64         // lower limit is to avoid abusing master servers with excess traffic,
65         // upper limit is to avoid timing out on the master server (which uses
66         // 300 sec timeout)
67         if (sv_heartbeatperiod.value < 30)
68                 Cvar_SetValueQuick(&sv_heartbeatperiod, 30);
69         if (sv_heartbeatperiod.value > 270)
70                 Cvar_SetValueQuick(&sv_heartbeatperiod, 270);
71         // send a heartbeat as often as the admin wants
72         nextheartbeattime = realtime + sv_heartbeatperiod.value;
73         return true;
74 }
75
76
77 /*
78 ====================
79 Master_BuildGetServers
80
81 Build a getservers request for a master server
82 ====================
83 */
84 const char* Master_BuildGetServers (void)
85 {
86         static int nextmaster = 0;
87         cvar_t* sv_master;
88         char request [256];
89
90         if (nextmaster >= (int)(sizeof (sv_masters) / sizeof (sv_masters[0])))
91         {
92                 nextmaster = 0;
93                 return NULL;
94         }
95
96         // find a non-empty master server address in the list
97         for(;;)
98         {
99                 sv_master = &sv_masters[nextmaster++];
100                 if (sv_master->string[0])
101                         break;
102                 if (nextmaster >= (int)(sizeof (sv_masters) / sizeof (sv_masters[0])))
103                 {
104                         nextmaster = 0;
105                         return NULL;
106                 }
107         }
108
109         // Build the heartbeat
110         snprintf (request, sizeof (request), "getservers %s %u empty full\x0A", gamename, NET_PROTOCOL_VERSION);
111         SZ_Clear (&net_message);
112         MSG_WriteLong (&net_message, -1);
113         MSG_WriteString (&net_message, request);
114
115         net_message.cursize--;  // we don't send the trailing '\0'
116
117         return sv_master->string;
118 }
119
120
121 /*
122 ====================
123 Master_BuildHeartbeat
124
125 Build an heartbeat for a master server
126 ====================
127 */
128 const char* Master_BuildHeartbeat (void)
129 {
130         static int nextmaster = 0;
131         cvar_t* sv_master;
132
133         if (nextmaster >= (int)(sizeof (sv_masters) / sizeof (sv_masters[0])))
134         {
135                 nextmaster = 0;
136                 return NULL;
137         }
138
139         // find a non-empty master server address in the list
140         for(;;)
141         {
142                 sv_master = &sv_masters[nextmaster++];
143                 if (sv_master->string[0])
144                         break;
145                 if (nextmaster >= (int)(sizeof (sv_masters) / sizeof (sv_masters[0])))
146                 {
147                         nextmaster = 0;
148                         return NULL;
149                 }
150         }
151
152         // Build the heartbeat
153         SZ_Clear (&net_message);
154         MSG_WriteLong (&net_message, -1);
155         MSG_WriteString (&net_message, "heartbeat DarkPlaces\x0A");
156
157         net_message.cursize--;  // we don't send the trailing '\0'
158
159         return sv_master->string;
160 }
161
162
163 /*
164 ====================
165 Master_HandleMessage
166
167 Handle the master server messages
168 ====================
169 */
170 int Master_HandleMessage (void)
171 {
172         const char* string = MSG_ReadString ();
173
174         // If it's a "getinfo" request
175         if (!strncmp (string, "getinfo", 7))
176         {
177                 char response [512];
178                 size_t length;
179
180                 length = snprintf (response, sizeof (response), "infoResponse\x0A"
181                                         "\\gamename\\%s\\modname\\%s\\sv_maxclients\\%d"
182                                         "\\clients\\%d\\mapname\\%s\\hostname\\%s\\protocol\\%d",
183                                         gamename, com_modname, svs.maxclients, net_activeconnections,
184                                         sv.name, hostname.string, NET_PROTOCOL_VERSION);
185
186                 // Too long to fit into the buffer?
187                 if (length >= sizeof (response))
188                         return -1;
189
190                 // If there was a challenge in the getinfo message
191                 if (string[7] == ' ')
192                 {
193                         string += 8;  // skip the header and the space
194
195                         // If the challenge wouldn't fit into the buffer
196                         if (length + 11 + strlen (string) >= sizeof (response))
197                                 return -1;
198
199                         sprintf (response + length, "\\challenge\\%s", string);
200                 }
201
202                 SZ_Clear (&net_message);
203                 MSG_WriteLong (&net_message, -1);
204                 MSG_WriteString (&net_message, response);
205
206                 return net_message.cursize - 1;
207         }
208
209         return 0;
210 }
211
212
213 /*
214 ====================
215 Master_Init
216
217 Initialize the code that handles master server requests and reponses
218 ====================
219 */
220 void Master_Init (void)
221 {
222         unsigned int ind;
223         Cvar_RegisterVariable (&sv_public);
224         Cvar_RegisterVariable (&sv_heartbeatperiod);
225         for (ind = 0; ind < sizeof (sv_masters) / sizeof (sv_masters[0]); ind++)
226                 Cvar_RegisterVariable (&sv_masters[ind]);
227 }
228
229
230 /*
231 ====================
232 Master_ParseServerList
233
234 Parse getserverResponse messages
235 ====================
236 */
237 void Master_ParseServerList (net_landriver_t* dfunc)
238 {
239         int control;
240         qbyte* servers;
241         qbyte* crtserver;
242         unsigned int ipaddr;
243         struct qsockaddr svaddr;
244         char ipstring [32];
245
246         if (developer.integer)
247         {
248                 Con_Printf("Master_ParseServerList: packet received:\n");
249                 SZ_HexDumpToConsole(&net_message);
250         }
251
252         if (net_message.cursize < (int)sizeof(int))
253                 return;
254
255         // is the cache full?
256         if (hostCacheCount == HOSTCACHESIZE)
257                 return;
258
259         MSG_BeginReading ();
260         control = BigLong(*((int *)net_message.data));
261         MSG_ReadLong();
262         if (control != -1)
263                 return;
264
265         if (strncmp (net_message.data + 4, "getserversResponse\\", 19))
266                 return;
267
268         // Skip the next 19 bytes
269         MSG_ReadLong(); MSG_ReadLong(); MSG_ReadLong(); MSG_ReadLong();
270         MSG_ReadShort(); MSG_ReadByte();
271
272         crtserver = servers = Z_Malloc (net_message.cursize - 23);
273         memcpy (servers , net_message.data + 23, net_message.cursize - 23);
274
275         // Extract the IP addresses
276         while ((ipaddr = (crtserver[3] << 24) | (crtserver[2] << 16) | (crtserver[1] << 8) | crtserver[0]) != 0xFFFFFFFF)
277         {
278                 int port = (crtserver[5] << 8) | crtserver[4];
279
280                 if (port < 1 || port >= 65535)
281                         break;
282
283                 port = ((port >> 8) & 0xFF) + ((port & 0xFF) << 8);
284                 sprintf (ipstring, "%u.%u.%u.%u:%hu",
285                                         ipaddr & 0xFF, (ipaddr >> 8) & 0xFF,
286                                         (ipaddr >> 16) & 0xFF, (ipaddr >> 24) & 0xFF,
287                                         port);
288                 dfunc->GetAddrFromName (ipstring, &svaddr);
289
290                 Con_DPrintf("Requesting info from server %s\n", ipstring);
291                 // Send a request at this address
292                 SZ_Clear(&net_message);
293                 MSG_WriteLong(&net_message, 0);  // save space for the header, filled in later
294                 MSG_WriteByte(&net_message, CCREQ_SERVER_INFO);
295                 MSG_WriteString(&net_message, "QUAKE");
296                 MSG_WriteByte(&net_message, NET_PROTOCOL_VERSION);
297                 *((int *)net_message.data) = BigLong(NETFLAG_CTL | (net_message.cursize & NETFLAG_LENGTH_MASK));
298                 dfunc->Write(dfunc->controlSock, net_message.data, net_message.cursize, &svaddr);
299                 SZ_Clear(&net_message);
300
301                 if (crtserver[6] != '\\')
302                         break;
303                 crtserver += 7;
304         }
305
306         Z_Free (servers);
307 }