File tree Expand file tree Collapse file tree
core/src/main/java/io/questdb/client/cutlass/qwp/client Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2862,10 +2862,11 @@ private void ensureConnected() {
28622862 }
28632863 cursorSendLoop .setProgressDispatcher (progressDispatcher );
28642864 // Connection-event dispatcher: lets the cursor I/O loop fire
2865- // DISCONNECTED on outage entry and RECONNECT_BUDGET_EXHAUSTED on
2866- // budget exit. Sender-side fire points (buildAndConnect) write
2867- // directly to connectionDispatcher; this getter just shares the
2868- // same instance with the loop.
2865+ // DISCONNECTED on outage entry. Sender-side fire points
2866+ // (buildAndConnect) write directly to connectionDispatcher; this
2867+ // getter just shares the same instance with the loop. (Invariant B:
2868+ // the loop no longer fires a terminal budget-exhaustion event -- it
2869+ // retries indefinitely.)
28692870 cursorSendLoop .setConnectionDispatcher (connectionDispatcher );
28702871 cursorSendLoop .start ();
28712872 } catch (Throwable t ) {
You can’t perform that action at this time.
0 commit comments