home *** CD-ROM | disk | FTP | other *** search
/ Enigma Amiga Life 113 / EnigmaAmiga113CD.iso / software / sviluppo / quakeworld_src / client / cl_parse.c < prev    next >
Encoding:
C/C++ Source or Header  |  2000-06-17  |  31.0 KB  |  1,387 lines
  1. /*
  2. Copyright (C) 1996-1997 Id Software, Inc.
  3.  
  4. This program is free software; you can redistribute it and/or
  5. modify it under the terms of the GNU General Public License
  6. as published by the Free Software Foundation; either version 2
  7. of the License, or (at your option) any later version.
  8.  
  9. This program is distributed in the hope that it will be useful,
  10. but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  
  12.  
  13. See the GNU General Public License for more details.
  14.  
  15. You should have received a copy of the GNU General Public License
  16. along with this program; if not, write to the Free Software
  17. Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  18.  
  19. */
  20. // cl_parse.c  -- parse a message received from the server
  21.  
  22. #include "quakedef.h"
  23.  
  24. char *svc_strings[] =
  25. {
  26.   "svc_bad",
  27.   "svc_nop",
  28.   "svc_disconnect",
  29.   "svc_updatestat",
  30.   "svc_version",    // [long] server version
  31.   "svc_setview",    // [short] entity number
  32.   "svc_sound",      // <see code>
  33.   "svc_time",     // [float] server time
  34.   "svc_print",      // [string] null terminated string
  35.   "svc_stufftext",    // [string] stuffed into client's console buffer
  36.             // the string should be \n terminated
  37.   "svc_setangle",   // [vec3] set the view angle to this absolute value
  38.   
  39.   "svc_serverdata",   // [long] version ...
  40.   "svc_lightstyle",   // [byte] [string]
  41.   "svc_updatename",   // [byte] [string]
  42.   "svc_updatefrags",  // [byte] [short]
  43.   "svc_clientdata",   // <shortbits + data>
  44.   "svc_stopsound",    // <see code>
  45.   "svc_updatecolors", // [byte] [byte]
  46.   "svc_particle",   // [vec3] <variable>
  47.   "svc_damage",     // [byte] impact [byte] blood [vec3] from
  48.   
  49.   "svc_spawnstatic",
  50.   "OBSOLETE svc_spawnbinary",
  51.   "svc_spawnbaseline",
  52.   
  53.   "svc_temp_entity",    // <variable>
  54.   "svc_setpause",
  55.   "svc_signonnum",
  56.   "svc_centerprint",
  57.   "svc_killedmonster",
  58.   "svc_foundsecret",
  59.   "svc_spawnstaticsound",
  60.   "svc_intermission",
  61.   "svc_finale",
  62.  
  63.   "svc_cdtrack",
  64.   "svc_sellscreen",
  65.  
  66.   "svc_smallkick",
  67.   "svc_bigkick",
  68.  
  69.   "svc_updateping",
  70.   "svc_updateentertime",
  71.  
  72.   "svc_updatestatlong",
  73.   "svc_muzzleflash",
  74.   "svc_updateuserinfo",
  75.   "svc_download",
  76.   "svc_playerinfo",
  77.   "svc_nails",
  78.   "svc_choke",
  79.   "svc_modellist",
  80.   "svc_soundlist",
  81.   "svc_packetentities",
  82.   "svc_deltapacketentities",
  83.   "svc_maxspeed",
  84.   "svc_entgravity",
  85.  
  86.   "svc_setinfo",
  87.   "svc_serverinfo",
  88.   "svc_updatepl",
  89.   "NEW PROTOCOL",
  90.   "NEW PROTOCOL",
  91.   "NEW PROTOCOL",
  92.   "NEW PROTOCOL",
  93.   "NEW PROTOCOL",
  94.   "NEW PROTOCOL",
  95.   "NEW PROTOCOL",
  96.   "NEW PROTOCOL",
  97.   "NEW PROTOCOL",
  98.   "NEW PROTOCOL",
  99.   "NEW PROTOCOL",
  100.   "NEW PROTOCOL",
  101.   "NEW PROTOCOL"
  102. };
  103.  
  104. int oldparsecountmod;
  105. int parsecountmod;
  106. double  parsecounttime;
  107.  
  108. int   cl_spikeindex, cl_playerindex, cl_flagindex;
  109.  
  110. //=============================================================================
  111.  
  112. int packet_latency[NET_TIMINGS];
  113.  
  114. int CL_CalcNet (void)
  115. {
  116.   int   a, i;
  117.   frame_t *frame;
  118.   int lost;
  119.   char st[80];
  120.  
  121.   for (i=cls.netchan.outgoing_sequence-UPDATE_BACKUP+1
  122.     ; i <= cls.netchan.outgoing_sequence
  123.     ; i++)
  124.   {
  125.     frame = &cl.frames[i&UPDATE_MASK];
  126.     if (frame->receivedtime == -1)
  127.       packet_latency[i&NET_TIMINGSMASK] = 9999; // dropped
  128.     else if (frame->receivedtime == -2)
  129.       packet_latency[i&NET_TIMINGSMASK] = 10000;  // choked
  130.     else if (frame->invalid)
  131.       packet_latency[i&NET_TIMINGSMASK] = 9998; // invalid delta
  132.     else
  133.       packet_latency[i&NET_TIMINGSMASK] = (frame->receivedtime - frame->senttime)*20;
  134.   }
  135.  
  136.   lost = 0;
  137.   for (a=0 ; a<NET_TIMINGS ; a++)
  138.   {
  139.     i = (cls.netchan.outgoing_sequence-a) & NET_TIMINGSMASK;
  140.     if (packet_latency[i] == 9999)
  141.       lost++;
  142.   }
  143.   return lost * 100 / NET_TIMINGS;
  144. }
  145.  
  146. //=============================================================================
  147.  
  148. /*
  149. ===============
  150. CL_CheckOrDownloadFile
  151.  
  152. Returns true if the file exists, otherwise it attempts
  153. to start a download from the server.
  154. ===============
  155. */
  156. qboolean  CL_CheckOrDownloadFile (char *filename)
  157. {
  158.   FILE  *f;
  159.  
  160.   if (strstr (filename, ".."))
  161.   {
  162.     Con_Printf ("Refusing to download a path with ..\n");
  163.     return true;
  164.   }
  165.  
  166.   COM_FOpenFile (filename, &f);
  167.   if (f)
  168.   { // it exists, no need to download
  169.     fclose (f);
  170.     return true;
  171.   }
  172.  
  173.   //ZOID - can't download when recording
  174.   if (cls.demorecording) {
  175.     Con_Printf("Unable to download %s in record mode.\n", cls.downloadname);
  176.     return true;
  177.   }
  178.   //ZOID - can't download when playback
  179.   if (cls.demoplayback)
  180.     return true;
  181.  
  182.   strcpy (cls.downloadname, filename);
  183.   Con_Printf ("Downloading %s...\n", cls.downloadname);
  184.  
  185.   // download to a temp name, and only rename
  186.   // to the real name when done, so if interrupted
  187.   // a runt file wont be left
  188.   COM_StripExtension (cls.downloadname, cls.downloadtempname);
  189.   strcat (cls.downloadtempname, ".tmp");
  190.  
  191.   MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  192.   MSG_WriteString (&cls.netchan.message, va("download %s", cls.downloadname));
  193.  
  194.   cls.downloadnumber++;
  195.  
  196.   return false;
  197. }
  198.  
  199. /*
  200. =================
  201. Model_NextDownload
  202. =================
  203. */
  204. void Model_NextDownload (void)
  205. {
  206.   char  *s;
  207.   int   i;
  208.   extern  char gamedirfile[];
  209.  
  210.   if (cls.downloadnumber == 0)
  211.   {
  212.     Con_Printf ("Checking models...\n");
  213.     cls.downloadnumber = 1;
  214.   }
  215.  
  216.   cls.downloadtype = dl_model;
  217.   for ( 
  218.     ; cl.model_name[cls.downloadnumber][0]
  219.     ; cls.downloadnumber++)
  220.   {
  221.     s = cl.model_name[cls.downloadnumber];
  222.     if (s[0] == '*')
  223.       continue; // inline brush model
  224.     if (!CL_CheckOrDownloadFile(s))
  225.       return;   // started a download
  226.   }
  227.  
  228.   for (i=1 ; i<MAX_MODELS ; i++)
  229.   {
  230.     if (!cl.model_name[i][0])
  231.       break;
  232.  
  233.     cl.model_precache[i] = Mod_ForName (cl.model_name[i], false);
  234.  
  235.     if (!cl.model_precache[i])
  236.     {
  237.       Con_Printf ("\nThe required model file '%s' could not be found or downloaded.\n\n"
  238.         , cl.model_name[i]);
  239.       Con_Printf ("You may need to download or purchase a %s client "
  240.         "pack in order to play on this server.\n\n", gamedirfile);
  241.       CL_Disconnect ();
  242.       return;
  243.     }
  244.   }
  245.  
  246.   // all done
  247.   cl.worldmodel = cl.model_precache[1]; 
  248.   R_NewMap ();
  249.   Hunk_Check ();    // make sure nothing is hurt
  250.  
  251.   // done with modellist, request first of static signon messages
  252.   MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  253. //  MSG_WriteString (&cls.netchan.message, va("prespawn %i 0 %i", cl.servercount, cl.worldmodel->checksum2));
  254.  
  255.   /* Bug fix! Server expects checksum in little endian format! (phx) */
  256.   MSG_WriteString (&cls.netchan.message, va(prespawn_name, cl.servercount,
  257.                    (unsigned)LittleLong(cl.worldmodel->checksum2)));
  258. }
  259.  
  260. /*
  261. =================
  262. Sound_NextDownload
  263. =================
  264. */
  265. void Sound_NextDownload (void)
  266. {
  267.   char  *s;
  268.   int   i;
  269.  
  270.   if (cls.downloadnumber == 0)
  271.   {
  272.     Con_Printf ("Checking sounds...\n");
  273.     cls.downloadnumber = 1;
  274.   }
  275.  
  276.   cls.downloadtype = dl_sound;
  277.   for ( 
  278.     ; cl.sound_name[cls.downloadnumber][0]
  279.     ; cls.downloadnumber++)
  280.   {
  281.     s = cl.sound_name[cls.downloadnumber];
  282.     if (!CL_CheckOrDownloadFile(va("sound/%s",s)))
  283.       return;   // started a download
  284.   }
  285.  
  286.   for (i=1 ; i<MAX_SOUNDS ; i++)
  287.   {
  288.     if (!cl.sound_name[i][0])
  289.       break;
  290.     cl.sound_precache[i] = S_PrecacheSound (cl.sound_name[i]);
  291.   }
  292.  
  293.   // done with sounds, request models now
  294.   memset (cl.model_precache, 0, sizeof(cl.model_precache));
  295.   cl_playerindex = -1;
  296.   cl_spikeindex = -1;
  297.   cl_flagindex = -1;
  298.   MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  299. //  MSG_WriteString (&cls.netchan.message, va("modellist %i 0", cl.servercount));
  300.   MSG_WriteString (&cls.netchan.message, va(modellist_name, cl.servercount, 0));
  301. }
  302.  
  303.  
  304. /*
  305. ======================
  306. CL_RequestNextDownload
  307. ======================
  308. */
  309. void CL_RequestNextDownload (void)
  310. {
  311.   switch (cls.downloadtype)
  312.   {
  313.   case dl_single:
  314.     break;
  315.   case dl_skin:
  316.     Skin_NextDownload ();
  317.     break;
  318.   case dl_model:
  319.     Model_NextDownload ();
  320.     break;
  321.   case dl_sound:
  322.     Sound_NextDownload ();
  323.     break;
  324.   case dl_none:
  325.   default:
  326.     Con_DPrintf("Unknown download type.\n");
  327.   }
  328. }
  329.  
  330. /*
  331. =====================
  332. CL_ParseDownload
  333.  
  334. A download message has been received from the server
  335. =====================
  336. */
  337. void CL_ParseDownload (void)
  338. {
  339.   int   size, percent;
  340.   byte  name[1024];
  341.   int   r;
  342.  
  343.  
  344.   // read the data
  345.   size = MSG_ReadShort ();
  346.   percent = MSG_ReadByte ();
  347.  
  348.   if (cls.demoplayback) {
  349.     if (size > 0)
  350.       msg_readcount += size;
  351.     return; // not in demo playback
  352.   }
  353.  
  354.   if (size == -1)
  355.   {
  356.     Con_Printf ("File not found.\n");
  357.     if (cls.download)
  358.     {
  359.       Con_Printf ("cls.download shouldn't have been set\n");
  360.       fclose (cls.download);
  361.       cls.download = NULL;
  362.     }
  363.     CL_RequestNextDownload ();
  364.     return;
  365.   }
  366.  
  367.   // open the file if not opened yet
  368.   if (!cls.download)
  369.   {
  370.     if (strncmp(cls.downloadtempname,"skins/",6))
  371.       sprintf (name, "%s/%s", com_gamedir, cls.downloadtempname);
  372.     else
  373.       sprintf (name, "qw/%s", cls.downloadtempname);
  374.  
  375.     COM_CreatePath (name);
  376.  
  377.     cls.download = fopen (name, "wb");
  378.     if (!cls.download)
  379.     {
  380.       msg_readcount += size;
  381.       Con_Printf ("Failed to open %s\n", cls.downloadtempname);
  382.       CL_RequestNextDownload ();
  383.       return;
  384.     }
  385.   }
  386.  
  387.   fwrite (net_message.data + msg_readcount, 1, size, cls.download);
  388.   msg_readcount += size;
  389.  
  390.   if (percent != 100)
  391.   {
  392. // change display routines by zoid
  393.     // request next block
  394. #if 0
  395.     Con_Printf (".");
  396.     if (10*(percent/10) != cls.downloadpercent)
  397.     {
  398.       cls.downloadpercent = 10*(percent/10);
  399.       Con_Printf ("%i%%", cls.downloadpercent);
  400.     }
  401. #endif
  402.     cls.downloadpercent = percent;
  403.  
  404.     MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  405.     SZ_Print (&cls.netchan.message, "nextdl");
  406.   }
  407.   else
  408.   {
  409.     char  oldn[MAX_OSPATH];
  410.     char  newn[MAX_OSPATH];
  411.  
  412. #if 0
  413.     Con_Printf ("100%%\n");
  414. #endif
  415.  
  416.     fclose (cls.download);
  417.  
  418.     // rename the temp file to it's final name
  419.     if (strcmp(cls.downloadtempname, cls.downloadname)) {
  420.       if (strncmp(cls.downloadtempname,"skins/",6)) {
  421.         sprintf (oldn, "%s/%s", com_gamedir, cls.downloadtempname);
  422.         sprintf (newn, "%s/%s", com_gamedir, cls.downloadname);
  423.       } else {
  424.         sprintf (oldn, "qw/%s", cls.downloadtempname);
  425.         sprintf (newn, "qw/%s", cls.downloadname);
  426.       }
  427.       r = rename (oldn, newn);
  428.       if (r)
  429.         Con_Printf ("failed to rename.\n");
  430.     }
  431.  
  432.     cls.download = NULL;
  433.     cls.downloadpercent = 0;
  434.  
  435.     // get another file if needed
  436.  
  437.     CL_RequestNextDownload ();
  438.   }
  439. }
  440.  
  441. static byte *upload_data;
  442. static int upload_pos;
  443. static int upload_size;
  444.  
  445. void CL_NextUpload(void)
  446. {
  447.   byte  buffer[1024];
  448.   int   r;
  449.   int   percent;
  450.   int   size;
  451.  
  452.   if (!upload_data)
  453.     return;
  454.  
  455.   r = upload_size - upload_pos;
  456.   if (r > 768)
  457.     r = 768;
  458.   memcpy(buffer, upload_data + upload_pos, r);
  459.   MSG_WriteByte (&cls.netchan.message, clc_upload);
  460.   MSG_WriteShort (&cls.netchan.message, r);
  461.  
  462.   upload_pos += r;
  463.   size = upload_size;
  464.   if (!size)
  465.     size = 1;
  466.   percent = upload_pos*100/size;
  467.   MSG_WriteByte (&cls.netchan.message, percent);
  468.   SZ_Write (&cls.netchan.message, buffer, r);
  469.  
  470. Con_DPrintf ("UPLOAD: %6d: %d written\n", upload_pos - r, r);
  471.  
  472.   if (upload_pos != upload_size)
  473.     return;
  474.  
  475.   Con_Printf ("Upload completed\n");
  476.  
  477.   free(upload_data);
  478.   upload_data = 0;
  479.   upload_pos = upload_size = 0;
  480. }
  481.  
  482. void CL_StartUpload (byte *data, int size)
  483. {
  484.   if (cls.state < ca_onserver)
  485.     return; // gotta be connected
  486.  
  487.   // override
  488.   if (upload_data)
  489.     free(upload_data);
  490.  
  491. Con_DPrintf("Upload starting of %d...\n", size);
  492.  
  493.   upload_data = malloc(size);
  494.   memcpy(upload_data, data, size);
  495.   upload_size = size;
  496.   upload_pos = 0;
  497.  
  498.   CL_NextUpload();
  499. } 
  500.  
  501. qboolean CL_IsUploading(void)
  502. {
  503.   if (upload_data)
  504.     return true;
  505.   return false;
  506. }
  507.  
  508. void CL_StopUpload(void)
  509. {
  510.   if (upload_data)
  511.     free(upload_data);
  512.   upload_data = NULL;
  513. }
  514.  
  515. /*
  516. =====================================================================
  517.  
  518.   SERVER CONNECTING MESSAGES
  519.  
  520. =====================================================================
  521. */
  522.  
  523. /*
  524. ==================
  525. CL_ParseServerData
  526. ==================
  527. */
  528. void CL_ParseServerData (void)
  529. {
  530.   char  *str;
  531.   FILE  *f;
  532.   char  fn[MAX_OSPATH];
  533.   qboolean  cflag = false;
  534.   extern  char  gamedirfile[MAX_OSPATH];
  535.   int protover;
  536.   
  537.   Con_DPrintf ("Serverdata packet received.\n");
  538. //
  539. // wipe the client_state_t struct
  540. //
  541.   CL_ClearState ();
  542.  
  543. // parse protocol version number
  544. // allow 2.2 and 2.29 demos to play
  545.   protover = MSG_ReadLong ();
  546.   if (protover != PROTOCOL_VERSION && 
  547.     !(cls.demoplayback && (protover == 26 || protover == 27 || protover == 28)))
  548.     Host_EndGame ("Server returned version %i, not %i\nYou probably need to upgrade.\nCheck http://www.quakeworld.net/", protover, PROTOCOL_VERSION);
  549.  
  550.   cl.servercount = MSG_ReadLong ();
  551.  
  552.   // game directory
  553.   str = MSG_ReadString ();
  554.  
  555.   if (stricmp(gamedirfile, str)) {
  556.     // save current config
  557.     Host_WriteConfiguration (); 
  558.     cflag = true;
  559.   }
  560.  
  561.   COM_Gamedir(str);
  562.  
  563.   //ZOID--run the autoexec.cfg in the gamedir
  564.   //if it exists
  565.   if (cflag) {
  566.     sprintf(fn, "%s/%s", com_gamedir, "config.cfg");
  567.     if ((f = fopen(fn, "r")) != NULL) {
  568.       fclose(f);
  569.       Cbuf_AddText ("cl_warncmd 0\n");
  570.       Cbuf_AddText("exec config.cfg\n");
  571.       Cbuf_AddText("exec frontend.cfg\n");
  572.       Cbuf_AddText ("cl_warncmd 1\n");
  573.     }
  574.   }
  575.  
  576.   // parse player slot, high bit means spectator
  577.   cl.playernum = MSG_ReadByte ();
  578.   if (cl.playernum & 128)
  579.   {
  580.     cl.spectator = true;
  581.     cl.playernum &= ~128;
  582.   }
  583.  
  584.   // get the full level name
  585.   str = MSG_ReadString ();
  586.   strncpy (cl.levelname, str, sizeof(cl.levelname)-1);
  587.  
  588.   // get the movevars
  589.   movevars.gravity      = MSG_ReadFloat();
  590.   movevars.stopspeed          = MSG_ReadFloat();
  591.   movevars.maxspeed           = MSG_ReadFloat();
  592.   movevars.spectatormaxspeed  = MSG_ReadFloat();
  593.   movevars.accelerate         = MSG_ReadFloat();
  594.   movevars.airaccelerate      = MSG_ReadFloat();
  595.   movevars.wateraccelerate    = MSG_ReadFloat();
  596.   movevars.friction           = MSG_ReadFloat();
  597.   movevars.waterfriction      = MSG_ReadFloat();
  598.   movevars.entgravity         = MSG_ReadFloat();
  599.  
  600.   // seperate the printfs so the server message can have a color
  601.   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");
  602.   Con_Printf ("%c%s\n", 2, str);
  603.  
  604.   // ask for the sound list next
  605.   memset(cl.sound_name, 0, sizeof(cl.sound_name));
  606.   MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  607. //  MSG_WriteString (&cls.netchan.message, va("soundlist %i 0", cl.servercount));
  608.   MSG_WriteString (&cls.netchan.message, va(soundlist_name, cl.servercount, 0));
  609.  
  610.   // now waiting for downloads, etc
  611.   cls.state = ca_onserver;
  612. }
  613.  
  614. /*
  615. ==================
  616. CL_ParseSoundlist
  617. ==================
  618. */
  619. void CL_ParseSoundlist (void)
  620. {
  621.   int numsounds;
  622.   char  *str;
  623.   int n;
  624.  
  625. // precache sounds
  626. //  memset (cl.sound_precache, 0, sizeof(cl.sound_precache));
  627.  
  628.   numsounds = MSG_ReadByte();
  629.  
  630.   for (;;) {
  631.     str = MSG_ReadString ();
  632.     if (!str[0])
  633.       break;
  634.     numsounds++;
  635.     if (numsounds == MAX_SOUNDS)
  636.       Host_EndGame ("Server sent too many sound_precache");
  637.     strcpy (cl.sound_name[numsounds], str);
  638.   }
  639.  
  640.   n = MSG_ReadByte();
  641.  
  642.   if (n) {
  643.     MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  644. //    MSG_WriteString (&cls.netchan.message, va("soundlist %i %i", cl.servercount, n));
  645.     MSG_WriteString (&cls.netchan.message, va(soundlist_name, cl.servercount, n));
  646.     return;
  647.   }
  648.  
  649.   cls.downloadnumber = 0;
  650.   cls.downloadtype = dl_sound;
  651.   Sound_NextDownload ();
  652. }
  653.  
  654. /*
  655. ==================
  656. CL_ParseModellist
  657. ==================
  658. */
  659. void CL_ParseModellist (void)
  660. {
  661.   int nummodels;
  662.   char  *str;
  663.   int n;
  664.  
  665. // precache models and note certain default indexes
  666.   nummodels = MSG_ReadByte();
  667.  
  668.   for (;;)
  669.   {
  670.     str = MSG_ReadString ();
  671.     if (!str[0])
  672.       break;
  673.     nummodels++;
  674.     if (nummodels==MAX_MODELS)
  675.       Host_EndGame ("Server sent too many model_precache");
  676.     strcpy (cl.model_name[nummodels], str);
  677.  
  678.     if (!strcmp(cl.model_name[nummodels],"progs/spike.mdl"))
  679.       cl_spikeindex = nummodels;
  680.     if (!strcmp(cl.model_name[nummodels],"progs/player.mdl"))
  681.       cl_playerindex = nummodels;
  682.     if (!strcmp(cl.model_name[nummodels],"progs/flag.mdl"))
  683.       cl_flagindex = nummodels;
  684.   }
  685.  
  686.   n = MSG_ReadByte();
  687.  
  688.   if (n) {
  689.     MSG_WriteByte (&cls.netchan.message, clc_stringcmd);
  690. //    MSG_WriteString (&cls.netchan.message, va("modellist %i %i", cl.servercount, n));
  691.     MSG_WriteString (&cls.netchan.message, va(modellist_name, cl.servercount, n));
  692.     return;
  693.   }
  694.  
  695.   cls.downloadnumber = 0;
  696.   cls.downloadtype = dl_model;
  697.   Model_NextDownload ();
  698. }
  699.  
  700. /*
  701. ==================
  702. CL_ParseBaseline
  703. ==================
  704. */
  705. void CL_ParseBaseline (entity_state_t *es)
  706. {
  707.   int     i;
  708.   
  709.   es->modelindex = MSG_ReadByte ();
  710.   es->frame = MSG_ReadByte ();
  711.   es->colormap = MSG_ReadByte();
  712.   es->skinnum = MSG_ReadByte();
  713.   for (i=0 ; i<3 ; i++)
  714.   {
  715.     es->origin[i] = MSG_ReadCoord ();
  716.     es->angles[i] = MSG_ReadAngle ();
  717.   }
  718. }
  719.  
  720.  
  721.  
  722. /*
  723. =====================
  724. CL_ParseStatic
  725.  
  726. Static entities are non-interactive world objects
  727. like torches
  728. =====================
  729. */
  730. void CL_ParseStatic (void)
  731. {
  732.   entity_t *ent;
  733.   int   i;
  734.   entity_state_t  es;
  735.  
  736.   CL_ParseBaseline (&es);
  737.     
  738.   i = cl.num_statics;
  739.   if (i >= MAX_STATIC_ENTITIES)
  740.     Host_EndGame ("Too many static entities");
  741.   ent = &cl_static_entities[i];
  742.   cl.num_statics++;
  743.  
  744. // copy it to the current state
  745.   ent->model = cl.model_precache[es.modelindex];
  746.   ent->frame = es.frame;
  747.   ent->colormap = vid.colormap;
  748.   ent->skinnum = es.skinnum;
  749.  
  750.   VectorCopy (es.origin, ent->origin);
  751.   VectorCopy (es.angles, ent->angles);
  752.   
  753.   R_AddEfrags (ent);
  754. }
  755.  
  756. /*
  757. ===================
  758. CL_ParseStaticSound
  759. ===================
  760. */
  761. void CL_ParseStaticSound (void)
  762. {
  763.   vec3_t    org;
  764.   int     sound_num, vol, atten;
  765.   int     i;
  766.   
  767.   for (i=0 ; i<3 ; i++)
  768.     org[i] = MSG_ReadCoord ();
  769.   sound_num = MSG_ReadByte ();
  770.   vol = MSG_ReadByte ();
  771.   atten = MSG_ReadByte ();
  772.   
  773.   S_StaticSound (cl.sound_precache[sound_num], org, vol, atten);
  774. }
  775.  
  776.  
  777.  
  778. /*
  779. =====================================================================
  780.  
  781. ACTION MESSAGES
  782.  
  783. =====================================================================
  784. */
  785.  
  786. /*
  787. ==================
  788. CL_ParseStartSoundPacket
  789. ==================
  790. */
  791. void CL_ParseStartSoundPacket(void)
  792. {
  793.     vec3_t  pos;
  794.     int   channel, ent;
  795.     int   sound_num;
  796.     int   volume;
  797.     float   attenuation;  
  798.   int   i;
  799.              
  800.     channel = MSG_ReadShort(); 
  801.  
  802.     if (channel & SND_VOLUME)
  803.     volume = MSG_ReadByte ();
  804.   else
  805.     volume = DEFAULT_SOUND_PACKET_VOLUME;
  806.   
  807.     if (channel & SND_ATTENUATION)
  808.     attenuation = MSG_ReadByte () / 64.0;
  809.   else
  810.     attenuation = DEFAULT_SOUND_PACKET_ATTENUATION;
  811.   
  812.   sound_num = MSG_ReadByte ();
  813.  
  814.   for (i=0 ; i<3 ; i++)
  815.     pos[i] = MSG_ReadCoord ();
  816.  
  817.   ent = (channel>>3)&1023;
  818.   channel &= 7;
  819.  
  820.   if (ent > MAX_EDICTS)
  821.     Host_EndGame ("CL_ParseStartSoundPacket: ent = %i", ent);
  822.   
  823.     S_StartSound (ent, channel, cl.sound_precache[sound_num], pos, volume/255.0, attenuation);
  824. }       
  825.  
  826.  
  827. /*
  828. ==================
  829. CL_ParseClientdata
  830.  
  831. Server information pertaining to this client only, sent every frame
  832. ==================
  833. */
  834. void CL_ParseClientdata (void)
  835. {
  836.   int       i;
  837.   float   latency;
  838.   frame_t   *frame;
  839.  
  840. // calculate simulated time of message
  841.   oldparsecountmod = parsecountmod;
  842.  
  843.   i = cls.netchan.incoming_acknowledged;
  844.   cl.parsecount = i;
  845.   i &= UPDATE_MASK;
  846.   parsecountmod = i;
  847.   frame = &cl.frames[i];
  848.   parsecounttime = cl.frames[i].senttime;
  849.  
  850.   frame->receivedtime = realtime;
  851.  
  852. // calculate latency
  853.   latency = frame->receivedtime - frame->senttime;
  854.  
  855.   if (latency < 0 || latency > 1.0)
  856.   {
  857. //    Con_Printf ("Odd latency: %5.2f\n", latency);
  858.   }
  859.   else
  860.   {
  861.   // drift the average latency towards the observed latency
  862.     if (latency < cls.latency)
  863.       cls.latency = latency;
  864.     else
  865.       cls.latency += 0.001; // drift up, so correction are needed
  866.   } 
  867. }
  868.  
  869. /*
  870. =====================
  871. CL_NewTranslation
  872. =====================
  873. */
  874. void CL_NewTranslation (int slot)
  875. {
  876. #ifdef GLQUAKE
  877.   if (slot > MAX_CLIENTS)
  878.     Sys_Error ("CL_NewTranslation: slot > MAX_CLIENTS");
  879.  
  880.   R_TranslatePlayerSkin(slot);
  881. #else
  882.  
  883.   int   i, j;
  884.   int   top, bottom;
  885.   byte  *dest, *source;
  886.   player_info_t *player;
  887.   char s[512];
  888.  
  889.   if (slot > MAX_CLIENTS)
  890.     Sys_Error ("CL_NewTranslation: slot > MAX_CLIENTS");
  891.  
  892.   player = &cl.players[slot];
  893.  
  894.   strcpy(s, Info_ValueForKey(player->userinfo, "skin"));
  895.   COM_StripExtension(s, s);
  896.   if (player->skin && !stricmp(s, player->skin->name))
  897.     player->skin = NULL;
  898.  
  899.   if (player->_topcolor != player->topcolor ||
  900.     player->_bottomcolor != player->bottomcolor || !player->skin) {
  901.     player->_topcolor = player->topcolor;
  902.     player->_bottomcolor = player->bottomcolor;
  903.  
  904.     dest = player->translations;
  905.     source = vid.colormap;
  906.     memcpy (dest, vid.colormap, sizeof(player->translations));
  907.     top = player->topcolor;
  908.     if (top > 13 || top < 0)
  909.       top = 13;
  910.     top *= 16;
  911.     bottom = player->bottomcolor;
  912.     if (bottom > 13 || bottom < 0)
  913.       bottom = 13;
  914.     bottom *= 16;
  915.  
  916.     for (i=0 ; i<VID_GRADES ; i++, dest += 256, source+=256)
  917.     {
  918.       if (top < 128)  // the artists made some backwards ranges.  sigh.
  919.         memcpy (dest + TOP_RANGE, source + top, 16);
  920.       else
  921.         for (j=0 ; j<16 ; j++)
  922.           dest[TOP_RANGE+j] = source[top+15-j];
  923.           
  924.       if (bottom < 128)
  925.         memcpy (dest + BOTTOM_RANGE, source + bottom, 16);
  926.       else
  927.         for (j=0 ; j<16 ; j++)
  928.           dest[BOTTOM_RANGE+j] = source[bottom+15-j];   
  929.     }
  930.   }
  931. #endif
  932. }
  933.  
  934. /*
  935. ==============
  936. CL_UpdateUserinfo
  937. ==============
  938. */
  939. void CL_ProcessUserInfo (int slot, player_info_t *player)
  940. {
  941.   strncpy (player->name, Info_ValueForKey (player->userinfo, "name"), sizeof(player->name)-1);
  942.   player->topcolor = atoi(Info_ValueForKey (player->userinfo, "topcolor"));
  943.   player->bottomcolor = atoi(Info_ValueForKey (player->userinfo, "bottomcolor"));
  944.   if (Info_ValueForKey (player->userinfo, "*spectator")[0])
  945.     player->spectator = true;
  946.   else
  947.     player->spectator = false;
  948.  
  949.   if (cls.state == ca_active)
  950.     Skin_Find (player);
  951.  
  952.   Sbar_Changed ();
  953.   CL_NewTranslation (slot);
  954. }
  955.  
  956. /*
  957. ==============
  958. CL_UpdateUserinfo
  959. ==============
  960. */
  961. void CL_UpdateUserinfo (void)
  962. {
  963.   int   slot;
  964.   player_info_t *player;
  965.  
  966.   slot = MSG_ReadByte ();
  967.   if (slot >= MAX_CLIENTS)
  968.     Host_EndGame ("CL_ParseServerMessage: svc_updateuserinfo > MAX_SCOREBOARD");
  969.  
  970.   player = &cl.players[slot];
  971.   player->userid = MSG_ReadLong ();
  972.   strncpy (player->userinfo, MSG_ReadString(), sizeof(player->userinfo)-1);
  973.  
  974.   CL_ProcessUserInfo (slot, player);
  975. }
  976.  
  977. /*
  978. ==============
  979. CL_SetInfo
  980. ==============
  981. */
  982. void CL_SetInfo (void)
  983. {
  984.   int   slot;
  985.   player_info_t *player;
  986.   char key[MAX_MSGLEN];
  987.   char value[MAX_MSGLEN];
  988.  
  989.   slot = MSG_ReadByte ();
  990.   if (slot >= MAX_CLIENTS)
  991.     Host_EndGame ("CL_ParseServerMessage: svc_setinfo > MAX_SCOREBOARD");
  992.  
  993.   player = &cl.players[slot];
  994.  
  995.   strncpy (key, MSG_ReadString(), sizeof(key) - 1);
  996.   key[sizeof(key) - 1] = 0;
  997.   strncpy (value, MSG_ReadString(), sizeof(value) - 1);
  998.   key[sizeof(value) - 1] = 0;
  999.  
  1000.   Con_DPrintf("SETINFO %s: %s=%s\n", player->name, key, value);
  1001.  
  1002.   Info_SetValueForKey (player->userinfo, key, value, MAX_INFO_STRING);
  1003.  
  1004.   CL_ProcessUserInfo (slot, player);
  1005. }
  1006.  
  1007. /*
  1008. ==============
  1009. CL_ServerInfo
  1010. ==============
  1011. */
  1012. void CL_ServerInfo (void)
  1013. {
  1014.   int   slot;
  1015.   player_info_t *player;
  1016.   char key[MAX_MSGLEN];
  1017.   char value[MAX_MSGLEN];
  1018.  
  1019.   strncpy (key, MSG_ReadString(), sizeof(key) - 1);
  1020.   key[sizeof(key) - 1] = 0;
  1021.   strncpy (value, MSG_ReadString(), sizeof(value) - 1);
  1022.   key[sizeof(value) - 1] = 0;
  1023.  
  1024.   Con_DPrintf("SERVERINFO: %s=%s\n", key, value);
  1025.  
  1026.   Info_SetValueForKey (cl.serverinfo, key, value, MAX_SERVERINFO_STRING);
  1027. }
  1028.  
  1029. /*
  1030. =====================
  1031. CL_SetStat
  1032. =====================
  1033. */
  1034. void CL_SetStat (int stat, int value)
  1035. {
  1036.   int j;
  1037.   if (stat < 0 || stat >= MAX_CL_STATS)
  1038.     Sys_Error ("CL_SetStat: %i is invalid", stat);
  1039.  
  1040.   Sbar_Changed ();
  1041.   
  1042.   if (stat == STAT_ITEMS)
  1043.   { // set flash times
  1044.     Sbar_Changed ();
  1045.     for (j=0 ; j<32 ; j++)
  1046.       if ( (value & (1<<j)) && !(cl.stats[stat] & (1<<j)))
  1047.         cl.item_gettime[j] = cl.time;
  1048.   }
  1049.  
  1050.   cl.stats[stat] = value;
  1051. }
  1052.  
  1053. /*
  1054. ==============
  1055. CL_MuzzleFlash
  1056. ==============
  1057. */
  1058. void CL_MuzzleFlash (void)
  1059. {
  1060.   vec3_t    fv, rv, uv;
  1061.   dlight_t  *dl;
  1062.   int     i;
  1063.   player_state_t  *pl;
  1064.  
  1065.   i = MSG_ReadShort ();
  1066.  
  1067.   if ((unsigned)(i-1) >= MAX_CLIENTS)
  1068.     return;
  1069.  
  1070. #ifdef GLQUAKE
  1071.   // don't draw our own muzzle flash in gl if flashblending
  1072.   if (i-1 == cl.playernum && gl_flashblend.value)
  1073.     return;
  1074. #endif
  1075.  
  1076.   pl = &cl.frames[parsecountmod].playerstate[i-1];
  1077.  
  1078.   dl = CL_AllocDlight (i);
  1079.   VectorCopy (pl->origin,  dl->origin);
  1080.   AngleVectors (pl->viewangles, fv, rv, uv);
  1081.     
  1082.   VectorMA (dl->origin, 18, fv, dl->origin);
  1083.   dl->radius = 200 + (rand()&31);
  1084.   dl->minlight = 32;
  1085.   dl->die = cl.time + 0.1;
  1086.   dl->color[0] = 0.2;
  1087.   dl->color[1] = 0.1;
  1088.   dl->color[2] = 0.05;
  1089.   dl->color[3] = 0.7;
  1090. }
  1091.  
  1092.  
  1093. #define SHOWNET(x) if(cl_shownet.value==2)Con_Printf ("%3i:%s\n", msg_readcount-1, x);
  1094. /*
  1095. =====================
  1096. CL_ParseServerMessage
  1097. =====================
  1098. */
  1099. int received_framecount;
  1100. void CL_ParseServerMessage (void)
  1101. {
  1102.   int     cmd;
  1103.   char    *s;
  1104.   int     i, j;
  1105.  
  1106.   received_framecount = host_framecount;
  1107.   cl.last_servermessage = realtime;
  1108.   CL_ClearProjectiles ();
  1109.  
  1110. //
  1111. // if recording demos, copy the message out
  1112. //
  1113.   if (cl_shownet.value == 1)
  1114.     Con_Printf ("%i ",net_message.cursize);
  1115.   else if (cl_shownet.value == 2)
  1116.     Con_Printf ("------------------\n");
  1117.  
  1118.  
  1119.   CL_ParseClientdata ();
  1120.  
  1121. //
  1122. // parse the message
  1123. //
  1124.   while (1)
  1125.   {
  1126.     if (msg_badread)
  1127.     {
  1128.       Host_EndGame ("CL_ParseServerMessage: Bad server message");
  1129.       break;
  1130.     }
  1131.  
  1132.     cmd = MSG_ReadByte ();
  1133.  
  1134.     if (cmd == -1)
  1135.     {
  1136.       msg_readcount++;  // so the EOM showner has the right value
  1137.       SHOWNET("END OF MESSAGE");
  1138.       break;
  1139.     }
  1140.  
  1141.     SHOWNET(svc_strings[cmd]);
  1142.   
  1143.   // other commands
  1144.     switch (cmd)
  1145.     {
  1146.     default:
  1147.       Host_EndGame ("CL_ParseServerMessage: Illegible server message");
  1148.       break;
  1149.       
  1150.     case svc_nop:
  1151. //      Con_Printf ("svc_nop\n");
  1152.       break;
  1153.       
  1154.     case svc_disconnect:
  1155.       if (cls.state == ca_connected)
  1156.         Host_EndGame ("Server disconnected\n"
  1157.           "Server version may not be compatible");
  1158.       else
  1159.         Host_EndGame ("Server disconnected");
  1160.       break;
  1161.  
  1162.     case svc_print:
  1163.       i = MSG_ReadByte ();
  1164.       if (i == PRINT_CHAT)
  1165.       {
  1166.         S_LocalSound ("misc/talk.wav");
  1167.         con_ormask = 128;
  1168.       }
  1169.       Con_Printf ("%s", MSG_ReadString ());
  1170.       con_ormask = 0;
  1171.       break;
  1172.       
  1173.     case svc_centerprint:
  1174.       SCR_CenterPrint (MSG_ReadString ());
  1175.       break;
  1176.       
  1177.     case svc_stufftext:
  1178.       s = MSG_ReadString ();
  1179.       Con_DPrintf ("stufftext: %s\n", s);
  1180.       Cbuf_AddText (s);
  1181.       break;
  1182.       
  1183.     case svc_damage:
  1184.       V_ParseDamage ();
  1185.       break;
  1186.       
  1187.     case svc_serverdata:
  1188.       Cbuf_Execute ();    // make sure any stuffed commands are done
  1189.       CL_ParseServerData ();
  1190.       vid.recalc_refdef = true; // leave full screen intermission
  1191.       break;
  1192.       
  1193.     case svc_setangle:
  1194.       for (i=0 ; i<3 ; i++)
  1195.         cl.viewangles[i] = MSG_ReadAngle ();
  1196. //      cl.viewangles[PITCH] = cl.viewangles[ROLL] = 0;
  1197.       break;
  1198.       
  1199.     case svc_lightstyle:
  1200.       i = MSG_ReadByte ();
  1201.       if (i >= MAX_LIGHTSTYLES)
  1202.         Sys_Error ("svc_lightstyle > MAX_LIGHTSTYLES");
  1203.       Q_strcpy (cl_lightstyle[i].map,  MSG_ReadString());
  1204.       cl_lightstyle[i].length = Q_strlen(cl_lightstyle[i].map);
  1205.       break;
  1206.       
  1207.     case svc_sound:
  1208.       CL_ParseStartSoundPacket();
  1209.       break;
  1210.       
  1211.     case svc_stopsound:
  1212.       i = MSG_ReadShort();
  1213.       S_StopSound(i>>3, i&7);
  1214.       break;
  1215.     
  1216.     case svc_updatefrags:
  1217.       Sbar_Changed ();
  1218.       i = MSG_ReadByte ();
  1219.       if (i >= MAX_CLIENTS)
  1220.         Host_EndGame ("CL_ParseServerMessage: svc_updatefrags > MAX_SCOREBOARD");
  1221.       cl.players[i].frags = MSG_ReadShort ();
  1222.       break;      
  1223.  
  1224.     case svc_updateping:
  1225.       i = MSG_ReadByte ();
  1226.       if (i >= MAX_CLIENTS)
  1227.         Host_EndGame ("CL_ParseServerMessage: svc_updateping > MAX_SCOREBOARD");
  1228.       cl.players[i].ping = MSG_ReadShort ();
  1229.       break;
  1230.       
  1231.     case svc_updatepl:
  1232.       i = MSG_ReadByte ();
  1233.       if (i >= MAX_CLIENTS)
  1234.         Host_EndGame ("CL_ParseServerMessage: svc_updatepl > MAX_SCOREBOARD");
  1235.       cl.players[i].pl = MSG_ReadByte ();
  1236.       break;
  1237.       
  1238.     case svc_updateentertime:
  1239.     // time is sent over as seconds ago
  1240.       i = MSG_ReadByte ();
  1241.       if (i >= MAX_CLIENTS)
  1242.         Host_EndGame ("CL_ParseServerMessage: svc_updateentertime > MAX_SCOREBOARD");
  1243.       cl.players[i].entertime = realtime - MSG_ReadFloat ();
  1244.       break;
  1245.       
  1246.     case svc_spawnbaseline:
  1247.       i = MSG_ReadShort ();
  1248.       CL_ParseBaseline (&cl_baselines[i]);
  1249.       break;
  1250.     case svc_spawnstatic:
  1251.       CL_ParseStatic ();
  1252.       break;      
  1253.     case svc_temp_entity:
  1254.       CL_ParseTEnt ();
  1255.       break;
  1256.  
  1257.     case svc_killedmonster:
  1258.       cl.stats[STAT_MONSTERS]++;
  1259.       break;
  1260.  
  1261.     case svc_foundsecret:
  1262.       cl.stats[STAT_SECRETS]++;
  1263.       break;
  1264.  
  1265.     case svc_updatestat:
  1266.       i = MSG_ReadByte ();
  1267.       j = MSG_ReadByte ();
  1268.       CL_SetStat (i, j);
  1269.       break;
  1270.     case svc_updatestatlong:
  1271.       i = MSG_ReadByte ();
  1272.       j = MSG_ReadLong ();
  1273.       CL_SetStat (i, j);
  1274.       break;
  1275.       
  1276.     case svc_spawnstaticsound:
  1277.       CL_ParseStaticSound ();
  1278.       break;
  1279.  
  1280.     case svc_cdtrack:
  1281.       cl.cdtrack = MSG_ReadByte ();
  1282.       CDAudio_Play ((byte)cl.cdtrack, true);
  1283.       break;
  1284.  
  1285.     case svc_intermission:
  1286.       cl.intermission = 1;
  1287.       cl.completed_time = realtime;
  1288.       vid.recalc_refdef = true; // go to full screen
  1289.       for (i=0 ; i<3 ; i++)
  1290.         cl.simorg[i] = MSG_ReadCoord ();      
  1291.       for (i=0 ; i<3 ; i++)
  1292.         cl.simangles[i] = MSG_ReadAngle ();
  1293.       VectorCopy (vec3_origin, cl.simvel);
  1294.       break;
  1295.  
  1296.     case svc_finale:
  1297.       cl.intermission = 2;
  1298.       cl.completed_time = realtime;
  1299.       vid.recalc_refdef = true; // go to full screen
  1300.       SCR_CenterPrint (MSG_ReadString ());      
  1301.       break;
  1302.       
  1303.     case svc_sellscreen:
  1304.       Cmd_ExecuteString ("help");
  1305.       break;
  1306.  
  1307.     case svc_smallkick:
  1308.       cl.punchangle = -2;
  1309.       break;
  1310.     case svc_bigkick:
  1311.       cl.punchangle = -4;
  1312.       break;
  1313.  
  1314.     case svc_muzzleflash:
  1315.       CL_MuzzleFlash ();
  1316.       break;
  1317.  
  1318.     case svc_updateuserinfo:
  1319.       CL_UpdateUserinfo ();
  1320.       break;
  1321.  
  1322.     case svc_setinfo:
  1323.       CL_SetInfo ();
  1324.       break;
  1325.  
  1326.     case svc_serverinfo:
  1327.       CL_ServerInfo ();
  1328.       break;
  1329.  
  1330.     case svc_download:
  1331.       CL_ParseDownload ();
  1332.       break;
  1333.  
  1334.     case svc_playerinfo:
  1335.       CL_ParsePlayerinfo ();
  1336.       break;
  1337.  
  1338.     case svc_nails:
  1339.       CL_ParseProjectiles ();
  1340.       break;
  1341.  
  1342.     case svc_chokecount:    // some preceding packets were choked
  1343.       i = MSG_ReadByte ();
  1344.       for (j=0 ; j<i ; j++)
  1345.         cl.frames[ (cls.netchan.incoming_acknowledged-1-j)&UPDATE_MASK ].receivedtime = -2;
  1346.       break;
  1347.  
  1348.     case svc_modellist:
  1349.       CL_ParseModellist ();
  1350.       break;
  1351.  
  1352.     case svc_soundlist:
  1353.       CL_ParseSoundlist ();
  1354.       break;
  1355.  
  1356.     case svc_packetentities:
  1357.       CL_ParsePacketEntities (false);
  1358.       break;
  1359.  
  1360.     case svc_deltapacketentities:
  1361.       CL_ParsePacketEntities (true);
  1362.       break;
  1363.  
  1364.     case svc_maxspeed :
  1365.       movevars.maxspeed = MSG_ReadFloat();
  1366.       break;
  1367.  
  1368.     case svc_entgravity :
  1369.       movevars.entgravity = MSG_ReadFloat();
  1370.       break;
  1371.  
  1372.     case svc_setpause:
  1373.       cl.paused = MSG_ReadByte ();
  1374.       if (cl.paused)
  1375.         CDAudio_Pause ();
  1376.       else
  1377.         CDAudio_Resume ();
  1378.       break;
  1379.  
  1380.     }
  1381.   }
  1382.  
  1383.   CL_SetSolidEntities ();
  1384. }
  1385.  
  1386.  
  1387.