Method _stopOnlineProcesses

db/database.go:623–638

_stopOnlineProcesses is called to represent an error condition from startOnlineProcesses, or from DatabaseContext.Close. Most of the objects are not safe to close twice, since they have internal terminator objects and goroutines that wait on closed channels. Acquire the bucket lock, to avoid calling

(ctx context.Context)

// _stopOnlineProcesses is called to represent an error condition from startOnlineProcesses, or from DatabaseContext.Close. Most of the objects are not safe to close twice, since they have internal terminator objects and goroutines that wait on closed channels. Acquire the bucket lock, to avoid calling this function multiple times.
func (db *DatabaseContext) _stopOnlineProcesses(ctx context.Context) {
	db.mutationListener.Stop(ctx)
	db.changeCache.Stop(ctx)
	if db.ImportListener != nil {
		db.ImportListener.Stop()
		db.ImportListener = nil
	}
	if db.Heartbeater != nil {
		db.Heartbeater.Stop(ctx)
		db.Heartbeater = nil
	}
	if db.SGReplicateMgr != nil {
		db.SGReplicateMgr.Stop()
		db.SGReplicateMgr = nil
	}
}

func (context *DatabaseContext) Close(ctx context.Context) {
	context.BucketLock.Lock()