diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 14:15:36 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 14:15:36 -0800 |
| commit | 15f1f6865d51a62c51098cb1ff93161fa725837c (patch) | |
| tree | f6372216b89d2498a50a72dd7a31f5cdd7f01629 | |
| parent | 1157380f21293aff8cd9c3272484f99848a810c2 (diff) | |
| download | spark-15f1f6865d51a62c51098cb1ff93161fa725837c.tar.gz spark-15f1f6865d51a62c51098cb1ff93161fa725837c.tar.bz2 spark-15f1f6865d51a62c51098cb1ff93161fa725837c.zip | |
Variable renaming.
| -rw-r--r-- | src/scala/spark/BitTorrentBroadcast.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/scala/spark/BitTorrentBroadcast.scala b/src/scala/spark/BitTorrentBroadcast.scala index 6a041b1ab0..7dc376a3c5 100644 --- a/src/scala/spark/BitTorrentBroadcast.scala +++ b/src/scala/spark/BitTorrentBroadcast.scala @@ -10,7 +10,7 @@ import java.util.concurrent.{Executors, ThreadFactory, ThreadPoolExecutor} import scala.collection.mutable.{ListBuffer, Map, Set} @serializable -class BitTorrentBroadcast[T] (@transient var value_ : T, local: Boolean) +class BitTorrentBroadcast[T] (@transient var value_ : T, isLocal: Boolean) extends Broadcast with Logging { def value = value_ @@ -51,7 +51,7 @@ extends Broadcast with Logging { @transient var stopBroadcast = false // Must call this after all the variables have been created/initialized - if (!local) { + if (!isLocal) { sendBroadcast } |