INNER CODE UNIT · Go

tailShards

rwynn/gtm · gtm.go:587

func tailShards(multi *OpCtxMulti, ctx *OpCtx, o *Options, handler ShardInsertHandler) {
	defer multi.allWg.Done()
	if o == nil {
		o = DefaultOptions()
	} else {
		o.SetDefaults()
	}
	for {
		select {
		case <-multi.stopC:
			return
		case <-multi.pauseC:
			select {
			case <-multi.stopC:
				return
			case <-multi.resumeC:
				break
			}

View source record →