Skip to content

Commit 94aa4b2

Browse files
committed
Fix build.
1 parent 0de3964 commit 94aa4b2

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Common/Cpp/SerialConnection/SerialConnectionPOSIX.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ class SerialConnection : public StreamConnection{
164164

165165
// Start receiver thread.
166166
try{
167-
m_listener = thread_pool.blocking_dispatch([this]{
167+
m_listener = thread_pool.dispatch_now_blocking([this]{
168168
run_with_catch(
169169
"SerialConnection::SerialConnection()",
170170
[this]{ recv_loop(); }

Common/Cpp/Sockets/ClientSocket_POSIX.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ class ClientSocket_POSIX final : public AbstractClientSocket{
6262
}
6363
try{
6464
m_state.store(State::CONNECTING, std::memory_order_relaxed);
65-
m_thread = m_thread_pool.blocking_dispatch([=, this]{
65+
m_thread = m_thread_pool.dispatch_now_blocking([=, this]{
6666
thread_loop(address, port);
6767
});
6868
}catch (...){

0 commit comments

Comments
 (0)