// 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.

/**

 * @file WriterQos.cpp

 *

 */

#include <fastdds/dds/publisher/qos/WriterQos.hpp>

#include <fastdds/dds/log/Log.hpp>

using namespace eprosima::fastdds::rtps;

namespace eprosima {

namespace fastdds {

namespace dds {

//FASTDDS_EXPORTED_API const WriterQos DATAWRITER_QOS_DEFAULT;

WriterQos::WriterQos()

{

    m_reliability.kind = RELIABLE_RELIABILITY_QOS;

    m_durability.kind = TRANSIENT_LOCAL_DURABILITY_QOS;

}

WriterQos::~WriterQos()

{

}

void WriterQos::setQos(

        const WriterQos& qos,

        bool first_time)

{

    if (first_time)

    {

        m_durability = qos.m_durability;

    }

    if (first_time || m_deadline.period != qos.m_deadline.period)

    {

        m_deadline = qos.m_deadline;

    }

    if (m_latencyBudget.duration != qos.m_latencyBudget.duration)

    {

        m_latencyBudget = qos.m_latencyBudget;

    }

    if (first_time)

    {

        m_liveliness = qos.m_liveliness;

    }

    if (first_time)

    {

        m_reliability = qos.m_reliability;

    }

    if (first_time)

    {

        m_ownership = qos.m_ownership;

    }

    if (m_destinationOrder.kind != qos.m_destinationOrder.kind)

    {

        m_destinationOrder = qos.m_destinationOrder;

    }

    if (first_time || m_userData.data_vec() != qos.m_userData.data_vec())

    {

        m_userData = qos.m_userData;

    }

    if (first_time || m_timeBasedFilter.minimum_separation != qos.m_timeBasedFilter.minimum_separation)

    {

        m_timeBasedFilter = qos.m_timeBasedFilter;

    }

    if (first_time || m_presentation.access_scope != qos.m_presentation.access_scope ||

            m_presentation.coherent_access != qos.m_presentation.coherent_access ||

            m_presentation.ordered_access != qos.m_presentation.ordered_access)

    {

        m_presentation = qos.m_presentation;

    }

    if (first_time || qos.m_partition.names() != m_partition.names())

    {

        m_partition = qos.m_partition;

    }

    if (first_time || m_topicData.getValue() != qos.m_topicData.getValue())

    {

        m_topicData = qos.m_topicData;

    }

    if (first_time || m_groupData.getValue() != qos.m_groupData.getValue())

    {

        m_groupData = qos.m_groupData;

    }

    if (first_time || m_durabilityService.history_kind != qos.m_durabilityService.history_kind ||

            m_durabilityService.history_depth != qos.m_durabilityService.history_depth ||

            m_durabilityService.max_instances != qos.m_durabilityService.max_instances ||

            m_durabilityService.max_samples != qos.m_durabilityService.max_samples ||

            m_durabilityService.max_samples_per_instance != qos.m_durabilityService.max_samples_per_instance ||

            m_durabilityService.service_cleanup_delay != qos.m_durabilityService.service_cleanup_delay

            )

    {

        m_durabilityService = qos.m_durabilityService;

    }

    if (m_lifespan.duration != qos.m_lifespan.duration)

    {

        m_lifespan = qos.m_lifespan;

    }

    if (qos.m_ownershipStrength.value != m_ownershipStrength.value)

    {

        m_ownershipStrength = qos.m_ownershipStrength;

    }

    if (first_time)

    {

        m_disablePositiveACKs = qos.m_disablePositiveACKs;

    }

    // Writers only manages the first element in the list of data representations.

    if (qos.representation.m_value.size() != representation.m_value.size() ||

            (qos.representation.m_value.size() > 0 && representation.m_value.size() > 0 &&

            *qos.representation.m_value.begin() != *representation.m_value.begin()))

    {

        representation = qos.representation;

    }

    if (first_time && !(data_sharing == qos.data_sharing))

    {

        data_sharing = qos.data_sharing;

    }

}

bool WriterQos::checkQos() const

{

    if (m_durability.kind == PERSISTENT_DURABILITY_QOS)

    {

        EPROSIMA_LOG_ERROR(RTPS_QOS_CHECK, "PERSISTENT Durability not supported");

        return false;

    }

    if (m_destinationOrder.kind == BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS)

    {

        EPROSIMA_LOG_ERROR(RTPS_QOS_CHECK, "BY SOURCE TIMESTAMP DestinationOrder not supported");

        return false;

    }

    if (m_liveliness.kind == AUTOMATIC_LIVELINESS_QOS || m_liveliness.kind == MANUAL_BY_PARTICIPANT_LIVELINESS_QOS)

    {

        if (m_liveliness.lease_duration < dds::c_TimeInfinite &&

                m_liveliness.lease_duration <= m_liveliness.announcement_period)

        {

            EPROSIMA_LOG_ERROR(RTPS_QOS_CHECK, "WRITERQOS: LeaseDuration <= announcement period.");

            return false;

        }

    }

    return true;

}

bool WriterQos::canQosBeUpdated(

        const WriterQos& qos) const

{

    bool updatable = true;

    if ( m_durability.kind != qos.m_durability.kind)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK, "Durability kind cannot be changed after the creation of a publisher.");

    }

    if (m_liveliness.kind !=  qos.m_liveliness.kind)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK, "Liveliness Kind cannot be changed after the creation of a publisher.");

    }

    if (m_liveliness.lease_duration != qos.m_liveliness.lease_duration)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK,

                "Liveliness lease duration cannot be changed after the creation of a publisher.");

    }

    if (m_liveliness.announcement_period != qos.m_liveliness.announcement_period)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK,

                "Liveliness announcement cannot be changed after the creation of a publisher.");

    }

    if (m_reliability.kind != qos.m_reliability.kind)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK, "Reliability Kind cannot be changed after the creation of a publisher.");

    }

    if (m_ownership.kind != qos.m_ownership.kind)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK, "Ownership Kind cannot be changed after the creation of a publisher.");

    }

    if (m_destinationOrder.kind != qos.m_destinationOrder.kind)

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK,

                "Destination order Kind cannot be changed after the creation of a publisher.");

    }

    if (data_sharing.kind() != qos.data_sharing.kind() ||

            data_sharing.domain_ids() != qos.data_sharing.domain_ids())

    {

        updatable = false;

        EPROSIMA_LOG_WARNING(RTPS_QOS_CHECK,

                "Data sharing configuration cannot be changed after the creation of a publisher.");

    }

    return updatable;

}

void WriterQos::clear()

{

    m_durability.clear();

    m_deadline.clear();

    m_latencyBudget.clear();

    m_liveliness.clear();

    m_reliability.clear();

    m_ownership.clear();

    m_destinationOrder.clear();

    m_userData.clear();

    m_timeBasedFilter.clear();

    m_presentation.clear();

    m_partition.clear();

    m_topicData.clear();

    m_groupData.clear();

    m_durabilityService.clear();

    m_lifespan.clear();

    m_disablePositiveACKs.clear();

    m_ownershipStrength.clear();

    m_publishMode.clear();

    representation.clear();

    data_sharing.clear();

    m_reliability.kind = RELIABLE_RELIABILITY_QOS;

}

} //namespace dds

} //namespace fastdds

} //namespace eprosima