From 53d9bff707755ad11486fed5d99f21248bfa6381 Mon Sep 17 00:00:00 2001
From: Pat Moroney <pat@pat.email>
Date: Tue, 24 Oct 2017 13:46:58 -0600
Subject: [PATCH] read lock around ReadHosts()

---
 plugin/hosts/hostsfile.go | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/plugin/hosts/hostsfile.go b/plugin/hosts/hostsfile.go
index ca867e203..7280049db 100644
--- a/plugin/hosts/hostsfile.go
+++ b/plugin/hosts/hostsfile.go
@@ -68,11 +68,17 @@ type Hostsfile struct {
 func (h *Hostsfile) ReadHosts() {
 	now := time.Now()
 
+	// Not deferring h.RUnlock() because we may need to remove the read lock and aquire a write lock
+	h.RLock()
 	if now.Before(h.expire) && len(h.byAddr) > 0 {
+		h.RUnlock()
 		return
 	}
 	stat, err := os.Stat(h.path)
 	if err == nil && h.mtime.Equal(stat.ModTime()) && h.size == stat.Size() {
+		h.RUnlock()
+		h.Lock()
+		defer h.Unlock()
 		h.expire = now.Add(cacheMaxAge)
 		return
 	}
@@ -83,10 +89,14 @@ func (h *Hostsfile) ReadHosts() {
 		if len(h.byAddr) == 0 && len(h.inline) > 0 {
 			h.Parse(nil)
 		}
+		h.RUnlock()
 		return
 	}
 	defer file.Close()
 
+	h.RUnlock()
+	h.Lock()
+	defer h.Unlock()
 	h.Parse(file)
 
 	// Update the data cache.
@@ -139,8 +149,6 @@ func (h *Hostsfile) Parse(file io.Reader) {
 			is[addr.String()] = append(is[addr.String()], name)
 		}
 	}
-	h.Lock()
-	defer h.Unlock()
 	h.byNameV4 = hsv4
 	h.byNameV6 = hsv6
 	h.byAddr = is