perfsonar development work

Author: michael.bischoff
Date: 2008-05-29 09:26:48 -0400 (Thu, 29 May 2008)
New Revision: 3918

Modified:
   
trunk/surfnet_java-flowsubscription-mp/src/main/java/org/perfsonar/service/measurementPoint/flowsubscription/NfReplayControll.java
Log:
using waitFor instead of exit-value, even if the end of the inputstream it's 
still not necessarily finished.  

Modified: 
trunk/surfnet_java-flowsubscription-mp/src/main/java/org/perfsonar/service/measurementPoint/flowsubscription/NfReplayControll.java
===================================================================
--- 
trunk/surfnet_java-flowsubscription-mp/src/main/java/org/perfsonar/service/measurementPoint/flowsubscription/NfReplayControll.java
  2008-05-29 13:25:43 UTC (rev 3917)
+++ 
trunk/surfnet_java-flowsubscription-mp/src/main/java/org/perfsonar/service/measurementPoint/flowsubscription/NfReplayControll.java
  2008-05-29 13:26:48 UTC (rev 3918)
@@ -141,10 +141,10 @@
                                try {
                                        resultValues.add(task.take().get());
                                } catch (ExecutionException e) {
-                                       if(e.getCause()!= null) {
-                                               logger.error("nfreplaytask 
failed"  + e.getCause().getLocalizedMessage());
+                                       if(e.getCause() != null) {
+                                               
logger.error("processNewFile() nfreplaytask failed " + 
e.getCause().getLocalizedMessage());
                                        } else {
-                                               logger.error("nfreplaytask 
failed " + e.getLocalizedMessage() );
+                                               
logger.error("processNewFile() nfreplaytask failed " + 
e.getLocalizedMessage() );
                                        }
                                }
                        }
@@ -229,7 +229,7 @@
                                        while(input.read() != -1) {
                                                /* ignore */
                                        }
-                                       return 
Integer.valueOf(proces.exitValue());
+                                       return 
Integer.valueOf(proces.waitFor());
                                } catch (IOException e) {
                                        logger.warn("Error relaying output");
                                }