Home
last modified time | relevance | path

Searched refs:grpc_metadata_batch (Results 1 – 25 of 36) sorted by relevance

12

/external/grpc-grpc/src/core/lib/transport/
Dmetadata_batch.h47 typedef struct grpc_metadata_batch { struct
55 } grpc_metadata_batch; typedef
57 void grpc_metadata_batch_init(grpc_metadata_batch* batch);
58 void grpc_metadata_batch_destroy(grpc_metadata_batch* batch);
59 void grpc_metadata_batch_clear(grpc_metadata_batch* batch);
60 bool grpc_metadata_batch_is_empty(grpc_metadata_batch* batch);
63 size_t grpc_metadata_batch_size(grpc_metadata_batch* batch);
66 void grpc_metadata_batch_remove(grpc_metadata_batch* batch,
70 grpc_error* grpc_metadata_batch_substitute(grpc_metadata_batch* batch,
82 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch,
[all …]
Dmetadata_batch.cc56 static void assert_valid_callouts(grpc_metadata_batch* batch) { in assert_valid_callouts()
71 void grpc_metadata_batch_assert_ok(grpc_metadata_batch* batch) { in grpc_metadata_batch_assert_ok()
76 void grpc_metadata_batch_init(grpc_metadata_batch* batch) { in grpc_metadata_batch_init()
81 void grpc_metadata_batch_destroy(grpc_metadata_batch* batch) { in grpc_metadata_batch_destroy()
96 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch,
100 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch, in maybe_link_callout()
117 static void maybe_unlink_callout(grpc_metadata_batch* batch, in maybe_unlink_callout()
129 grpc_error* grpc_metadata_batch_add_head(grpc_metadata_batch* batch, in grpc_metadata_batch_add_head()
152 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, in grpc_metadata_batch_link_head()
165 grpc_error* grpc_metadata_batch_add_tail(grpc_metadata_batch* batch, in grpc_metadata_batch_add_tail()
[all …]
Dtransport.h170 grpc_metadata_batch* send_initial_metadata;
183 grpc_metadata_batch* send_trailing_metadata;
195 grpc_metadata_batch* recv_initial_metadata;
224 grpc_metadata_batch* recv_trailing_metadata;
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dincoming_metadata.h28 grpc_metadata_batch batch;
38 grpc_chttp2_incoming_metadata_buffer* buffer, grpc_metadata_batch* batch);
Dinternal.h497 grpc_metadata_batch* send_initial_metadata;
499 grpc_metadata_batch* send_trailing_metadata;
511 grpc_metadata_batch* recv_initial_metadata;
516 grpc_metadata_batch* recv_trailing_metadata;
Dhpack_encoder.h92 grpc_metadata_batch* metadata,
Dincoming_metadata.cc71 grpc_chttp2_incoming_metadata_buffer* buffer, grpc_metadata_batch* batch) { in grpc_chttp2_incoming_metadata_buffer_publish()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc70 grpc_metadata_batch to_read_initial_md;
73 grpc_metadata_batch to_read_trailing_md;
80 grpc_metadata_batch write_buffer_initial_md;
84 grpc_metadata_batch write_buffer_trailing_md;
183 static void log_metadata(const grpc_metadata_batch* md_batch, bool is_client, in log_metadata()
197 const grpc_metadata_batch* metadata, in fill_in_metadata()
198 uint32_t flags, grpc_metadata_batch* out_md, in fill_in_metadata()
406 grpc_metadata_batch fake_md; in fail_helper_locked()
410 grpc_metadata_batch* dest = (other == nullptr) in fail_helper_locked()
432 grpc_metadata_batch fake_md; in fail_helper_locked()
[all …]
/external/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc37 grpc_metadata_batch* recv_initial_metadata;
47 static bool get_user_agent_mdelem(const grpc_metadata_batch* batch, in get_user_agent_mdelem()
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc53 grpc_metadata_batch* recv_initial_metadata;
58 grpc_metadata_batch* recv_trailing_metadata;
80 grpc_metadata_batch* b) { in client_filter_incoming_metadata()
290 grpc_metadata_batch* b = in update_path_for_get()
296 static void remove_if_present(grpc_metadata_batch* batch, in remove_if_present()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h50 explicit MetadataBatch(grpc_metadata_batch* batch) : batch_(batch) {} in MetadataBatch()
52 grpc_metadata_batch* batch() const { return batch_; } in batch()
102 grpc_metadata_batch* batch_; // Not owned.
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_filter.cc45 void FilterInitialMetadata(grpc_metadata_batch* b, in FilterInitialMetadata()
87 grpc_metadata_batch* initial_metadata = calld->recv_initial_metadata_; in OnDoneRecvInitialMetadataCb()
Dserver_filter.h83 grpc_metadata_batch* recv_initial_metadata_;
Dclient_filter.h82 grpc_metadata_batch* recv_trailing_metadata_;
Dclient_filter.cc37 void FilterTrailingMetadata(grpc_metadata_batch* b, uint64_t* elapsed_time) { in FilterTrailingMetadata()
/external/grpc-grpc/test/core/transport/chttp2/
Dhpack_encoder_test.cc63 grpc_metadata_batch b; in verify()
209 grpc_metadata_batch b; in verify_table_size_change_match_elem_size()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc56 grpc_metadata_batch* recv_initial_metadata;
77 grpc_metadata_batch* b) { in hs_filter_outgoing_metadata()
102 grpc_metadata_batch* b) { in hs_filter_incoming_metadata()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc321 grpc_metadata_batch b; in BM_StreamCreateSendInitialMetadataDestroy()
409 grpc_metadata_batch b; in BM_TransportStreamSend()
540 grpc_metadata_batch b; in BM_TransportStreamRecv()
542 grpc_metadata_batch b_recv; in BM_TransportStreamRecv()
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.h90 grpc_metadata_batch* recv_initial_metadata_;
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dlb_policy.h66 grpc_metadata_batch* initial_metadata;
Dclient_channel.cc854 grpc_metadata_batch send_initial_metadata;
860 grpc_metadata_batch send_trailing_metadata;
862 grpc_metadata_batch recv_initial_metadata;
869 grpc_metadata_batch recv_trailing_metadata;
939 grpc_metadata_batch* recv_trailing_metadata;
976 grpc_metadata_batch send_initial_metadata;
992 grpc_metadata_batch send_trailing_metadata;
1020 grpc_metadata_batch* send_initial_metadata = in maybe_cache_send_ops_for_batch()
1045 grpc_metadata_batch* send_trailing_metadata = in maybe_cache_send_ops_for_batch()
1791 grpc_metadata_batch* md_batch, grpc_error* error, in get_call_status()
[all …]
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc105 grpc_call_element* elem, grpc_metadata_batch* initial_metadata,
108 grpc_call_element* elem, grpc_metadata_batch* initial_metadata, in process_send_initial_metadata()
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc107 grpc_metadata_batch* mdb = in on_credentials_metadata()
295 grpc_metadata_batch* metadata = in auth_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc151 grpc_metadata_batch metadata_batch[2][2];
865 grpc_metadata_batch* batch = in prepare_application_metadata()
949 static void publish_app_metadata(grpc_call* call, grpc_metadata_batch* b, in publish_app_metadata()
972 static void recv_initial_filter(grpc_call* call, grpc_metadata_batch* b) { in recv_initial_filter()
1006 static void recv_trailing_filter(void* args, grpc_metadata_batch* b, in recv_trailing_filter()
1394 grpc_metadata_batch* md = in receiving_initial_metadata_ready()
1449 grpc_metadata_batch* md = in receiving_trailing_metadata_ready()
Dlame_client.cc54 static void fill_metadata(grpc_call_element* elem, grpc_metadata_batch* mdb) { in fill_metadata()

12