X-Git-Url: http://git.xonotic.org/?a=blobdiff_plain;f=protocol.c;h=073828ee21f9768383d75f99e12e66d733fafa19;hb=27b8e67dec8c8084ba38ed8201dc54ccd46fdb23;hp=304a2d6155bff858390a52480b0bff035f1e6280;hpb=bbfa614b656aa345e70174b6fdccd1804ca42fb6;p=xonotic%2Fdarkplaces.git

diff --git a/protocol.c b/protocol.c
index 304a2d61..073828ee 100644
--- a/protocol.c
+++ b/protocol.c
@@ -1,15 +1,22 @@
 #include "quakedef.h"
 
-#define ENTITYSIZEPROFILING_START(msg, num) \
+#define ENTITYSIZEPROFILING_START(msg, num, flags) \
 	int entityprofiling_startsize = msg->cursize
 
-#define ENTITYSIZEPROFILING_END(msg, num) \
+#define ENTITYSIZEPROFILING_END(msg, num, flags) \
 	if(developer_networkentities.integer >= 2) \
 	{ \
-		prvm_edict_t *ed = prog->edicts + num; \
-		Con_Printf("sent entity update of size %d for a %s\n", (msg->cursize - entityprofiling_startsize), PRVM_serveredictstring(ed, classname) ? PRVM_GetString(PRVM_serveredictstring(ed, classname)) : "(no classname)"); \
+		prvm_edict_t *edict = prog->edicts + num; \
+		Con_Printf("sent entity update of size %u for %d classname %s flags %d\n", (msg->cursize - entityprofiling_startsize), num, PRVM_serveredictstring(edict, classname) ? PRVM_GetString(prog, PRVM_serveredictstring(edict, classname)) : "(no classname)", flags); \
 	}
 
+// CSQC entity scope values. Bitflags!
+#define SCOPE_WANTREMOVE 1        // Set if a remove has been scheduled. Never set together with WANTUPDATE.
+#define SCOPE_WANTUPDATE 2        // Set if an update has been scheduled.
+#define SCOPE_WANTSEND (SCOPE_WANTREMOVE | SCOPE_WANTUPDATE)
+#define SCOPE_EXISTED_ONCE 4      // Set if the entity once existed. All these get resent on a full loss.
+#define SCOPE_ASSUMED_EXISTING 8  // Set if the entity is currently assumed existing and therefore needs removes.
+
 // this is 88 bytes (must match entity_state_t in protocol.h)
 entity_state_t defaultstate =
 {
@@ -29,6 +36,7 @@ entity_state_t defaultstate =
 	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;
@@ -46,7 +54,7 @@ entity_state_t defaultstate =
 	{32, 32, 32},//unsigned char glowmod[3];
 };
 
-// LordHavoc: I own protocol ranges 96, 97, 3500-3599
+// LadyHavoc: I own protocol ranges 96, 97, 3500-3599
 
 struct protocolversioninfo_s
 {
@@ -130,18 +138,18 @@ void EntityFrameQuake_ReadEntity(int bits)
 	entity_state_t s;
 
 	if (bits & U_MOREBITS)
-		bits |= (MSG_ReadByte()<<8);
+		bits |= (MSG_ReadByte(&cl_message)<<8);
 	if ((bits & U_EXTEND1) && cls.protocol != PROTOCOL_NEHAHRAMOVIE)
 	{
-		bits |= MSG_ReadByte() << 16;
+		bits |= MSG_ReadByte(&cl_message) << 16;
 		if (bits & U_EXTEND2)
-			bits |= MSG_ReadByte() << 24;
+			bits |= MSG_ReadByte(&cl_message) << 24;
 	}
 
 	if (bits & U_LONGENTITY)
-		num = (unsigned short) MSG_ReadShort ();
+		num = (unsigned short) MSG_ReadShort(&cl_message);
 	else
-		num = MSG_ReadByte ();
+		num = MSG_ReadByte(&cl_message);
 
 	if (num >= MAX_EDICTS)
 		Host_Error("EntityFrameQuake_ReadEntity: entity number (%i) >= MAX_EDICTS (%i)", num, MAX_EDICTS);
@@ -177,42 +185,42 @@ void EntityFrameQuake_ReadEntity(int bits)
 	if (bits & U_MODEL)
 	{
 		if (cls.protocol == PROTOCOL_NEHAHRABJP || cls.protocol == PROTOCOL_NEHAHRABJP2 || cls.protocol == PROTOCOL_NEHAHRABJP3)
-							s.modelindex = (unsigned short) MSG_ReadShort();
+							s.modelindex = (unsigned short) MSG_ReadShort(&cl_message);
 		else
-							s.modelindex = (s.modelindex & 0xFF00) | MSG_ReadByte();
-	}
-	if (bits & U_FRAME)		s.frame = (s.frame & 0xFF00) | MSG_ReadByte();
-	if (bits & U_COLORMAP)	s.colormap = MSG_ReadByte();
-	if (bits & U_SKIN)		s.skin = MSG_ReadByte();
-	if (bits & U_EFFECTS)	s.effects = (s.effects & 0xFF00) | MSG_ReadByte();
-	if (bits & U_ORIGIN1)	s.origin[0] = MSG_ReadCoord(cls.protocol);
-	if (bits & U_ANGLE1)	s.angles[0] = MSG_ReadAngle(cls.protocol);
-	if (bits & U_ORIGIN2)	s.origin[1] = MSG_ReadCoord(cls.protocol);
-	if (bits & U_ANGLE2)	s.angles[1] = MSG_ReadAngle(cls.protocol);
-	if (bits & U_ORIGIN3)	s.origin[2] = MSG_ReadCoord(cls.protocol);
-	if (bits & U_ANGLE3)	s.angles[2] = MSG_ReadAngle(cls.protocol);
+							s.modelindex = (s.modelindex & 0xFF00) | MSG_ReadByte(&cl_message);
+	}
+	if (bits & U_FRAME)		s.frame = (s.frame & 0xFF00) | MSG_ReadByte(&cl_message);
+	if (bits & U_COLORMAP)	s.colormap = MSG_ReadByte(&cl_message);
+	if (bits & U_SKIN)		s.skin = MSG_ReadByte(&cl_message);
+	if (bits & U_EFFECTS)	s.effects = (s.effects & 0xFF00) | MSG_ReadByte(&cl_message);
+	if (bits & U_ORIGIN1)	s.origin[0] = MSG_ReadCoord(&cl_message, cls.protocol);
+	if (bits & U_ANGLE1)	s.angles[0] = MSG_ReadAngle(&cl_message, cls.protocol);
+	if (bits & U_ORIGIN2)	s.origin[1] = MSG_ReadCoord(&cl_message, cls.protocol);
+	if (bits & U_ANGLE2)	s.angles[1] = MSG_ReadAngle(&cl_message, cls.protocol);
+	if (bits & U_ORIGIN3)	s.origin[2] = MSG_ReadCoord(&cl_message, cls.protocol);
+	if (bits & U_ANGLE3)	s.angles[2] = MSG_ReadAngle(&cl_message, cls.protocol);
 	if (bits & U_STEP)		s.flags |= RENDER_STEP;
-	if (bits & U_ALPHA)		s.alpha = MSG_ReadByte();
-	if (bits & U_SCALE)		s.scale = MSG_ReadByte();
-	if (bits & U_EFFECTS2)	s.effects = (s.effects & 0x00FF) | (MSG_ReadByte() << 8);
-	if (bits & U_GLOWSIZE)	s.glowsize = MSG_ReadByte();
-	if (bits & U_GLOWCOLOR)	s.glowcolor = MSG_ReadByte();
-	if (bits & U_COLORMOD)	{int c = MSG_ReadByte();s.colormod[0] = (unsigned char)(((c >> 5) & 7) * (32.0f / 7.0f));s.colormod[1] = (unsigned char)(((c >> 2) & 7) * (32.0f / 7.0f));s.colormod[2] = (unsigned char)((c & 3) * (32.0f / 3.0f));}
+	if (bits & U_ALPHA)		s.alpha = MSG_ReadByte(&cl_message);
+	if (bits & U_SCALE)		s.scale = MSG_ReadByte(&cl_message);
+	if (bits & U_EFFECTS2)	s.effects = (s.effects & 0x00FF) | (MSG_ReadByte(&cl_message) << 8);
+	if (bits & U_GLOWSIZE)	s.glowsize = MSG_ReadByte(&cl_message);
+	if (bits & U_GLOWCOLOR)	s.glowcolor = MSG_ReadByte(&cl_message);
+	if (bits & U_COLORMOD)	{int c = MSG_ReadByte(&cl_message);s.colormod[0] = (unsigned char)(((c >> 5) & 7) * (32.0f / 7.0f));s.colormod[1] = (unsigned char)(((c >> 2) & 7) * (32.0f / 7.0f));s.colormod[2] = (unsigned char)((c & 3) * (32.0f / 3.0f));}
 	if (bits & U_GLOWTRAIL) s.flags |= RENDER_GLOWTRAIL;
-	if (bits & U_FRAME2)	s.frame = (s.frame & 0x00FF) | (MSG_ReadByte() << 8);
-	if (bits & U_MODEL2)	s.modelindex = (s.modelindex & 0x00FF) | (MSG_ReadByte() << 8);
+	if (bits & U_FRAME2)	s.frame = (s.frame & 0x00FF) | (MSG_ReadByte(&cl_message) << 8);
+	if (bits & U_MODEL2)	s.modelindex = (s.modelindex & 0x00FF) | (MSG_ReadByte(&cl_message) << 8);
 	if (bits & U_VIEWMODEL)	s.flags |= RENDER_VIEWMODEL;
 	if (bits & U_EXTERIORMODEL)	s.flags |= RENDER_EXTERIORMODEL;
 
-	// LordHavoc: to allow playback of the Nehahra movie
+	// LadyHavoc: to allow playback of the Nehahra movie
 	if (cls.protocol == PROTOCOL_NEHAHRAMOVIE && (bits & U_EXTEND1))
 	{
-		// LordHavoc: evil format
-		int i = (int)MSG_ReadFloat();
-		int j = (int)(MSG_ReadFloat() * 255.0f);
+		// LadyHavoc: evil format
+		int i = (int)MSG_ReadFloat(&cl_message);
+		int j = (int)(MSG_ReadFloat(&cl_message) * 255.0f);
 		if (i == 2)
 		{
-			i = (int)MSG_ReadFloat();
+			i = (int)MSG_ReadFloat(&cl_message);
 			if (i)
 				s.effects |= EF_FULLBRIGHT;
 		}
@@ -232,7 +240,7 @@ void EntityFrameQuake_ReadEntity(int bits)
 		cl.entities_active[ent->state_current.number] = true;
 	}
 
-	if (msg_badread)
+	if (cl_message.badread)
 		Host_Error("EntityFrameQuake_ReadEntity: read error");
 }
 
@@ -269,6 +277,7 @@ void EntityFrameQuake_ISeeDeadEntities(void)
 // Always use the DP5 protocol, or a higher one, when using CSQC entities.
 static void EntityFrameCSQC_LostAllFrames(client_t *client)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	// mark ALL csqc entities as requiring a FULL resend!
 	// I know this is a bad workaround, but better than nothing.
 	int i, n;
