X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=fifos%2Fstart.go;h=a005c640036e5503054ef7e9aa52738f5736be81;hb=2df541457d24653f0fb789bfdc8de828c03f4f6c;hp=f37abe632cac8ababa37282c71f95105e93ae7a0;hpb=df97583cd82601875eab45e250e08966f2529a7a;p=tofuproxy.git

diff --git a/fifos/start.go b/fifos/start.go
index f37abe6..a005c64 100644
--- a/fifos/start.go
+++ b/fifos/start.go
@@ -22,6 +22,7 @@ func Start(fifos string) {
 	go listAccepted(filepath.Join(fifos, "list-accepted"))
 	go listHTTPAuth(filepath.Join(fifos, "list-http-auth"))
 	go listRejected(filepath.Join(fifos, "list-rejected"))
+	go listSpies(filepath.Join(fifos, "list-spies"))
 	go listTLSAuth(filepath.Join(fifos, "list-tls-auth"))
 
 	go del(
@@ -40,4 +41,18 @@ func Start(fifos string) {
 		&caches.TLSAuthCacheM, func(host string) { delete(caches.TLSAuthCache, host) },
 		filepath.Join(fifos, "del-tls-auth"),
 	)
+
+	go addSpy(filepath.Join(fifos, "add-spies"))
+	go del(
+		&caches.SpiesM, func(host string) {
+			for i, spy := range caches.Spies {
+				if spy == host {
+					caches.Spies[i] = caches.Spies[len(caches.Spies)-1]
+					caches.Spies = caches.Spies[:len(caches.Spies)-1]
+					return
+				}
+			}
+		},
+		filepath.Join(fifos, "del-spies"),
+	)
 }