/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
_channel_rpc.py | 23 def send_initial_metadata(self, initial_metadata): member in class:_UnaryUnary 24 self._rpc_state.send_initial_metadata(initial_metadata) 39 def send_initial_metadata(self, initial_metadata): member in class:_UnaryStream 40 self._rpc_state.send_initial_metadata(initial_metadata) 57 def send_initial_metadata(self, initial_metadata): member in class:_StreamUnary 58 self._rpc_state.send_initial_metadata(initial_metadata) 79 def send_initial_metadata(self, initial_metadata): member in class:_StreamStream 80 self._rpc_state.send_initial_metadata(initial_metadata)
|
/external/grpc-grpc/src/core/ext/filters/http/client/ |
http_client_filter.cc | 45 // State for handling send_initial_metadata ops. 252 // Modifies the path entry in the batch's send_initial_metadata to 258 GRPC_MDVALUE(batch->payload->send_initial_metadata.send_initial_metadata 291 batch->payload->send_initial_metadata.send_initial_metadata; 331 if (batch->send_initial_metadata) { 338 (batch->payload->send_initial_metadata.send_initial_metadata_flags & 370 } else if (batch->payload->send_initial_metadata 377 batch->payload->send_initial_metadata.send_initial_metadata [all...] |
/external/grpc-grpc/src/cpp/common/ |
channel_filter.h | 136 op->send_initial_metadata 137 ? op->payload->send_initial_metadata.send_initial_metadata 157 MetadataBatch* send_initial_metadata() { function in class:grpc::TransportStreamOpBatch 158 return op_->send_initial_metadata ? &send_initial_metadata_ : nullptr; 171 return op_->send_initial_metadata ? &op_->payload->send_initial_metadata 211 if (op_->send_initial_metadata && 212 op_->payload->send_initial_metadata.peer_string != nullptr) { 213 return op_->payload->send_initial_metadata.peer_string [all...] |
/external/grpc-grpc/src/core/ext/filters/http/ |
client_authority_filter.cc | 54 // Handle send_initial_metadata. 56 batch->payload->send_initial_metadata.send_initial_metadata; 58 if (batch->send_initial_metadata &&
|
/external/grpc-grpc/src/objective-c/GRPCClient/private/ |
GRPCWrappedCall.m | 66 _op.data.send_initial_metadata.count = metadata.count; 67 _op.data.send_initial_metadata.metadata = metadata.grpc_metadataArray; 68 _op.data.send_initial_metadata.maybe_compression_level.is_set = false; 69 _op.data.send_initial_metadata.maybe_compression_level.level = 0; 77 for (int i = 0; i < _op.data.send_initial_metadata.count; i++) { 78 grpc_slice_unref(_op.data.send_initial_metadata.metadata[i].key); 79 grpc_slice_unref(_op.data.send_initial_metadata.metadata[i].value); 81 gpr_free(_op.data.send_initial_metadata.metadata);
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
_servicer_context.py | 59 def send_initial_metadata(self, initial_metadata): member in class:ServicerContext 60 initial_metadata_sent = self._rpc.send_initial_metadata( 64 'ServicerContext.send_initial_metadata called too late!')
|
/external/grpc-grpc/src/csharp/ext/ |
grpc_csharp_ext.c | 55 grpc_metadata_array send_initial_metadata; member in struct:grpcsharp_batch_context 200 &(ctx->send_initial_metadata)); 570 grpcsharp_metadata_array_move(&(ctx->send_initial_metadata), 572 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; 573 ops[0].data.send_initial_metadata.metadata = 574 ctx->send_initial_metadata.metadata; 620 grpcsharp_metadata_array_move(&(ctx->send_initial_metadata), 622 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count [all...] |
/external/grpc-grpc/src/core/lib/transport/ |
transport.h | 140 bool send_initial_metadata : 1; member in struct:grpc_transport_stream_op_batch 170 grpc_metadata_batch* send_initial_metadata; member in struct:grpc_transport_stream_op_batch_payload::__anon23252 171 /** Iff send_initial_metadata != NULL, flags associated with 172 send_initial_metadata: a bitfield of GRPC_INITIAL_METADATA_xxx */ 177 // send_initial_metadata op is completed. It must remain valid 180 } send_initial_metadata; member in struct:grpc_transport_stream_op_batch_payload
|
/external/grpc-grpc/src/cpp/ext/filters/census/ |
client_filter.cc | 83 if (op->send_initial_metadata() != nullptr) { 94 op->send_initial_metadata()->batch(), &tracing_bin_, 106 op->send_initial_metadata()->batch(), &stats_bin_,
|
/external/grpc-grpc/src/core/lib/surface/ |
call_log_batch.cc | 55 gpr_strvec_add(&b, gpr_strdup("SEND_INITIAL_METADATA")); 56 add_metadata(&b, op->data.send_initial_metadata.metadata, 57 op->data.send_initial_metadata.count);
|
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
_compression_test.py | 29 servicer_context.send_initial_metadata([('grpc-internal-encoding-request', 37 servicer_context.send_initial_metadata([('grpc-internal-encoding-request',
|
_metadata_test.py | 103 servicer_context.send_initial_metadata(_INITIAL_METADATA) 110 servicer_context.send_initial_metadata(_INITIAL_METADATA) 118 servicer_context.send_initial_metadata(_INITIAL_METADATA) 128 servicer_context.send_initial_metadata(_INITIAL_METADATA)
|
/external/grpc-grpc/src/ruby/lib/grpc/generic/ |
active_call.rb | 66 call.run_batch(SEND_INITIAL_METADATA => metadata) 119 def send_initial_metadata(new_metadata = {}) method in class:GRPC.ActiveCall 192 send_initial_metadata 208 send_initial_metadata 231 ops[SEND_INITIAL_METADATA] = @metadata_to_send unless @metadata_sent 362 ops[SEND_INITIAL_METADATA] = @metadata_to_send.merge!(metadata) 396 send_initial_metadata(metadata) 445 ops[SEND_INITIAL_METADATA] = @metadata_to_send.merge!(metadata) 498 send_initial_metadata(metadata) 617 merge_metadata_to_send(metadata) && send_initial_metadata [all...] |
/external/grpc-grpc/test/core/bad_client/tests/ |
large_metadata.cc | 125 op.data.send_initial_metadata.count = 1; 126 op.data.send_initial_metadata.metadata = &meta;
|
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
_server_application.py | 44 context.send_initial_metadata(((
|
_client_test.py | 60 rpc.send_initial_metadata(()) 76 rpc.send_initial_metadata(()) 90 rpc.send_initial_metadata(()) 174 rpc.send_initial_metadata(()) 196 rpc.send_initial_metadata((( 246 rpc.send_initial_metadata(()) 287 rpc.send_initial_metadata(())
|
/external/grpc-grpc/test/core/fling/ |
server.cc | 95 op->data.send_initial_metadata.count = 0; 121 static void send_initial_metadata(void) { function 126 metadata_send_op.data.send_initial_metadata.count = 0; 263 send_initial_metadata();
|
/external/grpc-grpc/src/core/ext/filters/http/server/ |
http_server_filter.cc | 43 // Outgoing headers to add to send_initial_metadata. 345 if (op->send_initial_metadata) { 350 op->payload->send_initial_metadata.send_initial_metadata, 354 op->payload->send_initial_metadata.send_initial_metadata, 360 elem, op->payload->send_initial_metadata.send_initial_metadata));
|
/external/grpc-grpc/test/core/end2end/tests/ |
stream_compression_compressed_payload.cc | 159 op->data.send_initial_metadata.count = 1; 160 op->data.send_initial_metadata.metadata = client_metadata; 162 op->data.send_initial_metadata.count = 0; 198 op->data.send_initial_metadata.count = 0; 355 op->data.send_initial_metadata.count = 1; 356 op->data.send_initial_metadata.metadata = client_init_metadata; 358 op->data.send_initial_metadata.count = 0; 402 op->data.send_initial_metadata.count = 0; 404 op->data.send_initial_metadata.maybe_compression_level.is_set = true; 405 op->data.send_initial_metadata.maybe_compression_level.level [all...] |
bad_ping.cc | 124 op->data.send_initial_metadata.count = 0; 125 op->data.send_initial_metadata.metadata = nullptr; 174 op->data.send_initial_metadata.count = 0; 283 op->data.send_initial_metadata.count = 0; 284 op->data.send_initial_metadata.metadata = nullptr; 330 op->data.send_initial_metadata.count = 0;
|
filter_status_code.cc | 153 op->data.send_initial_metadata.count = 0; 154 op->data.send_initial_metadata.metadata = nullptr; 193 op->data.send_initial_metadata.count = 0; 264 if (op->send_initial_metadata) { 265 auto* batch = op->payload->send_initial_metadata.send_initial_metadata;
|
max_connection_age.cc | 125 op->data.send_initial_metadata.count = 0; 126 op->data.send_initial_metadata.metadata = nullptr; 176 op->data.send_initial_metadata.count = 0; 267 op->data.send_initial_metadata.count = 0; 268 op->data.send_initial_metadata.metadata = nullptr; 309 op->data.send_initial_metadata.count = 0;
|
workaround_cronet_compression.cc | 172 op->data.send_initial_metadata.count = 1; 173 op->data.send_initial_metadata.metadata = client_init_metadata; 175 op->data.send_initial_metadata.count = 0; 215 op->data.send_initial_metadata.count = 0; 217 op->data.send_initial_metadata.maybe_compression_level.is_set = true; 218 op->data.send_initial_metadata.maybe_compression_level.level =
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
writing.cc | 411 s->sent_initial_metadata, s->send_initial_metadata != nullptr, 419 if (s_->send_initial_metadata == nullptr) return; 430 is_default_initial_metadata(s_->send_initial_metadata)) { 444 s_->send_initial_metadata, &hopt, &t_->outbuf); 449 s_->send_initial_metadata = nullptr; 557 if (s_->send_initial_metadata->idx.named.status != nullptr) { 560 &s_->send_initial_metadata->idx.named.status->md; 562 if (s_->send_initial_metadata->idx.named.content_type != nullptr) { 565 &s_->send_initial_metadata->idx.named.content_type->md;
|
/external/grpc-grpc/src/core/lib/security/transport/ |
client_auth_filter.cc | 106 GPR_ASSERT(batch->send_initial_metadata); 108 batch->payload->send_initial_metadata.send_initial_metadata; 294 if (batch->send_initial_metadata) { 296 batch->payload->send_initial_metadata.send_initial_metadata;
|