mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-27 03:45:11 +00:00
streaming: Rename start to init_streaming_service
stream_session::start is used to start a session instead of initialization on startup.
This commit is contained in:
@@ -88,7 +88,7 @@ void stream_session::init_messaging_service_handler() {
|
||||
|
||||
distributed<stream_session::handler> stream_session::_handlers;
|
||||
|
||||
future<> stream_session::start() {
|
||||
future<> stream_session::init_streaming_service() {
|
||||
return _handlers.start().then([this] {
|
||||
return _handlers.invoke_on_all([this] (handler& h) {
|
||||
this->init_messaging_service_handler();
|
||||
|
||||
@@ -125,7 +125,7 @@ private:
|
||||
};
|
||||
static distributed<handler> _handlers;
|
||||
void init_messaging_service_handler();
|
||||
future<> start();
|
||||
future<> init_streaming_service();
|
||||
public:
|
||||
struct ss_table_streaming_sections {
|
||||
sstables::sstable& sstable;
|
||||
|
||||
Reference in New Issue
Block a user