Commit 352b44a0 authored by Philipp Götze's avatar Philipp Götze
Browse files

Calling future's get instead of wait to forward exceptions

parent e8ea0592
Pipeline #188 canceled with stages
in 2 minutes and 38 seconds
...@@ -78,7 +78,7 @@ void Topology::wait(const std::chrono::milliseconds &dur) { ...@@ -78,7 +78,7 @@ void Topology::wait(const std::chrono::milliseconds &dur) {
std::lock_guard<std::mutex> guard(mMutex); std::lock_guard<std::mutex> guard(mMutex);
// let's wait until the function finished // let's wait until the function finished
for(auto &f : startupFutures) for(auto &f : startupFutures)
f.wait(); f.get();
//TODO: wait for EndOfStream Punctuations on all sinks //TODO: wait for EndOfStream Punctuations on all sinks
//TODO: what about merging streams or no actual sinks? //TODO: what about merging streams or no actual sinks?
std::unique_lock<std::mutex> lk(mCv_m); std::unique_lock<std::mutex> lk(mCv_m);
......
...@@ -17,6 +17,7 @@ ...@@ -17,6 +17,7 @@
* along with PipeFabric. If not, see <http://www.gnu.org/licenses/>. * along with PipeFabric. If not, see <http://www.gnu.org/licenses/>.
*/ */
#pragma once
#ifndef Topology_hpp_ #ifndef Topology_hpp_
#define Topology_hpp_ #define Topology_hpp_
......
Supports Markdown
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