superfly/corrosion

Subscription channel can run out of capacity and drop events

Aberta

#183 aberto em 11 de abr. de 2024

Ver no GitHub
 (2 comentários) (0 reação) (0 responsável)Rust (83 forks)auto 404
buggood first issuehelp wanted

Métricas do repositório

Stars
 (1.817 estrelas)
Métricas de merge de PR
 (Métricas PR pendentes)

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.

Guia do colaborador

Direção de pesquisa
Investigue o canal de broadcast usado para assinaturas e a função forward sub to sender. Entenda por que o loop select! pode não receber RecvError::Lagged quando o canal transborda. Verifique a capacidade do canal e como os eventos são produzidos e consumidos. Procure testes relacionados ou execute uma reprodução local.
Pilha de tecnologia
rust
Domain
backenddistributed systems
Tipo Issue
Bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
GitRustAsync programming
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
40