fte/fteqw
2
0
Fork 1
Code Issues Pull requests Releases 1 Activity Actions

Forward it before an svc_disconenct kills us off.

Browse source 
git-svn-id: https://svn.code.sf.net/p/fteqw/code/trunk@1362 fc73d0e0-1445-4013-8a0c-d673dee63da5
This commit is contained in:
Spoike 2005-09-24 14:49:45 +00:00
parent 404f706512
commit 4be832f1b3
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
fteqtv/source.c
View file

@ -436,7 +436,7 @@ void Prox_SendPlayerStats(sv_t *qtv, oproxy_t *prox)
if (msg.cursize) if (msg.cursize)
{ {
Prox_SendMessage(prox, msg.data, msg.cursize, dem_stats|(player<<3), (1<<player)); // Prox_SendMessage(prox, msg.data, msg.cursize, dem_stats|(player<<3), (1<<player));
msg.cursize = 0; msg.cursize = 0;
} }
} }
@ -795,7 +795,8 @@ void QTV_Run(sv_t *qtv)
{ //our input buffer is full { //our input buffer is full
//so our receiving tcp socket probably has something waiting on it //so our receiving tcp socket probably has something waiting on it
//so our select calls will never wait //so our select calls will never wait
//so we add some extra sleeping. //so we're using close to 100% cpu
//so we add some extra sleeping here.
#ifdef _WIN32 #ifdef _WIN32
Sleep(5); Sleep(5);
#else #else
@ -914,6 +915,9 @@ void QTV_Run(sv_t *qtv)
if (qtv->nextpackettime < qtv->curtime) if (qtv->nextpackettime < qtv->curtime)
{ {
if (qtv->lateforward)
Net_ForwardStream(qtv, qtv->buffer, lengthofs+4+length);
switch(qtv->buffer[1]&dem_mask) switch(qtv->buffer[1]&dem_mask)
{ {
case dem_multiple: case dem_multiple:
@ -935,8 +939,6 @@ void QTV_Run(sv_t *qtv)
qtv->oldpackettime = qtv->curtime; qtv->oldpackettime = qtv->curtime;
packettime = buffer[0]; packettime = buffer[0];
if (qtv->lateforward)
Net_ForwardStream(qtv, qtv->buffer, lengthofs+4+length);
if (qtv->buffersize) if (qtv->buffersize)
{ //svc_disconnect can flush our input buffer (to prevent the EndOfDemo part from interfering) { //svc_disconnect can flush our input buffer (to prevent the EndOfDemo part from interfering)
memmove(qtv->buffer, qtv->buffer+lengthofs+4+length, qtv->buffersize-(lengthofs+length+4)); memmove(qtv->buffer, qtv->buffer+lengthofs+4+length, qtv->buffersize-(lengthofs+length+4));