(req pipelineRequestType)
| 2331 | } |
| 2332 | |
| 2333 | func (s *pipelineState) PushBackRequestType(req pipelineRequestType) { |
| 2334 | if req == pipelineNil { |
| 2335 | return |
| 2336 | } |
| 2337 | |
| 2338 | if req != pipelineFlushRequest { |
| 2339 | s.requestEventQueue.PushBack(pipelineRequestEvent{RequestType: req}) |
| 2340 | } |
| 2341 | if req == pipelineFlushRequest || req == pipelineSyncRequest { |
| 2342 | s.registerFlushingBufferOnServer() |
| 2343 | } |
| 2344 | s.lastRequestType = req |
| 2345 | |
| 2346 | if req == pipelineSyncRequest { |
| 2347 | s.expectedReadyForQueryCount++ |
| 2348 | } |
| 2349 | } |
| 2350 | |
| 2351 | func (s *pipelineState) ExtractFrontRequestType() pipelineRequestType { |
| 2352 | for { |
no test coverage detected