| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 58 class CallData { class
60 CallData(const grpc_call_element_args& args, const ChannelData* chand) in CallData() function in grpc_core::__anone4066a570111::CallData
86 ~CallData() { grpc_slice_buffer_destroy_internal(&recv_slices_); } in ~CallData()
152 void CallData::OnRecvInitialMetadataReady(void* arg, grpc_error* error) { in OnRecvInitialMetadataReady()
153 CallData* calld = static_cast<CallData*>(arg); in OnRecvInitialMetadataReady()
168 void CallData::MaybeResumeOnRecvMessageReady() { in MaybeResumeOnRecvMessageReady()
177 void CallData::OnRecvMessageReady(void* arg, grpc_error* error) { in OnRecvMessageReady()
178 CallData* calld = static_cast<CallData*>(arg); in OnRecvMessageReady()
217 void CallData::ContinueReadingRecvMessage() { in ContinueReadingRecvMessage()
232 grpc_error* CallData::PullSliceFromRecvMessage() { in PullSliceFromRecvMessage()
[all …]
|
| D | message_compress_filter.cc | 103 class CallData { class
105 CallData(grpc_call_element* elem, const grpc_call_element_args& args) in CallData() function in __anon1526ae8e0111::CallData
120 ~CallData() { in ~CallData()
176 bool CallData::SkipMessageCompression() { in SkipMessageCompression()
225 void CallData::InitializeState(grpc_call_element* elem) { in InitializeState()
235 grpc_error* CallData::ProcessSendInitialMetadata( in ProcessSendInitialMetadata()
284 void CallData::SendMessageOnComplete(void* calld_arg, grpc_error* error) { in SendMessageOnComplete()
285 CallData* calld = static_cast<CallData*>(calld_arg); in SendMessageOnComplete()
292 void CallData::SendMessageBatchContinue(grpc_call_element* elem) { in SendMessageBatchContinue()
300 void CallData::FinishSendMessage(grpc_call_element* elem) { in FinishSendMessage()
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | lame_client.cc | 42 struct CallData { struct
55 CallData* calld = static_cast<CallData*>(elem->call_data); in fill_metadata()
81 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch()
122 CallData* calld = static_cast<CallData*>(elem->call_data); in init_call_elem()
149 sizeof(grpc_core::CallData),
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | server.cc | 183 CallData* calld) = 0;
207 CallData* calld = pending_.front(); in ZombifyPending()
208 calld->SetState(CallData::CallState::ZOMBIED); in ZombifyPending()
236 CallData* calld; in RequestCallWithPossiblePublish()
267 CallData* calld) override { in MatchOrQueue()
274 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()
299 calld->SetState(CallData::CallState::PENDING); in MatchOrQueue()
305 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()
313 std::queue<CallData*> pending_;
372 CallData* calld) override { in MatchOrQueue()
[all …]
|
| D | lame_client.cc | 51 struct CallData { struct
57 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch()
95 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_init_call_elem()
132 sizeof(grpc_core::CallData),
|
| D | server.h | 230 class CallData {
239 CallData(grpc_call_element* elem, const grpc_call_element_args& args,
241 ~CallData();
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 70 class CallData { class in ServerImpl
75 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData() function in ServerImpl::CallData
97 new CallData(service_, cq_); in Proceed()
142 new CallData(&service_, cq_.get()); in HandleRpcs()
153 static_cast<CallData*>(tag)->Proceed(); in HandleRpcs()
|
| /external/webrtc/modules/audio_processing/test/ |
| D | api_call_statistics.h | 35 struct CallData { struct
36 CallData(int64_t duration_nanos, CallType call_type);
40 std::vector<CallData> calls_; argument
|
| D | api_call_statistics.cc | 25 calls_.push_back(CallData(duration_nanos, call_type)); in Add()
88 ApiCallStatistics::CallData::CallData(int64_t duration_nanos, in CallData() function in webrtc::test::ApiCallStatistics::CallData
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/ |
| D | client_idle_filter.cc | 382 class CallData { class
391 grpc_error* CallData::Init(grpc_call_element* elem, in Init()
398 void CallData::Destroy(grpc_call_element* elem, in Destroy()
408 sizeof(CallData),
409 CallData::Init,
411 CallData::Destroy,
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 409 class CallData { class
436 CallData(grpc_call_element* elem, const ChannelData& chand,
438 ~CallData();
2151 CallData* calld = static_cast<CallData*>(elem->call_data); in OnResolverErrorLocked()
2341 CallData* calld = static_cast<CallData*>(elem->call_data); in UpdateServiceConfigInDataPlaneLocked()
2642 CallData::CallData(grpc_call_element* elem, const ChannelData& chand, in CallData() function in grpc_core::__anon5e2240680111::CallData
2656 CallData::~CallData() { in ~CallData()
2665 grpc_error* CallData::Init(grpc_call_element* elem, in Init()
2668 new (elem->call_data) CallData(elem, *chand, *args); in Init()
2672 void CallData::Destroy(grpc_call_element* elem, in Destroy()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | channel_filter.cc | 54 void CallData::StartTransportStreamOpBatch(grpc_call_element* elem, in StartTransportStreamOpBatch()
59 void CallData::SetPollsetOrPollsetSet(grpc_call_element* elem, in SetPollsetOrPollsetSet()
|
| D | channel_filter.h | 254 class CallData {
256 CallData() {} in CallData() function
257 virtual ~CallData() {} in ~CallData()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.cc | 55 void CallData::StartTransportStreamOpBatch(grpc_call_element* elem, in StartTransportStreamOpBatch()
60 void CallData::SetPollsetOrPollsetSet(grpc_call_element* elem, in SetPollsetOrPollsetSet()
|
| D | channel_filter.h | 254 class CallData {
256 CallData() {} in CallData() function
257 virtual ~CallData() {} in ~CallData()
|
| /external/grpc-grpc/test/cpp/common/ |
| D | channel_filter_test.cc | 38 class MyCallData : public CallData {
|
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.h | 44 class ServerLoadReportingCallData : public CallData {
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.h | 46 class ServerLoadReportingCallData : public CallData {
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | client_filter.h | 35 class CensusClientCallData : public CallData {
|
| D | server_filter.h | 37 class CensusServerCallData : public CallData {
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/ |
| D | client_filter.h | 35 class CensusClientCallData : public CallData {
|
| D | server_filter.h | 37 class CensusServerCallData : public CallData {
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 207 class CallData final { class in grpc::Server::SyncRequest
209 explicit CallData(Server* server, SyncRequest* mrd) in CallData() function in grpc::Server::SyncRequest::CallData
225 ~CallData() { in ~CallData()
322 SyncRequest::CallData cd(server_, sync_req); in DoWork()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 418 class CallData final { class in grpc::Server::SyncRequest
420 explicit CallData(Server* server, SyncRequest* mrd) in CallData() function in grpc::Server::SyncRequest::CallData
442 ~CallData() { in ~CallData()
798 auto* cd = new SyncRequest::CallData(server_, sync_req); in DoWork()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | filter_end2end_test.cc | 109 class CallDataImpl : public CallData {
|