From cd4f17a41074826d25175a22a9acada857d4ef51 Mon Sep 17 00:00:00 2001 From: Armon Dadgar Date: Wed, 7 Jan 2015 18:10:18 -0800 Subject: [PATCH] consul: Remove cruft from KV watching --- consul/state_store.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/consul/state_store.go b/consul/state_store.go index 71a9d6bf69..f4124eee21 100644 --- a/consul/state_store.go +++ b/consul/state_store.go @@ -405,9 +405,6 @@ func (s *StateStore) initialize() error { "CheckServiceNodes": MDBTables{s.nodeTable, s.serviceTable, s.checkTable}, "NodeInfo": MDBTables{s.nodeTable, s.serviceTable, s.checkTable}, "NodeDump": MDBTables{s.nodeTable, s.serviceTable, s.checkTable}, - "KVSGet": MDBTables{s.kvsTable}, - "KVSList": MDBTables{s.kvsTable}, - "KVSListKeys": MDBTables{s.kvsTable}, "SessionGet": MDBTables{s.sessionTable}, "SessionList": MDBTables{s.sessionTable}, "NodeSessions": MDBTables{s.sessionTable}, @@ -445,9 +442,6 @@ func (s *StateStore) WatchKV(prefix string, notify chan struct{}) { // notifyKV is used to notify any KV listeners of a change // on a prefix func (s *StateStore) notifyKV(path string, prefix bool) { - // Backwards compatibility for old listeners - s.watch[s.kvsTable].Notify() - s.kvWatchLock.Lock() defer s.kvWatchLock.Unlock()