1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
// Copyright 2022 The Pigweed Authors
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
// use this file except in compliance with the License. You may obtain a copy of
// the License at
//
// https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations under
// the License.
#pragma once
#include <cinttypes>
#include "pw_rpc/internal/client_server_testing_threaded.h"
#include "pw_rpc/nanopb/fake_channel_output.h"
namespace pw::rpc {
namespace internal {
template <size_t kOutputSize,
size_t kMaxPackets,
size_t kPayloadsBufferSizeBytes>
class NanopbWatchableChannelOutput final
: public WatchableChannelOutput<
NanopbFakeChannelOutput<kMaxPackets, kPayloadsBufferSizeBytes>,
kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes> {
private:
template <auto kMethod>
using MethodInfo = internal::MethodInfo<kMethod>;
template <auto kMethod>
using Response = typename MethodInfo<kMethod>::Response;
template <auto kMethod>
using Request = typename MethodInfo<kMethod>::Request;
using Base = WatchableChannelOutput<
NanopbFakeChannelOutput<kMaxPackets, kPayloadsBufferSizeBytes>,
kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes>;
public:
constexpr NanopbWatchableChannelOutput() = default;
template <auto kMethod>
Response<kMethod> response(uint32_t channel_id, uint32_t index)
PW_LOCKS_EXCLUDED(Base::mutex_) {
std::lock_guard lock(Base::mutex_);
PW_ASSERT(Base::PacketCount() >= index);
return Base::output_.template responses<kMethod>(channel_id)[index];
}
template <auto kMethod>
Request<kMethod> request(uint32_t channel_id, uint32_t index)
PW_LOCKS_EXCLUDED(Base::mutex_) {
std::lock_guard lock(Base::mutex_);
PW_ASSERT(Base::PacketCount() >= index);
return Base::output_.template requests<kMethod>(channel_id)[index];
}
};
} // namespace internal
template <size_t kOutputSize = 128,
size_t kMaxPackets = 16,
size_t kPayloadsBufferSizeBytes = 128>
class NanopbClientServerTestContextThreaded final
: public internal::ClientServerTestContextThreaded<
internal::NanopbWatchableChannelOutput<kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes>,
kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes> {
private:
template <auto kMethod>
using MethodInfo = internal::MethodInfo<kMethod>;
template <auto kMethod>
using Response = typename MethodInfo<kMethod>::Response;
template <auto kMethod>
using Request = typename MethodInfo<kMethod>::Request;
using Base = internal::ClientServerTestContextThreaded<
internal::NanopbWatchableChannelOutput<kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes>,
kOutputSize,
kMaxPackets,
kPayloadsBufferSizeBytes>;
public:
NanopbClientServerTestContextThreaded(const thread::Options& options)
: Base(options) {}
// Retrieve copy of request indexed by order of occurance
template <auto kMethod>
Request<kMethod> request(uint32_t index) {
return Base::channel_output_.template request<kMethod>(Base::channel().id(),
index);
}
// Retrieve copy of resonse indexed by order of occurance
template <auto kMethod>
Response<kMethod> response(uint32_t index) {
return Base::channel_output_.template response<kMethod>(
Base::channel().id(), index);
}
};
} // namespace pw::rpc
|
