core/src/main/scala/spark/network/ConnectionManagerId.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

package spark.network

import java.net.InetSocketAddress

import spark.Utils


private[spark] case class ConnectionManagerId(host: String, port: Int) {
  // DEBUG code
  Utils.checkHost(host)
  assert (port > 0)

  def toSocketAddress() = new InetSocketAddress(host, port)
}


private[spark] object ConnectionManagerId {
  def fromSocketAddress(socketAddress: InetSocketAddress): ConnectionManagerId = {
    new ConnectionManagerId(socketAddress.getHostName(), socketAddress.getPort())
  }
}