nzp-team/fteqw
0
0
Fork 0
mirror of https://github.com/nzp-team/fteqw.git synced 2025-02-16 17:01:44 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix for silly cpu usage.

Browse source 
git-svn-id: https://svn.code.sf.net/p/fteqw/code/trunk@1357 fc73d0e0-1445-4013-8a0c-d673dee63da5
This commit is contained in:
Spoike 2005-09-24 11:42:05 +00:00
parent 393e7f4a33
commit bb16df2141
1 changed files with 20 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
fteqtv/source.c
View file

@ -407,7 +407,7 @@ void Prox_SendMessage(oproxy_t *prox, char *buf, int length, int dem_type, unsig
void Prox_SendPlayerStats(sv_t *qtv, oproxy_t *prox) void Prox_SendPlayerStats(sv_t *qtv, oproxy_t *prox)
{ {
char buffer[MAX_MSGLEN*8]; char buffer[MAX_MSGLEN];
netmsg_t msg; netmsg_t msg;
int player, snum; int player, snum;
@ -435,7 +435,10 @@ 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;
}
} }
} }
@ -492,6 +495,7 @@ void Net_SendConnectionMVD(sv_t *qtv, oproxy_t *prox)
Net_TryFlushProxyBuffer(prox); Net_TryFlushProxyBuffer(prox);
Prox_SendPlayerStats(qtv, prox); Prox_SendPlayerStats(qtv, prox);
Net_TryFlushProxyBuffer(prox);
if (!qtv->lateforward) if (!qtv->lateforward)
Net_ProxySend(prox, qtv->buffer, qtv->buffersize); //send all the info we've not yet processed. Net_ProxySend(prox, qtv->buffer, qtv->buffersize); //send all the info we've not yet processed.
@ -636,7 +640,6 @@ unsigned int Sys_Milliseconds(void)
void NetSleep(sv_t *tv) void NetSleep(sv_t *tv)
{ {
int m; int m;
int ret;
struct timeval timeout; struct timeval timeout;
fd_set socketset; fd_set socketset;
@ -667,7 +670,7 @@ void NetSleep(sv_t *tv)
timeout.tv_sec = 100/1000; timeout.tv_sec = 100/1000;
timeout.tv_usec = (100%1000)*1000; timeout.tv_usec = (100%1000)*1000;
ret = select(m, &socketset, NULL, NULL, &timeout); select(m, &socketset, NULL, NULL, &timeout);
#ifdef _WIN32 #ifdef _WIN32
for (;;) for (;;)
@ -788,6 +791,18 @@ void QTV_Run(sv_t *qtv)
while(1) while(1)
{ {
if (MAX_PROXY_BUFFER == qtv->buffersize)
{ //our input buffer is full
//so our receiving tcp socket probably has something waiting on it
//so our select calls will never wait
//so we add some extra sleeping.
#ifdef _WIN32
Sleep(5);
#else
usleep(5000);
#endif
}
NetSleep(qtv); NetSleep(qtv);
if (qtv->sourcesock == INVALID_SOCKET && !qtv->file) if (qtv->sourcesock == INVALID_SOCKET && !qtv->file)
@ -938,6 +953,8 @@ void QTV_Run(sv_t *qtv)
} }
QW_UpdateUDPStuff(qtv); QW_UpdateUDPStuff(qtv);
} }
} }