Home
last modified time | relevance | path

Searched refs:tx_code (Results 1 – 24 of 24) sorted by relevance

/aosp_15_r20/external/grpc-grpc/test/core/transport/binder/end2end/
H A Dfake_binder_test.cc51 [&](transaction_code_t tx_code, ReadableParcel* parcel, int /*uid*/) { in TEST_P() argument
52 EXPECT_EQ(tx_code, kTxCode); in TEST_P()
76 [&](transaction_code_t tx_code, ReadableParcel* parcel, int /*uid*/) { in TEST_P() argument
77 EXPECT_EQ(tx_code, kTxCode); in TEST_P()
101 [&](transaction_code_t tx_code, ReadableParcel* parcel, int /*uid*/) { in TEST_P() argument
102 EXPECT_EQ(tx_code, kTxCode); in TEST_P()
131 [&](transaction_code_t tx_code, ReadableParcel* parcel, int /*uid*/) { in TEST_P() argument
133 EXPECT_EQ(tx_code, kTxCode); in TEST_P()
167 [&](transaction_code_t tx_code, ReadableParcel* parcel, int /*uid*/) { in TEST_P() argument
168 EXPECT_EQ(tx_code, kTxCode); in TEST_P()
[all …]
H A Dfake_binder.cc116 absl::Status FakeBinder::Transact(BinderTransportTxCode tx_code) { in Transact() argument
117 endpoint_->tunnel->EnQueueTransaction(endpoint_->other_end, tx_code, in Transact()
197 BinderTransportTxCode tx_code{}; in Flush() local
205 std::tie(target, tx_code, data) = std::move(tx_queue_.front()); in Flush()
214 tx_receiver->Receive(tx_code, parcel.get()).IgnoreError(); in Flush()
221 BinderTransportTxCode tx_code{}; in ProcessLoop() local
229 std::tie(target, tx_code, data) = std::move(tx_queue_.front()); in ProcessLoop()
238 tx_receiver->Receive(tx_code, parcel.get()).IgnoreError(); in ProcessLoop()
251 BinderTransportTxCode tx_code, in EnQueueTransaction() argument
258 tx_queue_.emplace(target, tx_code, std::move(data)); in EnQueueTransaction()
H A Dfake_binder.h185 absl::Status Receive(BinderTransportTxCode tx_code, ReadableParcel* parcel) { in Receive() argument
186 return callback_(static_cast<transaction_code_t>(tx_code), parcel, in Receive()
211 absl::Status Transact(BinderTransportTxCode tx_code) override;
244 void EnQueueTransaction(FakeEndpoint* target, BinderTransportTxCode tx_code,
287 void EnQueueTransaction(FakeEndpoint* target, BinderTransportTxCode tx_code, in EnQueueTransaction() argument
289 g_transaction_processor->EnQueueTransaction(target, tx_code, in EnQueueTransaction()
H A Dtesting_channel_create.cc44 [this](transaction_code_t tx_code, ReadableParcel* parcel, int uid) { in ServerSetupTransportHelper() argument
45 return this->wire_reader_->ProcessTransaction(tx_code, parcel, uid); in ServerSetupTransportHelper()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/binder/transport/
Dbinder_stream.h25 int tx_code; member
32 int tx_code; member
39 int tx_code; member
55 int tx_code, bool is_client) in grpc_binder_stream()
59 tx_code(tx_code), in grpc_binder_stream()
77 int GetTxCode() const { return tx_code; } in GetTxCode()
82 int tx_code; member
Dbinder_transport.cc158 gbt->transport_stream_receiver->CancelStream(gbs->tx_code); in cancel_stream_locked()
159 gbt->registered_stream.erase(gbs->tx_code); in cancel_stream_locked()
449 int tx_code = gbs->tx_code; in perform_stream_op_locked() local
450 auto tx = std::make_unique<grpc_binder::Transaction>(tx_code, gbt->is_client); in perform_stream_op_locked()
489 tx_code, [tx_code, gbs, in perform_stream_op_locked()
492 gbs->recv_initial_metadata_args.tx_code = tx_code; in perform_stream_op_locked()
510 tx_code, [tx_code, gbs, gbt](absl::StatusOr<std::string> message) { in perform_stream_op_locked()
512 gbs->recv_message_args.tx_code = tx_code; in perform_stream_op_locked()
528 tx_code, [tx_code, gbs, gbt]( in perform_stream_op_locked()
532 gbs->recv_trailing_metadata_args.tx_code = tx_code; in perform_stream_op_locked()
/aosp_15_r20/external/grpc-grpc/src/core/ext/transport/binder/transport/
H A Dbinder_stream.h25 int tx_code; member
32 int tx_code; member
39 int tx_code; member
55 int tx_code, bool is_client) in grpc_binder_stream()
59 tx_code(tx_code), in grpc_binder_stream()
77 int GetTxCode() const { return tx_code; } in GetTxCode()
82 int tx_code; member
H A Dbinder_transport.cc148 transport->transport_stream_receiver->CancelStream(stream->tx_code); in cancel_stream_locked()
149 transport->registered_stream.erase(stream->tx_code); in cancel_stream_locked()
446 int tx_code = stream->tx_code; in perform_stream_op_locked() local
448 std::make_unique<grpc_binder::Transaction>(tx_code, transport->is_client); in perform_stream_op_locked()
488 tx_code, [tx_code, stream, transport]( in perform_stream_op_locked()
491 stream->recv_initial_metadata_args.tx_code = tx_code; in perform_stream_op_locked()
512 tx_code, in perform_stream_op_locked()
513 [tx_code, stream, transport](absl::StatusOr<std::string> message) { in perform_stream_op_locked()
515 stream->recv_message_args.tx_code = tx_code; in perform_stream_op_locked()
532 tx_code, [tx_code, stream, transport]( in perform_stream_op_locked()
[all …]
/aosp_15_r20/external/grpc-grpc/test/core/transport/binder/
H A Dbinder_transport_test.cc386 EXPECT_EQ(gbs0->tx_code, kFirstCallId); in TEST_F()
389 EXPECT_EQ(gbs1->tx_code, kFirstCallId + 1); in TEST_F()
392 EXPECT_EQ(gbs2->tx_code, kFirstCallId + 2); in TEST_F()
529 gbt->transport_stream_receiver->NotifyRecvInitialMetadata(gbs->tx_code, in TEST_F()
552 gbs->tx_code, kInitialMetadataWithMethodRef); in TEST_F()
572 gbt->transport_stream_receiver->NotifyRecvMessage(gbs->tx_code, kMessage); in TEST_F()
594 gbs->tx_code, kTrailingMetadata, kStatus); in TEST_F()
618 gbs->tx_code, kInitialMetadataWithMethodRef); in TEST_F()
621 gbt->transport_stream_receiver->NotifyRecvMessage(gbs->tx_code, kMessage); in TEST_F()
626 gbs->tx_code, trailing_metadata, kStatus); in TEST_F()
[all …]
H A Dwire_reader_test.cc92 absl::Status CallProcessTransaction(T tx_code) { in CallProcessTransaction() argument
94 static_cast<transaction_code_t>(tx_code), &mock_readable_parcel_, in CallProcessTransaction()
/aosp_15_r20/external/grpc-grpc/src/core/ext/transport/binder/wire_format/
H A Dtransaction.h44 Transaction(int tx_code, bool is_client) in Transaction() argument
45 : tx_code_(tx_code), is_client_(is_client) {} in Transaction()
H A Dwire_writer.cc105 BinderTransportTxCode tx_code, in MakeBinderTransaction() argument
112 if (static_cast<int32_t>(tx_code) >= kFirstCallId) { in MakeBinderTransaction()
127 absl::Status result = binder_->Transact(tx_code); in MakeBinderTransaction()
H A Dbinder_android.cc203 absl::Status BinderAndroid::Transact(BinderTransportTxCode tx_code) { in Transact() argument
209 binder, static_cast<transaction_code_t>(tx_code), in Transact()
H A Dwire_writer.h83 BinderTransportTxCode tx_code,
H A Dbinder.h93 virtual absl::Status Transact(BinderTransportTxCode tx_code) = 0;
H A Dbinder_android.h90 absl::Status Transact(BinderTransportTxCode tx_code) override;
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/binder/wire_format/
Dtransaction.h44 Transaction(int tx_code, bool is_client) in Transaction() argument
45 : tx_code_(tx_code), is_client_(is_client) {} in Transaction()
Dwire_writer.cc103 BinderTransportTxCode tx_code, in MakeBinderTransaction() argument
110 if (static_cast<int32_t>(tx_code) >= kFirstCallId) { in MakeBinderTransaction()
125 absl::Status result = binder_->Transact(tx_code); in MakeBinderTransaction()
Dbinder_android.cc203 absl::Status BinderAndroid::Transact(BinderTransportTxCode tx_code) { in Transact() argument
209 binder, static_cast<transaction_code_t>(tx_code), in Transact()
Dwire_writer.h83 BinderTransportTxCode tx_code,
Dbinder.h93 virtual absl::Status Transact(BinderTransportTxCode tx_code) = 0;
Dbinder_android.h90 absl::Status Transact(BinderTransportTxCode tx_code) override;
/aosp_15_r20/external/grpc-grpc/test/core/transport/binder/end2end/fuzzers/
H A Dfuzzer_utils.cc126 transaction_code_t tx_code = tx_iter.code(); in FuzzingLoop() local
129 callback(tx_code, parcel.get(), in FuzzingLoop()
/aosp_15_r20/external/pytorch/torch/_dynamo/
H A Doutput_graph.py1943 tx_code = tx.f_code
1947 line = get_instruction_source_311(tx_code, cur_inst).rstrip()