Merge pull request #4 from mosharaf/master

RandomAccessFiles are not thread-safe.
coflow · Aug 2, 2014 · c427909 · c427909
2 parents 9ef8d93 + f622016
commit c427909
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/examples/src/main/scala/varys/examples/BroadcastService.scala b/examples/src/main/scala/varys/examples/BroadcastService.scala
@@ -365,8 +365,10 @@ private[varys] object BroadcastReceiver extends Logging {
       logInfo("Got " + blockName + " of " + bArr.length + " bytes. Writing to " + localPathToFile + 
         " at " + offset)
 
-      FILE.seek(offset)
-      FILE.write(bArr)
+      FILE.synchronized {
+        FILE.seek(offset)
+        FILE.write(bArr)
+      }
     })
 
     Await.result(futureList, Duration.Inf)