yacloud/tunasync
1
0
Fork 0
mirror of https://github.com/tuna/tunasync.git synced 2025-04-21 04:42:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

style(worker): put exported methods together

Browse Source
This commit is contained in:
bigeagle 2016-05-02 22:19:02 +08:00
parent 76ad3d40d6
commit 5b5f020075
No known key found for this signature in database
GPG Key ID: 9171A4571C27920A
1 changed files with 26 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
worker/worker.go
View File

@ -59,12 +59,26 @@ func GetTUNASyncWorker(cfg *Config) *Worker {
return w return w
} }
func (w *Worker) initJobs() { // Run runs worker forever
for _, mirror := range w.cfg.Mirrors { func (w *Worker) Run() {
// Create Provider w.registorWorker()
provider := newMirrorProvider(mirror, w.cfg) go w.runHTTPServer()
w.jobs[provider.Name()] = newMirrorJob(provider) 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 // ReloadMirrorConfig refresh the providers and jobs
@ -134,7 +148,14 @@ func (w *Worker) ReloadMirrorConfig(newMirrors []mirrorConfig) {
} }
w.cfg.Mirrors = newMirrors 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) { 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() { func (w *Worker) runSchedule() {
w.L.Lock() w.L.Lock()