superfly/corrosion

Subscription channel can run out of capacity and drop events

Ouverte

#183 ouverte le 11 avr. 2024

Voir sur GitHub
 (2 commentaires) (0 réaction) (0 personne assignée)Rust (83 forks)auto 404
buggood first issuehelp wanted

Métriques du dépôt

Stars
 (1 817 étoiles)
Métriques de merge PR
 (Métriques PR en attente)

Description

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.

Guide contributeur

Direction de recherche
Examinez le canal de diffusion utilisé pour les abonnements et la fonction forward sub to sender. Comprenez pourquoi la boucle select! pourrait ne pas recevoir RecvError::Lagged lorsque le canal déborde. Vérifiez la capacité du canal et comment les événements sont produits et consommés. Recherchez des tests associés ou effectuez une reproduction locale.
Stack technique
rust
Domaine
backenddistributed systems
Type d'issue
Bug
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
3
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
Une demi journée
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Active
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Claire
Prérequis
GitRustAsync programming
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
40