diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-01 14:00:40 -0700 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-01 14:00:40 -0700 |
| commit | 10fc66b1c4d13af0fab4a964b133a6c9c02b272b (patch) | |
| tree | 6b9e55a3bc58fcc3dc81b10acadcdd8842d37e07 | |
| parent | 03d73dea9f6faa8b3a94500bcfe6fc646b3bd72c (diff) | |
| download | spark-10fc66b1c4d13af0fab4a964b133a6c9c02b272b.tar.gz spark-10fc66b1c4d13af0fab4a964b133a6c9c02b272b.tar.bz2 spark-10fc66b1c4d13af0fab4a964b133a6c9c02b272b.zip | |
Print reception messages for duplicate blocks as well...
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 64027d4ece..e0934e6a6b 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -552,6 +552,8 @@ extends BroadcastRecipe with Logging { val bcBlock = oisSource.readObject.asInstanceOf[BroadcastBlock] val receptionTime = (System.currentTimeMillis - recvStartTime) + logInfo ("Received block: " + bcBlock.blockID + " from " + peerToTalkTo + " in " + receptionTime + " millis.") + if (!hasBlocksBitVector.get(bcBlock.blockID)) { arrayOfBlocks(bcBlock.blockID) = bcBlock hasBlocksBitVector.synchronized { @@ -563,7 +565,6 @@ extends BroadcastRecipe with Logging { hasBlocks += 1 rxSpeeds.addDataPoint (peerToTalkTo, receptionTime) - logInfo ("Received block: " + bcBlock.blockID + " from " + peerToTalkTo + " in " + receptionTime + " millis.") } // Send the latest SourceInfo |