[mobicents] r9252 committed - Fixed RTSP controller part

[mobicents]

Revision: 9252
Author: oleg.kulikoff
Date: Wed Jan  6 04:03:40 2010
Log: Fixed RTSP controller part
http://code.google.com/p/mobicents/source/detail?r=9252
Modified:
  
/trunk/servers/media/core/server-impl/src/main/java/org/mobicents/media/server/impl/resource/video/AVPlayer.java

=======================================
---  
/trunk/servers/media/core/server-impl/src/main/java/org/mobicents/media/server/impl/resource/video/AVPlayer.java	 
Tue Jan  5 03:17:17 2010
+++  
/trunk/servers/media/core/server-impl/src/main/java/org/mobicents/media/server/impl/resource/video/AVPlayer.java	 
Wed Jan  6 04:03:40 2010
@@ -305,7 +305,8 @@
     }

     public void start() {
-        throw new UnsupportedOperationException("Not supported yet.");
+        this.audioSource.start();
+        this.videoSource.start();
     }

     public void stop() {
@@ -346,7 +347,8 @@

             // TODO : but we can have array of HeartBeat if its not  
constant. Also we are converting float to int here,
             // we can loose some fractions of ms. Rather should we  
consider using nanoseconds?
-            this.setPeriod((int) this.audioWrapper.getHeartBeat());
+            //this.setPeriod((int) this.audioWrapper.getHeartBeat());
+            this.setPeriod(128);
         }

         @Override
@@ -369,6 +371,9 @@
                 List<RTPPacket> rtpPackets = this.audioWrapper.process();
                 // TODO : handle more than one RTPPackets

+                if (rtpPackets.size() == 0) {
+                    return;
+                }
                 RTPPacket rtpPacket = rtpPackets.get(0);

                 byte[] data = rtpPacket.getPayload();
@@ -439,7 +444,8 @@

             // TODO : but we can have array of HeartBeat if its not  
constant. Also we are converting float to int here,
             // we can loose some fractions of ms. Rather should we  
consider using nanoseconds?
-            this.setPeriod((int) this.videoWrapper.getHeartBeat());
+           // this.setPeriod((int) this.videoWrapper.getHeartBeat());
+            this.setPeriod(66);
         }

         @Override
@@ -459,6 +465,9 @@
         public void evolve(Buffer buffer, long timestamp, long  
sequenceNumber) {
             try {
                 List<RTPPacket> rtpPackets = this.videoWrapper.process();
+                if (rtpPackets.size() == 0) {
+                    return;
+                }
                 // TODO : handle more than one RTPPackets

                 RTPPacket rtpPacket = rtpPackets.get(0);