code: func (c *cluster) initializeAntiEntropy() {
  	c.mu.Lock()
  	c.abortAntiEntropyCh = make(chan struct{})
  	c.mu.Unlock()
  }
docs: // initializeAntiEntropy is called by the anti entropy routine when it starts.
  // If the AE channel is created without a routine reading from it, cluster will
  // block indefinitely when calling abortAntiEntropy().