vbatts/pkg
1
0
Fork 0
Code Pull requests Releases Activity

Retry registering a volume driver

Browse source 
Signed-off-by: Stephen Rust <srust@blockbridge.com>
This commit is contained in:
Stephen Rust 2015-08-28 14:55:05 -04:00
parent 65841492f0
commit 7eb8f570af
1 changed files with 33 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
plugins/plugins.go
View file

@ -25,6 +25,7 @@ package plugins
import (
"errors"
"sync"
"time"
"github.com/Sirupsen/logrus"
"github.com/docker/docker/pkg/tlsconfig"
@ -109,18 +110,35 @@ func (p *Plugin) activateWithLock() error {
}
func load(name string) (*Plugin, error) {
storage.Lock()
registry := newLocalRegistry()
pl, err := registry.Plugin(name)
if err == nil {
storage.plugins[name] = pl
return loadWithRetry(name, true)
}
storage.Unlock()
func loadWithRetry(name string, retry bool) (*Plugin, error) {
registry := newLocalRegistry()
start := time.Now()
var retries int
for {
pl, err := registry.Plugin(name)
if err != nil {
if !retry {
return nil, err
}
timeOff := backoff(retries)
if abort(start, timeOff) {
return nil, err
}
retries++
logrus.Warnf("Unable to locate plugin: %s, retrying in %v", name, timeOff)
time.Sleep(timeOff)
continue
}
storage.Lock()
storage.plugins[name] = pl
storage.Unlock()
err = pl.activate()
if err != nil {
@ -131,6 +149,7 @@ func load(name string) (*Plugin, error) {
return pl, err
}
}
func get(name string) (*Plugin, error) {
storage.Lock()