@@ -277,16 +286,12 @@ static void EntityFrameCSQC_LostAllFrames(client_t *client)
 	n = client->csqcnumedicts;
 	for(i = 0; i < n; ++i)
 	{
-		if(client->csqcentityglobalhistory[i])
+		if(client->csqcentityscope[i] & SCOPE_EXISTED_ONCE)
 		{
 			ed = prog->edicts + i;
-			if (PRVM_serveredictfunction(ed, SendEntity))
-				client->csqcentitysendflags[i] |= 0xFFFFFF; // FULL RESEND
-			else // if it was ever sent to that client as a CSQC entity
-			{
-				client->csqcentityscope[i] = 1; // REMOVE
-				client->csqcentitysendflags[i] |= 0xFFFFFF;
-			}
+			client->csqcentitysendflags[i] |= 0xFFFFFF;  // FULL RESEND. We can't clear SCOPE_ASSUMED_EXISTING yet as this would cancel removes on a rejected send attempt.
+			if (!PRVM_serveredictfunction(ed, SendEntity))  // If it was ever sent to that client as a CSQC entity...
+				client->csqcentityscope[i] |= SCOPE_ASSUMED_EXISTING;  // FORCE REMOVE.
 		}
 	}
 }
@@ -296,7 +301,7 @@ void EntityFrameCSQC_LostFrame(client_t *client, int framenum)
 	int i, j;
 	qboolean valid;
 	int ringfirst, ringlast;
-	static int recoversendflags[MAX_EDICTS];
+	static int recoversendflags[MAX_EDICTS]; // client only
 	csqcentityframedb_t *d;
 
 	if(client->csqcentityframe_lastreset < 0)
@@ -393,12 +398,7 @@ void EntityFrameCSQC_LostFrame(client_t *client, int framenum)
 	for(i = 0; i < client->csqcnumedicts; ++i)
 	{
 		if(recoversendflags[i] < 0)
-		{
-			// a remove got lost, then either send a remove or - if it was
-			// recreated later - a FULL update to make totally sure
-			client->csqcentityscope[i] = 1;
-			client->csqcentitysendflags[i] = 0xFFFFFF;
-		}
+			client->csqcentityscope[i] |= SCOPE_ASSUMED_EXISTING;  // FORCE REMOVE.
 		else
 			client->csqcentitysendflags[i] |= recoversendflags[i];
 	}
@@ -431,6 +431,7 @@ static void EntityFrameCSQC_DeallocFrame(client_t *client, int framenum)
 // amounts of csqc networked entities
 qboolean EntityFrameCSQC_WriteFrame (sizebuf_t *msg, int maxsize, int numnumbers, const unsigned short *numbers, int framenum)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	int num, number, end, sendflags;
 	qboolean sectionstarted = false;
 	const unsigned short *n;
@@ -458,18 +459,19 @@ qboolean EntityFrameCSQC_WriteFrame (sizebuf_t *msg, int maxsize, int numnumbers
 		end = *n;
 		for (;number < end;number++)
 		{
-			if (client->csqcentityscope[number])
-			{
-				client->csqcentityscope[number] = 1;
-				client->csqcentitysendflags[number] = 0xFFFFFF;
-			}
+			client->csqcentityscope[number] &= ~SCOPE_WANTSEND;
+			if (client->csqcentityscope[number] & SCOPE_ASSUMED_EXISTING)
+				client->csqcentityscope[number] |= SCOPE_WANTREMOVE;
+			client->csqcentitysendflags[number] = 0xFFFFFF;
 		}
 		ed = prog->edicts + number;
+		client->csqcentityscope[number] &= ~SCOPE_WANTSEND;
 		if (PRVM_serveredictfunction(ed, SendEntity))
-			client->csqcentityscope[number] = 2;
-		else if (client->csqcentityscope[number])
+			client->csqcentityscope[number] |= SCOPE_WANTUPDATE;
+		else
 		{
-			client->csqcentityscope[number] = 1;
+			if (client->csqcentityscope[number] & SCOPE_ASSUMED_EXISTING)
+				client->csqcentityscope[number] |= SCOPE_WANTREMOVE;
 			client->csqcentitysendflags[number] = 0xFFFFFF;
 		}
 		number++;
@@ -477,44 +479,25 @@ qboolean EntityFrameCSQC_WriteFrame (sizebuf_t *msg, int maxsize, int numnumbers
 	end = client->csqcnumedicts;
 	for (;number < end;number++)
 	{
-		if (client->csqcentityscope[number])
-		{
-			client->csqcentityscope[number] = 1;
-			client->csqcentitysendflags[number] = 0xFFFFFF;
-		}
-	}
-
-	/*
-	// mark all scope entities as remove
-	for (number = 1;number < client->csqcnumedicts;number++)
-		if (client->csqcentityscope[number])
-			client->csqcentityscope[number] = 1;
-	// keep visible entities
-	for (i = 0, n = numbers;i < numnumbers;i++, n++)
-	{
-		number = *n;
-		ed = prog->edicts + number;
-		if (PRVM_serveredictfunction(ed, SendEntity))
-			client->csqcentityscope[number] = 2;
+		client->csqcentityscope[number] &= ~SCOPE_WANTSEND;
+		if (client->csqcentityscope[number] & SCOPE_ASSUMED_EXISTING)
+			client->csqcentityscope[number] |= SCOPE_WANTREMOVE;
+		client->csqcentitysendflags[number] = 0xFFFFFF;
 	}
-	*/
 
 	// now try to emit the entity updates
 	// (FIXME: prioritize by distance?)
 	end = client->csqcnumedicts;
 	for (number = 1;number < end;number++)
 	{
-		if (!client->csqcentityscope[number])
-			continue;
-		sendflags = client->csqcentitysendflags[number];
-		if (!sendflags)
+		if (!(client->csqcentityscope[number] & SCOPE_WANTSEND))
 			continue;
 		if(db->num >= NUM_CSQCENTITIES_PER_FRAME)
 			break;
 		ed = prog->edicts + number;
-		// entity scope is either update (2) or remove (1)
-		if (client->csqcentityscope[number] == 1)
+		if (client->csqcentityscope[number] & SCOPE_WANTREMOVE)  // Also implies ASSUMED_EXISTING.
 		{
+			// A removal. SendFlags have no power here.
 			// write a remove message
 			// first write the message identifier if needed
 			if(!sectionstarted)
@@ -524,50 +507,91 @@ qboolean EntityFrameCSQC_WriteFrame (sizebuf_t *msg, int maxsize, int numnumbers
 			}
 			// write the remove message
 			{
-				ENTITYSIZEPROFILING_START(msg, number);
+				ENTITYSIZEPROFILING_START(msg, number, 0);
 				MSG_WriteShort(msg, (unsigned short)number | 0x8000);
-				client->csqcentityscope[number] = 0;
+				client->csqcentityscope[number] &= ~(SCOPE_WANTSEND | SCOPE_ASSUMED_EXISTING);
 				client->csqcentitysendflags[number] = 0xFFFFFF; // resend completely if it becomes active again
 				db->entno[db->num] = number;
 				db->sendflags[db->num] = -1;
 				db->num += 1;
-				client->csqcentityglobalhistory[number] = 1;
-				ENTITYSIZEPROFILING_END(msg, number);
+				ENTITYSIZEPROFILING_END(msg, number, 0);
 			}
 			if (msg->cursize + 17 >= maxsize)
 				break;
 		}
 		else
 		{
-			// write an update
 			// save the cursize value in case we overflow and have to rollback
 			int oldcursize = msg->cursize;
-			client->csqcentityscope[number] = 1;
+
+			// An update.
+			sendflags = client->csqcentitysendflags[number];
+			// Nothing to send? FINE.
+			if (!sendflags)
+				continue;
+			// If it's a new entity, always assume sendflags 0xFFFFFF.
+			if (!(client->csqcentityscope[number] & SCOPE_ASSUMED_EXISTING))
+				sendflags = 0xFFFFFF;
+
+			// write an update
 			if (PRVM_serveredictfunction(ed, SendEntity))
 			{
 				if(!sectionstarted)
 					MSG_WriteByte(msg, svc_csqcentities);
 				{
-					ENTITYSIZEPROFILING_START(msg, number);
+					int oldcursize2 = msg->cursize;
+					ENTITYSIZEPROFILING_START(msg, number, sendflags);
 					MSG_WriteShort(msg, number);
 					msg->allowoverflow = true;
 					PRVM_G_INT(OFS_PARM0) = sv.writeentitiestoclient_cliententitynumber;
 					PRVM_G_FLOAT(OFS_PARM1) = sendflags;
 					PRVM_serverglobaledict(self) = number;
-					PRVM_ExecuteProgram(PRVM_serveredictfunction(ed, SendEntity), "Null SendEntity\n");
+					prog->ExecuteProgram(prog, PRVM_serveredictfunction(ed, SendEntity), "Null SendEntity\n");
 					msg->allowoverflow = false;
-					if(PRVM_G_FLOAT(OFS_RETURN) && msg->cursize + 2 <= maxsize)
+					if(!PRVM_G_FLOAT(OFS_RETURN))
+					{
+						// Send rejected by CSQC. This means we want to remove it.
+						// CSQC requests we remove this one.
+						if (client->csqcentityscope[number] & SCOPE_ASSUMED_EXISTING)
+						{
+							msg->cursize = oldcursize2;
+							msg->overflowed = false;
+							MSG_WriteShort(msg, (unsigned short)number | 0x8000);
+							client->csqcentityscope[number] &= ~(SCOPE_WANTSEND | SCOPE_ASSUMED_EXISTING);
+							client->csqcentitysendflags[number] = 0;
+							db->entno[db->num] = number;
+							db->sendflags[db->num] = -1;
+							db->num += 1;
+							// and take note that we have begun the svc_csqcentities
+							// section of the packet
+							sectionstarted = 1;
+							ENTITYSIZEPROFILING_END(msg, number, 0);
+							if (msg->cursize + 17 >= maxsize)
+								break;
+						}
+						else
+						{
+							// Nothing to do. Just don't do it again.
+							msg->cursize = oldcursize;
+							msg->overflowed = false;
+							client->csqcentityscope[number] &= ~SCOPE_WANTSEND;
+							client->csqcentitysendflags[number] = 0;
+						}
+						continue;
+					}
+					else if(PRVM_G_FLOAT(OFS_RETURN) && msg->cursize + 2 <= maxsize)
 					{
 						// an update has been successfully written
 						client->csqcentitysendflags[number] = 0;
 						db->entno[db->num] = number;
 						db->sendflags[db->num] = sendflags;
 						db->num += 1;
-						client->csqcentityglobalhistory[number] = 1;
+						client->csqcentityscope[number] &= ~SCOPE_WANTSEND;
+						client->csqcentityscope[number] |= SCOPE_EXISTED_ONCE | SCOPE_ASSUMED_EXISTING;
 						// and take note that we have begun the svc_csqcentities
 						// section of the packet
 						sectionstarted = 1;
-						ENTITYSIZEPROFILING_END(msg, number);
+						ENTITYSIZEPROFILING_END(msg, number, sendflags);
 						if (msg->cursize + 17 >= maxsize)
 							break;
 						continue;
@@ -676,6 +700,7 @@ void Protocol_WriteStatsReliable(void)
 
 qboolean EntityFrameQuake_WriteFrame(sizebuf_t *msg, int maxsize, int numstates, const entity_state_t **states)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	const entity_state_t *s;
 	entity_state_t baseline;
 	int i, bits;
@@ -690,7 +715,6 @@ qboolean EntityFrameQuake_WriteFrame(sizebuf_t *msg, int maxsize, int numstates,
 
 	for (i = 0;i < numstates;i++)
 	{
-		ENTITYSIZEPROFILING_START(msg, states[i]->number);
 		s = states[i];
 		if(PRVM_serveredictfunction((&prog->edicts[s->number]), SendEntity))
 			continue;
@@ -711,7 +735,7 @@ qboolean EntityFrameQuake_WriteFrame(sizebuf_t *msg, int maxsize, int numstates,
 		if (s->flags & RENDER_EXTERIORMODEL)
 			bits |= U_EXTERIORMODEL;
 
-		// LordHavoc: old stuff, but rewritten to have more exact tolerances
+		// LadyHavoc: old stuff, but rewritten to have more exact tolerances
 		baseline = prog->edicts[s->number].priv.server->baseline;
 		if (baseline.origin[0] != s->origin[0])
 			bits |= U_ORIGIN1;
@@ -774,68 +798,72 @@ qboolean EntityFrameQuake_WriteFrame(sizebuf_t *msg, int maxsize, int numstates,
 			bits |= U_MOREBITS;
 		bits |= U_SIGNAL;
 
-		MSG_WriteByte (&buf, bits);
-		if (bits & U_MOREBITS)		MSG_WriteByte(&buf, bits>>8);
-		if (sv.protocol != PROTOCOL_NEHAHRAMOVIE)
 		{
-			if (bits & U_EXTEND1)	MSG_WriteByte(&buf, bits>>16);
-			if (bits & U_EXTEND2)	MSG_WriteByte(&buf, bits>>24);
-		}
-		if (bits & U_LONGENTITY)	MSG_WriteShort(&buf, s->number);
-		else						MSG_WriteByte(&buf, s->number);
+			ENTITYSIZEPROFILING_START(msg, states[i]->number, bits);
 
-		if (bits & U_MODEL)
-		{
-			if (sv.protocol == PROTOCOL_NEHAHRABJP || sv.protocol == PROTOCOL_NEHAHRABJP2 || sv.protocol == PROTOCOL_NEHAHRABJP3)
-				MSG_WriteShort(&buf, s->modelindex);
-			else
-				MSG_WriteByte(&buf, s->modelindex);
-		}
-		if (bits & U_FRAME)			MSG_WriteByte(&buf, s->frame);
-		if (bits & U_COLORMAP)		MSG_WriteByte(&buf, s->colormap);
-		if (bits & U_SKIN)			MSG_WriteByte(&buf, s->skin);
-		if (bits & U_EFFECTS)		MSG_WriteByte(&buf, s->effects);
-		if (bits & U_ORIGIN1)		MSG_WriteCoord(&buf, s->origin[0], sv.protocol);
-		if (bits & U_ANGLE1)		MSG_WriteAngle(&buf, s->angles[0], sv.protocol);
-		if (bits & U_ORIGIN2)		MSG_WriteCoord(&buf, s->origin[1], sv.protocol);
-		if (bits & U_ANGLE2)		MSG_WriteAngle(&buf, s->angles[1], sv.protocol);
-		if (bits & U_ORIGIN3)		MSG_WriteCoord(&buf, s->origin[2], sv.protocol);
-		if (bits & U_ANGLE3)		MSG_WriteAngle(&buf, s->angles[2], sv.protocol);
-		if (bits & U_ALPHA)			MSG_WriteByte(&buf, s->alpha);
-		if (bits & U_SCALE)			MSG_WriteByte(&buf, s->scale);
-		if (bits & U_EFFECTS2)		MSG_WriteByte(&buf, s->effects >> 8);
-		if (bits & U_GLOWSIZE)		MSG_WriteByte(&buf, s->glowsize);
-		if (bits & U_GLOWCOLOR)		MSG_WriteByte(&buf, s->glowcolor);
-		if (bits & U_COLORMOD)		{int c = ((int)bound(0, s->colormod[0] * (7.0f / 32.0f), 7) << 5) | ((int)bound(0, s->colormod[1] * (7.0f / 32.0f), 7) << 2) | ((int)bound(0, s->colormod[2] * (3.0f / 32.0f), 3) << 0);MSG_WriteByte(&buf, c);}
-		if (bits & U_FRAME2)		MSG_WriteByte(&buf, s->frame >> 8);
-		if (bits & U_MODEL2)		MSG_WriteByte(&buf, s->modelindex >> 8);
-
-		// the nasty protocol
-		if ((bits & U_EXTEND1) && sv.protocol == PROTOCOL_NEHAHRAMOVIE)
-		{
-			if (s->effects & EF_FULLBRIGHT)
+			MSG_WriteByte (&buf, bits);
+			if (bits & U_MOREBITS)		MSG_WriteByte(&buf, bits>>8);
+			if (sv.protocol != PROTOCOL_NEHAHRAMOVIE)
 			{
-				MSG_WriteFloat(&buf, 2); // QSG protocol version
-				MSG_WriteFloat(&buf, s->alpha <= 0 ? 0 : (s->alpha >= 255 ? 1 : s->alpha * (1.0f / 255.0f))); // alpha
-				MSG_WriteFloat(&buf, 1); // fullbright
+				if (bits & U_EXTEND1)	MSG_WriteByte(&buf, bits>>16);
+				if (bits & U_EXTEND2)	MSG_WriteByte(&buf, bits>>24);
 			}
-			else
+			if (bits & U_LONGENTITY)	MSG_WriteShort(&buf, s->number);
+			else						MSG_WriteByte(&buf, s->number);
+
+			if (bits & U_MODEL)
 			{
-				MSG_WriteFloat(&buf, 1); // QSG protocol version
-				MSG_WriteFloat(&buf, s->alpha <= 0 ? 0 : (s->alpha >= 255 ? 1 : s->alpha * (1.0f / 255.0f))); // alpha
+				if (sv.protocol == PROTOCOL_NEHAHRABJP || sv.protocol == PROTOCOL_NEHAHRABJP2 || sv.protocol == PROTOCOL_NEHAHRABJP3)
+					MSG_WriteShort(&buf, s->modelindex);
+				else
+					MSG_WriteByte(&buf, s->modelindex);
+			}
+			if (bits & U_FRAME)			MSG_WriteByte(&buf, s->frame);
+			if (bits & U_COLORMAP)		MSG_WriteByte(&buf, s->colormap);
+			if (bits & U_SKIN)			MSG_WriteByte(&buf, s->skin);
+			if (bits & U_EFFECTS)		MSG_WriteByte(&buf, s->effects);
+			if (bits & U_ORIGIN1)		MSG_WriteCoord(&buf, s->origin[0], sv.protocol);
+			if (bits & U_ANGLE1)		MSG_WriteAngle(&buf, s->angles[0], sv.protocol);
+			if (bits & U_ORIGIN2)		MSG_WriteCoord(&buf, s->origin[1], sv.protocol);
+			if (bits & U_ANGLE2)		MSG_WriteAngle(&buf, s->angles[1], sv.protocol);
+			if (bits & U_ORIGIN3)		MSG_WriteCoord(&buf, s->origin[2], sv.protocol);
+			if (bits & U_ANGLE3)		MSG_WriteAngle(&buf, s->angles[2], sv.protocol);
+			if (bits & U_ALPHA)			MSG_WriteByte(&buf, s->alpha);
+			if (bits & U_SCALE)			MSG_WriteByte(&buf, s->scale);
+			if (bits & U_EFFECTS2)		MSG_WriteByte(&buf, s->effects >> 8);
+			if (bits & U_GLOWSIZE)		MSG_WriteByte(&buf, s->glowsize);
+			if (bits & U_GLOWCOLOR)		MSG_WriteByte(&buf, s->glowcolor);
+			if (bits & U_COLORMOD)		{int c = ((int)bound(0, s->colormod[0] * (7.0f / 32.0f), 7) << 5) | ((int)bound(0, s->colormod[1] * (7.0f / 32.0f), 7) << 2) | ((int)bound(0, s->colormod[2] * (3.0f / 32.0f), 3) << 0);MSG_WriteByte(&buf, c);}
+			if (bits & U_FRAME2)		MSG_WriteByte(&buf, s->frame >> 8);
+			if (bits & U_MODEL2)		MSG_WriteByte(&buf, s->modelindex >> 8);
+
+			// the nasty protocol
+			if ((bits & U_EXTEND1) && sv.protocol == PROTOCOL_NEHAHRAMOVIE)
+			{
+				if (s->effects & EF_FULLBRIGHT)
+				{
+					MSG_WriteFloat(&buf, 2); // QSG protocol version
+					MSG_WriteFloat(&buf, s->alpha <= 0 ? 0 : (s->alpha >= 255 ? 1 : s->alpha * (1.0f / 255.0f))); // alpha
+					MSG_WriteFloat(&buf, 1); // fullbright
+				}
+				else
+				{
+					MSG_WriteFloat(&buf, 1); // QSG protocol version
+					MSG_WriteFloat(&buf, s->alpha <= 0 ? 0 : (s->alpha >= 255 ? 1 : s->alpha * (1.0f / 255.0f))); // alpha
+				}
 			}
-		}
 
-		// if the commit is full, we're done this frame
-		if (msg->cursize + buf.cursize > maxsize)
-		{
-			// next frame we will continue where we left off
-			break;
+			// if the commit is full, we're done this frame
+			if (msg->cursize + buf.cursize > maxsize)
+			{
+				// next frame we will continue where we left off
+				break;
+			}
+			// write the message to the packet
+			SZ_Write(msg, buf.data, buf.cursize);
+			success = true;
+			ENTITYSIZEPROFILING_END(msg, s->number, bits);
 		}
-		// write the message to the packet
-		SZ_Write(msg, buf.data, buf.cursize);
-		success = true;
-		ENTITYSIZEPROFILING_END(msg, s->number);
 	}
 	return success;
 }
@@ -934,7 +962,7 @@ void EntityState_WriteFields(const entity_state_t *ent, sizebuf_t *msg, unsigned
 	}
 	else
 	{
-		// LordHavoc: have to write flags first, as they can modify protocol
+		// LadyHavoc: have to write flags first, as they can modify protocol
 		if (bits & E_FLAGS)
 			MSG_WriteByte(msg, ent->flags);
 		if (ent->flags & RENDER_LOWPRECISION)
@@ -1021,17 +1049,19 @@ void EntityState_WriteFields(const entity_state_t *ent, sizebuf_t *msg, unsigned
 
 void EntityState_WriteUpdate(const entity_state_t *ent, sizebuf_t *msg, const entity_state_t *delta)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	unsigned int bits;
-	ENTITYSIZEPROFILING_START(msg, ent->number);
 	if (ent->active == ACTIVE_NETWORK)
 	{
 		// entity is active, check for changes from the delta
 		if ((bits = EntityState_DeltaBits(delta, ent)))
 		{
 			// write the update number, bits, and fields
+			ENTITYSIZEPROFILING_START(msg, ent->number, bits);
 			MSG_WriteShort(msg, ent->number);
 			EntityState_WriteExtendBits(msg, bits);
 			EntityState_WriteFields(ent, msg, bits);
+			ENTITYSIZEPROFILING_END(msg, ent->number, bits);
 		}
 	}
 	else
@@ -1040,24 +1070,25 @@ void EntityState_WriteUpdate(const entity_state_t *ent, sizebuf_t *msg, const en
 		if (delta->active == ACTIVE_NETWORK)
 		{
 			// write the remove number
+			ENTITYSIZEPROFILING_START(msg, ent->number, 0);
 			MSG_WriteShort(msg, ent->number | 0x8000);
+			ENTITYSIZEPROFILING_END(msg, ent->number, 0);
 		}
 	}
-	ENTITYSIZEPROFILING_END(msg, ent->number);
 }
 
 int EntityState_ReadExtendBits(void)
 {
 	unsigned int bits;
-	bits = MSG_ReadByte();
+	bits = MSG_ReadByte(&cl_message);
 	if (bits & 0x00000080)
 	{
-		bits |= MSG_ReadByte() << 8;
+		bits |= MSG_ReadByte(&cl_message) << 8;
 		if (bits & 0x00008000)
 		{
-			bits |= MSG_ReadByte() << 16;
+			bits |= MSG_ReadByte(&cl_message) << 16;
 			if (bits & 0x00800000)
-				bits |= MSG_ReadByte() << 24;
+				bits |= MSG_ReadByte(&cl_message) << 24;
 		}
 	}
 	return bits;
@@ -1068,96 +1099,96 @@ void EntityState_ReadFields(entity_state_t *e, unsigned int bits)
 	if (cls.protocol == PROTOCOL_DARKPLACES2)
 	{
 		if (bits & E_ORIGIN1)
-			e->origin[0] = MSG_ReadCoord16i();
+			e->origin[0] = MSG_ReadCoord16i(&cl_message);
 		if (bits & E_ORIGIN2)
-			e->origin[1] = MSG_ReadCoord16i();
+			e->origin[1] = MSG_ReadCoord16i(&cl_message);
 		if (bits & E_ORIGIN3)
-			e->origin[2] = MSG_ReadCoord16i();
+			e->origin[2] = MSG_ReadCoord16i(&cl_message);
 	}
 	else
 	{
 		if (bits & E_FLAGS)
-			e->flags = MSG_ReadByte();
+			e->flags = MSG_ReadByte(&cl_message);
 		if (e->flags & RENDER_LOWPRECISION)
 		{
 			if (bits & E_ORIGIN1)
-				e->origin[0] = MSG_ReadCoord16i();
+				e->origin[0] = MSG_ReadCoord16i(&cl_message);
 			if (bits & E_ORIGIN2)
-				e->origin[1] = MSG_ReadCoord16i();
+				e->origin[1] = MSG_ReadCoord16i(&cl_message);
 			if (bits & E_ORIGIN3)
-				e->origin[2] = MSG_ReadCoord16i();
+				e->origin[2] = MSG_ReadCoord16i(&cl_message);
 		}
 		else
 		{
 			if (bits & E_ORIGIN1)
-				e->origin[0] = MSG_ReadCoord32f();
+				e->origin[0] = MSG_ReadCoord32f(&cl_message);
 			if (bits & E_ORIGIN2)
-				e->origin[1] = MSG_ReadCoord32f();
+				e->origin[1] = MSG_ReadCoord32f(&cl_message);
 			if (bits & E_ORIGIN3)
-				e->origin[2] = MSG_ReadCoord32f();
+				e->origin[2] = MSG_ReadCoord32f(&cl_message);
 		}
 	}
 	if ((cls.protocol == PROTOCOL_DARKPLACES5 || cls.protocol == PROTOCOL_DARKPLACES6) && !(e->flags & RENDER_LOWPRECISION))
 	{
 		if (bits & E_ANGLE1)
-			e->angles[0] = MSG_ReadAngle16i();
+			e->angles[0] = MSG_ReadAngle16i(&cl_message);
 		if (bits & E_ANGLE2)
-			e->angles[1] = MSG_ReadAngle16i();
+			e->angles[1] = MSG_ReadAngle16i(&cl_message);
 		if (bits & E_ANGLE3)
-			e->angles[2] = MSG_ReadAngle16i();
+			e->angles[2] = MSG_ReadAngle16i(&cl_message);
 	}
 	else
 	{
 		if (bits & E_ANGLE1)
-			e->angles[0] = MSG_ReadAngle8i();
+			e->angles[0] = MSG_ReadAngle8i(&cl_message);
 		if (bits & E_ANGLE2)
-			e->angles[1] = MSG_ReadAngle8i();
+			e->angles[1] = MSG_ReadAngle8i(&cl_message);
 		if (bits & E_ANGLE3)
-			e->angles[2] = MSG_ReadAngle8i();
+			e->angles[2] = MSG_ReadAngle8i(&cl_message);
 	}
 	if (bits & E_MODEL1)
-		e->modelindex = (e->modelindex & 0xFF00) | (unsigned int) MSG_ReadByte();
+		e->modelindex = (e->modelindex & 0xFF00) | (unsigned int) MSG_ReadByte(&cl_message);
 	if (bits & E_MODEL2)
-		e->modelindex = (e->modelindex & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8);
+		e->modelindex = (e->modelindex & 0x00FF) | ((unsigned int) MSG_ReadByte(&cl_message) << 8);
 	if (bits & E_FRAME1)
-		e->frame = (e->frame & 0xFF00) | (unsigned int) MSG_ReadByte();
+		e->frame = (e->frame & 0xFF00) | (unsigned int) MSG_ReadByte(&cl_message);
 	if (bits & E_FRAME2)
-		e->frame = (e->frame & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8);
+		e->frame = (e->frame & 0x00FF) | ((unsigned int) MSG_ReadByte(&cl_message) << 8);
 	if (bits & E_EFFECTS1)
-		e->effects = (e->effects & 0xFF00) | (unsigned int) MSG_ReadByte();
+		e->effects = (e->effects & 0xFF00) | (unsigned int) MSG_ReadByte(&cl_message);
 	if (bits & E_EFFECTS2)
-		e->effects = (e->effects & 0x00FF) | ((unsigned int) MSG_ReadByte() << 8);
+		e->effects = (e->effects & 0x00FF) | ((unsigned int) MSG_ReadByte(&cl_message) << 8);
 	if (bits & E_COLORMAP)
-		e->colormap = MSG_ReadByte();
+		e->colormap = MSG_ReadByte(&cl_message);
 	if (bits & E_SKIN)
-		e->skin = MSG_ReadByte();
+		e->skin = MSG_ReadByte(&cl_message);
 	if (bits & E_ALPHA)
-		e->alpha = MSG_ReadByte();
+		e->alpha = MSG_ReadByte(&cl_message);
 	if (bits & E_SCALE)
-		e->scale = MSG_ReadByte();
+		e->scale = MSG_ReadByte(&cl_message);
 	if (bits & E_GLOWSIZE)
-		e->glowsize = MSG_ReadByte();
+		e->glowsize = MSG_ReadByte(&cl_message);
 	if (bits & E_GLOWCOLOR)
-		e->glowcolor = MSG_ReadByte();
+		e->glowcolor = MSG_ReadByte(&cl_message);
 	if (cls.protocol == PROTOCOL_DARKPLACES2)
 		if (bits & E_FLAGS)
-			e->flags = MSG_ReadByte();
+			e->flags = MSG_ReadByte(&cl_message);
 	if (bits & E_TAGATTACHMENT)
 	{
-		e->tagentity = (unsigned short) MSG_ReadShort();
-		e->tagindex = MSG_ReadByte();
+		e->tagentity = (unsigned short) MSG_ReadShort(&cl_message);
+		e->tagindex = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E_LIGHT)
 	{
-		e->light[0] = (unsigned short) MSG_ReadShort();
-		e->light[1] = (unsigned short) MSG_ReadShort();
-		e->light[2] = (unsigned short) MSG_ReadShort();
-		e->light[3] = (unsigned short) MSG_ReadShort();
+		e->light[0] = (unsigned short) MSG_ReadShort(&cl_message);
+		e->light[1] = (unsigned short) MSG_ReadShort(&cl_message);
+		e->light[2] = (unsigned short) MSG_ReadShort(&cl_message);
+		e->light[3] = (unsigned short) MSG_ReadShort(&cl_message);
 	}
 	if (bits & E_LIGHTSTYLE)
-		e->lightstyle = MSG_ReadByte();
+		e->lightstyle = MSG_ReadByte(&cl_message);
 	if (bits & E_LIGHTPFLAGS)
-		e->lightpflags = MSG_ReadByte();
+		e->lightpflags = MSG_ReadByte(&cl_message);
 
 	if (developer_networkentities.integer >= 2)
 	{
@@ -1209,8 +1240,6 @@ void EntityState_ReadFields(entity_state_t *e, unsigned int bits)
 	}
 }
 
-extern void CL_NewFrameReceived(int num);
-
 // (client and server) allocates a new empty database
 entityframe_database_t *EntityFrame_AllocDatabase(mempool_t *mempool)
 {
@@ -1383,6 +1412,7 @@ void EntityFrame_AddFrame_Server(entityframe_database_t *d, vec3_t eye, int fram
 // (server) writes a frame to network stream
 qboolean EntityFrame_WriteFrame(sizebuf_t *msg, int maxsize, entityframe_database_t *d, int numstates, const entity_state_t **states, int viewentnum)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	int i, onum, number;
 	entity_frame_t *o = &d->deltaframe;
 	const entity_state_t *ent, *delta;
@@ -1467,20 +1497,20 @@ void EntityFrame_CL_ReadFrame(void)
 
 	// read the frame header info
 	f->time = cl.mtime[0];
-	number = MSG_ReadLong();
-	f->framenum = MSG_ReadLong();
+	number = MSG_ReadLong(&cl_message);
+	f->framenum = MSG_ReadLong(&cl_message);
 	CL_NewFrameReceived(f->framenum);
-	f->eye[0] = MSG_ReadFloat();
-	f->eye[1] = MSG_ReadFloat();
-	f->eye[2] = MSG_ReadFloat();
+	f->eye[0] = MSG_ReadFloat(&cl_message);
+	f->eye[1] = MSG_ReadFloat(&cl_message);
+	f->eye[2] = MSG_ReadFloat(&cl_message);
 	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 && !msg_badread)
+	while ((number = (unsigned short) MSG_ReadShort(&cl_message)) != 0xFFFF && !cl_message.badread)
 	{
-		if (msg_badread)
+		if (cl_message.badread)
 			Host_Error("EntityFrame_Read: read error");
 		removed = number & 0x8000;
 		number &= 0x7FFF;
@@ -1670,10 +1700,12 @@ int EntityFrame4_AckFrame(entityframe4_database_t *d, int framenum, int servermo
 		// reset reference, but leave commits alone
 		d->referenceframenum = -1;
 		for (i = 0;i < d->maxreferenceentities;i++)
+		{
 			d->referenceentity[i] = defaultstate;
 		// if this is the server, remove commits
 			for (i = 0, commit = d->commit;i < MAX_ENTITY_HISTORY;i++, commit++)
 				commit->numentities = 0;
+		}
 		found = true;
 	}
 	else if (d->referenceframenum == framenum)
@@ -1732,12 +1764,12 @@ void EntityFrame4_CL_ReadFrame(void)
 		cl.entitydatabase4 = EntityFrame4_AllocDatabase(cls.levelmempool);
 	d = cl.entitydatabase4;
 	// read the number of the frame this refers to
-	referenceframenum = MSG_ReadLong();
+	referenceframenum = MSG_ReadLong(&cl_message);
 	// read the number of this frame
-	framenum = MSG_ReadLong();
+	framenum = MSG_ReadLong(&cl_message);
 	CL_NewFrameReceived(framenum);
 	// read the start number
-	enumber = (unsigned short) MSG_ReadShort();
+	enumber = (unsigned short) MSG_ReadShort(&cl_message);
 	if (developer_networkentities.integer >= 10)
 	{
 		Con_Printf("recv svc_entities num:%i ref:%i database: ref:%i commits:", framenum, referenceframenum, d->referenceframenum);
@@ -1767,18 +1799,18 @@ void EntityFrame4_CL_ReadFrame(void)
 		skip = true;
 	}
 	done = false;
-	while (!done && !msg_badread)
+	while (!done && !cl_message.badread)
 	{
 		// read the number of the modified entity
 		// (gaps will be copied unmodified)
-		n = (unsigned short)MSG_ReadShort();
+		n = (unsigned short)MSG_ReadShort(&cl_message);
 		if (n == 0x8000)
 		{
 			// no more entities in this update, but we still need to copy the
 			// rest of the reference entities (final gap)
 			done = true;
 			// read end of range number, then process normally
-			n = (unsigned short)MSG_ReadShort();
+			n = (unsigned short)MSG_ReadShort(&cl_message);
 		}
 		// high bit means it's a remove message
 		cnumber = n & 0x7FFF;
@@ -1858,6 +1890,7 @@ void EntityFrame4_CL_ReadFrame(void)
 
 qboolean EntityFrame4_WriteFrame(sizebuf_t *msg, int maxsize, entityframe4_database_t *d, int numstates, const entity_state_t **states)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	const entity_state_t *e, *s;
 	entity_state_t inactiveentitystate;
 	int i, n, startnumber;
@@ -2057,14 +2090,43 @@ static int EntityState5_Priority(entityframe5_database_t *d, int stateindex)
 	return bound(1, priority, ENTITYFRAME5_PRIORITYLEVELS - 1);
 }
 
+static double anim_reducetime(double t, double frameduration, double maxtime)
+{
+	if(t < 0) // clamp to non-negative
+		return 0;
+	if(t <= maxtime) // time can be represented normally
+		return t;
+	if(frameduration == 0) // don't like dividing by zero
+		return t;
+	if(maxtime <= 2 * frameduration) // if two frames don't fit, we better not do this
+		return t;
+	t -= frameduration * ceil((t - maxtime) / frameduration);
+	// now maxtime - frameduration < t <= maxtime
+	return t;
+}
+
+// see VM_SV_frameduration
+static double anim_frameduration(dp_model_t *model, int framenum)
+{
+	if (!model || !model->animscenes || framenum < 0 || framenum >= model->numframes)
+		return 0;
+	if(model->animscenes[framenum].framerate)
+		return model->animscenes[framenum].framecount / model->animscenes[framenum].framerate;
+	return 0;
+}
+
 void EntityState5_WriteUpdate(int number, const entity_state_t *s, int changedbits, sizebuf_t *msg)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	unsigned int bits = 0;
 	//dp_model_t *model;
-	ENTITYSIZEPROFILING_START(msg, s->number);
 
 	if (s->active != ACTIVE_NETWORK)
+	{
+		ENTITYSIZEPROFILING_START(msg, s->number, 0);
 		MSG_WriteShort(msg, number | 0x8000);
+		ENTITYSIZEPROFILING_END(msg, s->number, 0);
+	}
 	else
 	{
 		if (PRVM_serveredictfunction((&prog->edicts[s->number]), SendEntity))
@@ -2102,194 +2164,203 @@ void EntityState5_WriteUpdate(int number, const entity_state_t *s, int changedbi
 			bits |= E5_EXTEND2;
 		if (bits >= 16777216)
 			bits |= E5_EXTEND3;
-		MSG_WriteShort(msg, number);
-		MSG_WriteByte(msg, bits & 0xFF);
-		if (bits & E5_EXTEND1)
-			MSG_WriteByte(msg, (bits >> 8) & 0xFF);
-		if (bits & E5_EXTEND2)
-			MSG_WriteByte(msg, (bits >> 16) & 0xFF);
-		if (bits & E5_EXTEND3)
-			MSG_WriteByte(msg, (bits >> 24) & 0xFF);
-		if (bits & E5_FLAGS)
-			MSG_WriteByte(msg, s->flags);
-		if (bits & E5_ORIGIN)
 		{
-			if (bits & E5_ORIGIN32)
+			ENTITYSIZEPROFILING_START(msg, s->number, bits);
+			MSG_WriteShort(msg, number);
+			MSG_WriteByte(msg, bits & 0xFF);
+			if (bits & E5_EXTEND1)
+				MSG_WriteByte(msg, (bits >> 8) & 0xFF);
+			if (bits & E5_EXTEND2)
+				MSG_WriteByte(msg, (bits >> 16) & 0xFF);
+			if (bits & E5_EXTEND3)
+				MSG_WriteByte(msg, (bits >> 24) & 0xFF);
+			if (bits & E5_FLAGS)
+				MSG_WriteByte(msg, s->flags);
+			if (bits & E5_ORIGIN)
 			{
-				MSG_WriteCoord32f(msg, s->origin[0]);
-				MSG_WriteCoord32f(msg, s->origin[1]);
-				MSG_WriteCoord32f(msg, s->origin[2]);
+				if (bits & E5_ORIGIN32)
+				{
+					MSG_WriteCoord32f(msg, s->origin[0]);
+					MSG_WriteCoord32f(msg, s->origin[1]);
+					MSG_WriteCoord32f(msg, s->origin[2]);
+				}
+				else
+				{
+					MSG_WriteCoord13i(msg, s->origin[0]);
+					MSG_WriteCoord13i(msg, s->origin[1]);
+					MSG_WriteCoord13i(msg, s->origin[2]);
+				}
 			}
-			else
+			if (bits & E5_ANGLES)
+			{
+				if (bits & E5_ANGLES16)
+				{
+					MSG_WriteAngle16i(msg, s->angles[0]);
+					MSG_WriteAngle16i(msg, s->angles[1]);
+					MSG_WriteAngle16i(msg, s->angles[2]);
+				}
+				else
+				{
+					MSG_WriteAngle8i(msg, s->angles[0]);
+					MSG_WriteAngle8i(msg, s->angles[1]);
+					MSG_WriteAngle8i(msg, s->angles[2]);
+				}
+			}
+			if (bits & E5_MODEL)
 			{
-				MSG_WriteCoord13i(msg, s->origin[0]);
-				MSG_WriteCoord13i(msg, s->origin[1]);
-				MSG_WriteCoord13i(msg, s->origin[2]);
+				if (bits & E5_MODEL16)
+					MSG_WriteShort(msg, s->modelindex);
+				else
+					MSG_WriteByte(msg, s->modelindex);
 			}
-		}
-		if (bits & E5_ANGLES)
-		{
-			if (bits & E5_ANGLES16)
+			if (bits & E5_FRAME)
 			{
-				MSG_WriteAngle16i(msg, s->angles[0]);
-				MSG_WriteAngle16i(msg, s->angles[1]);
-				MSG_WriteAngle16i(msg, s->angles[2]);
+				if (bits & E5_FRAME16)
+					MSG_WriteShort(msg, s->frame);
+				else
+					MSG_WriteByte(msg, s->frame);
 			}
-			else
+			if (bits & E5_SKIN)
+				MSG_WriteByte(msg, s->skin);
+			if (bits & E5_EFFECTS)
 			{
-				MSG_WriteAngle8i(msg, s->angles[0]);
-				MSG_WriteAngle8i(msg, s->angles[1]);
-				MSG_WriteAngle8i(msg, s->angles[2]);
+				if (bits & E5_EFFECTS32)
+					MSG_WriteLong(msg, s->effects);
+				else if (bits & E5_EFFECTS16)
+					MSG_WriteShort(msg, s->effects);
+				else
+					MSG_WriteByte(msg, s->effects);
 			}
-		}
-		if (bits & E5_MODEL)
-		{
-			if (bits & E5_MODEL16)
-				MSG_WriteShort(msg, s->modelindex);
-			else
-				MSG_WriteByte(msg, s->modelindex);
-		}
-		if (bits & E5_FRAME)
-		{
-			if (bits & E5_FRAME16)
-				MSG_WriteShort(msg, s->frame);
-			else
-				MSG_WriteByte(msg, s->frame);
-		}
-		if (bits & E5_SKIN)
-			MSG_WriteByte(msg, s->skin);
-		if (bits & E5_EFFECTS)
-		{
-			if (bits & E5_EFFECTS32)
-				MSG_WriteLong(msg, s->effects);
-			else if (bits & E5_EFFECTS16)
-				MSG_WriteShort(msg, s->effects);
-			else
-				MSG_WriteByte(msg, s->effects);
-		}
-		if (bits & E5_ALPHA)
-			MSG_WriteByte(msg, s->alpha);
-		if (bits & E5_SCALE)
-			MSG_WriteByte(msg, s->scale);
-		if (bits & E5_COLORMAP)
-			MSG_WriteByte(msg, s->colormap);
-		if (bits & E5_ATTACHMENT)
-		{
-			MSG_WriteShort(msg, s->tagentity);
-			MSG_WriteByte(msg, s->tagindex);
-		}
-		if (bits & E5_LIGHT)
-		{
-			MSG_WriteShort(msg, s->light[0]);
-			MSG_WriteShort(msg, s->light[1]);
-			MSG_WriteShort(msg, s->light[2]);
-			MSG_WriteShort(msg, s->light[3]);
-			MSG_WriteByte(msg, s->lightstyle);
-			MSG_WriteByte(msg, s->lightpflags);
-		}
-		if (bits & E5_GLOW)
-		{
-			MSG_WriteByte(msg, s->glowsize);
-			MSG_WriteByte(msg, s->glowcolor);
-		}
-		if (bits & E5_COLORMOD)
-		{
-			MSG_WriteByte(msg, s->colormod[0]);
-			MSG_WriteByte(msg, s->colormod[1]);
-			MSG_WriteByte(msg, s->colormod[2]);
-		}
-		if (bits & E5_GLOWMOD)
-		{
-			MSG_WriteByte(msg, s->glowmod[0]);
-			MSG_WriteByte(msg, s->glowmod[1]);
-			MSG_WriteByte(msg, s->glowmod[2]);
-		}
-		if (bits & E5_COMPLEXANIMATION)
-		{
-			if (s->skeletonobject.model && s->skeletonobject.relativetransforms)
+			if (bits & E5_ALPHA)
+				MSG_WriteByte(msg, s->alpha);
+			if (bits & E5_SCALE)
+				MSG_WriteByte(msg, s->scale);
+			if (bits & E5_COLORMAP)
+				MSG_WriteByte(msg, s->colormap);
+			if (bits & E5_ATTACHMENT)
 			{
-				int numbones = s->skeletonobject.model->num_bones;
-				int bonenum;
-				short pose6s[6];
-				MSG_WriteByte(msg, 4);
-				MSG_WriteShort(msg, s->modelindex);
-				MSG_WriteByte(msg, numbones);
-				for (bonenum = 0;bonenum < numbones;bonenum++)
-				{
-					Matrix4x4_ToBonePose6s(s->skeletonobject.relativetransforms + bonenum, 64, pose6s);
-					MSG_WriteShort(msg, pose6s[0]);
-					MSG_WriteShort(msg, pose6s[1]);
-					MSG_WriteShort(msg, pose6s[2]);
-					MSG_WriteShort(msg, pose6s[3]);
-					MSG_WriteShort(msg, pose6s[4]);
-					MSG_WriteShort(msg, pose6s[5]);
-				}
+				MSG_WriteShort(msg, s->tagentity);
+				MSG_WriteByte(msg, s->tagindex);
 			}
-			else if (s->framegroupblend[3].lerp > 0)
+			if (bits & E5_LIGHT)
 			{
-				MSG_WriteByte(msg, 3);
-				MSG_WriteShort(msg, s->framegroupblend[0].frame);
-				MSG_WriteShort(msg, s->framegroupblend[1].frame);
-				MSG_WriteShort(msg, s->framegroupblend[2].frame);
-				MSG_WriteShort(msg, s->framegroupblend[3].frame);
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[0].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[1].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[2].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[3].start) * 1000.0));
-				MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[2].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[3].lerp * 255.0f);
+				MSG_WriteShort(msg, s->light[0]);
+				MSG_WriteShort(msg, s->light[1]);
+				MSG_WriteShort(msg, s->light[2]);
+				MSG_WriteShort(msg, s->light[3]);
+				MSG_WriteByte(msg, s->lightstyle);
+				MSG_WriteByte(msg, s->lightpflags);
 			}
-			else if (s->framegroupblend[2].lerp > 0)
+			if (bits & E5_GLOW)
 			{
-				MSG_WriteByte(msg, 2);
-				MSG_WriteShort(msg, s->framegroupblend[0].frame);
-				MSG_WriteShort(msg, s->framegroupblend[1].frame);
-				MSG_WriteShort(msg, s->framegroupblend[2].frame);
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[0].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[1].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[2].start) * 1000.0));
-				MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[2].lerp * 255.0f);
+				MSG_WriteByte(msg, s->glowsize);
+				MSG_WriteByte(msg, s->glowcolor);
 			}
-			else if (s->framegroupblend[1].lerp > 0)
+			if (bits & E5_COLORMOD)
 			{
-				MSG_WriteByte(msg, 1);
-				MSG_WriteShort(msg, s->framegroupblend[0].frame);
-				MSG_WriteShort(msg, s->framegroupblend[1].frame);
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[0].start) * 1000.0));
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[1].start) * 1000.0));
-				MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
-				MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
+				MSG_WriteByte(msg, s->colormod[0]);
+				MSG_WriteByte(msg, s->colormod[1]);
+				MSG_WriteByte(msg, s->colormod[2]);
 			}
-			else
+			if (bits & E5_GLOWMOD)
 			{
-				MSG_WriteByte(msg, 0);
-				MSG_WriteShort(msg, s->framegroupblend[0].frame);
-				MSG_WriteShort(msg, (int)((sv.time - s->framegroupblend[0].start) * 1000.0));
+				MSG_WriteByte(msg, s->glowmod[0]);
+				MSG_WriteByte(msg, s->glowmod[1]);
+				MSG_WriteByte(msg, s->glowmod[2]);
+			}
+			if (bits & E5_COMPLEXANIMATION)
+			{
+				if (s->skeletonobject.model && s->skeletonobject.relativetransforms)
+				{
+					int numbones = s->skeletonobject.model->num_bones;
+					int bonenum;
+					short pose7s[7];
+					MSG_WriteByte(msg, 4);
+					MSG_WriteShort(msg, s->modelindex);
+					MSG_WriteByte(msg, numbones);
+					for (bonenum = 0;bonenum < numbones;bonenum++)
+					{
+						Matrix4x4_ToBonePose7s(s->skeletonobject.relativetransforms + bonenum, 64, pose7s);
+						MSG_WriteShort(msg, pose7s[0]);
+						MSG_WriteShort(msg, pose7s[1]);
+						MSG_WriteShort(msg, pose7s[2]);
+						MSG_WriteShort(msg, pose7s[3]);
+						MSG_WriteShort(msg, pose7s[4]);
+						MSG_WriteShort(msg, pose7s[5]);
+						MSG_WriteShort(msg, pose7s[6]);
+					}
+				}
+				else
+				{
+					dp_model_t *model = SV_GetModelByIndex(s->modelindex);
+					if (s->framegroupblend[3].lerp > 0)
+					{
+						MSG_WriteByte(msg, 3);
+						MSG_WriteShort(msg, s->framegroupblend[0].frame);
+						MSG_WriteShort(msg, s->framegroupblend[1].frame);
+						MSG_WriteShort(msg, s->framegroupblend[2].frame);
+						MSG_WriteShort(msg, s->framegroupblend[3].frame);
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[0].start, anim_frameduration(model, s->framegroupblend[0].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[1].start, anim_frameduration(model, s->framegroupblend[1].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[2].start, anim_frameduration(model, s->framegroupblend[2].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[3].start, anim_frameduration(model, s->framegroupblend[3].frame), 65.535) * 1000.0));
+						MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[2].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[3].lerp * 255.0f);
+					}
+					else if (s->framegroupblend[2].lerp > 0)
+					{
+						MSG_WriteByte(msg, 2);
+						MSG_WriteShort(msg, s->framegroupblend[0].frame);
+						MSG_WriteShort(msg, s->framegroupblend[1].frame);
+						MSG_WriteShort(msg, s->framegroupblend[2].frame);
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[0].start, anim_frameduration(model, s->framegroupblend[0].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[1].start, anim_frameduration(model, s->framegroupblend[1].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[2].start, anim_frameduration(model, s->framegroupblend[2].frame), 65.535) * 1000.0));
+						MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[2].lerp * 255.0f);
+					}
+					else if (s->framegroupblend[1].lerp > 0)
+					{
+						MSG_WriteByte(msg, 1);
+						MSG_WriteShort(msg, s->framegroupblend[0].frame);
+						MSG_WriteShort(msg, s->framegroupblend[1].frame);
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[0].start, anim_frameduration(model, s->framegroupblend[0].frame), 65.535) * 1000.0));
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[1].start, anim_frameduration(model, s->framegroupblend[1].frame), 65.535) * 1000.0));
+						MSG_WriteByte(msg, s->framegroupblend[0].lerp * 255.0f);
+						MSG_WriteByte(msg, s->framegroupblend[1].lerp * 255.0f);
+					}
+					else
+					{
+						MSG_WriteByte(msg, 0);
+						MSG_WriteShort(msg, s->framegroupblend[0].frame);
+						MSG_WriteShort(msg, (int)(anim_reducetime(sv.time - s->framegroupblend[0].start, anim_frameduration(model, s->framegroupblend[0].frame), 65.535) * 1000.0));
+					}
+				}
 			}
