|
@@ -119,10 +119,10 @@ func newMirrorProvider(mirror mirrorConfig, cfg *Config) mirrorProvider {
|
|
env: mirror.Env,
|
|
env: mirror.Env,
|
|
}
|
|
}
|
|
p, err := newCmdProvider(pc)
|
|
p, err := newCmdProvider(pc)
|
|
- p.isMaster = isMaster
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
panic(err)
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
+ p.isMaster = isMaster
|
|
provider = p
|
|
provider = p
|
|
case provRsync:
|
|
case provRsync:
|
|
rc := rsyncConfig{
|
|
rc := rsyncConfig{
|
|
@@ -141,10 +141,10 @@ func newMirrorProvider(mirror mirrorConfig, cfg *Config) mirrorProvider {
|
|
retry: mirror.Retry,
|
|
retry: mirror.Retry,
|
|
}
|
|
}
|
|
p, err := newRsyncProvider(rc)
|
|
p, err := newRsyncProvider(rc)
|
|
- p.isMaster = isMaster
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
panic(err)
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
+ p.isMaster = isMaster
|
|
provider = p
|
|
provider = p
|
|
case provTwoStageRsync:
|
|
case provTwoStageRsync:
|
|
rc := twoStageRsyncConfig{
|
|
rc := twoStageRsyncConfig{
|
|
@@ -163,10 +163,10 @@ func newMirrorProvider(mirror mirrorConfig, cfg *Config) mirrorProvider {
|
|
retry: mirror.Retry,
|
|
retry: mirror.Retry,
|
|
}
|
|
}
|
|
p, err := newTwoStageRsyncProvider(rc)
|
|
p, err := newTwoStageRsyncProvider(rc)
|
|
- p.isMaster = isMaster
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
panic(err)
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
+ p.isMaster = isMaster
|
|
provider = p
|
|
provider = p
|
|
default:
|
|
default:
|
|
panic(errors.New("Invalid mirror provider"))
|
|
panic(errors.New("Invalid mirror provider"))
|