mirror of
https://git.code.sf.net/p/quake/quakeforge
synced 2024-11-23 12:52:46 +00:00
6d5ffa9f8e
There's still some cleanup to do, but everything seems to be working nicely: `make -j` works, `make distcheck` passes. There is probably plenty of bitrot in the package directories (RPM, debian), though. The vc project files have been removed since those versions are way out of date and quakeforge is pretty much dependent on gcc now anyway. Most of the old Makefile.am files are now Makemodule.am. This should allow for new Makefile.am files that allow local building (to be added on an as-needed bases). The current remaining Makefile.am files are for standalone sub-projects.a The installable bins are currently built in the top-level build directory. This may change if the clutter gets to be too much. While this does make a noticeable difference in build times, the main reason for the switch was to take care of the growing dependency issues: now it's possible to build tools for code generation (eg, using qfcc and ruamoko programs for code-gen).
1696 lines
41 KiB
C
1696 lines
41 KiB
C
/*
|
|
cl_parse.c
|
|
|
|
parse a message received from the server
|
|
|
|
Copyright (C) 1996-1997 Id Software, Inc.
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; either version 2
|
|
of the License, or (at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
|
|
See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to:
|
|
|
|
Free Software Foundation, Inc.
|
|
59 Temple Place - Suite 330
|
|
Boston, MA 02111-1307, USA
|
|
|
|
*/
|
|
#ifdef HAVE_CONFIG_H
|
|
# include "config.h"
|
|
#endif
|
|
|
|
#ifdef HAVE_STRING_H
|
|
# include <string.h>
|
|
#endif
|
|
#ifdef HAVE_STRINGS_H
|
|
# include <strings.h>
|
|
#endif
|
|
#ifdef HAVE_ERRNO_H
|
|
# include <errno.h>
|
|
#endif
|
|
#ifdef HAVE_UNISTD_H
|
|
# include <unistd.h>
|
|
#endif
|
|
|
|
#include "QF/cbuf.h"
|
|
#include "QF/cdaudio.h"
|
|
#include "QF/cmd.h"
|
|
#include "QF/console.h"
|
|
#include "QF/cvar.h"
|
|
#include "QF/draw.h"
|
|
#include "QF/dstring.h"
|
|
#include "QF/gib.h"
|
|
#include "QF/idparse.h"
|
|
#include "QF/msg.h"
|
|
#include "QF/progs.h"
|
|
#include "QF/qfplist.h"
|
|
#include "QF/quakeio.h"
|
|
#include "QF/screen.h"
|
|
#include "QF/skin.h"
|
|
#include "QF/sound.h"
|
|
#include "QF/sys.h"
|
|
#include "QF/teamplay.h"
|
|
#include "QF/va.h"
|
|
|
|
#include "compat.h"
|
|
#include "clview.h"
|
|
#include "sbar.h"
|
|
|
|
#include "qw/bothdefs.h"
|
|
#include "qw/pmove.h"
|
|
#include "qw/protocol.h"
|
|
|
|
#include "qw/include/cl_cam.h"
|
|
#include "qw/include/cl_chat.h"
|
|
#include "qw/include/cl_ents.h"
|
|
#include "qw/include/cl_http.h"
|
|
#include "qw/include/cl_input.h"
|
|
#include "qw/include/cl_main.h"
|
|
#include "qw/include/cl_parse.h"
|
|
#include "qw/include/cl_skin.h"
|
|
#include "qw/include/cl_tent.h"
|
|
#include "qw/include/client.h"
|
|
#include "qw/include/host.h"
|
|
#include "qw/include/map_cfg.h"
|
|
|
|
const char *svc_strings[] = {
|
|
"svc_bad",
|
|
"svc_nop",
|
|
"svc_disconnect",
|
|
"svc_updatestat",
|
|
"svc_version", // [long] server version
|
|
"svc_setview", // [short] entity number
|
|
"svc_sound", // <see code>
|
|
"svc_time", // [float] server time
|
|
"svc_print", // [string] null terminated string
|
|
"svc_stufftext", // [string] stuffed into client's console
|
|
// buffer the string should be \n terminated
|
|
"svc_setangle", // [vec3] set view angle to this absolute value
|
|
|
|
"svc_serverdata", // [long] version ...
|
|
"svc_lightstyle", // [byte] [string]
|
|
"svc_updatename", // [byte] [string]
|
|
"svc_updatefrags", // [byte] [short]
|
|
"svc_clientdata", // <shortbits + data>
|
|
"svc_stopsound", // <see code>
|
|
"svc_updatecolors", // [byte] [byte]
|
|
"svc_particle", // [vec3] <variable>
|
|
"svc_damage", // [byte] impact [byte] blood [vec3] from
|
|
|
|
"svc_spawnstatic",
|
|
"OBSOLETE svc_spawnbinary",
|
|
"svc_spawnbaseline",
|
|
|
|
"svc_temp_entity", // <variable>
|
|
"svc_setpause",
|
|
"svc_signonnum",
|
|
"svc_centerprint",
|
|
"svc_killedmonster",
|
|
"svc_foundsecret",
|
|
"svc_spawnstaticsound",
|
|
"svc_intermission",
|
|
"svc_finale", // [string] text
|
|
"svc_cdtrack", // [byte] track
|
|
"svc_sellscreen",
|
|
"svc_smallkick",
|
|
"svc_bigkick",
|
|
"svc_updateping",
|
|
"svc_updateentertime",
|
|
"svc_updatestatlong",
|
|
"svc_muzzleflash",
|
|
"svc_updateuserinfo",
|
|
"svc_download",
|
|
"svc_playerinfo",
|
|
"svc_nails",
|
|
"svc_chokecount",
|
|
"svc_modellist",
|
|
"svc_soundlist",
|
|
"svc_packetentities",
|
|
"svc_deltapacketentities",
|
|
"svc_maxspeed",
|
|
"svc_entgravity",
|
|
"svc_setinfo",
|
|
"svc_serverinfo",
|
|
"svc_updatepl",
|
|
"svc_nails2", // FIXME from qwex
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL",
|
|
"NEW PROTOCOL"
|
|
};
|
|
|
|
dstring_t *centerprint;
|
|
int oldparsecountmod;
|
|
int parsecountmod;
|
|
double parsecounttime;
|
|
|
|
int cl_spikeindex, cl_playerindex, cl_flagindex;
|
|
int cl_h_playerindex, cl_gib1index, cl_gib2index, cl_gib3index;
|
|
|
|
int packet_latency[NET_TIMINGS];
|
|
|
|
extern cvar_t *hud_scoreboard_uid;
|
|
|
|
entity_t *cl_static_entities;
|
|
static entity_t **cl_static_tail;
|
|
|
|
static void
|
|
CL_LoadSky (void)
|
|
{
|
|
plitem_t *item;
|
|
const char *name = 0;
|
|
|
|
if (!cl.worldspawn) {
|
|
r_funcs->R_LoadSkys (0);
|
|
return;
|
|
}
|
|
if ((item = PL_ObjectForKey (cl.worldspawn, "sky")) // Q2/DarkPlaces
|
|
|| (item = PL_ObjectForKey (cl.worldspawn, "skyname")) // old QF
|
|
|| (item = PL_ObjectForKey (cl.worldspawn, "qlsky"))) /* QuakeLives */ {
|
|
name = PL_String (item);
|
|
}
|
|
r_funcs->R_LoadSkys (name);
|
|
}
|
|
|
|
int
|
|
CL_CalcNet (void)
|
|
{
|
|
int lost, a, i;
|
|
frame_t *frame;
|
|
|
|
for (i = cls.netchan.outgoing_sequence - UPDATE_BACKUP + 1;
|
|
i <= cls.netchan.outgoing_sequence; i++) {
|
|
frame = &cl.frames[i & UPDATE_MASK];
|
|
if (frame->receivedtime == -1)
|
|
packet_latency[i & NET_TIMINGSMASK] = 9999; // dropped
|
|
else if (frame->receivedtime == -2)
|
|
packet_latency[i & NET_TIMINGSMASK] = 10000; // choked
|
|
else if (frame->invalid)
|
|
packet_latency[i & NET_TIMINGSMASK] = 9998; // invalid delta
|
|
else
|
|
packet_latency[i & NET_TIMINGSMASK] =
|
|
(frame->receivedtime - frame->senttime) * 20;
|
|
}
|
|
|
|
lost = 0;
|
|
for (a = 0; a < NET_TIMINGS; a++) {
|
|
i = (cls.netchan.outgoing_sequence - a) & NET_TIMINGSMASK;
|
|
if (packet_latency[i] == 9999)
|
|
lost++;
|
|
}
|
|
return lost * 100 / NET_TIMINGS;
|
|
}
|
|
|
|
/*
|
|
CL_CheckOrDownloadFile
|
|
|
|
Returns true if the file exists, otherwise it attempts
|
|
to start a download from the server.
|
|
*/
|
|
qboolean
|
|
CL_CheckOrDownloadFile (const char *filename)
|
|
{
|
|
QFile *f;
|
|
|
|
if (strstr (filename, "..")) {
|
|
Sys_Printf ("Refusing to download a path with ..\n");
|
|
return true;
|
|
}
|
|
/*
|
|
if (!snd_initialized && strnequal ("sound/", filename, 6)) {
|
|
// don't bother downloading sounds if we can't play them
|
|
return true;
|
|
}
|
|
*/
|
|
f = QFS_FOpenFile (filename);
|
|
if (f) { // it exists, no need to download
|
|
Qclose (f);
|
|
return true;
|
|
}
|
|
// ZOID - can't download when recording
|
|
if (cls.demorecording) {
|
|
Sys_Printf ("Unable to download %s in record mode.\n",
|
|
cls.downloadname->str);
|
|
return true;
|
|
}
|
|
// ZOID - can't download when playback
|
|
if (cls.demoplayback)
|
|
return true;
|
|
|
|
dstring_copystr (cls.downloadname, filename);
|
|
dstring_copystr (cls.downloadtempname, filename);
|
|
Sys_Printf ("Downloading %s...\n", cls.downloadname->str);
|
|
|
|
// download to a temp name, and rename to the real name only when done,
|
|
// so if interrupted a runt file wont be left
|
|
QFS_StripExtension (cls.downloadname->str, cls.downloadtempname->str);
|
|
dstring_appendstr (cls.downloadtempname, ".tmp");
|
|
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va ("download \"%s\"", cls.downloadname->str));
|
|
|
|
cls.downloadnumber++;
|
|
|
|
return false;
|
|
}
|
|
|
|
static plitem_t *
|
|
map_ent (const char *mapname)
|
|
{
|
|
static progs_t edpr;
|
|
char *name = malloc (strlen (mapname) + 4 + 1);
|
|
char *buf;
|
|
plitem_t *edicts = 0;
|
|
QFile *ent_file;
|
|
|
|
QFS_StripExtension (mapname, name);
|
|
strcat (name, ".ent");
|
|
ent_file = QFS_VOpenFile (name, 0, cl.model_precache[1]->vpath);
|
|
if ((buf = (char *) QFS_LoadFile (ent_file, 0))) {
|
|
edicts = ED_Parse (&edpr, buf);
|
|
free (buf);
|
|
} else {
|
|
edicts = ED_Parse (&edpr, cl.model_precache[1]->entities);
|
|
}
|
|
free (name);
|
|
return edicts;
|
|
}
|
|
|
|
static void
|
|
CL_NewMap (const char *mapname)
|
|
{
|
|
cl_static_entities = 0;
|
|
cl_static_tail = &cl_static_entities;
|
|
r_funcs->R_NewMap (cl.worldmodel, cl.model_precache, cl.nummodels);
|
|
Team_NewMap ();
|
|
Con_NewMap ();
|
|
Hunk_Check (); // make sure nothing is hurt
|
|
Sbar_CenterPrint (0);
|
|
|
|
if (cl.model_precache[1] && cl.model_precache[1]->entities) {
|
|
cl.edicts = map_ent (mapname);
|
|
if (cl.edicts) {
|
|
cl.worldspawn = PL_ObjectAtIndex (cl.edicts, 0);
|
|
CL_LoadSky ();
|
|
if (r_funcs->Fog_ParseWorldspawn)
|
|
r_funcs->Fog_ParseWorldspawn (cl.worldspawn);
|
|
}
|
|
}
|
|
|
|
map_cfg (mapname, 1);
|
|
}
|
|
|
|
static void
|
|
Model_NextDownload (void)
|
|
{
|
|
char *s;
|
|
int i;
|
|
|
|
if (cls.downloadnumber == 0) {
|
|
Sys_Printf ("Checking models...\n");
|
|
CL_UpdateScreen (realtime);
|
|
cls.downloadnumber = 1;
|
|
}
|
|
|
|
cls.downloadtype = dl_model;
|
|
for (; cl.model_name[cls.downloadnumber][0]; cls.downloadnumber++) {
|
|
s = cl.model_name[cls.downloadnumber];
|
|
if (s[0] == '*')
|
|
continue; // inline brush model
|
|
if (!CL_CheckOrDownloadFile (s))
|
|
return; // started a download
|
|
}
|
|
|
|
if (cl.model_name[1])
|
|
map_cfg (cl.model_name[1], 0);
|
|
|
|
for (i = 1; i < cl.nummodels; i++) {
|
|
char *info_key = 0;
|
|
|
|
if (!cl.model_name[i][0])
|
|
break;
|
|
|
|
cl.model_precache[i] = Mod_ForName (cl.model_name[i], false);
|
|
|
|
if (!cl.model_precache[i]) {
|
|
Sys_Printf ("\nThe required model file '%s' could not be found or "
|
|
"downloaded.\n\n", cl.model_name[i]);
|
|
Sys_Printf ("You may need to download or purchase a %s client "
|
|
"pack in order to play on this server.\n\n",
|
|
qfs_gamedir->gamedir);
|
|
CL_Disconnect ();
|
|
return;
|
|
}
|
|
|
|
if (strequal (cl.model_name[i], "progs/player.mdl")
|
|
&& cl.model_precache[i]->type == mod_alias) {
|
|
info_key = pmodel_name;
|
|
//XXX mod_funcs->Skin_Player_Model (cl.model_precache[i]);
|
|
}
|
|
if (strequal (cl.model_name[i], "progs/eyes.mdl")
|
|
&& cl.model_precache[i]->type == mod_alias)
|
|
info_key = emodel_name;
|
|
|
|
if (info_key && cl_model_crcs->int_val) {
|
|
aliashdr_t *ahdr = cl.model_precache[i]->aliashdr;
|
|
if (!ahdr)
|
|
ahdr = Cache_Get (&cl.model_precache[i]->cache);
|
|
Info_SetValueForKey (cls.userinfo, info_key, va ("%d", ahdr->crc),
|
|
0);
|
|
if (!cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
SZ_Print (&cls.netchan.message, va ("setinfo %s %d", info_key,
|
|
ahdr->crc));
|
|
}
|
|
if (!cl.model_precache[i]->aliashdr)
|
|
Cache_Release (&cl.model_precache[i]->cache);
|
|
}
|
|
}
|
|
|
|
// Something went wrong (probably in the server, probably a TF server)
|
|
// We need to disconnect gracefully.
|
|
if (!cl.model_precache[1]) {
|
|
Sys_Printf ("\nThe server has failed to provide the map name.\n\n");
|
|
Sys_Printf ("Disconnecting to prevent a crash.\n\n");
|
|
CL_Disconnect ();
|
|
return;
|
|
}
|
|
|
|
// all done
|
|
cl.worldmodel = cl.model_precache[1];
|
|
CL_NewMap (cl.model_name[1]);
|
|
|
|
// done with modellist, request first of static signon messages
|
|
if (!cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va (prespawn_name, cl.servercount,
|
|
cl.worldmodel->checksum2));
|
|
}
|
|
}
|
|
|
|
static void
|
|
Sound_NextDownload (void)
|
|
{
|
|
char *s;
|
|
int i;
|
|
|
|
if (cls.downloadnumber == 0) {
|
|
Sys_Printf ("Checking sounds...\n");
|
|
CL_UpdateScreen (realtime);
|
|
cls.downloadnumber = 1;
|
|
}
|
|
|
|
cls.downloadtype = dl_sound;
|
|
for (; cl.sound_name[cls.downloadnumber][0];
|
|
cls.downloadnumber++) {
|
|
s = cl.sound_name[cls.downloadnumber];
|
|
if (!CL_CheckOrDownloadFile (va ("sound/%s", s)))
|
|
return; // started a download
|
|
}
|
|
|
|
for (i = 1; i < cl.numsounds; i++) {
|
|
if (!cl.sound_name[i][0])
|
|
break;
|
|
cl.sound_precache[i] = S_PrecacheSound (cl.sound_name[i]);
|
|
}
|
|
|
|
// done with sounds, request models now
|
|
memset (cl.model_precache, 0, sizeof (cl.model_precache));
|
|
cl_playerindex = -1;
|
|
cl_spikeindex = -1;
|
|
cl_flagindex = -1;
|
|
cl_h_playerindex = -1;
|
|
cl_gib1index = cl_gib2index = cl_gib3index = -1;
|
|
if (!cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va (modellist_name, cl.servercount, 0));
|
|
}
|
|
}
|
|
|
|
static void
|
|
CL_RequestNextDownload (void)
|
|
{
|
|
switch (cls.downloadtype) {
|
|
case dl_single:
|
|
break;
|
|
case dl_skin:
|
|
Skin_NextDownload ();
|
|
break;
|
|
case dl_model:
|
|
Model_NextDownload ();
|
|
break;
|
|
case dl_sound:
|
|
Sound_NextDownload ();
|
|
break;
|
|
case dl_none:
|
|
default:
|
|
Sys_MaskPrintf (SYS_DEV, "Unknown download type.\n");
|
|
}
|
|
}
|
|
|
|
void
|
|
CL_FinishDownload (void)
|
|
{
|
|
Qclose (cls.download);
|
|
VID_SetCaption (va ("Connecting to %s", cls.servername->str));
|
|
|
|
// rename the temp file to it's final name
|
|
if (strcmp (cls.downloadtempname->str, cls.downloadname->str)) {
|
|
dstring_t *oldn = dstring_new ();
|
|
dstring_t *newn = dstring_new ();
|
|
|
|
if (strncmp (cls.downloadtempname->str, "skins/", 6)) {
|
|
dsprintf (oldn, "%s/%s", qfs_gamedir->dir.def,
|
|
cls.downloadtempname->str);
|
|
dsprintf (newn, "%s/%s", qfs_gamedir->dir.def,
|
|
cls.downloadname->str);
|
|
} else {
|
|
dsprintf (oldn, "%s/%s", qfs_gamedir->dir.skins,
|
|
cls.downloadtempname->str + 6);
|
|
dsprintf (newn, "%s/%s", qfs_gamedir->dir.skins,
|
|
cls.downloadname->str + 6);
|
|
}
|
|
if (QFS_Rename (oldn->str, newn->str))
|
|
Sys_Printf ("failed to rename %s to %s, %s.\n", oldn->str,
|
|
newn->str, strerror (errno));
|
|
dstring_delete (oldn);
|
|
dstring_delete (newn);
|
|
}
|
|
|
|
cls.download = NULL;
|
|
dstring_clearstr (cls.downloadname);
|
|
dstring_clearstr (cls.downloadtempname);
|
|
dstring_clearstr (cls.downloadurl);
|
|
cls.downloadpercent = 0;
|
|
|
|
// get another file if needed
|
|
CL_RequestNextDownload ();
|
|
}
|
|
|
|
void
|
|
CL_FailDownload (void)
|
|
{
|
|
if (cls.download) {
|
|
Qclose (cls.download);
|
|
cls.download = NULL;
|
|
}
|
|
dstring_clearstr (cls.downloadname);
|
|
dstring_clearstr (cls.downloadtempname);
|
|
dstring_clearstr (cls.downloadurl);
|
|
CL_RequestNextDownload ();
|
|
}
|
|
|
|
static int
|
|
CL_OpenDownload (void)
|
|
{
|
|
dstring_t *name = dstring_newstr ();
|
|
const char *fname, *path;
|
|
|
|
if (strncmp (cls.downloadtempname->str, "skins/", 6) == 0) {
|
|
path = qfs_gamedir->dir.skins;
|
|
fname = cls.downloadtempname->str + 6;
|
|
} else if (strncmp (cls.downloadtempname->str, "progs/", 6) == 0) {
|
|
path = qfs_gamedir->dir.models;
|
|
fname = cls.downloadtempname->str + 6;
|
|
} else if (strncmp (cls.downloadtempname->str, "sound/", 6) == 0) {
|
|
path = qfs_gamedir->dir.sound;
|
|
fname = cls.downloadtempname->str + 6;
|
|
} else if (strncmp (cls.downloadtempname->str, "maps/", 5) == 0) {
|
|
path = qfs_gamedir->dir.maps;
|
|
fname = cls.downloadtempname->str + 5;
|
|
} else {
|
|
path = qfs_gamedir->dir.def;
|
|
fname = cls.downloadtempname->str;
|
|
}
|
|
dsprintf (name, "%s/%s", path, fname);
|
|
|
|
cls.download = QFS_WOpen (name->str, 0);
|
|
if (!cls.download) {
|
|
dstring_clearstr (cls.downloadname);
|
|
dstring_clearstr (cls.downloadurl);
|
|
Sys_Printf ("Failed to open %s\n", name->str);
|
|
CL_RequestNextDownload ();
|
|
return 0;
|
|
}
|
|
dstring_delete (name);
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
CL_ParseDownload
|
|
|
|
A download message has been received from the server
|
|
*/
|
|
static void
|
|
CL_ParseDownload (void)
|
|
{
|
|
int size, percent;
|
|
|
|
// read the data
|
|
size = (short) MSG_ReadShort (net_message);
|
|
percent = MSG_ReadByte (net_message);
|
|
|
|
if (cls.demoplayback) {
|
|
if (size > 0)
|
|
net_message->readcount += size;
|
|
dstring_clearstr (cls.downloadname);
|
|
dstring_clearstr (cls.downloadtempname);
|
|
dstring_clearstr (cls.downloadurl);
|
|
return; // not in demo playback
|
|
}
|
|
|
|
if (size == DL_NOFILE) {
|
|
Sys_Printf ("File not found.\n");
|
|
if (cls.download) {
|
|
Sys_Printf ("cls.download shouldn't have been set\n");
|
|
Qclose (cls.download);
|
|
cls.download = NULL;
|
|
}
|
|
dstring_clearstr (cls.downloadname);
|
|
dstring_clearstr (cls.downloadtempname);
|
|
dstring_clearstr (cls.downloadurl);
|
|
CL_RequestNextDownload ();
|
|
return;
|
|
}
|
|
|
|
if (size == DL_RENAME) {
|
|
const char *newname = MSG_ReadString (net_message);
|
|
|
|
if (strncmp (newname, cls.downloadname->str,
|
|
strlen (cls.downloadname->str))
|
|
|| strstr (newname + strlen (cls.downloadname->str), "/")) {
|
|
Sys_Printf
|
|
("WARNING: server tried to give a strange new name: %s\n",
|
|
newname);
|
|
CL_RequestNextDownload ();
|
|
return;
|
|
}
|
|
if (cls.download) {
|
|
Qclose (cls.download);
|
|
unlink (cls.downloadname->str);
|
|
}
|
|
dstring_copystr (cls.downloadname, newname);
|
|
Sys_Printf ("downloading to %s\n", cls.downloadname->str);
|
|
return;
|
|
}
|
|
if (size == DL_HTTP) {
|
|
#ifdef HAVE_LIBCURL
|
|
const char *url = MSG_ReadString (net_message);
|
|
const char *newname = MSG_ReadString (net_message);
|
|
|
|
if (*newname) {
|
|
if (strncmp (newname, cls.downloadname->str,
|
|
strlen (cls.downloadname->str))
|
|
|| strstr (newname + strlen (cls.downloadname->str), "/")) {
|
|
Sys_Printf
|
|
("WARNING: server tried to give a strange new name: %s\n",
|
|
newname);
|
|
CL_RequestNextDownload ();
|
|
return;
|
|
}
|
|
if (cls.download) {
|
|
Qclose (cls.download);
|
|
unlink (cls.downloadname->str);
|
|
}
|
|
dstring_copystr (cls.downloadname, newname);
|
|
}
|
|
dstring_copystr (cls.downloadurl, url);
|
|
Sys_Printf ("downloading %s to %s\n", cls.downloadurl->str,
|
|
cls.downloadname->str);
|
|
CL_HTTP_StartDownload ();
|
|
#else
|
|
MSG_ReadString (net_message);
|
|
MSG_ReadString (net_message);
|
|
Sys_Printf ("server sent http redirect but we don't know how to handle"
|
|
"it :(\n");
|
|
#endif
|
|
CL_OpenDownload ();
|
|
return;
|
|
}
|
|
// open the file if not opened yet
|
|
if (!cls.download) {
|
|
if (!CL_OpenDownload ()) {
|
|
return;
|
|
net_message->readcount += size;
|
|
}
|
|
}
|
|
|
|
Qwrite (cls.download, net_message->message->data + net_message->readcount,
|
|
size);
|
|
net_message->readcount += size;
|
|
|
|
if (percent != 100) {
|
|
// request next block
|
|
if (percent != cls.downloadpercent)
|
|
VID_SetCaption (va ("Downloading %s %d%%", cls.downloadname->str,
|
|
percent));
|
|
cls.downloadpercent = percent;
|
|
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
SZ_Print (&cls.netchan.message, "nextdl");
|
|
} else {
|
|
CL_FinishDownload ();
|
|
}
|
|
}
|
|
|
|
static byte *upload_data;
|
|
static int upload_pos, upload_size;
|
|
|
|
void
|
|
CL_NextUpload (void)
|
|
{
|
|
byte buffer[1024];
|
|
int percent, size, r;
|
|
|
|
if (!upload_data)
|
|
return;
|
|
|
|
r = upload_size - upload_pos;
|
|
if (r > 768)
|
|
r = 768;
|
|
memcpy (buffer, upload_data + upload_pos, r);
|
|
MSG_WriteByte (&cls.netchan.message, clc_upload);
|
|
MSG_WriteShort (&cls.netchan.message, r);
|
|
|
|
upload_pos += r;
|
|
size = upload_size;
|
|
if (!size)
|
|
size = 1;
|
|
percent = upload_pos * 100 / size;
|
|
MSG_WriteByte (&cls.netchan.message, percent);
|
|
SZ_Write (&cls.netchan.message, buffer, r);
|
|
|
|
Sys_MaskPrintf (SYS_DEV, "UPLOAD: %6d: %d written\n", upload_pos - r, r);
|
|
|
|
if (upload_pos != upload_size)
|
|
return;
|
|
|
|
Sys_Printf ("Upload completed\n");
|
|
|
|
free (upload_data);
|
|
upload_data = 0;
|
|
upload_pos = upload_size = 0;
|
|
}
|
|
|
|
void
|
|
CL_StartUpload (byte * data, int size)
|
|
{
|
|
if (cls.state < ca_onserver)
|
|
return; // must be connected
|
|
|
|
// override
|
|
if (upload_data)
|
|
free (upload_data);
|
|
|
|
Sys_MaskPrintf (SYS_DEV, "Upload starting of %d...\n", size);
|
|
|
|
upload_data = malloc (size);
|
|
memcpy (upload_data, data, size);
|
|
upload_size = size;
|
|
upload_pos = 0;
|
|
|
|
CL_NextUpload ();
|
|
}
|
|
|
|
qboolean
|
|
CL_IsUploading (void)
|
|
{
|
|
if (upload_data)
|
|
return true;
|
|
return false;
|
|
}
|
|
|
|
void
|
|
CL_StopUpload (void)
|
|
{
|
|
if (upload_data)
|
|
free (upload_data);
|
|
upload_data = NULL;
|
|
}
|
|
|
|
// SERVER CONNECTING MESSAGES =================================================
|
|
|
|
// LordHavoc: BIG BUG-FIX! Clear baselines each time it connects...
|
|
static void
|
|
CL_ClearBaselines (void)
|
|
{
|
|
int i;
|
|
|
|
i = qw_entstates.num_entities;
|
|
memset (qw_entstates.baseline, 0, i * sizeof (entity_state_t));
|
|
for (i = 0; i < MAX_EDICTS; i++) {
|
|
qw_entstates.baseline[i].colormod = 255;
|
|
qw_entstates.baseline[i].alpha = 255;
|
|
qw_entstates.baseline[i].scale = 16;
|
|
qw_entstates.baseline[i].glow_size = 0;
|
|
qw_entstates.baseline[i].glow_color = 254;
|
|
}
|
|
}
|
|
|
|
static void
|
|
CL_ParseServerData (void)
|
|
{
|
|
const char *str;
|
|
int protover;
|
|
//FIXME qboolean cflag = false;
|
|
|
|
Sys_MaskPrintf (SYS_DEV, "Serverdata packet received.\n");
|
|
|
|
// wipe the client_state_t struct
|
|
CL_ClearState ();
|
|
|
|
// parse protocol version number
|
|
// allow 2.2 and 2.29 demos to play
|
|
protover = MSG_ReadLong (net_message);
|
|
if (protover != PROTOCOL_VERSION
|
|
&& !(cls.demoplayback && (protover <= 26 || protover >= 28)))
|
|
Host_Error ("Server returned version %i, not %i\nYou probably "
|
|
"need to upgrade.\nCheck http://www.quakeworld.net/",
|
|
protover, PROTOCOL_VERSION);
|
|
|
|
cl.servercount = MSG_ReadLong (net_message);
|
|
|
|
// game directory
|
|
str = MSG_ReadString (net_message);
|
|
|
|
if (!strequal (qfs_gamedir->gamedir, str)) {
|
|
// save current config
|
|
Host_WriteConfiguration ();
|
|
//FIXME cflag = true;
|
|
QFS_Gamedir (str);
|
|
}
|
|
|
|
if (cls.demoplayback2) {
|
|
realtime = cls.basetime = MSG_ReadFloat (net_message);
|
|
cl.playernum = 31;
|
|
cl.spectator = true;
|
|
} else {
|
|
// parse player slot, high bit means spectator
|
|
cl.playernum = MSG_ReadByte (net_message);
|
|
if (cl.playernum & 128) {
|
|
cl.spectator = true;
|
|
cl.playernum &= ~128;
|
|
}
|
|
}
|
|
|
|
cl.viewentity = cl.playernum + 1;
|
|
|
|
// get the full level name
|
|
str = MSG_ReadString (net_message);
|
|
strncpy (cl.levelname, str, sizeof (cl.levelname) - 1);
|
|
|
|
// get the movevars
|
|
movevars.gravity = MSG_ReadFloat (net_message);
|
|
r_data->gravity = movevars.gravity; // Gravity for renderer effects
|
|
movevars.stopspeed = MSG_ReadFloat (net_message);
|
|
movevars.maxspeed = MSG_ReadFloat (net_message);
|
|
movevars.spectatormaxspeed = MSG_ReadFloat (net_message);
|
|
movevars.accelerate = MSG_ReadFloat (net_message);
|
|
movevars.airaccelerate = MSG_ReadFloat (net_message);
|
|
movevars.wateraccelerate = MSG_ReadFloat (net_message);
|
|
movevars.friction = MSG_ReadFloat (net_message);
|
|
movevars.waterfriction = MSG_ReadFloat (net_message);
|
|
movevars.entgravity = MSG_ReadFloat (net_message);
|
|
|
|
// separate the printfs so the server message can have a color
|
|
Sys_Printf ("\n\n\35\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36"
|
|
"\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\36\37\n\n");
|
|
Sys_Printf ("%c%s\n", 2, str);
|
|
|
|
// ask for the sound list next
|
|
memset (cl.sound_name, 0, sizeof (cl.sound_name));
|
|
if (!cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va (soundlist_name, cl.servercount, 0));
|
|
}
|
|
|
|
// now waiting for downloads, etc
|
|
CL_SetState (ca_onserver);
|
|
|
|
CL_ClearBaselines ();
|
|
}
|
|
|
|
static void
|
|
CL_ParseSoundlist (void)
|
|
{
|
|
const char *str;
|
|
int n;
|
|
|
|
// precache sounds
|
|
// memset (cl.sound_precache, 0, sizeof (cl.sound_precache));
|
|
|
|
cl.numsounds = MSG_ReadByte (net_message);
|
|
|
|
for (;;) {
|
|
str = MSG_ReadString (net_message);
|
|
if (!str[0])
|
|
break;
|
|
cl.numsounds++;
|
|
if (cl.numsounds >= MAX_SOUNDS)
|
|
Host_Error ("Server sent too many sound_precache");
|
|
strcpy (cl.sound_name[cl.numsounds], str);
|
|
}
|
|
cl.numsounds++;
|
|
|
|
n = MSG_ReadByte (net_message);
|
|
|
|
if (n && !cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va (soundlist_name, cl.servercount, n));
|
|
return;
|
|
}
|
|
|
|
cls.downloadnumber = 0;
|
|
cls.downloadtype = dl_sound;
|
|
Sound_NextDownload ();
|
|
}
|
|
|
|
static void
|
|
CL_ParseModellist (void)
|
|
{
|
|
int n;
|
|
const char *str;
|
|
|
|
// precache models and note certain default indexes
|
|
cl.nummodels = MSG_ReadByte (net_message);
|
|
|
|
for (;;) {
|
|
str = MSG_ReadString (net_message);
|
|
if (!str[0])
|
|
break;
|
|
cl.nummodels++;
|
|
if (cl.nummodels >= MAX_MODELS)
|
|
Host_Error ("Server sent too many model_precache");
|
|
strcpy (cl.model_name[cl.nummodels], str);
|
|
|
|
if (!strcmp (cl.model_name[cl.nummodels], "progs/spike.mdl"))
|
|
cl_spikeindex = cl.nummodels;
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/player.mdl"))
|
|
cl_playerindex = cl.nummodels;
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/flag.mdl"))
|
|
cl_flagindex = cl.nummodels;
|
|
// for deadbodyfilter & gib filter
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/h_player.mdl"))
|
|
cl_h_playerindex = cl.nummodels;
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib1.mdl"))
|
|
cl_gib1index = cl.nummodels;
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib2.mdl"))
|
|
cl_gib2index = cl.nummodels;
|
|
else if (!strcmp (cl.model_name[cl.nummodels], "progs/gib3.mdl"))
|
|
cl_gib3index = cl.nummodels;
|
|
}
|
|
cl.nummodels++;
|
|
|
|
n = MSG_ReadByte (net_message);
|
|
|
|
if (n) {
|
|
if (!cls.demoplayback) {
|
|
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
|
|
MSG_WriteString (&cls.netchan.message,
|
|
va (modellist_name, cl.servercount, n));
|
|
}
|
|
return;
|
|
}
|
|
|
|
cls.downloadnumber = 0;
|
|
cls.downloadtype = dl_model;
|
|
Model_NextDownload ();
|
|
}
|
|
|
|
static void
|
|
CL_ParseBaseline (entity_state_t *es)
|
|
{
|
|
es->modelindex = MSG_ReadByte (net_message);
|
|
es->frame = MSG_ReadByte (net_message);
|
|
es->colormap = MSG_ReadByte (net_message);
|
|
es->skinnum = MSG_ReadByte (net_message);
|
|
|
|
MSG_ReadCoordAngleV (net_message, es->origin, es->angles);
|
|
|
|
// LordHavoc: set up baseline to for new effects (alpha, colormod, etc)
|
|
es->colormod = 255;
|
|
es->alpha = 255;
|
|
es->scale = 16;
|
|
es->glow_size = 0;
|
|
es->glow_color = 254;
|
|
}
|
|
|
|
/*
|
|
CL_ParseStatic
|
|
|
|
Static entities are non-interactive world objects
|
|
like torches
|
|
*/
|
|
static void
|
|
CL_ParseStatic (void)
|
|
{
|
|
entity_t *ent;
|
|
entity_state_t es;
|
|
|
|
CL_ParseBaseline (&es);
|
|
|
|
ent = r_funcs->R_AllocEntity ();
|
|
CL_Init_Entity (ent);
|
|
|
|
*cl_static_tail = ent;
|
|
cl_static_tail = &ent->unext;
|
|
|
|
// copy it to the current state
|
|
ent->model = cl.model_precache[es.modelindex];
|
|
ent->frame = es.frame;
|
|
ent->skinnum = es.skinnum;
|
|
|
|
VectorCopy (es.origin, ent->origin);
|
|
CL_TransformEntity (ent, es.angles, true);
|
|
|
|
r_funcs->R_AddEfrags (ent);
|
|
}
|
|
|
|
static void
|
|
CL_ParseStaticSound (void)
|
|
{
|
|
int sound_num, vol, atten;
|
|
vec3_t org;
|
|
|
|
MSG_ReadCoordV (net_message, org);
|
|
sound_num = MSG_ReadByte (net_message);
|
|
vol = MSG_ReadByte (net_message);
|
|
atten = MSG_ReadByte (net_message);
|
|
|
|
S_StaticSound (cl.sound_precache[sound_num], org, vol, atten);
|
|
}
|
|
|
|
// ACTION MESSAGES ============================================================
|
|
|
|
static void
|
|
CL_ParseStartSoundPacket (void)
|
|
{
|
|
float attenuation;
|
|
int bits, channel, ent, sound_num, volume;
|
|
vec3_t pos;
|
|
|
|
bits = MSG_ReadShort (net_message);
|
|
|
|
if (bits & SND_VOLUME)
|
|
volume = MSG_ReadByte (net_message);
|
|
else
|
|
volume = DEFAULT_SOUND_PACKET_VOLUME;
|
|
|
|
if (bits & SND_ATTENUATION)
|
|
attenuation = MSG_ReadByte (net_message) / 64.0;
|
|
else
|
|
attenuation = DEFAULT_SOUND_PACKET_ATTENUATION;
|
|
|
|
sound_num = MSG_ReadByte (net_message);
|
|
|
|
MSG_ReadCoordV (net_message, pos);
|
|
|
|
ent = (bits >> 3) & 1023;
|
|
channel = bits & 7;
|
|
|
|
if (ent > MAX_EDICTS)
|
|
Host_Error ("CL_ParseStartSoundPacket: ent = %i", ent);
|
|
|
|
S_StartSound (ent, channel, cl.sound_precache[sound_num], pos,
|
|
volume / 255.0, attenuation);
|
|
}
|
|
|
|
/*
|
|
CL_ParseClientdata
|
|
|
|
Server information pertaining to only this client, sent every frame
|
|
*/
|
|
void
|
|
CL_ParseClientdata (void)
|
|
{
|
|
float latency;
|
|
frame_t *frame;
|
|
int i;
|
|
|
|
// calculate simulated time of message
|
|
oldparsecountmod = parsecountmod;
|
|
|
|
i = cls.netchan.incoming_acknowledged;
|
|
|
|
cl.parsecount = i;
|
|
i &= UPDATE_MASK;
|
|
parsecountmod = i;
|
|
frame = &cl.frames[i];
|
|
if (cls.demoplayback2)
|
|
frame->senttime = realtime - host_frametime; //realtime;
|
|
parsecounttime = cl.frames[i].senttime;
|
|
|
|
frame->receivedtime = realtime;
|
|
|
|
// calculate latency
|
|
latency = frame->receivedtime - frame->senttime;
|
|
|
|
if (!(latency < 0 || latency > 1.0)) {
|
|
// drift the average latency towards the observed latency
|
|
if (latency < cls.latency)
|
|
cls.latency = latency;
|
|
else
|
|
cls.latency += 0.001; // drift up, so correction is needed
|
|
}
|
|
}
|
|
|
|
static void
|
|
CL_ProcessUserInfo (int slot, player_info_t *player)
|
|
{
|
|
char skin[MAX_SKIN_LENGTH] = { 0 };
|
|
const char *s;
|
|
|
|
s = Info_ValueForKey (player->userinfo, "skin");
|
|
|
|
if (strlen(s) < sizeof skin) {
|
|
QFS_StripExtension (s, skin);
|
|
if (!strequal (s, skin))
|
|
Info_SetValueForKey (player->userinfo, "skin", skin, 1);
|
|
} else {
|
|
Info_SetValueForKey (player->userinfo, "skin", skin, 1);
|
|
}
|
|
|
|
while (!(player->name = Info_Key (player->userinfo, "name"))) {
|
|
if (player->userid)
|
|
Info_SetValueForKey (player->userinfo, "name",
|
|
va ("user-%i [exploit]", player->userid), 1);
|
|
else
|
|
Info_SetValueForKey (player->userinfo, "name", "", 1);
|
|
}
|
|
player->topcolor = atoi (Info_ValueForKey (player->userinfo, "topcolor"));
|
|
player->bottomcolor =
|
|
atoi (Info_ValueForKey (player->userinfo, "bottomcolor"));
|
|
|
|
while (!(player->team = Info_Key (player->userinfo, "team")))
|
|
Info_SetValueForKey (player->userinfo, "team", "", 1);
|
|
while (!(player->skinname = Info_Key (player->userinfo, "skin")))
|
|
Info_SetValueForKey (player->userinfo, "skin", "", 1);
|
|
while (!(player->chat = Info_Key (player->userinfo, "chat")))
|
|
Info_SetValueForKey (player->userinfo, "chat", "0", 1);
|
|
|
|
if (Info_ValueForKey (player->userinfo, "*spectator")[0])
|
|
player->spectator = true;
|
|
else
|
|
player->spectator = false;
|
|
|
|
mod_funcs->Skin_SetTranslation (slot + 1, player->topcolor,
|
|
player->bottomcolor);
|
|
player->skin = mod_funcs->Skin_SetSkin (player->skin, slot + 1,
|
|
player->skinname->value);
|
|
player->skin = mod_funcs->Skin_SetColormap (player->skin, slot + 1);
|
|
|
|
Sbar_Changed ();
|
|
}
|
|
|
|
static void
|
|
CL_UpdateUserinfo (void)
|
|
{
|
|
int slot, uid;
|
|
const char *info;
|
|
player_info_t *player;
|
|
|
|
slot = MSG_ReadByte (net_message);
|
|
if (slot >= MAX_CLIENTS)
|
|
Host_Error
|
|
("CL_ParseServerMessage: svc_updateuserinfo > MAX_SCOREBOARD");
|
|
|
|
player = &cl.players[slot];
|
|
uid = MSG_ReadLong (net_message);
|
|
info = MSG_ReadString (net_message);
|
|
if (*info) {
|
|
// a totally empty userinfo string should not be possible
|
|
player->userid = uid;
|
|
if (player->userinfo)
|
|
Info_Destroy (player->userinfo);
|
|
player->userinfo = Info_ParseString (info, MAX_INFO_STRING, 0);
|
|
CL_ProcessUserInfo (slot, player);
|
|
CL_Chat_Check_Name (Info_ValueForKey (player->userinfo, "name"), slot);
|
|
} else {
|
|
// the server dropped the client
|
|
CL_Chat_User_Disconnected (player->userid);
|
|
if (player->userinfo)
|
|
Info_Destroy (player->userinfo);
|
|
memset (player, 0, sizeof (*player));
|
|
}
|
|
}
|
|
|
|
static void
|
|
CL_SetInfo (void)
|
|
{
|
|
char key[MAX_MSGLEN], value[MAX_MSGLEN];
|
|
int flags, slot;
|
|
player_info_t *player;
|
|
|
|
slot = MSG_ReadByte (net_message);
|
|
if (slot >= MAX_CLIENTS)
|
|
Host_Error ("CL_ParseServerMessage: svc_setinfo > MAX_SCOREBOARD");
|
|
|
|
player = &cl.players[slot];
|
|
|
|
strncpy (key, MSG_ReadString (net_message), sizeof (key) - 1);
|
|
key[sizeof (key) - 1] = 0;
|
|
strncpy (value, MSG_ReadString (net_message), sizeof (value) - 1);
|
|
key[sizeof (value) - 1] = 0;
|
|
|
|
if (!player->userinfo)
|
|
player->userinfo = Info_ParseString ("", MAX_INFO_STRING, 0);
|
|
|
|
flags = !strequal (key, "name");
|
|
flags |= strequal (key, "team") << 1;
|
|
Info_SetValueForKey (player->userinfo, key, value, flags);
|
|
|
|
CL_ProcessUserInfo (slot, player);
|
|
|
|
Sys_MaskPrintf (SYS_DEV, "SETINFO %s: %s=%s\n", player->name->value, key,
|
|
value);
|
|
}
|
|
|
|
static void
|
|
CL_ServerInfo (void)
|
|
{
|
|
char key[MAX_MSGLEN], value[MAX_MSGLEN];
|
|
|
|
strncpy (key, MSG_ReadString (net_message), sizeof (key) - 1);
|
|
key[sizeof (key) - 1] = 0;
|
|
strncpy (value, MSG_ReadString (net_message), sizeof (value) - 1);
|
|
key[sizeof (value) - 1] = 0;
|
|
|
|
Sys_MaskPrintf (SYS_DEV, "SERVERINFO: %s=%s\n", key, value);
|
|
|
|
Info_SetValueForKey (cl.serverinfo, key, value, 0);
|
|
if (strequal (key, "chase")) {
|
|
cl.chase = atoi (value);
|
|
} else if (strequal (key, "cshifts")) {
|
|
cl.sv_cshifts = atoi (value);
|
|
} else if (strequal (key, "no_pogo_stick")) {
|
|
Cvar_Set (no_pogo_stick, value);
|
|
cl.no_pogo_stick = no_pogo_stick->int_val;
|
|
} else if (strequal (key, "teamplay")) {
|
|
cl.teamplay = atoi (value);
|
|
Sbar_DMO_Init_f (hud_scoreboard_uid); // HUD setup, cl.teamplay changed
|
|
} else if (strequal (key, "watervis")) {
|
|
cl.watervis = atoi (value);
|
|
} else if (strequal (key, "fpd")) {
|
|
cl.fpd = atoi (value);
|
|
} else if (strequal (key, "fbskins")) {
|
|
cl.fbskins = atoi (value);
|
|
// } else if (strequal (key, "*z_ext") {
|
|
// cl.z_ext = atoi (value);
|
|
// } else if (strequal (key, "pm_bunnyspeedcap") {
|
|
// cl.bunnyspeedcap = atof (value);
|
|
// } else if (strequal (key, "pm_slidefix") {
|
|
// movevars.slidefix = atoi (value);
|
|
// } else if (strequal (key, "pm_ktjump") {
|
|
// movevars.ktjump = atof (value);
|
|
// FIXME: need to set to 0.5 otherwise, outside of else structure
|
|
}
|
|
}
|
|
|
|
static void
|
|
CL_SetStat (int stat, int value)
|
|
{
|
|
if (stat < 0 || stat >= MAX_CL_STATS)
|
|
Host_Error ("CL_SetStat: %i is invalid", stat);
|
|
|
|
if (cls.demoplayback2) {
|
|
cl.players[cls.lastto].stats[stat] = value;
|
|
if (Cam_TrackNum () != cls.lastto)
|
|
return;
|
|
}
|
|
|
|
Sbar_Changed ();
|
|
|
|
switch (stat) {
|
|
case STAT_ITEMS:
|
|
Sbar_Changed ();
|
|
break;
|
|
case STAT_HEALTH:
|
|
if (cl_player_health_e->func)
|
|
GIB_Event_Callback (cl_player_health_e, 1, va ("%i", value));
|
|
if (value <= 0)
|
|
Team_Dead ();
|
|
break;
|
|
}
|
|
cl.stats[stat] = value;
|
|
}
|
|
|
|
static void
|
|
CL_MuzzleFlash (void)
|
|
{
|
|
dlight_t *dl;
|
|
int i;
|
|
player_state_t *pl;
|
|
vec3_t fv, rv, uv;
|
|
|
|
i = MSG_ReadShort (net_message);
|
|
|
|
if ((unsigned int) (i - 1) >= MAX_CLIENTS)
|
|
return;
|
|
|
|
pl = &cl.frames[parsecountmod].playerstate[i - 1];
|
|
|
|
dl = r_funcs->R_AllocDlight (i);
|
|
if (!dl)
|
|
return;
|
|
|
|
if (i - 1 == cl.playernum)
|
|
AngleVectors (cl.viewangles, fv, rv, uv);
|
|
else
|
|
AngleVectors (pl->viewangles, fv, rv, uv);
|
|
|
|
VectorMultAdd (pl->pls.origin, 18, fv, dl->origin);
|
|
dl->radius = 200 + (rand () & 31);
|
|
dl->die = cl.time + 0.1;
|
|
dl->minlight = 32;
|
|
dl->color[0] = 0.2;
|
|
dl->color[1] = 0.1;
|
|
dl->color[2] = 0.05;
|
|
dl->color[3] = 0.7;
|
|
}
|
|
|
|
#define SHOWNET(x) \
|
|
if (cl_shownet->int_val == 2) \
|
|
Sys_Printf ("%3i:%s\n", net_message->readcount - 1, x);
|
|
|
|
int received_framecount;
|
|
|
|
void
|
|
CL_ParseServerMessage (void)
|
|
{
|
|
int cmd = 0, i, j;
|
|
const char *str;
|
|
static dstring_t *stuffbuf;
|
|
|
|
received_framecount = host_framecount;
|
|
cl.last_servermessage = realtime;
|
|
CL_ClearProjectiles ();
|
|
|
|
// if recording demos, copy the message out
|
|
if (cl_shownet->int_val == 1)
|
|
Sys_Printf ("%i ", net_message->message->cursize);
|
|
else if (cl_shownet->int_val == 2)
|
|
Sys_Printf ("------------------ %d\n",
|
|
cls.netchan.incoming_acknowledged);
|
|
|
|
CL_ParseClientdata ();
|
|
|
|
// parse the message
|
|
while (1) {
|
|
if (net_message->badread)
|
|
Host_Error ("CL_ParseServerMessage: Bad server message: %s\n",
|
|
svc_strings[cmd]);
|
|
|
|
cmd = MSG_ReadByte (net_message);
|
|
|
|
if (cmd == -1) {
|
|
net_message->readcount++; // so the EOM SHOWNET has the right
|
|
// value
|
|
SHOWNET ("END OF MESSAGE");
|
|
break; // end of message
|
|
}
|
|
|
|
SHOWNET (va ("%s(%d)", svc_strings[cmd], cmd));
|
|
|
|
// other commands
|
|
switch (cmd) {
|
|
default:
|
|
Host_Error ("CL_ParseServerMessage: Illegible server "
|
|
"message: %d\n", cmd);
|
|
break;
|
|
|
|
case svc_nop:
|
|
break;
|
|
|
|
case svc_disconnect:
|
|
if (cls.state == ca_connected)
|
|
Host_EndGame ("Server disconnected\n"
|
|
"Server version may not be compatible");
|
|
else
|
|
Host_EndGame ("Server disconnected\n");
|
|
|
|
case svc_updatestat:
|
|
i = MSG_ReadByte (net_message);
|
|
j = MSG_ReadByte (net_message);
|
|
CL_SetStat (i, j);
|
|
break;
|
|
|
|
// svc_version
|
|
// svc_setview
|
|
|
|
case svc_sound:
|
|
CL_ParseStartSoundPacket ();
|
|
break;
|
|
|
|
// svc_time
|
|
|
|
case svc_print:
|
|
{
|
|
dstring_t *p = 0;
|
|
|
|
i = MSG_ReadByte (net_message);
|
|
str = MSG_ReadString (net_message);
|
|
if (i == PRINT_CHAT) {
|
|
if (!CL_Chat_Allow_Message (str))
|
|
break;
|
|
// TODO: cl_nofake 2 -- accept fake messages from teammates
|
|
|
|
if (cl_nofake->int_val) {
|
|
char *c;
|
|
|
|
p = dstring_strdup (str);
|
|
for (c = p->str; *c; c++) {
|
|
if (*c == '\r')
|
|
*c = '#';
|
|
}
|
|
str = p->str;
|
|
}
|
|
Con_SetOrMask (128);
|
|
S_LocalSound ("misc/talk.wav");
|
|
if (cl_chat_e->func)
|
|
GIB_Event_Callback (cl_chat_e, 1, str);
|
|
Team_ParseChat (str);
|
|
}
|
|
Sys_Printf ("%s", str);
|
|
if (p)
|
|
dstring_delete (p);
|
|
Con_SetOrMask (0);
|
|
break;
|
|
}
|
|
case svc_stufftext:
|
|
str = MSG_ReadString (net_message);
|
|
if (str[strlen (str) - 1] == '\n') {
|
|
if (stuffbuf && stuffbuf->str[0]) {
|
|
Sys_MaskPrintf (SYS_DEV, "stufftext: %s%s\n",
|
|
stuffbuf->str, str);
|
|
Cbuf_AddText (cl_stbuf, stuffbuf->str);
|
|
dstring_clearstr (stuffbuf);
|
|
} else {
|
|
Sys_MaskPrintf (SYS_DEV, "stufftext: %s\n", str);
|
|
}
|
|
Cbuf_AddText (cl_stbuf, str);
|
|
} else {
|
|
Sys_MaskPrintf (SYS_DEV, "partial stufftext: %s\n", str);
|
|
if (!stuffbuf)
|
|
stuffbuf = dstring_newstr ();
|
|
dstring_appendstr (stuffbuf, str);
|
|
}
|
|
break;
|
|
|
|
case svc_setangle:
|
|
{
|
|
vec_t *dest = cl.viewangles;
|
|
vec3_t dummy;
|
|
|
|
if (cls.demoplayback2) {
|
|
j = MSG_ReadByte (net_message);
|
|
// fixangle |= 1 << j;
|
|
if (j != Cam_TrackNum ())
|
|
dest = dummy;
|
|
}
|
|
MSG_ReadAngleV (net_message, dest);
|
|
break;
|
|
}
|
|
case svc_serverdata:
|
|
// make sure any stuffed commands are done
|
|
if (stuffbuf && stuffbuf->str[0]) {
|
|
Cbuf_AddText (cl_stbuf, stuffbuf->str);
|
|
dstring_clearstr (stuffbuf);
|
|
}
|
|
Cbuf_Execute_Stack (cl_stbuf);
|
|
CL_ParseServerData ();
|
|
// leave full screen intermission
|
|
r_data->vid->recalc_refdef = true;
|
|
break;
|
|
|
|
case svc_lightstyle:
|
|
i = MSG_ReadByte (net_message);
|
|
if (i >= MAX_LIGHTSTYLES)
|
|
Host_Error ("svc_lightstyle > MAX_LIGHTSTYLES");
|
|
strcpy (cl.lightstyle[i].map, MSG_ReadString (net_message));
|
|
cl.lightstyle[i].length = strlen (cl.lightstyle[i].map);
|
|
if (cl.lightstyle[i].length) {
|
|
int total = 0;
|
|
|
|
cl.lightstyle[i].peak = 'a';
|
|
for (j = 0; j < cl.lightstyle[i].length; j++) {
|
|
total += cl.lightstyle[i].map[j] - 'a';
|
|
cl.lightstyle[i].peak = max (cl.lightstyle[i].peak,
|
|
cl.lightstyle[i].map[j]);
|
|
}
|
|
total /= cl.lightstyle[i].length;
|
|
cl.lightstyle[i].average = total + 'a';
|
|
} else {
|
|
cl.lightstyle[i].average = 'm';
|
|
cl.lightstyle[i].peak = 'm';
|
|
}
|
|
break;
|
|
|
|
// svc_updatename
|
|
|
|
case svc_updatefrags:
|
|
Sbar_Changed ();
|
|
i = MSG_ReadByte (net_message);
|
|
if (i >= MAX_CLIENTS)
|
|
Host_Error ("CL_ParseServerMessage: svc_updatefrags > "
|
|
"MAX_SCOREBOARD");
|
|
cl.players[i].frags = (short) MSG_ReadShort (net_message);
|
|
break;
|
|
|
|
// svc_clientdata
|
|
|
|
case svc_stopsound:
|
|
i = MSG_ReadShort (net_message);
|
|
S_StopSound (i >> 3, i & 7);
|
|
break;
|
|
|
|
// svc_updatecolors
|
|
// svc_particle
|
|
|
|
case svc_damage:
|
|
V_ParseDamage ();
|
|
break;
|
|
|
|
case svc_spawnstatic:
|
|
CL_ParseStatic ();
|
|
break;
|
|
|
|
// svc_spawnbinary
|
|
|
|
case svc_spawnbaseline:
|
|
i = MSG_ReadShort (net_message);
|
|
CL_ParseBaseline (&qw_entstates.baseline[i]);
|
|
break;
|
|
|
|
case svc_temp_entity:
|
|
CL_ParseTEnt ();
|
|
break;
|
|
|
|
case svc_setpause:
|
|
r_data->paused = cl.paused = MSG_ReadByte (net_message);
|
|
if (cl.paused)
|
|
CDAudio_Pause ();
|
|
else
|
|
CDAudio_Resume ();
|
|
break;
|
|
|
|
// svc_signonnum
|
|
|
|
case svc_centerprint:
|
|
str = MSG_ReadString (net_message);
|
|
if (strcmp (str, centerprint->str)) {
|
|
dstring_copystr (centerprint, str);
|
|
//FIXME logging
|
|
}
|
|
Sbar_CenterPrint (str);
|
|
break;
|
|
|
|
case svc_killedmonster:
|
|
cl.stats[STAT_MONSTERS]++;
|
|
break;
|
|
|
|
case svc_foundsecret:
|
|
cl.stats[STAT_SECRETS]++;
|
|
break;
|
|
|
|
case svc_spawnstaticsound:
|
|
CL_ParseStaticSound ();
|
|
break;
|
|
|
|
case svc_intermission:
|
|
Sys_MaskPrintf (SYS_DEV, "svc_intermission\n");
|
|
|
|
cl.intermission = 1;
|
|
r_data->force_fullscreen = 1;
|
|
cl.completed_time = realtime;
|
|
r_data->vid->recalc_refdef = true; // go to full screen
|
|
Sys_MaskPrintf (SYS_DEV, "intermission simorg: ");
|
|
MSG_ReadCoordV (net_message, cl.simorg);
|
|
for (i = 0; i < 3; i++)
|
|
Sys_MaskPrintf (SYS_DEV, "%f ", cl.simorg[i]);
|
|
Sys_MaskPrintf (SYS_DEV, "\nintermission simangles: ");
|
|
MSG_ReadAngleV (net_message, cl.simangles);
|
|
cl.simangles[ROLL] = 0; // FIXME @@@
|
|
for (i = 0; i < 3; i++)
|
|
Sys_MaskPrintf (SYS_DEV, "%f ", cl.simangles[i]);
|
|
Sys_MaskPrintf (SYS_DEV, "\n");
|
|
VectorZero (cl.simvel);
|
|
|
|
// automatic fraglogging (by elmex)
|
|
// XXX: Should this _really_ called here?
|
|
if (!cls.demoplayback)
|
|
Sbar_LogFrags ();
|
|
break;
|
|
|
|
case svc_finale:
|
|
cl.intermission = 2;
|
|
r_data->force_fullscreen = 1;
|
|
cl.completed_time = realtime;
|
|
r_data->vid->recalc_refdef = true; // go to full screen
|
|
str = MSG_ReadString (net_message);
|
|
if (strcmp (str, centerprint->str)) {
|
|
dstring_copystr (centerprint, str);
|
|
//FIXME logging
|
|
}
|
|
Sbar_CenterPrint (str);
|
|
break;
|
|
|
|
case svc_cdtrack:
|
|
cl.cdtrack = MSG_ReadByte (net_message);
|
|
CDAudio_Play ((byte) cl.cdtrack, true);
|
|
break;
|
|
|
|
case svc_sellscreen:
|
|
Cmd_ExecuteString ("help", src_command);
|
|
break;
|
|
|
|
// svc_cutscene (same value as svc_smallkick)
|
|
|
|
case svc_smallkick:
|
|
cl.punchangle[PITCH] = -2;
|
|
break;
|
|
|
|
case svc_bigkick:
|
|
cl.punchangle[PITCH] = -4;
|
|
break;
|
|
|
|
case svc_updateping:
|
|
i = MSG_ReadByte (net_message);
|
|
if (i >= MAX_CLIENTS)
|
|
Host_Error ("CL_ParseServerMessage: svc_updateping > "
|
|
"MAX_SCOREBOARD");
|
|
cl.players[i].ping = MSG_ReadShort (net_message);
|
|
break;
|
|
|
|
case svc_updateentertime:
|
|
// time is sent over as seconds ago
|
|
i = MSG_ReadByte (net_message);
|
|
if (i >= MAX_CLIENTS)
|
|
Host_Error ("CL_ParseServerMessage: svc_updateentertime "
|
|
"> MAX_SCOREBOARD");
|
|
cl.players[i].entertime = realtime - MSG_ReadFloat
|
|
(net_message);
|
|
break;
|
|
|
|
case svc_updatestatlong:
|
|
i = MSG_ReadByte (net_message);
|
|
j = MSG_ReadLong (net_message);
|
|
CL_SetStat (i, j);
|
|
break;
|
|
|
|
case svc_muzzleflash:
|
|
CL_MuzzleFlash ();
|
|
break;
|
|
|
|
case svc_updateuserinfo:
|
|
CL_UpdateUserinfo ();
|
|
break;
|
|
|
|
case svc_download:
|
|
CL_ParseDownload ();
|
|
break;
|
|
|
|
case svc_playerinfo:
|
|
CL_ParsePlayerinfo ();
|
|
break;
|
|
|
|
case svc_nails:
|
|
CL_ParseProjectiles (false);
|
|
break;
|
|
|
|
case svc_chokecount: // some preceding packets were choked
|
|
i = MSG_ReadByte (net_message);
|
|
for (j = 0; j < i; j++)
|
|
cl.frames[(cls.netchan.incoming_acknowledged - 1 - j) &
|
|
UPDATE_MASK].receivedtime = -2;
|
|
break;
|
|
|
|
case svc_modellist:
|
|
CL_ParseModellist ();
|
|
break;
|
|
|
|
case svc_soundlist:
|
|
CL_ParseSoundlist ();
|
|
break;
|
|
|
|
case svc_packetentities:
|
|
CL_ParsePacketEntities (false);
|
|
break;
|
|
|
|
case svc_deltapacketentities:
|
|
CL_ParsePacketEntities (true);
|
|
break;
|
|
|
|
case svc_maxspeed:
|
|
movevars.maxspeed = MSG_ReadFloat (net_message);
|
|
break;
|
|
|
|
case svc_entgravity:
|
|
movevars.entgravity = MSG_ReadFloat (net_message);
|
|
break;
|
|
|
|
case svc_setinfo:
|
|
CL_SetInfo ();
|
|
break;
|
|
|
|
case svc_serverinfo:
|
|
CL_ServerInfo ();
|
|
break;
|
|
|
|
case svc_updatepl:
|
|
i = MSG_ReadByte (net_message);
|
|
if (i >= MAX_CLIENTS)
|
|
Host_Error ("CL_ParseServerMessage: svc_updatepl > "
|
|
"MAX_SCOREBOARD");
|
|
cl.players[i].pl = MSG_ReadByte (net_message);
|
|
break;
|
|
|
|
case svc_nails2: // FIXME from qwex
|
|
CL_ParseProjectiles (true);
|
|
break;
|
|
}
|
|
}
|
|
|
|
CL_SetSolidEntities ();
|
|
}
|