mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
58a76ae04cfcab69b313a685be10a26c1946cff3
scylladb/streaming
History
Amnon Heiman 47465d515a stream_manager expose the initiated_streams and the receiving_streams 
This expose the initiated_streams and the receiving_streams in the
stream_manager so the API would have access to it.

Signed-off-by: Amnon Heiman <amnon@cloudius-systems.com>
2015-09-10 01:03:08 +03:00
..
compress
streaming: Convert CompressionInfo.java to C++
2015-06-23 16:06:28 +08:00
messages
streaming: Send STREAM_MUTATION in parallel
2015-08-17 10:52:30 +08:00
progress_info.cc
streaming: Convert ProgressInfo.java to C++
2015-06-18 23:02:31 +08:00
progress_info.hh
streaming: Complete session_info
2015-06-24 16:13:30 +08:00
session_info.cc
streaming: Complete session_info
2015-06-24 16:13:30 +08:00
session_info.hh
streaming: Rename getTotalFilesToSend to get_total_files_to_send
2015-07-21 16:12:54 +08:00
stream_coordinator.cc
streaming: Fix stream_coordinator::is_receiving
2015-07-31 16:27:55 +08:00
stream_coordinator.hh
streaming: Fix stream_coordinator::is_receiving
2015-07-31 16:27:55 +08:00
stream_detail.hh
mutation_reader: make noncopyable
2015-08-25 15:49:08 +03:00
stream_event_handler.hh
streaming: Implement stream_result_future::handle_session_prepared
2015-07-21 16:12:54 +08:00
stream_event.hh
streaming: Swith to use shared_ptr from std::shared_ptr
2015-07-14 20:41:14 +08:00
stream_exception.hh
streaming: Convert StreamException.java to C++
2015-07-31 16:27:55 +08:00
stream_manager.cc
streaming: Remove completed stream in stream_manager
2015-07-31 16:27:55 +08:00
stream_manager.hh
stream_manager expose the initiated_streams and the receiving_streams
2015-09-10 01:03:08 +03:00
stream_plan.cc
streaming: Make stream_plan::execute return a future
2015-07-31 16:27:55 +08:00
stream_plan.hh
streaming: Make stream_plan::execute return a future
2015-07-31 16:27:55 +08:00
stream_receive_task.cc
streaming: Swith to use shared_ptr from std::shared_ptr
2015-07-14 20:41:14 +08:00
stream_receive_task.hh
streaming: Swith to use shared_ptr from std::shared_ptr
2015-07-14 20:41:14 +08:00
stream_request.cc
streaming: Serialize query::range<token> in stream_request
2015-07-23 09:08:15 +08:00
stream_request.hh
streaming: Add operator<< for stream_request
2015-07-22 11:49:30 +08:00
stream_result_future.cc
streaming: Remove completed stream in stream_manager
2015-07-31 16:27:55 +08:00
stream_result_future.hh
streaming: Make stream_plan::execute return a future
2015-07-31 16:27:55 +08:00
stream_session_state.hh
streaming: Add stream_session_state
2015-06-24 16:13:30 +08:00
stream_session.cc
streaming: Fix a race between initiator and follower
2015-08-17 14:28:11 +08:00
stream_session.hh
streaming: Fix a race between initiator and follower
2015-08-17 14:28:11 +08:00
stream_state.hh
streaming: Implement stream_result_future::handle_session_complete
2015-07-21 16:12:54 +08:00
stream_summary.cc
streaming: Add operator<< for stream_summary
2015-08-04 16:21:40 +08:00
stream_summary.hh
streaming: Add operator<< for stream_summary
2015-08-04 16:21:40 +08:00
stream_task.cc
streaming: Swith to use shared_ptr from std::shared_ptr
2015-07-14 20:41:14 +08:00
stream_task.hh
streaming: Swith to use shared_ptr from std::shared_ptr
2015-07-14 20:41:14 +08:00
stream_transfer_task.cc
mutation_reader: make noncopyable
2015-08-25 15:49:08 +03:00
stream_transfer_task.hh
streaming: Fix create_message_for_retry
2015-08-17 10:52:30 +08:00
streaming.cc
streaming: Convert StreamManager.java to C++
2015-07-14 20:41:14 +08:00