gst/debugutils/gstnavseek.c

   1 /* GStreamer
   2  * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
   3  * Copyright (C) <2003> David Schleef <ds@schleef.org>
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Library General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Library General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Library General Public
  16  * License along with this library; if not, write to the
  17  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18  * Boston, MA 02111-1307, USA.
  19  */
  20
  21 /*
  22  * This file was (probably) generated from gstnavseek.c,
  23  * gstnavseek.c,v 1.7 2003/11/08 02:48:59 dschleef Exp
  24  */
  25
  26 #ifdef HAVE_CONFIG_H
  27 #include "config.h"
  28 #endif
  29
  30 #include "gstnavseek.h"
  31 #include <string.h>
  32 #include <math.h>
  33
  34 enum
  35 {
  36   ARG_0,
  37   ARG_SEEKOFFSET
  38 };
  39
  40 GstStaticPadTemplate navseek_src_template = GST_STATIC_PAD_TEMPLATE ("src",
  41     GST_PAD_SRC,
  42     GST_PAD_ALWAYS,
  43     GST_STATIC_CAPS_ANY);
  44
  45 GstStaticPadTemplate navseek_sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
  46     GST_PAD_SINK,
  47     GST_PAD_ALWAYS,
  48     GST_STATIC_CAPS_ANY);
  49
  50 static gboolean gst_navseek_sink_event (GstBaseTransform * trans,
  51     GstEvent * event);
  52 static GstFlowReturn gst_navseek_transform_ip (GstBaseTransform * basetrans,
  53     GstBuffer * buf);
  54 static gboolean gst_navseek_src_event (GstBaseTransform * trans,
  55     GstEvent * event);
  56 static gboolean gst_navseek_stop (GstBaseTransform * trans);
  57 static gboolean gst_navseek_start (GstBaseTransform * trans);
  58
  59 static void gst_navseek_set_property (GObject * object, guint prop_id,
  60     const GValue * value, GParamSpec * pspec);
  61 static void gst_navseek_get_property (GObject * object, guint prop_id,
  62     GValue * value, GParamSpec * pspec);
  63
  64 GType gst_navseek_get_type (void);
  65 #define gst_navseek_parent_class parent_class
  66 G_DEFINE_TYPE (GstNavSeek, gst_navseek, GST_TYPE_BASE_TRANSFORM);
  67
  68 static void
  69 gst_navseek_class_init (GstNavSeekClass * klass)
  70 {
  71   GstBaseTransformClass *gstbasetrans_class;
  72   GstElementClass *element_class;
  73   GObjectClass *gobject_class;
  74
  75   gobject_class = G_OBJECT_CLASS (klass);
  76   element_class = GST_ELEMENT_CLASS (klass);
  77   gstbasetrans_class = GST_BASE_TRANSFORM_CLASS (klass);
  78
  79   gobject_class->set_property = gst_navseek_set_property;
  80   gobject_class->get_property = gst_navseek_get_property;
  81
  82   g_object_class_install_property (gobject_class,
  83       ARG_SEEKOFFSET, g_param_spec_double ("seek-offset", "Seek Offset",
  84           "Time in seconds to seek by", 0.0, G_MAXDOUBLE, 5.0,
  85           G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
  86
  87   gst_element_class_add_pad_template (element_class,
  88       gst_static_pad_template_get (&navseek_sink_template));
  89   gst_element_class_add_pad_template (element_class,
  90       gst_static_pad_template_get (&navseek_src_template));
  91
  92   gst_element_class_set_static_metadata (element_class,
  93       "Seek based on left-right arrows", "Filter/Video",
  94       "Seek based on navigation keys left-right",
  95       "Jan Schmidt <thaytan@mad.scientist.com>");
  96
  97   gstbasetrans_class->src_event = GST_DEBUG_FUNCPTR (gst_navseek_src_event);
  98   gstbasetrans_class->sink_event = GST_DEBUG_FUNCPTR (gst_navseek_sink_event);
  99   gstbasetrans_class->transform_ip =
 100       GST_DEBUG_FUNCPTR (gst_navseek_transform_ip);
 101   gstbasetrans_class->start = GST_DEBUG_FUNCPTR (gst_navseek_start);
 102   gstbasetrans_class->stop = GST_DEBUG_FUNCPTR (gst_navseek_stop);
 103 }
 104
 105 static void
 106 gst_navseek_init (GstNavSeek * navseek)
 107 {
 108   gst_base_transform_set_passthrough (GST_BASE_TRANSFORM (navseek), TRUE);
 109
 110   navseek->seek_offset = 5.0;
 111   navseek->loop = FALSE;
 112   navseek->grab_seg_start = FALSE;
 113   navseek->grab_seg_end = FALSE;
 114   navseek->segment_start = GST_CLOCK_TIME_NONE;
 115   navseek->segment_end = GST_CLOCK_TIME_NONE;
 116 }
 117
 118 static void
 119 gst_navseek_seek (GstNavSeek * navseek, gint64 offset)
 120 {
 121   gboolean ret;
 122   GstPad *peer_pad;
 123   gint64 peer_value;
 124
 125   /* Query for the current time then attempt to set to time + offset */
 126   peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
 127   ret = gst_pad_query_position (peer_pad, GST_FORMAT_TIME, &peer_value);
 128
 129   if (ret) {
 130     GstEvent *event;
 131
 132     peer_value += offset;
 133     if (peer_value < 0)
 134       peer_value = 0;
 135
 136     event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
 137         GST_SEEK_FLAG_ACCURATE | GST_SEEK_FLAG_FLUSH,
 138         GST_SEEK_TYPE_SET, peer_value, GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE);
 139
 140     gst_pad_send_event (peer_pad, event);
 141   }
 142
 143   gst_object_unref (peer_pad);
 144 }
 145
 146 static void
 147 gst_navseek_change_playback_rate (GstNavSeek * navseek, gdouble rate)
 148 {
 149   gboolean ret;
 150   GstPad *peer_pad;
 151   gint64 current_position;
 152
 153   peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
 154   ret = gst_pad_query_position (peer_pad, GST_FORMAT_TIME, &current_position);
 155
 156   if (ret) {
 157     GstEvent *event;
 158     gint64 start;
 159     gint64 stop;
 160
 161     if (rate > 0.0) {
 162       start = current_position;
 163       stop = -1;
 164     } else {
 165       /* negative rate: we play from stop to start */
 166       start = 0;
 167       stop = current_position;
 168     }
 169
 170     event = gst_event_new_seek (rate, GST_FORMAT_TIME,
 171         GST_SEEK_FLAG_ACCURATE | GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SKIP,
 172         GST_SEEK_TYPE_SET, start, GST_SEEK_TYPE_SET, stop);
 173
 174     gst_pad_send_event (peer_pad, event);
 175   }
 176 }
 177
 178 static void
 179 gst_navseek_segseek (GstNavSeek * navseek)
 180 {
 181   GstEvent *event;
 182   GstPad *peer_pad;
 183
 184   if ((navseek->segment_start == GST_CLOCK_TIME_NONE) ||
 185       (navseek->segment_end == GST_CLOCK_TIME_NONE) ||
 186       (!GST_PAD_IS_LINKED (GST_BASE_TRANSFORM (navseek)->sinkpad))) {
 187     return;
 188   }
 189
 190   if (navseek->loop) {
 191     event =
 192         gst_event_new_seek (1.0, GST_FORMAT_TIME,
 193         GST_SEEK_FLAG_ACCURATE | GST_SEEK_FLAG_SEGMENT,
 194         GST_SEEK_TYPE_SET, navseek->segment_start, GST_SEEK_TYPE_SET,
 195         navseek->segment_end);
 196   } else {
 197     event =
 198         gst_event_new_seek (1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_ACCURATE,
 199         GST_SEEK_TYPE_SET, navseek->segment_start, GST_SEEK_TYPE_SET,
 200         navseek->segment_end);
 201   }
 202
 203   peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
 204   gst_pad_send_event (peer_pad, event);
 205   gst_object_unref (peer_pad);
 206 }
 207
 208 static void
 209 gst_navseek_toggle_play_pause (GstNavSeek * navseek)
 210 {
 211   GstStateChangeReturn sret;
 212   GstState current, pending, state;
 213
 214   sret = gst_element_get_state (GST_ELEMENT (navseek), &current, &pending, 0);
 215   if (sret == GST_STATE_CHANGE_FAILURE)
 216     return;
 217
 218   state = (pending != GST_STATE_VOID_PENDING) ? pending : current;
 219
 220   gst_element_post_message (GST_ELEMENT (navseek),
 221       gst_message_new_request_state (GST_OBJECT (navseek),
 222           (state == GST_STATE_PLAYING) ? GST_STATE_PAUSED : GST_STATE_PLAYING));
 223 }
 224
 225 static gboolean
 226 gst_navseek_src_event (GstBaseTransform * trans, GstEvent * event)
 227 {
 228   GstNavSeek *navseek;
 229   gboolean ret = TRUE;
 230
 231   navseek = GST_NAVSEEK (trans);
 232
 233   switch (GST_EVENT_TYPE (event)) {
 234     case GST_EVENT_NAVIGATION:
 235     {
 236       /* Check for a keyup and convert left/right to a seek event */
 237       const GstStructure *structure;
 238       const gchar *event_type;
 239
 240       structure = gst_event_get_structure (event);
 241       g_return_val_if_fail (structure != NULL, FALSE);
 242
 243       event_type = gst_structure_get_string (structure, "event");
 244       g_return_val_if_fail (event_type != NULL, FALSE);
 245
 246       if (strcmp (event_type, "key-press") == 0) {
 247         const gchar *key;
 248
 249         key = gst_structure_get_string (structure, "key");
 250         g_return_val_if_fail (key != NULL, FALSE);
 251
 252         if (strcmp (key, "Left") == 0) {
 253           /* Seek backward by 5 secs */
 254           gst_navseek_seek (navseek, -1.0 * navseek->seek_offset * GST_SECOND);
 255         } else if (strcmp (key, "Right") == 0) {
 256           /* Seek forward */
 257           gst_navseek_seek (navseek, navseek->seek_offset * GST_SECOND);
 258         } else if (strcmp (key, "s") == 0) {
 259           /* Grab the next frame as the start frame of a segment */
 260           navseek->grab_seg_start = TRUE;
 261         } else if (strcmp (key, "e") == 0) {
 262           /* Grab the next frame as the end frame of a segment */
 263           navseek->grab_seg_end = TRUE;
 264         } else if (strcmp (key, "l") == 0) {
 265           /* Toggle the loop flag. If we have both start and end segment times send a seek */
 266           navseek->loop = !navseek->loop;
 267           gst_navseek_segseek (navseek);
 268         } else if (strcmp (key, "f") == 0) {
 269           /* fast forward */
 270           gst_navseek_change_playback_rate (navseek, 2.0);
 271         } else if (strcmp (key, "r") == 0) {
 272           /* rewind */
 273           gst_navseek_change_playback_rate (navseek, -2.0);
 274         } else if (strcmp (key, "n") == 0) {
 275           /* normal speed */
 276           gst_navseek_change_playback_rate (navseek, 1.0);
 277         } else if (strcmp (key, "space") == 0) {
 278           gst_navseek_toggle_play_pause (navseek);
 279         }
 280       } else {
 281         break;
 282       }
 283       gst_event_unref (event);
 284       event = NULL;
 285       break;
 286     }
 287     default:
 288       break;
 289   }
 290
 291   if (event)
 292     ret = GST_BASE_TRANSFORM_CLASS (parent_class)->src_event (trans, event);
 293
 294   return ret;
 295 }
 296
 297 static void
 298 gst_navseek_set_property (GObject * object, guint prop_id,
 299     const GValue * value, GParamSpec * pspec)
 300 {
 301   GstNavSeek *navseek = GST_NAVSEEK (object);
 302
 303   switch (prop_id) {
 304     case ARG_SEEKOFFSET:
 305       GST_OBJECT_LOCK (navseek);
 306       navseek->seek_offset = g_value_get_double (value);
 307       GST_OBJECT_UNLOCK (navseek);
 308       break;
 309     default:
 310       G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
 311       break;
 312   }
 313 }
 314
 315 static void
 316 gst_navseek_get_property (GObject * object, guint prop_id,
 317     GValue * value, GParamSpec * pspec)
 318 {
 319   GstNavSeek *navseek = GST_NAVSEEK (object);
 320
 321   switch (prop_id) {
 322     case ARG_SEEKOFFSET:
 323       GST_OBJECT_LOCK (navseek);
 324       g_value_set_double (value, navseek->seek_offset);
 325       GST_OBJECT_UNLOCK (navseek);
 326       break;
 327     default:
 328       G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
 329       break;
 330   }
 331 }
 332
 333 static gboolean
 334 gst_navseek_sink_event (GstBaseTransform * trans, GstEvent * event)
 335 {
 336   GstNavSeek *navseek = GST_NAVSEEK (trans);
 337
 338   switch (GST_EVENT_TYPE (event)) {
 339     case GST_EVENT_EOS:
 340       GST_OBJECT_LOCK (navseek);
 341       if (navseek->loop)
 342         gst_navseek_segseek (navseek);
 343       GST_OBJECT_UNLOCK (navseek);
 344       break;
 345     default:
 346       break;
 347   }
 348   return GST_BASE_TRANSFORM_CLASS (parent_class)->sink_event (trans, event);
 349 }
 350
 351 static GstFlowReturn
 352 gst_navseek_transform_ip (GstBaseTransform * basetrans, GstBuffer * buf)
 353 {
 354   GstNavSeek *navseek = GST_NAVSEEK (basetrans);
 355
 356   GST_OBJECT_LOCK (navseek);
 357
 358   if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
 359     if (navseek->grab_seg_start) {
 360       navseek->segment_start = GST_BUFFER_TIMESTAMP (buf);
 361       navseek->segment_end = GST_CLOCK_TIME_NONE;
 362       navseek->grab_seg_start = FALSE;
 363     }
 364
 365     if (navseek->grab_seg_end) {
 366       navseek->segment_end = GST_BUFFER_TIMESTAMP (buf);
 367       navseek->grab_seg_end = FALSE;
 368       gst_navseek_segseek (navseek);
 369     }
 370   }
 371
 372   GST_OBJECT_UNLOCK (navseek);
 373
 374   return GST_FLOW_OK;
 375 }
 376
 377 static gboolean
 378 gst_navseek_start (GstBaseTransform * trans)
 379 {
 380   /* anything we should be doing here? */
 381   return TRUE;
 382 }
 383
 384 static gboolean
 385 gst_navseek_stop (GstBaseTransform * trans)
 386 {
 387   /* anything we should be doing here? */
 388   return TRUE;
 389 }