svn commit: r1342359 - /incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java

[sebawagner]

Author: sebawagner
Date: Thu May 24 18:04:01 2012
New Revision: 1342359

URL: http://svn.apache.org/viewvc?rev=1342359&view=rev
Log:
OPENMEETINGS-270 Debug further information and synchronize start/stop calls 
that manipulate the stream map

Modified:
    
incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java

Modified: 
incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java
URL: 
http://svn.apache.org/viewvc/incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java?rev=1342359&r1=1342358&r2=1342359&view=diff
==============================================================================
--- 
incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java
 (original)
+++ 
incubator/openmeetings/trunk/singlewebapp/src/org/openmeetings/app/remote/FLVRecorderService.java
 Thu May 24 18:04:01 2012
@@ -306,7 +306,7 @@ public class FLVRecorderService implemen
         * @param flvRecordingMetaDataId
         * @throws Exception
         */
-       private void recordShow(IConnection conn, String broadcastid,
+       private synchronized void recordShow(IConnection conn, String 
broadcastid,
                        String streamName, Long flvRecordingMetaDataId,
                        boolean isScreenData, Boolean isInterview) throws 
Exception {
                try {
@@ -364,7 +364,7 @@ public class FLVRecorderService implemen
         * 
         * @param conn
         */
-       public void stopRecordingShow(IConnection conn, String broadcastId,
+       public synchronized void stopRecordingShow(IConnection conn, String 
broadcastId,
                        Long flvRecordingMetaDataId) {
                try {
                        
@@ -386,6 +386,14 @@ public class FLVRecorderService implemen
                        log.debug("Stream Closing :: " + 
flvRecordingMetaDataId);
                        
                        if (listenerAdapter == null) {
+                               
+                               log.debug("Stream Not Found :: " + 
flvRecordingMetaDataId);
+                               log.debug("Available Stream :: ");
+                               
+                               for (Long entryKey : streamListeners.keySet()) {
+                                       log.debug("Stored 
flvRecordingMetaDataId in Map: "+ entryKey);
+                               }
+                               
                                throw new IllegalStateException("Could not find 
Listener to stop! flvRecordingMetaDataId "+flvRecordingMetaDataId);
                        }