Lines Matching refs:comm
308 Communication *comm = (Communication *)p; in ReadThread() local
320 while (!done && comm->m_read_thread_enabled) { in ReadThread()
321 size_t bytes_read = comm->ReadFromConnection( in ReadThread()
324 comm->AppendBytesToCache(buf, bytes_read, true, status); in ReadThread()
332 disconnect = comm->GetCloseOnEOF(); in ReadThread()
337 disconnect = comm->GetCloseOnEOF(); in ReadThread()
348 comm->BroadcastEvent(eBroadcastBitNoMorePendingInput); in ReadThread()
369 comm->m_read_thread_did_exit = true; in ReadThread()
372 comm->BroadcastEvent(eBroadcastBitNoMorePendingInput); in ReadThread()
375 std::lock_guard<std::mutex> guard(comm->m_synchronize_mutex); in ReadThread()
378 comm->Disconnect(); in ReadThread()
382 comm->BroadcastEvent(eBroadcastBitReadThreadDidExit); in ReadThread()