+			if (bits & E5_TRAILEFFECTNUM)
+				MSG_WriteShort(msg, s->traileffectnum);
+			ENTITYSIZEPROFILING_END(msg, s->number, bits);
 		}
 	}
-
-	ENTITYSIZEPROFILING_END(msg, s->number);
 }
 
-extern dp_model_t *CL_GetModelByIndex(int modelindex);
-
 static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 {
 	int bits;
-	bits = MSG_ReadByte();
+	int startoffset = cl_message.readcount;
+	int bytes = 0;
+	bits = MSG_ReadByte(&cl_message);
 	if (bits & E5_EXTEND1)
 	{
-		bits |= MSG_ReadByte() << 8;
+		bits |= MSG_ReadByte(&cl_message) << 8;
 		if (bits & E5_EXTEND2)
 		{
-			bits |= MSG_ReadByte() << 16;
+			bits |= MSG_ReadByte(&cl_message) << 16;
 			if (bits & E5_EXTEND3)
-				bits |= MSG_ReadByte() << 24;
+				bits |= MSG_ReadByte(&cl_message) << 24;
 		}
 	}
 	if (bits & E5_FULLUPDATE)
@@ -2298,98 +2369,98 @@ static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 		s->active = ACTIVE_NETWORK;
 	}
 	if (bits & E5_FLAGS)
