mirror of
https://github.com/nzp-team/fteqw.git
synced 2024-11-10 22:51:57 +00:00
6e3f69f504
fte particle scripts are disabled (classic works). I'll fix these in the new year. Redid framestate stuff again. Slightly better now, but this is the bulk of the changes here. Reworked the renderqueue to provide batches of items instead of individual items. This cleans up the particle rendering code significantly, and is a step towards multiple concurrent particle systems. fte's scripted particles are broken as I'm trying to find a way to rework them to batch types together, rather than having to restart each batch after each particle when you have two particles in a trail. I'll fix it some time. Reworked some alias model code regarding skeletal models. Added some conceptual skeletal bone control builtins available to csqc. Currently it can query the bone names and save off animation states, but can't animate - its just not complete. Added more info to glsl custom shaders. Updated surface sorting on halflife maps to properly cope with alphaed entities, rather than just texture-based blends (q2-style). git-svn-id: https://svn.code.sf.net/p/fteqw/code/trunk@3095 fc73d0e0-1445-4013-8a0c-d673dee63da5
2022 lines
41 KiB
C
2022 lines
41 KiB
C
/*
|
|
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 included (GNU.txt) 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 the Free Software
|
|
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
|
|
|
|
*/
|
|
|
|
#include "quakedef.h"
|
|
|
|
void CL_FinishTimeDemo (void);
|
|
float demtime;
|
|
|
|
int cls_lastto;
|
|
int cls_lasttype;
|
|
|
|
void CL_PlayDemo(char *demoname);
|
|
char lastdemoname[256];
|
|
|
|
extern cvar_t qtvcl_forceversion1;
|
|
extern cvar_t qtvcl_eztvextensions;
|
|
|
|
unsigned char demobuffer[1024*16];
|
|
int demobuffersize;
|
|
int demopreparsedbytes;
|
|
qboolean disablepreparse;
|
|
qboolean endofdemo;
|
|
|
|
#define BUFFERTIME 0.5
|
|
/*
|
|
==============================================================================
|
|
|
|
DEMO CODE
|
|
|
|
When a demo is playing back, all NET_SendMessages are skipped, and
|
|
NET_GetMessages are read from the demo file.
|
|
|
|
Whenever cl.time gets past the last received message, another message is
|
|
read from the demo file.
|
|
==============================================================================
|
|
*/
|
|
|
|
/*
|
|
==============
|
|
CL_StopPlayback
|
|
|
|
Called when a demo file runs out, or the user starts a game
|
|
==============
|
|
*/
|
|
void CL_StopPlayback (void)
|
|
{
|
|
if (!cls.demoplayback)
|
|
return;
|
|
|
|
Media_CaptureDemoEnd();
|
|
|
|
VFS_CLOSE (cls.demofile);
|
|
cls.demofile = NULL;
|
|
cls.state = ca_disconnected;
|
|
cls.demoplayback = DPB_NONE;
|
|
|
|
if (cls.timedemo)
|
|
CL_FinishTimeDemo ();
|
|
}
|
|
|
|
#define dem_cmd 0
|
|
#define dem_read 1
|
|
#define dem_set 2
|
|
|
|
/*
|
|
====================
|
|
CL_WriteDemoCmd
|
|
|
|
Writes the player0 user cmd (demos don't support split screen)
|
|
====================
|
|
*/
|
|
void CL_WriteDemoCmd (usercmd_t *pcmd)
|
|
{
|
|
int i;
|
|
float fl;
|
|
qbyte c;
|
|
q1usercmd_t cmd;
|
|
|
|
//Con_Printf("write: %ld bytes, %4.4f\n", msg->cursize, demtime);
|
|
|
|
fl = LittleFloat((float)demtime);
|
|
VFS_WRITE (cls.demofile, &fl, sizeof(fl));
|
|
|
|
c = dem_cmd;
|
|
VFS_WRITE (cls.demofile, &c, sizeof(c));
|
|
|
|
// correct for byte order, bytes don't matter
|
|
|
|
cmd.buttons = pcmd->buttons;
|
|
cmd.impulse = pcmd->impulse;
|
|
cmd.msec = pcmd->msec;
|
|
|
|
for (i = 0; i < 3; i++)
|
|
cmd.angles[i] = LittleFloat(pcmd->angles[i]*65536/360);
|
|
|
|
cmd.forwardmove = LittleShort(pcmd->forwardmove);
|
|
cmd.sidemove = LittleShort(pcmd->sidemove);
|
|
cmd.upmove = LittleShort(pcmd->upmove);
|
|
|
|
VFS_WRITE (cls.demofile, &cmd, sizeof(cmd));
|
|
|
|
for (i=0 ; i<3 ; i++)
|
|
{
|
|
fl = LittleFloat (cl.viewangles[0][i]);
|
|
VFS_WRITE (cls.demofile, &fl, 4);
|
|
}
|
|
|
|
VFS_FLUSH (cls.demofile);
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_WriteDemoMessage
|
|
|
|
Dumps the current net message, prefixed by the length and view angles
|
|
====================
|
|
*/
|
|
void CL_WriteDemoMessage (sizebuf_t *msg)
|
|
{
|
|
int len;
|
|
float fl;
|
|
qbyte c;
|
|
|
|
//Con_Printf("write: %ld bytes, %4.4f\n", msg->cursize, demtime);
|
|
|
|
if (!cls.demorecording)
|
|
return;
|
|
|
|
fl = LittleFloat((float)demtime);
|
|
VFS_WRITE (cls.demofile, &fl, sizeof(fl));
|
|
|
|
c = dem_read;
|
|
VFS_WRITE (cls.demofile, &c, sizeof(c));
|
|
|
|
len = LittleLong (msg->cursize);
|
|
VFS_WRITE (cls.demofile, &len, 4);
|
|
VFS_WRITE (cls.demofile, msg->data, msg->cursize);
|
|
|
|
VFS_FLUSH (cls.demofile);
|
|
}
|
|
|
|
int demo_preparsedemo(unsigned char *buffer, int bytes)
|
|
{
|
|
int parsed = 0;
|
|
int ofs;
|
|
unsigned int length;
|
|
#define dem_mask 7
|
|
if (cls.demoplayback != DPB_MVD && cls.demoplayback != DPB_EZTV)
|
|
return bytes; //no need if its not an mvd (this simplifies it a little)
|
|
|
|
while (bytes>2)
|
|
{
|
|
switch(buffer[1]&dem_mask)
|
|
{
|
|
case dem_set:
|
|
ofs = -10;
|
|
break;
|
|
case dem_multiple:
|
|
ofs = 6;
|
|
break;
|
|
default:
|
|
ofs = 2;
|
|
break;
|
|
}
|
|
if (ofs > 0)
|
|
{
|
|
if (ofs+4 > bytes)
|
|
break;
|
|
length = (buffer[ofs+0]<<0) + (buffer[ofs+1]<<8) + (buffer[ofs+2]<<16) + (buffer[ofs+3]<<24);
|
|
if (length > MAX_OVERALLMSGLEN)
|
|
{
|
|
disablepreparse = true;
|
|
Con_Printf("Error looking ahead at demo\n");
|
|
return parsed;
|
|
}
|
|
ofs+=4;
|
|
}
|
|
else
|
|
{
|
|
length = -ofs;
|
|
ofs = 2;
|
|
}
|
|
//ofs is now the offset of the data
|
|
if (ofs+length > bytes)
|
|
{
|
|
return parsed; //not got it all
|
|
}
|
|
if ((buffer[1]&dem_mask) == dem_all && (buffer[1] & ~dem_mask) && length < MAX_NQMSGLEN)
|
|
{
|
|
net_message.cursize = length;
|
|
memcpy(net_message.data, buffer+ofs, length);
|
|
CL_ParseServerMessage();
|
|
}
|
|
|
|
parsed += ofs+length;
|
|
buffer += ofs+length;
|
|
bytes -= ofs+length;
|
|
}
|
|
|
|
return parsed;
|
|
}
|
|
|
|
int readdemobytes(int *readpos, void *data, int len)
|
|
{
|
|
int i;
|
|
int trybytes;
|
|
|
|
if (demopreparsedbytes < 0) //won't happen in normal running, but can still happen on corrupt data... if we don't disconnect first.
|
|
{
|
|
Con_Printf("reset preparsed (underflow)\n");
|
|
demopreparsedbytes = 0;
|
|
}
|
|
if (demopreparsedbytes > demobuffersize)
|
|
{
|
|
Con_Printf("reset preparsed (overflow)\n");
|
|
demopreparsedbytes = 0;
|
|
}
|
|
|
|
trybytes = sizeof(demobuffer)-demobuffersize;
|
|
|
|
i = VFS_READ(cls.demofile, demobuffer+demobuffersize, trybytes);
|
|
if (i > 0)
|
|
{
|
|
demobuffersize += i;
|
|
if (disablepreparse)
|
|
demopreparsedbytes = demobuffersize;
|
|
else
|
|
demopreparsedbytes += demo_preparsedemo(demobuffer+demopreparsedbytes, demobuffersize-demopreparsedbytes);
|
|
}
|
|
else if (i < 0)
|
|
{ //0 means no data available yet
|
|
printf("VFS_READ failed\n");
|
|
endofdemo = true;
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
if (*readpos+len > demobuffersize)
|
|
{
|
|
len = demobuffersize;
|
|
return 0;
|
|
}
|
|
memcpy(data, demobuffer+*readpos, len);
|
|
*readpos += len;
|
|
return len;
|
|
}
|
|
|
|
void demo_flushbytes(int bytes)
|
|
{
|
|
if (bytes > demobuffersize)
|
|
Sys_Error("demo_flushbytes: flushed too much!\n");
|
|
memmove(demobuffer, demobuffer+bytes, demobuffersize - bytes);
|
|
demobuffersize -= bytes;
|
|
demopreparsedbytes -= bytes;
|
|
}
|
|
|
|
void demo_flushcache(void)
|
|
{
|
|
demobuffersize = 0;
|
|
demopreparsedbytes = 0;
|
|
|
|
//no errors yet
|
|
disablepreparse = false;
|
|
}
|
|
|
|
void demo_resetcache(int bytes, void *data)
|
|
{
|
|
endofdemo = false;
|
|
demo_flushcache();
|
|
|
|
demobuffersize = bytes;
|
|
demopreparsedbytes = 0;
|
|
memcpy(demobuffer, data, bytes);
|
|
|
|
//preparse it now
|
|
bytes = 0;
|
|
readdemobytes(&bytes, NULL, 0);
|
|
}
|
|
|
|
|
|
void CL_ProgressDemoTime(void)
|
|
{
|
|
extern cvar_t cl_demospeed;
|
|
|
|
if (cl.parsecount && Media_PausedDemo())
|
|
{ //console visible whilst democapturing
|
|
cls.netchan.last_received = realtime;
|
|
return;
|
|
}
|
|
|
|
if (cl_demospeed.value >= 0)
|
|
demtime += host_frametime*cl_demospeed.value;
|
|
else
|
|
demtime += host_frametime;
|
|
}
|
|
|
|
void CL_DemoJump_f(void)
|
|
{
|
|
float newtime;
|
|
char *s = Cmd_Argv(1);
|
|
char *colon = strchr(s, ':');
|
|
|
|
if (!cls.demoplayback)
|
|
return;
|
|
|
|
if (*s == '+')
|
|
{
|
|
if (colon)
|
|
{
|
|
colon++;
|
|
demtime += atoi(colon);
|
|
|
|
demtime += atoi(s)*60;
|
|
}
|
|
else
|
|
demtime += atoi(s);
|
|
}
|
|
else
|
|
{
|
|
if (colon)
|
|
{
|
|
colon++;
|
|
newtime = atoi(colon);
|
|
newtime += atoi(s)*60;
|
|
}
|
|
else
|
|
newtime = atoi(s);
|
|
|
|
if (newtime >= demtime)
|
|
demtime = newtime;
|
|
else
|
|
{
|
|
Con_Printf("Rewinding demo\n");
|
|
CL_PlayDemo(lastdemoname);
|
|
|
|
demtime = newtime;
|
|
}
|
|
}
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_GetDemoMessage
|
|
|
|
FIXME...
|
|
====================
|
|
*/
|
|
|
|
float olddemotime = 0;
|
|
float nextdemotime = 0;
|
|
qboolean CL_GetDemoMessage (void)
|
|
{
|
|
int r, i, j, tracknum;
|
|
float f;
|
|
float demotime;
|
|
qbyte c, msecsadded=0;
|
|
usercmd_t *pcmd;
|
|
q1usercmd_t q1cmd;
|
|
int demopos = 0;
|
|
int msglength;
|
|
|
|
if (endofdemo)
|
|
{
|
|
endofdemo = false;
|
|
CL_StopPlayback ();
|
|
return 0;
|
|
}
|
|
|
|
#ifdef NQPROT
|
|
if (cls.demoplayback == DPB_NETQUAKE
|
|
#ifdef Q2CLIENT
|
|
|| cls.demoplayback == DPB_QUAKE2
|
|
#endif
|
|
)
|
|
{ //read the nq demo
|
|
|
|
#ifdef Q2CLIENT
|
|
if (cls.demoplayback == DPB_QUAKE2 && (cls.netchan.last_received == realtime || cls.netchan.last_received > realtime-0.1))
|
|
return 0;
|
|
else
|
|
#endif
|
|
if (cls.demoplayback == DPB_NETQUAKE && cls.signon == 4/*SIGNONS*/)
|
|
{
|
|
if (!demtime)
|
|
{
|
|
cl.gametime = 0;
|
|
cl.gametimemark = demtime;
|
|
olddemotime = 0;
|
|
return 0;
|
|
}
|
|
if (demtime<= cl.gametime && cl.gametime)// > dem_lasttime+demtime)
|
|
{
|
|
if (demtime <= cl.gametime-1||cls.timedemo)
|
|
{
|
|
demtime = cl.gametime;
|
|
cls.netchan.last_received = realtime;
|
|
}
|
|
|
|
{
|
|
float f = (cl.gametime-demtime)/(cl.gametime-olddemotime);
|
|
float a1;
|
|
float a2;
|
|
|
|
for (i=0 ; i<3 ; i++)
|
|
{
|
|
a1 = cl.viewangles[2][i];
|
|
a2 = cl.viewangles[1][i];
|
|
if (a1 - a2 > 180)
|
|
a1 -= 360;
|
|
if (a1 - a2 < -180)
|
|
a1 += 360;
|
|
cl.simangles[0][i] = a2 + f * (a1 - a2);
|
|
}
|
|
VectorCopy(cl.simangles[0], cl.viewangles[0]);
|
|
}
|
|
return 0;
|
|
}
|
|
}
|
|
if (readdemobytes(&demopos, &msglength, 4) != 4)
|
|
{
|
|
return 0;
|
|
}
|
|
if (cls.demoplayback == DPB_NETQUAKE)
|
|
{
|
|
VectorCopy (cl.viewangles[1], cl.viewangles[2]);
|
|
for (i=0 ; i<3 ; i++)
|
|
{
|
|
readdemobytes(&demopos, &f, 4);
|
|
cl.simangles[0][i] = cl.viewangles[1][i] = LittleFloat (f);
|
|
}
|
|
VectorCopy (cl.viewangles[1], cl.viewangles[0]);
|
|
}
|
|
|
|
olddemotime = demtime;
|
|
|
|
msglength = LittleLong (msglength);
|
|
if (msglength > MAX_NQMSGLEN)
|
|
{
|
|
Con_Printf ("Demo message > MAX_MSGLEN");
|
|
CL_StopPlayback ();
|
|
return 0;
|
|
}
|
|
if (readdemobytes(&demopos, net_message.data, msglength) != msglength)
|
|
{
|
|
return 0;
|
|
}
|
|
demo_flushbytes(demopos);
|
|
net_message.cursize = msglength;
|
|
|
|
return 1;
|
|
}
|
|
#endif
|
|
|
|
//client is loading content, don't flood it with packets while its still got no map loaded
|
|
if (cl.sendprespawn)
|
|
return 0;
|
|
|
|
readnext:
|
|
// read the time from the packet
|
|
if (cls.demoplayback == DPB_MVD || cls.demoplayback == DPB_EZTV)
|
|
{
|
|
if (demtime < 0)
|
|
{
|
|
readdemobytes(&demopos, NULL, 0); //keep it feeding through
|
|
return 0;
|
|
}
|
|
if (olddemotime > demtime)
|
|
olddemotime = demtime;
|
|
if (demtime + 1.0 < olddemotime)
|
|
demtime = olddemotime - 1.0;
|
|
|
|
if (readdemobytes(&demopos, &msecsadded, sizeof(msecsadded)) != sizeof(msecsadded))
|
|
{
|
|
Con_DPrintf("Not enoug buffered\n");
|
|
demotime = olddemotime;
|
|
nextdemotime = demotime;
|
|
}
|
|
else
|
|
{
|
|
demotime = olddemotime + msecsadded*(1.0f/1000);
|
|
nextdemotime = demotime;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (readdemobytes(&demopos, &demotime, sizeof(demotime)) != sizeof(demotime))
|
|
{
|
|
Con_DPrintf("Not enough buffered\n");
|
|
olddemotime = demtime; //if we ran out of buffered demo, delay the demo parsing a little
|
|
return 0;
|
|
}
|
|
demotime = LittleFloat(demotime);
|
|
}
|
|
|
|
// decide if it is time to grab the next message
|
|
if (cls.timedemo)
|
|
{
|
|
if (cls.td_lastframe < 0)
|
|
cls.td_lastframe = demotime;
|
|
else if (demotime > cls.td_lastframe)
|
|
{
|
|
cls.td_lastframe = demotime;
|
|
return 0; // already read this frame's message
|
|
}
|
|
if (!cls.td_starttime && cls.state == ca_active)
|
|
{ //start the timer only once we are connected.
|
|
cls.td_starttime = Sys_DoubleTime();
|
|
cls.td_startframe = host_framecount;
|
|
}
|
|
demtime = demotime; // warp
|
|
}
|
|
else if (!cl.paused && cls.state >= ca_onserver)
|
|
{ // always grab until fully connected
|
|
if (demtime + 1.0 < demotime)
|
|
{
|
|
// too far back
|
|
demtime = demotime - 1.0;
|
|
return 0;
|
|
}
|
|
else if (demtime < demotime)
|
|
{
|
|
return 0; // don't need another message yet
|
|
}
|
|
}
|
|
else
|
|
demtime = demotime; // we're warping
|
|
|
|
if (cls.demoplayback == DPB_MVD || cls.demoplayback == DPB_EZTV)
|
|
{
|
|
if ((msecsadded || cls.netchan.incoming_sequence < 2) && olddemotime != demotime)
|
|
{
|
|
cls.netchan.incoming_sequence++;
|
|
cls.netchan.incoming_acknowledged++;
|
|
cls.netchan.frame_latency = 0;
|
|
cls.netchan.last_received = realtime; // just to happy timeout check
|
|
}
|
|
}
|
|
|
|
if (cls.state < ca_demostart)
|
|
Host_Error ("CL_GetDemoMessage: cls.state != ca_active");
|
|
|
|
// get the msg type
|
|
if (!readdemobytes (&demopos, &c, sizeof(c)))
|
|
{
|
|
Con_DPrintf("Not enough buffered\n");
|
|
olddemotime = demtime+1;
|
|
return 0;
|
|
}
|
|
// Con_Printf("demo packet %x\n", (int)c);
|
|
switch (c&7)
|
|
{
|
|
case dem_cmd :
|
|
/* if (cls.demoplayback == DPB_MVD)
|
|
{
|
|
unsigned short samps;
|
|
unsigned char bits;
|
|
unsigned char rateid;
|
|
unsigned char audio[8192];
|
|
|
|
if (readdemobytes (&demopos, &samps, 2) == 2)
|
|
{
|
|
if (readdemobytes (&demopos, &bits, 1) == 1)
|
|
{
|
|
if (samps > sizeof(audio))
|
|
{
|
|
Con_Printf("Corrupted/too large audio chunk\n");
|
|
CL_StopPlayback();
|
|
return 0;
|
|
}
|
|
if (readdemobytes (&demopos, &rateid, 1) == 1)
|
|
{
|
|
if (readdemobytes (&demopos, audio, samps) == samps)
|
|
{
|
|
FILE *f;
|
|
samps = samps/(bits/8);
|
|
f = fopen("c:/test.raw", "r+b");
|
|
if (f)
|
|
{
|
|
fseek(f, 0, SEEK_END);
|
|
fwrite(audio, samps, bits/8, f);
|
|
fclose(f);
|
|
}
|
|
S_RawAudio(0, audio, 11025, samps, 1, bits/8);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
else
|
|
{*/
|
|
// user sent input
|
|
i = cls.netchan.outgoing_sequence & UPDATE_MASK;
|
|
pcmd = &cl.frames[i].cmd[0];
|
|
r = readdemobytes (&demopos, &q1cmd, sizeof(q1cmd));
|
|
if (r != sizeof(q1cmd))
|
|
{
|
|
Con_DPrintf("Not enough buffered\n");
|
|
olddemotime = demtime+1;
|
|
CL_StopPlayback ();
|
|
return 0;
|
|
}
|
|
// byte order stuff
|
|
for (j = 0; j < 3; j++)
|
|
{
|
|
q1cmd.angles[j] = LittleFloat(q1cmd.angles[j]);
|
|
pcmd->angles[j] = ((int)(q1cmd.angles[j]*65536.0/360)&65535);
|
|
}
|
|
pcmd->forwardmove = q1cmd.forwardmove = LittleShort(q1cmd.forwardmove);
|
|
pcmd->sidemove = q1cmd.sidemove = LittleShort(q1cmd.sidemove);
|
|
pcmd->upmove = q1cmd.upmove = LittleShort(q1cmd.upmove);
|
|
pcmd->msec = q1cmd.msec;
|
|
pcmd->buttons = q1cmd.buttons;
|
|
|
|
|
|
cl.frames[i].senttime = demotime;
|
|
cl.frames[i].receivedtime = -1; // we haven't gotten a reply yet
|
|
cls.netchan.outgoing_sequence++;
|
|
for (i=0 ; i<3 ; i++)
|
|
{
|
|
readdemobytes (&demopos, &f, 4);
|
|
cl.viewangles[0][i] = LittleFloat (f);
|
|
}
|
|
/* }*/
|
|
break;
|
|
|
|
case dem_read:
|
|
readit:
|
|
// get the next message
|
|
if (readdemobytes (&demopos, &msglength, 4) != 4)
|
|
{
|
|
Con_DPrintf("Not enough buffered\n");
|
|
olddemotime = demtime+1;
|
|
return 0;
|
|
}
|
|
msglength = LittleLong (msglength);
|
|
//Con_Printf("read: %ld bytes\n", msglength);
|
|
if ((unsigned int)msglength > MAX_OVERALLMSGLEN)
|
|
{
|
|
Con_Printf ("Demo message > MAX_OVERALLMSGLEN\n");
|
|
CL_StopPlayback ();
|
|
return 0;
|
|
}
|
|
if (readdemobytes (&demopos, net_message.data, msglength) != msglength)
|
|
{
|
|
Con_DPrintf("Not enough buffered\n");
|
|
olddemotime = demtime+1;
|
|
return 0;
|
|
}
|
|
net_message.cursize = msglength;
|
|
|
|
if (cls.demoplayback == DPB_MVD || cls.demoplayback == DPB_EZTV)
|
|
{
|
|
switch(cls_lasttype)
|
|
{
|
|
case dem_multiple:
|
|
tracknum = spec_track[0];
|
|
if (!autocam[0])
|
|
tracknum = -1;
|
|
if (tracknum == -1 || !(cls_lastto & (1 << tracknum)))
|
|
{
|
|
olddemotime = demotime;
|
|
goto readnext;
|
|
}
|
|
break;
|
|
case dem_single:
|
|
tracknum = spec_track[0];
|
|
if (!autocam[0])
|
|
tracknum = -1;
|
|
if (tracknum == -1 || cls_lastto != tracknum)
|
|
{
|
|
olddemotime = demotime;
|
|
goto readnext;
|
|
}
|
|
break;
|
|
case dem_all:
|
|
if (c & ~dem_mask)
|
|
{
|
|
olddemotime = demotime;
|
|
goto readnext;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
|
|
case dem_set :
|
|
readdemobytes (&demopos, &i, 4);
|
|
cls.netchan.outgoing_sequence = LittleLong(i);
|
|
readdemobytes (&demopos, &i, 4);
|
|
cls.netchan.incoming_sequence = LittleLong(i);
|
|
|
|
if (cls.demoplayback == DPB_MVD || cls.demoplayback == DPB_EZTV)
|
|
cls.netchan.incoming_acknowledged = cls.netchan.incoming_sequence;
|
|
goto readnext;
|
|
|
|
case dem_multiple:
|
|
if (readdemobytes (&demopos, &i, sizeof(i)) != sizeof(i))
|
|
{
|
|
olddemotime = demtime;
|
|
return 0;
|
|
}
|
|
cls_lastto = LittleLong(i);
|
|
cls_lasttype = dem_multiple;
|
|
goto readit;
|
|
|
|
case dem_single:
|
|
cls_lastto = c >> 3;
|
|
cls_lasttype = dem_single;
|
|
goto readit;
|
|
|
|
case dem_stats:
|
|
cls_lastto = c >> 3;
|
|
cls_lasttype = dem_stats;
|
|
goto readit;
|
|
|
|
case dem_all:
|
|
cls_lastto = 0;
|
|
cls_lasttype = dem_all;
|
|
goto readit;
|
|
|
|
default :
|
|
Con_Printf("Corrupted demo.\n");
|
|
CL_StopPlayback ();
|
|
return 0;
|
|
}
|
|
demo_flushbytes(demopos);
|
|
|
|
olddemotime = demotime;
|
|
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_GetMessage
|
|
|
|
Handles recording and playback of demos, on top of NET_ code
|
|
====================
|
|
*/
|
|
qboolean CL_GetMessage (void)
|
|
{
|
|
if (cls.demoplayback != DPB_NONE)
|
|
return CL_GetDemoMessage ();
|
|
|
|
if (!NET_GetPacket (NS_CLIENT))
|
|
return false;
|
|
|
|
CL_WriteDemoMessage (&net_message);
|
|
|
|
return true;
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_Stop_f
|
|
|
|
stop recording a demo
|
|
====================
|
|
*/
|
|
void CL_Stop_f (void)
|
|
{
|
|
if (!cls.demorecording)
|
|
{
|
|
#ifndef CLIENTONLY
|
|
SV_MVDStop_f();
|
|
#endif
|
|
Con_Printf ("Not recording a demo.\n");
|
|
return;
|
|
}
|
|
|
|
// write a disconnect message to the demo file
|
|
SZ_Clear (&net_message);
|
|
MSG_WriteLong (&net_message, -1); // -1 sequence means out of band
|
|
MSG_WriteByte (&net_message, svc_disconnect);
|
|
MSG_WriteString (&net_message, "EndOfDemo");
|
|
CL_WriteDemoMessage (&net_message);
|
|
|
|
// finish up
|
|
VFS_CLOSE (cls.demofile);
|
|
cls.demofile = NULL;
|
|
cls.demorecording = false;
|
|
Con_Printf ("Completed demo\n");
|
|
|
|
FS_FlushFSHash();
|
|
}
|
|
|
|
|
|
/*
|
|
====================
|
|
CL_WriteDemoMessage
|
|
|
|
Dumps the current net message, prefixed by the length and view angles
|
|
====================
|
|
*/
|
|
void CL_WriteRecordDemoMessage (sizebuf_t *msg, int seq)
|
|
{
|
|
int len;
|
|
int i;
|
|
float fl;
|
|
qbyte c;
|
|
|
|
//Con_Printf("write: %ld bytes, %4.4f\n", msg->cursize, demtime);
|
|
|
|
if (!cls.demorecording)
|
|
return;
|
|
|
|
fl = LittleFloat((float)demtime);
|
|
VFS_WRITE (cls.demofile, &fl, sizeof(fl));
|
|
|
|
c = dem_read;
|
|
VFS_WRITE (cls.demofile, &c, sizeof(c));
|
|
|
|
len = LittleLong (msg->cursize + 8);
|
|
VFS_WRITE (cls.demofile, &len, 4);
|
|
|
|
i = LittleLong(seq);
|
|
VFS_WRITE (cls.demofile, &i, 4);
|
|
VFS_WRITE (cls.demofile, &i, 4);
|
|
|
|
VFS_WRITE (cls.demofile, msg->data, msg->cursize);
|
|
|
|
VFS_FLUSH (cls.demofile);
|
|
}
|
|
|
|
|
|
void CL_WriteSetDemoMessage (void)
|
|
{
|
|
int len;
|
|
float fl;
|
|
qbyte c;
|
|
|
|
//Con_Printf("write: %ld bytes, %4.4f\n", msg->cursize, demtime);
|
|
|
|
if (!cls.demorecording)
|
|
return;
|
|
|
|
fl = LittleFloat((float)demtime);
|
|
VFS_WRITE (cls.demofile, &fl, sizeof(fl));
|
|
|
|
c = dem_set;
|
|
VFS_WRITE (cls.demofile, &c, sizeof(c));
|
|
|
|
len = LittleLong(cls.netchan.outgoing_sequence);
|
|
VFS_WRITE (cls.demofile, &len, 4);
|
|
len = LittleLong(cls.netchan.incoming_sequence);
|
|
VFS_WRITE (cls.demofile, &len, 4);
|
|
|
|
VFS_FLUSH (cls.demofile);
|
|
}
|
|
|
|
|
|
|
|
|
|
/*
|
|
====================
|
|
CL_Record_f
|
|
|
|
record <demoname> <server>
|
|
====================
|
|
*/
|
|
void CL_Record_f (void)
|
|
{
|
|
int c;
|
|
char name[MAX_OSPATH];
|
|
int namelen = sizeof(name);
|
|
sizebuf_t buf;
|
|
char buf_data[MAX_QWMSGLEN];
|
|
int n, i, j;
|
|
char *s, *p, *fname;
|
|
entity_t *ent;
|
|
entity_state_t *es;
|
|
player_info_t *player;
|
|
extern char gamedirfile[];
|
|
int seq = 1;
|
|
|
|
c = Cmd_Argc();
|
|
if (c > 2)
|
|
{
|
|
Con_Printf ("record <demoname>\n");
|
|
return;
|
|
}
|
|
|
|
if (cls.state != ca_active)
|
|
{
|
|
Con_Printf ("You must be connected to record.\n");
|
|
return;
|
|
}
|
|
|
|
if (cls.demorecording)
|
|
CL_Stop_f();
|
|
|
|
namelen -= strlen(com_gamedir)+1;
|
|
if (c == 2) //user supplied a name
|
|
{
|
|
fname = Cmd_Argv(1);
|
|
}
|
|
else
|
|
{ //automagically generate a name
|
|
if (cl.spectator)
|
|
{ // FIXME: if tracking a player, use his name
|
|
fname = va ("spec_%s_%s",
|
|
TP_PlayerName(),
|
|
TP_MapName());
|
|
}
|
|
else
|
|
{ // guess game type and write demo name
|
|
i = TP_CountPlayers();
|
|
if (cl.teamplay && i >= 3)
|
|
{ // Teamplay
|
|
fname = va ("%s_%s_vs_%s_%s",
|
|
TP_PlayerName(),
|
|
TP_PlayerTeam(),
|
|
TP_EnemyTeam(),
|
|
TP_MapName());
|
|
}
|
|
else
|
|
{
|
|
if (i == 2)
|
|
{ // Duel
|
|
fname = va ("%s_vs_%s_%s",
|
|
TP_PlayerName(),
|
|
TP_EnemyName(),
|
|
TP_MapName());
|
|
}
|
|
else if (i > 2)
|
|
{ // FFA
|
|
fname = va ("%s_ffa_%s",
|
|
TP_PlayerName(),
|
|
TP_MapName());
|
|
}
|
|
else
|
|
{ // one player
|
|
fname = va ("%s_%s",
|
|
TP_PlayerName(),
|
|
TP_MapName());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
while((p = strstr(fname, "..")))
|
|
{
|
|
p[0] = '_';
|
|
p[1] = '_';
|
|
}
|
|
|
|
// Make sure the filename doesn't contain illegal characters
|
|
for (p=fname ; *p ; p++)
|
|
{
|
|
char c;
|
|
*p &= 0x7F; // strip high bit
|
|
c = *p;
|
|
if (c<=' ' || c=='?' || c=='*' || (c!=2&&(c=='\\' || c=='/')) || c==':'
|
|
|| c=='<' || c=='>' || c=='"' || c=='.')
|
|
*p = '_';
|
|
}
|
|
strncpy(name, fname, sizeof(name)-1-8);
|
|
name[sizeof(name)-1-8] = '\0';
|
|
|
|
//make a unique name (unless the user specified it).
|
|
strcat (name, ".qwd"); //we have the space
|
|
if (c != 2)
|
|
{
|
|
vfsfile_t *f;
|
|
|
|
f = FS_OpenVFS (name, "rb", FS_GAME);
|
|
if (f)
|
|
{
|
|
COM_StripExtension(name, name, sizeof(name));
|
|
p = name + strlen(name);
|
|
strcat(p, "_XX.qwd");
|
|
p++;
|
|
i = 0;
|
|
do
|
|
{
|
|
VFS_CLOSE (f);
|
|
p[0] = i%100 + '0';
|
|
p[1] = i%10 + '0';
|
|
f = FS_OpenVFS (name, "rb", FS_GAME);
|
|
i++;
|
|
} while (f && i < 100);
|
|
}
|
|
}
|
|
|
|
//
|
|
// open the demo file
|
|
//
|
|
cls.demofile = FS_OpenVFS (name, "wb", FS_GAME);
|
|
if (!cls.demofile)
|
|
{
|
|
Con_Printf ("ERROR: couldn't open.\n");
|
|
return;
|
|
}
|
|
|
|
Con_Printf ("recording to %s.\n", name);
|
|
cls.demorecording = true;
|
|
|
|
/*-------------------------------------------------*/
|
|
|
|
// serverdata
|
|
// send the info about the new client to all connected clients
|
|
memset(&buf, 0, sizeof(buf));
|
|
buf.data = buf_data;
|
|
buf.maxsize = sizeof(buf_data);
|
|
|
|
// send the serverdata
|
|
MSG_WriteByte (&buf, svc_serverdata);
|
|
#ifdef PROTOCOL_VERSION_FTE
|
|
if (cls.fteprotocolextensions) //maintain demo compatability
|
|
{
|
|
MSG_WriteLong (&buf, PROTOCOL_VERSION_FTE);
|
|
MSG_WriteLong (&buf, cls.fteprotocolextensions);
|
|
}
|
|
#endif
|
|
MSG_WriteLong (&buf, PROTOCOL_VERSION_QW);
|
|
MSG_WriteLong (&buf, cl.servercount);
|
|
MSG_WriteString (&buf, gamedirfile);
|
|
|
|
for (i = 0; i < cl.splitclients; i++)
|
|
{
|
|
if (cl.spectator)
|
|
MSG_WriteByte (&buf, cl.playernum[i] | 128);
|
|
else
|
|
MSG_WriteByte (&buf, cl.playernum[i]);
|
|
}
|
|
if (cls.fteprotocolextensions & PEXT_SPLITSCREEN)
|
|
MSG_WriteByte (&buf, 128);
|
|
|
|
// send full levelname
|
|
MSG_WriteString (&buf, cl.levelname);
|
|
|
|
// send the movevars
|
|
MSG_WriteFloat(&buf, movevars.gravity);
|
|
MSG_WriteFloat(&buf, movevars.stopspeed);
|
|
MSG_WriteFloat(&buf, movevars.maxspeed);
|
|
MSG_WriteFloat(&buf, movevars.spectatormaxspeed);
|
|
MSG_WriteFloat(&buf, movevars.accelerate);
|
|
MSG_WriteFloat(&buf, movevars.airaccelerate);
|
|
MSG_WriteFloat(&buf, movevars.wateraccelerate);
|
|
MSG_WriteFloat(&buf, movevars.friction);
|
|
MSG_WriteFloat(&buf, movevars.waterfriction);
|
|
MSG_WriteFloat(&buf, movevars.entgravity);
|
|
|
|
// send server info string
|
|
MSG_WriteByte (&buf, svc_stufftext);
|
|
MSG_WriteString (&buf, va("fullserverinfo \"%s\"\n", cl.serverinfo) );
|
|
|
|
// send music (delayed)
|
|
MSG_WriteByte (&buf, svc_cdtrack);
|
|
MSG_WriteByte (&buf, 0); // none in demos
|
|
|
|
#ifdef PEXT_SETVIEW
|
|
if (cl.viewentity[0]) //tell the player if we have a different view entity
|
|
{
|
|
MSG_WriteByte (&buf, svc_setview);
|
|
MSG_WriteByte (&buf, cl.viewentity[0]);
|
|
}
|
|
#endif
|
|
// flush packet
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
|
|
// soundlist
|
|
MSG_WriteByte (&buf, svc_soundlist);
|
|
MSG_WriteByte (&buf, 0);
|
|
|
|
n = 0;
|
|
s = cl.sound_name[n+1];
|
|
while (*s)
|
|
{
|
|
MSG_WriteString (&buf, s);
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
MSG_WriteByte (&buf, 0);
|
|
MSG_WriteByte (&buf, n);
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
MSG_WriteByte (&buf, svc_soundlist);
|
|
MSG_WriteByte (&buf, n + 1);
|
|
}
|
|
n++;
|
|
s = cl.sound_name[n+1];
|
|
}
|
|
if (buf.cursize)
|
|
{
|
|
MSG_WriteByte (&buf, 0);
|
|
MSG_WriteByte (&buf, 0);
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
|
|
// modellist
|
|
MSG_WriteByte (&buf, svc_modellist);
|
|
MSG_WriteByte (&buf, 0);
|
|
|
|
n = 0;
|
|
s = cl.model_name[n+1];
|
|
while (*s)
|
|
{
|
|
MSG_WriteString (&buf, s);
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
MSG_WriteByte (&buf, 0);
|
|
MSG_WriteByte (&buf, n);
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
MSG_WriteByte (&buf, svc_modellist);
|
|
MSG_WriteByte (&buf, n + 1);
|
|
}
|
|
n++;
|
|
s = cl.model_name[n+1];
|
|
}
|
|
if (buf.cursize)
|
|
{
|
|
MSG_WriteByte (&buf, 0);
|
|
MSG_WriteByte (&buf, 0);
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
|
|
// spawnstatic
|
|
|
|
for (i = 0; i < cl.num_statics; i++)
|
|
{
|
|
ent = cl_static_entities + i;
|
|
|
|
MSG_WriteByte (&buf, svc_spawnstatic);
|
|
|
|
for (j = 1; j < MAX_MODELS; j++)
|
|
if (ent->model == cl.model_precache[j])
|
|
break;
|
|
if (j == MAX_MODELS)
|
|
MSG_WriteByte (&buf, 0);
|
|
else
|
|
MSG_WriteByte (&buf, j);
|
|
|
|
MSG_WriteByte (&buf, ent->framestate.g[FS_REG].frame[0]);
|
|
MSG_WriteByte (&buf, 0);
|
|
MSG_WriteByte (&buf, ent->skinnum);
|
|
for (j=0 ; j<3 ; j++)
|
|
{
|
|
MSG_WriteCoord (&buf, ent->origin[j]);
|
|
MSG_WriteAngle (&buf, ent->angles[j]);
|
|
}
|
|
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
}
|
|
|
|
// spawnstaticsound
|
|
// static sounds are skipped in demos, life is hard
|
|
|
|
// baselines
|
|
|
|
for (i = 0; i < cl_baselines_count; i++)
|
|
{
|
|
es = cl_baselines + i;
|
|
|
|
if (memcmp(es, &nullentitystate, sizeof(nullentitystate)))
|
|
{
|
|
MSG_WriteByte (&buf,svc_spawnbaseline);
|
|
MSG_WriteShort (&buf, i);
|
|
|
|
MSG_WriteByte (&buf, es->modelindex);
|
|
MSG_WriteByte (&buf, es->frame);
|
|
MSG_WriteByte (&buf, es->colormap);
|
|
MSG_WriteByte (&buf, es->skinnum);
|
|
for (j=0 ; j<3 ; j++)
|
|
{
|
|
MSG_WriteCoord(&buf, es->origin[j]);
|
|
MSG_WriteAngle(&buf, es->angles[j]);
|
|
}
|
|
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
}
|
|
}
|
|
|
|
MSG_WriteByte (&buf, svc_stufftext);
|
|
MSG_WriteString (&buf, va("cmd spawn %i\n", cl.servercount) );
|
|
|
|
if (buf.cursize)
|
|
{
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
|
|
// send current status of all other players
|
|
|
|
for (i = 0; i < MAX_CLIENTS; i++)
|
|
{
|
|
player = cl.players + i;
|
|
|
|
MSG_WriteByte (&buf, svc_updatefrags);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteShort (&buf, player->frags);
|
|
|
|
MSG_WriteByte (&buf, svc_updateping);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteShort (&buf, player->ping);
|
|
|
|
MSG_WriteByte (&buf, svc_updatepl);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteByte (&buf, player->pl);
|
|
|
|
MSG_WriteByte (&buf, svc_updateentertime);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteFloat (&buf, player->entertime);
|
|
|
|
MSG_WriteByte (&buf, svc_updateuserinfo);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteLong (&buf, player->userid);
|
|
MSG_WriteString (&buf, player->userinfo);
|
|
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
}
|
|
|
|
// send all current light styles
|
|
for (i=0 ; i<MAX_LIGHTSTYLES ; i++)
|
|
{
|
|
if (i >= MAX_STANDARDLIGHTSTYLES)
|
|
if (!*cl_lightstyle[i].map)
|
|
continue;
|
|
|
|
MSG_WriteByte (&buf, svc_lightstyle);
|
|
MSG_WriteByte (&buf, (char)i);
|
|
MSG_WriteString (&buf, cl_lightstyle[i].map);
|
|
}
|
|
|
|
for (i = ((cls.fteprotocolextensions&PEXT_HEXEN2)?MAX_QW_STATS:MAX_CL_STATS); i >= 0; i--)
|
|
{
|
|
if (!cl.stats[0][i])
|
|
continue;
|
|
MSG_WriteByte (&buf, svc_updatestatlong);
|
|
MSG_WriteByte (&buf, i);
|
|
MSG_WriteLong (&buf, cl.stats[0][i]);
|
|
if (buf.cursize > MAX_QWMSGLEN/2)
|
|
{
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
SZ_Clear (&buf);
|
|
}
|
|
}
|
|
|
|
// get the client to check and download skins
|
|
// when that is completed, a begin command will be issued
|
|
MSG_WriteByte (&buf, svc_stufftext);
|
|
MSG_WriteString (&buf, va("skins\n") );
|
|
|
|
CL_WriteRecordDemoMessage (&buf, seq++);
|
|
|
|
CL_WriteSetDemoMessage();
|
|
|
|
// done
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_ReRecord_f
|
|
|
|
record <demoname>
|
|
====================
|
|
*/
|
|
void CL_ReRecord_f (void)
|
|
{
|
|
int c;
|
|
char name[MAX_OSPATH];
|
|
char *s;
|
|
|
|
c = Cmd_Argc();
|
|
if (c != 2)
|
|
{
|
|
Con_Printf ("rerecord <demoname>\n");
|
|
return;
|
|
}
|
|
|
|
if (!*cls.servername) {
|
|
Con_Printf("No server to reconnect to...\n");
|
|
return;
|
|
}
|
|
|
|
if (cls.demorecording)
|
|
CL_Stop_f();
|
|
|
|
s = Cmd_Argv(1);
|
|
if (strstr(s, ".."))
|
|
{
|
|
Con_Printf ("Relative paths not allowed.\n");
|
|
return;
|
|
}
|
|
|
|
sprintf (name, "%s", s);
|
|
|
|
//
|
|
// open the demo file
|
|
//
|
|
COM_DefaultExtension (name, ".qwd", sizeof(name));
|
|
|
|
cls.demofile = FS_OpenVFS (name, "wb", FS_GAME);
|
|
if (!cls.demofile)
|
|
{
|
|
Con_Printf ("ERROR: couldn't open.\n");
|
|
return;
|
|
}
|
|
|
|
Con_Printf ("recording to %s.\n", name);
|
|
cls.demorecording = true;
|
|
|
|
CL_Disconnect();
|
|
CL_BeginServerReconnect();
|
|
}
|
|
|
|
#ifdef WEBCLIENT
|
|
void CL_PlayDownloadedDemo(char *name, qboolean success)
|
|
{
|
|
if (success == false)
|
|
Con_Printf("Failed to download %s\n", name);
|
|
else
|
|
{
|
|
FS_FlushFSHash();
|
|
Cbuf_AddText(va("playdemo %s\n", name), RESTRICT_LOCAL);
|
|
}
|
|
}
|
|
#endif
|
|
|
|
/*
|
|
====================
|
|
CL_PlayDemo_f
|
|
|
|
play [demoname]
|
|
====================
|
|
*/
|
|
void CL_PlayDemo_f (void)
|
|
{
|
|
if (Cmd_Argc() != 2)
|
|
{
|
|
Con_Printf ("playdemo <demoname> : plays a demo\n");
|
|
return;
|
|
}
|
|
|
|
#ifdef WEBCLIENT
|
|
if (!strncmp(Cmd_Argv(1), "ftp://", 6) || !strncmp(Cmd_Argv(1), "http://", 7))
|
|
{
|
|
if (Cmd_ExecLevel == RESTRICT_LOCAL)
|
|
HTTP_CL_Get(Cmd_Argv(1), COM_SkipPath(Cmd_Argv(1)), CL_PlayDownloadedDemo);
|
|
return;
|
|
}
|
|
#endif
|
|
|
|
CL_PlayDemo(Cmd_Argv(1));
|
|
}
|
|
|
|
void CL_PlayDemo(char *demoname)
|
|
{
|
|
char name[256];
|
|
int ft, neg;
|
|
int len;
|
|
char type;
|
|
char chr;
|
|
int protocol;
|
|
int start;
|
|
|
|
//
|
|
// disconnect from server
|
|
//
|
|
CL_Disconnect_f ();
|
|
|
|
demo_flushcache();
|
|
//
|
|
// open the demo file
|
|
//
|
|
Q_strncpyz (name, demoname, sizeof(name));
|
|
COM_DefaultExtension (name, ".qwd", sizeof(name));
|
|
cls.demofile = FS_OpenVFS(name, "rb", FS_GAME);
|
|
if (!cls.demofile)
|
|
{
|
|
Q_strncpyz (name, demoname, sizeof(name));
|
|
COM_DefaultExtension (name, ".dem", sizeof(name));
|
|
cls.demofile = FS_OpenVFS(name, "rb", FS_GAME);
|
|
}
|
|
if (!cls.demofile)
|
|
{
|
|
Q_strncpyz (name, demoname, sizeof(name));
|
|
COM_DefaultExtension (name, ".mvd", sizeof(name));
|
|
cls.demofile = FS_OpenVFS(name, "rb", FS_GAME);
|
|
}
|
|
if (!cls.demofile)
|
|
{
|
|
Con_Printf ("ERROR: couldn't open \"%s\".\n", demoname);
|
|
cls.demonum = -1; // stop demo loop
|
|
return;
|
|
}
|
|
Q_strncpyz (lastdemoname, demoname, sizeof(lastdemoname));
|
|
Con_Printf ("Playing demo from %s.\n", name);
|
|
|
|
if (!VFS_GETLEN (cls.demofile))
|
|
{
|
|
VFS_CLOSE(cls.demofile);
|
|
cls.demofile = NULL;
|
|
Con_Printf ("demo \"%s\" is empty.\n", demoname);
|
|
cls.demonum = -1; // stop demo loop
|
|
return;
|
|
}
|
|
|
|
if (!Q_strcasecmp(name + strlen(name) - 3, "mvd") ||
|
|
!Q_strcasecmp(name + strlen(name) - 6, "mvd.gz"))
|
|
{
|
|
cls.demoplayback = DPB_MVD;
|
|
cls.findtrack = true;
|
|
}
|
|
else
|
|
cls.demoplayback = DPB_QUAKEWORLD;
|
|
|
|
cls.state = ca_demostart;
|
|
net_message.packing = SZ_RAWBYTES;
|
|
Netchan_Setup (NS_CLIENT, &cls.netchan, net_from, 0);
|
|
demtime = 0;
|
|
cl.gametime = 0;
|
|
cl.gametimemark = demtime;
|
|
|
|
cls.netchan.last_received=demtime;
|
|
|
|
|
|
start = VFS_TELL(cls.demofile);
|
|
VFS_READ(cls.demofile, &len, sizeof(len));
|
|
VFS_READ(cls.demofile, &type, sizeof(type));
|
|
VFS_READ(cls.demofile, &protocol, sizeof(protocol));
|
|
VFS_SEEK(cls.demofile, start);
|
|
if (len > 5 && type == svcq2_serverdata && protocol == PROTOCOL_VERSION_Q2)
|
|
{
|
|
#ifdef Q2CLIENT
|
|
cls.demoplayback = DPB_QUAKE2;
|
|
cls.protocol = CP_QUAKE2;
|
|
#else
|
|
Con_Printf ("ERROR: cannot play Quake2 demos.\n");
|
|
CL_StopPlayback();
|
|
return;
|
|
#endif
|
|
}
|
|
else
|
|
{
|
|
cls.protocol = CP_QUAKEWORLD;
|
|
|
|
ft = 0; //work out if the first line is a int for the track number.
|
|
while ((VFS_READ(cls.demofile, &chr, 1)==1) && (chr != '\n'))
|
|
{
|
|
if (chr == '-')
|
|
neg = true;
|
|
else if (chr < '0' || chr > '9')
|
|
break;
|
|
else
|
|
ft = ft * 10 + ((int)chr - '0');
|
|
}
|
|
if (chr == '\n')
|
|
{
|
|
#ifndef NQPROT
|
|
Con_Printf ("ERROR: cannot play NQ demos.\n");
|
|
CL_StopPlayback();
|
|
return;
|
|
#else
|
|
cls.protocol = CP_NETQUAKE;
|
|
cls.demoplayback = DPB_NETQUAKE; //nq demos. :o)
|
|
#endif
|
|
}
|
|
else
|
|
VFS_SEEK(cls.demofile, start); //quakeworld demo, so go back to start.
|
|
}
|
|
|
|
TP_ExecTrigger ("f_demostart");
|
|
}
|
|
|
|
void CL_QTVPlay (vfsfile_t *newf, qboolean iseztv)
|
|
{
|
|
CL_Disconnect_f ();
|
|
|
|
cls.demofile = newf;
|
|
|
|
demo_flushcache(); //just in case
|
|
|
|
if (iseztv)
|
|
cls.demoplayback = DPB_EZTV;
|
|
else
|
|
cls.demoplayback = DPB_MVD;
|
|
|
|
cls.findtrack = true;
|
|
|
|
cls.state = ca_demostart;
|
|
net_message.packing = SZ_RAWBYTES;
|
|
Netchan_Setup (NS_CLIENT, &cls.netchan, net_from, 0);
|
|
demtime = -BUFFERTIME;
|
|
cl.gametime = -BUFFERTIME;
|
|
cl.gametimemark = demtime;
|
|
if (demtime < -0.5)
|
|
Con_Printf("Buffering for %i seconds\n", (int)-demtime);
|
|
|
|
cls.netchan.last_received=realtime;
|
|
|
|
cls.protocol = CP_QUAKEWORLD;
|
|
TP_ExecTrigger ("f_demostart");
|
|
}
|
|
|
|
void CL_Demo_ClientCommand(char *commandtext)
|
|
{
|
|
unsigned char b = 1;
|
|
unsigned short len = LittleShort((unsigned short)(strlen(commandtext) + 4));
|
|
#ifndef _MSC_VER
|
|
#warning "this needs buffering safely"
|
|
#endif
|
|
VFS_WRITE(cls.demofile, &len, sizeof(len));
|
|
VFS_WRITE(cls.demofile, &b, sizeof(b));
|
|
VFS_WRITE(cls.demofile, commandtext, strlen(commandtext)+1);
|
|
}
|
|
|
|
char qtvhostname[1024];
|
|
char qtvrequestbuffer[4096];
|
|
int qtvrequestsize;
|
|
vfsfile_t *qtvrequest;
|
|
|
|
void CL_QTVPoll (void)
|
|
{
|
|
char *s, *e, *colon;
|
|
char *tail = NULL;
|
|
int len;
|
|
qboolean streamavailable = false;
|
|
qboolean saidheader = false;
|
|
menu_t *sourcesmenu = NULL;
|
|
int sourcenum = 0;
|
|
|
|
int streamid;
|
|
int numplayers = 0;
|
|
int numviewers = 0;
|
|
qboolean init_numplayers = false;
|
|
qboolean init_numviewers = false;
|
|
qboolean iseztv = false;
|
|
char srchost[256];
|
|
|
|
|
|
if (!qtvrequest)
|
|
return;
|
|
|
|
for(;;)
|
|
{
|
|
len = VFS_READ(qtvrequest, qtvrequestbuffer+qtvrequestsize, (sizeof(qtvrequestbuffer) - qtvrequestsize -1 > 0)?1:0);
|
|
if (len <= 0)
|
|
break;
|
|
qtvrequestsize += len;
|
|
}
|
|
qtvrequestbuffer[qtvrequestsize] = '\0';
|
|
if (!qtvrequestsize)
|
|
return;
|
|
|
|
//make sure it's a compleate chunk.
|
|
for (s = qtvrequestbuffer; *s; s++)
|
|
{
|
|
if (s[0] == '\n' && s[1] == '\n')
|
|
{
|
|
tail = s+2;
|
|
break;
|
|
}
|
|
if (s[0] == '\r' && s[1] == '\n' && s[2] == '\r' && s[3] == '\n')
|
|
{
|
|
tail = s+4;
|
|
break;
|
|
}
|
|
if (s[0] == '\r' && s[1] == '\n' && s[2] == '\n')
|
|
{
|
|
tail = s+3;
|
|
break;
|
|
}
|
|
if (s[0] == '\n' && s[1] == '\r' && s[2] == '\n')
|
|
{
|
|
tail = s+3;
|
|
break;
|
|
}
|
|
}
|
|
if (!tail)
|
|
return;
|
|
s[1] = '\0'; //make sure its null terminated before the data payload
|
|
s = qtvrequestbuffer;
|
|
for (e = s; *e; )
|
|
{
|
|
if (*e == '\r')
|
|
*e = '\0';
|
|
else if (*e == '\n')
|
|
{
|
|
*e = '\0';
|
|
colon = strchr(s, ':');
|
|
if (colon)
|
|
*colon++ = '\0';
|
|
else
|
|
colon = "";
|
|
|
|
if (!strcmp(s, "PERROR"))
|
|
{ //printable error
|
|
Con_Printf("QTV Error:\n%s\n", colon);
|
|
}
|
|
else if (!strcmp(s, "PRINT"))
|
|
{ //printable error
|
|
Con_Printf("QTV:\n%s\n", colon);
|
|
}
|
|
else if (!strcmp(s, "TERROR"))
|
|
{ //printable error
|
|
Con_Printf("QTV Error:\n%s\n", colon);
|
|
}
|
|
else if (!strcmp(s, "ADEMO"))
|
|
{ //printable error
|
|
Con_Printf("Demo%s is available\n", colon);
|
|
}
|
|
|
|
//generic sourcelist responce
|
|
else if (!strcmp(s, "ASOURCE"))
|
|
{ //printable source
|
|
if (!saidheader)
|
|
{
|
|
saidheader=true;
|
|
Con_Printf("Available Sources:\n");
|
|
}
|
|
Con_Printf("%s\n", colon);
|
|
//we're too lazy to even try and parse this
|
|
}
|
|
|
|
else if (!strcmp(s, "BEGIN"))
|
|
{
|
|
if (*colon)
|
|
Con_Printf("streaming \"%s\" from qtv\n", colon);
|
|
else
|
|
Con_Printf("qtv connection established\n", colon);
|
|
streamavailable = true;
|
|
}
|
|
|
|
//eztv extensions to v1.0
|
|
else if (!strcmp(s, "QTV_EZQUAKE_EXT"))
|
|
{
|
|
iseztv = true;
|
|
Con_Printf("Warning: eztv extensions %s\n", colon);
|
|
}
|
|
|
|
//v1.1 sourcelist response includes SRCSRV, SRCHOST, SRCPLYRS, SRCVIEWS, SRCID
|
|
else if (!strcmp(s, "SRCSRV"))
|
|
{
|
|
//the proxy's source string (beware of file:blah without file:blah@blah)
|
|
}
|
|
else if (!strcmp(s, "SRCHOST"))
|
|
{
|
|
//the hostname from the server the stream came from
|
|
Q_strncpyz(srchost, colon, sizeof(srchost));
|
|
}
|
|
else if (!strcmp(s, "SRCPLYRS"))
|
|
{
|
|
//number of active players actually playing on that stream
|
|
numplayers = atoi(colon);
|
|
init_numplayers = true;
|
|
}
|
|
else if (!strcmp(s, "SRCVIEWS"))
|
|
{
|
|
//number of people watching this stream on the proxy itself
|
|
numviewers = atoi(colon);
|
|
init_numviewers = true;
|
|
}
|
|
else if (!strcmp(s, "SRCID"))
|
|
{
|
|
streamid = atoi(colon);
|
|
|
|
//now put it on a menu
|
|
if (!sourcesmenu)
|
|
{
|
|
m_state = m_complex;
|
|
key_dest = key_menu;
|
|
sourcesmenu = M_CreateMenu(0);
|
|
|
|
MC_AddPicture(sourcesmenu, 16, 4, "gfx/qplaque.lmp");
|
|
MC_AddCenterPicture(sourcesmenu, 4, "gfx/p_option.lmp");
|
|
}
|
|
if (init_numplayers == true && init_numviewers == true)
|
|
MC_AddConsoleCommand(sourcesmenu, 42, (sourcenum++)*8 + 32, va("%s (p%i, v%i)", srchost, numplayers, numviewers), va("qtvplay %i@%s\n", streamid, qtvhostname));
|
|
//else
|
|
// FIXME: add error message here
|
|
}
|
|
//end of sourcelist entry
|
|
|
|
//from e to s, we have a line
|
|
s = e+1;
|
|
}
|
|
e++;
|
|
}
|
|
|
|
if (streamavailable)
|
|
{
|
|
CL_QTVPlay(qtvrequest, iseztv);
|
|
qtvrequest = NULL;
|
|
demo_resetcache(qtvrequestsize - (tail-qtvrequestbuffer), tail);
|
|
return;
|
|
}
|
|
|
|
VFS_CLOSE(qtvrequest);
|
|
qtvrequest = NULL;
|
|
qtvrequestsize = 0;
|
|
}
|
|
|
|
char *strchrrev(char *str, char chr)
|
|
{
|
|
char *firstchar = str;
|
|
for (str = str + strlen(str)-1; str>=firstchar; str--)
|
|
if (*str == chr)
|
|
return str;
|
|
|
|
return NULL;
|
|
}
|
|
|
|
void CL_QTVPlay_f (void)
|
|
{
|
|
qboolean raw=0;
|
|
char *connrequest;
|
|
vfsfile_t *newf;
|
|
char *host;
|
|
|
|
if (Cmd_Argc() < 2)
|
|
{
|
|
Con_Printf("Usage: qtvplay [stream@]hostname[:port] [password]\n");
|
|
return;
|
|
}
|
|
|
|
connrequest = Cmd_Argv(1);
|
|
|
|
if (*connrequest == '#')
|
|
{
|
|
char buffer[1024];
|
|
char *s;
|
|
FILE *f;
|
|
f = fopen(connrequest+1, "rt");
|
|
if (!f)
|
|
{
|
|
Con_Printf("Couldn't open QTV file: %s\n", connrequest+1);
|
|
return;
|
|
}
|
|
while (!feof(f))
|
|
{
|
|
fgets(buffer, sizeof(buffer)-1, f);
|
|
if (!strncmp(buffer, "Stream=", 7) || !strncmp(buffer, "Stream:", 7))
|
|
{
|
|
for (s = buffer + strlen(buffer)-1; s >= buffer; s--)
|
|
{
|
|
if (*s == '\r' || *s == '\n' || *s == ';')
|
|
*s = 0;
|
|
else
|
|
break;
|
|
}
|
|
s = buffer+7;
|
|
while(*s && *s <= ' ')
|
|
s++;
|
|
Cbuf_AddText(va("qtvplay \"%s\"\n", s), Cmd_ExecLevel);
|
|
break;
|
|
}
|
|
if (!strncmp(buffer, "Connect=", 8) || !strncmp(buffer, "Connect:", 8))
|
|
{
|
|
for (s = buffer + strlen(buffer)-1; s >= buffer; s--)
|
|
{
|
|
if (*s == '\r' || *s == '\n' || *s == ';')
|
|
*s = 0;
|
|
else
|
|
break;
|
|
}
|
|
s = buffer+8;
|
|
while(*s && *s <= ' ')
|
|
s++;
|
|
Cbuf_AddText(va("connect \"%s\"\n", s), Cmd_ExecLevel);
|
|
break;
|
|
}
|
|
if (!strncmp(buffer, "Join=", 5) || !strncmp(buffer, "Join:", 5))
|
|
{
|
|
for (s = buffer + strlen(buffer)-1; s >= buffer; s--)
|
|
{
|
|
if (*s == '\r' || *s == '\n' || *s == ';')
|
|
*s = 0;
|
|
else
|
|
break;
|
|
}
|
|
s = buffer+5;
|
|
while(*s && *s <= ' ')
|
|
s++;
|
|
Cbuf_AddText(va("join \"%s\"\n", s), Cmd_ExecLevel);
|
|
break;
|
|
}
|
|
if (!strncmp(buffer, "Observe=", 8) || !strncmp(buffer, "Observe:", 8))
|
|
{
|
|
for (s = buffer + strlen(buffer)-1; s >= buffer; s--)
|
|
{
|
|
if (*s == '\r' || *s == '\n' || *s == ';')
|
|
*s = 0;
|
|
else
|
|
break;
|
|
}
|
|
s = buffer+8;
|
|
while(*s && *s <= ' ')
|
|
s++;
|
|
Cbuf_AddText(va("observe \"%s\"\n", s), Cmd_ExecLevel);
|
|
break;
|
|
}
|
|
}
|
|
fclose(f);
|
|
return;
|
|
}
|
|
|
|
host = connrequest;
|
|
|
|
connrequest = strchrrev(connrequest, '@');
|
|
if (connrequest)
|
|
host = connrequest+1;
|
|
Q_strncpyz(qtvhostname, host, sizeof(qtvhostname));
|
|
newf = FS_OpenTCP(qtvhostname);
|
|
|
|
if (!newf)
|
|
{
|
|
Con_Printf("Couldn't connect to proxy\n");
|
|
return;
|
|
}
|
|
|
|
host = Cmd_Argv(1);
|
|
if (connrequest)
|
|
*connrequest = '\0';
|
|
else
|
|
host = NULL;
|
|
|
|
if (qtvcl_forceversion1.value)
|
|
{
|
|
connrequest = "QTV\n"
|
|
"VERSION: 1.0\n";
|
|
}
|
|
else
|
|
{
|
|
connrequest = "QTV\n"
|
|
"VERSION: 1.1\n";
|
|
}
|
|
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
|
|
if (qtvcl_eztvextensions.value)
|
|
{
|
|
connrequest = "QTV_EZQUAKE_EXT: 3\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = va("USERINFO: %s\n", cls.userinfo);
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
}
|
|
else if (raw)
|
|
{
|
|
connrequest = "RAW: 1\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
}
|
|
if (host)
|
|
{
|
|
connrequest = "SOURCE: ";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = host;
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "\n";
|
|
}
|
|
else
|
|
{
|
|
connrequest = "SOURCELIST\n";
|
|
}
|
|
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
|
|
if (raw)
|
|
{
|
|
CL_QTVPlay(newf, false);
|
|
}
|
|
else
|
|
{
|
|
if (qtvrequest)
|
|
VFS_CLOSE(qtvrequest);
|
|
qtvrequest = newf;
|
|
qtvrequestsize = 0;
|
|
}
|
|
}
|
|
|
|
void CL_QTVList_f (void)
|
|
{
|
|
char *connrequest;
|
|
vfsfile_t *newf;
|
|
newf = FS_OpenTCP(qtvhostname);
|
|
|
|
if (!newf)
|
|
{
|
|
Con_Printf("Couldn't connect to proxy\n");
|
|
return;
|
|
}
|
|
|
|
if (qtvcl_forceversion1.value)
|
|
{
|
|
connrequest = "QTV\n"
|
|
"VERSION: 1.0\n";
|
|
}
|
|
else
|
|
{
|
|
connrequest = "QTV\n"
|
|
"VERSION: 1.1\n";
|
|
}
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "SOURCELIST\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
|
|
if (qtvrequest)
|
|
VFS_CLOSE(qtvrequest);
|
|
qtvrequest = newf;
|
|
qtvrequestsize = 0;
|
|
}
|
|
|
|
void CL_QTVDemos_f (void)
|
|
{
|
|
char *connrequest;
|
|
vfsfile_t *newf;
|
|
newf = FS_OpenTCP(Cmd_Argv(1));
|
|
|
|
if (!newf)
|
|
{
|
|
Con_Printf("Couldn't connect to proxy\n");
|
|
return;
|
|
}
|
|
|
|
connrequest = "QTV\n"
|
|
"VERSION: 1\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "DEMOLIST\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
connrequest = "\n";
|
|
VFS_WRITE(newf, connrequest, strlen(connrequest));
|
|
|
|
if (qtvrequest)
|
|
VFS_CLOSE(qtvrequest);
|
|
qtvrequest = newf;
|
|
qtvrequestsize = 0;
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_FinishTimeDemo
|
|
|
|
====================
|
|
*/
|
|
void CL_FinishTimeDemo (void)
|
|
{
|
|
int frames;
|
|
float time;
|
|
|
|
cls.timedemo = false;
|
|
|
|
// the first frame didn't count
|
|
frames = (host_framecount - cls.td_startframe) - 1;
|
|
time = Sys_DoubleTime() - cls.td_starttime;
|
|
if (!time)
|
|
time = 1;
|
|
Con_Printf ("%i frames %5.1f seconds %5.1f fps\n", frames, time, frames/time);
|
|
|
|
Con_Printf("NOTE: times currently depend on load times\n");
|
|
}
|
|
|
|
/*
|
|
====================
|
|
CL_TimeDemo_f
|
|
|
|
timedemo [demoname]
|
|
====================
|
|
*/
|
|
void CL_TimeDemo_f (void)
|
|
{
|
|
if (Cmd_Argc() != 2)
|
|
{
|
|
Con_Printf ("timedemo <demoname> : gets demo speeds\n");
|
|
return;
|
|
}
|
|
|
|
CL_PlayDemo_f ();
|
|
|
|
if (cls.state != ca_demostart)
|
|
return;
|
|
|
|
CL_ReadPackets();
|
|
|
|
// cls.td_starttime will be grabbed at the second frame of the demo, so
|
|
// all the loading time doesn't get counted
|
|
|
|
cls.timedemo = true;
|
|
cls.td_starttime = Sys_DoubleTime();
|
|
cls.td_startframe = host_framecount;
|
|
cls.td_lastframe = -1; // get a new message this frame
|
|
}
|
|
|