Program Listing for File SenderResource.h
↰ Return to documentation for file (/tmp/ws/src/fastrtps/include/fastdds/rtps/network/SenderResource.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_SENDER_RESOURCE_H
#define _FASTDDS_RTPS_SENDER_RESOURCE_H
#include <fastdds/rtps/common/Types.h>
#include <functional>
#include <vector>
#include <chrono>
#include <fastdds/rtps/common/Locator.h>
namespace eprosima {
namespace fastrtps {
namespace rtps {
class RTPSParticipantImpl;
class MessageReceiver;
class SenderResource
{
public:
bool send(
const octet* data,
uint32_t dataLength,
LocatorsIterator* destination_locators_begin,
LocatorsIterator* destination_locators_end,
const std::chrono::steady_clock::time_point& max_blocking_time_point)
{
bool returned_value = false;
if (send_lambda_)
{
returned_value = send_lambda_(data, dataLength, destination_locators_begin, destination_locators_end,
max_blocking_time_point);
}
return returned_value;
}
SenderResource(
SenderResource&& rValueResource)
{
clean_up.swap(rValueResource.clean_up);
send_lambda_.swap(rValueResource.send_lambda_);
}
virtual ~SenderResource() = default;
int32_t kind() const
{
return transport_kind_;
}
virtual void add_locators_to_list(
LocatorList_t& locators) const
{
(void)locators;
}
protected:
SenderResource(
int32_t transport_kind)
: transport_kind_(transport_kind)
{
}
int32_t transport_kind_;
std::function<void()> clean_up;
std::function<bool(
const octet*,
uint32_t,
LocatorsIterator* destination_locators_begin,
LocatorsIterator* destination_locators_end,
const std::chrono::steady_clock::time_point&)> send_lambda_;
private:
SenderResource() = delete;
SenderResource(
const SenderResource&) = delete;
SenderResource& operator =(
const SenderResource&) = delete;
};
} // namespace rtps
} // namespace fastrtps
} // namespace eprosima
#endif /* _FASTDDS_RTPS_SENDER_RESOURCE_H */