Line data    Source code

       1              : /*
       2              :  * If not stated otherwise in this file or this component's LICENSE file the
       3              :  * following copyright and licenses apply:
       4              :  *
       5              :  * Copyright 2022 Sky UK
       6              :  *
       7              :  * Licensed under the Apache License, Version 2.0 (the "License");
       8              :  * you may not use this file except in compliance with the License.
       9              :  * You may obtain a copy of the License at
      10              :  *
      11              :  * http://www.apache.org/licenses/LICENSE-2.0
      12              :  *
      13              :  * Unless required by applicable law or agreed to in writing, software
      14              :  * distributed under the License is distributed on an "AS IS" BASIS,
      15              :  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
      16              :  * See the License for the specific language governing permissions and
      17              :  * limitations under the License.
      18              :  */
      19              : 
      20              : #include "tasks/generic/Eos.h"
      21              : #include "GenericPlayerContext.h"
      22              : #include "IGstWrapper.h"
      23              : #include "RialtoServerLogging.h"
      24              : #include "TypeConverters.h"
      25              : 
      26              : namespace firebolt::rialto::server::tasks::generic
      27              : {
      28           11 : Eos::Eos(GenericPlayerContext &context, IGstGenericPlayerPrivate &player,
      29              :          std::shared_ptr<firebolt::rialto::wrappers::IGstWrapper> gstWrapper,
      30           11 :          const firebolt::rialto::MediaSourceType &type)
      31           11 :     : m_context{context}, m_player{player}, m_gstWrapper{gstWrapper}, m_type{type}
      32              : {
      33           11 :     RIALTO_SERVER_LOG_DEBUG("Constructing Eos");
      34              : }
      35              : 
      36           12 : Eos::~Eos()
      37              : {
      38           11 :     RIALTO_SERVER_LOG_DEBUG("Eos finished");
      39           12 : }
      40              : 
      41           10 : void Eos::execute() const
      42              : {
      43           10 :     RIALTO_SERVER_LOG_DEBUG("Executing Eos for %s", common::convertMediaSourceType(m_type));
      44              : 
      45           10 :     m_player.cancelUnderflow(m_type);
      46              : 
      47           10 :     auto elem = m_context.streamInfo.find(m_type);
      48           10 :     if (elem == m_context.streamInfo.end())
      49              :     {
      50            1 :         RIALTO_SERVER_LOG_WARN("Set eos failed - Stream not found");
      51            2 :         return;
      52              :     }
      53              : 
      54            9 :     const auto eosInfoIt = m_context.endOfStreamInfo.find(m_type);
      55            9 :     if (eosInfoIt != m_context.endOfStreamInfo.end() && eosInfoIt->second == EosState::SET)
      56              :     {
      57            1 :         RIALTO_SERVER_LOG_DEBUG("Eos already set for source %s", common::convertMediaSourceType(m_type));
      58            1 :         return;
      59              :     }
      60              : 
      61            8 :     StreamInfo &streamInfo = elem->second;
      62            8 :     if (!streamInfo.buffers.empty())
      63              :     {
      64            1 :         RIALTO_SERVER_LOG_INFO("There are pending buffers; delaying sending EOS");
      65            1 :         m_context.endOfStreamInfo[m_type] = EosState::PENDING;
      66              :     }
      67            7 :     else if (m_gstWrapper->gstAppSrcEndOfStream(GST_APP_SRC(elem->second.appSrc)) != GST_FLOW_OK)
      68              :     {
      69            1 :         RIALTO_SERVER_LOG_WARN("Set eos failed - Gstreamer error");
      70              :     }
      71              :     else
      72              :     {
      73            6 :         RIALTO_SERVER_LOG_MIL("Successfully set EOS for source %s", common::convertMediaSourceType(m_type));
      74            6 :         m_context.endOfStreamInfo[m_type] = EosState::SET;
      75              :     }
      76              : }
      77              : } // namespace firebolt::rialto::server::tasks::generic