Searched refs:recv_message_ (Results 1 – 13 of 13) sorted by relevance
121 OrphanablePtr<ByteStream>* recv_message_ = nullptr; member in grpc_core::__anonf6df0ef00111::CallData190 if (*calld->recv_message_ == nullptr || in OnRecvMessageReady()191 (*calld->recv_message_)->length() == 0 || in OnRecvMessageReady()192 ((*calld->recv_message_)->flags() & GRPC_WRITE_INTERNAL_COMPRESS) == in OnRecvMessageReady()197 (*calld->recv_message_)->length() > in OnRecvMessageReady()201 (*calld->recv_message_)->length(), calld->max_recv_message_length_); in OnRecvMessageReady()218 while ((*recv_message_) in ContinueReadingRecvMessage()219 ->Next((*recv_message_)->length() - recv_slices_.length, in ContinueReadingRecvMessage()226 if (recv_slices_.length == (*recv_message_)->length()) { in ContinueReadingRecvMessage()234 grpc_error* error = (*recv_message_)->Pull(&incoming_slice); in PullSliceFromRecvMessage()[all …]
356 payload_.recv_message.recv_message = &recv_message_; in StartCall()459 recv_message_.reset(); in DoneReadingRecvMessage()481 payload_.recv_message.recv_message = &recv_message_; in DoneReadingRecvMessage()490 grpc_error* error = recv_message_->Pull(&slice); in PullSliceFromRecvMessage()498 while (recv_message_->Next(SIZE_MAX, &recv_message_ready_)) { in ContinueReadingRecvMessage()504 if (recv_message_buffer_.length == recv_message_->length()) { in ContinueReadingRecvMessage()524 if (self->recv_message_buffer_.length == self->recv_message_->length()) { in OnByteStreamNext()536 if (self->recv_message_ == nullptr) { in RecvMessageReady()
126 OrphanablePtr<ByteStream> recv_message_; variable
48 recv_message_(nullptr), in CensusServerCallData()91 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message_; variable
47 recv_message_(nullptr), in CensusClientCallData()93 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message_; variable
75 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()115 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
74 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()140 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
82 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()125 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
74 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()142 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
122 void* GetRecvMessage() override { return recv_message_; } in GetRecvMessage()169 recv_message_ = message; in SetRecvMessage()405 void* recv_message_ = nullptr; variable