-		s->flags = MSG_ReadByte();
+		s->flags = MSG_ReadByte(&cl_message);
 	if (bits & E5_ORIGIN)
 	{
 		if (bits & E5_ORIGIN32)
 		{
-			s->origin[0] = MSG_ReadCoord32f();
-			s->origin[1] = MSG_ReadCoord32f();
-			s->origin[2] = MSG_ReadCoord32f();
+			s->origin[0] = MSG_ReadCoord32f(&cl_message);
+			s->origin[1] = MSG_ReadCoord32f(&cl_message);
+			s->origin[2] = MSG_ReadCoord32f(&cl_message);
 		}
 		else
 		{
-			s->origin[0] = MSG_ReadCoord13i();
-			s->origin[1] = MSG_ReadCoord13i();
-			s->origin[2] = MSG_ReadCoord13i();
+			s->origin[0] = MSG_ReadCoord13i(&cl_message);
+			s->origin[1] = MSG_ReadCoord13i(&cl_message);
+			s->origin[2] = MSG_ReadCoord13i(&cl_message);
 		}
 	}
 	if (bits & E5_ANGLES)
 	{
 		if (bits & E5_ANGLES16)
 		{
-			s->angles[0] = MSG_ReadAngle16i();
-			s->angles[1] = MSG_ReadAngle16i();
-			s->angles[2] = MSG_ReadAngle16i();
+			s->angles[0] = MSG_ReadAngle16i(&cl_message);
+			s->angles[1] = MSG_ReadAngle16i(&cl_message);
+			s->angles[2] = MSG_ReadAngle16i(&cl_message);
 		}
 		else
 		{
-			s->angles[0] = MSG_ReadAngle8i();
-			s->angles[1] = MSG_ReadAngle8i();
-			s->angles[2] = MSG_ReadAngle8i();
+			s->angles[0] = MSG_ReadAngle8i(&cl_message);
+			s->angles[1] = MSG_ReadAngle8i(&cl_message);
+			s->angles[2] = MSG_ReadAngle8i(&cl_message);
 		}
 	}
 	if (bits & E5_MODEL)
 	{
 		if (bits & E5_MODEL16)
-			s->modelindex = (unsigned short) MSG_ReadShort();
+			s->modelindex = (unsigned short) MSG_ReadShort(&cl_message);
 		else
-			s->modelindex = MSG_ReadByte();
+			s->modelindex = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_FRAME)
 	{
 		if (bits & E5_FRAME16)
-			s->frame = (unsigned short) MSG_ReadShort();
+			s->frame = (unsigned short) MSG_ReadShort(&cl_message);
 		else
-			s->frame = MSG_ReadByte();
+			s->frame = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_SKIN)
-		s->skin = MSG_ReadByte();
+		s->skin = MSG_ReadByte(&cl_message);
 	if (bits & E5_EFFECTS)
 	{
 		if (bits & E5_EFFECTS32)
-			s->effects = (unsigned int) MSG_ReadLong();
+			s->effects = (unsigned int) MSG_ReadLong(&cl_message);
 		else if (bits & E5_EFFECTS16)
-			s->effects = (unsigned short) MSG_ReadShort();
+			s->effects = (unsigned short) MSG_ReadShort(&cl_message);
 		else
-			s->effects = MSG_ReadByte();
+			s->effects = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_ALPHA)
-		s->alpha = MSG_ReadByte();
+		s->alpha = MSG_ReadByte(&cl_message);
 	if (bits & E5_SCALE)
