quakeforge/qw/source/cl_parse.c
Adam Olsen 2994824bc6 - convert MSG_Write to the same overflow checking MSG_Read uses, so
errors can be handled
- add a MSG_ReadBlock and MSG_WriteBlock, which write arbitrary
- add a MSG_PeekByte, although I never actually used it..
- canonicalize the svc's, so that if qw and nq have a svc with the
  same name but different contents, they get different names
- add all the nq stuff to svc_t, so it has both nq and qw.  fun enum
  that :)
- fix all the sizebuf_t usages so they init all the fields properly
- move qw's net_svc.c, net_clc.c, net_packetlog.c, and msg_ucmd.c
  (renamed to net_ucmd.c) into libs/net
- move headers for the above in include/QF
- convert remaining clc bits to NET_CLC (I think I got them all)
- I split net_svc into net_svc_common and net_svc_qw too, in
  preperation for adding nq
- moved movevars_t into "QF/net_svc_qw.h", from pmove.h
- made the CL_Parse* functions in qw get the net_svc_*_t as a param,
  instead of parsing themselves
- use a jumptable for CL_Parse*
- probably other machinates I've forgotten
- and of course, probably added numerous bugs :)
2001-11-10 23:52:35 +00:00

1334 lines
32 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
*/
static const char rcsid[] =
"$Id$";
#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/cdaudio.h"
#include "QF/cmd.h"
#include "QF/console.h"
#include "QF/cvar.h"
#include "QF/hash.h"
#include "QF/msg.h"
#include "QF/net_clc.h"
#include "QF/net_protocol.h"
#include "QF/net_svc.h"
#include "QF/screen.h"
#include "QF/sound.h"
#include "QF/sys.h"
#include "QF/teamplay.h"
#include "QF/va.h"
#include "QF/vfile.h"
#include "bothdefs.h"
#include "cl_ents.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 "pmove.h"
#include "sbar.h"
#include "view.h"
int oldparsecountmod;
int parsecountmod;
double parsecounttime;
int viewentity;
int cl_spikeindex, cl_playerindex, cl_flagindex;
int cl_h_playerindex, cl_gib1index, cl_gib2index, cl_gib3index;
int packet_latency[NET_TIMINGS];
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)
{
VFile *f;
net_clc_stringcmd_t block;
if (strstr (filename, "..")) {
Con_Printf ("Refusing to download a path with ..\n");
return true;
}
if (!snd_initialized && strnequal ("sound/", filename, 6)) {
// don't bother downloading sownds if we can't play them
return true;
}
COM_FOpenFile (filename, &f);
if (f) { // it exists, no need to download
Qclose (f);
return true;
}
// ZOID - can't download when recording
if (cls.demorecording) {
Con_Printf ("Unable to download %s in record mode.\n",
cls.downloadname);
return true;
}
// ZOID - can't download when playback
if (cls.demoplayback)
return true;
strcpy (cls.downloadname, filename);
Con_Printf ("Downloading %s...\n", cls.downloadname);
// download to a temp name, and only rename
// to the real name when done, so if interrupted
// a runt file wont be left
COM_StripExtension (cls.downloadname, cls.downloadtempname);
strncat (cls.downloadtempname, ".tmp",
sizeof (cls.downloadtempname) - strlen (cls.downloadtempname));
block.command = va ("download %s", cls.downloadname);
NET_CLC_Emit (clc_stringcmd, &block, &cls.netchan.message);
cls.downloadnumber++;
return false;
}
void
Model_NextDownload (void)
{
char *s;
int i;
net_clc_stringcmd_t block;
if (cls.downloadnumber == 0) {
Con_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 (!cls.demoplayback)
Netchan_AckPacket (&cls.netchan);
for (i = 1; i < MAX_MODELS; 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]) {
Con_Printf ("\nThe required model file '%s' could not be found or "
"downloaded.\n\n", cl.model_name[i]);
Con_Printf ("You may need to download or purchase a %s client "
"pack in order to play on this server.\n\n",
gamedirfile);
CL_Disconnect ();
return;
}
if (strequal (cl.model_name[i], "progs/player.mdl")
&& cl.model_precache[i]->type == mod_alias)
info_key = pmodel_name;
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 = Cache_Get
(&cl.model_precache[i]->cache);
Info_SetValueForKey (cls.userinfo, info_key, va ("%d", ahdr->crc),
0);
block.command = va ("setinfo %s %d", info_key, ahdr->crc);
NET_CLC_Emit (clc_stringcmd, &block, &cls.netchan.message);
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]) {
Host_NetError ("\nThe server has failed to provide the map name.\n\n"
"Disconnecting to prevent a crash.\n\n");
return;
}
// all done
cl.worldmodel = cl.model_precache[1];
R_NewMap (cl.worldmodel, cl.model_precache, MAX_MODELS);
Team_NewMap ();
Hunk_Check (); // make sure nothing is hurt
// done with modellist, request first of static signon messages
block.command = va (prespawn_name, cl.servercount,
cl.worldmodel->checksum2);
NET_CLC_Emit (clc_stringcmd, &block, &cls.netchan.message);
}
void
Sound_NextDownload (void)
{
char *s;
int i;
net_clc_stringcmd_t block;
if (cls.downloadnumber == 0) {
Con_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
}
if (!cls.demoplayback)
Netchan_AckPacket (&cls.netchan);
for (i = 1; i < MAX_SOUNDS; 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;
block.command = va (modellist_name, cl.servercount, 0);
NET_CLC_Emit (clc_stringcmd, &block, &cls.netchan.message);
}
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:
Con_DPrintf ("Unknown download type.\n");
}
}
/*
CL_ParseDownload
A download message has been received from the server
*/
void
CL_ParseDownload (net_svc_download_t *block)
{
byte name[1024];
int r;
net_clc_stringcmd_t stringcmd;
if (cls.demoplayback)
return; // not in demo playback
if (block->size == -1) {
Con_Printf ("File not found.\n");
if (cls.download) {
Con_Printf ("cls.download shouldn't have been set\n");
Qclose (cls.download);
cls.download = NULL;
}
CL_RequestNextDownload ();
return;
}
if (block->size == -2) {
// don't compare past the end of cls.downloadname due to gz support
if (strncmp (block->name, cls.downloadname, strlen (cls.downloadname))
|| strstr (block->name + strlen (cls.downloadname), "/")) {
Con_Printf ("WARNING: server tried to give a strange new "
"name: %s\n", block->name);
CL_RequestNextDownload ();
return;
}
if (cls.download) {
Qclose (cls.download);
unlink (cls.downloadname);
}
strncpy (cls.downloadname, block->name,
sizeof (cls.downloadname) - 1);
Con_Printf ("downloading to %s\n", cls.downloadname);
return;
}
if (block->size <= 0) {
Host_NetError ("Bad download block, size %d", block->size);
return;
}
// open the file if not opened yet
if (!cls.download) {
if (strncmp (cls.downloadtempname, "skins/", 6))
snprintf (name, sizeof (name), "%s/%s", com_gamedir,
cls.downloadtempname);
else
snprintf (name, sizeof (name), "%s/%s/%s", fs_userpath->string,
fs_skinbase->string, cls.downloadtempname);
COM_CreatePath (name);
cls.download = Qopen (name, "wb");
if (!cls.download) {
Con_Printf ("Failed to open %s\n", cls.downloadtempname);
CL_RequestNextDownload ();
return;
}
}
Qwrite (cls.download, block->data, block->size);
if (block->percent != 100) {
// change display routines by zoid
// request next block
#if 0
Con_Printf (".");
if (10 * (download.percent / 10) != cls.downloadpercent) {
cls.downloadpercent = 10 * (download.percent / 10);
Con_Printf ("%i%%", cls.downloadpercent);
}
#endif
if (block->percent != cls.downloadpercent)
VID_SetCaption (va ("Downloading %s %d%%", cls.downloadname,
block->percent));
cls.downloadpercent = block->percent;
stringcmd.command = "nextdl";
NET_CLC_Emit (clc_stringcmd, &stringcmd, &cls.netchan.message);
} else {
char oldn[MAX_OSPATH];
char newn[MAX_OSPATH];
#if 0
Con_Printf ("100%%\n");
#endif
Qclose (cls.download);
VID_SetCaption (va ("Connecting to %s", cls.servername));
// rename the temp file to it's final name
if (strcmp (cls.downloadtempname, cls.downloadname)) {
if (strncmp (cls.downloadtempname, "skins/", 6)) {
snprintf (oldn, sizeof (oldn), "%s/%s", com_gamedir,
cls.downloadtempname);
snprintf (newn, sizeof (newn), "%s/%s", com_gamedir,
cls.downloadname);
} else {
snprintf (oldn, sizeof (oldn), "%s/%s/%s", fs_userpath->string,
fs_skinbase->string, cls.downloadtempname);
snprintf (newn, sizeof (newn), "%s/%s/%s", fs_userpath->string,
fs_skinbase->string, cls.downloadname);
}
r = Qrename (oldn, newn);
if (r)
Con_Printf ("failed to rename, %s.\n", strerror (errno));
}
cls.download = NULL;
cls.downloadpercent = 0;
// get another file if needed
CL_RequestNextDownload ();
}
}
static byte *upload_data;
static int upload_pos, upload_size;
void
CL_NextUpload (void)
{
int r;
net_clc_upload_t block;
if (!upload_data)
return;
r = upload_size - upload_pos;
if (r > 768)
r = 768;
block.size = r;
block.percent = upload_pos * 100 / (upload_size ?: 1);
block.data = upload_data + upload_pos;
NET_CLC_Emit (clc_upload, &block, &cls.netchan.message);
upload_pos += r;
Con_DPrintf ("UPLOAD: %6d: %d written\n", upload_pos - r, r);
if (upload_pos != upload_size)
return;
Con_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; // gotta be connected
// override
if (upload_data)
free (upload_data);
Con_DPrintf ("Upload starting of %d...\n", size);
upload_data = malloc (size);
if (!upload_data)
Sys_Error ("CL_StartUpload: Memory Allocation Failure\n");
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;
}
void
CL_ParseQWPrint (net_svc_qwprint_t *block)
{
const char *string;
char tmpstring[2048];
string = block->message;
if (block->level == PRINT_CHAT) {
// TODO: cl_nofake 2 -- accept fake messages from
// teammates
if (cl_nofake->int_val) {
char *c;
strncpy (tmpstring, string, sizeof (tmpstring));
tmpstring[sizeof (tmpstring) - 1] = 0;
for (c = tmpstring; *c; c++)
if (*c == '\r')
*c = '#';
string = tmpstring;
}
con_ormask = 128;
S_LocalSound ("misc/talk.wav");
Team_ParseChat(string);
}
Con_Printf ("%s", string);
con_ormask = 0;
}
/* SERVER CONNECTING MESSAGES */
void Draw_ClearCache (void);
void CL_ClearBaselines (void); // LordHavoc: BIG BUG-FIX!
void
CL_ParseServerData (net_svc_serverdata_t *block)
{
char fn[MAX_OSPATH];
int protover;
qboolean cflag = false;
net_clc_stringcmd_t stringcmd;
Con_DPrintf ("Serverdata packet received.\n");
// make sure any stuffed commands are done
Cbuf_Execute ();
// wipe the client_state_t struct
CL_ClearState ();
// parse protocol version number
// allow 2.2 and 2.29 demos to play
protover = block->protocolversion;
if (protover != PROTOCOL_VERSION &&
!(cls.demoplayback
&& (protover <= 26 && protover >= 28)))
Host_NetError ("Server returned version %i, not %i\nYou probably "
"need to upgrade.\nCheck http://www.quakeworld.net/",
protover, PROTOCOL_VERSION);
cl.servercount = block->servercount;
// game directory
if (!strequal (gamedirfile, block->gamedir)) {
// save current config
Host_WriteConfiguration ();
cflag = true;
Draw_ClearCache ();
}
COM_Gamedir (block->gamedir);
// ZOID--run the autoexec.cfg in the gamedir
// if it exists
if (cflag) {
int cmd_warncmd_val = cmd_warncmd->int_val;
Cbuf_AddText ("cmd_warncmd 0\n");
Cbuf_AddText ("exec config.cfg\n");
Cbuf_AddText ("exec frontend.cfg\n");
if (cl_autoexec->int_val) {
Cbuf_AddText ("exec autoexec.cfg\n");
}
snprintf (fn, sizeof (fn), "cmd_warncmd %d\n", cmd_warncmd_val);
Cbuf_AddText (fn);
}
// parse player slot
cl.playernum = block->playernum;
cl.spectator = block->spectator;
if (cl.playernum >= MAX_CLIENTS) {
Host_NetError ("CL_ParseServerData: playernum %d >= MAX_CLIENTS",
cl.playernum);
return;
}
// FIXME: evil hack so NQ and QW can share sound code
cl.viewentity = cl.playernum + 1;
viewentity = cl.playernum + 1;
// get the full level name
strncpy (cl.levelname, block->levelname, sizeof (cl.levelname) - 1);
// get the movevars
memcpy (&movevars, &block->movevars, sizeof (movevars));
// seperate the printfs so the server message can have a color
Con_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");
Con_Printf ("%c%s\n", 2, block->levelname);
// ask for the sound list next
memset (cl.sound_name, 0, sizeof (cl.sound_name));
stringcmd.command = va (soundlist_name, cl.servercount, 0);
NET_CLC_Emit (clc_stringcmd, &stringcmd, &cls.netchan.message);
// now waiting for downloads, etc
CL_SetState (ca_onserver);
CL_ClearBaselines ();
// leave full screen intermission
vid.recalc_refdef = true;
}
// LordHavoc: BIG BUG-FIX! Clear baselines each time it connects...
void
CL_ClearBaselines (void)
{
int i;
memset (cl_baselines, 0, sizeof (cl_baselines));
for (i = 0; i < MAX_EDICTS; i++) {
cl_baselines[i].alpha = 255;
cl_baselines[i].scale = 16;
cl_baselines[i].glow_color = 254;
cl_baselines[i].glow_size = 0;
cl_baselines[i].colormod = 255;
}
}
void
CL_ParseSoundlist (net_svc_soundlist_t *block)
{
const char *str;
int numsounds, i;
net_clc_stringcmd_t stringcmd;
// precache sounds
for (i = 0, numsounds = block->startsound;; i++) {
str = block->sounds[i];
if (!str[0])
break;
numsounds++;
if (numsounds >= MAX_SOUNDS) {
Host_NetError ("CL_ParseSoundlist: too many sounds");
return;
}
strcpy (cl.sound_name[numsounds], str);
}
if (block->nextsound) {
stringcmd.command = va (soundlist_name, cl.servercount,
block->nextsound);
NET_CLC_Emit (clc_stringcmd, &stringcmd, &cls.netchan.message);
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_sound;
Sound_NextDownload ();
}
void
CL_ParseModellist (net_svc_modellist_t *block)
{
int nummodels, i;
const char *str;
net_clc_stringcmd_t stringcmd;
// precache models and note certain default indexes
for (i = 0, nummodels = block->startmodel;; i++) {
str = block->models[i];
if (!str[0])
break;
nummodels++;
if (nummodels >= MAX_MODELS) {
Host_NetError ("CL_ParseModellist: too many models");
return;
}
strncpy (cl.model_name[nummodels], str, MAX_QPATH - 1);
cl.model_name[nummodels][MAX_QPATH - 1] = '\0';
if (!strcmp (str, "progs/spike.mdl"))
cl_spikeindex = nummodels;
else if (!strcmp (str, "progs/player.mdl"))
cl_playerindex = nummodels;
else if (!strcmp (str, "progs/flag.mdl"))
cl_flagindex = nummodels;
// for deadbodyfilter & gibfilter
else if (!strcmp (str, "progs/h_player.mdl"))
cl_h_playerindex = nummodels;
else if (!strcmp (str, "progs/gib1.mdl"))
cl_gib1index = nummodels;
else if (!strcmp (str, "progs/gib2.mdl"))
cl_gib2index = nummodels;
else if (!strcmp (str, "progs/gib3.mdl"))
cl_gib3index = nummodels;
}
if (block->nextmodel) {
stringcmd.command = va (modellist_name, cl.servercount,
block->nextmodel);
NET_CLC_Emit (clc_stringcmd, &stringcmd, &cls.netchan.message);
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_model;
Model_NextDownload ();
}
void
CL_ParseNOP (net_svc_nop_t *block)
{
}
void
CL_ParseDisconnect (net_svc_disconnect_t *block)
{
if (cls.state == ca_connected)
Host_EndGame ("Server disconnected\n"
"Server version may not be compatible");
else
Host_EndGame ("Server disconnected");
}
void
CL_ParseCenterprint (net_svc_centerprint_t *block)
{
SCR_CenterPrint (block->message);
}
void
CL_ParseStufftext (net_svc_stufftext_t *block)
{
Con_DPrintf ("stufftext: %s\n", block->commands);
Cbuf_AddText (block->commands);
}
void
CL_ParseSetAngle (net_svc_setangle_t *block)
{
VectorCopy (block->angles, cl.viewangles);
}
void
CL_ParseLightStyle (net_svc_lightstyle_t *block)
{
lightstyle_t *style;
if (block->stylenum >= MAX_LIGHTSTYLES) {
Host_NetError ("svc_lightstyle > MAX_LIGHTSTYLES");
return;
}
style = &r_lightstyle[block->stylenum];
strncpy (style->map, block->map, sizeof (style->map) - 1);
style->map[sizeof (style->map) - 1] = 0;
style->length = strlen (style->map);
}
void
CL_ParseStopSound (net_svc_stopsound_t *block)
{
S_StopSound (block->entity, block->channel);
}
void
CL_ParseUpdateFrags (net_svc_updatefrags_t *block)
{
Sbar_Changed ();
if (block->player >= MAX_CLIENTS) {
Host_NetError ("CL_ParseServerMessage: svc_updatefrags > "
"MAX_SCOREBOARD");
return;
}
cl.players[block->player].frags = block->frags;
}
void
CL_ParseUpdatePing (net_svc_updateping_t *block)
{
if (block->player >= MAX_CLIENTS) {
Host_NetError ("CL_ParseServerMessage: svc_updateping > "
"MAX_SCOREBOARD");
return;
}
cl.players[block->player].ping = block->ping;
}
void
CL_ParseUpdatePL (net_svc_updatepl_t *block)
{
if (block->player >= MAX_CLIENTS) {
Host_NetError ("CL_ParseServerMessage: svc_updatepl > "
"MAX_SCOREBOARD");
return;
}
cl.players[block->player].pl = block->packetloss;
}
void
CL_ParseUpdateEnterTime (net_svc_updateentertime_t *block)
{
if (block->player >= MAX_CLIENTS) {
Host_NetError ("CL_ParseServerMessage: svc_updateentertime "
"> MAX_SCOREBOARD");
return;
}
cl.players[block->player].entertime = realtime - block->secondsago;
}
void
CL_ParseSpawnBaseline (net_svc_spawnbaseline_t *block)
{
entity_state_t *es;
if (block->num >= MAX_EDICTS) {
Host_NetError ("CL_ParseSpawnBaseline: num %i >= MAX_EDICTS",
block->num);
return;
}
if (block->modelindex >= MAX_MODELS) {
Host_NetError ("CL_ParseSpawnBaseline: modelindex %i >= MAX_MODELS",
block->modelindex);
return;
}
es = &cl_baselines[block->num];
es->modelindex = block->modelindex;
es->frame = block->frame;
es->colormap = block->colormap;
es->skinnum = block->skinnum;
VectorCopy (block->origin, es->origin);
VectorCopy (block->angles, es->angles);
// LordHavoc: set up the baseline to account for new effects (alpha,
// colormod, etc)
es->alpha = 255;
es->scale = 16;
es->glow_color = 254;
es->glow_size = 0;
es->colormod = 255;
}
/*
CL_ParseStatic
Static entities are non-interactive world objects
like torches
*/
void
CL_ParseStatic (net_svc_spawnstatic_t *block)
{
entity_t *ent;
if (block->modelindex >= MAX_MODELS) {
Host_NetError ("CL_ParseStatic: modelindex %i >= MAX_MODELS",
block->modelindex);
return;
}
if (cl.num_statics >= MAX_STATIC_ENTITIES) {
Host_NetError ("Too many static entities");
return;
}
ent = &cl_static_entities[cl.num_statics++];
CL_Init_Entity (ent);
// copy it to the current state
ent->model = cl.model_precache[block->modelindex];
ent->frame = block->frame;
ent->skinnum = block->skinnum;
VectorCopy (block->origin, ent->origin);
VectorCopy (block->angles, ent->angles);
R_AddEfrags (ent);
}
void
CL_ParseStaticSound (net_svc_spawnstaticsound_t *block)
{
S_StaticSound (cl.sound_precache[block->sound_num], block->position,
block->volume, block->attenuation);
}
/* ACTION MESSAGES */
void
CL_ParseQWSound (net_svc_qwsound_t *block)
{
if (block->entity >= MAX_EDICTS) {
Host_NetError ("CL_ParseQWSound: ent = %i", block->entity);
return;
}
if (block->sound_num >= MAX_SOUNDS) {
Host_NetError ("CL_ParseQWSound: sound_num = %i",
block->sound_num);
return;
}
S_StartSound (block->entity, block->channel,
cl.sound_precache[block->sound_num], block->position,
block->volume, block->attenuation);
}
/*
CL_ParseClientdata
Server information pertaining to this client only, 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];
parsecounttime = cl.frames[i].senttime;
frame->receivedtime = realtime;
// calculate latency
latency = frame->receivedtime - frame->senttime;
if (latency < 0 || latency > 1.0) {
// Con_Printf ("Odd latency: %5.2f\n", latency);
} else {
// 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
}
}
void
CL_ProcessUserInfo (int slot, player_info_t *player)
{
char skin[512];
const char *s;
s = Info_ValueForKey (player->userinfo, "skin");
COM_StripExtension (s, skin); // FIXME buffer overflow
if (!strequal (s, skin))
Info_SetValueForKey (player->userinfo, "skin", skin, 1);
strncpy (player->name, Info_ValueForKey (player->userinfo, "name"),
sizeof (player->name) - 1);
player->_topcolor = player->_bottomcolor = -1;
player->topcolor = atoi (Info_ValueForKey (player->userinfo, "topcolor"));
player->bottomcolor =
atoi (Info_ValueForKey (player->userinfo, "bottomcolor"));
while (!(player->team = Hash_Find (player->userinfo->tab, "team")))
Info_SetValueForKey (player->userinfo, "team", "", 1);
while (!(player->skinname = Hash_Find (player->userinfo->tab, "skin")))
Info_SetValueForKey (player->userinfo, "skin", "", 1);
if (Info_ValueForKey (player->userinfo, "*spectator")[0])
player->spectator = true;
else
player->spectator = false;
if (cls.state == ca_active)
Skin_Find (player);
Sbar_Changed ();
//XXX CL_NewTranslation (slot);
}
void
CL_ParseUpdateUserInfo (net_svc_updateuserinfo_t *block)
{
player_info_t *player;
if (block->slot >= MAX_CLIENTS) {
Host_NetError ("CL_ParseUpdateUserInfo: slot %i >= MAX_CLIENTS",
block->slot);
return;
}
player = &cl.players[block->slot];
player->userid = block->userid;
if (player->userinfo)
Info_Destroy (player->userinfo);
player->userinfo = Info_ParseString (block->userinfo,
MAX_INFO_STRING);
CL_ProcessUserInfo (block->slot, player);
}
void
CL_ParseSetInfo (net_svc_setinfo_t *block)
{
int flags;
player_info_t *player;
if (block->slot >= MAX_CLIENTS) {
Host_NetError ("CL_ParseSetInfo: slot %i >= MAX_CLIENTS", block->slot);
return;
}
player = &cl.players[block->slot];
if (!player->userinfo)
player->userinfo = Info_ParseString ("", MAX_INFO_STRING);
Con_DPrintf ("SETINFO %s: %s=%s\n", player->name, block->key,
block->value);
flags = !strequal (block->key, "name");
flags |= strequal (block->key, "team") << 1;
Info_SetValueForKey (player->userinfo, block->key, block->value, flags);
CL_ProcessUserInfo (block->slot, player);
}
void
CL_ParseQWServerInfo (net_svc_qwserverinfo_t *block)
{
Con_DPrintf ("SERVERINFO: %s=%s\n", block->key, block->value);
Info_SetValueForKey (cl.serverinfo, block->key, block->value, 0);
if (strequal (block->key, "chase")) {
cl.chase = atoi (block->value);
} else if (strequal (block->key, "watervis")) {
cl.watervis = atoi (block->value);
}
}
void
CL_SetStat (int stat, int value)
{
int j;
if (stat < 0 || stat >= MAX_CL_STATS)
// Sys_Error ("CL_SetStat: %i is invalid", stat);
Host_NetError ("CL_SetStat: %i is invalid", stat);
Sbar_Changed ();
switch (stat) {
case STAT_ITEMS: // set flash times
Sbar_Changed ();
for (j = 0; j < 32; j++)
if ((value & (1 << j)) && !(cl.stats[stat] & (1 << j)))
cl.item_gettime[j] = cl.time;
break;
case STAT_HEALTH:
if (value <= 0)
Team_Dead ();
break;
}
cl.stats[stat] = value;
}
void
CL_ParseKilledMonster (net_svc_killedmonster_t *block)
{
cl.stats[STAT_MONSTERS]++;
}
void
CL_ParseFoundSecret (net_svc_foundsecret_t *block)
{
cl.stats[STAT_SECRETS]++;
}
void
CL_ParseQWUpdateStat (net_svc_qwupdatestat_t *block)
{
CL_SetStat (block->stat, block->value);
}
void
CL_ParseUpdateStatLong (net_svc_updatestatlong_t *block)
{
CL_SetStat (block->stat, block->value);
}
void
CL_ParseQWCDTrack (net_svc_qwcdtrack_t *block)
{
cl.cdtrack = block->cdtrack;
CDAudio_Play (cl.cdtrack, true);
}
void
CL_ParseQWIntermission (net_svc_qwintermission_t *block)
{
cl.intermission = 1;
cl.completed_time = realtime;
vid.recalc_refdef = true; // go to full screen
VectorCopy (block->origin, cl.simorg);
VectorCopy (block->angles, cl.simangles);
VectorCopy (vec3_origin, cl.simvel);
Con_DPrintf ("Intermission origin: %f %f %f\nIntermission angles: "
"%f %f %f\n", cl.simorg[0], cl.simorg[1], cl.simorg[2],
cl.simangles[0], cl.simangles[1], cl.simangles[2]);
}
void
CL_ParseFinale (net_svc_finale_t *block)
{
cl.intermission = 2;
cl.completed_time = realtime;
vid.recalc_refdef = true; // go to full screen
SCR_CenterPrint (block->message);
}
void
CL_ParseSellScreen (net_svc_sellscreen_t *block)
{
Cmd_ExecuteString ("help", src_command);
}
void
CL_ParseSmallKick (net_svc_smallkick_t *block)
{
cl.punchangle = -2;
}
void
CL_ParseBigKick (net_svc_bigkick_t *block)
{
cl.punchangle = -4;
}
void
CL_ParseMuzzleFlash (net_svc_muzzleflash_t *block)
{
dlight_t *dl;
int i;
player_state_t *pl;
vec3_t fv, rv, uv;
i = block->player;
if (i < 1 || i > MAX_CLIENTS)
return;
pl = &cl.frames[parsecountmod].playerstate[i - 1];
dl = R_AllocDlight (i); //FIXME
// this interfers with powerup glows, but we need more lights.
VectorCopy (pl->origin, dl->origin);
if (i - 1 == cl.playernum)
AngleVectors (cl.viewangles, fv, rv, uv);
else
AngleVectors (pl->viewangles, fv, rv, uv);
VectorMA (dl->origin, 18, fv, dl->origin);
dl->radius = 200 + (rand () & 31);
dl->minlight = 32;
dl->die = cl.time + 0.1;
dl->color[0] = 0.2;
dl->color[1] = 0.1;
dl->color[2] = 0.05;
}
void
CL_ParseChokeCount (net_svc_chokecount_t *block)
{
int j;
for (j = 0; j < block->count; j++)
cl.frames[(cls.netchan.incoming_acknowledged - 1 - j) &
UPDATE_MASK].receivedtime = -2;
}
void
CL_ParseMaxSpeed (net_svc_maxspeed_t *block)
{
movevars.maxspeed = block->maxspeed;
}
void
CL_ParseEntGravity (net_svc_entgravity_t *block)
{
movevars.entgravity = block->gravity;
}
void
CL_ParseSetPause (net_svc_setpause_t *block)
{
cl.paused = block->paused;
if (cl.paused)
CDAudio_Pause ();
else
CDAudio_Resume ();
}
typedef void (*cl_parse_t) (net_svc_any_t *block);
static cl_parse_t cl_parse_jumptable [] = {
[svc_nop] = (cl_parse_t) CL_ParseNOP,
[svc_disconnect] = (cl_parse_t) CL_ParseDisconnect,
[svc_qwprint] = (cl_parse_t) CL_ParseQWPrint,
[svc_centerprint] = (cl_parse_t) CL_ParseCenterprint,
[svc_stufftext] = (cl_parse_t) CL_ParseStufftext,
[svc_damage] = (cl_parse_t) CL_ParseDamage,
[svc_serverdata] = (cl_parse_t) CL_ParseServerData,
[svc_setangle] = (cl_parse_t) CL_ParseSetAngle,
[svc_lightstyle] = (cl_parse_t) CL_ParseLightStyle,
[svc_qwsound] = (cl_parse_t) CL_ParseQWSound,
[svc_stopsound] = (cl_parse_t) CL_ParseStopSound,
[svc_updatefrags] = (cl_parse_t) CL_ParseUpdateFrags,
[svc_updateping] = (cl_parse_t) CL_ParseUpdatePing,
[svc_updatepl] = (cl_parse_t) CL_ParseUpdatePL,
[svc_updateentertime] = (cl_parse_t) CL_ParseUpdateEnterTime,
[svc_spawnbaseline] = (cl_parse_t) CL_ParseSpawnBaseline,
[svc_spawnstatic] = (cl_parse_t) CL_ParseStatic,
[svc_qwtempentity] = (cl_parse_t) CL_ParseQWTEnt,
[svc_killedmonster] = (cl_parse_t) CL_ParseKilledMonster,
[svc_foundsecret] = (cl_parse_t) CL_ParseFoundSecret,
[svc_qwupdatestat] = (cl_parse_t) CL_ParseQWUpdateStat,
[svc_updatestatlong] = (cl_parse_t) CL_ParseUpdateStatLong,
[svc_spawnstaticsound] = (cl_parse_t) CL_ParseStaticSound,
[svc_qwcdtrack] = (cl_parse_t) CL_ParseQWCDTrack,
[svc_qwintermission] = (cl_parse_t) CL_ParseQWIntermission,
[svc_finale] = (cl_parse_t) CL_ParseFinale,
[svc_sellscreen] = (cl_parse_t) CL_ParseSellScreen,
[svc_smallkick] = (cl_parse_t) CL_ParseSmallKick,
[svc_bigkick] = (cl_parse_t) CL_ParseBigKick,
[svc_muzzleflash] = (cl_parse_t) CL_ParseMuzzleFlash,
[svc_updateuserinfo] = (cl_parse_t) CL_ParseUpdateUserInfo,
[svc_setinfo] = (cl_parse_t) CL_ParseSetInfo,
[svc_qwserverinfo] = (cl_parse_t) CL_ParseQWServerInfo,
[svc_download] = (cl_parse_t) CL_ParseDownload,
[svc_playerinfo] = (cl_parse_t) CL_ParsePlayerinfo,
[svc_nails] = (cl_parse_t) CL_ParseProjectiles,
[svc_chokecount] = (cl_parse_t) CL_ParseChokeCount,
[svc_modellist] = (cl_parse_t) CL_ParseModellist,
[svc_soundlist] = (cl_parse_t) CL_ParseSoundlist,
[svc_packetentities] = (cl_parse_t) CL_ParsePacketEntities,
[svc_deltapacketentities] = (cl_parse_t) CL_ParseDeltaPacketEntities,
[svc_maxspeed] = (cl_parse_t) CL_ParseMaxSpeed,
[svc_entgravity] = (cl_parse_t) CL_ParseEntGravity,
[svc_setpause] = (cl_parse_t) CL_ParseSetPause,
};
void
CL_ParseServerMessage (void)
{
svc_t cmd;
net_status_t retval;
net_svc_any_t block;
cl.last_servermessage = realtime;
CL_ClearProjectiles ();
if (cl_shownet->int_val == 1)
Con_Printf ("%i ", net_message->message->cursize);
else if (cl_shownet->int_val == 2)
Con_Printf ("------------------\n");
CL_ParseClientdata ();
// parse the message
while (1) {
if (cls.state == ca_disconnected)
break; // something called Host_NetError
if (net_message->badread) {
Host_NetError ("CL_ParseServerMessage: Bad server message");
break;
}
if (net_message->readcount == net_message->message->cursize) {
if (cl_shownet->int_val == 2)
Con_Printf ("%3i:%s\n", net_message->readcount,
"END OF MESSAGE");
break;
}
if (cl_shownet->int_val == 2)
Con_Printf ("%3i:%s\n", net_message->readcount - 1,
NET_SVC_GetString (cmd));
if ((retval = NET_SVC_Parse (&cmd, &block, net_message))) {
Host_NetError (retval == NET_SHORT ?
"CL_ParseServerMessage: Truncated Packet" :
"CL_ParseServerMessage: Invalid Packet");
return;
}
if (cmd < 0 || cmd >= sizeof (cl_parse_jumptable) /
sizeof (cl_parse_t) || !cl_parse_jumptable[cmd]) {
Host_NetError ("CL_ParseServerMessage: Jumptable Mismatch");
break;
}
cl_parse_jumptable[cmd] (&block);
}
CL_SetSolidEntities ();
}