fluent / fluent-plugin-opensearch / 35073772214

93%

main: 93%

Build Type

Pull #195

github

Committed by kenhys

Commit Message

out_opensearch: lock the client cache against flush threads

Before: client() cleared the shared @_os slot and then rebuilt it with
`||=`, without a lock. With flush_thread_count of 2 or more and a host
placeholder, a thread could pass the "is this the same host" check and
then pick up the client another thread had just built for a different
host, so its chunk went to that cluster instead.

After: the whole check-and-build runs under a mutex, so a thread always
gets a client for the host it asked for. The mutex is created in
initialize because configure builds a client before it returns.

Co-Authored-By: Claude <noreply@anthropic.com>
Signed-off-by: Kentaro Hayashi <hayashi@clear-code.com>

Pull Request Pull Request #195: out_opensearch: lock the client cache against flush threads

Coverage Stats

10 of 10 new or added lines in 1 file covered. (100.0%)

16 existing lines in 1 file now uncovered.

1197 of 1289 relevant lines covered (92.86%)

315.48 hits per line