qf/quakeforge
0
0
Fork 0
mirror of https://git.code.sf.net/p/quake/quakeforge synced 2024-11-23 12:52:46 +00:00
Code Issues Projects Releases Packages Wiki Activity
quakeforge/qw/source/cl_parse.c
Bill Currie 80bc0e9fb8 Make nq and qw use the new entity state struct. 
This isn't really the best solution, but it does get things being shared
with the minimum of fuss.
2012-07-05 09:39:16 +09:00

1692 lines
41 KiB
C
Raw Blame History

/*
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 "qw/bothdefs.h"
#include "cl_cam.h"
#include "cl_chat.h"
#include "cl_ents.h"
#include "cl_http.h"
#include "cl_input.h"
#include "cl_main.h"
#include "cl_parse.h"
#include "cl_skin.h"
#include "cl_tent.h"
#include "client.h"
#include "compat.h"
#include "host.h"
#include "map_cfg.h"
#include "qw/pmove.h"
#include "qw/protocol.h"
#include "sbar.h"
#include "clview.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;
}
*/
QFS_FOpenFile (filename, &f);
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;
QFS_StripExtension (mapname, name);
strcat (name, ".ent");
if ((buf = (char *) QFS_LoadFile (name, 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 ();
}
Reference in a new issue View git blame Copy permalink