Commit d638a99a authored by Dominik Charousset's avatar Dominik Charousset

Fix deadlock in producer_adapter test

parent c375eeb4
...@@ -108,7 +108,9 @@ public: ...@@ -108,7 +108,9 @@ public:
FAIL("unable to parse input: " << err); FAIL("unable to parse input: " << err);
++received_messages; ++received_messages;
if (auto capacity_left = adapter_->push(val); capacity_left == 0) if (auto capacity_left = adapter_->push(val); capacity_left == 0)
{
down->suspend_reading(); down->suspend_reading();
}
return static_cast<ptrdiff_t>(buf.size()); return static_cast<ptrdiff_t>(buf.size());
} }
...@@ -119,7 +121,6 @@ public: ...@@ -119,7 +121,6 @@ public:
struct fixture : test_coordinator_fixture<>, host_fixture { struct fixture : test_coordinator_fixture<>, host_fixture {
fixture() : mm(sys) { fixture() : mm(sys) {
mm.mpx().set_thread_id();
if (auto err = mm.mpx().init()) if (auto err = mm.mpx().init())
CAF_FAIL("mpx.init() failed: " << err); CAF_FAIL("mpx.init() failed: " << err);
} }
......
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