Searched refs:got_message (Results 1 – 5 of 5) sorted by relevance
431 bool got_message = false; variable447 got_message = *status = in FinishOp()452 got_message = false; in FinishOp()480 if (!got_message) interceptor_methods->SetRecvMessage(nullptr, nullptr); in SetFinishInterceptionHookPoint()487 got_message = true; in SetHijackingState()493 got_message = false; in FinishOpRecvMessageFailureHandler()540 bool got_message = false; variable556 got_message = true; in FinishOp()560 got_message = false; in FinishOp()572 got_message = false; in FinishOp()[all …]
89 if (!ops.got_message && status_.ok()) { in BlockingUnaryCallImpl()
215 return cq_.Pluck(&ops) && ops.got_message; in Read()485 return cq_.Pluck(&ops) && ops.got_message; in Read()611 return call_->cq()->Pluck(&ops) && ops.got_message; in Read()739 return call_->cq()->Pluck(&ops) && ops.got_message; in Read()
215 return cq_.Pluck(&ops) && ops.got_message; in Read()484 return cq_.Pluck(&ops) && ops.got_message; in Read()610 return call_->cq()->Pluck(&ops) && ops.got_message; in Read()737 return call_->cq()->Pluck(&ops) && ops.got_message; in Read()
862 got_message (GstRtmpConnection * connection, GstBuffer * buffer, in got_message() function996 got_message, g_object_ref (self), g_object_unref); in connect_task_done()