Bug #2627
open
Missing timeout
0%
Description
OpenMOLE get freezed here on a low bandwith connection:
"Thread-41" daemon prio=10 tid=0x00007f05cc03c000 nid=0x71c9 in Object.wait() [0x00007f062ab14000]
java.lang.Thread.State: TIMED_WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x00000000e21b0d60> (a java.io.PipedInputStream)
at java.io.PipedInputStream.awaitSpace(PipedInputStream.java:274)
at java.io.PipedInputStream.receive(PipedInputStream.java:232)
- locked <0x00000000e21b0d60> (a java.io.PipedInputStream)
at java.io.PipedOutputStream.write(PipedOutputStream.java:149)
at fr.in2p3.jsaga.impl.file.stream.PipedOutputStreamImpl.write(PipedOutputStreamImpl.java:57)
at fr.in2p3.jsaga.impl.file.stream.FileOutputStreamPipedImpl.write(FileOutputStreamPipedImpl.java:94)
at org.openmole.core.batch.file.JSAGAOutputStream.write(JSAGAOutputStream.scala:30)
at java.util.zip.GZIPOutputStream.finish(GZIPOutputStream.java:169)
at java.util.zip.DeflaterOutputStream.close(DeflaterOutputStream.java:238)
at org.openmole.core.batch.file.URIFile$.copy(URIFile.scala:116)
at org.openmole.core.batch.replication.ReplicaCatalog$$anonfun$uploadAndInsert$1.apply$mcV$sp(ReplicaCatalog.scala:203)
at org.openmole.core.batch.replication.ReplicaCatalog$$anonfun$uploadAndInsert$1.apply(ReplicaCatalog.scala:203)
at org.openmole.core.batch.replication.ReplicaCatalog$$anonfun$uploadAndInsert$1.apply(ReplicaCatalog.scala:203)
at org.openmole.core.batch.environment.BatchEnvironment$.signalUpload(BatchEnvironment.scala:56)
at org.openmole.core.batch.replication.ReplicaCatalog$.uploadAndInsert(ReplicaCatalog.scala:203)
at org.openmole.core.batch.replication.ReplicaCatalog$.uploadAndGet(ReplicaCatalog.scala:173)
at org.openmole.core.batch.environment.CopyToEnvironment.toReplicatedFile(CopyToEnvironment.scala:136)
at org.openmole.core.batch.environment.CopyToEnvironment.replicateTheRuntime(CopyToEnvironment.scala:146)
at org.openmole.core.batch.environment.CopyToEnvironment.initCommunication(CopyToEnvironment.scala:74)
at org.openmole.core.batch.environment.CopyToEnvironment.call(CopyToEnvironment.scala:121)
at org.openmole.core.batch.environment.CopyToEnvironment.call(CopyToEnvironment.scala:52)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
Is there a timeout missing for the close method?
Updated by Reuillon Romain over 12 years ago
The plugin at stake here is the ssh2 plugin:
"Thread-202" daemon prio=10 tid=0x00007f0614017800 nid=0x7bf5 in Object.wait() [0x00007f062a60f000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x00000000fa007198> (a ch.ethz.ssh2.channel.Channel)
at java.lang.Object.wait(Object.java:503)
at ch.ethz.ssh2.channel.ChannelManager.getChannelData(ChannelManager.java:966)
- locked <0x00000000fa007198> (a ch.ethz.ssh2.channel.Channel)
at ch.ethz.ssh2.channel.ChannelInputStream.read(ChannelInputStream.java:64)
at ch.ethz.ssh2.SFTPv3Client.readBytes(SFTPv3Client.java:211)
at ch.ethz.ssh2.SFTPv3Client.receiveMessage(SFTPv3Client.java:238)
at ch.ethz.ssh2.SFTPv3Client.receiveAMessage(SFTPv3Client.java:1262)
at ch.ethz.ssh2.SFTPv3Client.write(SFTPv3Client.java:1384)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$1$$anonfun$apply$mcV$sp$3.apply(SFTPDataAdaptor.scala:121)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$1$$anonfun$apply$mcV$sp$3.apply(SFTPDataAdaptor.scala:119)
at scala.collection.Iterator$class.foreach(Iterator.scala:660)
at scala.collection.Iterator$$anon$25.foreach(Iterator.scala:457)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$1.apply$mcV$sp(SFTPDataAdaptor.scala:119)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$1.apply(SFTPDataAdaptor.scala:96)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$1.apply(SFTPDataAdaptor.scala:96)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$.fr$in2p3$jsaga$adaptor$ssh2$data$SFTPDataAdaptor$$mapExceptions(SFTPDataAdaptor.scala:56)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$.putFromStream(SFTPDataAdaptor.scala:96)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$2.apply(SFTPDataAdaptor.scala:179)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor$$anonfun$putFromStream$2.apply(SFTPDataAdaptor.scala:179)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor.fr$in2p3$jsaga$adaptor$ssh2$data$SFTPDataAdaptor$$withSftpClient(SFTPDataAdaptor.scala:152)
at fr.in2p3.jsaga.adaptor.ssh2.data.SFTPDataAdaptor.putFromStream(SFTPDataAdaptor.scala:179)
at fr.in2p3.jsaga.impl.file.stream.PipedOutputStreamImpl.run(PipedOutputStreamImpl.java:74)
at java.lang.Thread.run(Thread.java:722)
Should the timeout be implement in generic way at the engine level or supported by the plugin?
Updated by Reuillon Romain over 12 years ago
Actually it went through after a while no idea if a timeout is required here....