ref: 7f9c4b6c2d5017d10b370b4e55691b5a2631eb75
dir: /qw/cl_parse.c/
// cl_parse.c -- parse a message received from the server
#include <u.h>
#include <libc.h>
#include <stdio.h>
#include "quakedef.h"
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 the 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",
"svc_cdtrack",
"svc_sellscreen",
"svc_smallkick",
"svc_bigkick",
"svc_updateping",
"svc_updateentertime",
"svc_updatestatlong",
"svc_muzzleflash",
"svc_updateuserinfo",
"svc_download",
"svc_playerinfo",
"svc_nails",
"svc_choke",
"svc_modellist",
"svc_soundlist",
"svc_packetentities",
"svc_deltapacketentities",
"svc_maxspeed",
"svc_entgravity",
"svc_setinfo",
"svc_serverinfo",
"svc_updatepl",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL",
"NEW PROTOCOL"
};
int oldparsecountmod;
int parsecountmod;
double parsecounttime;
int cl_spikeindex, cl_playerindex, cl_flagindex;
//=============================================================================
int packet_latency[NET_TIMINGS];
int CL_CalcNet (void)
{
int a, i;
frame_t *frame;
int lost;
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 (char *filename)
{
FILE *f;
if (strstr (filename, ".."))
{
Con_Printf ("Refusing to download a path with ..\n");
return true;
}
COM_FOpenFile (filename, &f);
if (f)
{ // it exists, no need to download
fclose (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);
strcat (cls.downloadtempname, ".tmp");
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
MSG_WriteString (&cls.netchan.message, va("download %s", cls.downloadname));
cls.downloadnumber++;
return false;
}
/*
=================
Model_NextDownload
=================
*/
void Model_NextDownload (void)
{
char *s;
int i;
extern char gamedirfile[];
if (cls.downloadnumber == 0)
{
Con_Printf ("Checking models...\n");
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
}
for (i=1 ; i<MAX_MODELS ; i++)
{
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;
}
}
// all done
cl.worldmodel = cl.model_precache[1];
R_NewMap ();
Hunk_Check (); // make sure nothing is hurt
// done with modellist, request first of static signon messages
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
// MSG_WriteString (&cls.netchan.message, va("prespawn %d 0 %d", cl.servercount, cl.worldmodel->checksum2));
MSG_WriteString (&cls.netchan.message, va(prespawn_name, cl.servercount, cl.worldmodel->checksum2));
}
/*
=================
Sound_NextDownload
=================
*/
void Sound_NextDownload (void)
{
char *s;
int i;
if (cls.downloadnumber == 0)
{
Con_Printf ("Checking sounds...\n");
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<MAX_SOUNDS ; i++)
{
if (!cl.sound_name[i][0])
break;
cl.sound_precache[i] = precachesfx(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;
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
// MSG_WriteString (&cls.netchan.message, va("modellist %d 0", cl.servercount));
MSG_WriteString (&cls.netchan.message, va(modellist_name, cl.servercount, 0));
}
/*
======================
CL_RequestNextDownload
======================
*/
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");
}
}
static void
rename(char *old, char *new)
{
char *p;
Dir d;
if((p = strrchr(new, '/')) == nil)
p = new;
else
p++;
nulldir(&d);
d.name = p;
if(dirwstat(old, &d) < 0)
fprint(2, "rename: %r\n");
}
/*
=====================
CL_ParseDownload
A download message has been received from the server
=====================
*/
void CL_ParseDownload (void)
{
int size, percent;
char name[1024];
// read the data
size = MSG_ReadShort ();
percent = MSG_ReadByte ();
if (cls.demoplayback) {
if (size > 0)
msg_readcount += size;
return; // not in demo playback
}
if (size == -1)
{
Con_Printf ("File not found.\n");
if (cls.download)
{
Con_Printf ("cls.download shouldn't have been set\n");
fclose (cls.download);
cls.download = NULL;
}
CL_RequestNextDownload ();
return;
}
// open the file if not opened yet
if (!cls.download)
{
if(strncmp(cls.downloadtempname, "skins/", 6))
sprint(name, "%s/%s", com_gamedir, cls.downloadtempname);
else
sprint(name, "qw/%s", cls.downloadtempname);
COM_CreatePath (name);
cls.download = fopen (name, "wb");
if (!cls.download)
{
msg_readcount += size;
Con_Printf ("Failed to open %s\n", cls.downloadtempname);
CL_RequestNextDownload ();
return;
}
}
fwrite (net_message.data + msg_readcount, 1, size, cls.download);
msg_readcount += size;
if (percent != 100)
{
// change display routines by zoid
// request next block
/*
Con_Printf (".");
if (10*(percent/10) != cls.downloadpercent)
{
cls.downloadpercent = 10*(percent/10);
Con_Printf ("%d%%", cls.downloadpercent);
}
*/
cls.downloadpercent = percent;
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
SZ_Print (&cls.netchan.message, "nextdl");
}
else
{
char oldn[MAX_OSPATH];
char newn[MAX_OSPATH];
/*
Con_Printf ("100%%\n");
*/
fclose (cls.download);
// rename the temp file to it's final name
if (strcmp(cls.downloadtempname, cls.downloadname)) {
if (strncmp(cls.downloadtempname,"skins/",6)) {
sprint(oldn, "%s/%s", com_gamedir, cls.downloadtempname);
sprint(newn, "%s/%s", com_gamedir, cls.downloadname);
} else {
sprint(oldn, "qw/%s", cls.downloadtempname);
sprint(newn, "qw/%s", cls.downloadname);
}
rename(oldn, newn);
}
cls.download = NULL;
cls.downloadpercent = 0;
// get another file if needed
CL_RequestNextDownload ();
}
}
static byte *upload_data;
static int upload_pos;
static int upload_size;
void CL_NextUpload(void)
{
byte buffer[1024];
int r;
int percent;
int size;
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);
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);
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
=====================================================================
*/
/*
==================
CL_ParseServerData
==================
*/
void CL_ParseServerData (void)
{
char *str;
FILE *f;
char fn[MAX_OSPATH];
qboolean cflag = false;
extern char gamedirfile[MAX_OSPATH];
int protover;
Con_DPrintf ("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 ();
if (protover != PROTOCOL_VERSION &&
!(cls.demoplayback && (protover == 26 || protover == 27 || protover == 28)))
Host_EndGame ("Server returned version %d, not %d\nYou probably need to upgrade.\nCheck http://www.quakeworld.net/", protover, PROTOCOL_VERSION);
cl.servercount = MSG_ReadLong ();
// game directory
str = MSG_ReadString ();
if (cistrcmp(gamedirfile, str)) {
// save current config
Host_WriteConfiguration ();
cflag = true;
}
COM_Gamedir(str);
//ZOID--run the autoexec.cfg in the gamedir
//if it exists
if (cflag) {
sprintf(fn, "%s/%s", com_gamedir, "config.cfg");
if ((f = fopen(fn, "r")) != NULL) {
fclose(f);
Cbuf_AddText ("cl_warncmd 0\n");
Cbuf_AddText("exec config.cfg\n");
Cbuf_AddText("exec frontend.cfg\n");
Cbuf_AddText ("cl_warncmd 1\n");
}
}
// parse player slot, high bit means spectator
cl.playernum = MSG_ReadByte ();
if (cl.playernum & 128)
{
cl.spectator = true;
cl.playernum &= ~128;
}
// get the full level name
str = MSG_ReadString ();
strncpy (cl.levelname, str, sizeof(cl.levelname)-1);
// get the movevars
movevars.gravity = MSG_ReadFloat();
movevars.stopspeed = MSG_ReadFloat();
movevars.maxspeed = MSG_ReadFloat();
movevars.spectatormaxspeed = MSG_ReadFloat();
movevars.accelerate = MSG_ReadFloat();
movevars.airaccelerate = MSG_ReadFloat();
movevars.wateraccelerate = MSG_ReadFloat();
movevars.friction = MSG_ReadFloat();
movevars.waterfriction = MSG_ReadFloat();
movevars.entgravity = MSG_ReadFloat();
// 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, str);
// ask for the sound list next
memset(cl.sound_name, 0, sizeof(cl.sound_name));
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
// MSG_WriteString (&cls.netchan.message, va("soundlist %d 0", cl.servercount));
MSG_WriteString (&cls.netchan.message, va(soundlist_name, cl.servercount, 0));
// now waiting for downloads, etc
cls.state = ca_onserver;
}
/*
==================
CL_ParseSoundlist
==================
*/
void CL_ParseSoundlist (void)
{
int numsounds;
char *str;
int n;
// precache sounds
// memset (cl.sound_precache, 0, sizeof(cl.sound_precache));
numsounds = MSG_ReadByte();
for (;;) {
str = MSG_ReadString ();
if (!str[0])
break;
numsounds++;
if (numsounds == MAX_SOUNDS)
Host_EndGame ("Server sent too many sound_precache");
strcpy (cl.sound_name[numsounds], str);
}
n = MSG_ReadByte();
if (n) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
// MSG_WriteString (&cls.netchan.message, va("soundlist %d %d", cl.servercount, n));
MSG_WriteString (&cls.netchan.message, va(soundlist_name, cl.servercount, n));
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_sound;
Sound_NextDownload ();
}
/*
==================
CL_ParseModellist
==================
*/
void CL_ParseModellist (void)
{
int nummodels;
char *str;
int n;
// precache models and note certain default indexes
nummodels = MSG_ReadByte();
for (;;)
{
str = MSG_ReadString ();
if (!str[0])
break;
nummodels++;
if (nummodels==MAX_MODELS)
Host_EndGame ("Server sent too many model_precache");
strcpy (cl.model_name[nummodels], str);
if (!strcmp(cl.model_name[nummodels],"progs/spike.mdl"))
cl_spikeindex = nummodels;
if (!strcmp(cl.model_name[nummodels],"progs/player.mdl"))
cl_playerindex = nummodels;
if (!strcmp(cl.model_name[nummodels],"progs/flag.mdl"))
cl_flagindex = nummodels;
}
n = MSG_ReadByte();
if (n) {
MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
// MSG_WriteString (&cls.netchan.message, va("modellist %d %d", cl.servercount, n));
MSG_WriteString (&cls.netchan.message, va(modellist_name, cl.servercount, n));
return;
}
cls.downloadnumber = 0;
cls.downloadtype = dl_model;
Model_NextDownload ();
}
/*
==================
CL_ParseBaseline
==================
*/
void CL_ParseBaseline (entity_state_t *es)
{
int i;
es->modelindex = MSG_ReadByte ();
es->frame = MSG_ReadByte ();
es->colormap = MSG_ReadByte();
es->skinnum = MSG_ReadByte();
for (i=0 ; i<3 ; i++)
{
es->origin[i] = MSG_ReadCoord ();
es->angles[i] = MSG_ReadAngle ();
}
}
/*
=====================
CL_ParseStatic
Static entities are non-interactive world objects
like torches
=====================
*/
void CL_ParseStatic (void)
{
entity_t *ent;
int i;
entity_state_t es;
CL_ParseBaseline (&es);
i = cl.num_statics;
if (i >= MAX_STATIC_ENTITIES)
Host_EndGame ("Too many static entities");
ent = &cl_static_entities[i];
cl.num_statics++;
// copy it to the current state
ent->model = cl.model_precache[es.modelindex];
ent->frame = es.frame;
ent->colormap = vid.colormap;
ent->skinnum = es.skinnum;
VectorCopy (es.origin, ent->origin);
VectorCopy (es.angles, ent->angles);
R_AddEfrags (ent);
}
/*
===================
CL_ParseStaticSound
===================
*/
void CL_ParseStaticSound (void)
{
vec3_t org;
int sound_num, vol, atten;
int i;
for (i=0 ; i<3 ; i++)
org[i] = MSG_ReadCoord ();
sound_num = MSG_ReadByte ();
vol = MSG_ReadByte ();
atten = MSG_ReadByte ();
staticsfx (cl.sound_precache[sound_num], org, vol, atten);
}
/*
=====================================================================
ACTION MESSAGES
=====================================================================
*/
/*
==================
CL_ParseStartSoundPacket
==================
*/
void CL_ParseStartSoundPacket(void)
{
vec3_t pos;
int channel, ent;
int sound_num;
int volume;
float attenuation;
int i;
channel = MSG_ReadShort();
if (channel & SND_VOLUME)
volume = MSG_ReadByte ();
else
volume = DEFAULT_SOUND_PACKET_VOLUME;
if (channel & SND_ATTENUATION)
attenuation = MSG_ReadByte () / 64.0;
else
attenuation = DEFAULT_SOUND_PACKET_ATTENUATION;
sound_num = MSG_ReadByte ();
for (i=0 ; i<3 ; i++)
pos[i] = MSG_ReadCoord ();
ent = (channel>>3)&1023;
channel &= 7;
if (ent > MAX_EDICTS)
Host_EndGame ("CL_ParseStartSoundPacket: ent = %d", ent);
startsfx (ent, channel, cl.sound_precache[sound_num], pos, volume/255.0, attenuation);
}
/*
==================
CL_ParseClientdata
Server information pertaining to this client only, sent every frame
==================
*/
void CL_ParseClientdata (void)
{
int i;
float latency;
frame_t *frame;
// 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 are needed
}
}
/*
=====================
CL_NewTranslation
=====================
*/
void CL_NewTranslation (int slot)
{
int i, j;
int top, bottom;
byte *dest, *source;
player_info_t *player;
char s[512];
if (slot > MAX_CLIENTS)
Sys_Error ("CL_NewTranslation: slot > MAX_CLIENTS");
player = &cl.players[slot];
strcpy(s, Info_ValueForKey(player->userinfo, "skin"));
COM_StripExtension(s, s);
if (player->skin && !cistrcmp(s, player->skin->name))
player->skin = NULL;
if (player->_topcolor != player->topcolor ||
player->_bottomcolor != player->bottomcolor || !player->skin) {
player->_topcolor = player->topcolor;
player->_bottomcolor = player->bottomcolor;
dest = player->translations;
source = vid.colormap;
memcpy (dest, vid.colormap, sizeof(player->translations));
top = player->topcolor;
if (top > 13 || top < 0)
top = 13;
top *= 16;
bottom = player->bottomcolor;
if (bottom > 13 || bottom < 0)
bottom = 13;
bottom *= 16;
for (i=0 ; i<VID_GRADES ; i++, dest += 256, source+=256)
{
if (top < 128) // the artists made some backwards ranges. sigh.
memcpy (dest + TOP_RANGE, source + top, 16);
else
for (j=0 ; j<16 ; j++)
dest[TOP_RANGE+j] = source[top+15-j];
if (bottom < 128)
memcpy (dest + BOTTOM_RANGE, source + bottom, 16);
else
for (j=0 ; j<16 ; j++)
dest[BOTTOM_RANGE+j] = source[bottom+15-j];
}
}
}
/*
==============
CL_UpdateUserinfo
==============
*/
void CL_ProcessUserInfo (int slot, player_info_t *player)
{
strncpy (player->name, Info_ValueForKey (player->userinfo, "name"), sizeof(player->name)-1);
player->topcolor = atoi(Info_ValueForKey (player->userinfo, "topcolor"));
player->bottomcolor = atoi(Info_ValueForKey (player->userinfo, "bottomcolor"));
if (Info_ValueForKey (player->userinfo, "*spectator")[0])
player->spectator = true;
else
player->spectator = false;
if (cls.state == ca_active)
Skin_Find (player);
Sbar_Changed ();
CL_NewTranslation (slot);
}
/*
==============
CL_UpdateUserinfo
==============
*/
void CL_UpdateUserinfo (void)
{
int slot;
player_info_t *player;
slot = MSG_ReadByte ();
if (slot >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_updateuserinfo > MAX_SCOREBOARD");
player = &cl.players[slot];
player->userid = MSG_ReadLong ();
strncpy (player->userinfo, MSG_ReadString(), sizeof(player->userinfo)-1);
CL_ProcessUserInfo (slot, player);
}
/*
==============
CL_SetInfo
==============
*/
void CL_SetInfo (void)
{
int slot;
player_info_t *player;
char key[MAX_MSGLEN];
char value[MAX_MSGLEN];
slot = MSG_ReadByte ();
if (slot >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_setinfo > MAX_SCOREBOARD");
player = &cl.players[slot];
strncpy (key, MSG_ReadString(), sizeof(key) - 1);
key[sizeof(key) - 1] = 0;
strncpy (value, MSG_ReadString(), sizeof(value) - 1);
key[sizeof(value) - 1] = 0;
Con_DPrintf("SETINFO %s: %s=%s\n", player->name, key, value);
Info_SetValueForKey (player->userinfo, key, value, MAX_INFO_STRING);
CL_ProcessUserInfo (slot, player);
}
/*
==============
CL_ServerInfo
==============
*/
void CL_ServerInfo (void)
{
char key[MAX_MSGLEN];
char value[MAX_MSGLEN];
strncpy (key, MSG_ReadString(), sizeof(key) - 1);
key[sizeof(key) - 1] = 0;
strncpy (value, MSG_ReadString(), sizeof(value) - 1);
key[sizeof(value) - 1] = 0;
Con_DPrintf("SERVERINFO: %s=%s\n", key, value);
Info_SetValueForKey (cl.serverinfo, key, value, MAX_SERVERINFO_STRING);
}
/*
=====================
CL_SetStat
=====================
*/
void CL_SetStat (int stat, int value)
{
int j;
if (stat < 0 || stat >= MAX_CL_STATS)
Sys_Error ("CL_SetStat: %d is invalid", stat);
Sbar_Changed ();
if (stat == 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;
}
cl.stats[stat] = value;
}
/*
==============
CL_MuzzleFlash
==============
*/
void CL_MuzzleFlash (void)
{
vec3_t fv, rv, uv;
dlight_t *dl;
int i;
player_state_t *pl;
i = MSG_ReadShort ();
if ((unsigned)(i-1) >= MAX_CLIENTS)
return;
pl = &cl.frames[parsecountmod].playerstate[i-1];
dl = CL_AllocDlight (i);
VectorCopy (pl->origin, dl->origin);
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;
dl->color[3] = 0.7;
}
#define SHOWNET(x) if(cl_shownet.value==2)Con_Printf ("%3d:%s\n", msg_readcount-1, x);
/*
=====================
CL_ParseServerMessage
=====================
*/
int received_framecount;
void CL_ParseServerMessage (void)
{
int cmd;
char *s;
int i, j;
received_framecount = host_framecount;
cl.last_servermessage = realtime;
CL_ClearProjectiles ();
//
// if recording demos, copy the message out
//
if (cl_shownet.value == 1)
Con_Printf ("%d ",net_message.cursize);
else if (cl_shownet.value == 2)
Con_Printf ("------------------\n");
CL_ParseClientdata ();
//
// parse the message
//
while (1)
{
if (msg_badread)
{
Host_EndGame ("CL_ParseServerMessage: Bad server message");
break;
}
cmd = MSG_ReadByte ();
if (cmd == -1)
{
msg_readcount++; // so the EOM showner has the right value
SHOWNET("END OF MESSAGE");
break;
}
SHOWNET(svc_strings[cmd]);
// other commands
switch (cmd)
{
default:
Host_EndGame ("CL_ParseServerMessage: Illegible server message");
break;
case svc_nop:
// Con_Printf ("svc_nop\n");
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");
break;
case svc_print:
i = MSG_ReadByte ();
if (i == PRINT_CHAT)
{
localsfx ("misc/talk.wav");
con_ormask = 128;
}
Con_Printf ("%s", MSG_ReadString ());
con_ormask = 0;
break;
case svc_centerprint:
SCR_CenterPrint (MSG_ReadString ());
break;
case svc_stufftext:
s = MSG_ReadString ();
Con_DPrintf ("stufftext: %s\n", s);
Cbuf_AddText (s);
break;
case svc_damage:
V_ParseDamage ();
break;
case svc_serverdata:
Cbuf_Execute (); // make sure any stuffed commands are done
CL_ParseServerData ();
vid.recalc_refdef = true; // leave full screen intermission
break;
case svc_setangle:
for (i=0 ; i<3 ; i++)
cl.viewangles[i] = MSG_ReadAngle ();
// cl.viewangles[PITCH] = cl.viewangles[ROLL] = 0;
break;
case svc_lightstyle:
i = MSG_ReadByte ();
if (i >= MAX_LIGHTSTYLES)
Sys_Error ("svc_lightstyle > MAX_LIGHTSTYLES");
strcpy(cl_lightstyle[i].map, MSG_ReadString());
cl_lightstyle[i].length = strlen(cl_lightstyle[i].map);
break;
case svc_sound:
CL_ParseStartSoundPacket();
break;
case svc_stopsound:
i = MSG_ReadShort();
stopsfx(i>>3, i&7);
break;
case svc_updatefrags:
Sbar_Changed ();
i = MSG_ReadByte ();
if (i >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_updatefrags > MAX_SCOREBOARD");
cl.players[i].frags = MSG_ReadShort ();
break;
case svc_updateping:
i = MSG_ReadByte ();
if (i >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_updateping > MAX_SCOREBOARD");
cl.players[i].ping = MSG_ReadShort ();
break;
case svc_updatepl:
i = MSG_ReadByte ();
if (i >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_updatepl > MAX_SCOREBOARD");
cl.players[i].pl = MSG_ReadByte ();
break;
case svc_updateentertime:
// time is sent over as seconds ago
i = MSG_ReadByte ();
if (i >= MAX_CLIENTS)
Host_EndGame ("CL_ParseServerMessage: svc_updateentertime > MAX_SCOREBOARD");
cl.players[i].entertime = realtime - MSG_ReadFloat ();
break;
case svc_spawnbaseline:
i = MSG_ReadShort ();
CL_ParseBaseline (&cl_baselines[i]);
break;
case svc_spawnstatic:
CL_ParseStatic ();
break;
case svc_temp_entity:
CL_ParseTEnt ();
break;
case svc_killedmonster:
cl.stats[STAT_MONSTERS]++;
break;
case svc_foundsecret:
cl.stats[STAT_SECRETS]++;
break;
case svc_updatestat:
i = MSG_ReadByte ();
j = MSG_ReadByte ();
CL_SetStat (i, j);
break;
case svc_updatestatlong:
i = MSG_ReadByte ();
j = MSG_ReadLong ();
CL_SetStat (i, j);
break;
case svc_spawnstaticsound:
CL_ParseStaticSound ();
break;
case svc_cdtrack:
cl.cdtrack = MSG_ReadByte ();
playcd ((byte)cl.cdtrack, true);
break;
case svc_intermission:
cl.intermission = 1;
cl.completed_time = realtime;
vid.recalc_refdef = true; // go to full screen
for (i=0 ; i<3 ; i++)
cl.simorg[i] = MSG_ReadCoord ();
for (i=0 ; i<3 ; i++)
cl.simangles[i] = MSG_ReadAngle ();
VectorCopy (vec3_origin, cl.simvel);
break;
case svc_finale:
cl.intermission = 2;
cl.completed_time = realtime;
vid.recalc_refdef = true; // go to full screen
SCR_CenterPrint (MSG_ReadString ());
break;
case svc_sellscreen:
Cmd_ExecuteString ("help");
break;
case svc_smallkick:
cl.punchangle = -2;
break;
case svc_bigkick:
cl.punchangle = -4;
break;
case svc_muzzleflash:
CL_MuzzleFlash ();
break;
case svc_updateuserinfo:
CL_UpdateUserinfo ();
break;
case svc_setinfo:
CL_SetInfo ();
break;
case svc_serverinfo:
CL_ServerInfo ();
break;
case svc_download:
CL_ParseDownload ();
break;
case svc_playerinfo:
CL_ParsePlayerinfo ();
break;
case svc_nails:
CL_ParseProjectiles ();
break;
case svc_chokecount: // some preceding packets were choked
i = MSG_ReadByte ();
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();
break;
case svc_entgravity :
movevars.entgravity = MSG_ReadFloat();
break;
case svc_setpause:
cl.paused = MSG_ReadByte ();
if (cl.paused)
pausecd ();
else
resumecd ();
break;
}
}
CL_SetSolidEntities ();
}