VideoStreaming.cc 6.38 KB
Newer Older
1
/****************************************************************************
2
 *
Gus Grubba's avatar
Gus Grubba committed
3
 * (c) 2009-2020 QGROUNDCONTROL PROJECT <http://www.qgroundcontrol.org>
4 5 6 7 8
 *
 * QGroundControl is licensed according to the terms in the file
 * COPYING.md in the root of the source code directory.
 *
 ****************************************************************************/
9 10 11 12 13


/**
 * @file
 *   @brief QGC Video Streaming Initialization
Gus Grubba's avatar
Gus Grubba committed
14
 *   @author Gus Grubba <gus@auterion.com>
15 16 17 18 19 20 21
 */

#include <QtQml>
#include <QDebug>

#if defined(QGC_GST_STREAMING)
#include <gst/gst.h>
22 23 24
#ifdef __android__
//#define ANDDROID_GST_DEBUG
#endif
25 26 27
#if defined(__ios__)
#include "gst_ios_init.h"
#endif
28 29
#else
#include "GLVideoItemStub.h"
30 31 32 33 34 35 36 37 38 39 40
#endif

#include "VideoStreaming.h"

#if defined(QGC_GST_STREAMING)
    G_BEGIN_DECLS
    // The static plugins we use
#if defined(__mobile__)
    GST_PLUGIN_STATIC_DECLARE(coreelements);
    GST_PLUGIN_STATIC_DECLARE(libav);
    GST_PLUGIN_STATIC_DECLARE(rtp);
41
    GST_PLUGIN_STATIC_DECLARE(rtsp);
42 43 44
    GST_PLUGIN_STATIC_DECLARE(udp);
    GST_PLUGIN_STATIC_DECLARE(videoparsersbad);
    GST_PLUGIN_STATIC_DECLARE(x264);
45
    GST_PLUGIN_STATIC_DECLARE(rtpmanager);
46 47
    GST_PLUGIN_STATIC_DECLARE(isomp4);
    GST_PLUGIN_STATIC_DECLARE(matroska);
48
    GST_PLUGIN_STATIC_DECLARE(opengl);
49 50 51
#endif
#if defined(__android__)
    GST_PLUGIN_STATIC_DECLARE(androidmedia);
52
#endif
53
    GST_PLUGIN_STATIC_DECLARE(qmlgl);
54 55 56
    G_END_DECLS
#endif

dogmaphobic's avatar
dogmaphobic committed
57
#if defined(QGC_GST_STREAMING)
58
#if (defined(Q_OS_MAC) && defined(QGC_INSTALL_RELEASE)) || defined(Q_OS_WIN)
dogmaphobic's avatar
dogmaphobic committed
59 60 61 62 63 64
static void qgcputenv(const QString& key, const QString& root, const QString& path)
{
    QString value = root + path;
    qputenv(key.toStdString().c_str(), QByteArray(value.toStdString().c_str()));
}
#endif
Don Gagne's avatar
Don Gagne committed
65
#endif
dogmaphobic's avatar
dogmaphobic committed
66

67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109
#ifdef ANDDROID_GST_DEBUG
// Redirects stdio and stderr to logcat
#include <unistd.h>
#include <pthread.h>
#include <android/log.h>

static int pfd[2];
static pthread_t thr;
static const char *tag = "myapp";

static void *thread_func(void*)
{
    ssize_t rdsz;
    char buf[128];
    while((rdsz = read(pfd[0], buf, sizeof buf - 1)) > 0) {
        if(buf[rdsz - 1] == '\n') --rdsz;
        buf[rdsz] = 0;  /* add null-terminator */
        __android_log_write(ANDROID_LOG_DEBUG, tag, buf);
    }
    return 0;
}

int start_logger(const char *app_name)
{
    tag = app_name;

    /* make stdout line-buffered and stderr unbuffered */
    setvbuf(stdout, 0, _IOLBF, 0);
    setvbuf(stderr, 0, _IONBF, 0);

    /* create the pipe and redirect stdout and stderr */
    pipe(pfd);
    dup2(pfd[1], 1);
    dup2(pfd[1], 2);

    /* spawn the logging thread */
    if(pthread_create(&thr, 0, thread_func, 0) == -1)
        return -1;
    pthread_detach(thr);
    return 0;
}
#endif

