apache / apache/arrow-java

[FlightRPC][Java] CallbackBackpressureStrategy should not rely on listener.isReady()

Aperta
#346 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub
Type: bug
Lingua principale
Java
Stelle
94
Fork
152
Merge medio
3g 16h
PR unite (30g)
11

Descrizione

According to the spec for , we can get into a state where the ready flag on the listener has already switched back to false by the time we execute the on ready handler.

We currently use the listener's ready flag after the ready handler to check if we received a spurious wake, but it's not reliable because of this. Instead we should use our own readiness flag that gets set within a synchronized block local to the CallbackBackpressureStrategy.

**Reporter**: [James Duong](https://issues.apache.org/jira/browse/ARROW-15876) / @jduo

**Note**: *This issue was originally created as [ARROW-15876](https://issues.apache.org/jira/browse/ARROW-15876). Please see the [migration documentation](https://github.com/apache/arrow/issues/14542) for further details.*

Guida per i contributori

Apri la guida per i contributori

Direzione di ricerca

Inizia con CallbackBackpressureStrategy e la specifica di CallStreamObserver setOnReadyHandler collegata nell’issue. Traccia il modo in cui il flag di disponibilità del listener viene verificato dopo il ready handler, quindi verifica che il completamento non dipenda più da quel flag del listener e utilizzi lo stato di disponibilità sincronizzato della strategia.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Valutazione

Stack tecnologico
grpc, java
Ambito
api
Tipo di issue
Bug
Difficoltà
3/5
Tempo stimato
1-2 giorni
Stato di attività
Ferma
Chiarezza
Abbastanza chiara
Idoneità per principianti
52/100

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.