quakeforge/nq/source/cl_parse.c
Bill Currie 12c84046f3 [cvar] Make cvars properly typed
This is an extremely extensive patch as it hits every cvar, and every
usage of the cvars. Cvars no longer store the value they control,
instead, they use a cexpr value object to reference the value and
specify the value's type (currently, a null type is used for strings).
Non-string cvars are passed through cexpr, allowing expressions in the
cvars' settings. Also, cvars have returned to an enhanced version of the
original (id quake) registration scheme.

As a minor benefit, relevant code having direct access to the
cvar-controlled variables is probably a slight optimization as it
removed a pointer dereference, and the variables can be located for data
locality.

The static cvar descriptors are made private as an additional safety
layer, though there's nothing stopping external modification via
Cvar_FindVar (which is needed for adding listeners).

While not used yet (partly due to working out the design), cvars can
have a validation function.

Registering a cvar allows a primary listener (and its data) to be
specified: it will always be called first when the cvar is modified. The
combination of proper listeners and direct access to the controlled
variable greatly simplifies the more complex cvar interactions as much
less null checking is required, and there's no need for one cvar's
callback to call another's.

nq-x11 is known to work at least well enough for the demos. More testing
will come.
2022-04-24 19:15:22 +09:00

1081 lines
27 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
#include "QF/cbuf.h"
#include "QF/cdaudio.h"
#include "QF/cmd.h"
#include "QF/console.h"
#include "QF/cvar.h"
#include "QF/dstring.h"
#include "QF/idparse.h"
#include "QF/input.h"
#include "QF/msg.h"
#include "QF/plist.h"
#include "QF/sys.h"
#include "QF/screen.h"
#include "QF/skin.h"
#include "QF/sound.h" // FIXME: DEFAULT_SOUND_PACKET_*
#include "QF/va.h"
#include "QF/scene/scene.h"
#include "QF/plugin/vid_render.h"
#include "QF/scene/entity.h"
#include "client/particles.h"
#include "client/temp_entities.h"
#include "client/world.h"
#include "compat.h"
#include "sbar.h"
#include "nq/include/client.h"
#include "nq/include/host.h"
#include "nq/include/server.h"
#include "nq/include/game.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_serverinfo", // [long] version
// [string] signon string
// [string]..[0]model cache
// [string]...[0]sounds cache
// [string]..[0]item cache
"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 [byte] looptrack
"svc_sellscreen",
"svc_cutscene",
// end of iD svc
// FIXME switchable extensions?
// protocol 666
"",
"",
"svc_skybox",
"",
"",
"svc_bf",
"svc_fog",
"svc_spawnbaseline2",
"svc_spawnstatic2",
"svc_spawnstaticsound2",
};
dstring_t *centerprint;
/*
CL_EntityNum
This error checks and tracks the total number of entities
*/
static entity_state_t *
CL_EntityNum (int num)
{
if (num < 0 || num >= MAX_EDICTS)
Host_Error ("CL_EntityNum: %i is an invalid number", num);
if (num >= cl.num_entities)
cl.num_entities = num + 1;
return &nq_entstates.baseline[num];
}
static void
CL_ParseStartSoundPacket (void)
{
float attenuation;
int channel, ent, field_mask, sound_num, volume;
field_mask = MSG_ReadByte (net_message);
if (field_mask & SND_VOLUME)
volume = MSG_ReadByte (net_message);
else
volume = DEFAULT_SOUND_PACKET_VOLUME;
if (field_mask & SND_ATTENUATION)
attenuation = MSG_ReadByte (net_message) / 64.0;
else
attenuation = DEFAULT_SOUND_PACKET_ATTENUATION;
if (field_mask & SND_LARGEENTITY) {
ent = MSG_ReadShort (net_message);
channel = MSG_ReadByte (net_message);
} else {
channel = MSG_ReadShort (net_message);
ent = channel >> 3;
channel &= 7;
}
if (field_mask & SND_LARGESOUND)
sound_num = MSG_ReadShort (net_message);
else
sound_num = MSG_ReadByte (net_message);
if (sound_num >= MAX_SOUNDS)
Host_Error ("CL_ParseStartSoundPacket: %i > MAX_SOUNDS", sound_num);
if (ent > MAX_EDICTS)
Host_Error ("CL_ParseStartSoundPacket: ent = %i", ent);
vec4f_t pos = { 0, 0, 0, 1};
MSG_ReadCoordV (net_message, (vec_t*)&pos);//FIXME
S_StartSound (ent, channel, cl.sound_precache[sound_num], pos,
volume / 255.0, attenuation);
}
/*
CL_KeepaliveMessage
When the client is taking a long time to load stuff, send keepalive
messages so the server doesn't disconnect.
*/
static void
CL_KeepaliveMessage (void)
{
byte olddata[8192];
float time;
static float lastmsg;
int ret;
sizebuf_t old;
if (sv.active)
return; // no need if server is local
if (cls.demoplayback)
return;
// read messages from server, should just be nops
old = *net_message->message;
memcpy (olddata, net_message->message->data,
net_message->message->cursize);
do {
ret = CL_GetMessage ();
switch (ret) {
default:
Host_Error ("CL_KeepaliveMessage: CL_GetMessage failed");
case 0:
break; // nothing waiting
case 1:
Host_Error ("CL_KeepaliveMessage: received a message");
break;
case 2:
if (MSG_ReadByte (net_message) != svc_nop)
Host_Error ("CL_KeepaliveMessage: datagram wasn't a nop");
break;
}
} while (ret);
*net_message->message = old;
memcpy (net_message->message->data, olddata,
net_message->message->cursize);
// check time
time = Sys_DoubleTime ();
if (time - lastmsg < 5)
return;
lastmsg = time;
// write out a nop
Sys_Printf ("--> client to server keepalive\n");
MSG_WriteByte (&cls.message, clc_nop);
NET_SendMessage (cls.netcon, &cls.message);
SZ_Clear (&cls.message);
}
static void
CL_NewMap (const char *mapname)
{
Con_NewMap ();
Hunk_Check (0); // make sure nothing is hurt
Sbar_CenterPrint (0);
CL_World_NewMap (mapname, 0);
}
static void
CL_ParseServerInfo (void)
{
char model_precache[MAX_MODELS][MAX_QPATH];
char sound_precache[MAX_SOUNDS][MAX_QPATH];
const char *str;
int i;
int nummodels;
Sys_MaskPrintf (SYS_dev, "Serverinfo packet received.\n");
S_BlockSound ();
S_StopAllSounds ();
// wipe the client_state_t struct
CL_ClearState ();
// parse protocol version number
i = MSG_ReadLong (net_message);
if (i != PROTOCOL_NETQUAKE && i!= PROTOCOL_FITZQUAKE) {
Host_Error ("Server returned version %i, not %i or %i\n", i,
PROTOCOL_NETQUAKE, PROTOCOL_FITZQUAKE);
goto done;
}
cl.protocol = i;
if (cl.protocol == PROTOCOL_FITZQUAKE)
write_angles = MSG_WriteAngle16V;
else
write_angles = MSG_WriteAngleV;
// parse maxclients
cl.maxclients = MSG_ReadByte (net_message);
if (cl.maxclients < 1 || cl.maxclients > MAX_SCOREBOARD) {
Sys_Printf ("Bad maxclients (%u) from server\n", cl.maxclients);
goto done;
}
cl.players = Hunk_AllocName (0, cl.maxclients * sizeof (*cl.players),
"players");
cl.viewstate.voffs_enabled = cl.maxclients == 1;
cl.viewstate.bob_enabled = 1;
for (i = 0; i < cl.maxclients; i++) {
cl.players[i].userinfo = Info_ParseString ("name\\", 0, 0);
cl.players[i].name = Info_Key (cl.players[i].userinfo, "name");
cl.players[i].topcolor = 0;
cl.players[i].bottomcolor = 0;
}
// parse gametype
cl.gametype = MSG_ReadByte (net_message);
// parse signon message
str = MSG_ReadString (net_message);
strncpy (cl.levelname, str, sizeof (cl.levelname) - 1);
// 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);
// first we go through and touch all of the precache data that still
// happens to be in the cache, so precaching something else doesn't
// needlessly purge it
// precache models
cl_world.models.size = 0;
DARRAY_APPEND (&cl_world.models, 0); // ind 0 is null model
for (nummodels = 1;; nummodels++) {
str = MSG_ReadString (net_message);
if (!str[0])
break;
if (nummodels >= MAX_MODELS) {
Sys_Printf ("Server sent too many model precaches\n");
goto done;
}
strcpy (model_precache[nummodels], str);
Mod_TouchModel (str);
}
// precache sounds
memset (cl.sound_precache, 0, sizeof (cl.sound_precache));
for (cl.numsounds = 1;; cl.numsounds++) {
str = MSG_ReadString (net_message);
if (!str[0])
break;
if (cl.numsounds >= MAX_SOUNDS) {
Sys_Printf ("Server sent too many sound precaches\n");
goto done;
}
strcpy (sound_precache[cl.numsounds], str);
}
// now we try to load everything else until a cache allocation fails
CL_MapCfg (model_precache[1]);
for (i = 1; i < nummodels; i++) {
DARRAY_APPEND (&cl_world.models,
Mod_ForName (model_precache[i], false));
if (cl_world.models.a[i] == NULL) {
Sys_Printf ("Model %s not found\n", model_precache[i]);
goto done;
}
CL_KeepaliveMessage ();
}
for (i = 1; i < cl.numsounds; i++) {
cl.sound_precache[i] = S_PrecacheSound (sound_precache[i]);
CL_KeepaliveMessage ();
}
// local state
cl_world.worldmodel = cl_world.models.a[1];
cl.chasestate.worldmodel = cl_world.worldmodel;
if (!centerprint)
centerprint = dstring_newstr ();
else
dstring_clearstr (centerprint);
CL_NewMap (model_precache[1]);
Hunk_Check (0); // make sure nothing is hurt
noclip_anglehack = false; // noclip is turned off at start
CL_ParticlesGravity (800); // Set up gravity for renderer effects
done:
S_UnblockSound ();
}
int bitcounts[16];
/*
CL_ParseUpdate
Parse an entity update message from the server
If an entities model or origin changes from frame to frame, it must be
relinked. Other attributes can change without relinking.
*/
static void
CL_ParseUpdate (int bits)
{
entity_state_t *baseline;
entity_state_t *state;
int modnum, num, i;
qboolean forcelink;
if (cls.signon == so_begin) {
// first update is the final signon stage
cls.signon = so_active;
CL_SignonReply ();
}
if (bits & U_MOREBITS) {
i = MSG_ReadByte (net_message);
bits |= (i << 8);
}
if (cl.protocol == PROTOCOL_FITZQUAKE) {
if (bits & U_EXTEND1)
bits |= MSG_ReadByte(net_message) << 16;
if (bits & U_EXTEND2)
bits |= MSG_ReadByte(net_message) << 24;
}
if (bits & U_LONGENTITY)
num = MSG_ReadShort (net_message);
else
num = MSG_ReadByte (net_message);
baseline = CL_EntityNum (num);
state = &nq_entstates.frame[0 + cl.frameIndex][num];
for (i = 0; i < 16; i++)
if (bits & (1 << i))
bitcounts[i]++;
if (cl_msgtime[num] != cl.mtime[1])
forcelink = true; // no previous frame to lerp from
else
forcelink = false;
cl_msgtime[num] = cl.mtime[0];
if (bits & U_MODEL) {
modnum = MSG_ReadByte (net_message);
if (modnum >= MAX_MODELS)
Host_Error ("CL_ParseModel: bad modnum");
} else
modnum = baseline->modelindex;
if (bits & U_FRAME)
state->frame = MSG_ReadByte (net_message);
else
state->frame = baseline->frame;
if (bits & U_COLORMAP)
state->colormap = MSG_ReadByte (net_message);
else
state->colormap = baseline->colormap;
if (state->colormap > cl.maxclients)
Sys_Error ("colormap > cl.maxclients");
if (bits & U_SKIN)
state->skinnum = MSG_ReadByte (net_message);
else
state->skinnum = baseline->skinnum;
if (bits & U_EFFECTS)
state->effects = MSG_ReadByte (net_message);
else
state->effects = baseline->effects;
if (bits & U_ORIGIN1)
state->origin[0] = MSG_ReadCoord (net_message);
else
state->origin[0] = baseline->origin[0];
if (bits & U_ANGLE1)
state->angles[0] = MSG_ReadAngle (net_message);
else
state->angles[0] = baseline->angles[0];
if (bits & U_ORIGIN2)
state->origin[1] = MSG_ReadCoord (net_message);
else
state->origin[1] = baseline->origin[1];
if (bits & U_ANGLE2)
state->angles[1] = MSG_ReadAngle (net_message);
else
state->angles[1] = baseline->angles[1];
if (bits & U_ORIGIN3)
state->origin[2] = MSG_ReadCoord (net_message);
else
state->origin[2] = baseline->origin[2];
if (bits & U_ANGLE3)
state->angles[2] = MSG_ReadAngle (net_message);
else
state->angles[2] = baseline->angles[2];
// if (bits & U_STEP) //FIXME lerping (see fitzquake)
// forcelink = true;
if (cl.protocol == PROTOCOL_FITZQUAKE) {
if (bits & U_ALPHA)
state->alpha = MSG_ReadByte(net_message);
else
state->alpha = baseline->alpha;
if (bits & U_FRAME2)
state->frame |= MSG_ReadByte(net_message) << 8;
if (bits & U_MODEL2)
modnum |= MSG_ReadByte(net_message) << 8;
if (bits & U_LERPFINISH) {
MSG_ReadByte (net_message); //FIXME ignored for now. see fitzquake
}
state->scale = 16;
state->glow_size = 0;
state->glow_color = 254;
state->colormod = 255;
} else {
baseline->alpha = 255;
state->scale = 16;
state->glow_size = 0;
state->glow_color = 254;
state->colormod = 255;
}
state->modelindex = modnum;
if (forcelink) { // didn't have an update last message
//VectorCopy (state->msg_origins[0], state->msg_origins[1]);
//VectorCopy (state->msg_origins[0], ent->origin);
//VectorCopy (state->msg_angles[0], state->msg_angles[1]);
//CL_TransformEntity (ent, state->msg_angles[0]);
//state->forcelink = true;
SET_ADD (&cl_forcelink, num);
}
}
/*
CL_ParseClientdata
Server information pertaining to only this client
*/
static void
CL_ParseClientdata (void)
{
int i, j;
int bits;
bits = MSG_ReadShort (net_message);
if (bits & SU_EXTEND1)
bits |= MSG_ReadByte (net_message) << 16;
if (bits & SU_EXTEND2)
bits |= MSG_ReadByte (net_message) << 24;
if (bits & SU_VIEWHEIGHT)
cl.viewstate.height = ((signed char) MSG_ReadByte (net_message));
else
cl.viewstate.height = DEFAULT_VIEWHEIGHT;
if (bits & SU_IDEALPITCH)
cl.viewstate.idealpitch = ((signed char) MSG_ReadByte (net_message));
else
cl.viewstate.idealpitch = 0;
cl.frameVelocity[1] = cl.frameVelocity[0];
vec3_t punchangle = { };
for (i = 0; i < 3; i++) {
if (bits & (SU_PUNCH1 << i)) {
punchangle[i] = ((signed char) MSG_ReadByte (net_message));
}
if (bits & (SU_VELOCITY1 << i))
cl.frameVelocity[0][i] = ((signed char) MSG_ReadByte (net_message))
* 16;
else
cl.frameVelocity[0][i] = 0;
}
AngleQuat (punchangle, (vec_t*)&cl.viewstate.punchangle);//FIXME
//FIXME
//if (!VectorCompare (v_punchangles[0], cl.punchangle[0])) {
// VectorCopy (v_punchangles[0], v_punchangles[1]);
// VectorCopy (cl.punchangle, v_punchangles[0]);
//}
// [always sent] if (bits & SU_ITEMS)
i = MSG_ReadLong (net_message);
if (cl.stats[STAT_ITEMS] != i) { // set flash times
Sbar_Changed ();
for (j = 0; j < 32; j++)
if ((i & (1 << j)) && !(cl.stats[STAT_ITEMS] & (1 << j)))
cl.item_gettime[j] = cl.time;
cl.stats[STAT_ITEMS] = i;
#define IT_POWER (IT_QUAD | IT_SUIT | IT_INVULNERABILITY | IT_INVISIBILITY)
cl.viewstate.powerup_index = (cl.stats[STAT_ITEMS] & IT_POWER) >> 19;
}
cl.viewstate.onground = (bits & SU_ONGROUND) ? 0 : -1;
cl.inwater = (bits & SU_INWATER) != 0;
if (bits & SU_WEAPONFRAME)
cl.stats[STAT_WEAPONFRAME] = MSG_ReadByte (net_message);
else
cl.stats[STAT_WEAPONFRAME] = 0;
cl.viewstate.weaponframe = cl.stats[STAT_WEAPONFRAME];
if (bits & SU_ARMOR)
i = MSG_ReadByte (net_message);
else
i = 0;
if (cl.stats[STAT_ARMOR] != i) {
cl.stats[STAT_ARMOR] = i;
Sbar_Changed ();
}
if (bits & SU_WEAPON)
i = MSG_ReadByte (net_message);
else
i = 0;
if (cl.stats[STAT_WEAPON] != i) {
cl.stats[STAT_WEAPON] = i;
Sbar_Changed ();
cl.viewstate.weapon_model = cl_world.models.a[cl.stats[STAT_WEAPON]];
}
i = (short) MSG_ReadShort (net_message);
if (cl.stats[STAT_HEALTH] != i) {
cl.stats[STAT_HEALTH] = i;
Sbar_Changed ();
}
i = MSG_ReadByte (net_message);
if (cl.stats[STAT_AMMO] != i) {
cl.stats[STAT_AMMO] = i;
Sbar_Changed ();
}
for (i = 0; i < 4; i++) {
j = MSG_ReadByte (net_message);
if (cl.stats[STAT_SHELLS + i] != j) {
cl.stats[STAT_SHELLS + i] = j;
Sbar_Changed ();
}
}
i = MSG_ReadByte (net_message);
if (standard_quake) {
if (cl.stats[STAT_ACTIVEWEAPON] != i) {
cl.stats[STAT_ACTIVEWEAPON] = i;
Sbar_Changed ();
}
} else {
// hipnotic/rogue weapon "bit field" (stupid idea)
if (cl.stats[STAT_ACTIVEWEAPON] != (1 << i)) {
cl.stats[STAT_ACTIVEWEAPON] = (1 << i);
Sbar_Changed ();
}
}
if (bits & SU_WEAPON2)
cl.stats[STAT_WEAPON] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_ARMOR2)
cl.stats[STAT_ARMOR] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_AMMO2)
cl.stats[STAT_AMMO] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_SHELLS2)
cl.stats[STAT_SHELLS] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_NAILS2)
cl.stats[STAT_NAILS] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_ROCKETS2)
cl.stats[STAT_ROCKETS] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_CELLS2)
cl.stats[STAT_CELLS] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_WEAPONFRAME2)
cl.stats[STAT_WEAPONFRAME] |= MSG_ReadByte (net_message) << 8;
if (bits & SU_WEAPONALPHA) {
byte alpha = MSG_ReadByte (net_message);
float a = ENTALPHA_DECODE (alpha);
cl.viewstate.weapon_entity->renderer.colormod[3] = a;
} else {
cl.viewstate.weapon_entity->renderer.colormod[3] = 1;
}
}
static void
CL_ParseStaticSound (int version)
{
int sound_num, vol, atten;
vec4f_t org = { 0, 0, 0, 1 };
MSG_ReadCoordV (net_message, (vec_t*)&org);//FIXME
if (version == 2)
sound_num = MSG_ReadShort (net_message);
else
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);
}
static void
CL_SetStat (int stat, int value)
{
if (stat < 0 || stat >= MAX_CL_STATS)
Host_Error ("CL_SetStat: %i is invalid", stat);
cl.stats[stat] = value;
}
#define SHOWNET(x) \
if (cl_shownet == 2) \
Sys_Printf ("%3i:%s\n", net_message->readcount - 1, x);
void
CL_ParseServerMessage (void)
{
int cmd = 0, i, j;
const char *str;
static dstring_t *stuffbuf;
signon_t so;
cl.last_servermessage = realtime;
TEntContext_t tentCtx = {
cl.viewstate.player_origin,
cl.viewentity
};
// if recording demos, copy the message out
if (cl_shownet == 1)
Sys_Printf ("%i ", net_message->message->cursize);
else if (cl_shownet == 2)
Sys_Printf ("------------------\n");
cl.viewstate.onground = -1; // unless the server says otherwise
// parse the message
MSG_BeginReading (net_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
}
// if the high bit of the command byte is set, it is a fast update
if (cmd & U_SIGNAL) {
SHOWNET ("fast update");
CL_ParseUpdate (cmd & ~U_SIGNAL);
continue;
}
SHOWNET (va (0, "%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_ReadLong (net_message);
CL_SetStat (i, j);
break;
case svc_version:
i = MSG_ReadLong (net_message);
if (i != PROTOCOL_NETQUAKE && i!= PROTOCOL_FITZQUAKE)
Host_Error ("CL_ParseServerMessage: Server is protocol %i "
"instead of %i or %i\n", i, PROTOCOL_NETQUAKE,
PROTOCOL_FITZQUAKE);
cl.protocol = i;
break;
case svc_setview:
cl.viewentity = MSG_ReadShort (net_message);
break;
case svc_sound:
CL_ParseStartSoundPacket ();
break;
case svc_time:
cl.mtime[1] = cl.mtime[0];
cl.mtime[0] = MSG_ReadFloat (net_message);
cl.frameIndex = !cl.frameIndex;
break;
case svc_print:
Sys_Printf ("%s", MSG_ReadString (net_message));
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 (host_cbuf, stuffbuf->str);
dstring_clearstr (stuffbuf);
} else {
Sys_MaskPrintf (SYS_dev, "stufftext: %s\n", str);
}
Cbuf_AddText (host_cbuf, 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.viewstate.player_angles;
MSG_ReadAngleV (net_message, dest);
break;
}
case svc_serverinfo:
// make sure any stuffed commands are done
if (stuffbuf && stuffbuf->str[0]) {
Cbuf_AddText (host_cbuf, stuffbuf->str);
dstring_clearstr (stuffbuf);
}
Cbuf_Execute_Stack (host_cbuf);
CL_ParseServerInfo ();
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;
case svc_updatename:
Sbar_Changed ();
i = MSG_ReadByte (net_message);
if (i >= cl.maxclients)
Host_Error ("CL_ParseServerMessage: svc_updatename > "
"MAX_SCOREBOARD");
Info_SetValueForKey (cl.players[i].userinfo, "name",
MSG_ReadString (net_message), 0);
break;
case svc_updatefrags:
Sbar_Changed ();
i = MSG_ReadByte (net_message);
if (i >= cl.maxclients)
Host_Error ("CL_ParseServerMessage: svc_updatefrags > "
"MAX_SCOREBOARD");
cl.players[i].frags = (short) MSG_ReadShort (net_message);
break;
case svc_clientdata:
CL_ParseClientdata ();
break;
case svc_stopsound:
i = MSG_ReadShort (net_message);
S_StopSound (i >> 3, i & 7);
break;
case svc_updatecolors:
Sbar_Changed ();
i = MSG_ReadByte (net_message);
if (i >= cl.maxclients) {
Host_Error ("CL_ParseServerMessage: svc_updatecolors > "
"MAX_SCOREBOARD");
} else {
entity_t *ent = CL_GetEntity (i + 1);
byte col = MSG_ReadByte (net_message);
byte top = col >> 4;
byte bot = col & 0xf;
if (top != cl.players[i].topcolor
|| bot != cl.players[i].bottomcolor)
mod_funcs->Skin_SetTranslation (i + 1, top, bot);
cl.players[i].topcolor = top;
cl.players[i].bottomcolor = bot;
ent->renderer.skin
= mod_funcs->Skin_SetColormap (ent->renderer.skin,
i + 1);
}
break;
case svc_particle:
CL_ParseParticleEffect (net_message);
break;
case svc_damage:
V_ParseDamage (net_message, &cl.viewstate);
// put sbar face into pain frame
cl.faceanimtime = cl.time + 0.2;
break;
case svc_spawnstatic:
CL_ParseStatic (net_message, 1);
break;
// svc_spawnbinary
case svc_spawnbaseline:
i = MSG_ReadShort (net_message);
// must use CL_EntityNum () to force cl.num_entities up
CL_ParseBaseline (net_message, CL_EntityNum (i), 1);
break;
case svc_temp_entity:
CL_ParseTEnt_nq (net_message, cl.time, &tentCtx);
break;
case svc_setpause:
r_data->paused = cl.paused = MSG_ReadByte (net_message);
if (cl.paused)
CDAudio_Pause ();
else
CDAudio_Resume ();
break;
case svc_signonnum:
so = MSG_ReadByte (net_message);
if (so <= cls.signon || so >= so_active)
Host_Error ("Received signon %i when at %i", so,
cls.signon);
cls.signon = so;
CL_SignonReply ();
break;
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 (1);
break;
case svc_intermission:
cl.intermission = 1;
SCR_SetFullscreen (1);
cl.completed_time = cl.time;
break;
case svc_finale:
cl.intermission = 2;
SCR_SetFullscreen (1);
cl.completed_time = cl.time;
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);
MSG_ReadByte (net_message); // looptrack (not used)
if ((cls.demoplayback || cls.demorecording)
&& (cls.forcetrack != -1))
CDAudio_Play ((byte) cls.forcetrack, true);
else
CDAudio_Play ((byte) cl.cdtrack, true);
break;
case svc_sellscreen:
Cmd_ExecuteString ("help", src_command);
break;
case svc_cutscene:
cl.intermission = 3;
SCR_SetFullscreen (1);
cl.completed_time = cl.time;
str = MSG_ReadString (net_message);
if (strcmp (str, centerprint->str)) {
dstring_copystr (centerprint, str);
//FIXME logging
}
Sbar_CenterPrint (str);
break;
// svc_smallkick (same value as svc_cutscene)
// 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
// PROTOCOL_FITZQUAKE (these overlap with the above listed qw svcs)
case svc_skybox:
r_funcs->R_LoadSkys (MSG_ReadString(net_message));
break;
case svc_bf:
Cmd_ExecuteString ("bf", src_command);
break;
case svc_fog:
{
float density, red, green, blue, time;
density = MSG_ReadByte (net_message) / 255.0;
red = MSG_ReadByte (net_message) / 255.0;
green = MSG_ReadByte (net_message) / 255.0;
blue = MSG_ReadByte (net_message) / 255.0;
time = (short) MSG_ReadShort (net_message) / 100.0;
time = max (0.0, time);
Fog_Update (density, red, green, blue, time);
}
break;
case svc_spawnbaseline2:
i = MSG_ReadShort (net_message);
// must use CL_EntityNum() to force cl.num_entities up
CL_ParseBaseline (net_message, CL_EntityNum(i), 2);
break;
case svc_spawnstatic2:
CL_ParseStatic (net_message, 2);
break;
case svc_spawnstaticsound2:
CL_ParseStaticSound (2);
break;
}
}
}