+++ /dev/null
-/*
- * wfdrtspsrcmanager
- *
- * Copyright (c) 2000 - 2014 Samsung Electronics Co., Ltd. All rights reserved.
- *
- * Contact: JongHyuk Choi <jhchoi.choi@samsung.com>
- *
- * Permission is hereby granted, free of charge, to any person obtaining a
- * copy of this software and associated documentation files (the "Software"),
- * to deal in the Software without restriction, including without limitation
- * the rights to use, copy, modify, merge, publish, distribute, sublicense,
- * and/or sell copies of the Software, and to permit persons to whom the
- * Software is furnished to do so, subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be included in
- * all copies or substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
- * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
- * DEALINGS IN THE SOFTWARE.
- *
- * Alternatively, the contents of this file may be used under the
- * GNU Lesser General Public License Version 2.1 (the "LGPL"), in
- * which case the following provisions apply instead of the ones
- * mentioned above:
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Library General Public
- * License as published by the Free Software Foundation; either
- * version 2 of the License, or (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Library General Public License for more details.
- *
- * You should have received a copy of the GNU Library General Public
- * License along with this library; if not, write to the
- * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
- * Boston, MA 02111-1307, USA.
- */
-
-
- #ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#ifdef HAVE_UNISTD_H
-#include <unistd.h>
-#endif /* HAVE_UNISTD_H */
-#include <stdlib.h>
-#include <string.h>
-#include <locale.h>
-#include <stdio.h>
-#include <stdarg.h>
-
-#include <sys/ioctl.h>
-#include <netdb.h>
-#include <sys/socket.h>
-#include <fcntl.h>
-#include <netinet/in.h>
-
-#include "wfdrtspmanager.h"
-
-#ifdef G_OS_WIN32
-#include <winsock2.h>
-#endif
-
-GST_DEBUG_CATEGORY_STATIC (wfd_rtsp_manager_debug);
-#define GST_CAT_DEFAULT wfd_rtsp_manager_debug
-
-/* signals and args */
-enum
-{
- LAST_SIGNAL
-};
-
-enum
-{
- PROP_0,
- PROP_DO_RTCP,
- PROP_LATENCY,
- PROP_UDP_BUFFER_SIZE,
- PROP_UDP_TIMEOUT,
- PROP_ENABLE_PAD_PROBE,
- PROP_LAST
-};
-
-#define DEFAULT_DO_RTCP TRUE
-#define DEFAULT_LATENCY_MS 2000
-#define DEFAULT_UDP_BUFFER_SIZE 0x80000
-#define DEFAULT_UDP_TIMEOUT 10000000
-
-G_DEFINE_TYPE (WFDRTSPManager, wfd_rtsp_manager, G_TYPE_OBJECT);
-
-/* GObject vmethods */
-static void wfd_rtsp_manager_finalize (GObject * object);
-static void wfd_rtsp_manager_set_property (GObject * object, guint prop_id,
- const GValue * value, GParamSpec * pspec);
-static void wfd_rtsp_manager_get_property (GObject * object, guint prop_id,
- GValue * value, GParamSpec * pspec);
-
-static void wfd_rtsp_manager_enable_pad_probe(WFDRTSPManager * manager);
-GstPadProbeReturn
-wfd_rtsp_manager_pad_probe_cb(GstPad * pad, GstPadProbeInfo *info, gpointer u_data);
-
-static void
-wfd_rtsp_manager_class_init (WFDRTSPManagerClass * klass)
-{
- GObjectClass *gobject_class;
-
- gobject_class = (GObjectClass *) klass;
-
- gobject_class->finalize = wfd_rtsp_manager_finalize;
- gobject_class->set_property = wfd_rtsp_manager_set_property;
- gobject_class->get_property = wfd_rtsp_manager_get_property;
-
- g_object_class_install_property (gobject_class, PROP_DO_RTCP,
- g_param_spec_boolean ("do-rtcp", "Do RTCP",
- "Send RTCP packets, disable for old incompatible server.",
- DEFAULT_DO_RTCP, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
-
- g_object_class_install_property (gobject_class, PROP_LATENCY,
- g_param_spec_uint ("latency", "Buffer latency in ms",
- "Amount of ms to buffer", 0, G_MAXUINT, DEFAULT_LATENCY_MS,
- G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
-
- g_object_class_install_property (gobject_class, PROP_UDP_BUFFER_SIZE,
- g_param_spec_int ("udp-buffer-size", "UDP Buffer Size",
- "Size of the kernel UDP receive buffer in bytes, 0=default",
- 0, G_MAXINT, DEFAULT_UDP_BUFFER_SIZE,
- G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
-
- g_object_class_install_property (gobject_class, PROP_UDP_TIMEOUT,
- g_param_spec_uint64 ("timeout", "UDP Timeout",
- "Fail after timeout microseconds on UDP connections (0 = disabled)",
- 0, G_MAXUINT64, DEFAULT_UDP_TIMEOUT,
- G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
-
- g_object_class_install_property (gobject_class, PROP_ENABLE_PAD_PROBE,
- g_param_spec_boolean ("enable-pad-probe", "Enable Pad Probe",
- "Enable pad probe for debugging",
- FALSE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
-
- GST_DEBUG_CATEGORY_INIT (wfd_rtsp_manager_debug, "wfdrtspmanager", 0, "WFD RTSP Manager");
-}
-
-static void
-wfd_rtsp_manager_init (WFDRTSPManager * manager)
-{
- GstStructure *s = NULL;
- gint i = 0;
-
- /* initialize variables */
- manager->do_rtcp = DEFAULT_DO_RTCP;
- manager->latency = DEFAULT_LATENCY_MS;
- manager->udp_buffer_size = DEFAULT_UDP_BUFFER_SIZE;
- manager->udp_timeout = DEFAULT_UDP_TIMEOUT;
- manager->enable_pad_probe = FALSE;
-
- manager->eos = FALSE;
- manager->seqbase = GST_CLOCK_TIME_NONE;
- manager->timebase = GST_CLOCK_TIME_NONE;
- manager->is_ipv6 = FALSE;
- manager->caps = gst_caps_new_simple ("application/x-rtp",
- "media", G_TYPE_STRING, "video", "payload", G_TYPE_INT, 33, NULL);
-
- manager->srcpad = NULL;
- manager->blockedpad = NULL;
- manager->session = NULL;
- manager->wfdrtpbuffer = NULL;
- for (i=0; i<2; i++) {
- manager->udpsrc[i] = NULL;
- manager->udpsink[i] = NULL;
- manager->channelpad[i] = NULL;
- }
-
- s = gst_caps_get_structure (manager->caps, 0);
- gst_structure_set (s, "clock-rate", G_TYPE_INT, 90000, NULL);
- gst_structure_set (s, "encoding-params", G_TYPE_STRING, "MP2T-ES", NULL);
-
- g_rec_mutex_init (&(manager->state_rec_lock));
-
- manager->protocol = GST_RTSP_LOWER_TRANS_UDP;
-}
-
-
-static void
-wfd_rtsp_manager_finalize (GObject * object)
-{
- WFDRTSPManager *manager;
- gint i;
-
- manager = WFD_RTSP_MANAGER_CAST (object);
-
- if (manager->caps)
- gst_caps_unref (manager->caps);
- manager->caps = NULL;
-
- for (i=0; i <2; i++) {
- if (manager->udpsrc[i]) {
- gst_element_set_state (manager->udpsrc[i], GST_STATE_NULL);
- gst_bin_remove (GST_BIN_CAST (manager->wfdrtspsrc), manager->udpsrc[i]);
- gst_object_unref (manager->udpsrc[i]);
- manager->udpsrc[i] = NULL;
- }
- if (manager->channelpad[i]) {
- gst_object_unref (manager->channelpad[i]);
- manager->channelpad[i] = NULL;
- }
- if (manager->udpsink[i]) {
- gst_element_set_state (manager->udpsink[i], GST_STATE_NULL);
- gst_bin_remove (GST_BIN_CAST (manager->wfdrtspsrc), manager->udpsink[i]);
- gst_object_unref (manager->udpsink[i]);
- manager->udpsink[i] = NULL;
- }
- }
- if (manager->session) {
- gst_element_set_state (manager->session, GST_STATE_NULL);
- gst_bin_remove (GST_BIN_CAST (manager->wfdrtspsrc), manager->session);
- gst_object_unref (manager->session);
- manager->session = NULL;
- }
- if (manager->wfdrtpbuffer) {
- gst_element_set_state (manager->wfdrtpbuffer, GST_STATE_NULL);
- gst_bin_remove (GST_BIN_CAST (manager->wfdrtspsrc), manager->wfdrtpbuffer);
- gst_object_unref (manager->wfdrtpbuffer);
- manager->wfdrtpbuffer = NULL;
- }
- g_rec_mutex_clear (&(manager->state_rec_lock));
-
- G_OBJECT_CLASS (wfd_rtsp_manager_parent_class)->finalize (object);
-}
-
-
-WFDRTSPManager *
-wfd_rtsp_manager_new (GstElement *wfdrtspsrc)
-{
- WFDRTSPManager *manager;
-
- g_return_val_if_fail (wfdrtspsrc, NULL);
- g_return_val_if_fail (GST_IS_ELEMENT(wfdrtspsrc), NULL);
-
- manager = g_object_new (WFD_TYPE_RTSP_MANAGER, NULL);
- if (G_UNLIKELY(!manager)) {
- GST_ERROR("failed to create Wi-Fi Display manager.");
- return NULL;
- }
-
- manager->wfdrtspsrc = wfdrtspsrc;
-
- return manager;
-}
-
-static void
-wfd_rtsp_manager_set_property (GObject * object, guint prop_id,
- const GValue * value, GParamSpec * pspec)
-{
- WFDRTSPManager *manager;
-
- manager = WFD_RTSP_MANAGER_CAST (object);
-
- switch (prop_id) {
- case PROP_DO_RTCP:
- manager->do_rtcp = g_value_get_boolean (value);
- break;
- case PROP_LATENCY:
- manager->latency = g_value_get_uint (value);
- g_object_set (G_OBJECT(manager->wfdrtpbuffer), "latency", manager->latency, NULL);
- break;
- case PROP_UDP_BUFFER_SIZE:
- manager->udp_buffer_size = g_value_get_int (value);
- break;
- case PROP_UDP_TIMEOUT:
- manager->udp_timeout = g_value_get_uint64 (value);
- break;
- case PROP_ENABLE_PAD_PROBE:
- manager->enable_pad_probe = g_value_get_boolean (value);
- break;
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
- break;
- }
-}
-
-static void wfd_rtsp_manager_get_property (GObject * object, guint prop_id,
- GValue * value, GParamSpec * pspec)
-{
- WFDRTSPManager *manager;
-
- manager = WFD_RTSP_MANAGER_CAST (object);
-
- switch (prop_id) {
- case PROP_DO_RTCP:
- g_value_set_boolean (value, manager->do_rtcp);
- break;
- case PROP_LATENCY:
- g_value_set_uint (value, manager->latency);
- break;
- case PROP_UDP_BUFFER_SIZE:
- g_value_set_int (value, manager->udp_buffer_size);
- break;
- case PROP_UDP_TIMEOUT:
- g_value_set_uint64 (value, manager->udp_timeout);
- break;
- case PROP_ENABLE_PAD_PROBE:
- g_value_set_boolean (value, manager->enable_pad_probe);
- break;
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
- break;
- }
-}
-
-static gboolean
-wfd_rtsp_manager_activate (WFDRTSPManager *manager)
-{
- GST_DEBUG_OBJECT (manager, "activating streams");
-
- if (manager->udpsrc[0]) {
- /* remove timeout, we are streaming now and timeouts will be handled by
- * the session manager and jitter buffer */
- g_object_set (G_OBJECT (manager->udpsrc[0]), "timeout", (guint64) 0, NULL);
- }
-
- if (manager->srcpad) {
- GST_DEBUG_OBJECT (manager, "setting pad caps for manager %p", manager);
- gst_pad_set_caps (manager->srcpad, manager->caps);
-
- GST_DEBUG_OBJECT (manager, "activating manager pad %p", manager);
- gst_pad_set_active (manager->srcpad, TRUE);
- }
-
- /* unblock all pads */
- if (manager->blockedpad && manager->blockid != 0) {
- GST_DEBUG_OBJECT (manager, "unblocking manager pad %p", manager);
- gst_pad_remove_probe (manager->blockedpad, manager->blockid);
- manager->blockid = 0;
- manager->blockedpad = NULL;
- }
-
- return TRUE;
-}
-
-
-static void
-pad_blocked (GstPad * pad, gboolean blocked, WFDRTSPManager *manager)
-{
- GST_DEBUG_OBJECT (manager, "pad %s:%s blocked, activating streams",
- GST_DEBUG_PAD_NAME (pad));
-
- /* activate the streams */
- if (!manager->need_activate)
- goto was_ok;
-
- manager->need_activate = FALSE;
-
- wfd_rtsp_manager_activate (manager);
-
-was_ok:
- return;
-}
-
-static gboolean
-wfd_rtsp_manager_configure_udp (WFDRTSPManager *manager)
-{
- GstPad *outpad = NULL;
-
- /* we manage the UDP elements now. For unicast, the UDP sources where
- * allocated in the stream when we suggested a transport. */
- if (manager->udpsrc[0]) {
- GstCaps *caps;
-
- gst_element_set_locked_state (manager->udpsrc[0], TRUE);
- gst_bin_add (GST_BIN_CAST (manager->wfdrtspsrc), manager->udpsrc[0]);
-
- GST_DEBUG_OBJECT (manager, "setting up UDP source");
-
- /* configure a timeout on the UDP port. When the timeout message is
- * posted */
- g_object_set (G_OBJECT (manager->udpsrc[0]), "timeout",
- manager->udp_timeout * 1000, NULL);
-
- caps = gst_caps_new_simple ("application/x-rtp",
- "media", G_TYPE_STRING, "video", "payload", G_TYPE_INT, 33,
- "clock-rate", G_TYPE_INT, 90000, "encoding-params", G_TYPE_STRING, "MP2T-ES", NULL);
- g_object_set (manager->udpsrc[0], "caps", caps, NULL);
- gst_caps_unref (caps);
-
- /* get output pad of the UDP source. */
- outpad = gst_element_get_static_pad (manager->udpsrc[0], "src");
-
- /* save it so we can unblock */
- manager->blockedpad = outpad;
-
- /* configure pad block on the pad. As soon as there is dataflow on the
- * UDP source, we know that UDP is not blocked by a firewall and we can
- * configure all the streams to let the application autoplug decoders. */
- manager->blockid =
- gst_pad_add_probe (manager->blockedpad,
- GST_PAD_PROBE_TYPE_BLOCK | GST_PAD_PROBE_TYPE_BUFFER |
- GST_PAD_PROBE_TYPE_BUFFER_LIST, (GstPadProbeCallback)pad_blocked, manager, NULL);
-
- if (manager->channelpad[0]) {
- GST_DEBUG_OBJECT (manager, "connecting UDP source 0 to session");
- /* configure for UDP delivery, we need to connect the UDP pads to
- * the session plugin. */
- gst_pad_link_full (outpad, manager->channelpad[0],
- GST_PAD_LINK_CHECK_NOTHING);
- gst_object_unref (outpad);
- outpad = NULL;
- /* we connected to pad-added signal to get pads from the manager */
- } else {
- /* leave unlinked */
- }
- }
-
- /* RTCP port */
- if (manager->udpsrc[1]) {
- GstCaps *caps;
-
- gst_element_set_locked_state (manager->udpsrc[1], TRUE);
- gst_bin_add (GST_BIN_CAST (manager->wfdrtspsrc), manager->udpsrc[1]);
-
- caps = gst_caps_new_empty_simple ("application/x-rtcp");
- g_object_set (manager->udpsrc[1], "caps", caps, NULL);
- gst_caps_unref (caps);
-
- if (manager->channelpad[1]) {
- GstPad *pad;
-
- GST_DEBUG_OBJECT (manager, "connecting UDP source 1 to session");
-
- pad = gst_element_get_static_pad (manager->udpsrc[1], "src");
- gst_pad_link_full (pad, manager->channelpad[1],
- GST_PAD_LINK_CHECK_NOTHING);
- gst_object_unref (pad);
- } else {
- /* leave unlinked */
- }
- }
-
- return TRUE;
-}
-
-static void
-gst_wfdrtspsrc_get_transport_info (WFDRTSPManager * manager,
- GstRTSPTransport * transport, const gchar ** destination, gint * min, gint * max)
-{
- g_return_if_fail (transport);
- g_return_if_fail (transport->lower_transport == GST_RTSP_LOWER_TRANS_UDP);
-
- if (destination) {
- /* first take the source, then the endpoint to figure out where to send
- * the RTCP. */
- if (!(*destination = transport->source)) {
- if (manager->control_connection )
- *destination = gst_rtsp_connection_get_ip (manager->control_connection );
- else if (manager->conninfo.connection)
- *destination =
- gst_rtsp_connection_get_ip (manager->conninfo.connection);
- }
- }
- if (min && max) {
- /* for unicast we only expect the ports here */
- *min = transport->server_port.min;
- *max = transport->server_port.max;
- }
-}
-
-
-/* configure the UDP sink back to the server for status reports */
-static gboolean
-wfd_rtsp_manager_configure_udp_sinks ( WFDRTSPManager * manager, GstRTSPTransport * transport)
-{
- GstPad *pad = NULL;
- GSocket *socket = NULL;
- gint rtp_port = -1, rtcp_port = -1;
- gboolean do_rtcp = FALSE;
- const gchar *destination = NULL;
- gchar *uri = NULL;
-
- /* get transport info */
- gst_wfdrtspsrc_get_transport_info (manager, transport, &destination,
- &rtp_port, &rtcp_port);
-
- /* it's possible that the server does not want us to send RTCP in which case
- * the port is -1 */
- do_rtcp = (rtcp_port != -1 && manager->session != NULL && manager->do_rtcp);
-
- /* we need a destination when we have RTCP port */
- if (destination == NULL && do_rtcp)
- goto no_destination;
-
- if (do_rtcp) {
- GstPad *rtcppad = NULL;
-
- GST_DEBUG_OBJECT (manager, "configure RTCP UDP sink for %s:%d", destination,
- rtcp_port);
-
- uri = g_strdup_printf ("udp://%s:%d", destination, rtcp_port);
- manager->udpsink[1] = gst_element_make_from_uri (GST_URI_SINK, uri, NULL, NULL);
- g_free (uri);
- if (manager->udpsink[1] == NULL)
- goto no_sink_element;
-
- /* don't join multicast group, we will have the source socket do that */
- /* no sync or async state changes needed */
- g_object_set (G_OBJECT (manager->udpsink[1]), "auto-multicast", FALSE,
- "loop", FALSE, "sync", FALSE, "async", FALSE, NULL);
-
- if (manager->udpsrc[1]) {
- /* configure socket, we give it the same UDP socket as the udpsrc for RTCP
- * because some servers check the port number of where it sends RTCP to identify
- * the RTCP packets it receives */
- g_object_get (G_OBJECT (manager->udpsrc[1]), "used-socket", &socket, NULL);
- GST_DEBUG_OBJECT (manager, "RTCP UDP src has sock %p", socket);
- /* configure socket and make sure udpsink does not close it when shutting
- * down, it belongs to udpsrc after all. */
- g_object_set (G_OBJECT (manager->udpsink[1]), "socket", socket,
- "close-socket", FALSE, NULL);
- g_object_unref (socket);
- }
-
- /* we don't want to consider this a sink */
- GST_OBJECT_FLAG_UNSET (manager->udpsink[1], GST_ELEMENT_FLAG_SINK);
-
- /* we keep this playing always */
- gst_element_set_locked_state (manager->udpsink[1], TRUE);
- gst_element_set_state (manager->udpsink[1], GST_STATE_PLAYING);
-
- gst_object_ref (manager->udpsink[1]);
- gst_bin_add (GST_BIN_CAST (manager->wfdrtspsrc), manager->udpsink[1]);
-
- rtcppad = gst_element_get_static_pad (manager->udpsink[1], "sink");
-
- /* get session RTCP pad */
- pad = gst_element_get_request_pad (manager->session, "send_rtcp_src");
-
- /* and link */
- if (pad && rtcppad) {
- gst_pad_link_full (pad, rtcppad, GST_PAD_LINK_CHECK_NOTHING);
- gst_object_unref (pad);
- gst_object_unref (rtcppad);
- }
- }
-
- return TRUE;
-
- /* ERRORS */
-no_destination:
- {
- GST_DEBUG_OBJECT (manager, "no destination address specified");
- return FALSE;
- }
-no_sink_element:
- {
- GST_DEBUG_OBJECT (manager, "no UDP sink element found");
- return FALSE;
- }
-}
-
-static void
-on_bye_ssrc (GObject * session, GObject * source, WFDRTSPManager * manager)
-{
- GST_DEBUG_OBJECT (manager, "source in session received BYE");
-
- //gst_wfdrtspsrc_do_stream_eos (src, manager);
-}
-
-static void
-on_new_ssrc (GObject * session, GObject * source, WFDRTSPManager * manager)
-{
- GST_DEBUG_OBJECT (manager, "source in session received NEW");
-}
-
-static void
-on_timeout (GObject * session, GObject * source, WFDRTSPManager * manager)
-{
- GST_DEBUG_OBJECT (manager, "source in session timed out");
-
- //gst_wfdrtspsrc_do_stream_eos (src, manager);
-}
-
-static void
-on_ssrc_active (GObject * session, GObject * source, WFDRTSPManager * manager)
-{
- GST_DEBUG_OBJECT (manager, "source in session is active");
-}
-
-
-static GstCaps *
-request_pt_map_for_wfdrtpbuffer (GstElement * wfdrtpbuffer, guint pt, WFDRTSPManager * manager)
-{
- GstCaps *caps;
-
- if (!manager)
- goto unknown_stream;
-
- GST_DEBUG_OBJECT (manager, "getting pt map for pt %d", pt);
-
- WFD_RTSP_MANAGER_STATE_LOCK (manager);
-
- caps = manager->caps;
- if (caps)
- gst_caps_ref (caps);
- WFD_RTSP_MANAGER_STATE_UNLOCK (manager);
-
- return caps;
-
-unknown_stream:
- {
- GST_ERROR ( " manager is NULL");
- return NULL;
- }
-}
-
-static GstCaps *
-request_pt_map_for_session (GstElement * session, guint session_id, guint pt, WFDRTSPManager * manager)
-{
- GstCaps *caps;
-
- GST_DEBUG_OBJECT (manager, "getting pt map for pt %d in session %d", pt, session_id);
-
- WFD_RTSP_MANAGER_STATE_LOCK (manager);
- caps = manager->caps;
- if (caps)
- gst_caps_ref (caps);
- WFD_RTSP_MANAGER_STATE_UNLOCK (manager);
-
- return caps;
-}
-
-gboolean
-wfd_rtsp_manager_prepare_transport (WFDRTSPManager * manager,
- gint rtpport, gint rtcpport)
-{
- GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
- GstElement *udpsrc0 = NULL, *udpsrc1 = NULL;
- gint tmp_rtp = 0, tmp_rtcp = 0;
- const gchar *host = NULL;
-
- if (manager->is_ipv6)
- host = "udp://[::0]";
- else
- host = "udp://0.0.0.0";
-
- /* try to allocate 2 UDP ports */
- udpsrc0 = gst_element_make_from_uri (GST_URI_SRC, host, NULL, NULL);
- if (udpsrc0 == NULL)
- goto no_udp_protocol;
- g_object_set (G_OBJECT (udpsrc0), "port", rtpport, "reuse", FALSE, NULL);
-
- if (manager->udp_buffer_size != 0)
- g_object_set (G_OBJECT (udpsrc0), "buffer-size", manager->udp_buffer_size,
- NULL);
-
- ret = gst_element_set_state (udpsrc0, GST_STATE_READY);
- if (ret == GST_STATE_CHANGE_FAILURE) {
- GST_ERROR_OBJECT (manager, "Unable to make udpsrc from RTP port %d", rtpport);
- /* port not even, free RTP udpsrc */
- goto no_ports;
- }
-
- g_object_get (G_OBJECT (udpsrc0), "port", &tmp_rtp, NULL);
- GST_DEBUG_OBJECT (manager, "got RTP port %d", tmp_rtp);
-
- /* check if port is even */
- if ((tmp_rtp & 0x01) != 0) {
- GST_DEBUG_OBJECT (manager, "RTP port not even");
- /* port not even, free RTP udpsrc */
- goto no_ports;
- }
-
- /* allocate port+1 for RTCP now */
- udpsrc1 = gst_element_make_from_uri (GST_URI_SRC, host, NULL, NULL);
- if (udpsrc1 == NULL)
- goto no_udp_rtcp_protocol;
-
- /* set port */
- g_object_set (G_OBJECT (udpsrc1), "port", rtcpport, "reuse", FALSE, NULL);
-
- GST_DEBUG_OBJECT (manager, "starting RTCP on port %d", rtcpport);
- ret = gst_element_set_state (udpsrc1, GST_STATE_READY);
- if (ret == GST_STATE_CHANGE_FAILURE) {
- GST_ERROR_OBJECT (manager, "Unable to make udpsrc from RTCP port %d", rtcpport);
- goto no_ports;
- }
-
- /* all fine, do port check */
- g_object_get (G_OBJECT (udpsrc0), "port", &tmp_rtp, NULL);
- g_object_get (G_OBJECT (udpsrc1), "port", &tmp_rtcp, NULL);
-
- /* this should not happen... */
- if (rtpport != tmp_rtp || rtcpport != tmp_rtcp)
- goto port_error;
-
- /* we keep these elements, we configure all in configure_transport when the
- * server told us to really use the UDP ports. */
- manager->udpsrc[0] = gst_object_ref_sink (udpsrc0);
- manager->udpsrc[1] = gst_object_ref_sink (udpsrc1);
- gst_element_set_locked_state (manager->udpsrc[0], TRUE);
- gst_element_set_locked_state (manager->udpsrc[1], TRUE);
-
- return TRUE;
-
- /* ERRORS */
-no_udp_protocol:
- {
- GST_DEBUG_OBJECT (manager, "could not get UDP source");
- goto cleanup;
- }
-no_ports:
- {
- GST_DEBUG_OBJECT (manager, "could not allocate UDP port pair");
- goto cleanup;
- }
-no_udp_rtcp_protocol:
- {
- GST_DEBUG_OBJECT (manager, "could not get UDP source for RTCP");
- goto cleanup;
- }
-port_error:
- {
- GST_DEBUG_OBJECT (manager, "ports don't match rtp: %d<->%d, rtcp: %d<->%d",
- tmp_rtp, rtpport, tmp_rtcp, rtcpport);
- goto cleanup;
- }
-cleanup:
- {
- if (udpsrc0) {
- gst_element_set_state (udpsrc0, GST_STATE_NULL);
- gst_object_unref (udpsrc0);
- }
- if (udpsrc1) {
- gst_element_set_state (udpsrc1, GST_STATE_NULL);
- gst_object_unref (udpsrc1);
- }
- return FALSE;
- }
-}
-
-static gboolean
-wfd_rtsp_manager_configure_manager (WFDRTSPManager * manager)
-{
- GstPad *pad = NULL;
-
- g_return_val_if_fail (manager, FALSE);
-
- /* construct wfdrtspsrc */
- manager->session = gst_element_factory_make ("rtpsession", "wfdrtspsrc_session");
- if (G_UNLIKELY (manager->session == NULL)) {
- GST_ERROR_OBJECT (manager, "could not create gstrtpsession element");
- return FALSE;
- } else {
- g_signal_connect (manager->session, "on-bye-ssrc", (GCallback) on_bye_ssrc,
- manager);
- g_signal_connect (manager->session, "on-bye-timeout", (GCallback) on_timeout,
- manager);
- g_signal_connect (manager->session, "on-timeout", (GCallback) on_timeout,
- manager);
- g_signal_connect (manager->session, "on-ssrc-active",
- (GCallback) on_ssrc_active, manager);
- g_signal_connect (manager->session, "on-new-ssrc", (GCallback) on_new_ssrc,
- manager);
- g_signal_connect (manager->session, "request-pt-map",
- (GCallback) request_pt_map_for_session, manager);
-
- g_object_set (G_OBJECT(manager->session), "rtcp-min-interval", (guint64)1000000000, NULL);
-
- manager->channelpad[0] = gst_element_get_request_pad (manager->session, "recv_rtp_sink");
- if (G_UNLIKELY (manager->channelpad[0] == NULL)) {
- GST_ERROR_OBJECT (manager, "could not create rtp channel pad");
- return FALSE;
- }
-
- manager->channelpad[1] = gst_element_get_request_pad (manager->session, "recv_rtcp_sink");
- if (G_UNLIKELY (manager->channelpad[1] == NULL)) {
- GST_ERROR_OBJECT (manager, "could not create rtcp channel pad");
- return FALSE;
- }
-
- /* we manage sesion element */
- gst_element_set_locked_state (manager->session, TRUE);
-
- if (!gst_bin_add(GST_BIN_CAST(manager->wfdrtspsrc), manager->session)) {
- GST_ERROR_OBJECT (manager, "failed to add rtpsession to wfdrtspsrc");
- return FALSE;
- }
- }
-
- manager->wfdrtpbuffer = gst_element_factory_make ("wfdrtpbuffer", "wfdrtspsrc_wfdrtpbuffer");
- if (G_UNLIKELY (manager->wfdrtpbuffer == NULL)) {
- GST_ERROR_OBJECT (manager, "could not create wfdrtpbuffer element");
- return FALSE;
- } else {
- /* configure latency and packet lost */
- g_object_set (manager->wfdrtpbuffer, "latency", manager->latency, NULL);
-
- g_signal_connect (manager->wfdrtpbuffer, "request-pt-map",
- (GCallback) request_pt_map_for_wfdrtpbuffer, manager);
-
- /* we manage wfdrtpbuffer element */
- gst_element_set_locked_state (manager->wfdrtpbuffer, TRUE);
-
- if (!gst_bin_add(GST_BIN_CAST(manager->wfdrtspsrc), manager->wfdrtpbuffer)) {
- GST_ERROR_OBJECT (manager, "failed to add wfdrtpbuffer to wfdrtspsrc");
- return FALSE;
- }
- }
-
- if (!gst_element_link_many(manager->session, manager->wfdrtpbuffer, NULL)) {
- GST_ERROR_OBJECT (manager, "failed to link elements for wfdrtspsrc");
- return FALSE;
- }
-
- if (!gst_element_sync_state_with_parent(manager->session)) {
- GST_ERROR_OBJECT (manager, "failed for %s to sync state with wfdrtspsrc", GST_ELEMENT_NAME(manager->session));
- return FALSE;
- }
-
- if (!gst_element_sync_state_with_parent(manager->wfdrtpbuffer)) {
- GST_ERROR_OBJECT (manager, "failed for %s to sync state with wfdrtspsrc", GST_ELEMENT_NAME(manager->wfdrtpbuffer));
- return FALSE;
- }
-
- /* set ghost pad */
- pad = gst_element_get_static_pad (manager->wfdrtpbuffer, "src");
- if (G_UNLIKELY (pad == NULL)) {
- GST_ERROR_OBJECT (manager, "failed to get src pad of wfdrtpbuffer for setting ghost pad of wfdrtspsrc");
- return FALSE;
- }
- if (!gst_ghost_pad_set_target (GST_GHOST_PAD (manager->srcpad), pad)) {
- GST_ERROR_OBJECT (manager, "failed to set target pad of wfdrtpbuffer ghost pad");
- gst_object_unref (pad);
- return FALSE;
- }
- gst_object_unref (pad);
-
- if(manager->enable_pad_probe)
- wfd_rtsp_manager_enable_pad_probe(manager);
-
- return TRUE;
-}
-
-
-gboolean
-wfd_rtsp_manager_configure_transport (WFDRTSPManager * manager,
- GstRTSPTransport * transport)
-{
- const gchar * mime;
-
- g_return_val_if_fail(transport, FALSE);
-
- GST_DEBUG_OBJECT (manager, "configuring transport");
-
- /* get the proper mime type for this manager now */
- if (gst_rtsp_transport_get_mime (transport->trans, &mime) < 0)
- goto unknown_transport;
- if (!mime)
- goto unknown_transport;
-
- /* configure the final mime type */
- GST_DEBUG_OBJECT (manager, "setting mime to %s", mime);
-
- if (!wfd_rtsp_manager_configure_manager (manager))
- goto no_manager;
-
- switch (transport->lower_transport) {
- case GST_RTSP_LOWER_TRANS_TCP:
- case GST_RTSP_LOWER_TRANS_UDP_MCAST:
- goto transport_failed;
- case GST_RTSP_LOWER_TRANS_UDP:
- if (!wfd_rtsp_manager_configure_udp (manager))
- goto transport_failed;
- if (!wfd_rtsp_manager_configure_udp_sinks (manager, transport))
- goto transport_failed;
- break;
- default:
- goto unknown_transport;
- }
-
- manager->need_activate = TRUE;
- manager->protocol = transport->lower_transport;
-
- return TRUE;
-
- /* ERRORS */
-transport_failed:
- {
- GST_DEBUG_OBJECT (manager, "failed to configure transport");
- return FALSE;
- }
-unknown_transport:
- {
- GST_DEBUG_OBJECT (manager, "unknown transport");
- return FALSE;
- }
-no_manager:
- {
- GST_DEBUG_OBJECT (manager, "cannot get a session manager");
- return FALSE;
- }
-}
-
-void
-wfd_rtsp_manager_set_state (WFDRTSPManager * manager, GstState state)
-{
- gint i=0;
-
- g_return_if_fail(manager);
-
- if (manager->session)
- gst_element_set_state (manager->session, state);
-
- if (manager->wfdrtpbuffer)
- gst_element_set_state (manager->wfdrtpbuffer, state);
-
- for (i = 0; i < 2; i++) {
- if (manager->udpsrc[i])
- gst_element_set_state (manager->udpsrc[i], state);
- }
-}
-
-GstPadProbeReturn
-wfd_rtsp_manager_pad_probe_cb(GstPad * pad, GstPadProbeInfo *info, gpointer u_data)
-{
- GstElement* parent = NULL;
- const GstSegment *segment = NULL;
-
- g_return_val_if_fail (pad, GST_PAD_PROBE_DROP);
- g_return_val_if_fail (info, GST_PAD_PROBE_DROP);
-
- parent = (GstElement*)gst_object_get_parent(GST_OBJECT(pad));
- if(!parent)
- return GST_PAD_PROBE_DROP;
-
- if (info->type & GST_PAD_PROBE_TYPE_BUFFER) {
- GstBuffer *buffer = gst_pad_probe_info_get_buffer (info);
-
- /* show name and timestamp */
- GST_DEBUG_OBJECT(WFD_RTSP_MANAGER (u_data), "BUFFER PROBE : %s:%s : %u:%02u:%02u.%09u (%d bytes)",
- GST_STR_NULL(GST_ELEMENT_NAME(parent)), GST_STR_NULL(GST_PAD_NAME(pad)),
- GST_TIME_ARGS(GST_BUFFER_TIMESTAMP(buffer)), gst_buffer_get_size(buffer));
- } else if (info->type & GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM ||
- info->type & GST_PAD_PROBE_TYPE_EVENT_UPSTREAM ||
- info->type & GST_PAD_PROBE_TYPE_EVENT_FLUSH ||
- info->type & GST_PAD_PROBE_TYPE_EVENT_BOTH) {
- GstEvent *event = gst_pad_probe_info_get_event (info);
- /* show name and event type */
- GST_DEBUG_OBJECT(WFD_RTSP_MANAGER (u_data), "EVENT PROBE : %s:%s : %s",
- GST_STR_NULL(GST_ELEMENT_NAME(parent)), GST_STR_NULL(GST_PAD_NAME(pad)),
- GST_EVENT_TYPE_NAME(event));
-
- if (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) {
- gst_event_parse_segment (event, &segment);
- if (segment)
- GST_DEBUG_OBJECT (WFD_RTSP_MANAGER (u_data), "NEWSEGMENT : %"
- GST_TIME_FORMAT " -- %" GST_TIME_FORMAT ", time %" GST_TIME_FORMAT,
- GST_TIME_ARGS(segment->start), GST_TIME_ARGS(segment->stop),GST_TIME_ARGS(segment->time));
- }
- }
-
- if ( parent )
- gst_object_unref(parent);
-
- return GST_PAD_PROBE_OK;
-}
-
-static void wfd_rtsp_manager_enable_pad_probe(WFDRTSPManager * manager)
-{
- GstPad * pad = NULL;
-
- g_return_if_fail(manager);
-
- if(manager->udpsrc[0]) {
- pad = NULL;
- pad = gst_element_get_static_pad(manager->udpsrc[0], "src");
- if (pad) {
- if( gst_pad_add_probe(pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM, wfd_rtsp_manager_pad_probe_cb, (gpointer)manager, NULL)) {
- GST_DEBUG_OBJECT (manager, "added pad probe (pad : %s, element : %s)", gst_pad_get_name(pad), gst_element_get_name(manager->udpsrc[0]));
- }
- gst_object_unref (pad);
- pad = NULL;
- }
- }
-
- if(manager->session) {
- pad = gst_element_get_static_pad(manager->session, "recv_rtp_sink");
- if (pad) {
- if( gst_pad_add_probe(pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM, wfd_rtsp_manager_pad_probe_cb, (gpointer)manager, NULL)) {
- GST_DEBUG_OBJECT (manager, "added pad probe (pad : %s, element : %s)", gst_pad_get_name(pad), gst_element_get_name(manager->session));
- }
- gst_object_unref (pad);
- pad = NULL;
- }
- pad = gst_element_get_static_pad(manager->session, "recv_rtp_src");
- if (pad) {
- if( gst_pad_add_probe(pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM, wfd_rtsp_manager_pad_probe_cb, (gpointer)manager, NULL)) {
- GST_DEBUG_OBJECT (manager, "added pad probe (pad : %s, element : %s)", gst_pad_get_name(pad), gst_element_get_name(manager->session));
- }
- gst_object_unref (pad);
- pad = NULL;
- }
- }
-
- if(manager->wfdrtpbuffer) {
- pad = gst_element_get_static_pad(manager->wfdrtpbuffer, "sink");
- if (pad) {
- if( gst_pad_add_probe(pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM, wfd_rtsp_manager_pad_probe_cb, (gpointer)manager, NULL)) {
- GST_DEBUG_OBJECT (manager, "added pad probe (pad : %s, element : %s)", gst_pad_get_name(pad), gst_element_get_name(manager->wfdrtpbuffer));
- }
- gst_object_unref (pad);
- pad = NULL;
- }
-
- pad = gst_element_get_static_pad(manager->wfdrtpbuffer, "src");
- if (pad) {
- if( gst_pad_add_probe(pad, GST_PAD_PROBE_TYPE_DATA_DOWNSTREAM, wfd_rtsp_manager_pad_probe_cb, (gpointer)manager, NULL)) {
- GST_DEBUG_OBJECT (manager, "added pad probe (pad : %s, element : %s)", gst_pad_get_name(pad), gst_element_get_name(manager->wfdrtpbuffer));
- }
- gst_object_unref (pad);
- pad = NULL;
- }
- }
-
-}
+++ /dev/null
-/*
- * xvimagesrc
- *
- * Copyright (c) 2000 - 2015 Samsung Electronics Co., Ltd. All rights reserved.
- *
- * Contact: Hyunjun Ko <zzoon.ko@samsung.com>
- *
- * This library is free software; you can redistribute it and/or modify it under
- * the terms of the GNU Lesser General Public License as published by the
- * Free Software Foundation; either version 2.1 of the License, or (at your option)
- * any later version.
- *
- * This library is distributed in the hope that it will be useful, but WITHOUT ANY
- * WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
- * License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this library; if not, write to the Free Software Foundation, Inc., 51
- * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
- *
- */
-/**
-* SECTION:element-xvimagesrc
-*
-* xvimagesrc captures frame buffer which includes the application data along with video layer data
-* from the XServer and pushes the data to the downstream element.
-*
-*
-* <refsect2>
-* <title>Example launch line</title>
-* |[
-* gst-launch xvimagesrc ! "video/x-raw, width=720, height=1280, framerate=(fraction)30/1, format=(string)ST12" ! fakesink
-* ]| captures the frame buffer from the XServer and send the buffers to a fakesink.
-* </refsect2>
-*/
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include "gstxvimagesrc.h"
-
-/* headers for drm */
-#include <sys/stat.h>
-#include <sys/ioctl.h>
-#include <fcntl.h>
-#include <unistd.h>
-#include <X11/Xmd.h>
-#include <X11/Xlibint.h>
-#include <dri2.h>
-#include <drm.h>
-#include <sys/time.h>
-#include <sys/times.h>
-#include <xf86drm.h>
-#include <sys/mman.h>
-#include <exynos_drm.h>
-#include <mm_types.h>
-
-GST_DEBUG_CATEGORY_STATIC (xvimagesrc_debug);
-#define GST_CAT_DEFAULT xvimagesrc_debug
-
-#define GST_XV_IMAGE_SRC_CAPS \
- "video/x-raw, " \
- "format = (string) RGBx, " \
- "width = (int) [ 16, 4096 ], " \
- "height = (int) [ 16, 4096 ], " \
- "framerate = (fraction) [0/1, 2147483647/1];" \
- "video/x-raw," \
- "format = (string) { SN12, ST12 }, " \
- "width = (int) [ 1, 4096 ], " \
- "height = (int) [ 1, 4096 ], " \
- "framerate = (fraction) [0/1, 2147483647/1];"
-
-static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
- GST_PAD_SRC,
- GST_PAD_ALWAYS,
- GST_STATIC_CAPS (GST_XV_IMAGE_SRC_CAPS)
- );
-
-enum
-{
- PROP_0
-};
-
-enum
-{
- VIDEO_TYPE_VIDEO_WITH_UI,
- VIDEO_TYPE_VIDEO_ONLY,
-};
-
-enum
-{
- SIGNAL_VIDEO_WITH_UI = 0,
- SIGNAL_VIDEO_ONLY,
- SIGNAL_SELECTION_NOTIFY,
- SIGNAL_LAST
-};
-
-#define GEM_NAME_MAX 10
-
-#define SCMN_CS_YUV420 1 /* Y:U:V 4:2:0 */
-#define SCMN_CS_I420 SCMN_CS_YUV420 /* Y:U:V */
-#define SCMN_CS_NV12 6
-#define SCMN_CS_NV12_T64X32 11 /* 64x32 Tiled NV12 type */
-#define SCMN_CS_UYVY 100
-#define SCMN_CS_YUYV 101
-#define SCMN_CS_YUY2 SCMN_CS_YUYV
-
-typedef struct
-{
- void *address[GEM_NAME_MAX];
- int buffer_size[GEM_NAME_MAX];
- int name[GEM_NAME_MAX];
- gint32 fd[GEM_NAME_MAX];
- gint32 handle[GEM_NAME_MAX];
-} GEM_MMAP;
-
-typedef enum
-{
- BUF_SHARE_METHOD_PADDR = 0,
- BUF_SHARE_METHOD_FD,
- BUF_SHARE_METHOD_TIZEN_BUFFER
-} buf_share_method_t;
-
-typedef struct GstXvImageOutBuffer GstXvImageOutBuffer;
-
-struct GstXvImageOutBuffer
-{
- GstBuffer *buffer;
- int fd_name;
- unsigned int YBuf;
- tbm_bo bo[2];
- GstXVImageSrc *xvimagesrc;
-};
-
-static guint gst_xv_image_src_signals[SIGNAL_LAST] = { 0 };
-
-static const char fake_edid_info[] = {
- 0x00, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0x00, 0x4c, 0x2d, 0x05, 0x05,
- 0x00, 0x00, 0x00, 0x00, 0x30, 0x12, 0x01, 0x03, 0x80, 0x10, 0x09, 0x78,
- 0x0a, 0xee, 0x91, 0xa3, 0x54, 0x4c, 0x99, 0x26, 0x0f, 0x50, 0x54, 0xbd,
- 0xee, 0x00, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01,
- 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x66, 0x21, 0x50, 0xb0, 0x51, 0x00,
- 0x1b, 0x30, 0x40, 0x70, 0x36, 0x00, 0xa0, 0x5a, 0x00, 0x00, 0x00, 0x1e,
- 0x01, 0x1d, 0x00, 0x72, 0x51, 0xd0, 0x1e, 0x20, 0x6e, 0x28, 0x55, 0x00,
- 0xa0, 0x5a, 0x00, 0x00, 0x00, 0x1e, 0x00, 0x00, 0x00, 0xfd, 0x00, 0x18,
- 0x4b, 0x1a, 0x44, 0x17, 0x00, 0x0a, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
- 0x00, 0x00, 0x00, 0xfc, 0x00, 0x53, 0x41, 0x4d, 0x53, 0x55, 0x4e, 0x47,
- 0x0a, 0x20, 0x20, 0x20, 0x20, 0x20, 0x01, 0xbc, 0x02, 0x03, 0x1e, 0xf1,
- 0x46, 0x84, 0x05, 0x03, 0x10, 0x20, 0x22, 0x23, 0x09, 0x07, 0x07, 0x83,
- 0x01, 0x00, 0x00, 0xe2, 0x00, 0x0f, 0x67, 0x03, 0x0c, 0x00, 0x10, 0x00,
- 0xb8, 0x2d, 0x01, 0x1d, 0x80, 0x18, 0x71, 0x1c, 0x16, 0x20, 0x58, 0x2c,
- 0x25, 0x00, 0xa0, 0x5a, 0x00, 0x00, 0x00, 0x9e, 0x8c, 0x0a, 0xd0, 0x8a,
- 0x20, 0xe0, 0x2d, 0x10, 0x10, 0x3e, 0x96, 0x00, 0xa0, 0x5a, 0x00, 0x00,
- 0x00, 0x18, 0x02, 0x3a, 0x80, 0x18, 0x71, 0x38, 0x2d, 0x40, 0x58, 0x2c,
- 0x45, 0x00, 0xa0, 0x5a, 0x00, 0x00, 0x00, 0x1e, 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x06
-};
-
-//#define _MAKE_DUMP
-#ifdef _MAKE_DUMP
-#define YUV_FRAME_SIZE 3110400
-#define YUV_720_FRAME_SIZE 1382400
-#define YUV_VGA_FRAME_SIZE 460800
-
-static int g_prev_frame[YUV_FRAME_SIZE] = { 0, };
-
-static unsigned char g_dump_frame[100][921600];
-static unsigned char g_dump_frame1[100][462848];
-//static int g_dump_frame[100][YUV_720_FRAME_SIZE];
-//static int g_dump_frame[200][YUV_VGA_FRAME_SIZE];
-static int f_idx = 0;
-static int f_done = 0;
-#endif
-
-//#define COUNT_FRAMES
-#define BASE_TIME 33000
-#define LIMIT_TIME -33000
-
-#ifdef COUNT_FRAMES
-gchar old_time[10] = { 0, };
-#endif
-
-static gboolean error_caught = FALSE;
-
-#define BUFFER_COND_WAIT_TIMEOUT (1 * G_TIME_SPAN_SECOND)
-//#define GST_TYPE_GST_XV_IMAGE_OUT_BUFFER (gst_xv_image_out_buffer_get_type())
-//#define GST_IS_GST_XV_IMAGE_OUT_BUFFER(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_GST_XV_IMAGE_OUT_BUFFER))
-//static void gst_xv_image_out_buffer_finalize (GstXvImageOutBuffer * buffer);
-static GstXvImageOutBuffer *gst_xv_image_out_buffer_new (GstXVImageSrc * src);
-
-static void gst_xv_image_src_finalize (GObject * gobject);
-
-static void gst_xv_image_src_set_property (GObject * object, guint prop_id,
- const GValue * value, GParamSpec * pspec);
-static void gst_xv_image_src_get_property (GObject * object, guint prop_id,
- GValue * value, GParamSpec * pspec);
-static GstFlowReturn gst_xv_image_src_create (GstPushSrc * psrc,
- GstBuffer ** outbuf);
-static GstStateChangeReturn gst_xv_image_src_change_state (GstElement * element,
- GstStateChange transition);
-static gboolean gst_xv_image_src_start (GstBaseSrc * bsrc);
-static gboolean gst_xv_image_src_stop (GstBaseSrc * bsrc);
-static gboolean gst_xv_image_src_get_size (GstBaseSrc * bsrc, guint64 * size);
-static gboolean gst_xv_image_src_is_seekable (GstBaseSrc * bsrc);
-static gboolean gst_xv_image_src_query (GstBaseSrc * bsrc, GstQuery * query);
-static gboolean gst_xv_image_src_unlock (GstBaseSrc * bsrc);
-static gboolean gst_xv_image_src_unlock_stop (GstBaseSrc * bsrc);
-static gboolean gst_xv_image_src_setcaps (GstBaseSrc * bsrc, GstCaps * caps);
-
-static tbm_bufmgr bufmgr_get (Display * dpy, Pixmap pixmap);
-static int port_get (GstXVImageSrc * src, unsigned int id);
-static void pixmap_update (GstXVImageSrc * src, Display * dpy,
- tbm_bufmgr bufmgr, Pixmap pixmap, int x, int y, int width, int height);
-static Pixmap pixmap_create (GstXVImageSrc * src, Display * dpy, int width,
- int height);
-
-static void *gst_xv_image_src_update_thread (void *asrc);
-static gboolean xvimagesrc_thread_start (GstXVImageSrc * src);
-static void drm_init (GstXVImageSrc * src);
-static void drm_finalize (GstXVImageSrc * src);
-static tbm_bo drm_convert_gem_to_bo (tbm_bufmgr bufmgr, unsigned int gem_name);
-static gint32 drm_convert_gem_to_fd (int *gemname_cnt, int drm_fd,
- unsigned int name, void *data, void **virtual_address, guint * buf_size);
-static void gst_xv_get_image_sleep (void *asrc, long duration);
-
-static void
-_do_init (GType type)
-{
- GST_DEBUG_CATEGORY_INIT (xvimagesrc_debug, "xvimagesrc", 0, "Xv image src");
-}
-
-#define gst_xv_image_src_parent_class parent_class
-G_DEFINE_TYPE_WITH_CODE (GstXVImageSrc, gst_xv_image_src, GST_TYPE_PUSH_SRC,
- _do_init (G_TYPE_INVALID));
-
-//G_DEFINE_BOXED_TYPE (GstXvImageOutBuffer, gst_xv_image_out_buffer, NULL,
-// gst_xv_image_out_buffer_finalize);
-
-#ifdef DEBUG_BUFFER
-int value[5] = { 0 };
-
-static int value_count = 0;
-#endif
-
-
-static GstXvImageOutBuffer *
-gst_xv_image_out_buffer_new (GstXVImageSrc * src)
-{
- GstXvImageOutBuffer *newbuf = NULL;
- GST_LOG ("gst_xv_image_out_buffer_new");
-
- newbuf = (GstXvImageOutBuffer *) malloc (sizeof (GstXvImageOutBuffer));
- if (!newbuf) {
- GST_ERROR ("gst_xv_image_out_buffer_new out of memory");
- return NULL;
- }
- GST_LOG ("creating buffer : %p", newbuf);
- newbuf->buffer = gst_buffer_new ();
- newbuf->xvimagesrc = gst_object_ref (GST_OBJECT (src));
- newbuf->fd_name = 0;
- newbuf->YBuf = 0;
- newbuf->bo[0] = NULL;
- newbuf->bo[1] = NULL;
- return newbuf;
-}
-
-static void
-gst_xv_image_src_class_init (GstXVImageSrcClass * klass)
-{
- GObjectClass *gobject_class;
- GstElementClass *gstelement_class;
- GstBaseSrcClass *gstbasesrc_class;
- GstPushSrcClass *gstpushsrc_class;
- gobject_class = G_OBJECT_CLASS (klass);
- gstelement_class = GST_ELEMENT_CLASS (klass);
- gstbasesrc_class = (GstBaseSrcClass *) klass;
- gstpushsrc_class = (GstPushSrcClass *) klass;
- gobject_class->set_property = gst_xv_image_src_set_property;
- gobject_class->get_property = gst_xv_image_src_get_property;
- gobject_class->finalize = gst_xv_image_src_finalize;
-
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&srctemplate));
- gst_element_class_set_details_simple (gstelement_class,
- "XServer Display FB video source", "Source/video",
- "Receive frame buffer data from XServer and passes to next element",
- "Hyunjun Ko <zzoon.ko@samsung.com>");
-
- gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_xv_image_src_start);
- gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_xv_image_src_stop);
- gstbasesrc_class->unlock = GST_DEBUG_FUNCPTR (gst_xv_image_src_unlock);
- gstbasesrc_class->unlock_stop =
- GST_DEBUG_FUNCPTR (gst_xv_image_src_unlock_stop);
- gstbasesrc_class->get_size = GST_DEBUG_FUNCPTR (gst_xv_image_src_get_size);
- gstbasesrc_class->is_seekable =
- GST_DEBUG_FUNCPTR (gst_xv_image_src_is_seekable);
- gstbasesrc_class->query = GST_DEBUG_FUNCPTR (gst_xv_image_src_query);
- gstbasesrc_class->set_caps = GST_DEBUG_FUNCPTR (gst_xv_image_src_setcaps);
- gstpushsrc_class->create = GST_DEBUG_FUNCPTR (gst_xv_image_src_create);
- gstelement_class->change_state =
- GST_DEBUG_FUNCPTR (gst_xv_image_src_change_state);
-
- gst_xv_image_src_signals[SIGNAL_VIDEO_WITH_UI] =
- g_signal_new ("video-with-ui", G_TYPE_FROM_CLASS (klass),
- G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstXVImageSrcClass, video_with_ui),
- NULL, NULL, g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0, G_TYPE_NONE);
-
- gst_xv_image_src_signals[SIGNAL_VIDEO_ONLY] =
- g_signal_new ("video-only", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
- G_STRUCT_OFFSET (GstXVImageSrcClass, video_only), NULL, NULL,
- g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0, G_TYPE_NONE);
-
- gst_xv_image_src_signals[SIGNAL_SELECTION_NOTIFY] =
- g_signal_new ("selection-notify", G_TYPE_FROM_CLASS (klass),
- G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstXVImageSrcClass, selection_notify),
- NULL, NULL, g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0, G_TYPE_NONE);
-}
-
-static GstStateChangeReturn
-gst_xv_image_src_change_state (GstElement * element, GstStateChange transition)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (element);
-
- GstStateChangeReturn result = GST_STATE_CHANGE_FAILURE;
-
- switch (transition) {
- case GST_STATE_CHANGE_NULL_TO_READY:
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_NULL_TO_READY");
- break;
- case GST_STATE_CHANGE_READY_TO_PAUSED:
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_READY_TO_PAUSED");
- break;
- case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_PAUSED_TO_PLAYING");
- src->pause_cond_var = FALSE;
- g_cond_signal(&src->pause_cond);
- break;
- case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_PLAYING_TO_PAUSED: START");
- src->pause_cond_var = TRUE;
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_PLAYING_TO_PAUSED: End");
- break;
- case GST_STATE_CHANGE_PAUSED_TO_READY:
- GST_WARNING_OBJECT (src, "GST_STATE_CHANGE_PAUSED_TO_READY");
- src->thread_return = TRUE;
- g_cond_signal(&src->pause_cond);
- break;
- case GST_STATE_CHANGE_READY_TO_NULL:
- break;
- default:
- break;
- }
-
- result = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
-
- return result;
-}
-
-static gboolean
-gst_xv_image_src_get_frame_size (int fourcc, int width, int height,
- unsigned int *outsize)
-{
- switch (fourcc) {
-/* case GST_MAKE_FOURCC('I','4','2','0'): // V4L2_PIX_FMT_YUV420
- *outsize = GST_ROUND_UP_4 (width) * GST_ROUND_UP_2 (height);
- *outsize += 2 * ((GST_ROUND_UP_8 (width) / 2) * (GST_ROUND_UP_2 (height) / 2));
- break;*/
- case GST_MAKE_FOURCC ('S', 'N', '1', '2'): // V4L2_PIX_FMT_NV12 non-linear
- case GST_MAKE_FOURCC ('S', 'T', '1', '2'): // V4L2_PIX_FMT_NV12 tiled non-linear
- GST_INFO ("SN12 or ST12");
- *outsize = GST_ROUND_UP_4 (width) * GST_ROUND_UP_2 (height);
- *outsize += (GST_ROUND_UP_4 (width) * height) / 2;
- break;
- case GST_MAKE_FOURCC ('R', 'G', 'B', '4'):
- /* jpeg size can't be calculated here. */
- *outsize = width * height * 4;
- break;
- default:
- /* unkown format!! */
- *outsize = 0;
- return FALSE;
- }
- return TRUE;
-}
-
-static gboolean
-gst_xv_image_src_parse_caps (const GstCaps * caps, guint32 * fourcc,
- gint * width, gint * height, gint * rate_numerator, gint * rate_denominator,
- unsigned int *framesize)
-{
- const GstStructure *structure;
- GstPadLinkReturn ret = TRUE;
- const GValue *framerate;
- const char *media_type = NULL;
-
- if (gst_caps_get_size (caps) < 1)
- return FALSE;
-
- GST_INFO ("xvimagesrc src caps:%" GST_PTR_FORMAT, caps);
-
- structure = gst_caps_get_structure (caps, 0);
- ret = gst_structure_get_int (structure, "width", width);
- if (!ret) {
- GST_ERROR ("xvimagesrc width not specified in caps");
- goto error;
- }
-
- ret = gst_structure_get_int (structure, "height", height);
- if (!ret) {
- GST_ERROR ("xvimagesrc height not specified in caps");
- goto error;
- }
-
- media_type = gst_structure_get_name (structure);
- if (media_type == NULL) {
- GST_ERROR ("xvimagesrc media type not specified in caps");
- goto error;
- }
-
- framerate = gst_structure_get_value (structure, "framerate");
- if (framerate) {
- *rate_numerator = gst_value_get_fraction_numerator (framerate);
- *rate_denominator = gst_value_get_fraction_denominator (framerate);
- } else {
- GST_ERROR ("xvimagesrc frametype not specified in caps");
- goto error;
- }
-
- if (g_strcmp0 (media_type, "video/x-raw") == 0) {
- GST_INFO ("media_type is video/x-raw");
- guint32 format = FOURCC_SN12;
-
-#if 0
- ret = gst_structure_get_uint (structure, "format", &format);
- if (!ret)
- GST_DEBUG
- ("xvimagesrc format not specified in caps, SN12 selected as default");
-#endif
- const gchar * sformat = NULL;
-
- sformat = gst_structure_get_string(structure, "format");
- if (!sformat) {
- GST_WARNING ("xvimagesrc format not specified in caps");
- } else {
- format = FOURCC(sformat[0],sformat[1],sformat[2],sformat[3]);
- }
-
- ret = gst_xv_image_src_get_frame_size (format, *width, *height, framesize);
- if (!ret) {
- GST_ERROR ("xvimagesrc unsupported format type specified in caps");
- goto error;
- }
-
- *fourcc = format;
- }
- return TRUE;
-/* ERRORS */
-error:
- return FALSE;
-}
-
-static gboolean
-gst_xv_image_src_setcaps (GstBaseSrc * bsrc, GstCaps * caps)
-{
- gboolean res = TRUE;
- gint width, height, rate_denominator, rate_numerator;
- GstXVImageSrc *src;
-
- src = GST_XV_IMAGE_SRC (bsrc);
-
- res = gst_xv_image_src_parse_caps (caps, &src->format_id, &width, &height,
- &rate_numerator, &rate_denominator, &src->framesize);
- if (res) {
- /* looks ok here */
- src->width = width;
- src->height = height;
- src->rate_numerator = rate_numerator;
- src->rate_denominator = rate_denominator;
- GST_DEBUG_OBJECT (src, "size %dx%d, %d/%d fps, framesize : %d",
- src->width, src->height,
- src->rate_numerator, src->rate_denominator, src->framesize);
-
- if (src->rate_numerator) {
- src->sleep_base_time =
- (long) (((int) (1000 / src->rate_numerator)) * 1000);
- src->sleep_limit_time = (long) (-1 * src->sleep_base_time);
- }
- }
-
- xvimagesrc_thread_start (src);
- return res;
-}
-
-static void
-gst_xv_image_src_init (GstXVImageSrc * src)
-{
- src->format_id = 0;
- src->running_time = GST_CLOCK_TIME_NONE;
- src->frame_duration = GST_CLOCK_TIME_NONE;
- src->virtual = NULL;
- src->pixmap = 0;
- src->gc = NULL;
- src->bo = NULL;
- src->dri2_buffers = NULL;
- src->buf_share_method = BUF_SHARE_METHOD_TIZEN_BUFFER;
- g_mutex_init (&src->queue_lock);
- src->queue = g_queue_new ();
- g_cond_init (&src->queue_cond);
- g_mutex_init (&src->cond_lock);
-
- g_cond_init (&src->buffer_cond);
- g_mutex_init (&src->buffer_cond_lock);
- g_mutex_init (&src->dpy_lock);
-
- src->pause_cond_var = FALSE;
- g_cond_init (&src->pause_cond);
- g_mutex_init (&src->pause_lock);
-
- src->drm_fd = -1;
- src->current_data_type = VIDEO_TYPE_VIDEO_WITH_UI;
- src->new_data_type = VIDEO_TYPE_VIDEO_WITH_UI;
- src->get_image_overtime = 0;
- src->get_image_overtime_cnt = 0;
- src->gemname_cnt = 0;
- src->tz_enable = 0;
- src->sleep_base_time = 0;
- src->sleep_limit_time = 0;
-
- drm_init (src);
- gst_base_src_set_live (GST_BASE_SRC (src), TRUE);
-}
-
-static void
-gst_xv_image_src_finalize (GObject * gobject)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (gobject);
- GST_DEBUG_OBJECT (src, "finalize");
- g_mutex_clear (&src->queue_lock);
- g_mutex_clear (&src->pause_lock);
- g_mutex_clear (&src->dpy_lock);
- g_mutex_clear (&src->cond_lock);
- g_mutex_clear (&src->buffer_cond_lock);
- drm_finalize (src);
- G_OBJECT_CLASS (parent_class)->finalize (gobject);
-}
-
-static void
-drm_init (GstXVImageSrc * src)
-{
- Display *dpy;
- int eventBase, errorBase;
- int dri2Major, dri2Minor;
- char *driverName, *deviceName;
- struct drm_auth auth_arg = { 0 };
-
- src->drm_fd = -1;
- dpy = XOpenDisplay (0);
-
- /* DRI2 */
- if (!DRI2QueryExtension (dpy, &eventBase, &errorBase)) {
- GST_ERROR ("DRI2QueryExtension !!");
- return;
- }
- if (!DRI2QueryVersion (dpy, &dri2Major, &dri2Minor)) {
- GST_ERROR ("DRI2QueryVersion !!");
- return;
- }
- if (!DRI2Connect (dpy, RootWindow (dpy, DefaultScreen (dpy)), &driverName,
- &deviceName)) {
- GST_ERROR ("DRI2Connect !!");
- return;
- }
- GST_INFO ("Open drm device : %s", deviceName);
-
- /* get the drm_fd though opening the deviceName */
- src->drm_fd = open (deviceName, O_RDWR);
- if (src->drm_fd < 0) {
- GST_ERROR ("cannot open drm device (%s)", deviceName);
- return;
- }
-
- /* get magic from drm to authentication */
- if (ioctl (src->drm_fd, DRM_IOCTL_GET_MAGIC, &auth_arg)) {
- GST_ERROR ("cannot get drm auth magic");
- close (src->drm_fd);
- src->drm_fd = -1;
- return;
- }
- if (!DRI2Authenticate (dpy, RootWindow (dpy, DefaultScreen (dpy)),
- auth_arg.magic)) {
- GST_ERROR ("cannot get drm authentication from X");
- close (src->drm_fd);
- src->drm_fd = -1;
- return;
- }
-}
-
-static void
-drm_finalize (GstXVImageSrc * src)
-{
- if (src->drm_fd >= 0) {
- close (src->drm_fd);
- src->drm_fd = -1;
- }
-}
-
-static tbm_bo
-drm_convert_gem_to_bo (tbm_bufmgr bufmgr, unsigned int gem_name)
-{
- tbm_bo ret = NULL;
-
- ret = tbm_bo_import (bufmgr, gem_name);
- if (ret == NULL) {
- GST_ERROR ("[Error] : cannot import bo (key:%d)", gem_name);
- }
-
- return ret;
-}
-
-static gint32
-drm_convert_gem_to_fd (int *gemname_cnt, int drm_fd, unsigned int name,
- void *data, void **virtual_address, guint * buf_size)
-{
- g_return_val_if_fail ((data != NULL), 0);
- int count = 0;
- gint32 fd = 0;
- count = *gemname_cnt;
- GST_DEBUG ("gamname_cnt = %d", count);
- GST_DEBUG ("name = %u", name);
-
-
- GEM_MMAP *xv_gem_mmap = NULL;
- xv_gem_mmap = (GEM_MMAP *) data;
-
- if (count < GEM_NAME_MAX) {
- int i = 0;
-
- for (i = 0; i < GEM_NAME_MAX; i++) {
- if (name == xv_gem_mmap->name[i])
- goto PASS;
- }
-
- struct drm_prime_handle prime;
- struct drm_gem_open gem_open;
- /* TODO: drm_exynos_gem_mmap was removed. It can be replaced with drm_mode_map_dumb.
- struct drm_exynos_gem_mmap gem_mmap; //for virtual address
- */
-
- memset (&gem_open, 0, sizeof (struct drm_gem_open));
- gem_open.name = name;
- if (ioctl (drm_fd, DRM_IOCTL_GEM_OPEN, &gem_open)) {
- GST_ERROR ("Gem Open failed");
- return 0;
- }
-
- memset (&prime, 0, sizeof (struct drm_prime_handle));
- prime.handle = gem_open.handle;
- prime.flags = DRM_CLOEXEC;
-
- /*get gem_open handle */
- xv_gem_mmap->handle[count] = gem_open.handle;
- GST_DEBUG ("gem_open.handle =%d, xv_gem_mmap->handle[count]=%d",
- gem_open.handle, xv_gem_mmap->handle[count]);
-
- /*get virtual address */
- /*set name */
- xv_gem_mmap->name[count] = name;
- /* TODO: drm_exynos_gem_mmap was removed. It can be replaced with drm_mode_map_dumb.
- memset (&gem_mmap, 0, sizeof (struct drm_exynos_gem_mmap));
- gem_mmap.handle = prime.handle;
- gem_mmap.size = gem_open.size;
- */
-
- /*set size */
- /* TODO: drm_exynos_gem_mmap was removed. It can be replaced with drm_mode_map_dumb.
- xv_gem_mmap->buffer_size[count] = gem_mmap.size;
- */
- /* TODO: DRM_IOCTL_EXYNOS_GEM_MMAP was removed. It can be replaced with drm_mmap.
- if (drmIoctl (drm_fd, DRM_IOCTL_EXYNOS_GEM_MMAP, &gem_mmap) != 0) {
- GST_ERROR ("Gem mmap failed [handle %d, size %lld]", gem_mmap.handle,
- gem_mmap.size);
- return 0;
- }
- */
-
- /*set virtual address */
- /* TODO: drm_exynos_gem_mmap was removed. It can be replaced with drm_mode_map_dumb.
- xv_gem_mmap->address[count] = (void *) (gem_mmap.mapped);
- */
- GST_DEBUG ("%u - Virtual address[%d] = %p size=%d ", name, count,
- xv_gem_mmap->address[count], xv_gem_mmap->buffer_size[count]);
-
- /*get fd */
- if (ioctl (drm_fd, DRM_IOCTL_PRIME_HANDLE_TO_FD, &prime) < 0) {
- GST_ERROR ("Gem Handle to Fd failed");
- return 0;
- }
-
- xv_gem_mmap->fd[count] = prime.fd;
- GST_DEBUG ("fd = %d", xv_gem_mmap->fd[count]);
- }
-
- if (count < GEM_NAME_MAX) {
- count++;
- *gemname_cnt = count;
- }
-
-PASS:
- if (name == xv_gem_mmap->name[0]) {
- *virtual_address = xv_gem_mmap->address[0];
- fd = xv_gem_mmap->fd[0];
- *buf_size = xv_gem_mmap->buffer_size[0];
- } else if (name == xv_gem_mmap->name[1]) {
- *virtual_address = xv_gem_mmap->address[1];
- fd = xv_gem_mmap->fd[1];
- *buf_size = xv_gem_mmap->buffer_size[1];
- } else if (name == xv_gem_mmap->name[2]) {
- *virtual_address = xv_gem_mmap->address[2];
- fd = xv_gem_mmap->fd[2];
- *buf_size = xv_gem_mmap->buffer_size[2];
- } else if (name == xv_gem_mmap->name[3]) {
- *virtual_address = xv_gem_mmap->address[3];
- fd = xv_gem_mmap->fd[3];
- *buf_size = xv_gem_mmap->buffer_size[3];
- } else if (name == xv_gem_mmap->name[4]) {
- *virtual_address = xv_gem_mmap->address[4];
- fd = xv_gem_mmap->fd[4];
- *buf_size = xv_gem_mmap->buffer_size[4];
- } else if (name == xv_gem_mmap->name[5]) {
- *virtual_address = xv_gem_mmap->address[5];
- fd = xv_gem_mmap->fd[5];
- *buf_size = xv_gem_mmap->buffer_size[5];
- } else if (name == xv_gem_mmap->name[6]) {
- *virtual_address = xv_gem_mmap->address[6];
- fd = xv_gem_mmap->fd[6];
- *buf_size = xv_gem_mmap->buffer_size[6];
- } else if (name == xv_gem_mmap->name[7]) {
- *virtual_address = xv_gem_mmap->address[7];
- fd = xv_gem_mmap->fd[7];
- *buf_size = xv_gem_mmap->buffer_size[7];
- } else if (name == xv_gem_mmap->name[8]) {
- *virtual_address = xv_gem_mmap->address[8];
- fd = xv_gem_mmap->fd[8];
- *buf_size = xv_gem_mmap->buffer_size[8];
- } else if (name == xv_gem_mmap->name[9]) {
- *virtual_address = xv_gem_mmap->address[9];
- fd = xv_gem_mmap->fd[9];
- *buf_size = xv_gem_mmap->buffer_size[9];
- }
-
- GST_DEBUG ("virtual_address = %p (size: %d) fd = %d",
- *virtual_address, *buf_size, fd);
- return fd;
-}
-
-static void
-gst_xv_image_src_set_property (GObject * object, guint prop_id,
- const GValue * value, GParamSpec * pspec)
-{
- //GstXVImageSrc *src = GST_XV_IMAGE_SRC (object);
-
- switch (prop_id) {
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
- break;
- }
-
- return;
-}
-
-static void
-gst_xv_image_src_get_property (GObject * object, guint prop_id,
- GValue * value, GParamSpec * pspec)
-{
- //GstXVImageSrc *src = GST_XV_IMAGE_SRC (object);
-
- switch (prop_id) {
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
- break;
- }
-
- return;
-}
-
-static gboolean
-gst_xv_image_src_get_timeinfo (GstXVImageSrc *src, GstClockTime *time, GstClockTime *dur)
-{
- int fps_nu = 0;
- int fps_de = 0;
- GstClockTime timestamp = GST_CLOCK_TIME_NONE;
- GstClockTime duration = GST_CLOCK_TIME_NONE;
- static GstClockTime prev_timestamp = 0;
-
- GstClock *clock;
- if (!src) {
- GST_WARNING("Invalid pointer [handle:%p]", src);
- return FALSE;
- }
- clock = gst_element_get_clock (GST_ELEMENT (src));
- if (clock) {
- timestamp = gst_clock_get_time (clock);
- if(!gst_element_get_base_time (GST_ELEMENT(src)))
- timestamp = GST_CLOCK_TIME_NONE;
- else timestamp -= gst_element_get_base_time (GST_ELEMENT (src));
- gst_object_unref (clock);
- } else {
- /* not an error not to have a clock */
- timestamp = GST_CLOCK_TIME_NONE;
- }
-
- if ((timestamp - prev_timestamp <= 30000000) || (timestamp-prev_timestamp >=36000000)) {
- /*GST_ERROR("Gap is below 30ms or over 36ms!!");*/
- }
-
- /* if we have a framerate adjust timestamp for frame latency */
- if ((int)((float)src->rate_numerator / (float)src->rate_denominator) <= 0) {
- /*if fps is zero, auto fps mode*/
- fps_nu = 0;
- fps_de = 1;
- } else {
- fps_nu = 1;
- fps_de = (int)((float)src->rate_numerator / (float)src->rate_denominator);
- }
- if (fps_nu > 0 && fps_de > 0) {
- GstClockTime latency;
- latency = gst_util_uint64_scale_int(GST_SECOND, fps_nu, fps_de);
- duration = latency;
- }
- //timestamp+=src->initial_audio_latency;
- *time = timestamp;
- *dur = duration;
- prev_timestamp = timestamp;
- return TRUE;
-}
-
-#ifdef COUNT_FRAMES
-static int fps = 0;
-
-static gchar *
-get_current_system_time ()
-{
- gchar target[10] = { 0, };
- time_t t;
- struct tm tm;
-
- t = time (NULL);
- tzset ();
- /*localtimer_r : available since libc 5.2.5 */
- if (localtime_r (&t, &tm) == NULL) {
- return NULL;
- }
- snprintf (target, sizeof (target), "%02i:%02i:%02i", tm.tm_hour, tm.tm_min,
- tm.tm_sec);
- return g_strdup (target);
-}
-#endif
-
-#define XVIMAGESRC_SLEEP(msec) \
-do { \
- if(msec) { \
- unsigned long sec_t = 0; \
- unsigned long nsec_t = 0; \
- unsigned long cal_time = msec * 1000000; \
- sec_t = cal_time / 1000000000; \
- nsec_t = cal_time % 1000000000; \
- struct timespec reqtime; \
- reqtime.tv_sec = sec_t; \
- reqtime.tv_nsec = nsec_t; \
- nanosleep(&reqtime, NULL); \
- } \
-} while (0)
-
-static void
-gst_xv_get_image_sleep (void *asrc, long duration)
-{
- GST_INFO ("end_time duration=%ld", duration);
- if (duration < 0)
- return;
-
- GstXVImageSrc *src = (GstXVImageSrc *) asrc;
- g_return_if_fail (src != NULL);
-
- long sleep_time = 0;
- sleep_time = src->sleep_base_time - duration;
-
- if (sleep_time < 0) {
- src->get_image_overtime_cnt++;
- src->get_image_overtime += sleep_time;
-
- if (src->get_image_overtime_cnt > 2)
- src->get_image_overtime = 0;
-
- if (src->get_image_overtime <= src->sleep_limit_time)
- src->get_image_overtime = 0;
- } else if (sleep_time > 0) {
- src->get_image_overtime_cnt = 0;
- sleep_time = sleep_time + src->get_image_overtime;
- src->get_image_overtime = (sleep_time < 0) ? sleep_time : 0;
-
- if (sleep_time > 0) {
- GST_INFO ("end_time : sleep_time = %ld", sleep_time);
- sleep_time = sleep_time / 1000;
- XVIMAGESRC_SLEEP (sleep_time);
- }
- }
-}
-
-static GstFlowReturn
-gst_xv_image_src_create (GstPushSrc * psrc, GstBuffer ** buffer)
-{
- GstXVImageSrc *src;
- GstXvImageOutBuffer *outbuf = NULL;
-
- src = GST_XV_IMAGE_SRC (psrc);
- g_mutex_lock (&src->queue_lock);
-
- if (g_queue_is_empty (src->queue)) {
- g_mutex_unlock (&src->queue_lock);
- g_mutex_lock (&src->cond_lock);
- g_cond_wait (&src->queue_cond, &src->cond_lock);
- g_mutex_unlock (&src->cond_lock);
-
- g_mutex_lock (&src->queue_lock);
- outbuf = (GstXvImageOutBuffer *) g_queue_pop_head (src->queue);
- g_mutex_unlock (&src->queue_lock);
- } else {
- GstXvImageOutBuffer *tempbuf = NULL;
- while ((tempbuf =
- (GstXvImageOutBuffer *) g_queue_pop_head (src->queue)) != NULL) {
- /* To reduce latency, skipping the old frames and submitting only latest frames */
- outbuf = tempbuf;
- }
- g_mutex_unlock (&src->queue_lock);
- }
-
- if (outbuf == NULL)
- return GST_FLOW_ERROR;
-
- GST_INFO_OBJECT (src, "gem_name=%d, fd_name=%d, Time stamp of the buffer is %"
- GST_TIME_FORMAT, outbuf->YBuf, outbuf->fd_name,
- GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (outbuf->buffer)));
-
- *buffer = outbuf->buffer;
-
-#ifdef COUNT_FRAMES
- gchar *current_time = NULL;
- current_time = get_current_system_time ();
- if (strncmp (current_time, old_time, 10) == 0) {
- fps++;
- strncpy (old_time, current_time, 10);
- } else {
- g_printf ("xvimagesrc %s - fps : %d\n", old_time, fps);
- fps = 1;
- strncpy (old_time, current_time, 10);
- }
-#endif
-
- return GST_FLOW_OK;
-}
-
-static gboolean
-xvimagesrc_thread_start (GstXVImageSrc * src)
-{
- GError *error;
- if (!src->updates_thread) {
- src->updates_thread =
- g_thread_new ("xvimagecapture", (GThreadFunc) gst_xv_image_src_update_thread, src);
-#if 0
- g_thread_create ((GThreadFunc) gst_xv_image_src_update_thread, src,
- TRUE, &error);
-#endif
-
- GST_WARNING_OBJECT (src, "image capture thread start");
- } else {
- GST_LOG_OBJECT (src, "The thread function already running");
- }
-
- return TRUE;
-}
-
-static gboolean
-gst_xv_image_src_start (GstBaseSrc * bsrc)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- if (src->format_id)
- xvimagesrc_thread_start (src);
- return TRUE;
-}
-
-gboolean
-signal_emit_func (void *asrc)
-{
- GstXVImageSrc *src = (GstXVImageSrc *) asrc;
- if (src->current_data_type == VIDEO_TYPE_VIDEO_ONLY) {
- g_signal_emit (src, gst_xv_image_src_signals[SIGNAL_VIDEO_ONLY], 0, NULL);
- } else if (src->current_data_type == VIDEO_TYPE_VIDEO_WITH_UI) {
- g_signal_emit (src, gst_xv_image_src_signals[SIGNAL_VIDEO_WITH_UI], 0,
- NULL);
- }
- return FALSE;
-}
-
-static gboolean
-signal_selection_emit_func (void *asrc)
-{
- GstXVImageSrc *src = (GstXVImageSrc *) asrc;
-
- g_signal_emit (src, gst_xv_image_src_signals[SIGNAL_SELECTION_NOTIFY], 0,
- NULL);
-
- return FALSE;
-}
-
-static int
-gst_xvimagesrc_handle_xerror (Display * display, XErrorEvent * xevent)
-{
- char error_msg[1024];
-
- XGetErrorText (display, xevent->error_code, error_msg, 1024);
- GST_DEBUG ("XError. error: %s", error_msg);
- error_caught = TRUE;
- return 0;
-}
-
-static void
-gst_xv_image_out_buffer_unref (gpointer userdata)
-{
- Atom atom_retbuf = 0;
- GstXvImageOutBuffer *buffer = userdata;
-
- tbm_bo_unref (buffer->bo[0]);
- tbm_bo_unref (buffer->bo[1]);
-
- g_mutex_lock (&buffer->xvimagesrc->dpy_lock);
- atom_retbuf =
- XInternAtom (buffer->xvimagesrc->dpy,
- "_USER_WM_PORT_ATTRIBUTE_RETURN_BUFFER", False);
-
- /* data->YBuf is gemname, refer to drm_convert_gem_to_fd */
- GST_DEBUG ("gst_xv_image_out_buffer_unref : Gem [%d]", buffer->YBuf);
- XvSetPortAttribute (buffer->xvimagesrc->dpy, buffer->xvimagesrc->p,
- atom_retbuf, buffer->YBuf);
-
- g_mutex_unlock (&buffer->xvimagesrc->dpy_lock);
- g_cond_signal (&buffer->xvimagesrc->buffer_cond);
-
-#ifdef DEBUG_BUFFER
- int i = 0;
- for (i = 0; i < 5; i++) {
- if (value[i] == buffer->YBuf) {
- value[i] = 0;
- GST_ERROR ("value[%d]=%d", i, value[i]);
- }
- }
-#endif
-
- return;
-}
-
-static void *
-gst_xv_image_src_update_thread (void *asrc)
-{
- GstXVImageSrc *src = (GstXVImageSrc *) asrc;
- Atom atom_data_type = 0;
- Atom atom_display = 0;
- Atom atom_secure = 0, atom_capture = 0;
-
- g_return_val_if_fail ((src != NULL), NULL);
-
- struct drm_gem_close gem_close;
- int i = 0;
- GEM_MMAP *xv_gem_mmap = NULL;
- xv_gem_mmap = (GEM_MMAP *) malloc (sizeof (GEM_MMAP));
- g_return_val_if_fail ((xv_gem_mmap != NULL), NULL);
-
- memset (xv_gem_mmap, 0, sizeof (GEM_MMAP));
-
- GST_LOG_OBJECT (src, "The thread function start");
- int damage_err_base = 0;
- Atom atom_format = 0;
- src->dpy = XOpenDisplay (NULL);
-
- src->p = port_get (src, src->format_id);
- if (src->p < 0)
- goto finish;
-
- /*src->width and src->height is set by caps info */
- GST_LOG_OBJECT (src, "width and height of caps : %dx%d ", src->width,
- src->height);
- if (src->width == 0 || src->height == 0) {
- GST_ERROR_OBJECT (src, "width or height is 0");
- goto finish;
- }
-
- src->pixmap = pixmap_create (src, src->dpy, src->width, src->height);
- if (src->pixmap <= 0) {
- GST_ERROR_OBJECT (src, "Failed to create pixmap");
- goto finish;
- }
-
- src->gc = XCreateGC (src->dpy, src->pixmap, 0, 0);
- if (src->gc == NULL) {
- GST_ERROR_OBJECT (src, "Failed to create GC");
- goto finish;
- }
-
- src->bufmgr = bufmgr_get (src->dpy, src->pixmap);
- if (!src->bufmgr)
- goto finish;
-
- if (!XDamageQueryExtension (src->dpy, &src->damage_base, &damage_err_base)) {
- GST_ERROR_OBJECT (src, "XDamageQueryExtension failed");
- goto finish;
- }
-
- src->damage = XDamageCreate (src->dpy, src->pixmap, XDamageReportNonEmpty);
- atom_format = XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_FORMAT", False);
- atom_capture =
- XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_CAPTURE", False);
- atom_secure = XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_SECURE", False);
- atom_display =
- XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_DISPLAY", False);
-
- XvSetPortAttribute (src->dpy, src->p, atom_format, src->format_id);
- XvSetPortAttribute (src->dpy, src->p, atom_capture, 2);
- XvSetPortAttribute (src->dpy, src->p, atom_display, 1);
-
- /*get data type */
- atom_data_type =
- XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_DATA_TYPE", False);
- XvSelectPortNotify (src->dpy, src->p, 1);
- XvGetPortAttribute (src->dpy, src->p, atom_data_type, &(src->new_data_type));
-#if 0
- /*set Xorg write-back hz */
- atom_fps = XInternAtom (src->dpy, "_USER_WM_PORT_ATTRIBUTE_FPS", False);
- GST_DEBUG ("frame rate of caps %d", src->rate_numerator);
- XvSetPortAttribute (src->dpy, src->p, atom_fps, src->rate_numerator);
- GST_DEBUG ("gst_xv_image_src_update_thread XvSetPortAttribute !!");
-#endif
-
- struct timeval start_time, end_time;
- long duration;
- long starttime, endtime;
- //GTimeVal timeout;
- guint64 timeout;
- XEvent ev;
- void *virtual_address = NULL;
- guint buf_size_Y = 0;
- guint buf_size_Cb = 0;
- int (*handler) (Display *, XErrorEvent *);
- GstXvImageOutBuffer *outbuf = NULL;
-
- gboolean pause_trigger = FALSE;
- gboolean got_display_select_req = FALSE;
-
- GstClockTime ts_putstill = 0;
- GstClockTime dur_putstill = 0;
-
- while (!src->thread_return) {
- duration = 0;
- starttime = 0;
- endtime = 0;
- start_time.tv_sec = 0;
- start_time.tv_usec = 0;
- end_time.tv_sec = 0;
- end_time.tv_usec = 0;
- gettimeofday (&start_time, NULL);
-
- virtual_address = NULL;
- duration = 0;
- outbuf = NULL;
-
- if (pause_trigger) {
- g_cond_signal (&src->queue_cond);
-
- GST_WARNING_OBJECT (src, "PAUSED in capture thread");
- g_mutex_lock (&src->pause_lock);
- g_cond_wait (&src->pause_cond, &src->pause_lock);
- g_mutex_unlock (&src->pause_lock);
- pause_trigger = FALSE;
- continue;
- }
-
- if (src->pause_cond_var) {
- pause_trigger = TRUE;
- }
-
- g_mutex_lock (&src->dpy_lock);
- XSync (src->dpy, 0);
- g_mutex_unlock (&src->dpy_lock);
- error_caught = FALSE;
- handler = XSetErrorHandler (gst_xvimagesrc_handle_xerror);
-
- g_mutex_lock (&src->dpy_lock);
- XvPutStill (src->dpy, src->p, src->pixmap, src->gc, 0, 0, src->width,
- src->height, 0, 0, src->width, src->height);
- XSync (src->dpy, 0);
- g_mutex_unlock (&src->dpy_lock);
-
- gst_xv_image_src_get_timeinfo (src, &ts_putstill, &dur_putstill);
-
- if (error_caught) {
- GST_ERROR
- ("gst_xv_image_src_update_thread error_caught is TRUE, X is out of buffers");
- error_caught = FALSE;
- XSetErrorHandler (handler);
-
- timeout = g_get_monotonic_time () + BUFFER_COND_WAIT_TIMEOUT;
-
- g_mutex_lock (&src->buffer_cond_lock);
- if (!g_cond_wait_until (&src->buffer_cond, &src->buffer_cond_lock, timeout)) {
- GST_ERROR ("skip wating");
- } else {
- GST_ERROR ("Signal received");
- }
- g_mutex_unlock (&src->buffer_cond_lock);
- continue;
- }
-
- /*reset error handler */
- error_caught = FALSE;
- XSetErrorHandler (handler);
-
- next_event:
- g_mutex_lock (&src->dpy_lock);
- XNextEvent (src->dpy, &ev); /* wating for x event */
- g_mutex_unlock (&src->dpy_lock);
-
- if (ev.type == (src->damage_base + XDamageNotify)) {
- XDamageNotifyEvent *damage_ev = (XDamageNotifyEvent *) & ev;
- GST_INFO ("gst_xv_image_src_update_thread XDamageNotifyEvent");
-
- g_mutex_lock (&src->dpy_lock);
- if (damage_ev->drawable == src->pixmap) {
- pixmap_update (src, src->dpy, src->bufmgr, src->pixmap,
- damage_ev->area.x,
- damage_ev->area.y, damage_ev->area.width, damage_ev->area.height);
- GST_INFO ("gst_xv_image_src_update_thread pixmap_update");
- }
-
- XDamageSubtract (src->dpy, src->damage, None, None);
- g_mutex_unlock (&src->dpy_lock);
- } else if (ev.type == SelectionClear) {
- /* Added to handle display selection notify */
- //XSelectionEvent *selection_ev = (XSelectionEvent *) & ev;
-
- GST_ERROR ("ev.type : %d SelectionClear", ev.type);
- //g_timeout_add(1, signal_selection_emit_func, src);
- } else if (ev.type == SelectionRequest) {
- XSelectionRequestEvent *selection_ev = (XSelectionRequestEvent *) & ev;
-
- GST_ERROR ("ev.type : %d SelectionRequest", ev.type);
- src->requestor = selection_ev->requestor;
- src->selection = selection_ev->selection;
- src->target = selection_ev->target;
- src->property = selection_ev->property;
-
- got_display_select_req = TRUE;
- g_timeout_add (1, signal_selection_emit_func, src);
- } else if (ev.type == SelectionNotify) {
- //XSelectionEvent *selection_ev = (XSelectionEvent *) & ev;
-
- GST_ERROR ("ev.type : %d SelectionNotify", ev.type);
- //g_timeout_add(1, signal_selection_emit_func, src);
- } else if (ev.type == (src->evt_base + XvPortNotify)) {
- XvPortNotifyEvent *notify_ev = (XvPortNotifyEvent *) & ev;
-
- if (notify_ev->attribute == atom_secure) {
- GST_WARNING ("secure attr changed : %s \n",
- ((int) notify_ev->value) ? "Secure" : "Normal");
- src->tz_enable = (int) notify_ev->value;
- GST_WARNING ("src->tz_enable = %d", src->tz_enable);
- } else if (notify_ev->attribute == atom_data_type) {
- /* got a port notify, data_type */
- src->new_data_type = (int) notify_ev->value;
- if (src->current_data_type != src->new_data_type) {
- src->current_data_type = src->new_data_type;
- GST_WARNING ("current_data_type : %s \n",
- (src->current_data_type) ? "Video" : "UI+Video");
- g_timeout_add (1, signal_emit_func, src);
- }
- }
- goto next_event;
- }
-
- if (!src->virtual)
- continue;
- if (src->format_id == FOURCC_RGB32) {
- outbuf = (GstXvImageOutBuffer *) malloc (sizeof (GstXvImageOutBuffer));
- outbuf->buffer = gst_buffer_new_wrapped_full (GST_MEMORY_FLAG_READONLY,
- src->virtual, src->framesize, 0, src->framesize, NULL, NULL);
-#if 0
- void *tmp_data = NULL;
- tmp_data = (void *)malloc(buf_size_Y+buf_size_Cb);
- memset (tmp_data, 0x00, buf_size_Y+buf_size_Cb);
-
- memcpy (tmp_data, mm_video_buf->data[0], buf_size_Y);
- memcpy (tmp_data+buf_size_Y, mm_video_buf->data[1], buf_size_Cb);
-
- outbuf->buffer = gst_buffer_new_wrapped_full (GST_MEMORY_FLAG_READONLY,
- tmp_data, buf_size_Y+buf_size_Cb, 0, buf_size_Y+buf_size_Cb, (gpointer) outbuf,
- gst_xv_image_out_buffer_unref);
-
- free (tmp_data);
-/*
- GstBuffer *new_buf = NULL;
- new_buf = gst_buffer_new_and_alloc (buf_size_Y+buf_size_Cb);
- gst_buffer_set_size (new_buf, buf_size_Y+buf_size_Cb);
-
- GstMapInfo map;
- gst_buffer_map (new_buf, &map, GST_MAP_READ);
- memcpy (map.data, mm_video_buf->data[0], buf_size_Y);
- memcpy (map.data+buf_size_Y, mm_video_buf->data[1], buf_size_Cb);
-
- outbuf->buffer = gst_buffer_new_wrapped_full (GST_MEMORY_FLAG_READONLY,
- map.data, buf_size_Y+buf_size_Cb, 0, buf_size_Y+buf_size_Cb, (gpointer) outbuf,
- gst_xv_image_out_buffer_unref);
-
- gst_buffer_unmap (new_buf, &map);
- gst_buffer_unref (new_buf);
-*/
-
-#endif
- } else if (src->format_id == FOURCC_SN12) {
- XV_DATA_PTR data = (XV_DATA_PTR) src->virtual;
- int error = XV_VALIDATE_DATA (data);
-
- if (error == XV_HEADER_ERROR)
- GST_ERROR ("XV_HEADER_ERROR\n");
- else if (error == XV_VERSION_MISMATCH)
- GST_ERROR ("XV_VERSION_MISMATCH\n");
- else {
- MMVideoBuffer *mm_video_buf = NULL;
- mm_video_buf = (MMVideoBuffer *) malloc (sizeof (MMVideoBuffer));
- if (mm_video_buf == NULL) {
- GST_ERROR_OBJECT (src, "failed to alloc MMVideoBuffer");
- continue;
- }
-
- outbuf = gst_xv_image_out_buffer_new (src);
- if (!outbuf) {
- GST_ERROR ("Out of memory");
- g_free (mm_video_buf);
- continue;
- }
-
- memset (mm_video_buf, 0x00, sizeof (MMVideoBuffer));
-
- if (data->BufType == XV_BUF_TYPE_LEGACY) {
- GST_DEBUG ("XV_BUF_TYPE_LEGACY");
- mm_video_buf->handle.paddr[0] = (void *) data->YBuf;
- mm_video_buf->handle.paddr[1] = (void *) data->CbBuf;
- mm_video_buf->type = MM_VIDEO_BUFFER_TYPE_PHYSICAL_ADDRESS;
- mm_video_buf->data[0] = NULL;
- mm_video_buf->data[1] = NULL;
- } else if (data->BufType == XV_BUF_TYPE_DMABUF) {
- if (src->buf_share_method == BUF_SHARE_METHOD_FD) {
- mm_video_buf->handle.dmabuf_fd[0] =
- drm_convert_gem_to_fd (&src->gemname_cnt, src->drm_fd, data->YBuf,
- xv_gem_mmap, &virtual_address, &buf_size_Y);
- mm_video_buf->data[0] = virtual_address;
- GST_WARNING_OBJECT (src,
- "YBuf gem to dmabuf_fd[0]:%d virtual_address : %p size : %d",
- mm_video_buf->handle.dmabuf_fd[0], mm_video_buf->data[0], buf_size_Y);
-
- mm_video_buf->handle.dmabuf_fd[1] =
- drm_convert_gem_to_fd (&src->gemname_cnt, src->drm_fd,
- data->CbBuf, xv_gem_mmap, &virtual_address, &buf_size_Cb);
- mm_video_buf->data[1] = virtual_address;
- GST_WARNING_OBJECT (src,
- "CbBuf gem to dmabuf_fd[1]:%d virtual_address : %p size: %d",
- mm_video_buf->handle.dmabuf_fd[1], mm_video_buf->data[1], buf_size_Cb);
- mm_video_buf->type = MM_VIDEO_BUFFER_TYPE_DMABUF_FD;
- } else if (src->buf_share_method == BUF_SHARE_METHOD_TIZEN_BUFFER) {
- mm_video_buf->type = MM_VIDEO_BUFFER_TYPE_TBM_BO;
- mm_video_buf->handle.bo[0] = drm_convert_gem_to_bo (src->bufmgr, data->YBuf);
- mm_video_buf->handle.bo[1] = drm_convert_gem_to_bo (src->bufmgr, data->CbBuf);
- GST_WARNING_OBJECT (src, "BO : %p %p", mm_video_buf->handle.bo[0], mm_video_buf->handle.bo[1]);
-
- outbuf->bo[0] = mm_video_buf->handle.bo[0];
- outbuf->bo[1] = mm_video_buf->handle.bo[1];
- }
- }
-
- mm_video_buf->width[0] = src->width;
- mm_video_buf->height[0] = src->height;
- mm_video_buf->format = MM_PIXEL_FORMAT_NV12;
- mm_video_buf->width[1] = src->width;
- mm_video_buf->height[1] = src->height >> 1;
-
- mm_video_buf->stride_width[0] = GST_ROUND_UP_16 (mm_video_buf->width[0]);
- mm_video_buf->stride_height[0] = GST_ROUND_UP_16 (mm_video_buf->height[0]);
- mm_video_buf->stride_width[1] = GST_ROUND_UP_16 (mm_video_buf->width[1]);
- mm_video_buf->stride_height[1] = GST_ROUND_UP_16 (mm_video_buf->height[1]);
-
- mm_video_buf->is_secured = 0;
-
- outbuf->buffer = gst_buffer_new_wrapped_full (GST_MEMORY_FLAG_READONLY,
- src->virtual, src->framesize, 0, src->framesize, (gpointer) outbuf,
- gst_xv_image_out_buffer_unref);
- gst_buffer_append_memory (outbuf->buffer,
- gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY, mm_video_buf,
- sizeof (*mm_video_buf), 0, sizeof (*mm_video_buf), mm_video_buf, g_free));
-
- outbuf->YBuf = data->YBuf;
- outbuf->fd_name = mm_video_buf->handle.dmabuf_fd[0];
-
-#ifdef DEBUG_BUFFER
- for (i = 0; i < 5; i++) {
- if (value[value_count] == outbuf->YBuf) {
- GST_ERROR ("ERROR: value[%d](%d)==YBUf(%d)", value_count,
- value[value_count], outbuf->YBuf);
- }
- }
- value[value_count] = outbuf->YBuf;
- GST_ERROR ("value[%d]=%d", value_count, value[value_count]);
- if (value_count < 4) {
- value_count++;
- } else {
- value_count = 0;
- }
-#endif
-
-#ifdef _MAKE_DUMP
- if (f_idx < 100) {
- if (src->running_time > 14000000000
- && src->running_time < 20000000000) {
- GST_ERROR ("Mem copy");
- if (virtual_address == NULL) {
- GST_ERROR ("Mem virtual is NULL[%d]", f_idx);
- } else {
- //memcpy(g_dump_frame[f_idx++], mm_video_buf->data[0], YUV_720_FRAME_SIZE);
- //memcpy(g_dump_frame[f_idx++], virtual_address, YUV_VGA_FRAME_SIZE);
- memcpy (g_dump_frame[f_idx], mm_video_buf->data[0], 921600);
- memcpy (g_dump_frame1[f_idx], mm_video_buf->data[1], 462848);
- f_idx++;
- GST_ERROR ("Mem copy done[%d]", f_idx);
- }
- }
- } else {
- if (f_done == 0) {
- GST_ERROR ("File DUMP!!");
- FILE *fp = NULL;
- fp = fopen ("/root/frame.yuv", "a");
- int i = 0;
- for (i = 0; i < 100; i++) {
- fwrite (g_dump_frame[i], 921600, 1, fp);
- fwrite (g_dump_frame1[i], 462848, 1, fp);
- //fwrite(g_dump_frame[i], 1384448, 1, fp);
- //fwrite(g_dump_frame[i], YUV_720_FRAME_SIZE, 1, fp);
- //fwrite(g_dump_frame[i], YUV_VGA_FRAME_SIZE, 1, fp);
- }
- fclose (fp);
- f_done = 1;
- GST_ERROR ("File DUMP done!!");
- }
- }
-#endif
- }
- }
-
- if (!outbuf)
- continue;
-
- GST_BUFFER_TIMESTAMP (outbuf->buffer) = ts_putstill;
- GST_BUFFER_DURATION (outbuf->buffer) = dur_putstill;
- src->running_time = GST_BUFFER_TIMESTAMP (outbuf->buffer);
- src->frame_duration = GST_BUFFER_DURATION (outbuf->buffer);
- g_mutex_lock (&src->queue_lock);
- g_queue_push_tail (src->queue, outbuf);
- GST_INFO ("g_queue_push_tail");
- g_mutex_unlock (&src->queue_lock);
- g_cond_signal (&src->queue_cond);
- GST_INFO ("g_cond_signal");
-
- if (src->virtual)
- tbm_bo_unmap (src->bo);
- src->virtual = NULL;
-
- if (src->bo)
- tbm_bo_unref (src->bo);
- src->bo = NULL;
-
- if (src->dri2_buffers)
- free (src->dri2_buffers);
-
- src->dri2_buffers = NULL;
-
- gettimeofday (&end_time, NULL);
- starttime = start_time.tv_usec;
- endtime = end_time.tv_usec;
- GST_INFO ("star_time: %ld, end_time:%ld", starttime, endtime);
-
- if (endtime > starttime) {
- GST_INFO ("end_time > start_time");
- duration = endtime - starttime;
- } else {
- GST_INFO ("end_time.tv_usec < start_time.tv_usec");
- endtime = endtime + 1000000;
- GST_INFO ("end_time =%ld", endtime);
- duration = endtime - starttime;
- }
- GST_INFO ("end_time duration = %ld", duration);
-
- if (src->sleep_base_time > duration)
- gst_xv_get_image_sleep (src, duration);
- }
-
- for (i = 0; i < GEM_NAME_MAX; i++) {
- /*gem munmap */
- if (xv_gem_mmap->address[i]) {
- if (-1 == munmap (xv_gem_mmap->address[i], xv_gem_mmap->buffer_size[i])) {
- GST_ERROR ("munmap failed");
- return NULL;
- }
- }
- /*fd close */
- if (xv_gem_mmap->handle[i]) {
- gem_close.handle = xv_gem_mmap->handle[i];
- if (ioctl (src->drm_fd, DRM_IOCTL_GEM_CLOSE, &gem_close)) {
- GST_ERROR ("Gem Close failed");
- }
- }
-
- if (xv_gem_mmap->fd[i]) {
- close (xv_gem_mmap->fd[i]);
- }
- }
-
- if (xv_gem_mmap) {
- free (xv_gem_mmap);
- xv_gem_mmap = NULL;
- }
-
-
- GST_LOG_OBJECT (src, "The thread function cleanup");
-
- XvStopVideo (src->dpy, src->p, src->pixmap);
-
- if (src->bufmgr) {
- tbm_bufmgr_deinit (src->bufmgr);
- src->bufmgr = NULL;
- }
-
- if (src->p > 0) {
- XvUngrabPort (src->dpy, src->p, 0);
- src->p = 0;
- }
-
- if (got_display_select_req) {
- /* Notify miracast-destroyed to X */
- GST_WARNING_OBJECT (src, "There is display selection request");
- XEvent xev;
- XSelectionEvent xnotify;
-
- xnotify.type = SelectionNotify;
- xnotify.display = src->dpy;
- xnotify.requestor = src->requestor;
- xnotify.selection = src->selection;
- xnotify.target = src->target;
- xnotify.property = src->property;
- xnotify.time = 0;
- xnotify.send_event = True;
- xnotify.serial = 0;
- xev.xselection = xnotify;
- if (XSendEvent (src->dpy, src->requestor, False, 0, &xev) < 0) {
- GST_ERROR ("XSendEvent failed!");
- } else {
- GST_INFO ("XSendEvent success!");
- }
- }
-
- if (src->gc) {
- XFreeGC (src->dpy, src->gc);
- src->gc = NULL;
- }
-
- if (src->pixmap > 0) {
- XFreePixmap (src->dpy, src->pixmap);
- src->pixmap = 0;
- }
-
- if (src->dpy) {
- XCloseDisplay (src->dpy);
- src->dpy = NULL;
- }
-
- GST_LOG_OBJECT (src, "The thread function stop");
- return NULL;
-finish:
- GST_LOG_OBJECT (src, "The thread function Error cleanup");
-
- XvStopVideo (src->dpy, src->p, src->pixmap);
-
- if (src->bufmgr)
- tbm_bufmgr_deinit (src->bufmgr);
- src->bufmgr = NULL;
- if (src->p > 0)
- XvUngrabPort (src->dpy, src->p, 0);
- src->p = 0;
- if (src->gc)
- XFreeGC (src->dpy, src->gc);
- src->gc = NULL;
- if (src->pixmap > 0)
- XFreePixmap (src->dpy, src->pixmap);
- src->pixmap = 0;
- if (src->dpy)
- XCloseDisplay (src->dpy);
- src->dpy = NULL;
-
- GST_LOG_OBJECT (src, "The thread function Error stop");
- return NULL;
-}
-
-static tbm_bufmgr
-bufmgr_get (Display * dpy, Pixmap pixmap)
-{
- int screen;
- int drm_fd;
- tbm_bufmgr bufmgr;
- int eventBase, errorBase;
- int dri2Major, dri2Minor;
- char *driverName, *deviceName;
- drm_magic_t magic;
-
- screen = DefaultScreen (dpy);
- if (!DRI2QueryExtension (dpy, &eventBase, &errorBase)) {
- GST_ERROR ("!!Error : DRI2QueryExtension !!");
- return NULL;
- }
-
- if (!DRI2QueryVersion (dpy, &dri2Major, &dri2Minor)) {
- GST_ERROR ("!!Error : DRI2QueryVersion !!");
- return NULL;
- }
-
- if (!DRI2Connect (dpy, RootWindow (dpy, screen), &driverName, &deviceName)) {
- GST_ERROR ("!!Error : DRI2Connect !!");
- if (driverName)
- Xfree (driverName);
- if (deviceName)
- Xfree (deviceName);
- return NULL;
- }
-
- if (driverName)
- Xfree (driverName);
-
- if (!deviceName) return NULL;
-
- GST_DEBUG ("Open drm device : %s", deviceName);
-
- // get the drm_fd though opening the deviceName
- drm_fd = open (deviceName, O_RDWR);
- if (drm_fd < 0) {
- GST_ERROR ("!!Error : cannot open drm device (%s)", deviceName);
- if (deviceName)
- Xfree (deviceName);
- return NULL;
- }
-
- if (deviceName)
- Xfree (deviceName);
-
- struct drm_exynos_vidi_connection vidi;
-
- vidi.connection = 1;
- vidi.extensions = 1;
- vidi.edid = (uint64_t *)fake_edid_info;
-
- ioctl (drm_fd, DRM_IOCTL_EXYNOS_VIDI_CONNECTION, &vidi);
-
- /* get the drm magic */
- drmGetMagic (drm_fd, &magic);
- fprintf (stderr, ">>> drm magic=%d \n", magic);
- if (!DRI2Authenticate (dpy, RootWindow (dpy, screen), magic)) {
- fprintf (stderr, "!!Error : DRI2Authenticate !!\n");
- close (drm_fd);
- return NULL;
- }
-
- // drm slp buffer manager init
- bufmgr = tbm_bufmgr_init (drm_fd);
- if (!bufmgr) {
- GST_ERROR ("Error : fail to init buffer manager ");
- close (drm_fd);
- return NULL;
- }
-
- DRI2CreateDrawable (dpy, pixmap);
- return bufmgr;
-}
-
-static int
-port_get (GstXVImageSrc * src, unsigned int id)
-{
- unsigned int ver, rev, req_base, err_base;
- unsigned int adaptors;
- XvAdaptorInfo *ai = NULL;
- XvAttribute *at = NULL;
- XvImageFormatValues *fo = NULL;
- int attributes, formats;
- int i, j, p;
-
- if (XvQueryExtension (src->dpy, &ver, &rev, &req_base, &src->evt_base,
- &err_base) != Success)
- return -1;
-
- if (XvQueryAdaptors (src->dpy, DefaultRootWindow (src->dpy), &adaptors,
- &ai) != Success)
- return -1;
-
- if (!ai)
- return -1;
-
- for (i = 0; i < adaptors; i++) {
- int support_format = False;
- if (!(ai[i].type & XvInputMask) || !(ai[i].type & XvStillMask))
- continue;
-
- GST_LOG ("===========================================");
- GST_LOG (" name: %s"
- " first port: %ld"
- " ports: %ld", ai[i].name, ai[i].base_id, ai[i].num_ports);
- p = ai[i].base_id;
- GST_LOG (" attribute list:");
- at = XvQueryPortAttributes (src->dpy, p, &attributes);
- for (j = 0; j < attributes; j++)
- GST_LOG ("\t- name: %s\n"
- "\t\t flags: %s%s\n"
- "\t\t min_value: %i\n"
- "\t\t max_value: %i\n",
- at[j].name,
- (at[j].flags & XvGettable) ? " get" : "",
- (at[j].flags & XvSettable) ? " set" : "",
- at[j].min_value, at[j].max_value);
-
- if (at)
- XFree (at);
-
- GST_LOG (" image format list:");
- fo = XvListImageFormats (src->dpy, p, &formats);
- for (j = 0; j < formats; j++) {
- GST_LOG ("\t- 0x%x (%4.4s) %s", fo[j].id, (char *) &fo[j].id,
- (fo[j].format == XvPacked) ? "packed" : "planar");
- if (fo[j].id == (int) id)
- support_format = True;
- }
-
- if (fo)
- XFree (fo);
- if (!support_format)
- continue;
-
- for (; p < ai[i].base_id + ai[i].num_ports; p++) {
- if (XvGrabPort (src->dpy, p, 0) == Success) {
- GST_LOG ("========================================");
- GST_DEBUG ("XvGrabPort success : %d", p);
- GST_LOG ("========================================");
- XvFreeAdaptorInfo (ai);
- return p;
- }
- }
- }
-
- GST_ERROR_OBJECT (src, "XvGrabPort failed");
- XvFreeAdaptorInfo (ai);
- return -1;
-}
-
-static void
-pixmap_update (GstXVImageSrc * src, Display * dpy, tbm_bufmgr bufmgr,
- Pixmap pixmap, int x, int y, int width, int height)
-{
- unsigned int attachments[1];
- int dri2_count, dri2_out_count;
- int dri2_width, dri2_height, dri2_stride;
- int opt;
- tbm_bo_handle temp_virtual;
-
- attachments[0] = DRI2BufferFrontLeft;
- dri2_count = 1;
- src->dri2_buffers =
- DRI2GetBuffers (dpy, pixmap, &dri2_width, &dri2_height, attachments,
- dri2_count, &dri2_out_count);
-
- if (!src->dri2_buffers) {
- GST_ERROR ("[Error] : fail to get buffers");
- goto update_done;
- }
-
- if (!src->dri2_buffers[0].name) {
- GST_ERROR ("[Error] : a handle of the dri2 buffer is null ");
- goto update_done;
- }
-
- src->bo = tbm_bo_import (bufmgr, src->dri2_buffers[0].name);
- if (!src->bo) {
- GST_ERROR ("[Error] : cannot import bo (key:%d)",
- src->dri2_buffers[0].name);
- goto update_done;
- }
-
- dri2_stride = src->dri2_buffers[0].pitch;
- opt = TBM_OPTION_READ | TBM_OPTION_WRITE;
-
- temp_virtual = tbm_bo_map (src->bo, TBM_DEVICE_CPU, opt);
- src->virtual = temp_virtual.ptr;
- if (!src->virtual) {
- GST_ERROR ("[Error] : fail to map ");
- goto update_done;
- }
-
- return;
-update_done:
- if (src->virtual)
- tbm_bo_unmap (src->bo);
- src->virtual = NULL;
-
- if (src->bo)
- tbm_bo_unref (src->bo);
- src->bo = NULL;
-
- if (src->dri2_buffers)
- free (src->dri2_buffers);
- src->dri2_buffers = NULL;
-
- return;
-}
-
-static Pixmap
-pixmap_create (GstXVImageSrc * src, Display * dpy, int width, int height)
-{
- Pixmap pixmap = 0;
-
- pixmap = XCreatePixmap (dpy, DefaultRootWindow (dpy), width, height,
- DefaultDepth (dpy, DefaultScreen (dpy)));
- if (pixmap <= 0) {
- GST_ERROR_OBJECT (src, "Failed to create pixmap");
- return 0;
- }
-
- src->gc = XCreateGC (dpy, pixmap, 0, 0);
- if (src->gc == NULL) {
- GST_ERROR_OBJECT (src, "Failed to create GC");
- XFreePixmap (dpy, pixmap);
- return 0;
- }
-
- XSetForeground (dpy, src->gc, 0xFFFF0000);
- XFillRectangle (dpy, pixmap, src->gc, 0, 0, width, height);
- XSync (dpy, 0);
- XFreeGC (dpy, src->gc);
-
- return pixmap;
-}
-
-static gboolean
-gst_xv_image_src_stop (GstBaseSrc * bsrc)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- GST_DEBUG_OBJECT (src, "stop()");
-
- if (src->updates_thread) {
- src->thread_return = TRUE;
- g_thread_join (src->updates_thread);
- src->updates_thread = NULL;
- }
- GST_DEBUG_OBJECT (src, "stop end ");
- return TRUE;
-}
-
-/* Interrupt a blocking request. */
-static gboolean
-gst_xv_image_src_unlock (GstBaseSrc * bsrc)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- GST_DEBUG_OBJECT (src, "unlock()");
- return TRUE;
-}
-
-/* Interrupt interrupt. */
-static gboolean
-gst_xv_image_src_unlock_stop (GstBaseSrc * bsrc)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- GST_DEBUG_OBJECT (src, "unlock_stop()");
- return TRUE;
-}
-
-static gboolean
-gst_xv_image_src_get_size (GstBaseSrc * bsrc, guint64 * size)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- GST_INFO ("Get size %p", src);
- return FALSE;
-}
-
-static gboolean
-gst_xv_image_src_is_seekable (GstBaseSrc * bsrc)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- GST_INFO_OBJECT (src, "Is seekable");
- return FALSE;
-}
-
-static gboolean
-gst_xv_image_src_query (GstBaseSrc * bsrc, GstQuery * query)
-{
- GstXVImageSrc *src = GST_XV_IMAGE_SRC (bsrc);
- gboolean ret;
-
- switch (GST_QUERY_TYPE (query)) {
- default:
- GST_INFO_OBJECT (src, "Default");
- break;
- }
-
- ret = GST_BASE_SRC_CLASS (parent_class)->query (bsrc, query);
-
- return ret;
-}
-
-static gboolean
-plugin_init (GstPlugin * plugin)
-{
- GST_DEBUG_CATEGORY_INIT (xvimagesrc_debug, "xvimagesrc", 0,
- "XServer display FB video capture Source");
- return gst_element_register (plugin, "xvimagesrc", GST_RANK_PRIMARY,
- GST_TYPE_XV_IMAGE_SRC);
-}
-
-GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
- GST_VERSION_MINOR,
- xvimage,
- "XServer display video src",
- plugin_init, VERSION, "LGPL", "Samsung Electronics Co",
- "http://www.samsung.com")
projects / platform / upstream / gst-plugins-tizen.git / commitdiff