Method close

base/dcp_client.go:293–316

close is used internally to stop the DCP client. Sends any fatal errors to the client's done channel, and closes that channel.

()

// close is used internally to stop the DCP client.  Sends any fatal errors to the client's done channel, and
// closes that channel.
func (dc *DCPClient) close() {

	// set dc.closing to true, avoid re-triggering close if it's already in progress
	if !dc.closing.CompareAndSwap(false, true) {
		InfofCtx(dc.ctx, KeyDCP, "DCP Client close called - client is already closing")
		return
	}

	// Stop workers
	close(dc.terminator)
	if dc.agent != nil {
		agentErr := dc.agent.Close()
		if agentErr != nil {
			WarnfCtx(dc.ctx, "Error closing DCP agent in client close: %v", agentErr)
		}
	}

	// Wait for all workers to finish before closing doneChannel
	go func() {
		dc.workersWg.Wait()
		dc.doneChannel <- dc.getCloseError()
		close(dc.doneChannel)
	}()
}

// getAgentConfig returns a gocbcore.DCPAgentConfig for the given BucketSpec
func (dc *DCPClient) getAgentConfig(spec BucketSpec) (*gocbcore.DCPAgentConfig, error) {