HomeSort by relevance Sort by last modified time
    Searched refs:send_initial_metadata (Results 1 - 25 of 149) sorted by null

1 2 3 4 5 6

  /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;

Completed in 408 milliseconds

1 2 3 4 5 6