Lines Matching refs:m_comm

291     : m_comm(comm), m_acquired(false) {  in ContinueLock()
303 std::unique_lock<std::mutex> lock(m_comm.m_mutex); in unlock()
304 m_comm.m_is_running = false; in unlock()
306 m_comm.m_cv.notify_all(); in unlock()
314 __FUNCTION__, m_comm.m_continue_packet.c_str()); in lock()
317 std::unique_lock<std::mutex> lock(m_comm.m_mutex); in lock()
318 m_comm.m_cv.wait(lock, [this] { return m_comm.m_async_count == 0; }); in lock()
319 if (m_comm.m_should_stop) { in lock()
320 m_comm.m_should_stop = false; in lock()
325 if (m_comm.SendPacketNoLock(m_comm.m_continue_packet) != in lock()
329 lldbassert(!m_comm.m_is_running); in lock()
330 m_comm.m_is_running = true; in lock()
341 : m_async_lock(comm.m_async_mutex, std::defer_lock), m_comm(comm), in Lock()
351 std::unique_lock<std::mutex> lock(m_comm.m_mutex); in SyncWithContinueThread()
352 if (m_comm.m_is_running && m_interrupt_timeout == std::chrono::seconds(0)) in SyncWithContinueThread()
356 ++m_comm.m_async_count; in SyncWithContinueThread()
357 if (m_comm.m_is_running) { in SyncWithContinueThread()
358 if (m_comm.m_async_count == 1) { in SyncWithContinueThread()
363 size_t bytes_written = m_comm.Write(&ctrl_c, 1, status, nullptr); in SyncWithContinueThread()
365 --m_comm.m_async_count; in SyncWithContinueThread()
370 m_comm.m_interrupt_endpoint = steady_clock::now() + m_interrupt_timeout; in SyncWithContinueThread()
374 m_comm.m_cv.wait(lock, [this] { return !m_comm.m_is_running; }); in SyncWithContinueThread()
384 std::unique_lock<std::mutex> lock(m_comm.m_mutex); in ~Lock()
385 --m_comm.m_async_count; in ~Lock()
387 m_comm.m_cv.notify_one(); in ~Lock()