-		s->scale = MSG_ReadByte();
+		s->scale = MSG_ReadByte(&cl_message);
 	if (bits & E5_COLORMAP)
-		s->colormap = MSG_ReadByte();
+		s->colormap = MSG_ReadByte(&cl_message);
 	if (bits & E5_ATTACHMENT)
 	{
-		s->tagentity = (unsigned short) MSG_ReadShort();
-		s->tagindex = MSG_ReadByte();
+		s->tagentity = (unsigned short) MSG_ReadShort(&cl_message);
+		s->tagindex = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_LIGHT)
 	{
-		s->light[0] = (unsigned short) MSG_ReadShort();
-		s->light[1] = (unsigned short) MSG_ReadShort();
-		s->light[2] = (unsigned short) MSG_ReadShort();
-		s->light[3] = (unsigned short) MSG_ReadShort();
-		s->lightstyle = MSG_ReadByte();
-		s->lightpflags = MSG_ReadByte();
+		s->light[0] = (unsigned short) MSG_ReadShort(&cl_message);
+		s->light[1] = (unsigned short) MSG_ReadShort(&cl_message);
+		s->light[2] = (unsigned short) MSG_ReadShort(&cl_message);
+		s->light[3] = (unsigned short) MSG_ReadShort(&cl_message);
+		s->lightstyle = MSG_ReadByte(&cl_message);
+		s->lightpflags = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_GLOW)
 	{
-		s->glowsize = MSG_ReadByte();
-		s->glowcolor = MSG_ReadByte();
+		s->glowsize = MSG_ReadByte(&cl_message);
+		s->glowcolor = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_COLORMOD)
 	{
-		s->colormod[0] = MSG_ReadByte();
-		s->colormod[1] = MSG_ReadByte();
-		s->colormod[2] = MSG_ReadByte();
+		s->colormod[0] = MSG_ReadByte(&cl_message);
+		s->colormod[1] = MSG_ReadByte(&cl_message);
+		s->colormod[2] = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_GLOWMOD)
 	{
-		s->glowmod[0] = MSG_ReadByte();
-		s->glowmod[1] = MSG_ReadByte();
-		s->glowmod[2] = MSG_ReadByte();
+		s->glowmod[0] = MSG_ReadByte(&cl_message);
+		s->glowmod[1] = MSG_ReadByte(&cl_message);
+		s->glowmod[2] = MSG_ReadByte(&cl_message);
 	}
 	if (bits & E5_COMPLEXANIMATION)
 	{
@@ -2399,16 +2470,16 @@ static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 		int type;
 		int bonenum;
 		int numbones;
-		short pose6s[6];
-		type = MSG_ReadByte();
+		short pose7s[7];
+		type = MSG_ReadByte(&cl_message);
 		switch(type)
 		{
 		case 0:
-			s->framegroupblend[0].frame = MSG_ReadShort();
+			s->framegroupblend[0].frame = MSG_ReadShort(&cl_message);
 			s->framegroupblend[1].frame = 0;
 			s->framegroupblend[2].frame = 0;
 			s->framegroupblend[3].frame = 0;
-			s->framegroupblend[0].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
+			s->framegroupblend[0].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
 			s->framegroupblend[1].start = 0;
 			s->framegroupblend[2].start = 0;
 			s->framegroupblend[3].start = 0;
@@ -2418,72 +2489,73 @@ static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 			s->framegroupblend[3].lerp = 0;
 			break;
 		case 1:
-			s->framegroupblend[0].frame = MSG_ReadShort();
-			s->framegroupblend[1].frame = MSG_ReadShort();
+			s->framegroupblend[0].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[1].frame = MSG_ReadShort(&cl_message);
 			s->framegroupblend[2].frame = 0;
 			s->framegroupblend[3].frame = 0;
-			s->framegroupblend[0].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[1].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
+			s->framegroupblend[0].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[1].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
 			s->framegroupblend[2].start = 0;
 			s->framegroupblend[3].start = 0;
-			s->framegroupblend[0].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[1].lerp = MSG_ReadByte() * (1.0f / 255.0f);
+			s->framegroupblend[0].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[1].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
 			s->framegroupblend[2].lerp = 0;
 			s->framegroupblend[3].lerp = 0;
 			break;
 		case 2:
-			s->framegroupblend[0].frame = MSG_ReadShort();
-			s->framegroupblend[1].frame = MSG_ReadShort();
-			s->framegroupblend[2].frame = MSG_ReadShort();
+			s->framegroupblend[0].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[1].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[2].frame = MSG_ReadShort(&cl_message);
 			s->framegroupblend[3].frame = 0;
-			s->framegroupblend[0].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[1].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[2].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
+			s->framegroupblend[0].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[1].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[2].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
 			s->framegroupblend[3].start = 0;
-			s->framegroupblend[0].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[1].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[2].lerp = MSG_ReadByte() * (1.0f / 255.0f);
+			s->framegroupblend[0].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[1].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[2].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
 			s->framegroupblend[3].lerp = 0;
 			break;
 		case 3:
-			s->framegroupblend[0].frame = MSG_ReadShort();
-			s->framegroupblend[1].frame = MSG_ReadShort();
-			s->framegroupblend[2].frame = MSG_ReadShort();
-			s->framegroupblend[3].frame = MSG_ReadShort();
-			s->framegroupblend[0].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[1].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[2].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[3].start = cl.time - (short)MSG_ReadShort() * (1.0f / 1000.0f);
-			s->framegroupblend[0].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[1].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[2].lerp = MSG_ReadByte() * (1.0f / 255.0f);
-			s->framegroupblend[3].lerp = MSG_ReadByte() * (1.0f / 255.0f);
+			s->framegroupblend[0].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[1].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[2].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[3].frame = MSG_ReadShort(&cl_message);
+			s->framegroupblend[0].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[1].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[2].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[3].start = cl.time - (unsigned short)MSG_ReadShort(&cl_message) * (1.0f / 1000.0f);
+			s->framegroupblend[0].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[1].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[2].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
+			s->framegroupblend[3].lerp = MSG_ReadByte(&cl_message) * (1.0f / 255.0f);
 			break;
 		case 4:
 			if (!cl.engineskeletonobjects)
 				cl.engineskeletonobjects = (skeleton_t *) Mem_Alloc(cls.levelmempool, sizeof(*cl.engineskeletonobjects) * MAX_EDICTS);
 			skeleton = &cl.engineskeletonobjects[number];
-			modelindex = MSG_ReadShort();
+			modelindex = MSG_ReadShort(&cl_message);
 			model = CL_GetModelByIndex(modelindex);
-			numbones = MSG_ReadByte();
+			numbones = MSG_ReadByte(&cl_message);
 			if (model && numbones != model->num_bones)
 				Host_Error("E5_COMPLEXANIMATION: model has different number of bones than network packet describes\n");
 			if (!skeleton->relativetransforms || skeleton->model != model)
 			{
 				skeleton->model = model;
-				skeleton->relativetransforms = (matrix4x4_t *) Mem_Realloc(cls.levelmempool, skeleton->relativetransforms, sizeof(*skeleton->relativetransforms) * skeleton->model->num_bones);
-				for (bonenum = 0;bonenum < model->num_bones;bonenum++)
+				skeleton->relativetransforms = (matrix4x4_t *) Mem_Realloc(cls.levelmempool, skeleton->relativetransforms, sizeof(*skeleton->relativetransforms) * numbones);
+				for (bonenum = 0;bonenum < numbones;bonenum++)
 					skeleton->relativetransforms[bonenum] = identitymatrix;
 			}
 			for (bonenum = 0;bonenum < numbones;bonenum++)
 			{
-				pose6s[0] = (short)MSG_ReadShort();
-				pose6s[1] = (short)MSG_ReadShort();
-				pose6s[2] = (short)MSG_ReadShort();
-				pose6s[3] = (short)MSG_ReadShort();
-				pose6s[4] = (short)MSG_ReadShort();
-				pose6s[5] = (short)MSG_ReadShort();
-				Matrix4x4_FromBonePose6s(skeleton->relativetransforms + bonenum, 1.0f / 64.0f, pose6s);
+				pose7s[0] = (short)MSG_ReadShort(&cl_message);
+				pose7s[1] = (short)MSG_ReadShort(&cl_message);
+				pose7s[2] = (short)MSG_ReadShort(&cl_message);
+				pose7s[3] = (short)MSG_ReadShort(&cl_message);
+				pose7s[4] = (short)MSG_ReadShort(&cl_message);
+				pose7s[5] = (short)MSG_ReadShort(&cl_message);
+				pose7s[6] = (short)MSG_ReadShort(&cl_message);
+				Matrix4x4_FromBonePose7s(skeleton->relativetransforms + bonenum, 1.0f / 64.0f, pose7s);
 			}
 			s->skeletonobject = *skeleton;
 			break;
@@ -2492,11 +2564,14 @@ static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 			break;
 		}
 	}
