()
| 2320 | } |
| 2321 | |
| 2322 | func (s *pipelineState) registerFlushingBufferOnServer() { |
| 2323 | for elem := s.requestEventQueue.Back(); elem != nil; elem = elem.Prev() { |
| 2324 | val := elem.Value.(pipelineRequestEvent) |
| 2325 | if val.BeforeFlushOrSync { |
| 2326 | return |
| 2327 | } |
| 2328 | val.BeforeFlushOrSync = true |
| 2329 | elem.Value = val |
| 2330 | } |
| 2331 | } |
| 2332 | |
| 2333 | func (s *pipelineState) PushBackRequestType(req pipelineRequestType) { |
| 2334 | if req == pipelineNil { |