notifyQueryCancel delivers one query-cancel request, coalescing bursts: if a cancel is already pending (buffer full), the new one is dropped — the pending token will cancel the same in-flight query.
(ch chan struct{})
| 183 | // notifyQueryCancel delivers one query-cancel request, coalescing bursts: if |
| 184 | // a cancel is already pending (buffer full), the new one is dropped — the |
| 185 | // pending token will cancel the same in-flight query. |
| 186 | func notifyQueryCancel(ch chan struct{}) { |
| 187 | select { |
| 188 | case ch <- struct{}{}: |
| 189 | default: |
| 190 | } |
| 191 | } |
| 192 | |
| 193 | // runChildWorker handles a single client connection in a child process. |
no outgoing calls