[Red5commits] [1071] Drop 1 in every 100 packets, low tech lag fix. Also changed to using original ts

[lhubbard]

Drop 1 in every 100 packets, low tech lag fix. Also changed to using original ts when streaming.


Timestamp: 06/29/06 23:08:20 (less than one hour ago) 
Change: 1071 
Author: lhubbard

Files (see diff or trac for details): 
java/server/trunk/src/org/red5/server/stream/ClientBroadcastStream.java


Trac: http://mirror1.cvsdude.com/trac/osflash/red5/changeset/1071

Index: /java/server/trunk/src/org/red5/server/stream/ClientBroadcastStream.java
===================================================================
--- /java/server/trunk/src/org/red5/server/stream/ClientBroadcastStream.java (revision 1068)
+++ /java/server/trunk/src/org/red5/server/stream/ClientBroadcastStream.java (revision 1071)
@@ -142,4 +142,6 @@
 	}
 	
+	private int tempCounter = 0;
+	
 	public void dispatchEvent(IEvent event) {
 		if (!(event instanceof IRTMPEvent) && (event.getType() != IEvent.Type.STREAM_CONTROL) && (event.getType() != IEvent.Type.STREAM_DATA))
@@ -199,15 +201,16 @@
 		}
 		
-		
+	
 		// XXX: deltas for the different tag types don't seem to work, investigate!
 		delta = now - startTime;
 		startTime = now;
 		
-		rtmpEvent.setTimestamp((int) delta);
+		//rtmpEvent.setTimestamp((int) delta);
 		RTMPMessage msg = new RTMPMessage();
 		msg.setBody(rtmpEvent);
 		if (livePipe != null) {
 			// XXX probable race condition here
-			livePipe.pushMessage(msg);
+			// Drop 1 in every 100 packets, low tech lag fix.
+			if( (tempCounter++ % 100) != 0) livePipe.pushMessage(msg);
 		}
 		recordPipe.pushMessage(msg);


Note:
Diffs are chopped if more than 30k.
This is to get past the limit on the mailing list.