poseidon-concurrency-src

name

poseidon-concurrency-src

description

Especialista em IMPLEMENTAR e corrigir concorrência, lifetime de conexão e memória do Poseidon — Pool.Buffer, Pool.Arena, Pool.Workers, Connection, Connection.Manager, IdleSweep. Use ao aplicar patches de poseidon-concurrency-review (refcount AddRef/Release, corridas de dados, UAF, double-free, vazamentos de buffer, itens perdidos em Pool.Workers.Shutdown) ou adicionar estruturas atômicas. Herda regras de poseidon-src.

Implementação de concorrência — invariantes duros

Escopo: src/Poseidon.Net.Pool.Buffer.pas, src/Poseidon.Net.Pool.Arena.pas, src/Poseidon.Net.Pool.Workers.pas, src/Poseidon.Net.Connection.pas, src/Poseidon.Net.Connection.Manager.pas, src/Poseidon.Net.IdleSweep.pas. Regras gerais em poseidon-src.

Refcount na fronteira IO-thread ↔ worker-pool

Contrato para TNativeConn:

• Ao enfileirar trabalho para o worker: AddRef na IO-thread ANTES de PostQueuedCompletion/similar.
• No worker: try ... finally Release; end sempre. Nunca sair sem Release.
• Release que zera refcount executa o teardown (fechar socket, devolver buffers ao pool). Nunca faça o teardown fora do último Release.

Bug clássico: Release chamado 2x no mesmo caminho de erro → double-free.

TInterlocked — overloads e armadilhas

• TInterlocked.Read só existe para Int64. Campo Integer → mude para Int64 OU use TInterlocked.CompareExchange(campo, 0, 0) para leitura atômica.
• TInterlocked.Increment/Decrement retorna o novo valor. Use o retorno, não releia o campo (releitura não é atômica com o inc).
• Flag booleana atômica: use Integer (0/1) com CompareExchange. Não use Boolean — não há atômico para ele.

Pool.Buffer / Pool.Arena

• Acquire retorna buffer ao chamador; Release devolve.
• Pareamento estrito: um Acquire = um Release, mesmo em caminho de exceção. try/finally Release; end.
• Buffer devolvido não pode ser tocado por quem devolveu. Se você guardou referência, ela virou dangling — outro Acquire pode pegar o mesmo.
• Pool custom via IBufferPool injetado: contabilidade separada do pool estático. Não misture (achado ativo do review).

Pool.Workers

• Enqueue: item entra na fila. Se worker está livre, dispara.
• Shutdown: descartar itens enfileirados VAZA (o AddRef que os colocou lá nunca é pareado). Ao shutdown, ou drena a fila (executando handlers) ou chama Release explícito para cada item pendente.
• FInFlightCount: incrementa no dequeue, decrementa no fim do handler. Descartar item enfileirado sem decrementar bagunça o contador.

IdleSweep

• Timer periódico varre conexões e fecha idle > threshold.
• Sweep é uma thread só, mas conexões estão sendo mutadas por workers. Ler campos de TNativeConn (LastActivityTicks) precisa ser atômico OU ler-uma-vez em variável local (evita leitura torn).
• Ao decidir fechar: passe pela mesma fronteira (AddRef antes de sinalizar worker), nunca chame teardown direto do timer thread.

Connection.Manager

• Registra/desregistra TNativeConn. Enumeração concorrente com registro/remoção corrompe. Ou snapshot antes de iterar, ou lock durante toda a iteração.

Bugs típicos (do review)

• FShutdown: Integer + TInterlocked.Read — não compila Linux.
• Pool.Workers.Shutdown descartando itens sem Release → vaza refcount.
• Static TBufferPool misturado com IBufferPool injetado — contabilidade quebra.
• Release chamado em caminho de erro depois de já ter sido pareado no finally.
• Leitura de Boolean compartilhado sem atômica.
• Buffer TLC de IO-thread não liberado em graceful reload (vaza no restart).

False sharing (perf, mas listado aqui)

Contadores atômicos hot em struct compartilhada com outros contadores podem falso-compartilhar cache line. Padding para 64 bytes onde importa. Não é o foco principal — trate se profiling apontar.

Arquivos no escopo

src/Poseidon.Net.Pool.Buffer.pas, src/Poseidon.Net.Pool.Arena.pas, src/Poseidon.Net.Pool.Workers.pas, src/Poseidon.Net.Connection.pas, src/Poseidon.Net.Connection.Manager.pas, src/Poseidon.Net.IdleSweep.pas.

Cross-skill: teardown do servidor invoca drain daqui → poseidon-server-src. Backend I/O é quem dispara AddRef → poseidon-portability-src.