@@ -244,7 +244,7 @@ func Load(rd io.Reader, myID string) (Configuration, error) {
repo := &cfg.Repositories[i]
if len(repo.Directory) == 0 {
- repo.Invalid = "empty directory"
+ repo.Invalid = "no directory configured"
continue
}
@@ -275,7 +275,8 @@ func (m *Model) Index(nodeID string, repo string, fs []protocol.FileInfo) {
if r, ok := m.repoFiles[repo]; ok {
r.Replace(id, files)
} else {
- l.Warnf("Index from %s for nonexistant repo %q; dropping", nodeID, repo)
+ l.Warnf("Index from %s for unexpected repo %q; verify configuration", nodeID, repo)
+
m.rmut.RUnlock()
@@ -81,17 +81,8 @@ func compareClusterConfig(local, remote protocol.ClusterConfigMessage) error {
- } else {
- return ClusterConfigMismatch(fmt.Errorf("remote is missing repository %q", repo))
- for repo := range rm {
- if _, ok := lm[repo]; !ok {
- return ClusterConfigMismatch(fmt.Errorf("remote has extra repository %q", repo))
- }
-
return nil