+	if (bits & E5_TRAILEFFECTNUM)
+		s->traileffectnum = (unsigned short) MSG_ReadShort(&cl_message);
 
 
+	bytes = cl_message.readcount - startoffset;
 	if (developer_networkentities.integer >= 2)
 	{
-		Con_Printf("ReadFields e%i", number);
+		Con_Printf("ReadFields e%i (%i bytes)", number, bytes);
 
 		if (bits & E5_ORIGIN)
 			Con_Printf(" E5_ORIGIN %f %f %f", s->origin[0], s->origin[1], s->origin[2]);
@@ -2549,6 +2624,10 @@ static void EntityState5_ReadUpdate(entity_state_t *s, int number)
 			Con_Printf(" E5_COLORMOD %f:%f:%f", s->colormod[0] / 32.0f, s->colormod[1] / 32.0f, s->colormod[2] / 32.0f);
 		if (bits & E5_GLOWMOD)
 			Con_Printf(" E5_GLOWMOD %f:%f:%f", s->glowmod[0] / 32.0f, s->glowmod[1] / 32.0f, s->glowmod[2] / 32.0f);
+		if (bits & E5_COMPLEXANIMATION)
+			Con_Printf(" E5_COMPLEXANIMATION");
+		if (bits & E5_TRAILEFFECTNUM)
+			Con_Printf(" E5_TRAILEFFECTNUM %i", s->traileffectnum);
 		Con_Print("\n");
 	}
 }
@@ -2591,7 +2670,27 @@ static int EntityState5_DeltaBits(const entity_state_t *o, const entity_state_t
 		if (o->glowmod[0] != n->glowmod[0] || o->glowmod[1] != n->glowmod[1] || o->glowmod[2] != n->glowmod[2])
 			bits |= E5_GLOWMOD;
 		if (n->flags & RENDER_COMPLEXANIMATION)
-			bits |= E5_COMPLEXANIMATION;
+		{
+			if ((o->skeletonobject.model && o->skeletonobject.relativetransforms) != (n->skeletonobject.model && n->skeletonobject.relativetransforms))
+			{
+				bits |= E5_COMPLEXANIMATION;
+			}
+			else if (o->skeletonobject.model && o->skeletonobject.relativetransforms)
+			{
+				if(o->modelindex != n->modelindex)
+					bits |= E5_COMPLEXANIMATION;
+				else if(o->skeletonobject.model->num_bones != n->skeletonobject.model->num_bones)
+					bits |= E5_COMPLEXANIMATION;
+				else if(memcmp(o->skeletonobject.relativetransforms, n->skeletonobject.relativetransforms, o->skeletonobject.model->num_bones * sizeof(*o->skeletonobject.relativetransforms)))
+					bits |= E5_COMPLEXANIMATION;
+			}
+			else if (memcmp(o->framegroupblend, n->framegroupblend, sizeof(o->framegroupblend)))
+			{
+				bits |= E5_COMPLEXANIMATION;
+			}
+		}
+		if (o->traileffectnum != n->traileffectnum)
+			bits |= E5_TRAILEFFECTNUM;
 	}
 	else
 		if (o->active == ACTIVE_NETWORK)
