X-Git-Url: http://git.xonotic.org/?a=blobdiff_plain;f=protocol.c;h=d72e961571fb698cda74276421b2da6609caf224;hb=0d43a1bcf22b005ab7feec5373db766819aca92d;hp=32624a4f0d2b1ee932492761f4ddbc54bb08156d;hpb=ef35a088cb3ab1900acdbd5285465cd845368e79;p=xonotic%2Fdarkplaces.git diff --git a/protocol.c b/protocol.c index 32624a4f..d72e9615 100644 --- a/protocol.c +++ b/protocol.c @@ -1,743 +1,194 @@ - #include "quakedef.h" -void ClearStateToDefault(entity_state_t *s) +// this is 88 bytes (must match entity_state_t in protocol.h) +entity_state_t defaultstate = +{ + // ! means this is not sent to client + 0,//double time; // ! time this state was built (used on client for interpolation) + {0,0,0},//float netcenter[3]; // ! for network prioritization, this is the center of the bounding box (which may differ from the origin) + {0,0,0},//float origin[3]; + {0,0,0},//float angles[3]; + 0,//int effects; + 0,//unsigned int customizeentityforclient; // ! + 0,//unsigned short number; // entity number this state is for + 0,//unsigned short modelindex; + 0,//unsigned short frame; + 0,//unsigned short tagentity; + 0,//unsigned short specialvisibilityradius; // ! larger if it has effects/light + 0,//unsigned short viewmodelforclient; // ! + 0,//unsigned short exteriormodelforclient; // ! not shown if first person viewing from this entity, shown in all other cases + 0,//unsigned short nodrawtoclient; // ! + 0,//unsigned short drawonlytoclient; // ! + 0,//unsigned short traileffectnum; + {0,0,0,0},//unsigned short light[4]; // color*256 (0.00 to 255.996), and radius*1 + ACTIVE_NOT,//unsigned char active; // true if a valid state + 0,//unsigned char lightstyle; + 0,//unsigned char lightpflags; + 0,//unsigned char colormap; + 0,//unsigned char skin; // also chooses cubemap for rtlights if lightpflags & LIGHTPFLAGS_FULLDYNAMIC + 255,//unsigned char alpha; + 16,//unsigned char scale; + 0,//unsigned char glowsize; + 254,//unsigned char glowcolor; + 0,//unsigned char flags; + 0,//unsigned char internaleffects; // INTEF_FLAG1QW and so on + 0,//unsigned char tagindex; + {32, 32, 32},//unsigned char colormod[3]; + {32, 32, 32},//unsigned char glowmod[3]; +}; + +// LadyHavoc: I own protocol ranges 96, 97, 3500-3599 + +struct protocolversioninfo_s +{ + int number; + protocolversion_t version; + const char *name; +} +protocolversioninfo[] = +{ + { 3505, PROTOCOL_DARKPLACES8 , "DP8"}, + { 3504, PROTOCOL_DARKPLACES7 , "DP7"}, + { 3503, PROTOCOL_DARKPLACES6 , "DP6"}, + { 3502, PROTOCOL_DARKPLACES5 , "DP5"}, + { 3501, PROTOCOL_DARKPLACES4 , "DP4"}, + { 3500, PROTOCOL_DARKPLACES3 , "DP3"}, + { 97, PROTOCOL_DARKPLACES2 , "DP2"}, + { 96, PROTOCOL_DARKPLACES1 , "DP1"}, + { 15, PROTOCOL_QUAKEDP , "QUAKEDP"}, + { 15, PROTOCOL_QUAKE , "QUAKE"}, + { 28, PROTOCOL_QUAKEWORLD , "QW"}, + { 250, PROTOCOL_NEHAHRAMOVIE, "NEHAHRAMOVIE"}, + {10000, PROTOCOL_NEHAHRABJP , "NEHAHRABJP"}, + {10001, PROTOCOL_NEHAHRABJP2 , "NEHAHRABJP2"}, + {10002, PROTOCOL_NEHAHRABJP3 , "NEHAHRABJP3"}, + { 0, PROTOCOL_UNKNOWN , NULL} +}; + +protocolversion_t Protocol_EnumForName(const char *s) { - memset(s, 0, sizeof(*s)); - s->alpha = 255; - s->scale = 16; - s->glowcolor = 254; + int i; + for (i = 0;protocolversioninfo[i].name;i++) + if (!strcasecmp(s, protocolversioninfo[i].name)) + return protocolversioninfo[i].version; + return PROTOCOL_UNKNOWN; } -void EntityState_Write(entity_state_t *ent, sizebuf_t *msg, entity_state_t *delta) +const char *Protocol_NameForEnum(protocolversion_t p) { - int bits; - vec3_t org, deltaorg; - if (ent->active) - { - bits = 0; - VectorCopy(ent->origin, org); - VectorCopy(delta->origin, deltaorg); - if (ent->flags & RENDER_LOWPRECISION) - { - if (org[0] > 0) - org[0] = (int) (org[0] + 0.5f); - else - org[0] = (int) (org[0] - 0.5f); - if (org[1] > 0) - org[1] = (int) (org[1] + 0.5f); - else - org[1] = (int) (org[1] - 0.5f); - if (org[2] > 0) - org[2] = (int) (org[2] + 0.5f); - else - org[2] = (int) (org[2] - 0.5f); - } - if (delta->flags & RENDER_LOWPRECISION) - { - if (deltaorg[0] > 0) - deltaorg[0] = (int) (deltaorg[0] + 0.5f); - else - deltaorg[0] = (int) (deltaorg[0] - 0.5f); - if (deltaorg[1] > 0) - deltaorg[1] = (int) (deltaorg[1] + 0.5f); - else - deltaorg[1] = (int) (deltaorg[1] - 0.5f); - if (deltaorg[2] > 0) - deltaorg[2] = (int) (deltaorg[2] + 0.5f); - else - deltaorg[2] = (int) (deltaorg[2] - 0.5f); - } - if (fabs(org[0] - deltaorg[0]) > 0.01f) - bits |= E_ORIGIN1; - if (fabs(org[1] - deltaorg[1]) > 0.01f) - bits |= E_ORIGIN2; - if (fabs(org[2] - deltaorg[2]) > 0.01f) - bits |= E_ORIGIN3; - if ((qbyte) (ent->angles[0] * (256.0f / 360.0f)) != (qbyte) (delta->angles[0] * (256.0f / 360.0f))) - bits |= E_ANGLE1; - if ((qbyte) (ent->angles[1] * (256.0f / 360.0f)) != (qbyte) (delta->angles[1] * (256.0f / 360.0f))) - bits |= E_ANGLE2; - if ((qbyte) (ent->angles[2] * (256.0f / 360.0f)) != (qbyte) (delta->angles[2] * (256.0f / 360.0f))) - bits |= E_ANGLE3; - if ((ent->modelindex ^ delta->modelindex) & 0x00FF) - bits |= E_MODEL1; - if ((ent->modelindex ^ delta->modelindex) & 0xFF00) - bits |= E_MODEL2; - if ((ent->frame ^ delta->frame) & 0x00FF) - bits |= E_FRAME1; - if ((ent->frame ^ delta->frame) & 0xFF00) - bits |= E_FRAME2; - if ((ent->effects ^ delta->effects) & 0x00FF) - bits |= E_EFFECTS1; - if ((ent->effects ^ delta->effects) & 0xFF00) - bits |= E_EFFECTS2; - if (ent->colormap != delta->colormap) - bits |= E_COLORMAP; - if (ent->skin != delta->skin) - bits |= E_SKIN; - if (ent->alpha != delta->alpha) - bits |= E_ALPHA; - if (ent->scale != delta->scale) - bits |= E_SCALE; - if (ent->glowsize != delta->glowsize) - bits |= E_GLOWSIZE; - if (ent->glowcolor != delta->glowcolor) - bits |= E_GLOWCOLOR; - if (ent->flags != delta->flags) - bits |= E_FLAGS; - if (ent->tagindex != delta->tagindex || ent->tagentity != delta->tagentity) - bits |= E_TAGATTACHMENT; - - if (bits) // don't send anything if it hasn't changed - { - if (bits & 0xFF000000) - bits |= E_EXTEND3; - if (bits & 0x00FF0000) - bits |= E_EXTEND2; - if (bits & 0x0000FF00) - bits |= E_EXTEND1; - - MSG_WriteShort(msg, ent->number); - MSG_WriteByte(msg, bits & 0xFF); - if (bits & E_EXTEND1) - { - MSG_WriteByte(msg, (bits >> 8) & 0xFF); - if (bits & E_EXTEND2) - { - MSG_WriteByte(msg, (bits >> 16) & 0xFF); - if (bits & E_EXTEND3) - MSG_WriteByte(msg, (bits >> 24) & 0xFF); - } - } - // LordHavoc: have to write flags first, as they can modify protocol - if (bits & E_FLAGS) - MSG_WriteByte(msg, ent->flags); - if (ent->flags & RENDER_LOWPRECISION) - { - if (bits & E_ORIGIN1) - MSG_WriteShort(msg, org[0]); - if (bits & E_ORIGIN2) - MSG_WriteShort(msg, org[1]); - if (bits & E_ORIGIN3) - MSG_WriteShort(msg, org[2]); - } - else - { - if (bits & E_ORIGIN1) - MSG_WriteFloat(msg, org[0]); - if (bits & E_ORIGIN2) - MSG_WriteFloat(msg, org[1]); - if (bits & E_ORIGIN3) - MSG_WriteFloat(msg, org[2]); - } - if (bits & E_ANGLE1) - MSG_WriteAngle(msg, ent->angles[0]); - if (bits & E_ANGLE2) - MSG_WriteAngle(msg, ent->angles[1]); - if (bits & E_ANGLE3) - MSG_WriteAngle(msg, ent->angles[2]); - if (bits & E_MODEL1) - MSG_WriteByte(msg, ent->modelindex & 0xFF); - if (bits & E_MODEL2) - MSG_WriteByte(msg, (ent->modelindex >> 8) & 0xFF); - if (bits & E_FRAME1) - MSG_WriteByte(msg, ent->frame & 0xFF); - if (bits & E_FRAME2) - MSG_WriteByte(msg, (ent->frame >> 8) & 0xFF); - if (bits & E_EFFECTS1) - MSG_WriteByte(msg, ent->effects & 0xFF); - if (bits & E_EFFECTS2) - MSG_WriteByte(msg, (ent->effects >> 8) & 0xFF); - if (bits & E_COLORMAP) - MSG_WriteByte(msg, ent->colormap); - if (bits & E_SKIN) - MSG_WriteByte(msg, ent->skin); - if (bits & E_ALPHA) - MSG_WriteByte(msg, ent->alpha); - if (bits & E_SCALE) - MSG_WriteByte(msg, ent->scale); - if (bits & E_GLOWSIZE) - MSG_WriteByte(msg, ent->glowsize); - if (bits & E_GLOWCOLOR) - MSG_WriteByte(msg, ent->glowcolor); - if (bits & E_TAGATTACHMENT) - { - MSG_WriteShort(msg, ent->tagentity); - MSG_WriteByte(msg, ent->tagindex); - } - } - } - else if (!delta->active) - MSG_WriteShort(msg, ent->number | 0x8000); + int i; + for (i = 0;protocolversioninfo[i].name;i++) + if (protocolversioninfo[i].version == p) + return protocolversioninfo[i].name; + return "UNKNOWN"; } -void EntityState_Read(entity_state_t *e, entity_state_t *delta, int number) +protocolversion_t Protocol_EnumForNumber(int n) { - int bits; - memcpy(e, delta, sizeof(*e)); - e->active = true; - e->time = cl.mtime[0]; - e->number = number; - - bits = MSG_ReadByte(); - if (bits & E_EXTEND1) - { - bits |= MSG_ReadByte() << 8; - if (bits & E_EXTEND2) - { - bits |= MSG_ReadByte() << 16; - if (bits & E_EXTEND3) - bits |= MSG_ReadByte() << 24; - } - } - - if (dpprotocol == DPPROTOCOL_VERSION2) - { - if (bits & E_ORIGIN1) - e->origin[0] = (signed short) MSG_ReadShort(); - if (bits & E_ORIGIN2) - e->origin[1] = (signed short) MSG_ReadShort(); - if (bits & E_ORIGIN3) - e->origin[2] = (signed short) MSG_ReadShort(); - } - else - { - if (bits & E_FLAGS) - e->flags = MSG_ReadByte(); - if (e->flags & RENDER_LOWPRECISION || dpprotocol == DPPROTOCOL_VERSION2) - { - if (bits & E_ORIGIN1) - e->origin[0] = (signed short) MSG_ReadShort(); - if (bits & E_ORIGIN2) - e->origin[1] = (signed short) MSG_ReadShort(); - if (bits & E_ORIGIN3) - e->origin[2] = (signed short) MSG_ReadShort(); - } - else - { - if (bits & E_ORIGIN1) - e->origin[0] = MSG_ReadFloat(); - if (bits & E_ORIGIN2) - e->origin[1] = MSG_ReadFloat(); - if (bits & E_ORIGIN3) - e->origin[2] = MSG_ReadFloat(); - } - } - if (bits & E_ANGLE1) - e->angles[0] = MSG_ReadAngle(); - if (bits & E_ANGLE2) - e->angles[1] = MSG_ReadAngle(); - if (bits & E_ANGLE3) - e->angles[2] = MSG_ReadAngle(); - if (bits & E_MODEL1) - e->modelindex = (e->modelindex & 0xFF00) | (unsigned int) MSG_ReadByte(); - if (bits & E_MODEL2) - e->modelindex = (e->modelindex & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8); - if (bits & E_FRAME1) - e->frame = (e->frame & 0xFF00) | (unsigned int) MSG_ReadByte(); - if (bits & E_FRAME2) - e->frame = (e->frame & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8); - if (bits & E_EFFECTS1) - e->effects = (e->effects & 0xFF00) | (unsigned int) MSG_ReadByte(); - if (bits & E_EFFECTS2) - e->effects = (e->effects & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8); - if (bits & E_COLORMAP) - e->colormap = MSG_ReadByte(); - if (bits & E_SKIN) - e->skin = MSG_ReadByte(); - if (bits & E_ALPHA) - e->alpha = MSG_ReadByte(); - if (bits & E_SCALE) - e->scale = MSG_ReadByte(); - if (bits & E_GLOWSIZE) - e->glowsize = MSG_ReadByte(); - if (bits & E_GLOWCOLOR) - e->glowcolor = MSG_ReadByte(); - if (dpprotocol == DPPROTOCOL_VERSION2) - if (bits & E_FLAGS) - e->flags = MSG_ReadByte(); - if (bits & E_TAGATTACHMENT) - { - e->tagentity = MSG_ReadShort(); - e->tagindex = MSG_ReadByte(); - } + int i; + for (i = 0;protocolversioninfo[i].name;i++) + if (protocolversioninfo[i].number == n) + return protocolversioninfo[i].version; + return PROTOCOL_UNKNOWN; } -// (server) clears the database to contain no frames (thus delta compression compresses against nothing) -void EntityFrame_ClearDatabase(entity_database_t *d) +int Protocol_NumberForEnum(protocolversion_t p) { - memset(d, 0, sizeof(*d)); + int i; + for (i = 0;protocolversioninfo[i].name;i++) + if (protocolversioninfo[i].version == p) + return protocolversioninfo[i].number; + return 0; } -// (server and client) removes frames older than 'frame' from database -void EntityFrame_AckFrame(entity_database_t *d, int frame) +void Protocol_Names(char *buffer, size_t buffersize) { int i; - if (d->ackframe < frame) - d->ackframe = frame; - for (i = 0;i < d->numframes && d->frames[i].framenum < frame;i++); - // ignore outdated frame acks (out of order packets) - if (i == 0) + if (buffersize < 1) return; - d->numframes -= i; - // if some queue is left, slide it down to beginning of array - if (d->numframes) - memmove(&d->frames[0], &d->frames[i], sizeof(d->frames[0]) * d->numframes); -} - -// (server) clears frame, to prepare for adding entities -void EntityFrame_Clear(entity_frame_t *f, vec3_t eye, int framenum) -{ - f->time = 0; - f->framenum = framenum; - f->numentities = 0; - if (eye == NULL) - { - VectorClear(f->eye); - } - else + buffer[0] = 0; + for (i = 0;protocolversioninfo[i].name;i++) { - VectorCopy(eye, f->eye); + if (i > 0) + dp_strlcat(buffer, " ", buffersize); + dp_strlcat(buffer, protocolversioninfo[i].name, buffersize); } } -// (server) adds an entity to frame -void EntityFrame_AddEntity(entity_frame_t *f, entity_state_t *s) +void Protocol_UpdateClientStats(const int *stats) { - if (f->numentities < MAX_ENTITY_DATABASE) - { - f->entitydata[f->numentities] = *s; - f->entitydata[f->numentities++].active = true; - } -} - -// (server and client) reads a frame from the database -void EntityFrame_FetchFrame(entity_database_t *d, int framenum, entity_frame_t *f) -{ - int i, n; - EntityFrame_Clear(f, NULL, -1); - for (i = 0;i < d->numframes && d->frames[i].framenum < framenum;i++); - if (i < d->numframes && framenum == d->frames[i].framenum) - { - f->framenum = framenum; - f->numentities = d->frames[i].endentity - d->frames[i].firstentity; - n = MAX_ENTITY_DATABASE - (d->frames[i].firstentity % MAX_ENTITY_DATABASE); - if (n > f->numentities) - n = f->numentities; - memcpy(f->entitydata, d->entitydata + d->frames[i].firstentity % MAX_ENTITY_DATABASE, sizeof(*f->entitydata) * n); - if (f->numentities > n) - memcpy(f->entitydata + n, d->entitydata, sizeof(*f->entitydata) * (f->numentities - n)); - VectorCopy(d->eye, f->eye); - } -} - -// (server and client) adds a entity_frame to the database, for future reference -void EntityFrame_AddFrame(entity_database_t *d, entity_frame_t *f) -{ - int n, e; - entity_frameinfo_t *info; - - VectorCopy(f->eye, d->eye); - - // figure out how many entity slots are used already - if (d->numframes) - { - n = d->frames[d->numframes - 1].endentity - d->frames[0].firstentity; - if (n + f->numentities > MAX_ENTITY_DATABASE || d->numframes >= MAX_ENTITY_HISTORY) - { - // ran out of room, dump database - EntityFrame_ClearDatabase(d); - } - } - - info = &d->frames[d->numframes]; - info->framenum = f->framenum; - e = -1000; - // make sure we check the newly added frame as well, but we haven't incremented numframes yet - for (n = 0;n <= d->numframes;n++) + int i; + // update the stats array and set deltabits for any changed stats + for (i = 0;i < MAX_CL_STATS;i++) { - if (e >= d->frames[n].framenum) + if (host_client->stats[i] != stats[i]) { - if (e == f->framenum) - Con_Printf("EntityFrame_AddFrame: tried to add out of sequence frame to database\n"); - else - Con_Printf("EntityFrame_AddFrame: out of sequence frames in database\n"); - return; + host_client->statsdeltabits[i >> 3] |= 1 << (i & 7); + host_client->stats[i] = stats[i]; } - e = d->frames[n].framenum; } - // if database still has frames after that... - if (d->numframes) - info->firstentity = d->frames[d->numframes - 1].endentity; - else - info->firstentity = 0; - info->endentity = info->firstentity + f->numentities; - d->numframes++; - - n = info->firstentity % MAX_ENTITY_DATABASE; - e = MAX_ENTITY_DATABASE - n; - if (e > f->numentities) - e = f->numentities; - memcpy(d->entitydata + n, f->entitydata, sizeof(entity_state_t) * e); - if (f->numentities > e) - memcpy(d->entitydata, f->entitydata + e, sizeof(entity_state_t) * (f->numentities - e)); } -// (server) writes a frame to network stream -static entity_frame_t deltaframe; // FIXME? -void EntityFrame_Write(entity_database_t *d, entity_frame_t *f, sizebuf_t *msg) +// only a few stats are within the 32 stat limit of Quake, and most of them +// are sent every frame in svc_clientdata messages, so we only send the +// remaining ones here +static const int sendquakestats[] = { - int i, onum, number; - entity_frame_t *o = &deltaframe; - entity_state_t *ent, *delta, baseline; +// quake did not send these secrets/monsters stats in this way, but doing so +// allows a mod to increase STAT_TOTALMONSTERS during the game, and ensures +// that STAT_SECRETS and STAT_MONSTERS are always correct (even if a client +// didn't receive an svc_foundsecret or svc_killedmonster), which may be most +// valuable if randomly seeking around in a demo +STAT_TOTALSECRETS, // never changes during game +STAT_TOTALMONSTERS, // changes in some mods +STAT_SECRETS, // this makes svc_foundsecret unnecessary +STAT_MONSTERS, // this makes svc_killedmonster unnecessary +STAT_VIEWHEIGHT, // sent just for FTEQW clients +STAT_VIEWZOOM, // this rarely changes +-1, +}; - EntityFrame_AddFrame(d, f); - - ClearStateToDefault(&baseline); - EntityFrame_FetchFrame(d, d->ackframe > 0 ? d->ackframe : -1, o); - MSG_WriteByte (msg, svc_entities); - MSG_WriteLong (msg, o->framenum); - MSG_WriteLong (msg, f->framenum); - MSG_WriteFloat (msg, f->eye[0]); - MSG_WriteFloat (msg, f->eye[1]); - MSG_WriteFloat (msg, f->eye[2]); - - onum = 0; - for (i = 0;i < f->numentities;i++) - { - ent = f->entitydata + i; - number = ent->number; - for (;onum < o->numentities && o->entitydata[onum].number < number;onum++) - { - // write remove message - MSG_WriteShort(msg, o->entitydata[onum].number | 0x8000); - } - if (onum < o->numentities && (o->entitydata[onum].number == number)) - { - // delta from previous frame - delta = o->entitydata + onum; - // advance to next entity in delta frame - onum++; - } - else - { - // delta from baseline - delta = &baseline; - } - EntityState_Write(ent, msg, delta); - } - for (;onum < o->numentities;onum++) - { - // write remove message - MSG_WriteShort(msg, o->entitydata[onum].number | 0x8000); - } - MSG_WriteShort(msg, 0xFFFF); -} - -// (client) reads a frame from network stream -static entity_frame_t framedata; // FIXME? -void EntityFrame_Read(entity_database_t *d) +void Protocol_WriteStatsReliable(void) { - int number, removed; - entity_frame_t *f = &framedata, *delta = &deltaframe; - entity_state_t *e, baseline, *old, *oldend, *edelta; - - ClearStateToDefault(&baseline); - - EntityFrame_Clear(f, NULL, -1); - - // read the frame header info - f->time = cl.mtime[0]; - number = MSG_ReadLong(); - f->framenum = MSG_ReadLong(); - f->eye[0] = MSG_ReadFloat(); - f->eye[1] = MSG_ReadFloat(); - f->eye[2] = MSG_ReadFloat(); - EntityFrame_AckFrame(d, number); - EntityFrame_FetchFrame(d, number, delta); - old = delta->entitydata; - oldend = old + delta->numentities; - // read entities until we hit the magic 0xFFFF end tag - while ((number = (unsigned short) MSG_ReadShort()) != 0xFFFF) - { - if (msg_badread) - Host_Error("EntityFrame_Read: read error\n"); - removed = number & 0x8000; - number &= 0x7FFF; - if (number >= MAX_EDICTS) - Host_Error("EntityFrame_Read: number (%i) >= MAX_EDICTS (%i)\n", number, MAX_EDICTS); - - // seek to entity, while copying any skipped entities (assume unchanged) - while (old < oldend && old->number < number) - { - if (f->numentities >= MAX_ENTITY_DATABASE) - Host_Error("EntityFrame_Read: entity list too big\n"); - memcpy(f->entitydata + f->numentities, old, sizeof(entity_state_t)); - f->entitydata[f->numentities].time = cl.mtime[0]; - old++; - f->numentities++; - } - if (removed) - { - if (old < oldend && old->number == number) - old++; - else - Con_Printf("EntityFrame_Read: REMOVE on unused entity %i\n", number); - } - else - { - if (f->numentities >= MAX_ENTITY_DATABASE) - Host_Error("EntityFrame_Read: entity list too big\n"); - - // reserve this slot - e = f->entitydata + f->numentities++; - - if (old < oldend && old->number == number) + int i, j; + if (!host_client->netconnection) + return; + // detect changes in stats and write reliable messages + // this only deals with 32 stats because the older protocols which use + // this function can only cope with 32 stats, + // they also do not support svc_updatestatubyte which was introduced in + // DP6 protocol (except for QW) + for (j = 0;sendquakestats[j] >= 0;j++) + { + i = sendquakestats[j]; + // check if this bit is set + if (host_client->statsdeltabits[i >> 3] & (1 << (i & 7))) + { + host_client->statsdeltabits[i >> 3] -= (1 << (i & 7)); + // send the stat as a byte if possible + if (sv.protocol == PROTOCOL_QUAKEWORLD) { - // delta from old entity - edelta = old++; + if (host_client->stats[i] >= 0 && host_client->stats[i] < 256) + { + MSG_WriteByte(&host_client->netconnection->message, qw_svc_updatestat); + MSG_WriteByte(&host_client->netconnection->message, i); + MSG_WriteByte(&host_client->netconnection->message, host_client->stats[i]); + } + else + { + MSG_WriteByte(&host_client->netconnection->message, qw_svc_updatestatlong); + MSG_WriteByte(&host_client->netconnection->message, i); + MSG_WriteLong(&host_client->netconnection->message, host_client->stats[i]); + } } else { - // delta from baseline - edelta = &baseline; + // this could make use of svc_updatestatubyte in DP6 and later + // protocols but those protocols do not use this function + MSG_WriteByte(&host_client->netconnection->message, svc_updatestat); + MSG_WriteByte(&host_client->netconnection->message, i); + MSG_WriteLong(&host_client->netconnection->message, host_client->stats[i]); } - - EntityState_Read(e, edelta, number); } } - while (old < oldend) - { - if (f->numentities >= MAX_ENTITY_DATABASE) - Host_Error("EntityFrame_Read: entity list too big\n"); - memcpy(f->entitydata + f->numentities, old, sizeof(entity_state_t)); - f->entitydata[f->numentities].time = cl.mtime[0]; - old++; - f->numentities++; - } - EntityFrame_AddFrame(d, f); -} - - -// (client) returns the frame number of the most recent frame recieved -int EntityFrame_MostRecentlyRecievedFrameNum(entity_database_t *d) -{ - if (d->numframes) - return d->frames[d->numframes - 1].framenum; - else - return -1; } - - - - - - -static int EntityFrame4_SV_ChooseCommitToReplace(entity_database4_t *d) -{ - int i, best, bestframenum; - best = 0; - bestframenum = d->commit[0].framenum; - for (i = 0;i < MAX_ENTITY_HISTORY;i++) - { - if (!d->commit[i].numentities) - return i; - if (bestframenum > d->commit[i].framenum) - { - bestframenum = d->commit[i].framenum; - best = i; - } - } - return best; -} - -static entity_state_t *EntityFrame4_GetReferenceEntity(entity_database4_t *d, int number) -{ - if (d->maxreferenceentities <= number) - { - int oldmax = d->maxreferenceentities; - entity_state_t *oldentity = d->referenceentity; - d->maxreferenceentities = (number + 15) & ~7; - d->referenceentity = Mem_Alloc(d->mempool, d->maxreferenceentities * sizeof(*d->referenceentity)); - if (oldentity) - { - memcpy(d->referenceentity, oldentity, oldmax * sizeof(*d->referenceentity)); - Mem_Free(oldentity); - } - // clear the newly created entities - for (;oldmax < d->maxreferenceentities;oldmax++) - ClearStateToDefault(d->referenceentity + oldmax); - } - return d->referenceentity + number; -} - -static void EntityFrame4_AddCommitEntity(entity_database4_t *d, entity_state_t *s) -{ - // resize commit's entity list if full - if (d->currentcommit->maxentities <= d->currentcommit->numentities) - { - entity_state_t *oldentity = d->currentcommit->entity; - d->currentcommit->maxentities += 8; - d->currentcommit->entity = Mem_Alloc(d->mempool, d->currentcommit->maxentities * sizeof(*d->currentcommit->entity)); - if (oldentity) - { - memcpy(d->currentcommit->entity, oldentity, d->currentcommit->numentities * sizeof(*d->currentcommit->entity)); - Mem_Free(oldentity); - } - } - d->currentcommit->entity[d->currentcommit->numentities++] = *s; -} - -entity_database4_t *EntityFrame4_AllocDatabase(mempool_t *pool) -{ - entity_database4_t *d; - d = Mem_Alloc(pool, sizeof(*d)); - d->mempool = pool; - d->referenceframenum = -1; - return d; -} - -void EntityFrame4_FreeDatabase(entity_database4_t *d) -{ - int i; - for (i = 0;i < MAX_ENTITY_HISTORY;i++) - if (d->commit[i].entity) - Mem_Free(d->commit[i].entity); - if (d->referenceentity) - Mem_Free(d->referenceentity); - Mem_Free(d); -} - -void EntityFrame4_ResetDatabase(entity_database4_t *d) -{ - int i; - d->referenceframenum = -1; - for (i = 0;i < MAX_ENTITY_HISTORY;i++) - d->commit[i].numentities = 0; -} - -void EntityFrame4_AckFrame(entity_database4_t *d, int framenum) -{ - int i, foundit = false; - // check if client is requesting no delta compression - if (framenum == -1) - { - EntityFrame4_ResetDatabase(d); - return; - } - for (i = 0;i < MAX_ENTITY_HISTORY;i++) - { - if (d->commit[i].numentities && d->commit[i].framenum <= framenum) - { - if (d->commit[i].framenum == framenum) - { - // apply commit to database - d->referenceframenum = d->commit[i].framenum; - while (d->commit[i].numentities--) - *EntityFrame4_GetReferenceEntity(d, d->commit[i].entity[d->commit[i].numentities].number) = d->commit[i].entity[d->commit[i].numentities]; - foundit = true; - } - d->commit[i].numentities = 0; - d->commit[i].framenum = -1; - } - } - if (!foundit) - Con_DPrintf("EntityFrame4_AckFrame: frame %i not found in database, expect glitches!\n", framenum); -} - -void EntityFrame4_SV_WriteFrame_Begin(entity_database4_t *d, sizebuf_t *msg, int framenum) -{ - d->currentcommit = d->commit + EntityFrame4_SV_ChooseCommitToReplace(d); - d->currentcommit->numentities = 0; - d->currentcommit->framenum = framenum; - MSG_WriteByte(msg, svc_entities); - MSG_WriteLong(msg, d->referenceframenum); - MSG_WriteLong(msg, d->currentcommit->framenum); -} - -int EntityFrame4_SV_WriteFrame_Entity(entity_database4_t *d, sizebuf_t *msg, int maxbytes, entity_state_t *s) -{ - qbyte data[128]; - sizebuf_t buf; - entity_state_t *e; - // prepare the buffer - memset(&buf, 0, sizeof(buf)); - buf.data = data; - buf.maxsize = sizeof(data); - // make the message - e = EntityFrame4_GetReferenceEntity(d, s->number); - if (s->active) - { - // entity exists, send an update - EntityState_Write(s, &buf, e); - } - else if (e->active) - { - // entity used to exist but doesn't anymore, send remove - MSG_WriteShort(&buf, s->number | 0x8000); - } - // if the message is empty, skip out now - if (!buf.cursize) - return true; - // if the commit is full, we're done - if (msg->cursize + buf.cursize + 2 >= min(msg->maxsize, maxbytes)) - return false; - // add the entity to the commit - EntityFrame4_AddCommitEntity(d, s); - // write the message to the packet - SZ_Write(msg, buf.data, buf.cursize); - // carry on - return true; -} - -void EntityFrame4_SV_WriteFrame_End(entity_database4_t *d, sizebuf_t *msg) -{ - // remove world message (invalid, and thus a good terminator) - MSG_WriteShort(msg, 0x8000); - // just to be sure - d->currentcommit = NULL; -} - -extern void CL_MoveLerpEntityStates(entity_t *ent); -void EntityFrame4_CL_ReadFrame(entity_database4_t *d) -{ - int i, n, number, referenceframenum, framenum; - referenceframenum = MSG_ReadLong(); - framenum = MSG_ReadLong(); - EntityFrame4_AckFrame(d, referenceframenum); - for (i = 0;i < MAX_ENTITY_HISTORY;i++) - if (!d->commit[i].numentities) - break; - if (i < MAX_ENTITY_HISTORY) - { - d->currentcommit = d->commit + i; - d->currentcommit->framenum = framenum; - d->currentcommit->numentities = 0; - } - else - { - Con_Printf("EntityFrame4_CL_ReadFrame: error while decoding frame %i: database full, resetting, expect glitches!!\n", framenum); - d->currentcommit = NULL; - EntityFrame4_ResetDatabase(d); - } - while((n = MSG_ReadShort()) != 0x8000) - { - number = n & 0x7FFF; - cl_entities[number].state_previous = cl_entities[number].state_current; - if (number & 0x8000) - { - ClearStateToDefault(&cl_entities[number].state_current); - cl_entities[number].state_current.active = false; - cl_entities[number].state_current.number = number; - } - else - EntityState_Read(&cl_entities[number].state_current, EntityFrame4_GetReferenceEntity(d, number), number); - CL_MoveLerpEntityStates(&cl_entities[number]); - cl_entities_active[number] = true; - if (d->currentcommit) - EntityFrame4_AddCommitEntity(d, &cl_entities[number].state_current); - } - d->currentcommit = NULL; -} -