Skip to content

Commit b024697

Browse files
committed
iox-#27 Implement ClientPortRouDi
Signed-off-by: Mathias Kraus <[email protected]>
1 parent 9cf11ec commit b024697

File tree

5 files changed

+144
-16
lines changed

5 files changed

+144
-16
lines changed

doc/design/diagrams/request_response/client_port.puml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ class ClientPortUser {
2525
}
2626

2727
class ClientPortRouDi {
28+
getResponseQueueFullPolicy: QueueFullPolicy
2829
tryGetCaProMessage(): optional<CaProMessage>
2930
dispatchCaProMessageAndGetPossibleResponse(caProMessage: const CaProMessage): optional<CaProMessage>
3031
releaseAllChunks(): void
Lines changed: 6 additions & 6 deletions
Loading

iceoryx_posh/include/iceoryx_posh/iceoryx_posh_types.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,9 +158,9 @@ enum class ConnectionState : uint32_t
158158
{
159159
NOT_CONNECTED = 0,
160160
CONNECT_REQUESTED,
161+
CONNECT_HANDSHAKE,
161162
CONNECTED,
162-
DISCONNECT_REQUESTED,
163-
WAIT_FOR_OFFER
163+
DISCONNECT_REQUESTED
164164
};
165165

166166
// Default properties of ChunkDistributorData

iceoryx_posh/include/iceoryx_posh/internal/popo/ports/client_port_roudi.hpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,10 @@ class ClientPortRouDi : public BasePort
4444
ClientPortRouDi& operator=(ClientPortRouDi&& rhs) = default;
4545
~ClientPortRouDi() = default;
4646

47+
/// @brief Access to the configured responseQueueFullPolicy
48+
/// @return the configured responseQueueFullPolicy
49+
QueueFullPolicy2 getResponseQueueFullPolicy() const noexcept;
50+
4751
/// @brief get an optional CaPro message that requests changes to the desired connection state of the client
4852
/// @return CaPro message with desired connection state, empty optional if no state change
4953
cxx::optional<capro::CaproMessage> tryGetCaProMessage() noexcept;

0 commit comments

Comments
 (0)