@@ -2605,13 +2704,13 @@ void EntityFrame5_CL_ReadFrame(void)
 	entity_t *ent;
 	entity_state_t *s;
 	// read the number of this frame to echo back in next input packet
-	framenum = MSG_ReadLong();
+	framenum = MSG_ReadLong(&cl_message);
 	CL_NewFrameReceived(framenum);
 	if (cls.protocol != PROTOCOL_QUAKE && cls.protocol != PROTOCOL_QUAKEDP && cls.protocol != PROTOCOL_NEHAHRAMOVIE && cls.protocol != PROTOCOL_DARKPLACES1 && cls.protocol != PROTOCOL_DARKPLACES2 && cls.protocol != PROTOCOL_DARKPLACES3 && cls.protocol != PROTOCOL_DARKPLACES4 && cls.protocol != PROTOCOL_DARKPLACES5 && cls.protocol != PROTOCOL_DARKPLACES6)
-		cls.servermovesequence = MSG_ReadLong();
+		cls.servermovesequence = MSG_ReadLong(&cl_message);
 	// read entity numbers until we find a 0x8000
 	// (which would be remove world entity, but is actually a terminator)
-	while ((n = (unsigned short)MSG_ReadShort()) != 0x8000 && !msg_badread)
+	while ((n = (unsigned short)MSG_ReadShort(&cl_message)) != 0x8000 && !cl_message.badread)
 	{
 		// get the entity number
 		enumber = n & 0x7FFF;
@@ -2735,8 +2834,9 @@ void EntityFrame5_AckFrame(entityframe5_database_t *d, int framenum)
 			d->packetlog[i].packetnumber = 0;
 }
 
-qboolean EntityFrame5_WriteFrame(sizebuf_t *msg, int maxsize, entityframe5_database_t *d, int numstates, const entity_state_t **states, int viewentnum, int movesequence, qboolean need_empty)
+qboolean EntityFrame5_WriteFrame(sizebuf_t *msg, int maxsize, entityframe5_database_t *d, int numstates, const entity_state_t **states, int viewentnum, unsigned int movesequence, qboolean need_empty)
 {
+	prvm_prog_t *prog = SVVM_prog;
 	const entity_state_t *n;
 	int i, num, l, framenum, packetlognumber, priority;
 	sizebuf_t buf;
@@ -2971,7 +3071,7 @@ static void QW_TranslateEffects(entity_state_t *s, int qweffects)
 
 void EntityStateQW_ReadPlayerUpdate(void)
 {
-	int slot = MSG_ReadByte();
+	int slot = MSG_ReadByte(&cl_message);
 	int enumber = slot + 1;
 	int weaponframe;
 	int msec;
@@ -2992,9 +3092,9 @@ void EntityStateQW_ReadPlayerUpdate(void)
 	s->active = ACTIVE_NETWORK;
 	s->number = enumber;
 	s->colormap = enumber;
-	playerflags = MSG_ReadShort();
-	MSG_ReadVector(s->origin, cls.protocol);
-	s->frame = MSG_ReadByte();
+	playerflags = MSG_ReadShort(&cl_message);
+	MSG_ReadVector(&cl_message, s->origin, cls.protocol);
+	s->frame = MSG_ReadByte(&cl_message);
 
 	VectorClear(viewangles);
 	VectorClear(velocity);
@@ -3005,47 +3105,47 @@ void EntityStateQW_ReadPlayerUpdate(void)
 		// and last input we sent to the server (this packet is in response to
 		// our input, so msec is how long ago the last update of this player
 		// entity occurred, compared to our input being received)
-		msec = MSG_ReadByte();
+		msec = MSG_ReadByte(&cl_message);
 	}
 	else
 		msec = 0;
 	if (playerflags & QW_PF_COMMAND)
 	{
-		bits = MSG_ReadByte();
+		bits = MSG_ReadByte(&cl_message);
 		if (bits & QW_CM_ANGLE1)
-			viewangles[0] = MSG_ReadAngle16i(); // cmd->angles[0]
+			viewangles[0] = MSG_ReadAngle16i(&cl_message); // cmd->angles[0]
 		if (bits & QW_CM_ANGLE2)
-			viewangles[1] = MSG_ReadAngle16i(); // cmd->angles[1]
+			viewangles[1] = MSG_ReadAngle16i(&cl_message); // cmd->angles[1]
 		if (bits & QW_CM_ANGLE3)
-			viewangles[2] = MSG_ReadAngle16i(); // cmd->angles[2]
+			viewangles[2] = MSG_ReadAngle16i(&cl_message); // cmd->angles[2]
 		if (bits & QW_CM_FORWARD)
-			MSG_ReadShort(); // cmd->forwardmove
+			MSG_ReadShort(&cl_message); // cmd->forwardmove
 		if (bits & QW_CM_SIDE)
-			MSG_ReadShort(); // cmd->sidemove
+			MSG_ReadShort(&cl_message); // cmd->sidemove
 		if (bits & QW_CM_UP)
-			MSG_ReadShort(); // cmd->upmove
+			MSG_ReadShort(&cl_message); // cmd->upmove
 		if (bits & QW_CM_BUTTONS)
-			(void) MSG_ReadByte(); // cmd->buttons
+			(void) MSG_ReadByte(&cl_message); // cmd->buttons
 		if (bits & QW_CM_IMPULSE)
-			(void) MSG_ReadByte(); // cmd->impulse
-		(void) MSG_ReadByte(); // cmd->msec
+			(void) MSG_ReadByte(&cl_message); // cmd->impulse
+		(void) MSG_ReadByte(&cl_message); // cmd->msec
 	}
 	if (playerflags & QW_PF_VELOCITY1)
-		velocity[0] = MSG_ReadShort();
+		velocity[0] = MSG_ReadShort(&cl_message);
 	if (playerflags & QW_PF_VELOCITY2)
-		velocity[1] = MSG_ReadShort();
+		velocity[1] = MSG_ReadShort(&cl_message);
 	if (playerflags & QW_PF_VELOCITY3)
-		velocity[2] = MSG_ReadShort();
+		velocity[2] = MSG_ReadShort(&cl_message);
 	if (playerflags & QW_PF_MODEL)
-		s->modelindex = MSG_ReadByte();
+		s->modelindex = MSG_ReadByte(&cl_message);
 	else
 		s->modelindex = cl.qw_modelindex_player;
 	if (playerflags & QW_PF_SKINNUM)
-		s->skin = MSG_ReadByte();
+		s->skin = MSG_ReadByte(&cl_message);
 	if (playerflags & QW_PF_EFFECTS)
-		QW_TranslateEffects(s, MSG_ReadByte());
+		QW_TranslateEffects(s, MSG_ReadByte(&cl_message));
 	if (playerflags & QW_PF_WEAPONFRAME)
-		weaponframe = MSG_ReadByte();
+		weaponframe = MSG_ReadByte(&cl_message);
 	else
 		weaponframe = 0;
 
@@ -3107,32 +3207,32 @@ static void EntityStateQW_ReadEntityUpdate(entity_state_t *s, int bits)
 	s->number = bits & 511;
 	bits &= ~511;
 	if (bits & QW_U_MOREBITS)
-		bits |= MSG_ReadByte();
+		bits |= MSG_ReadByte(&cl_message);
 
 	// store the QW_U_SOLID bit here?
 
 	if (bits & QW_U_MODEL)
-		s->modelindex = MSG_ReadByte();
+		s->modelindex = MSG_ReadByte(&cl_message);
 	if (bits & QW_U_FRAME)
-		s->frame = MSG_ReadByte();
+		s->frame = MSG_ReadByte(&cl_message);
 	if (bits & QW_U_COLORMAP)
-		s->colormap = MSG_ReadByte();
+		s->colormap = MSG_ReadByte(&cl_message);
 	if (bits & QW_U_SKIN)
-		s->skin = MSG_ReadByte();
+		s->skin = MSG_ReadByte(&cl_message);
 	if (bits & QW_U_EFFECTS)
-		QW_TranslateEffects(s, qweffects = MSG_ReadByte());
+		QW_TranslateEffects(s, qweffects = MSG_ReadByte(&cl_message));
 	if (bits & QW_U_ORIGIN1)
-		s->origin[0] = MSG_ReadCoord13i();
+		s->origin[0] = MSG_ReadCoord13i(&cl_message);
 	if (bits & QW_U_ANGLE1)
-		s->angles[0] = MSG_ReadAngle8i();
+		s->angles[0] = MSG_ReadAngle8i(&cl_message);
 	if (bits & QW_U_ORIGIN2)
-		s->origin[1] = MSG_ReadCoord13i();
+		s->origin[1] = MSG_ReadCoord13i(&cl_message);
 	if (bits & QW_U_ANGLE2)
-		s->angles[1] = MSG_ReadAngle8i();
+		s->angles[1] = MSG_ReadAngle8i(&cl_message);
 	if (bits & QW_U_ORIGIN3)
-		s->origin[2] = MSG_ReadCoord13i();
+		s->origin[2] = MSG_ReadCoord13i(&cl_message);
 	if (bits & QW_U_ANGLE3)
-		s->angles[2] = MSG_ReadAngle8i();
+		s->angles[2] = MSG_ReadAngle8i(&cl_message);
 
 	if (developer_networkentities.integer >= 2)
 	{
@@ -3198,11 +3298,10 @@ void EntityFrameQW_CL_ReadFrame(qboolean delta)
 	newsnapindex = cl.qw_validsequence & QW_UPDATE_MASK;
 	newsnap = d->snapshot + newsnapindex;
 	memset(newsnap, 0, sizeof(*newsnap));
-	oldsnapindex = -1;
 	oldsnap = NULL;
 	if (delta)
 	{
-		number = MSG_ReadByte();
+		number = MSG_ReadByte(&cl_message);
 		oldsnapindex = cl.qw_deltasequence[newsnapindex];
 		if ((number & QW_UPDATE_MASK) != (oldsnapindex & QW_UPDATE_MASK))
 			Con_DPrintf("WARNING: from mismatch\n");
@@ -3230,8 +3329,8 @@ void EntityFrameQW_CL_ReadFrame(qboolean delta)
 	oldindex = 0;
 	for (;;)
 	{
-		int word = (unsigned short)MSG_ReadShort();
-		if (msg_badread)
+		int word = (unsigned short)MSG_ReadShort(&cl_message);
+		if (cl_message.badread)
 			return; // just return, the main parser will print an error
 		newnum = word == 0 ? 512 : (word & 511);
 		oldnum = delta ? (oldindex >= oldsnap->num_entities ? 9999 : oldsnap->entities[oldindex].number) : 9999;
@@ -3267,7 +3366,7 @@ void EntityFrameQW_CL_ReadFrame(qboolean delta)
 			if (newnum != oldnum && !delta && !invalid)
 			{
 				cl.qw_validsequence = 0;
-				Con_Printf("WARNING: U_REMOVE %i on full update\n", newnum);
+				Con_Printf(CON_WARN "WARNING: U_REMOVE %i on full update\n", newnum);
 			}
 		}
 		else