diff --git a/async/as/ThreadBase.h b/async/as/ThreadBase.h index 4201338..0c5bc08 100644 --- a/async/as/ThreadBase.h +++ b/async/as/ThreadBase.h @@ -207,9 +207,9 @@ class ThreadBase : public Base { * Wait for the asynchronous call to finish */ void wait() override { - m_waiting = true; - pthread_mutex_unlock(&m_readerLock); lock_spinlock(&m_writerLock); + // call wait synchronously here (TODO: move to output) + Base::wait(); m_phase = SEND_PHASE; }