Home
last modified time | relevance | path

Searched defs:call_data (Results 1 – 25 of 29) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc44 struct call_data { struct
45 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() argument
57 ~call_data() { in ~call_data()
64 grpc_core::CallCombiner* call_combiner;
67 grpc_linked_mdelem status;
68 grpc_linked_mdelem content_type;
72 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream;
73 bool have_read_stream = false;
76 grpc_closure recv_initial_metadata_ready;
77 grpc_error* recv_initial_metadata_ready_error = GRPC_ERROR_NONE;
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc57 struct call_data { struct
58 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() argument
72 ~call_data() { GRPC_ERROR_UNREF(recv_initial_metadata_error); } in ~call_data()
74 grpc_core::CallCombiner* call_combiner;
76 grpc_linked_mdelem method;
77 grpc_linked_mdelem scheme;
78 grpc_linked_mdelem authority;
79 grpc_linked_mdelem te_trailers;
80 grpc_linked_mdelem content_type;
81 grpc_linked_mdelem user_agent;
[all …]
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc40 struct call_data { struct
41 grpc_call_combiner* call_combiner;
44 grpc_linked_mdelem status;
45 grpc_linked_mdelem content_type;
49 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream;
50 bool have_read_stream;
53 grpc_closure recv_initial_metadata_ready;
54 grpc_error* recv_initial_metadata_ready_error;
55 grpc_closure* original_recv_initial_metadata_ready;
56 grpc_metadata_batch* recv_initial_metadata;
[all …]
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc43 struct call_data { struct
44 grpc_call_combiner* call_combiner;
46 grpc_linked_mdelem method;
47 grpc_linked_mdelem scheme;
48 grpc_linked_mdelem authority;
49 grpc_linked_mdelem te_trailers;
50 grpc_linked_mdelem content_type;
51 grpc_linked_mdelem user_agent;
53 grpc_metadata_batch* recv_initial_metadata;
54 grpc_error* recv_initial_metadata_error;
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc50 struct call_data { struct
51 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() argument
75 ~call_data() { GRPC_ERROR_UNREF(recv_initial_metadata_error); } in ~call_data()
77 grpc_core::CallCombiner* call_combiner;
78 grpc_call_stack* owning_call;
79 grpc_transport_stream_op_batch* recv_initial_metadata_batch;
80 grpc_closure* original_recv_initial_metadata_ready;
81 grpc_closure recv_initial_metadata_ready;
82 grpc_error* recv_initial_metadata_error = GRPC_ERROR_NONE;
83 grpc_closure recv_trailing_metadata_ready;
[all …]
Dclient_auth_filter.cc66 struct call_data { struct
67 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() function
90 void destroy() { in destroy()
98 grpc_call_stack* owning_call;
99 grpc_core::CallCombiner* call_combiner;
100 grpc_core::RefCountedPtr<grpc_call_credentials> creds;
101 grpc_slice host = grpc_empty_slice();
102 grpc_slice method = grpc_empty_slice();
107 grpc_polling_entity* pollent = nullptr;
108 grpc_credentials_mdelem_array md_array;
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc143 struct call_data { struct
144 call_data(grpc_call_element* elem, const channel_data& chand, in call_data() function
172 ~call_data() { GRPC_ERROR_UNREF(error); } in ~call_data()
174 grpc_core::CallCombiner* call_combiner;
175 grpc_core::MessageSizeParsedConfig::message_size_limits limits;
179 grpc_closure recv_message_ready;
180 grpc_closure recv_trailing_metadata_ready;
182 grpc_error* error = GRPC_ERROR_NONE;
184 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message = nullptr;
186 grpc_closure* next_recv_message_ready = nullptr;
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc39 struct call_data { struct
41 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats;
43 grpc_closure on_complete_for_send;
44 grpc_closure* original_on_complete_for_send;
45 bool send_initial_metadata_succeeded;
47 grpc_closure recv_initial_metadata_ready;
48 grpc_closure* original_recv_initial_metadata_ready;
49 bool recv_initial_metadata_succeeded;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc42 struct call_data { struct
44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats;
46 grpc_closure on_complete_for_send;
47 grpc_closure* original_on_complete_for_send;
48 bool send_initial_metadata_succeeded = false;
50 grpc_closure recv_initial_metadata_ready;
51 grpc_closure* original_recv_initial_metadata_ready;
52 bool recv_initial_metadata_succeeded = false;
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc52 struct call_data { struct
53 grpc_call_combiner* call_combiner;
54 grpc_linked_mdelem compression_algorithm_storage;
55 grpc_linked_mdelem stream_compression_algorithm_storage;
56 grpc_linked_mdelem accept_encoding_storage;
57 grpc_linked_mdelem accept_stream_encoding_storage;
60 grpc_message_compression_algorithm message_compression_algorithm;
61 initial_metadata_state send_initial_metadata_state;
62 grpc_error* cancel_error;
63 grpc_closure start_send_message_batch_in_call_combiner;
[all …]
/external/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc38 struct call_data { struct
39 grpc_call_combiner* call_combiner;
40 grpc_call_stack* owning_call;
41 grpc_transport_stream_op_batch* recv_initial_metadata_batch;
42 grpc_closure* original_recv_initial_metadata_ready;
43 grpc_closure recv_initial_metadata_ready;
44 grpc_error* error;
45 grpc_closure recv_trailing_metadata_ready;
46 grpc_closure* original_recv_trailing_metadata_ready;
47 grpc_metadata_array md;
[all …]
Dclient_auth_filter.cc44 struct call_data { struct
45 gpr_arena* arena;
46 grpc_call_stack* owning_call;
47 grpc_call_combiner* call_combiner;
48 grpc_call_credentials* creds;
49 grpc_slice host;
50 grpc_slice method;
55 grpc_polling_entity* pollent;
56 grpc_credentials_mdelem_array md_array;
57 grpc_linked_mdelem md_links[MAX_CREDENTIALS_METADATA_COUNT];
[all …]
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc95 struct call_data { struct
96 grpc_call_combiner* call_combiner;
97 message_size_limits limits;
101 grpc_closure recv_message_ready;
102 grpc_closure recv_trailing_metadata_ready;
104 grpc_error* error;
106 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message;
108 grpc_closure* next_recv_message_ready;
110 grpc_closure* original_recv_trailing_metadata_ready;
/external/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc31 struct call_data { struct
35 grpc_closure recv_initial_metadata_ready;
37 grpc_metadata_batch* recv_initial_metadata;
39 grpc_closure* next_recv_initial_metadata_ready;
42 bool workaround_active;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc31 struct call_data { struct
35 grpc_closure recv_initial_metadata_ready;
37 grpc_metadata_batch* recv_initial_metadata;
39 grpc_closure* next_recv_initial_metadata_ready;
42 bool workaround_active;
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc128 struct call_data { struct
129 grpc_call* call;
131 gpr_atm state;
133 bool path_set;
134 bool host_set;
135 grpc_slice path;
136 grpc_slice host;
137 grpc_millis deadline;
139 grpc_completion_queue* cq_new;
141 grpc_metadata_batch* recv_initial_metadata;
[all …]
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc41 struct call_data { struct
42 grpc_linked_mdelem authority_storage;
43 grpc_call_combiner* call_combiner;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc41 struct call_data { struct
42 grpc_linked_mdelem authority_storage;
43 grpc_core::CallCombiner* call_combiner;
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h325 CallDataType* call_data = new (elem->call_data) CallDataType(); in InitCallElement() local
332 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in DestroyCallElement() local
339 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in StartTransportStreamOpBatch() local
346 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in SetPollsetOrPollsetSet() local
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h325 CallDataType* call_data = new (elem->call_data) CallDataType(); in InitCallElement() local
332 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in DestroyCallElement() local
339 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in StartTransportStreamOpBatch() local
346 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in SetPollsetOrPollsetSet() local
/external/grpc-grpc/test/core/channel/
Dchannel_stack_test.cc97 int* call_data; in test_create_channel_stack() local
/external/freetype/src/bdf/
Dbdflib.c1269 void* call_data, in _bdf_parse_end()
1289 void* call_data, in _bdf_parse_glyphs()
1769 void* call_data, in _bdf_parse_properties()
1872 void* call_data, in _bdf_parse_start()
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_causes_close.cc192 } call_data; typedef
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc54 } call_data; typedef
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc55 } call_data; typedef

12