BaseStreamSource.h

Go to the documentation of this file.

/*
 * Copyright Amazon.com, Inc. or its affiliates. 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.
 * A copy of the License is located at
 *
 *     http://aws.amazon.com/apache2.0/
 *
 * or in the "license" file accompanying this file. This file 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 ALEXA_CLIENT_SDK_MEDIAPLAYER_GSTREAMERMEDIAPLAYER_INCLUDE_MEDIAPLAYER_BASESTREAMSOURCE_H_
#define ALEXA_CLIENT_SDK_MEDIAPLAYER_GSTREAMERMEDIAPLAYER_INCLUDE_MEDIAPLAYER_BASESTREAMSOURCE_H_

#include <memory>
#include <mutex>
#include <unordered_set>

#include <gst/gst.h>
#include <gst/app/gstappsrc.h>

#include <AVSCommon/Utils/MediaPlayer/MediaPlayerInterface.h>

#include "MediaPlayer/SourceInterface.h"

namespace alexaClientSDK {
namespace mediaPlayer {

class BaseStreamSource : public SourceInterface {
public:
    BaseStreamSource(PipelineInterface* pipeline, const std::string& className);

    ~BaseStreamSource() override;

    bool hasAdditionalData() override;
    bool handleEndOfStream() override;
    void preprocess() override;
    void addObserver(std::shared_ptr<SourceObserverInterface> observer) override;
    void removeObserver(std::shared_ptr<SourceObserverInterface> observer) override;

protected:
    bool init(const avsCommon::utils::AudioFormat* audioFormat = nullptr);

    virtual bool isOpen() = 0;

    virtual void close() = 0;

    virtual gboolean handleReadData() = 0;

    virtual gboolean handleSeekData(guint64 offset) = 0;

    GstAppSrc* getAppSrc() const;

    void signalEndOfData();

    void installOnReadDataHandler();

    void updateOnReadDataHandler();

    void uninstallOnReadDataHandler();

    void clearOnReadDataHandler();

    void notifyObserversOnReadData();

private:
    static void onNeedData(GstElement* pipeline, guint size, gpointer source);

    gboolean handleNeedData();

    static void onEnoughData(GstElement* pipeline, gpointer source);

    gboolean handleEnoughData();

    static gboolean onSeekData(GstElement* pipeline, guint64 offset, gpointer source);

    static gboolean onReadData(gpointer source);

    PipelineInterface* m_pipeline;

    guint m_sourceId;

    bool m_hasReadData;

    guint m_sourceRetryCount;

    const std::function<gboolean()> m_handleNeedDataFunction;

    const std::function<gboolean()> m_handleEnoughDataFunction;

    guint m_needDataHandlerId;

    guint m_enoughDataHandlerId;

    guint m_seekDataHandlerId;

    std::mutex m_callbackIdMutex;

    guint m_needDataCallbackId;

    guint m_enoughDataCallbackId;

    std::mutex m_observersMutex;

    std::unordered_set<std::shared_ptr<SourceObserverInterface>> m_observers;
};

}  // namespace mediaPlayer
}  // namespace alexaClientSDK

#endif  // ALEXA_CLIENT_SDK_MEDIAPLAYER_GSTREAMERMEDIAPLAYER_INCLUDE_MEDIAPLAYER_BASESTREAMSOURCE_H_