response_mut.hpp

Go to the documentation of this file.

// Copyright (c) 2025 Contributors to the Eclipse Foundation
//
// See the NOTICE file(s) distributed with this work for additional
// information regarding copyright ownership.
//
// This program and the accompanying materials are made available under the
// terms of the Apache Software License 2.0 which is available at
// https://www.apache.org/licenses/LICENSE-2.0, or the MIT license
// which is available at https://opensource.org/licenses/MIT.
//
// SPDX-License-Identifier: Apache-2.0 OR MIT
 
#ifndef IOX2_RESPONSE_MUT_HPP
#define IOX2_RESPONSE_MUT_HPP
 
#include "iox2/bb/expected.hpp"
#include "iox2/bb/slice.hpp"
#include "iox2/deployment/iceoryx2_cxx_feature_flags.hpp"
#include "iox2/header_request_response.hpp"
#include "iox2/marker.hpp"
#include "iox2/payload_info.hpp"
#include "iox2/port_error.hpp"
#include "iox2/service_type.hpp"
 
#if IOX2_FEATURE_FLATBUFFERS
#include <flatbuffers/flatbuffers.h>
#endif // IOX2_FEATURE_FLATBUFFERS
 
#include <type_traits>
 
namespace iox2 {
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
// NOLINTNEXTLINE(cppcoreguidelines-pro-type-member-init,hicpp-member-init) 'm_response' is not used directly but only via the initialized 'm_handle'; furthermore, it will be initialized on the call site
class ResponseMut {
    using ValueType = typename PayloadInfo<ResponsePayload>::ValueType;
 
  public:
    ResponseMut(ResponseMut&& rhs) noexcept;
    auto operator=(ResponseMut&& rhs) noexcept -> ResponseMut&;
    ~ResponseMut() noexcept;
 
    ResponseMut(const ResponseMut&) = delete;
    auto operator=(const ResponseMut&) -> ResponseMut& = delete;
 
    auto header() const -> ResponseHeader;
 
    template <typename T = ResponseUserHeader,
              typename = std::enable_if_t<!std::is_same<void, ResponseUserHeader>::value, T>>
    auto user_header() const -> const T&;
 
    template <typename T = ResponseUserHeader,
              typename = std::enable_if_t<!std::is_same<void, ResponseUserHeader>::value, T>>
    auto user_header_mut() -> T&;
 
    template <typename T = ResponsePayload,
              typename = std::enable_if_t<!bb::IsSlice<T>::VALUE && !has_flatbuffer_marker<T>(), void>>
    auto payload() const -> const ResponsePayload&;
 
    template <typename T = ResponsePayload, typename = std::enable_if_t<bb::IsSlice<T>::VALUE, void>>
    auto payload() const -> bb::ImmutableSlice<ValueType>;
 
    template <typename T = ResponsePayload,
              typename = std::enable_if_t<!bb::IsSlice<T>::VALUE && !has_flatbuffer_marker<T>(), void>>
    auto payload_mut() -> ResponsePayload&;
 
    template <typename T = ResponsePayload, typename = std::enable_if_t<bb::IsSlice<T>::VALUE, void>>
    auto payload_mut() -> bb::MutableSlice<ValueType>;
 
#if IOX2_FEATURE_FLATBUFFERS
    template <typename T = ResponsePayload, typename = std::enable_if_t<has_flatbuffer_marker<T>(), void>>
    auto payload_bytes() const -> bb::ImmutableSlice<uint8_t>;
 
    template <typename T = ResponsePayload, typename = std::enable_if_t<has_flatbuffer_marker<T>(), void>>
    auto payload_root() const -> const typename T::ValueType*;
#endif // IOX2_FEATURE_FLATBUFFERS
 
  private:
    template <ServiceType, typename, typename>
    friend class ResponseMutUninit;
    template <ServiceType, typename, typename, typename, typename>
    friend class ActiveRequest;
 
    template <ServiceType S, typename ResponsePayloadT, typename ResponseUserHeaderT>
    friend auto send(ResponseMut<S, ResponsePayloadT, ResponseUserHeaderT>&& response) -> bb::Expected<void, SendError>;
 
    explicit ResponseMut() = default;
    void drop();
 
