mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-27 03:45:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

streaming: Add flush_before_transfer to stream_plan

Browse Source
This commit is contained in:
Asias He
2015-06-30 15:36:28 +08:00
parent 878611beee
commit abf24b3bfa
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
streaming/stream_plan.cc
View File

@@ -52,4 +52,9 @@ stream_plan& stream_plan::transfer_files(inet_address to, std::vector<stream_ses
return *this;
}
stream_plan& stream_plan::flush_before_transfer(bool flush_before_transfer_) {
_flush_before_transfer = flush_before_transfer_;
return *this;
}
}

8
streaming/stream_plan.hh
View File

@@ -175,6 +175,7 @@ public:
{
return StreamResultFuture.init(planId, description, handlers, coordinator);
}
#endif
/**
* Set flushBeforeTransfer option.
@@ -183,12 +184,7 @@ public:
* @param flushBeforeTransfer set to true when the node should flush before transfer
* @return this object for chaining
*/
public StreamPlan flushBeforeTransfer(boolean flushBeforeTransfer)
{
this.flushBeforeTransfer = flushBeforeTransfer;
return this;
}
#endif
stream_plan& flush_before_transfer(bool flush_before_transfer_);
};
} // namespace streaming