Commit 3b10a63d authored by Dominik Charousset's avatar Dominik Charousset

Add abstract_downstream::paths

parent 815a51c4
...@@ -162,10 +162,15 @@ public: ...@@ -162,10 +162,15 @@ public:
/// Returns how many items should be stored on individual paths in order to /// Returns how many items should be stored on individual paths in order to
/// minimize latency between received demand and sent batches. /// minimize latency between received demand and sent batches.
long min_buffer_size() const { inline long min_buffer_size() const {
return min_buffer_size_; return min_buffer_size_;
} }
/// Returns all currently available paths on this downstream.
const path_list& paths() const {
return paths_;
}
protected: protected:
void send_batch(downstream_path& dest, long chunk_size, message chunk); void send_batch(downstream_path& dest, long chunk_size, message chunk);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment