diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-10-25 14:53:56 -0700 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-10-25 14:53:56 -0700 |
| commit | 96797cc997161aaa37cf63c16414d51832816c9f (patch) | |
| tree | 5659004adfec8e9ed8921ea7c7b88bfe8b0ccf74 | |
| parent | 2099aadbbdb403edd6d860d8064bb418de310a60 (diff) | |
| download | spark-96797cc997161aaa37cf63c16414d51832816c9f.tar.gz spark-96797cc997161aaa37cf63c16414d51832816c9f.tar.bz2 spark-96797cc997161aaa37cf63c16414d51832816c9f.zip | |
Replaced nested variable.synchronized blocks with a single top level synchronized { }
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index ea9ee6c532..50dbdc680e 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -433,11 +433,7 @@ extends BroadcastRecipe with Logging { // Find peers that are not connected right now var peersNotInUse = ListBuffer[SourceInfo] () - listOfSources.synchronized { - peersNowTalking.synchronized { - peersNotInUse = listOfSources -- peersNowTalking - } - } + synchronized { peersNotInUse = listOfSources -- peersNowTalking } peersNotInUse.foreach { eachSource => var tempHasBlocksBitVector: BitSet = null |