110
void initializeVideoStreaming(int &argc, char* argv[], char* logpath, char* debuglevel)
111 112
{
#if defined(QGC_GST_STREAMING)
113
    #ifdef Q_OS_MAC
114 115 116 117 118 119 120 121 122 123
        #ifdef QGC_INSTALL_RELEASE
            QString currentDir = QCoreApplication::applicationDirPath();
            qgcputenv("GST_PLUGIN_SCANNER",           currentDir, "/../Frameworks/GStreamer.framework/Versions/1.0/libexec/gstreamer-1.0/gst-plugin-scanner");
            qgcputenv("GTK_PATH",                     currentDir, "/../Frameworks/GStreamer.framework/Versions/Current");
            qgcputenv("GIO_EXTRA_MODULES",            currentDir, "/../Frameworks/GStreamer.framework/Versions/Current/lib/gio/modules");
            qgcputenv("GST_PLUGIN_SYSTEM_PATH_1_0",   currentDir, "/../Frameworks/GStreamer.framework/Versions/Current/lib/gstreamer-1.0");
            qgcputenv("GST_PLUGIN_SYSTEM_PATH",       currentDir, "/../Frameworks/GStreamer.framework/Versions/Current/lib/gstreamer-1.0");
            qgcputenv("GST_PLUGIN_PATH_1_0",          currentDir, "/../Frameworks/GStreamer.framework/Versions/Current/lib/gstreamer-1.0");
            qgcputenv("GST_PLUGIN_PATH",              currentDir, "/../Frameworks/GStreamer.framework/Versions/Current/lib/gstreamer-1.0");
        #endif
Don Gagne's avatar
Don Gagne committed
124 125 126
    #elif defined(Q_OS_WIN)
        QString currentDir = QCoreApplication::applicationDirPath();
        qgcputenv("GST_PLUGIN_PATH", currentDir, "/gstreamer-plugins");
127
    #endif
128

129 130 131 132 133 134
    // Initialize GStreamer
    #if defined(__ios__)
        //-- iOS specific initialization
        gst_ios_init();
    #else
        //-- Generic initialization
135
        if (qgetenv("GST_DEBUG").isEmpty() && logpath) {
136 137
            QString gstDebugFile = QString("%1/%2").arg(logpath).arg("gstreamer-log.txt");
            qDebug() << "GStreamer debug output:" << gstDebugFile;
138 139 140 141
            if (debuglevel) {
                qputenv("GST_DEBUG", debuglevel);
            }
            qputenv("GST_DEBUG_NO_COLOR", "1");
142
            qputenv("GST_DEBUG_FILE", gstDebugFile.toUtf8());
143 144
            qputenv("GST_DEBUG_DUMP_DOT_DIR", logpath);
        }
Gus Grubba's avatar
Gus Grubba committed
145
        GError* error = nullptr;
146 147 148 149
        if (!gst_init_check(&argc, &argv, &error)) {
            qCritical() << "gst_init_check() failed: " << error->message;
            g_error_free(error);
        }
150
    #endif
151
        // The static plugins we use
152
    #if defined(__android__)
153 154 155
        GST_PLUGIN_STATIC_REGISTER(coreelements);
        GST_PLUGIN_STATIC_REGISTER(libav);
        GST_PLUGIN_STATIC_REGISTER(rtp);
156
        GST_PLUGIN_STATIC_REGISTER(rtsp);
157 158 159
        GST_PLUGIN_STATIC_REGISTER(udp);
        GST_PLUGIN_STATIC_REGISTER(videoparsersbad);
        GST_PLUGIN_STATIC_REGISTER(x264);
160
        GST_PLUGIN_STATIC_REGISTER(rtpmanager);
161 162
        GST_PLUGIN_STATIC_REGISTER(isomp4);
        GST_PLUGIN_STATIC_REGISTER(matroska);
163
        GST_PLUGIN_STATIC_REGISTER(androidmedia);
164
    #endif
165 166 167

#if defined(__mobile__)
        GST_PLUGIN_STATIC_REGISTER(opengl);
168
#endif
169

170 171 172 173
    /* the plugin must be loaded before loading the qml file to register the
     * GstGLVideoItem qml item
     * FIXME Add a QQmlExtensionPlugin into qmlglsink to register GstGLVideoItem
     * with the QML engine, then remove this */
174 175 176 177 178 179 180 181
    GstElement *sink = gst_element_factory_make("qmlglsink", nullptr);

    if (sink == nullptr) {
        GST_PLUGIN_STATIC_REGISTER(qmlgl);
        sink = gst_element_factory_make("qmlglsink", nullptr);
    }

    if (sink != nullptr) {
182
        gst_object_unref(sink);
183
        sink = nullptr;
184 185 186
    } else {
        qCritical() << "unable to find qmlglsink - you need to build it yourself and add to GST_PLUGIN_PATH";
    }
187
#else
188 189 190 191 192
    qmlRegisterType<GLVideoItemStub> ("org.freedesktop.gstreamer.GLVideoItem", 1, 0, "GstGLVideoItem");
    Q_UNUSED(argc)
    Q_UNUSED(argv)
    Q_UNUSED(logpath)
    Q_UNUSED(debuglevel)
193
#endif
194
}