| /dports/devel/grpc/grpc-1.42.0/test/core/transport/binder/ |
| H A D | binder_transport_test.cc | 279 op->recv_trailing_metadata = true; in MakeRecvTrailingMetadata()
280 op->payload->recv_trailing_metadata.recv_trailing_metadata = in MakeRecvTrailingMetadata()
282 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in MakeRecvTrailingMetadata()
539 MakeRecvTrailingMetadata recv_trailing_metadata(&op); in TEST_F() local
548 recv_trailing_metadata.notification.WaitForNotification(); in TEST_F()
551 recv_trailing_metadata.grpc_trailing_metadata); in TEST_F()
563 MakeRecvTrailingMetadata recv_trailing_metadata(&op); in TEST_F() local
580 recv_trailing_metadata.notification.WaitForNotification(); in TEST_F()
586 recv_trailing_metadata.grpc_trailing_metadata); in TEST_F()
633 MakeRecvTrailingMetadata recv_trailing_metadata( in TEST_F() local
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/binder/transport/ |
| H A D | binder_transport.cc | 161 gbs->recv_trailing_metadata = nullptr; in cancel_stream_locked()
274 GPR_ASSERT(gbs->recv_trailing_metadata); in recv_trailing_metadata_locked()
295 GPR_ASSERT(gbs->recv_trailing_metadata->LinkTail(glm) == in recv_trailing_metadata_locked()
298 gbs->recv_trailing_metadata); in recv_trailing_metadata_locked()
307 gbs->recv_trailing_metadata = nullptr; in recv_trailing_metadata_locked()
333 !op->recv_message && !op->recv_trailing_metadata); in perform_stream_op_locked()
367 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
503 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
506 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in perform_stream_op_locked()
507 gbs->recv_trailing_metadata = in perform_stream_op_locked()
[all …]
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/binder/transport/ |
| H A D | binder_transport.cc | 161 gbs->recv_trailing_metadata = nullptr; in cancel_stream_locked()
274 GPR_ASSERT(gbs->recv_trailing_metadata); in recv_trailing_metadata_locked()
295 GPR_ASSERT(gbs->recv_trailing_metadata->LinkTail(glm) == in recv_trailing_metadata_locked()
298 gbs->recv_trailing_metadata); in recv_trailing_metadata_locked()
307 gbs->recv_trailing_metadata = nullptr; in recv_trailing_metadata_locked()
379 !op->recv_message && !op->recv_trailing_metadata); in perform_stream_op_locked()
413 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
519 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
522 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in perform_stream_op_locked()
523 gbs->recv_trailing_metadata = in perform_stream_op_locked()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/cpp/ext/filters/census/ |
| H A D | client_filter.cc | 120 if (op->recv_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
121 recv_trailing_metadata_ = op->recv_trailing_metadata()->batch(); in StartTransportStreamOpBatch()
123 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
124 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
|
| /dports/devel/grpc130/grpc-1.30.2/src/cpp/ext/filters/census/ |
| H A D | client_filter.cc | 130 if (op->recv_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
131 recv_trailing_metadata_ = op->recv_trailing_metadata()->batch(); in StartTransportStreamOpBatch()
133 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
134 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
|
| /dports/devel/grpc134/grpc-1.34.1/src/cpp/ext/filters/census/ |
| H A D | client_filter.cc | 130 if (op->recv_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
131 recv_trailing_metadata_ = op->recv_trailing_metadata()->batch(); in StartTransportStreamOpBatch()
133 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
134 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
|
| /dports/devel/grpc/grpc-1.42.0/src/cpp/common/ |
| H A D | channel_filter.h | 106 op->recv_trailing_metadata in TransportStreamOpBatch()
107 ? op->payload->recv_trailing_metadata.recv_trailing_metadata in TransportStreamOpBatch()
124 MetadataBatch* recv_trailing_metadata() { in recv_trailing_metadata() function
125 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/transport/ |
| H A D | transport.h | 170 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
205 bool recv_trailing_metadata : 1; member
305 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
309 } recv_trailing_metadata; member
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/transport/ |
| H A D | transport.h | 170 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
205 bool recv_trailing_metadata : 1; member
297 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
301 } recv_trailing_metadata; member
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/transport/ |
| H A D | transport.h | 170 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
205 bool recv_trailing_metadata : 1; member
303 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
307 } recv_trailing_metadata; member
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/transport/ |
| H A D | transport.h | 165 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
200 bool recv_trailing_metadata : 1; member
280 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
284 } recv_trailing_metadata; member
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/transport/ |
| H A D | transport.h | 170 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
205 bool recv_trailing_metadata : 1; member
305 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
309 } recv_trailing_metadata; member
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/transport/ |
| H A D | transport.h | 169 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
204 bool recv_trailing_metadata : 1; member
304 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
308 } recv_trailing_metadata; member
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 88 grpc_metadata_batch* recv_trailing_metadata; member
216 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
369 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
371 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
372 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 88 grpc_metadata_batch* recv_trailing_metadata; member
216 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
369 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
371 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
372 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 89 grpc_metadata_batch* recv_trailing_metadata; member
224 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
382 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
384 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
385 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
387 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
388 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 79 grpc_metadata_batch* recv_trailing_metadata; member
208 client_filter_incoming_metadata(elem, calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
359 if (batch->recv_trailing_metadata) { in hc_start_transport_stream_op_batch()
361 calld->recv_trailing_metadata = in hc_start_transport_stream_op_batch()
362 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in hc_start_transport_stream_op_batch()
364 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in hc_start_transport_stream_op_batch()
365 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in hc_start_transport_stream_op_batch()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 89 grpc_metadata_batch* recv_trailing_metadata; member
224 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
382 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
384 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
385 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
387 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
388 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 88 grpc_metadata_batch* recv_trailing_metadata; member
216 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
374 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
376 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
377 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
379 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
380 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc130/grpc-1.30.2/src/cpp/common/ |
| H A D | channel_filter.h | 148 op->recv_trailing_metadata in TransportStreamOpBatch()
149 ? op->payload->recv_trailing_metadata.recv_trailing_metadata in TransportStreamOpBatch()
166 MetadataBatch* recv_trailing_metadata() { in recv_trailing_metadata() function
167 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
|
| /dports/devel/grpc134/grpc-1.34.1/src/cpp/common/ |
| H A D | channel_filter.h | 148 op->recv_trailing_metadata in TransportStreamOpBatch()
149 ? op->payload->recv_trailing_metadata.recv_trailing_metadata in TransportStreamOpBatch()
166 MetadataBatch* recv_trailing_metadata() { in recv_trailing_metadata() function
167 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/cpp/common/ |
| H A D | channel_filter.h | 148 op->recv_trailing_metadata in TransportStreamOpBatch()
149 ? op->payload->recv_trailing_metadata.recv_trailing_metadata in TransportStreamOpBatch()
166 MetadataBatch* recv_trailing_metadata() { in recv_trailing_metadata() function
167 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/surface/ |
| H A D | lame_client.cc | 83 } else if (op->recv_trailing_metadata) { in lame_start_transport_stream_op_batch()
85 op->payload->recv_trailing_metadata.recv_trailing_metadata); in lame_start_transport_stream_op_batch()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/ |
| H A D | client_channel.cc | 1901 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in MaybeInjectRecvTrailingMetadataReadyForLoadBalancingPolicy()
2013 (!batch->recv_trailing_metadata || in MaybeClearPendingBatch()
2053 if (batch->recv_trailing_metadata) { in PendingBatchesFail()
2107 if (batch->recv_trailing_metadata) { in PendingBatchesResume()
2346 if (batch.recv_trailing_metadata) { in Destroy()
2578 &retry_state->recv_trailing_metadata, in AddClosureForRecvTrailingMetadataReady()
2579 pending->batch->payload->recv_trailing_metadata.recv_trailing_metadata); in AddClosureForRecvTrailingMetadataReady()
2707 batch_data->batch.payload->recv_trailing_metadata.recv_trailing_metadata; in RecvTrailingMetadataReady()
3014 batch_data->batch.payload->recv_trailing_metadata.recv_trailing_metadata = in AddRetriableRecvTrailingMetadataOp()
3155 if (batch->recv_trailing_metadata && in AddSubchannelBatchesForPendingBatches()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/surface/ |
| H A D | lame_client.cc | 88 } else if (op->recv_trailing_metadata) { in lame_start_transport_stream_op_batch()
90 op->payload->recv_trailing_metadata.recv_trailing_metadata); in lame_start_transport_stream_op_batch()
|