[Red5commits] [1807] Reenable the Flow controller.

sgong luke at codegent.com
Sat Mar 31 10:20:09 EST 2007


Reenable the Flow controller.


Timestamp: 03/31/07 10:11:51 EST (less than one hour ago) 
Change: 1807 
Author: sgong

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


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

Index: /java/server/trunk/src/org/red5/server/stream/PlaylistSubscriberStream.java
===================================================================
--- /java/server/trunk/src/org/red5/server/stream/PlaylistSubscriberStream.java (revision 1784)
+++ /java/server/trunk/src/org/red5/server/stream/PlaylistSubscriberStream.java (revision 1807)
@@ -1122,17 +1122,17 @@
 					while (true) {
 						IMessage msg = msgIn.pullMessage();
-//						if (adaptFlowJob == null) {
-//							adaptFlowJob = schedulingService.addScheduledJob(
-//									100, new IScheduledJob() {
-//										/** {@inheritDoc} */
-//                                        public void execute(
-//												ISchedulingService service) throws CloneNotSupportedException {
-//											streamFlowController
-//													.adaptBandwidthForFlow(
-//															getStreamFlow(),
-//															PlaylistSubscriberStream.this);
-//										}
-//									});
-//						}
+						if (adaptFlowJob == null) {
+							adaptFlowJob = schedulingService.addScheduledJob(
+									100, new IScheduledJob() {
+										/** {@inheritDoc} */
+                                        public void execute(
+												ISchedulingService service) throws CloneNotSupportedException {
+											streamFlowController
+													.adaptBandwidthForFlow(
+															getStreamFlow(),
+															PlaylistSubscriberStream.this);
+										}
+									});
+						}
 
 						if (msg == null) {


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



More information about the Red5commits mailing list