From 6d2317d60eb4594b3acf1b1a33833365284553e2 Mon Sep 17 00:00:00 2001 From: Alvaro Saurin Date: Thu, 28 May 2015 10:04:17 +0200 Subject: [PATCH] Silence "golint" errors Silence "go vet" errors Run goimports --- nameserver/addrs_test.go | 5 ++- nameserver/cache.go | 7 +-- nameserver/cache_test.go | 9 ++-- nameserver/dns.go | 3 +- nameserver/dns_test.go | 5 ++- nameserver/http.go | 7 +-- nameserver/http_test.go | 3 +- nameserver/mdns_client.go | 3 +- nameserver/mdns_client_test.go | 7 +-- nameserver/mdns_server.go | 3 +- nameserver/mdns_server_test.go | 7 +-- nameserver/mdns_test.go | 7 +-- nameserver/mocks_test.go | 29 +++++++------ nameserver/server.go | 7 +-- nameserver/server_cache_test.go | 7 +-- nameserver/server_test.go | 9 ++-- nameserver/zone.go | 75 +++++++++++++++++---------------- nameserver/zone_lookup.go | 24 +++++------ nameserver/zone_lookup_test.go | 5 ++- nameserver/zone_test.go | 5 ++- weavedns/main.go | 5 ++- 21 files changed, 126 insertions(+), 106 deletions(-) diff --git a/nameserver/addrs_test.go b/nameserver/addrs_test.go index 01c9acc3..1c09d73a 100644 --- a/nameserver/addrs_test.go +++ b/nameserver/addrs_test.go @@ -1,10 +1,11 @@ package nameserver import ( - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" + + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) func TestAddrs(t *testing.T) { diff --git a/nameserver/cache.go b/nameserver/cache.go index 7a5cc0c1..624236b8 100644 --- a/nameserver/cache.go +++ b/nameserver/cache.go @@ -5,12 +5,13 @@ import ( "container/heap" "errors" "fmt" - "github.com/benbjohnson/clock" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" "math" "sync" "time" + + "github.com/benbjohnson/clock" + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" ) var ( diff --git a/nameserver/cache_test.go b/nameserver/cache_test.go index b53d7529..890bea9b 100644 --- a/nameserver/cache_test.go +++ b/nameserver/cache_test.go @@ -2,13 +2,14 @@ package nameserver import ( "fmt" + "net" + "testing" + "time" + "github.com/benbjohnson/clock" "github.com/miekg/dns" . "github.com/weaveworks/weave/common" wt "github.com/weaveworks/weave/testing" - "net" - "testing" - "time" ) // Check that the cache keeps its intended capacity constant @@ -201,7 +202,7 @@ func TestCacheEntries(t *testing.T) { wt.AssertNotNil(t, err, "Get() error with CacheNoLocalReplies") clk.Add(time.Second * time.Duration(negLocalTTL+1)) - t.Logf("Checking that we get an expired response after %f seconds", negLocalTTL) + t.Logf("Checking that we get an expired response after %d seconds", negLocalTTL) resp, err = l.Get(questionMsg3, minUDPSize) wt.AssertNil(t, resp, "expired Get() response with CacheNoLocalReplies") wt.AssertNil(t, err, "expired Get() error with CacheNoLocalReplies") diff --git a/nameserver/dns.go b/nameserver/dns.go index 3f919993..8c08a2db 100644 --- a/nameserver/dns.go +++ b/nameserver/dns.go @@ -1,9 +1,10 @@ package nameserver import ( - "github.com/miekg/dns" "math/rand" "time" + + "github.com/miekg/dns" ) const ( diff --git a/nameserver/dns_test.go b/nameserver/dns_test.go index 58e53784..66eba2cb 100644 --- a/nameserver/dns_test.go +++ b/nameserver/dns_test.go @@ -1,11 +1,12 @@ package nameserver import ( + "net" + "testing" + "github.com/miekg/dns" . "github.com/weaveworks/weave/common" wt "github.com/weaveworks/weave/testing" - "net" - "testing" ) // Check that we can prune an answer diff --git a/nameserver/http.go b/nameserver/http.go index 5b9621a8..1f9a1e2b 100644 --- a/nameserver/http.go +++ b/nameserver/http.go @@ -2,12 +2,13 @@ package nameserver import ( "fmt" - "github.com/gorilla/mux" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" "log" "net" "net/http" + + "github.com/gorilla/mux" + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" ) func httpErrorAndLog(level *log.Logger, w http.ResponseWriter, msg string, diff --git a/nameserver/http_test.go b/nameserver/http_test.go index f3cee7a9..b0175fe7 100644 --- a/nameserver/http_test.go +++ b/nameserver/http_test.go @@ -2,7 +2,6 @@ package nameserver import ( "fmt" - wt "github.com/weaveworks/weave/testing" "math/rand" "net" "net/http" @@ -10,6 +9,8 @@ import ( "strings" "testing" "time" + + wt "github.com/weaveworks/weave/testing" ) func genForm(method string, url string, data url.Values) (resp *http.Response, err error) { diff --git a/nameserver/mdns_client.go b/nameserver/mdns_client.go index 4163e342..2ab57c99 100644 --- a/nameserver/mdns_client.go +++ b/nameserver/mdns_client.go @@ -3,10 +3,11 @@ package nameserver import ( "bytes" "fmt" - "github.com/miekg/dns" "math" "net" "time" + + "github.com/miekg/dns" ) // Portions of this code taken from github.com/armon/mdns diff --git a/nameserver/mdns_client_test.go b/nameserver/mdns_client_test.go index 7880c2a4..89d23757 100644 --- a/nameserver/mdns_client_test.go +++ b/nameserver/mdns_client_test.go @@ -1,13 +1,14 @@ package nameserver import ( - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "log" "net" "testing" "time" + + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) var ( diff --git a/nameserver/mdns_server.go b/nameserver/mdns_server.go index d67318c9..482d9244 100644 --- a/nameserver/mdns_server.go +++ b/nameserver/mdns_server.go @@ -1,9 +1,10 @@ package nameserver import ( + "net" + "github.com/miekg/dns" . "github.com/weaveworks/weave/common" - "net" ) type MDNSServer struct { diff --git a/nameserver/mdns_server_test.go b/nameserver/mdns_server_test.go index 5b11e60e..35ece389 100644 --- a/nameserver/mdns_server_test.go +++ b/nameserver/mdns_server_test.go @@ -1,12 +1,13 @@ package nameserver import ( - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" "time" + + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) func TestServerSimpleQuery(t *testing.T) { diff --git a/nameserver/mdns_test.go b/nameserver/mdns_test.go index 0ed34f93..2baeb3ff 100644 --- a/nameserver/mdns_test.go +++ b/nameserver/mdns_test.go @@ -1,12 +1,13 @@ package nameserver import ( - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" "time" + + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) // Check that we can use a regular mDNS server with a regular mDNS client diff --git a/nameserver/mocks_test.go b/nameserver/mocks_test.go index 7cafafd3..7cf195b4 100644 --- a/nameserver/mocks_test.go +++ b/nameserver/mocks_test.go @@ -2,15 +2,16 @@ package nameserver import ( "fmt" - "github.com/benbjohnson/clock" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "strconv" "sync" "testing" "time" + + "github.com/benbjohnson/clock" + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) const ( @@ -153,7 +154,7 @@ func (mc *mockedMDNSClient) LookupName(name string) ([]ZoneRecord, error) { defer mc.Unlock() // get a random result - mc.NumLookupsName += 1 + mc.NumLookupsName++ for _, server := range mc.servers { r, err := server.Zone().LookupName(name) if err == nil { @@ -168,7 +169,7 @@ func (mc *mockedMDNSClient) LookupInaddr(inaddr string) ([]ZoneRecord, error) { defer mc.Unlock() // get a random result - mc.NumLookupsInaddr += 1 + mc.NumLookupsInaddr++ for _, server := range mc.servers { r, err := server.Zone().LookupInaddr(inaddr) if err == nil { @@ -182,8 +183,8 @@ func (mc *mockedMDNSClient) InsistentLookupName(name string) ([]ZoneRecord, erro mc.Lock() defer mc.Unlock() - res := make([]ZoneRecord, 0) - mc.NumInsLookupsName += 1 + var res []ZoneRecord + mc.NumInsLookupsName++ for _, server := range mc.servers { r, err := server.Zone().LookupName(name) if err == nil { @@ -200,8 +201,8 @@ func (mc *mockedMDNSClient) InsistentLookupInaddr(inaddr string) ([]ZoneRecord, mc.Lock() defer mc.Unlock() - res := make([]ZoneRecord, 0) - mc.NumInsLookupsInaddr += 1 + var res []ZoneRecord + mc.NumInsLookupsInaddr++ for _, server := range mc.servers { r, err := server.Zone().LookupInaddr(inaddr) if err == nil { @@ -231,7 +232,7 @@ func (mc *mockedMDNSClient) RemoveServer(srv ZoneMDNSServer) { type zbmEntry struct { Server *mockedMDNSServer Client *mockedMDNSClient - Zone *zoneDb + Zone *ZoneDb } type zoneDbsWithMockedMDns []*zbmEntry @@ -303,14 +304,14 @@ type mockedCache struct { func newMockedCache() *mockedCache { return &mockedCache{} } func (c *mockedCache) Get(request *dns.Msg, maxLen int) (reply *dns.Msg, err error) { - c.NumGets += 1 + c.NumGets++ return nil, nil } func (c *mockedCache) Put(request *dns.Msg, reply *dns.Msg, ttl int, flags uint8) int { - c.NumPuts += 1 + c.NumPuts++ return 0 } -func (c *mockedCache) Remove(question *dns.Question) { c.NumRemovals += 1 } +func (c *mockedCache) Remove(question *dns.Question) { c.NumRemovals++ } func (c *mockedCache) Purge() {} func (c *mockedCache) Clear() {} func (c *mockedCache) Len() int { return 0 } diff --git a/nameserver/server.go b/nameserver/server.go index 940fe08d..224568ae 100644 --- a/nameserver/server.go +++ b/nameserver/server.go @@ -3,13 +3,14 @@ package nameserver import ( "bytes" "fmt" - "github.com/benbjohnson/clock" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" "net" "strconv" "sync" "time" + + "github.com/benbjohnson/clock" + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" ) const ( diff --git a/nameserver/server_cache_test.go b/nameserver/server_cache_test.go index cd16537a..3e3be2d9 100644 --- a/nameserver/server_cache_test.go +++ b/nameserver/server_cache_test.go @@ -2,12 +2,13 @@ package nameserver import ( "fmt" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" "time" + + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) // Check if the names updates lead to cache invalidations diff --git a/nameserver/server_test.go b/nameserver/server_test.go index 8f1897d1..6330a52e 100644 --- a/nameserver/server_test.go +++ b/nameserver/server_test.go @@ -3,12 +3,13 @@ package nameserver import ( "encoding/binary" "fmt" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" "time" + + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) const ( @@ -180,7 +181,7 @@ func TestTCPDNSServer(t *testing.T) { fallback.Start() defer fallback.Stop() - t.Logf("Creating a WeaveDNS server instance, falling back to 127.0.0.1:%s", fallback.Port) + t.Logf("Creating a WeaveDNS server instance, falling back to 127.0.0.1:%d", fallback.Port) srv, err := NewDNSServer(DNSServerConfig{ Zone: zone, UpstreamCfg: fallback.CliConfig, diff --git a/nameserver/zone.go b/nameserver/zone.go index 6f22ea79..908aee6d 100644 --- a/nameserver/zone.go +++ b/nameserver/zone.go @@ -3,12 +3,13 @@ package nameserver import ( "bytes" "fmt" - "github.com/benbjohnson/clock" - "github.com/miekg/dns" - . "github.com/weaveworks/weave/common" "net" "sync" "time" + + "github.com/benbjohnson/clock" + "github.com/miekg/dns" + . "github.com/weaveworks/weave/common" ) const ( @@ -103,8 +104,8 @@ func newRecordEntry(zr ZoneRecord, now time.Time) *recordEntry { } } -func (i *recordEntry) addIPObserver(zro ZoneRecordObserver) { - i.observers = append(i.observers, zro) +func (re *recordEntry) addIPObserver(zro ZoneRecordObserver) { + re.observers = append(re.observers, zro) } // Notify all the IP observers and then remove them all @@ -280,24 +281,24 @@ func newNamesSet() *namesSet { return &namesSet{names: make(map[string]*name func (ns *namesSet) len() int { return len(ns.names) } func (ns *namesSet) empty() bool { return ns.len() == 0 } func (ns *namesSet) hasName(name string) bool { - if n, found := ns.names[name]; !found { + n, found := ns.names[name] + if !found { return false - } else { - // the name must have some valid IPs in order to be considered as "existent" - return len(n.ipv4) > 0 } + // the name must have some valid IPs in order to be considered as "existent" + return len(n.ipv4) > 0 } // Get the zone entries for a name // If the name does not exist and `create` is true, a new name will be created func (ns *namesSet) getName(name string, create bool) (n *name) { - if n, found := ns.names[name]; !found && create { + n, found := ns.names[name] + if !found && create { newName := newName(name) ns.names[name] = newName return newName - } else { - return n } + return n } // Get all the entries for a name @@ -333,16 +334,16 @@ func (ns *namesSet) addIPToName(zr ZoneRecord, now time.Time) (*recordEntry, err // Delete a name in the names set func (ns *namesSet) deleteName(n string) error { - if name, found := ns.names[n]; found { + name, found := ns.names[n] + if found { for _, ipRecord := range name.getAllEntries() { ipRecord.notifyIPObservers() } name.notifyNameObservers() delete(ns.names, n) return nil - } else { - return LookupError(fmt.Sprintf("%+v", name)) } + return LookupError(fmt.Sprintf("%+v", name)) } // Delete an IPv4 from all names @@ -441,7 +442,7 @@ type ZoneConfig struct { // The zone database contains the locally known information about the zone. // The zone database uses some other mechanisms (eg, mDNS) for finding unknown // information or for keeping current information up to date. -type zoneDb struct { +type ZoneDb struct { mx sync.RWMutex idents identRecordsSet @@ -461,13 +462,13 @@ type zoneDb struct { } // Create a new zone database -func NewZoneDb(config ZoneConfig) (zone *zoneDb, err error) { +func NewZoneDb(config ZoneConfig) (zone *ZoneDb, err error) { maxRefreshRequests := defaultRefreshMailbox if config.MaxRefreshRequests > 0 { maxRefreshRequests = config.MaxRefreshRequests } - zone = &zoneDb{ + zone = &ZoneDb{ domain: config.Domain, idents: make(identRecordsSet), mdnsCli: config.MDNSClient, @@ -514,7 +515,7 @@ func NewZoneDb(config ZoneConfig) (zone *zoneDb, err error) { } // Start the zone database -func (zone *zoneDb) Start() (err error) { +func (zone *ZoneDb) Start() (err error) { if zone.iface != nil { Info.Printf("[zonedb] Using mDNS on %+v", zone.iface) } else { @@ -548,7 +549,7 @@ func (zone *zoneDb) Start() (err error) { } // Perform a graceful shutdown of the zone database -func (zone *zoneDb) Stop() error { +func (zone *ZoneDb) Stop() error { if zone.refreshInterval > 0 { Debug.Printf("[zonedb] Closing background updaters...") close(zone.refreshCloseChan) @@ -562,12 +563,12 @@ func (zone *zoneDb) Stop() error { } // Obtain the domain where this database keeps information for -func (zone *zoneDb) Domain() string { +func (zone *ZoneDb) Domain() string { return zone.domain } // Return the status string -func (zone *zoneDb) Status() string { +func (zone *ZoneDb) Status() string { var buf bytes.Buffer fmt.Fprintln(&buf, "Local domain", zone.domain) fmt.Fprintln(&buf, "Interface", zone.iface) @@ -576,7 +577,7 @@ func (zone *zoneDb) Status() string { } // Add a record with `name` pointing to `ip` -func (zone *zoneDb) AddRecord(ident string, name string, ip net.IP) (err error) { +func (zone *ZoneDb) AddRecord(ident string, name string, ip net.IP) (err error) { zone.mx.Lock() defer zone.mx.Unlock() Debug.Printf("[zonedb] Adding record: '%s'/'%s'[%s]", ident, name, ip) @@ -586,7 +587,7 @@ func (zone *zoneDb) AddRecord(ident string, name string, ip net.IP) (err error) } // Delete all records for an ident -func (zone *zoneDb) DeleteRecordsFor(ident string) (err error) { +func (zone *ZoneDb) DeleteRecordsFor(ident string) (err error) { zone.mx.Lock() defer zone.mx.Unlock() Debug.Printf("[zonedb] Deleting records for ident '%s'", ident) @@ -595,7 +596,7 @@ func (zone *zoneDb) DeleteRecordsFor(ident string) (err error) { } // Delete an IP in a ident -func (zone *zoneDb) DeleteRecord(ident string, ip net.IP) (err error) { +func (zone *ZoneDb) DeleteRecord(ident string, ip net.IP) (err error) { zone.mx.Lock() defer zone.mx.Unlock() @@ -620,7 +621,7 @@ func (zone *zoneDb) DeleteRecord(ident string, ip net.IP) (err error) { // The observer will be invoked on any change/removal that affects this name. // Each observer will be invoked at least once (but possibly more). After that, they will be removed. // The observer should not try to lock the ZoneDB (you will get a deadlock) -func (zone *zoneDb) ObserveName(name string, observer ZoneRecordObserver) (err error) { +func (zone *ZoneDb) ObserveName(name string, observer ZoneRecordObserver) (err error) { zone.mx.Lock() defer zone.mx.Unlock() @@ -629,7 +630,7 @@ func (zone *zoneDb) ObserveName(name string, observer ZoneRecordObserver) (err e for _, nameset := range zone.idents { if n := nameset.getName(name, false); n != nil { n.addNameObserver(observer) - cnt += 1 + cnt++ } } if cnt == 0 { @@ -646,7 +647,7 @@ func (zone *zoneDb) ObserveName(name string, observer ZoneRecordObserver) (err e // The observer will be invoked on any change/removal that affects this IP. // Each observer will be invoked at least once (but possibly more). After that, they will be removed. // The observer should not try to lock the ZoneDB (you will get a deadlock) -func (zone *zoneDb) ObserveInaddr(inaddr string, observer ZoneRecordObserver) (err error) { +func (zone *ZoneDb) ObserveInaddr(inaddr string, observer ZoneRecordObserver) (err error) { zone.mx.Lock() defer zone.mx.Unlock() @@ -658,7 +659,7 @@ func (zone *zoneDb) ObserveInaddr(inaddr string, observer ZoneRecordObserver) (e for _, nameset := range zone.idents { for _, entry := range nameset.getEntriesForIP(revIP) { entry.addIPObserver(observer) - cnt += 1 + cnt++ } } if cnt == 0 { @@ -668,20 +669,20 @@ func (zone *zoneDb) ObserveInaddr(inaddr string, observer ZoneRecordObserver) (e } // Get the string representation of a zone -func (zone *zoneDb) String() string { +func (zone *ZoneDb) String() string { zone.mx.RLock() defer zone.mx.RUnlock() return zone.idents.String() } // Notify that a container has died -func (zone *zoneDb) ContainerDied(ident string) error { +func (zone *ZoneDb) ContainerDied(ident string) error { Info.Printf("[zonedb] Container %s down. Removing records", ident) return zone.DeleteRecordsFor(ident) } // Return true if a remote name is still relevant -func (zone *zoneDb) IsNameRelevant(n string) bool { +func (zone *ZoneDb) IsNameRelevant(n string) bool { zone.mx.Lock() defer zone.mx.Unlock() @@ -699,7 +700,7 @@ func (zone *zoneDb) IsNameRelevant(n string) bool { // Returns true if the info we have for a remote name has expired. Local names are never expired // Returns false if we do not have info for this name from remote peers. -func (zone *zoneDb) IsNameExpired(n string) bool { +func (zone *ZoneDb) IsNameExpired(n string) bool { zone.mx.Lock() defer zone.mx.Unlock() @@ -716,7 +717,7 @@ func (zone *zoneDb) IsNameExpired(n string) bool { return false } -func (zone *zoneDb) HasNameLocalInfo(n string) bool { +func (zone *ZoneDb) HasNameLocalInfo(n string) bool { zone.mx.Lock() defer zone.mx.Unlock() @@ -734,7 +735,7 @@ func (zone *zoneDb) HasNameLocalInfo(n string) bool { // Return true if the we have obtained some information for a name from remote peers // We can have both local (eg, introduced through the HTTP API) and remote (eg, mDNS) // information for a name. This method only checks if there is remote information... -func (zone *zoneDb) HasNameRemoteInfo(n string) bool { +func (zone *ZoneDb) HasNameRemoteInfo(n string) bool { zone.mx.Lock() defer zone.mx.Unlock() @@ -746,7 +747,7 @@ func (zone *zoneDb) HasNameRemoteInfo(n string) bool { } // Get or create a names set -func (zone *zoneDb) getNamesSet(ident string) *namesSet { +func (zone *ZoneDb) getNamesSet(ident string) *namesSet { ns, found := zone.idents[ident] if !found { ns = newNamesSet() @@ -756,7 +757,7 @@ func (zone *zoneDb) getNamesSet(ident string) *namesSet { } // Delete a ident -func (zone *zoneDb) deleteIdent(ident string) { +func (zone *ZoneDb) deleteIdent(ident string) { Info.Printf("[zonedb] Removing everything for ident '%s'", ident) if ns, found := zone.idents[ident]; found { for _, n := range ns.names { diff --git a/nameserver/zone_lookup.go b/nameserver/zone_lookup.go index 35004400..292648a9 100644 --- a/nameserver/zone_lookup.go +++ b/nameserver/zone_lookup.go @@ -1,9 +1,10 @@ package nameserver import ( + "time" + "github.com/miekg/dns" . "github.com/weaveworks/weave/common" - "time" ) type uniqZoneRecordKey struct { @@ -38,7 +39,7 @@ func (uzr *uniqZoneRecords) toSlice() []ZoneRecord { ////////////////////////////////////////////////////////////////////////////// // Lookup in the database for locally-introduced information -func (zone *zoneDb) lookup(target string, lfun func(ns *namesSet) []*recordEntry) (res []ZoneRecord, err error) { +func (zone *ZoneDb) lookup(target string, lfun func(ns *namesSet) []*recordEntry) (res []ZoneRecord, err error) { uniq := newUniqZoneRecords() for identName, nameset := range zone.idents { if identName != defaultRemoteIdent { @@ -49,14 +50,13 @@ func (zone *zoneDb) lookup(target string, lfun func(ns *namesSet) []*recordEntry } if len(uniq) == 0 { return nil, LookupError(target) - } else { - return uniq.toSlice(), nil } + return uniq.toSlice(), nil } // Perform a lookup for a name in the zone // The name can be resolved locally with the local database -func (zone *zoneDb) LookupName(name string) (res []ZoneRecord, err error) { +func (zone *ZoneDb) LookupName(name string) (res []ZoneRecord, err error) { zone.mx.RLock() defer zone.mx.RUnlock() @@ -68,7 +68,7 @@ func (zone *zoneDb) LookupName(name string) (res []ZoneRecord, err error) { // Perform a lookup for a IP address in the zone // The address can be resolved locally with the local database -func (zone *zoneDb) LookupInaddr(inaddr string) (res []ZoneRecord, err error) { +func (zone *ZoneDb) LookupInaddr(inaddr string) (res []ZoneRecord, err error) { zone.mx.RLock() defer zone.mx.RUnlock() @@ -82,7 +82,7 @@ func (zone *zoneDb) LookupInaddr(inaddr string) (res []ZoneRecord, err error) { } // Perform a domain lookup with mDNS -func (zone *zoneDb) domainLookup(target string, lfun ZoneLookupFunc) (res []ZoneRecord, err error) { +func (zone *ZoneDb) domainLookup(target string, lfun ZoneLookupFunc) (res []ZoneRecord, err error) { // no local results have been obtained in the local database: try with a mDNS query Debug.Printf("[zonedb] '%s' not in local database... trying with mDNS", target) lanswers, err := lfun(target) @@ -115,7 +115,7 @@ func (zone *zoneDb) domainLookup(target string, lfun ZoneLookupFunc) (res []Zone // Perform a lookup for a name in the zone // The name can be resolved locally with the local database or with some other resolution method (eg, a mDNS query) -func (zone *zoneDb) DomainLookupName(name string) (res []ZoneRecord, err error) { +func (zone *ZoneDb) DomainLookupName(name string) (res []ZoneRecord, err error) { name = dns.Fqdn(name) Debug.Printf("[zonedb] Looking for name '%s' in local(&remote) database", name) @@ -156,7 +156,7 @@ func (zone *zoneDb) DomainLookupName(name string) (res []ZoneRecord, err error) // Perform a lookup for a IP address in the zone // The address can be resolved either with the local database or // with some other resolution method (eg, a mDNS query) -func (zone *zoneDb) DomainLookupInaddr(inaddr string) (res []ZoneRecord, err error) { +func (zone *ZoneDb) DomainLookupInaddr(inaddr string) (res []ZoneRecord, err error) { revIPv4, err := raddrToIPv4(inaddr) if err != nil { return nil, newParseError("lookup address", inaddr) @@ -239,7 +239,7 @@ func (zone *zoneDb) DomainLookupInaddr(inaddr string) (res []ZoneRecord, err err // Anyway, maybe we will move to a gossip-based solution instead of doing this polling... // Check if we must start updating a name and, in that case, trigger a immediate update -func (zone *zoneDb) startUpdatingName(name string) { +func (zone *ZoneDb) startUpdatingName(name string) { if zone.refreshInterval > 0 { zone.mx.Lock() defer zone.mx.Unlock() @@ -257,7 +257,7 @@ func (zone *zoneDb) startUpdatingName(name string) { } // A worker for updating the list of IPs we have for a name -func (zone *zoneDb) updater(num int) { +func (zone *ZoneDb) updater(num int) { defer zone.refreshWg.Done() Debug.Printf("[zonedb] Starting background updater #%d...", num) @@ -310,7 +310,7 @@ func (zone *zoneDb) updater(num int) { // The periodic updater // Consume requests from the `refreshSchedChan`, where requests with increasing scheduling time are enqueued // for refreshing names... -func (zone *zoneDb) periodicUpdater() { +func (zone *ZoneDb) periodicUpdater() { defer zone.refreshWg.Done() for { select { diff --git a/nameserver/zone_lookup_test.go b/nameserver/zone_lookup_test.go index 6c09ab6b..fde104bb 100644 --- a/nameserver/zone_lookup_test.go +++ b/nameserver/zone_lookup_test.go @@ -1,11 +1,12 @@ package nameserver import ( - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" "time" + + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) // Check that the refreshing mechanism works as expected diff --git a/nameserver/zone_test.go b/nameserver/zone_test.go index 968b4b7d..63d98fb3 100644 --- a/nameserver/zone_test.go +++ b/nameserver/zone_test.go @@ -2,10 +2,11 @@ package nameserver import ( "fmt" - . "github.com/weaveworks/weave/common" - wt "github.com/weaveworks/weave/testing" "net" "testing" + + . "github.com/weaveworks/weave/common" + wt "github.com/weaveworks/weave/testing" ) func TestZone(t *testing.T) { diff --git a/weavedns/main.go b/weavedns/main.go index db38cbcd..93a7bfd0 100644 --- a/weavedns/main.go +++ b/weavedns/main.go @@ -3,12 +3,13 @@ package main import ( "flag" "fmt" + "net" + "os" + . "github.com/weaveworks/weave/common" "github.com/weaveworks/weave/common/updater" weavedns "github.com/weaveworks/weave/nameserver" weavenet "github.com/weaveworks/weave/net" - "net" - "os" ) var version = "(unreleased version)"