16 Commits

Author	SHA1	Message	Date
Asias He	bdd6a69af7	streaming: Drop unused parameters ... - int connections_per_host Scylla does not create connections per stream_session, instead it uses rpc, thus connections_per_host is not relevant to scylla. - bool keep_ss_table_level - int repaired_at Scylla does not stream sstable files. They are not relevant to scylla.	2016-01-25 11:38:13 +08:00
Asias He	88e99e89d6	streaming: Add more debug info ... - Add debug for the peer address info - Add debug in stream_transfer_task and stream_receive_task - Add debug when cancel the keep_alive timer - Add debug for has_active_sessions in stream_result_future::maybe_complete	2016-01-22 07:43:16 +08:00
Asias He	13934140f6	streaming: Remove bogus file size info for prepare completed ... Scylla does not streaming sstable files directly for streaming. The file size info is incorrect, let's get rid of it.	2015-11-10 15:39:34 +08:00
Avi Kivity	d5cf0fb2b1	Add license notices	2015-09-20 10:43:39 +03:00
Asias He	804564fe76	streaming: Remove completed stream in stream_manager	2015-07-31 16:27:55 +08:00
Asias He	1749305165	streaming: Fix stream_result_future::create_and_register ... It is used to create stream initiated by us.	2015-07-31 16:27:55 +08:00
Asias He	59cae82470	streaming: Make stream_plan::execute return a future ... Returns a ready future if the stream_plan completes successfully, or a failed future otherwise.	2015-07-31 16:27:55 +08:00
Asias He	3a5af0a7fb	streaming: Fix stream_coordinator::is_receiving ... Unlike Origin, We can not use _connections_per_host == 0 to indicate we are a follower since we set _connections_per_host to 1 for follower too.	2015-07-31 16:27:55 +08:00
Asias He	93f17024a8	streaming: Fix a logger printout ... Before: [Stream #136c5310-2f7a-11e5-87df-000000000000 ID#0] [Stream #136c5310-2f7a-11e5-87df-000000000000, ID#0] After: [Stream #136c5310-2f7a-11e5-87df-000000000000 ID#0] [Stream #136c5310-2f7a-11e5-87df-000000000000 ID#0]	2015-07-21 16:12:54 +08:00
Asias He	0e5fa35bd2	streaming: Register to stream_manager in create_and_register	2015-07-21 16:12:54 +08:00
Asias He	1f5feee5f2	streaming: Implement stream_result_future::handle_progress	2015-07-21 16:12:54 +08:00
Asias He	d74e414d09	streaming: Implement stream_result_future::handle_session_complete	2015-07-21 16:12:54 +08:00
Asias He	5e6f84cba8	streaming: Implement stream_result_future::handle_session_prepared ... Instead of playing the game of casting between stream_event and derived class. We overload handle_stream_event with derived stream_event class. virtual void handle_stream_event(session_complete_event event) {} virtual void handle_stream_event(progress_event event) {} virtual void handle_stream_event(session_prepared_event event) {} Also, make the virtual function non pure virtual, so user can override the interested event only without defining all of the three.	2015-07-21 16:12:54 +08:00
Asias He	d9b7cb4142	streaming: Enable logger in stream_result_future	2015-07-21 16:12:54 +08:00
Asias He	fd04337e80	streaming: Wire up register_receiving init_receiving_side ... Now stream_result_future can create a stream_coordinator if not provided. So - On sending side, stream_coordinator is created by stream_plan - On receiving side, stream_coordinator is created by stream_result_future	2015-07-14 20:41:14 +08:00
Asias He	1828019d60	streaming: Convert StreamManager.java to C++	2015-07-14 20:41:14 +08:00