svn commit: r1589350 - in /openmeetings: branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java

[solomax]

Author: solomax
Date: Wed Apr 23 06:50:40 2014
New Revision: 1589350

URL: http://svn.apache.org/r1589350
Log:
Debugging of waitForTheStream method is enhanced

Modified:
    
openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java
    
openmeetings/trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java

Modified: 
openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java
URL: 
http://svn.apache.org/viewvc/openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java?rev=1589350&r1=1589349&r2=1589350&view=diff
==============================================================================
--- 
openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java
 (original)
+++ 
openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/converter/BaseConverter.java
 Wed Apr 23 06:50:40 2014
@@ -146,15 +146,18 @@ public abstract class BaseConverter {
                FlvRecordingMetaData metaData = metaDataDao.get(metaId);
                if (metaData.getStreamStatus() != Status.STOPPED) {
                        log.debug("### meta Stream not yet written to disk " + 
metaId);
-                       boolean doStop = true;
-                       while(doStop) {
+                       boolean doWait = true;
+                       long counter = 0;
+                       while(doWait) {
                                log.trace("### Stream not yet written Thread 
Sleep - " + metaId);
                                
                                metaData = metaDataDao.get(metaId);
                                
                                if (metaData.getStreamStatus() == 
Status.STOPPED) {
                                        log.debug("### Stream now written 
Thread continue - " );
-                                       doStop = false;
+                                       doWait = false;
+                               } else if (++counter % 1000 == 0) {
+                                       log.debug(String.format("### Still 
waiting for the stream with id %s; current status: %s ", metaId, 
metaData.getStreamStatus()));
                                }
                                
                                Thread.sleep(100L);

Modified: 
openmeetings/trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java
URL: 
http://svn.apache.org/viewvc/openmeetings/trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java?rev=1589350&r1=1589349&r2=1589350&view=diff
==============================================================================
--- 
openmeetings/trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java
 (original)
+++ 
openmeetings/trunk/singlewebapp/openmeetings-core/src/main/java/org/apache/openmeetings/core/converter/BaseConverter.java
 Wed Apr 23 06:50:40 2014
@@ -146,15 +146,18 @@ public abstract class BaseConverter {
                FlvRecordingMetaData metaData = metaDataDao.get(metaId);
                if (metaData.getStreamStatus() != Status.STOPPED) {
                        log.debug("### meta Stream not yet written to disk " + 
metaId);
-                       boolean doStop = true;
-                       while(doStop) {
+                       boolean doWait = true;
+                       long counter = 0;
+                       while(doWait) {
                                log.trace("### Stream not yet written Thread 
Sleep - " + metaId);
                                
                                metaData = metaDataDao.get(metaId);
                                
                                if (metaData.getStreamStatus() == 
Status.STOPPED) {
                                        log.debug("### Stream now written 
Thread continue - " );
-                                       doStop = false;
+                                       doWait = false;
+                               } else if (++counter % 1000 == 0) {
+                                       log.debug(String.format("### Still 
waiting for the stream with id %s; current status: %s ", metaId, 
metaData.getStreamStatus()));
                                }
                                
                                Thread.sleep(100L);