MediaEndpoint.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_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_MEDIAENDPOINT_H_
#define ALEXA_CLIENT_SDK_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_MEDIAENDPOINT_H_

#include <atomic>
#include <condition_variable>
#include <vector>

#include <AVSCommon/AVS/AudioInputStream.h>
#include <AVSCommon/SDKInterfaces/Bluetooth/Services/A2DPSourceInterface.h>
#include <AVSCommon/Utils/Bluetooth/FormattedAudioStreamAdapter.h>

#include "BlueZ/BlueZDeviceManager.h"
#include "BlueZ/BlueZUtils.h"
#include "BlueZ/MediaContext.h"

#include <gio/gio.h>
#include <sbc/sbc.h>

namespace alexaClientSDK {
namespace bluetoothImplementations {
namespace blueZ {

class MediaEndpoint : public DBusObject<MediaEndpoint> {
public:
    MediaEndpoint(std::shared_ptr<DBusConnection> connection, const std::string& endpointPath);

    ~MediaEndpoint() override;

    void onSetConfiguration(GVariant* arguments, GDBusMethodInvocation* invocation);

    void onSelectConfiguration(GVariant* arguments, GDBusMethodInvocation* invocation);

    void onClearConfiguration(GVariant* arguments, GDBusMethodInvocation* invocation);

    void onRelease(GVariant* arguments, GDBusMethodInvocation* invocation);

    void onMediaTransportStateChanged(
        avsCommon::utils::bluetooth::MediaStreamingState newState,
        const std::string& devicePath);

    std::string getEndpointPath() const;

    std::string getStreamingDevicePath() const;

    std::shared_ptr<avsCommon::utils::bluetooth::FormattedAudioStreamAdapter> getAudioStream();

private:
    enum class OperatingMode {
        INACTIVE,

        SINK,

        SOURCE,

        RELEASED
    };

    std::string operatingModeToString(OperatingMode mode);

    void mediaThread();

    void setOperatingMode(OperatingMode mode);

    void abortStreaming();

    std::string m_endpointPath;

    std::string m_streamingDevicePath;

    bool m_operatingModeChanged;

    std::atomic<OperatingMode> m_operatingMode;

    std::vector<uint8_t> m_sbcBuffer;

    std::mutex m_mutex;

    std::mutex m_streamMutex;

    std::condition_variable m_modeChangeSignal;

    std::shared_ptr<avsCommon::utils::bluetooth::FormattedAudioStreamAdapter> m_ioStream;

    std::vector<uint8_t> m_ioBuffer;

    avsCommon::utils::AudioFormat m_audioFormat;

    std::shared_ptr<MediaContext> m_currentMediaContext;

    /*
     * Dedicated thread for I/O.
     */
    std::thread m_thread;
};

}  // namespace blueZ
}  // namespace bluetoothImplementations
}  // namespace alexaClientSDK

#endif  // ALEXA_CLIENT_SDK_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_MEDIAENDPOINT_H_