Home
last modified time | relevance | path

Searched refs:op_payload (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc265 grpc_transport_stream_op_batch_payload op_payload; in BM_StreamCreateDestroy() local
268 op.payload = &op_payload; in BM_StreamCreateDestroy()
269 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateDestroy()
311 grpc_transport_stream_op_batch_payload op_payload; in BM_StreamCreateSendInitialMetadataDestroy() local
312 memset(&op_payload, 0, sizeof(op_payload)); in BM_StreamCreateSendInitialMetadataDestroy()
318 op.payload = &op_payload; in BM_StreamCreateSendInitialMetadataDestroy()
363 grpc_transport_stream_op_batch_payload op_payload; in BM_TransportEmptyOp() local
364 memset(&op_payload, 0, sizeof(op_payload)); in BM_TransportEmptyOp()
367 op.payload = &op_payload; in BM_TransportEmptyOp()
379 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportEmptyOp()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1339 grpc_transport_stream_op_batch_payload* op_payload = op->payload; in perform_stream_op_locked() local
1350 log_metadata(op_payload->send_initial_metadata.send_initial_metadata, in perform_stream_op_locked()
1354 log_metadata(op_payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op_locked()
1370 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()
1382 if (op_payload->send_initial_metadata.send_initial_metadata->idx.named in perform_stream_op_locked()
1386 op_payload->send_initial_metadata.send_initial_metadata->idx in perform_stream_op_locked()
1399 op_payload->send_initial_metadata.send_initial_metadata; in perform_stream_op_locked()
1439 if (op_payload->send_initial_metadata.peer_string != nullptr) { in perform_stream_op_locked()
1440 gpr_atm_rel_store(op_payload->send_initial_metadata.peer_string, in perform_stream_op_locked()
1465 uint32_t flags = op_payload->send_message.send_message->flags(); in perform_stream_op_locked()
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1368 grpc_transport_stream_op_batch_payload* op_payload = op->payload; in perform_stream_op_locked() local
1379 log_metadata(op_payload->send_initial_metadata.send_initial_metadata, in perform_stream_op_locked()
1383 log_metadata(op_payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op_locked()
1406 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()
1415 if (op_payload->send_initial_metadata.send_initial_metadata->idx.named in perform_stream_op_locked()
1419 op_payload->send_initial_metadata.send_initial_metadata->idx in perform_stream_op_locked()
1427 op_payload->send_initial_metadata.send_initial_metadata; in perform_stream_op_locked()
1487 if (op_payload->send_initial_metadata.peer_string != nullptr) { in perform_stream_op_locked()
1488 gpr_atm_rel_store(op_payload->send_initial_metadata.peer_string, in perform_stream_op_locked()
1518 uint32_t flags = op_payload->send_message.send_message->flags(); in perform_stream_op_locked()
[all …]