[SPARK-3736] Addressing PR comment to make some defs private.

mccheah · mccheah · commit a698e356b051 · 2014-10-16T11:43:26.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
@@ -372,13 +372,13 @@ private[spark] class Worker(
     }
   }
 
-  def masterDisconnected() {
+  private def masterDisconnected() {
     logError("Connection to master failed! Waiting for master to reconnect...")
     connected = false
     scheduleAttemptsToReconnectToMaster()
   }
 
-  def scheduleAttemptsToReconnectToMaster() {
+  private def scheduleAttemptsToReconnectToMaster() {
     if (!scheduledReconnectTask.isDefined) {
       scheduledReconnectTask = Some(context.system.scheduler.schedule(
         Duration Zero, RECONNECT_ATTEMPT_INTERVAL_MILLIS millis) {

Original file line number	Diff line number	Diff line change
`@@ -372,13 +372,13 @@ private[spark] class Worker(`
`372`	`372`	`}`
`373`	`373`	`}`
`374`	`374`
`375`		`- def masterDisconnected() {`
	`375`	`+ private def masterDisconnected() {`
`376`	`376`	`logError("Connection to master failed! Waiting for master to reconnect...")`
`377`	`377`	`connected = false`
`378`	`378`	`scheduleAttemptsToReconnectToMaster()`
`379`	`379`	`}`
`380`	`380`
`381`		`- def scheduleAttemptsToReconnectToMaster() {`
	`381`	`+ private def scheduleAttemptsToReconnectToMaster() {`
`382`	`382`	`if (!scheduledReconnectTask.isDefined) {`
`383`	`383`	`scheduledReconnectTask = Some(context.system.scheduler.schedule(`
`384`	`384`	`Duration Zero, RECONNECT_ATTEMPT_INTERVAL_MILLIS millis) {`