From 5b5f020075a411547b3a97c34bcf80c51539f96e Mon Sep 17 00:00:00 2001
From: bigeagle <justin.w.xd@gmail.com>
Date: Mon, 2 May 2016 22:19:02 +0800
Subject: [PATCH] style(worker): put exported methods together

---
 worker/worker.go | 53 ++++++++++++++++++++++++------------------------
 1 file changed, 26 insertions(+), 27 deletions(-)

diff --git a/worker/worker.go b/worker/worker.go
index 4857a86..61daf21 100644
--- a/worker/worker.go
+++ b/worker/worker.go
@@ -59,12 +59,26 @@ func GetTUNASyncWorker(cfg *Config) *Worker {
 	return w
 }
 
-func (w *Worker) initJobs() {
-	for _, mirror := range w.cfg.Mirrors {
-		// Create Provider
-		provider := newMirrorProvider(mirror, w.cfg)
-		w.jobs[provider.Name()] = newMirrorJob(provider)
+// Run runs worker forever
+func (w *Worker) Run() {
+	w.registorWorker()
+	go w.runHTTPServer()
+	w.runSchedule()
+}
+
+// Halt stops all jobs
+func (w *Worker) Halt() {
+	w.L.Lock()
+	logger.Notice("Stopping all the jobs")
+	for _, job := range w.jobs {
+		if job.State() != stateDisabled {
+			job.ctrlChan <- jobHalt
+		}
 	}
+	jobsDone.Wait()
+	logger.Notice("All the jobs are stopped")
+	w.L.Unlock()
+	close(w.exit)
 }
 
 // ReloadMirrorConfig refresh the providers and jobs
@@ -134,7 +148,14 @@ func (w *Worker) ReloadMirrorConfig(newMirrors []mirrorConfig) {
 	}
 
 	w.cfg.Mirrors = newMirrors
+}
 
+func (w *Worker) initJobs() {
+	for _, mirror := range w.cfg.Mirrors {
+		// Create Provider
+		provider := newMirrorProvider(mirror, w.cfg)
+		w.jobs[provider.Name()] = newMirrorJob(provider)
+	}
 }
 
 func (w *Worker) disableJob(job *mirrorJob) {
@@ -224,28 +245,6 @@ func (w *Worker) runHTTPServer() {
 	}
 }
 
-// Halt stops all jobs
-func (w *Worker) Halt() {
-	w.L.Lock()
-	logger.Notice("Stopping all the jobs")
-	for _, job := range w.jobs {
-		if job.State() != stateDisabled {
-			job.ctrlChan <- jobHalt
-		}
-	}
-	jobsDone.Wait()
-	logger.Notice("All the jobs are stopped")
-	w.L.Unlock()
-	close(w.exit)
-}
-
-// Run runs worker forever
-func (w *Worker) Run() {
-	w.registorWorker()
-	go w.runHTTPServer()
-	w.runSchedule()
-}
-
 func (w *Worker) runSchedule() {
 	w.L.Lock()