Make Publisher.Close concurrent safe

ipni · Jan 30, 2024 · ddcb8f9 · ddcb8f9
1 parent 5786367
commit ddcb8f9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dagsync/ipnisync/publisher.go b/dagsync/ipnisync/publisher.go
@@ -174,6 +174,9 @@ func (p *Publisher) SetRoot(c cid.Cid) {
 
 // Close closes the Publisher.
 func (p *Publisher) Close() error {
+	p.lock.Lock()
+	defer p.lock.Unlock()
+
 	if p.pubHost != nil {
 		err := p.pubHost.Close()
 		p.pubHost = nil