aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHenry Saputra <henry.saputra@gmail.com>2014-06-11 23:17:51 -0700
committerReynold Xin <rxin@apache.org>2014-06-11 23:17:51 -0700
commit4d8ae709fb8d986634c97d21036391ed4685db1a (patch)
treec47bd35276e9fca68f73b3cc8cbef109c8c86835
parente056320cc8e2af56983a198d26717485304695d7 (diff)
downloadspark-4d8ae709fb8d986634c97d21036391ed4685db1a.tar.gz
spark-4d8ae709fb8d986634c97d21036391ed4685db1a.tar.bz2
spark-4d8ae709fb8d986634c97d21036391ed4685db1a.zip
Cleanup on Connection and ConnectionManager
Simple cleanup on Connection and ConnectionManager to make IDE happy while working of issue: 1. Replace var with var 2. Add parentheses to Queue#dequeu to be consistent with side-effects. 3. Remove return on final line of a method. Author: Henry Saputra <henry.saputra@gmail.com> Closes #1060 from hsaputra/cleanup_connection_classes and squashes the following commits: 245fd09 [Henry Saputra] Cleanup on Connection and ConnectionManager to make IDE happy while working of issue: 1. Replace var with var 2. Add parentheses to Queue#dequeu to be consistent with side-effects. 3. Remove return on final line of a method.
-rw-r--r--core/src/main/scala/org/apache/spark/network/Connection.scala4
-rw-r--r--core/src/main/scala/org/apache/spark/network/ConnectionManager.scala18
2 files changed, 11 insertions, 11 deletions
diff --git a/core/src/main/scala/org/apache/spark/network/Connection.scala b/core/src/main/scala/org/apache/spark/network/Connection.scala
index 3ffaaab23d..3b6298a26d 100644
--- a/core/src/main/scala/org/apache/spark/network/Connection.scala
+++ b/core/src/main/scala/org/apache/spark/network/Connection.scala
@@ -210,7 +210,7 @@ class SendingConnection(val address: InetSocketAddress, selector_ : Selector,
var nextMessageToBeUsed = 0
def addMessage(message: Message) {
- messages.synchronized{
+ messages.synchronized {
/* messages += message */
messages.enqueue(message)
logDebug("Added [" + message + "] to outbox for sending to " +
@@ -223,7 +223,7 @@ class SendingConnection(val address: InetSocketAddress, selector_ : Selector,
while (!messages.isEmpty) {
/* nextMessageToBeUsed = nextMessageToBeUsed % messages.size */
/* val message = messages(nextMessageToBeUsed) */
- val message = messages.dequeue
+ val message = messages.dequeue()
val chunk = message.getChunkForSending(defaultChunkSize)
if (chunk.isDefined) {
messages.enqueue(message)
diff --git a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
index 5dd5fd0047..cf1c985c2f 100644
--- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
+++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
@@ -250,14 +250,14 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
try {
while(!selectorThread.isInterrupted) {
while (! registerRequests.isEmpty) {
- val conn: SendingConnection = registerRequests.dequeue
+ val conn: SendingConnection = registerRequests.dequeue()
addListeners(conn)
conn.connect()
addConnection(conn)
}
while(!keyInterestChangeRequests.isEmpty) {
- val (key, ops) = keyInterestChangeRequests.dequeue
+ val (key, ops) = keyInterestChangeRequests.dequeue()
try {
if (key.isValid) {
@@ -532,9 +532,9 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
}
return
}
- var securityMsgResp = SecurityMessage.fromResponse(replyToken,
+ val securityMsgResp = SecurityMessage.fromResponse(replyToken,
securityMsg.getConnectionId.toString())
- var message = securityMsgResp.toBufferMessage
+ val message = securityMsgResp.toBufferMessage
if (message == null) throw new Exception("Error creating security message")
sendSecurityMessage(waitingConn.getRemoteConnectionManagerId(), message)
} catch {
@@ -568,9 +568,9 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
logDebug("Server sasl not completed: " + connection.connectionId)
}
if (replyToken != null) {
- var securityMsgResp = SecurityMessage.fromResponse(replyToken,
+ val securityMsgResp = SecurityMessage.fromResponse(replyToken,
securityMsg.getConnectionId)
- var message = securityMsgResp.toBufferMessage
+ val message = securityMsgResp.toBufferMessage
if (message == null) throw new Exception("Error creating security Message")
sendSecurityMessage(connection.getRemoteConnectionManagerId(), message)
}
@@ -618,7 +618,7 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
return true
}
}
- return false
+ false
}
private def handleMessage(
@@ -694,9 +694,9 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
var firstResponse: Array[Byte] = null
try {
firstResponse = conn.sparkSaslClient.firstToken()
- var securityMsg = SecurityMessage.fromResponse(firstResponse,
+ val securityMsg = SecurityMessage.fromResponse(firstResponse,
conn.connectionId.toString())
- var message = securityMsg.toBufferMessage
+ val message = securityMsg.toBufferMessage
if (message == null) throw new Exception("Error creating security message")
connectionsAwaitingSasl += ((conn.connectionId, conn))
sendSecurityMessage(connManagerId, message)