307     : m_comm(comm), m_acquired(false) {  in ContinueLock()
319     std::unique_lock<std::mutex> lock(m_comm.m_mutex);  in unlock()
320     m_comm.m_is_running = false;  in unlock()
322   m_comm.m_cv.notify_all();  in unlock()
330             __FUNCTION__, m_comm.m_continue_packet.c_str());  in lock()
333   std::unique_lock<std::mutex> lock(m_comm.m_mutex);  in lock()
334   m_comm.m_cv.wait(lock, [this] { return m_comm.m_async_count == 0; });  in lock()
335   if (m_comm.m_should_stop) {  in lock()
336     m_comm.m_should_stop = false;  in lock()
341   if (m_comm.SendPacketNoLock(m_comm.m_continue_packet) !=  in lock()
345   lldbassert(!m_comm.m_is_running);  in lock()
346   m_comm.m_is_running = true;  in lock()
357     : m_async_lock(comm.m_async_mutex, std::defer_lock), m_comm(comm),  in Lock()
367   std::unique_lock<std::mutex> lock(m_comm.m_mutex);  in SyncWithContinueThread()
368   if (m_comm.m_is_running && m_interrupt_timeout == std::chrono::seconds(0))  in SyncWithContinueThread()
372   ++m_comm.m_async_count;  in SyncWithContinueThread()
373   if (m_comm.m_is_running) {  in SyncWithContinueThread()
374     if (m_comm.m_async_count == 1) {  in SyncWithContinueThread()
379       size_t bytes_written = m_comm.Write(&ctrl_c, 1, status, nullptr);  in SyncWithContinueThread()
381         --m_comm.m_async_count;  in SyncWithContinueThread()
386       m_comm.m_interrupt_endpoint = steady_clock::now() + m_interrupt_timeout;  in SyncWithContinueThread()
390     m_comm.m_cv.wait(lock, [this] { return !m_comm.m_is_running; });  in SyncWithContinueThread()
400     std::unique_lock<std::mutex> lock(m_comm.m_mutex);  in ~Lock()
401     --m_comm.m_async_count;  in ~Lock()
403   m_comm.m_cv.notify_one();  in ~Lock()