superfly/corrosion

Subscription channel can run out of capacity and drop events

Offen

#183 geöffnet am 11.04.2024

Auf GitHub ansehen
 (2 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Rust (83 Forks)auto 404
buggood first issuehelp wanted

Repository-Metriken

Stars
 (1.817 Sterne)
PR-Merge-Metriken
 (PR-Metriken ausstehend)

Beschreibung

The broadcast channel used by subscriptions (https://github.com/superfly/corrosion/blob/93561d180e3ebbdd275c9b80b9663b6dcb46e2fa/crates/corro-agent/src/api/public/pubsub.rs#L621) can run out of capacity and skip the events in case the data is read really fast from the disk.

Somehow, in this case, forward_sub_to_sender simply stops forwarding any event - https://github.com/superfly/corrosion/blob/93561d180e3ebbdd275c9b80b9663b6dcb46e2fa/crates/corro-agent/src/api/public/pubsub.rs#L728

It looks like the select! never matches RecvError::Lagged for some reasons.

Contributor Guide

Research-Richtung
Untersuche den für Abonnements verwendeten Broadcast Kanal und die Funktion forward sub to sender. Verstehe, warum die select! Schleife möglicherweise RecvError::Lagged nicht empfängt, wenn der Kanal überläuft. Überprüfe die Kanalkapazität und wie Ereignisse erzeugt und verbraucht werden. Suche nach verwandten Tests oder führe eine lokale Reproduktion durch.
Tech Stack
rust
Domain
backenddistributed systems
Issue Type
Fehler
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Halber Tag
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
GitRustAsync programming
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
40