mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-21 00:50:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

streaming: Handle cf_id does not exist case in STREAM_MUTATION handler

Browse Source
This commit is contained in:
Asias He
2015-07-15 11:01:21 +08:00
parent 69ce554a0f
commit 7e365cb440
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
streaming/stream_session.cc
View File

@@ -81,9 +81,15 @@ void stream_session::init_messaging_service_handler() {
sslog.debug("GOT STREAM_MUTATION");
return smp::submit_to(dst_cpu_id, [fm = std::move(fm)] () mutable {
auto cf_id = fm.column_family_id();
auto& db = stream_session::get_local_db();
auto& cf = db.find_column_family(cf_id);
cf.apply(fm, db::replay_position());
sslog.debug("STREAM_MUTATION: cf_id={}", cf_id);
try {
auto& db = stream_session::get_local_db();
auto& cf = db.find_column_family(cf_id);
cf.apply(fm, db::replay_position());
} catch (no_such_column_family) {
// TODO: Send error msg back
sslog.warn("stream_session: {} does not exist\n", cf_id);
}
return make_ready_future<>();
});
});