Program Listing for File RTPSMessageCreator.h

↰ Return to documentation for file (/tmp/ws/src/fastrtps/include/fastdds/rtps/messages/RTPSMessageCreator.h)

// Copyright 2016 Proyectos y Sistemas de Mantenimiento SL (eProsima).
//
// 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.

#ifndef _FASTDDS_RTPS_CDRMESSAGECREATOR_H_
#define _FASTDDS_RTPS_CDRMESSAGECREATOR_H_
#ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC

#include <fastdds/rtps/common/CDRMessage_t.h>
#include <fastdds/rtps/common/Guid.h>
#include <fastdds/rtps/common/SequenceNumber.h>
#include <fastdds/rtps/common/FragmentNumber.h>
#include <fastdds/rtps/common/CacheChange.h>

namespace eprosima {
namespace fastrtps {
namespace rtps {

class InlineQosWriter
{
public:

    virtual ~InlineQosWriter() = default;

    virtual bool writeQosToCDRMessage(
            CDRMessage_t* msg) = 0;
};

class RTPSMessageCreator
{
public:

    RTPSMessageCreator() = delete;
    ~RTPSMessageCreator() = delete;

    static bool addHeader(
            CDRMessage_t* msg,
            const GuidPrefix_t& Prefix,
            const ProtocolVersion_t& version,
            const VendorId_t& vendorId);

    static bool addHeader(
            CDRMessage_t* msg,
            const GuidPrefix_t& Prefix);

    static bool addCustomContent(
            CDRMessage_t* msg,
            const octet* content,
            const size_t contentSize);
    static bool addSubmessageHeader(
            CDRMessage_t* msg,
            octet id,
            octet flags,
            uint16_t size);



    static bool addMessageData(
            CDRMessage_t* msg,
            GuidPrefix_t& guidprefix,
            const CacheChange_t* change,
            TopicKind_t topicKind,
            const EntityId_t& readerId,
            bool expectsInlineQos,
            InlineQosWriter* inlineQos);

    static bool addSubmessageData(
            CDRMessage_t* msg,
            const CacheChange_t* change,
            TopicKind_t topicKind,
            const EntityId_t& readerId,
            bool expectsInlineQos,
            InlineQosWriter* inlineQos,
            bool* is_big_submessage);

    static bool addMessageDataFrag(
            CDRMessage_t* msg,
            GuidPrefix_t& guidprefix,
            const CacheChange_t* change,
            uint32_t fragment_number,
            TopicKind_t topicKind,
            const EntityId_t& readerId,
            bool expectsInlineQos,
            InlineQosWriter* inlineQos);
    static bool addSubmessageDataFrag(
            CDRMessage_t* msg,
            const CacheChange_t* change,
            uint32_t fragment_number,
            const SerializedPayload_t& data,
            TopicKind_t topicKind,
            const EntityId_t& readerId,
            bool expectsInlineQos,
            InlineQosWriter* inlineQos);

    static bool addMessageGap(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const GuidPrefix_t& remoteGuidPrefix,
            const SequenceNumber_t& seqNumFirst,
            const SequenceNumberSet_t& seqNumList,
            const EntityId_t& readerId,
            const EntityId_t& writerId);
    static bool addSubmessageGap(
            CDRMessage_t* msg,
            const SequenceNumber_t& seqNumFirst,
            const SequenceNumberSet_t& seqNumList,
            const EntityId_t& readerId,
            const EntityId_t& writerId);

    static bool addMessageHeartbeat(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumber_t& firstSN,
            const SequenceNumber_t& lastSN,
            Count_t count,
            bool isFinal,
            bool livelinessFlag);
    static bool addMessageHeartbeat(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const GuidPrefix_t& remoteGuidprefix,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumber_t& firstSN,
            const SequenceNumber_t& lastSN,
            Count_t count,
            bool isFinal,
            bool livelinessFlag);
    static bool addSubmessageHeartbeat(
            CDRMessage_t* msg,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumber_t& firstSN,
            const SequenceNumber_t& lastSN,
            Count_t count,
            bool isFinal,
            bool livelinessFlag);

    static bool addMessageHeartbeatFrag(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            SequenceNumber_t& firstSN,
            FragmentNumber_t& lastFN,
            Count_t count);
    static bool addSubmessageHeartbeatFrag(
            CDRMessage_t* msg,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            SequenceNumber_t& firstSN,
            FragmentNumber_t& lastFN,
            Count_t count);

    static bool addMessageAcknack(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const GuidPrefix_t& remoteGuidPrefix,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumberSet_t& SNSet,
            int32_t count,
            bool finalFlag);
    static bool addSubmessageAcknack(
            CDRMessage_t* msg,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumberSet_t& SNSet,
            int32_t count,
            bool finalFlag);

    static bool addMessageNackFrag(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidprefix,
            const GuidPrefix_t& remoteGuidPrefix,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            SequenceNumber_t& writerSN,
            FragmentNumberSet_t fnState,
            int32_t count);
    static bool addSubmessageNackFrag(
            CDRMessage_t* msg,
            const EntityId_t& readerId,
            const EntityId_t& writerId,
            const SequenceNumber_t& writerSN,
            FragmentNumberSet_t fnState,
            int32_t count);

    static bool addSubmessageInfoTS(
            CDRMessage_t* msg,
            const Time_t& time,
            bool invalidateFlag);
    static bool addSubmessageInfoTS_Now(
            CDRMessage_t* msg,
            bool invalidateFlag);

    static bool addSubmessageInfoSRC(
            CDRMessage_t* msg,
            const ProtocolVersion_t& version,
            const VendorId_t& vendorId,
            const GuidPrefix_t& guidP);
    static bool addSubmessageInfoDST(
            CDRMessage_t* msg,
            const GuidPrefix_t& guidP);
};
} // namespace rtps
} /* namespace rtps */
} /* namespace eprosima */
#endif // ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC
#endif /* _FASTDDS_RTPS_CDRMESSAGECREATOR_H_ */