Method waitLogDone

pkg/controller/rtctrl/request.go:185–199

()

	return http.StatusInternalServerError
}
func (info *RequestInfo) waitLogDone() {
	store := info.store
	if store.LogDone(false) {
		return
	}

	go func() {
		// max waiting time = 10ms
		timer := time.NewTimer(10 * time.Millisecond)
		<-timer.C
		store.LogDone(true)
		timer.Stop()
	}()
	store.Wait()
}
func (info *RequestInfo) Notify() {
	select {
	case info.SyncChannel <- struct{}{}: