| 149 | } |
| 150 | |
| 151 | static void |
| 152 | InstrStopNodeAsync(Instrumentation *instr, uint64 nTuples) |
| 153 | { |
| 154 | uint64 save_tuplecount = instr->tuplecount; |
| 155 | InstrStopNodeSync(instr, nTuples); |
| 156 | if (instr->running) |
| 157 | { |
| 158 | /* |
| 159 | * In async mode, if the plan node hadn't emitted any tuples before, |
| 160 | * this might be the first tuple |
| 161 | */ |
| 162 | if (instr->async_mode && save_tuplecount < 1) |
| 163 | instr->firsttuple = INSTR_TIME_GET_DOUBLE(instr->counter); |
| 164 | } |
| 165 | } |
| 166 | |
| 167 | void |
| 168 | InstrStopNode(Instrumentation *instr, uint64 nTuples) |
no test coverage detected