Asias He f527e07be6 streaming: Get stream_session in STREAM_MUTATION handler ...

Get from address from cinfo. It is needed to figure out which stream
session this mutation is belonged to, since we need to update the keep
alive timer for this stream session.

2015-12-24 20:34:44 +08:00

..

compress

Add license notices

2015-09-20 10:43:39 +03:00

messages

Fix typo in stream_init_message.hh

2015-09-20 11:42:50 +03:00

progress_info.cc

Add license notices

2015-09-20 10:43:39 +03:00

progress_info.hh

Add license notices

2015-09-20 10:43:39 +03:00

session_info.cc

Add license notices

2015-09-20 10:43:39 +03:00

session_info.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_coordinator.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_coordinator.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_detail.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_event_handler.hh

streaming: Add two more virtual destructors

2015-11-13 09:55:19 +02:00

stream_event.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_exception.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_manager.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_manager.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_plan.cc

streaming: Handle stream_plan with no range added

2015-11-10 15:39:34 +08:00

stream_plan.hh

streaming: Handle stream_plan with no range added

2015-11-10 15:39:34 +08:00

stream_receive_task.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_receive_task.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_request.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_request.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_result_future.cc

streaming: Remove bogus file size info for prepare completed

2015-11-10 15:39:34 +08:00

stream_result_future.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_session_state.cc

streaming: Add operator<< for stream_session_state

2015-11-10 15:39:34 +08:00

stream_session_state.hh

streaming: Add operator<< for stream_session_state

2015-11-10 15:39:34 +08:00

stream_session.cc

streaming: Get stream_session in STREAM_MUTATION handler

2015-12-24 20:34:44 +08:00

stream_session.hh

gossip: Pass const ref for versioned_value in on_change and before_change

2015-12-09 12:29:15 +08:00

stream_state.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_summary.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_summary.hh

Add license notices

2015-09-20 10:43:39 +03:00

stream_task.cc

Add license notices

2015-09-20 10:43:39 +03:00

stream_task.hh

streaming: Add two more virtual destructors

2015-11-13 09:55:19 +02:00

stream_transfer_task.cc

streaming: Ignore remote no_such_column_family for stream_transfer_task

2015-11-18 15:12:23 +02:00

stream_transfer_task.hh

Add license notices

2015-09-20 10:43:39 +03:00

streaming.cc

Add license notices

2015-09-20 10:43:39 +03:00