/* 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 #endif #ifdef HAVE_STRINGS_H # include #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/entity.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/plugin/vid_render.h" #include "client/temp_entities.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", // "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", // "svc_stopsound", // "svc_updatecolors", // [byte] [byte] "svc_particle", // [vec3] "svc_damage", // [byte] impact [byte] blood [vec3] from "svc_spawnstatic", "OBSOLETE svc_spawnbinary", "svc_spawnbaseline", "svc_temp_entity", // "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; 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); } /* 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; vec3_t pos; 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); MSG_ReadCoordV (net_message, pos); 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 map_cfg (const char *mapname, int all) { char *name = malloc (strlen (mapname) + 4 + 1); cbuf_t *cbuf = Cbuf_New (&id_interp); QFile *f; QFS_StripExtension (mapname, name); strcat (name, ".cfg"); f = QFS_FOpenFile (name); if (f) { Qclose (f); Cmd_Exec_File (cbuf, name, 1); } else { Cmd_Exec_File (cbuf, "maps_default.cfg", 1); } if (all) { Cbuf_Execute_Stack (cbuf); } else { Cbuf_Execute_Sets (cbuf); } free (name); Cbuf_Delete (cbuf); } static plitem_t * map_ent (const char *mapname) { static progs_t edpr; char *name = malloc (strlen (mapname) + 4 + 1); char *buf; plitem_t *edicts = 0; QFile *ent_file; QFS_StripExtension (mapname, name); strcat (name, ".ent"); ent_file = QFS_VOpenFile (name, 0, cl.model_precache[1]->vpath); if ((buf = (char *) QFS_LoadFile (ent_file, 0))) { edicts = ED_Parse (&edpr, buf); free (buf); } else { edicts = ED_Parse (&edpr, cl.model_precache[1]->brush.entities); } free (name); return edicts; } static void CL_NewMap (const char *mapname) { r_funcs->R_NewMap (cl.worldmodel, cl.model_precache, cl.nummodels); Con_NewMap (); Hunk_Check (); // make sure nothing is hurt Sbar_CenterPrint (0); if (cl.model_precache[1] && cl.model_precache[1]->brush.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 CL_ParseServerInfo (void) { char model_precache[MAX_MODELS][MAX_QPATH]; char sound_precache[MAX_SOUNDS][MAX_QPATH]; const char *str; int i; 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 (cl.maxclients * sizeof (*cl.players), "players"); 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 memset (cl.model_precache, 0, sizeof (cl.model_precache)); for (cl.nummodels = 1;; cl.nummodels++) { str = MSG_ReadString (net_message); if (!str[0]) break; if (cl.nummodels >= MAX_MODELS) { Sys_Printf ("Server sent too many model precaches\n"); goto done; } strcpy (model_precache[cl.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 if (model_precache[1]) map_cfg (model_precache[1], 0); for (i = 1; i < cl.nummodels; i++) { cl.model_precache[i] = Mod_ForName (model_precache[i], false); if (cl.model_precache[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_entities[0].renderer.model = cl.worldmodel = cl.model_precache[1]; if (!centerprint) centerprint = dstring_newstr (); else dstring_clearstr (centerprint); CL_NewMap (model_precache[1]); Hunk_Check (); // make sure nothing is hurt noclip_anglehack = false; // noclip is turned off at start r_data->gravity = 800.0; // 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; cl_forcelink[num] = true; } } static void CL_ParseBaseline (entity_state_t *baseline, int version) { int bits = 0; if (version == 2) bits = MSG_ReadByte (net_message); if (bits & B_LARGEMODEL) baseline->modelindex = MSG_ReadShort (net_message); else baseline->modelindex = MSG_ReadByte (net_message); if (bits & B_LARGEFRAME) baseline->frame = MSG_ReadShort (net_message); else baseline->frame = MSG_ReadByte (net_message); baseline->colormap = MSG_ReadByte (net_message); baseline->skinnum = MSG_ReadByte (net_message); MSG_ReadCoordAngleV (net_message, &baseline->origin[0], baseline->angles); baseline->origin[3] = 1;//FIXME if (bits & B_ALPHA) baseline->alpha = MSG_ReadByte (net_message); else baseline->alpha = 255;//FIXME alpha baseline->scale = 16; baseline->glow_size = 0; baseline->glow_color = 254; baseline->colormod = 255; } /* 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.viewheight = ((signed char) MSG_ReadByte (net_message)); else cl.viewheight = DEFAULT_VIEWHEIGHT; if (bits & SU_IDEALPITCH) cl.idealpitch = ((signed char) MSG_ReadByte (net_message)); else cl.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, &cl.viewstate.punchangle[0]);//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; } 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; 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 (); } 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); cl.viewent.renderer.colormod[3] = ENTALPHA_DECODE (alpha); } else { cl.viewent.renderer.colormod[3] = 1.0; } } static void CL_ParseStatic (int version) { entity_state_t baseline; entity_t *ent; ent = r_funcs->R_AllocEntity (); CL_Init_Entity (ent); CL_ParseBaseline (&baseline, version); // copy it to the current state //FIXME alpha & lerp ent->renderer.model = cl.model_precache[baseline.modelindex]; ent->animation.frame = baseline.frame; ent->renderer.skin = 0; ent->renderer.skinnum = baseline.skinnum; VectorCopy (ent_colormod[baseline.colormod], ent->renderer.colormod); ent->renderer.colormod[3] = ENTALPHA_DECODE (baseline.alpha); CL_TransformEntity (ent, baseline.scale / 16.0, baseline.angles, baseline.origin); r_funcs->R_AddEfrags (&cl.worldmodel->brush, ent); } static void CL_ParseStaticSound (int version) { int sound_num, vol, atten; vec3_t org; MSG_ReadCoordV (net_message, org); 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->int_val == 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 = { Transform_GetWorldPosition (cl_entities[cl.viewentity].transform), cl.worldmodel, cl.viewentity }; // 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 ("------------------\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.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 (); // 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; 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_entities[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 (); break; case svc_spawnstatic: CL_ParseStatic (1); break; // svc_spawnbinary case svc_spawnbaseline: i = MSG_ReadShort (net_message); // must use CL_EntityNum () to force cl.num_entities up CL_ParseBaseline (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; r_data->force_fullscreen = 1; cl.completed_time = cl.time; r_data->vid->recalc_refdef = true; // go to full screen break; case svc_finale: cl.intermission = 2; r_data->force_fullscreen = 1; cl.completed_time = cl.time; 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); 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; r_data->force_fullscreen = 1; cl.completed_time = cl.time; 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; // 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); if (r_funcs->Fog_Update) r_funcs->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 (CL_EntityNum(i), 2); break; case svc_spawnstatic2: CL_ParseStatic (2); break; case svc_spawnstaticsound2: CL_ParseStaticSound (2); break; } } }