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
|
// Copyright (c) 2020 by Robert Bosch GmbH. All rights reserved.
// Copyright (c) 2021 by Apex.AI Inc. All rights reserved.
//
// 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
//
// http://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.
//
// SPDX-License-Identifier: Apache-2.0
#ifndef IOX_EXAMPLES_ICEPERF_MQ_HPP
#define IOX_EXAMPLES_ICEPERF_MQ_HPP
#include "base.hpp"
#include "iceoryx_hoofs/cxx/optional.hpp"
#include "iceoryx_hoofs/design_pattern/creation.hpp"
#include "iceoryx_hoofs/internal/posix_wrapper/ipc_channel.hpp"
#include "iceoryx_hoofs/internal/units/duration.hpp"
#include "iceoryx_hoofs/platform/fcntl.hpp"
#include "iceoryx_hoofs/platform/mqueue.hpp"
#include "iceoryx_hoofs/platform/stat.hpp"
#include <string>
class MQ : public IcePerfBase
{
public:
static constexpr uint32_t MAX_MESSAGE_SIZE = 4 * IcePerfBase::ONE_KILOBYTE;
static constexpr uint32_t MAX_MESSAGES = 8;
static constexpr int32_t ERROR_CODE = -1;
static constexpr mqd_t INVALID_DESCRIPTOR = std::numeric_limits<mqd_t>::max();
MQ(const std::string& publisherName, const std::string& subscriberName) noexcept;
/// @brief Cleans up outdated message queues, e.g. from a previous test
/// @attention only leader is allowed to call this
static void cleanupOutdatedResources(const std::string& publisherName, const std::string& subscriberName) noexcept;
void initLeader() noexcept override;
void initFollower() noexcept override;
void shutdown() noexcept override;
private:
static constexpr const char* PREFIX{"/"};
void initMqAttributes() noexcept;
void open(const std::string& name, const iox::posix::IpcChannelSide channelSide) noexcept;
void send(const char* buffer, uint32_t length) noexcept;
void receive(char* buffer) noexcept;
void sendPerfTopic(const uint32_t payloadSizeInBytes, const RunFlag runFlag) noexcept override;
PerfTopic receivePerfTopic() noexcept override;
const std::string m_publisherMqName;
const std::string m_subscriberMqName;
struct mq_attr m_attributes;
mqd_t m_mqDescriptorPublisher = INVALID_DESCRIPTOR;
mqd_t m_mqDescriptorSubscriber = INVALID_DESCRIPTOR;
// read/write permissions
static constexpr mode_t m_filemode{S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH};
char m_message[MAX_MESSAGE_SIZE];
};
#endif // IOX_EXAMPLES_ICEPERF_MQ_HPP
|