Home
last modified time | relevance | path

Searched refs:kChannelId (Results 1 – 19 of 19) sorted by relevance

/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dtest_utils.h43 template <typename Service, uint32_t kChannelId = 99, uint32_t kServiceId = 16>
46 static constexpr uint32_t channel_id() { return kChannelId; } in channel_id()
50 : channel_(Channel::Create<kChannelId>(&output_)), in ServerContextForTest()
60 kChannelId, in request()
70 kChannelId,
80 kChannelId, in server_stream()
89 kChannelId, in client_stream()
118 uint32_t kChannelId = 99,
123 static constexpr uint32_t channel_id() { return kChannelId; } in channel_id()
128 : channel_(Channel::Create<kChannelId>(&output_)), in ClientContextForTest()
[all …]
Dpacket.h37 protobuf::SizeOfFieldUint32(pwpb::RpcPacket::Fields::kChannelId) +
/external/pigweed/pw_rpc/
Dfake_channel_output_test.cc29 constexpr uint32_t kChannelId = 1; variable
41 return payloads(type, kChannelId, kServiceId, kMethodId).back(); in last_response()
45 return payloads(type, kChannelId, kServiceId, kMethodId).size(); in total_payloads()
52 Channel channel(kChannelId, &output); in TEST()
54 kChannelId, in TEST()
79 Channel channel(kChannelId, &output); in TEST()
81 kChannelId, in TEST()
107 kChannelId, in TEST()
126 Channel channel(kChannelId, &output); in TEST()
128 kChannelId, in TEST()
[all …]
Dpacket_meta_test.cc24 const uint32_t kChannelId = 12; in TEST() local
29 packet.set_channel_id(kChannelId); in TEST()
40 EXPECT_EQ(decode_result->channel_id(), kChannelId); in TEST()
Dchannel.cc34 internal::pwpb::RpcPacket::Fields::kChannelId) { in ExtractChannelId()
Dclient_integration_test.cc45 pw::rpc::integration_test::kChannelId);
Dpacket.cc43 case RpcPacket::Fields::kChannelId: in FromBuffer()
Ddocs.rst1510 .. cpp:var:: constexpr uint32_t kChannelId
/external/pigweed/pw_rpc/nanopb/
Dserver_reader_writer_test.cc55 static constexpr uint32_t kChannelId = 1; member
58 : channel(Channel::Create<kChannelId>(&output)), in ReaderWriterTestContext()
249 ASSERT_EQ(OkStatus(), ctx.server.CloseChannel(ctx.kChannelId)); in TEST()
255 ctx.server, ctx.kChannelId, ctx.service); in TEST()
258 EXPECT_EQ(call.channel_id(), ctx.kChannelId); in TEST()
261 ASSERT_EQ(OkStatus(), ctx.server.OpenChannel(ctx.kChannelId, ctx.output)); in TEST()
278 ctx.server, ctx.kChannelId, ctx.service); in TEST()
289 ctx.server, ctx.kChannelId, ctx.service); in TEST()
Dclient_integration_test.cc70 pw::rpc::integration_test::kChannelId);
/external/pigweed/pw_rpc/pwpb/
Dserver_reader_writer_test.cc57 static constexpr uint32_t kChannelId = 1; member
60 : channel(Channel::Create<kChannelId>(&output)), in ReaderWriterTestContext()
246 ASSERT_EQ(OkStatus(), ctx.server.CloseChannel(ctx.kChannelId)); in TEST()
252 ctx.server, ctx.kChannelId, ctx.service); in TEST()
255 EXPECT_EQ(call.channel_id(), ctx.kChannelId); in TEST()
258 ASSERT_EQ(OkStatus(), ctx.server.OpenChannel(ctx.kChannelId, ctx.output)); in TEST()
275 ctx.server, ctx.kChannelId, ctx.service); in TEST()
286 ctx.server, ctx.kChannelId, ctx.service); in TEST()
Dclient_integration_test.cc72 pw::rpc::integration_test::kChannelId);
/external/pigweed/pw_rpc/raw/
Dserver_reader_writer_test.cc43 static constexpr uint32_t kChannelId = 1; member
46 : channel(Channel::Create<kChannelId>(&output)), in ReaderWriterTestContext()
184 ASSERT_EQ(OkStatus(), ctx.server.CloseChannel(ctx.kChannelId)); in TEST()
188 ctx.server, ctx.kChannelId, ctx.service); in TEST()
191 EXPECT_EQ(call.channel_id(), ctx.kChannelId); in TEST()
194 ASSERT_EQ(OkStatus(), ctx.server.OpenChannel(ctx.kChannelId, ctx.output)); in TEST()
399 ASSERT_EQ(writer.channel_id(), ReaderWriterTestContext::kChannelId); in WriteAsWriter()
/external/pigweed/pw_rpc/fuzz/
Dengine_test.cc69 static constexpr uint32_t kChannelId = 1; member in pw::rpc::fuzz::__anon1d9d2dcb0111::FuzzerContext
89 Fuzzer fuzzer(context_.client(), FuzzerContext::kChannelId); in Run()
Dclient_fuzzer.cc98 Fuzzer fuzzer(integration_test::client(), integration_test::kChannelId); in FuzzClient()
/external/pigweed/pw_rpc/public/pw_rpc/
Dintegration_testing.h25 inline constexpr uint32_t kChannelId = 1; variable
Dintegration_test_socket_client.h41 Channel::Create<kChannelId>(&channel_output_with_manipulator_)), in SocketClientContext()
/external/pigweed/pw_transfer/integration_test/
Dclient.cc88 rpc::integration_test::kChannelId, in PerformTransferActions()
/external/pigweed/pw_transfer/
Ddocs.rst208 constexpr uint32_t kChannelId = 42;
211 GetSystemRpcClient(), kChannelId, GetSystemTransferThread());