    iox2_response_mut_t m_response;
    iox2_response_mut_h m_handle = nullptr;
};
 
// NOLINTNEXTLINE(cppcoreguidelines-pro-type-member-init,hicpp-member-init) m_response will be initialized in the move assignment operator
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline ResponseMut<Service, ResponsePayload, ResponseUserHeader>::ResponseMut(ResponseMut&& rhs) noexcept {
    *this = std::move(rhs);
}
 
namespace internal {
extern "C" {
void iox2_response_mut_move(iox2_response_mut_t*, iox2_response_mut_t*, iox2_response_mut_h*);
}
} // namespace internal
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::operator=(ResponseMut&& rhs) noexcept
    -> ResponseMut& {
    if (this != &rhs) {
        drop();
 
        internal::iox2_response_mut_move(&rhs.m_response, &m_response, &m_handle);
        rhs.m_handle = nullptr;
    }
 
    return *this;
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline ResponseMut<Service, ResponsePayload, ResponseUserHeader>::~ResponseMut() noexcept {
    drop();
}
 
#if IOX2_FEATURE_FLATBUFFERS
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload_bytes() const
    -> bb::ImmutableSlice<uint8_t> {
    const void* ptr = nullptr;
    size_t number_of_elements = 0;
 
    iox2_response_mut_payload(&m_handle, &ptr, &number_of_elements);
    auto payload_offset = header().payload_offset();
    auto payload_len = header().number_of_elements();
 
    return bb::ImmutableSlice<uint8_t>(static_cast<const uint8_t*>(ptr) + payload_offset, payload_len - payload_offset);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload_root() const -> const
    typename T::ValueType* {
    return flatbuffers::GetRoot<typename T::ValueType>(payload_bytes().data());
}
#endif // IOX2_FEATURE_FLATBUFFERS
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::header() const -> ResponseHeader {
    iox2_response_header_h header_handle = nullptr;
    iox2_response_mut_header(&m_handle, nullptr, &header_handle);
    return ResponseHeader { header_handle };
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::user_header() const -> const T& {
    const void* ptr = nullptr;
    iox2_response_mut_user_header(&m_handle, &ptr);
    return *static_cast<const T*>(ptr);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::user_header_mut() -> T& {
    void* ptr = nullptr;
    iox2_response_mut_user_header_mut(&m_handle, &ptr);
    return *static_cast<T*>(ptr);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload() const -> const ResponsePayload& {
    const void* ptr = nullptr;
    iox2_response_mut_payload(&m_handle, &ptr, nullptr);
    return *static_cast<const T*>(ptr);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload() const
    -> bb::ImmutableSlice<ValueType> {
    const void* ptr = nullptr;
    size_t number_of_elements = 0;
    iox2_response_mut_payload(&m_handle, &ptr, &number_of_elements);
 
    // for the custom payload marker, the slice length is the
    // runtime payload byte size
    auto length = number_of_elements;
    if (std::is_same<ValueType, CustomPayloadMarker>::value) {
        length = iox2_response_mut_payload_number_of_bytes(&m_handle);
    }
 
    return bb::ImmutableSlice<ValueType>(static_cast<const ValueType*>(ptr), length);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload_mut() -> ResponsePayload& {
    void* ptr = nullptr;
    iox2_response_mut_payload_mut(&m_handle, &ptr, nullptr);
    return *static_cast<ResponsePayload*>(ptr);
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
template <typename T, typename>
inline auto ResponseMut<Service, ResponsePayload, ResponseUserHeader>::payload_mut() -> bb::MutableSlice<ValueType> {
    void* ptr = nullptr;
    size_t number_of_elements = 0;
    iox2_response_mut_payload_mut(&m_handle, &ptr, &number_of_elements);
 
    // for the custom payload marker, the slice length is the
    // runtime payload byte size
    auto length = number_of_elements;
    if (std::is_same<ValueType, CustomPayloadMarker>::value) {
        length = iox2_response_mut_payload_number_of_bytes(&m_handle);
    }
 
    return bb::MutableSlice<ValueType>(static_cast<ValueType*>(ptr), length);
}
 
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline auto send(ResponseMut<Service, ResponsePayload, ResponseUserHeader>&& response)
    -> bb::Expected<void, SendError> {
    auto result = iox2_response_mut_send(response.m_handle);
    response.m_handle = nullptr;
 
    if (result == IOX2_OK) {
        return {};
    }
    return bb::err(bb::into<SendError>(result));
}
 
template <ServiceType Service, typename ResponsePayload, typename ResponseUserHeader>
inline void ResponseMut<Service, ResponsePayload, ResponseUserHeader>::drop() {
    if (m_handle != nullptr) {
        iox2_response_mut_drop(m_handle);
        m_handle = nullptr;
    }
}
 
} // namespace iox2
 
#endif