Home
last modified time | relevance | path

Searched refs:grpc_mdelem (Results 1 – 25 of 61) sorted by relevance

123

/third_party/grpc/src/core/lib/transport/
Dmetadata.h65 typedef struct grpc_mdelem grpc_mdelem; typedef
98 struct grpc_mdelem { struct
109 (grpc_mdelem{((uintptr_t)(data)) | ((uintptr_t)(storage))}) argument
112 ((grpc_mdelem){((uintptr_t)(data)) | ((uintptr_t)(storage))})
122 grpc_mdelem grpc_mdelem_from_slices(const grpc_slice& key,
127 grpc_mdelem grpc_mdelem_from_slices(const grpc_core::StaticMetadataSlice& key,
131 grpc_mdelem grpc_mdelem_from_slices(
136 grpc_mdelem grpc_mdelem_from_slices(const grpc_core::StaticMetadataSlice& key,
140 grpc_mdelem grpc_mdelem_from_slices(const grpc_core::ManagedMemorySlice& key,
145 grpc_mdelem grpc_mdelem_from_grpc_metadata(grpc_metadata* metadata);
[all …]
Dmetadata_batch.h36 grpc_mdelem md;
76 grpc_mdelem new_mdelem);
113 grpc_mdelem elem_to_add) GRPC_MUST_USE_RESULT;
125 grpc_mdelem elem_to_add, grpc_metadata_batch_callouts_index idx) { in grpc_metadata_batch_add_head()
139 grpc_mdelem elem_to_add) GRPC_MUST_USE_RESULT;
149 grpc_mdelem elem_to_add, grpc_metadata_batch_callouts_index idx) { in grpc_metadata_batch_add_tail()
155 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md);
159 grpc_mdelem md;
169 void* user_data, grpc_mdelem elem);
Dmetadata.cc280 static int is_mdelem_static(grpc_mdelem e) { in is_mdelem_static()
355 static grpc_mdelem md_create_maybe_static(const grpc_slice& key,
358 static grpc_mdelem md_create_must_intern(const grpc_slice& key,
363 static grpc_mdelem md_create( in md_create()
400 static grpc_mdelem md_create_maybe_static(const grpc_slice& key, in md_create_maybe_static()
421 grpc_mdelem static_elem = grpc_static_mdelem_for_static_strings( in md_create_maybe_static()
437 static grpc_mdelem md_create_must_intern(const grpc_slice& key, in md_create_must_intern()
484 grpc_mdelem grpc_mdelem_create( in grpc_mdelem_create()
490 grpc_mdelem grpc_mdelem_create( in grpc_mdelem_create()
500 static grpc_mdelem md_from_slices(const grpc_slice& key, in md_from_slices()
[all …]
Dstatus_metadata.h29 grpc_status_code grpc_get_status_code_from_metadata(grpc_mdelem md);
35 grpc_mdelem grpc_get_reffed_status_elem_slowpath(int status_code);
36 inline grpc_mdelem grpc_get_reffed_status_elem(int status_code) { in grpc_get_reffed_status_elem()
Dmetadata_batch.cc94 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md) { in grpc_attach_md_to_error()
102 static grpc_error* GPR_ATTRIBUTE_NOINLINE error_with_md(grpc_mdelem md) { in error_with_md()
147 grpc_mdelem elem_to_add) { in grpc_metadata_batch_add_head()
202 grpc_mdelem elem_to_add) { in grpc_metadata_batch_add_tail()
292 grpc_mdelem old_mdelem = storage->md; in grpc_metadata_batch_set_value()
293 grpc_mdelem new_mdelem = grpc_mdelem_from_slices( in grpc_metadata_batch_set_value()
301 grpc_mdelem new_mdelem) { in grpc_metadata_batch_substitute()
304 grpc_mdelem old_mdelem = storage->md; in grpc_metadata_batch_substitute()
Dstatus_metadata.cc33 grpc_status_code grpc_get_status_code_from_metadata(grpc_mdelem md) { in grpc_get_status_code_from_metadata()
57 grpc_mdelem grpc_get_reffed_status_elem_slowpath(int status_code) { in grpc_get_reffed_status_elem_slowpath()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dhpack_table.h63 ents = static_cast<grpc_mdelem*>(gpr_malloc(AllocSize)); in grpc_chttp2_hptbl()
86 grpc_mdelem* ents = nullptr;
96 grpc_mdelem grpc_chttp2_hptbl_lookup_dynamic_index(const grpc_chttp2_hptbl* tbl,
98 grpc_mdelem grpc_chttp2_hptbl_lookup_ref_dynamic_index(
101 inline grpc_mdelem grpc_chttp2_hptbl_lookup(const grpc_chttp2_hptbl* tbl, in grpc_chttp2_hptbl_lookup()
121 grpc_mdelem md) GRPC_MUST_USE_RESULT;
123 size_t grpc_chttp2_get_size_in_hpack_table(grpc_mdelem elem,
129 inline uintptr_t grpc_chttp2_get_static_hpack_table_index(grpc_mdelem md) { in grpc_chttp2_get_static_hpack_table_index()
146 const grpc_chttp2_hptbl* tbl, grpc_mdelem md);
Dhpack_table.cc49 static grpc_mdelem lookup_dynamic_index(const grpc_chttp2_hptbl* tbl, in lookup_dynamic_index()
56 grpc_mdelem md = tbl->ents[offset]; in lookup_dynamic_index()
66 grpc_mdelem grpc_chttp2_hptbl_lookup_dynamic_index(const grpc_chttp2_hptbl* tbl, in grpc_chttp2_hptbl_lookup_dynamic_index()
71 grpc_mdelem grpc_chttp2_hptbl_lookup_ref_dynamic_index( in grpc_chttp2_hptbl_lookup_ref_dynamic_index()
78 grpc_mdelem first_ent = tbl->ents[tbl->first_ent]; in evict1()
90 grpc_mdelem* ents = in rebuild_ents()
91 static_cast<grpc_mdelem*>(gpr_malloc(sizeof(*ents) * new_cap)); in rebuild_ents()
148 grpc_error* grpc_chttp2_hptbl_add(grpc_chttp2_hptbl* tbl, grpc_mdelem md) { in grpc_chttp2_hptbl_add()
197 const grpc_chttp2_hptbl* tbl, grpc_mdelem md) { in grpc_chttp2_hptbl_find()
203 grpc_mdelem ent = grpc_static_mdelem_manifested()[i]; in grpc_chttp2_hptbl_find()
[all …]
Dhpack_encoder.cc106 typedef grpc_mdelem Type;
107 static const grpc_mdelem Null() { return {0}; } in Null()
108 static bool IsNull(const grpc_mdelem md) { return md.payload == 0; } in IsNull()
109 static bool Equals(const grpc_mdelem md1, const grpc_mdelem md2) { in Equals()
112 static void Ref(grpc_mdelem md) { in Ref()
116 static void Unref(grpc_mdelem md) { in Unref()
442 static void AddElemWithIndex(grpc_chttp2_hpack_compressor* c, grpc_mdelem elem, in AddElemWithIndex()
451 static void add_elem(grpc_chttp2_hpack_compressor* c, grpc_mdelem elem, in add_elem()
459 static void add_key(grpc_chttp2_hpack_compressor* c, grpc_mdelem elem, in add_key()
492 static wire_value get_wire_value(grpc_mdelem elem, bool true_binary_enabled) { in get_wire_value()
[all …]
Dincoming_metadata.h51 grpc_mdelem elem) GRPC_MUST_USE_RESULT;
54 grpc_mdelem elem) GRPC_MUST_USE_RESULT;
Dincoming_metadata.cc31 grpc_chttp2_incoming_metadata_buffer* buffer, grpc_mdelem elem) { in grpc_chttp2_incoming_metadata_buffer_add()
46 grpc_chttp2_incoming_metadata_buffer* buffer, grpc_mdelem elem) { in grpc_chttp2_incoming_metadata_buffer_replace_or_add()
Dhpack_encoder.h69 grpc_mdelem value;
101 grpc_mdelem** extra_headers,
Dhpack_parser.h48 grpc_error* (*on_header)(void* user_data, grpc_mdelem md);
75 grpc_mdelem md_for_index;
/third_party/grpc/test/core/transport/
Dmetadata_test.cc62 grpc_mdelem m1, m2, m3; in test_create_metadata()
118 grpc_mdelem* created = in test_create_many_persistant_metadata()
119 static_cast<grpc_mdelem*>(gpr_malloc(sizeof(grpc_mdelem) * MANY)); in test_create_many_persistant_metadata()
120 grpc_mdelem md; in test_create_many_persistant_metadata()
160 grpc_mdelem a, b, c; in test_spin_creating_the_same_thing()
187 grpc_mdelem a, b, c; in test_identity_laws()
273 grpc_mdelem md; in test_user_data_works()
296 grpc_mdelem md; in test_user_data_works_for_allocated_md()
317 grpc_mdelem elem = grpc_mdelem_from_slices( in verify_ascii_header_size()
329 grpc_mdelem elem = grpc_mdelem_from_slices( in verify_binary_header_size()
[all …]
Dstatic_metadata_test.cc34 const grpc_mdelem mdelem = grpc_static_mdelem_manifested()[i]; in TEST()
35 const grpc_mdelem mdelem2 = in TEST()
Dstatus_metadata_test.cc43 grpc_mdelem status_md = grpc_mdelem_from_slices( in TEST()
50 grpc_mdelem status_md = grpc_mdelem_from_slices( in TEST()
/third_party/grpc/src/core/lib/compression/
Dalgorithm_metadata.h38 grpc_mdelem grpc_compression_encoding_mdelem(
43 grpc_mdelem grpc_message_compression_encoding_mdelem(
48 grpc_mdelem grpc_stream_compression_encoding_mdelem(
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_chttp2_hpack.cc120 std::vector<grpc_mdelem> elems = Fixture::GetElems(); in BM_HpackEncoderEncodeHeader()
175 static std::vector<grpc_mdelem> GetElems() { return {}; } in GetElems()
181 static std::vector<grpc_mdelem> GetElems() { in GetElems()
189 static std::vector<grpc_mdelem> GetElems() { in GetElems()
200 static std::vector<grpc_mdelem> GetElems() { in GetElems()
202 std::vector<grpc_mdelem> out = {grpc_mdelem_from_slices( in GetElems()
223 static std::vector<grpc_mdelem> GetElems() { in GetElems()
233 static std::vector<grpc_mdelem> GetElems() { in GetElems()
243 static std::vector<grpc_mdelem> GetElems() { in GetElems()
262 static std::vector<grpc_mdelem> GetElems() { in GetElems()
[all …]
Dbm_metadata.cc125 grpc_mdelem seed = grpc_mdelem_create(k, v, nullptr); in BM_MetadataFromInternedSlicesAlreadyInIndex()
231 grpc_mdelem el = in BM_MetadataRefUnrefExternal()
250 grpc_mdelem el = grpc_mdelem_create( in BM_MetadataRefUnrefInterned()
266 grpc_mdelem el = in BM_MetadataRefUnrefAllocated()
281 grpc_mdelem el = in BM_MetadataRefUnrefStatic()
/third_party/grpc/src/core/lib/security/credentials/
Dcredentials_metadata.cc38 list->md = static_cast<grpc_mdelem*>( in mdelem_list_ensure_capacity()
39 gpr_realloc(list->md, sizeof(grpc_mdelem) * new_size)); in mdelem_list_ensure_capacity()
43 grpc_mdelem md) { in grpc_credentials_mdelem_array_add()
/third_party/grpc/src/core/ext/filters/workarounds/
Dworkaround_utils.h33 grpc_workaround_user_agent_md* grpc_parse_user_agent(grpc_mdelem md);
35 typedef bool (*user_agent_parser)(grpc_mdelem);
Dworkaround_cronet_compression_filter.cc48 grpc_mdelem* md) { in get_user_agent_mdelem()
62 grpc_mdelem md; in recv_initial_metadata_ready()
135 static bool parse_user_agent(grpc_mdelem md) { in parse_user_agent()
/third_party/grpc/src/core/lib/security/credentials/oauth2/
Doauth2_credentials.h98 grpc_mdelem access_token_md_ = GRPC_MDNULL;
149 grpc_mdelem access_token_md_;
161 const struct grpc_http_response* response, grpc_mdelem* token_md,
/third_party/grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.h76 grpc_mdelem md);
80 grpc_mdelem md);
/third_party/grpc/test/core/transport/chttp2/
Dhpack_table_test.cc46 grpc_mdelem md = grpc_chttp2_hptbl_lookup(tbl, idx); in assert_index()
130 grpc_mdelem elem; in test_many_additions()
154 grpc_mdelem md = grpc_mdelem_from_slices( in find_simple()
167 grpc_mdelem elem; in test_find()

123