Searched refs:RpcLogDrain (Results 1 – 9 of 9) sorted by relevance
| /external/pigweed/pw_log_rpc/ |
| D | rpc_log_drain_test.cc | 44 RpcLogDrain::kMinEntrySizeWithoutPayload + 32;
46 TEST(RpcLogDrain, TryFlushDrainWithClosedWriter) { in TEST() argument
51 RpcLogDrain drain( in TEST()
55 RpcLogDrain::LogDrainErrorHandling::kCloseStreamOnWriterError, in TEST()
77 std::array<RpcLogDrain, kMaxDrains> drains{ in TEST()
78 RpcLogDrain(0, in TEST()
81 RpcLogDrain::LogDrainErrorHandling::kCloseStreamOnWriterError, in TEST()
83 RpcLogDrain(1, in TEST()
86 RpcLogDrain::LogDrainErrorHandling::kCloseStreamOnWriterError, in TEST()
88 RpcLogDrain(2, in TEST()
[all …]
|
| D | rpc_log_drain.cc | 52 if (drop_message.size() + RpcLogDrain::kLogEntriesEncodeFrameSize < in TryEncodeDropMessage()
63 Status RpcLogDrain::Open(rpc::RawServerWriter& writer) { in Open()
78 Status RpcLogDrain::Flush(ByteSpan encoding_buffer) { in Flush()
84 std::optional<chrono::SystemClock::duration> RpcLogDrain::Trickle( in Trickle()
103 RpcLogDrain::LogDrainState RpcLogDrain::SendLogs(size_t max_num_bundles, in SendLogs()
145 RpcLogDrain::LogDrainState RpcLogDrain::EncodeOutgoingPacket( in EncodeOutgoingPacket()
258 Status RpcLogDrain::Close() { in Close()
|
| D | docs.rst | 36 Create an ``RpcLogDrainMap`` with one ``RpcLogDrain`` for each RPC channel used
40 way to access and maintain each ``RpcLogDrain``. Attach each ``RpcLogDrain`` to
41 the ``MultiSink``. Optionally, set the ``RpcLogDrain`` callback to decide if a
47 ``RpcLogDrain``\s or one thread per drain. The thread(s) must continuously call
48 ``RpcLogDrain::Flush()`` to pull entries from the ``MultiSink`` and send them to
49 the log listeners. Alternatively, use ``RpcLogDrain::Trickle`` to control the
59 receives the request and sets up the corresponding ``RpcLogDrain`` to start the
67 log_service-->rpc_log_drain_pc[RpcLogDrain<br>streams to<br>computer];;
83 multisink-->rpc_log_drain_pc[RpcLogDrain<br>streams to<br>computer];
84 multisink-->rpc_log_drain_other[RpcLogDrain<br>streams to<br>other log listener];
[all …]
|
| D | log_service_test.cc | 51 RpcLogDrain::kMinEntryBufferSize + kMaxMessageSize;
52 static_assert(RpcLogDrain::kMinEntryBufferSize < kMaxLogEntrySize);
62 static_assert(sizeof(kLongMessage) + RpcLogDrain::kMinEntrySizeWithoutPayload >
63 RpcLogDrain::kMinEntryBufferSize);
138 std::array<std::byte, RpcLogDrain::kMinEntryBufferSize> small_buffer_;
143 std::array<RpcLogDrain, kMaxDrains> drains_{
144 RpcLogDrain(kIgnoreWriterErrorsDrainId,
147 RpcLogDrain::LogDrainErrorHandling::kIgnoreWriterErrors,
149 RpcLogDrain(kCloseWriterOnErrorDrainId,
152 RpcLogDrain::LogDrainErrorHandling::kCloseStreamOnWriterError,
[all …]
|
| D | log_service.cc | 28 Result<RpcLogDrain*> drain = drains_.GetDrainFromChannelId(channel_id); in Listen()
|
| /external/pigweed/pw_log_rpc/public/pw_log_rpc/ |
| D | rpc_log_drain_map.h | 28 explicit constexpr RpcLogDrainMap(span<RpcLogDrain> drains) in RpcLogDrainMap()
37 Result<RpcLogDrain*> GetDrainFromChannelId(uint32_t channel_id) const { in GetDrainFromChannelId()
46 const span<RpcLogDrain>& drains() const { return drains_; } in drains()
49 const span<RpcLogDrain> drains_;
|
| D | rpc_log_drain.h | 55 class RpcLogDrain : public multisink::MultiSink::Drain {
114 RpcLogDrain(
143 RpcLogDrain(const RpcLogDrain&) = delete;
144 RpcLogDrain& operator=(const RpcLogDrain&) = delete;
|
| D | rpc_log_drain_thread.h | 91 const Result<RpcLogDrain*> drain = in OpenUnrequestedLogStream()
113 RpcLogDrain::kLogEntriesEncodeFrameSize +
114 RpcLogDrain::kMinEntryBufferSize,
|
| /external/pigweed/pw_system/ |
| D | log.cc | 31 using log_rpc::RpcLogDrain;
48 std::array<RpcLogDrain, 1> drains{{
49 RpcLogDrain(kDefaultRpcChannelId,
52 RpcLogDrain::LogDrainErrorHandling::kIgnoreWriterErrors),
|