mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
e6dd6b462eb0a32fbc37aaf3366495ecb897d339
scylladb/streaming
History
Asias He 74f739352d streaming: Enclose potential throws in try block and ensure sink close before logging 
- Move the initialization of log_done inside the try block to catch any
  exceptions it may throw.

- Relocate the failure warning log after sink.close() cleanup
  to guarantee sink.close() is always called before logging errors.

Refs #25497

Closes scylladb/scylladb#25591

(cherry picked from commit b12404ba52)

Closes scylladb/scylladb#25901
2025-09-10 11:02:09 +03:00
..
CMakeLists.txt
…
consumer.cc
…
consumer.hh
…
prepare_message.hh
…
progress_info.cc
…
progress_info.hh
…
session_info.cc
…
session_info.hh
…
stream_blob.cc
streaming: Enclose potential throws in try block and ensure sink close before logging
2025-09-10 11:02:09 +03:00
stream_blob.hh
…
stream_coordinator.cc
…
stream_coordinator.hh
…
stream_detail.hh
…
stream_event_handler.hh
…
stream_event.hh
…
stream_exception.hh
…
stream_fwd.hh
…
stream_manager.cc
…
stream_manager.hh
…
stream_mutation_fragments_cmd.hh
…
stream_plan.cc
…
stream_plan.hh
…
stream_reason.hh
…
stream_receive_task.cc
…
stream_receive_task.hh
…
stream_request.cc
…
stream_request.hh
dht: fragment token_range_vector
2025-08-27 18:28:58 +03:00
stream_result_future.cc
…
stream_result_future.hh
…
stream_session_state.cc
…
stream_session_state.hh
…
stream_session.cc
streaming: close sink when exception is thrown
2025-07-31 12:20:12 +03:00
stream_session.hh
…
stream_state.hh
…
stream_summary.cc
…
stream_summary.hh
…
stream_task.cc
…
stream_task.hh
…
stream_transfer_task.cc
…
stream_transfer_task.hh
dht: fragment token_range_vector
2025-08-27 18:28:58 +03:00
table_check.cc
…
table_check.hh
…