query_handlers.c

/*
 *			GPAC - Multimedia Framework C SDK
 *
 *			Authors: Deniz Ugur, Romain Bouqueau, Sohaib Larbi
 *			Copyright (c) Motion Spell
 *				All rights reserved
 *
 *  This file is part of the GPAC/GStreamer wrapper
 *
 *  This GPAC/GStreamer wrapper is free software; you can redistribute it
 *  and/or modify it under the terms of the GNU Affero General Public License
 *  as published by the Free Software Foundation; either version 3, or (at
 *  your option) any later version.
 *
 *  This GPAC/GStreamer wrapper 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 Affero General Public License for more details.
 *
 *  You should have received a copy of the GNU Affero General Public
 *  License along with this library; see the file LICENSE.  If not, write to
 *  the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 */

#include "common.h"
#include "gpacmessages.h"
#include "lib/pid.h"

#define QUERY_HANDLER_SIGNATURE(prop_nickname)                    \
  gboolean prop_nickname##_query_handler(GPAC_PID_PROP_IMPL_ARGS)

#define DEFAULT_HANDLER(prop_nickname)                            \
  gboolean prop_nickname##_query_handler(GPAC_PID_PROP_IMPL_ARGS) \
  {                                                               \
    return FALSE;                                                 \
  }

//
// Default Query handlers
//

//
// Query handlers
//
QUERY_HANDLER_SIGNATURE(duration)
{
  const GF_PropertyValue* p;

  // For text streams, we do not set duration
  p = gf_filter_pid_get_property(pid, GF_PROP_PID_STREAM_TYPE);
  if (p && p->value.uint == GF_STREAM_TEXT)
    return TRUE;

  // Query the duration
  g_autoptr(GstQuery) query = gst_query_new_duration(GST_FORMAT_TIME);
  gboolean ret = gst_pad_peer_query(priv->self, query);
  if (!ret) {
      GST_WARNING("No segment event and duration query failed, "
                  "skipping duration property (possibly live source)");
      return TRUE; // not an error, just skip setting duration
  }
  
  // Parse the duration
  gint64 duration;
  gst_query_parse_duration(query, NULL, &duration);

  // Get the fps from the PID
  GF_Fraction fps = { 30, 1 };
  p = gf_filter_pid_get_property(pid, GF_PROP_PID_FPS);
  if (p)
    fps = p->value.frac;

  // Get the timescale from the PID
  guint64 timescale = GST_SECOND;
  p = gf_filter_pid_get_property(pid, GF_PROP_PID_TIMESCALE);
  if (p)
    timescale = p->value.uint;

  // Construct the duration
  GF_Fraction64 duration_fr = {
    .num = (s64)gpac_time_rescale_with_fps(duration, fps, timescale),
    .den = timescale,
  };

  // Set the duration
  SET_PROP(GF_PROP_PID_DURATION, PROP_FRAC64(duration_fr));
  return TRUE;
}