diff --git a/daemon/daemon_test.go b/daemon/daemon_test.go index 8ce9aa1996..d286bcfebd 100644 --- a/daemon/daemon_test.go +++ b/daemon/daemon_test.go @@ -549,3 +549,28 @@ func TestParseSecurityOpt(t *testing.T) { t.Fatal("Expected parseSecurityOpt error, got nil") } } + +func TestNetworkOptions(t *testing.T) { + daemon := &Daemon{} + dconfigCorrect := &Config{ + CommonConfig: CommonConfig{ + DefaultNetwork: "netPlugin:mynet:dev", + ClusterStore: "consul://localhost:8500", + ClusterAdvertise: "192.168.0.1:8000", + }, + } + + if _, err := daemon.networkOptions(dconfigCorrect); err != nil { + t.Fatalf("Expect networkOptions sucess, got error: %v", err) + } + + dconfigWrong := &Config{ + CommonConfig: CommonConfig{ + ClusterStore: "consul://localhost:8500://test://bbb", + }, + } + + if _, err := daemon.networkOptions(dconfigWrong); err == nil { + t.Fatalf("Expected networkOptions error, got nil") + } +} diff --git a/daemon/daemon_unix.go b/daemon/daemon_unix.go index 22142bcf14..4867a57e8f 100644 --- a/daemon/daemon_unix.go +++ b/daemon/daemon_unix.go @@ -333,11 +333,11 @@ func (daemon *Daemon) networkOptions(dconfig *Config) ([]nwconfig.Option, error) if strings.TrimSpace(dconfig.ClusterStore) != "" { kv := strings.Split(dconfig.ClusterStore, "://") - if len(kv) < 2 { + if len(kv) != 2 { return nil, fmt.Errorf("kv store daemon config must be of the form KV-PROVIDER://KV-URL") } options = append(options, nwconfig.OptionKVProvider(kv[0])) - options = append(options, nwconfig.OptionKVProviderURL(strings.Join(kv[1:], "://"))) + options = append(options, nwconfig.OptionKVProviderURL(kv[1])) } if len(dconfig.ClusterOpts) > 0 { options = append(options, nwconfig.OptionKVOpts(dconfig.ClusterOpts))