diff options
Diffstat (limited to 'sys/v4l/v4lsrc_calls.c')
| -rw-r--r-- | sys/v4l/v4lsrc_calls.c | 764 |
1 files changed, 0 insertions, 764 deletions
diff --git a/sys/v4l/v4lsrc_calls.c b/sys/v4l/v4lsrc_calls.c deleted file mode 100644 index 31bd6dee..00000000 --- a/sys/v4l/v4lsrc_calls.c +++ /dev/null @@ -1,764 +0,0 @@ -/* GStreamer - * - * v4lsrc_calls.c: generic V4L source functions - * - * Copyright (C) 2001-2002 Ronald Bultje <rbultje@ronald.bitfreak.net> - * - * 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 - -#include <stdlib.h> -#include <sys/types.h> -#include <sys/stat.h> -#include <fcntl.h> -#include <sys/ioctl.h> -#include <sys/mman.h> -#include <string.h> -#include <errno.h> -#include "v4lsrc_calls.h" -#include <sys/time.h> - -/* number of buffers to be queued *at least* before syncing */ -#define MIN_BUFFERS_QUEUED 2 - -/* On some systems MAP_FAILED seems to be missing */ -#ifndef MAP_FAILED -#define MAP_FAILED ( (caddr_t) -1 ) -#endif - -GST_DEBUG_CATEGORY_EXTERN (v4l_debug); - -#define GST_CAT_DEFAULT v4l_debug - -#ifndef GST_DISABLE_GST_DEBUG -/* palette names */ -static const char *v4l_palette_name[] = { - "", /* 0 */ - "grayscale", /* VIDEO_PALETTE_GREY */ - "Hi-420", /* VIDEO_PALETTE_HI420 */ - "16-bit RGB (RGB-565)", /* VIDEO_PALETTE_RB565 */ - "24-bit RGB", /* VIDEO_PALETTE_RGB24 */ - "32-bit RGB", /* VIDEO_PALETTE_RGB32 */ - "15-bit RGB (RGB-555)", /* VIDEO_PALETTE_RGB555 */ - "YUV-4:2:2 (packed)", /* VIDEO_PALETTE_YUV422 */ - "YUYV", /* VIDEO_PALETTE_YUYV */ - "UYVY", /* VIDEO_PALETTE_UYVY */ - "YUV-4:2:0 (packed)", /* VIDEO_PALETTE_YUV420 */ - "YUV-4:1:1 (packed)", /* VIDEO_PALETTE_YUV411 */ - "Raw", /* VIDEO_PALETTE_RAW */ - "YUV-4:2:2 (planar)", /* VIDEO_PALETTE_YUV422P */ - "YUV-4:1:1 (planar)", /* VIDEO_PALETTE_YUV411P */ - "YUV-4:2:0 (planar)/I420", /* VIDEO_PALETTE_YUV420P */ - "YUV-4:1:0 (planar)" /* VIDEO_PALETTE_YUV410P */ -}; -#endif - -/****************************************************** - * gst_v4lsrc_queue_frame(): - * queue a frame for capturing - * (ie. instruct the hardware to start capture) - * Requires queue_state lock to be held! - * return value: TRUE on success, FALSE on error - ******************************************************/ - -static gboolean -gst_v4lsrc_queue_frame (GstV4lSrc * v4lsrc, gint num) -{ - GST_LOG_OBJECT (v4lsrc, "queueing frame %d", num); - - if (v4lsrc->frame_queue_state[num] != QUEUE_STATE_READY_FOR_QUEUE) { - return FALSE; - } - - /* instruct the driver to prepare capture using buffer frame num */ - v4lsrc->mmap.frame = num; - if (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, - VIDIOCMCAPTURE, &(v4lsrc->mmap)) < 0) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, WRITE, (NULL), - ("Error queueing a buffer (%d): %s", num, g_strerror (errno))); - return FALSE; - } - - v4lsrc->frame_queue_state[num] = QUEUE_STATE_QUEUED; - v4lsrc->num_queued++; - - return TRUE; -} - -/****************************************************** - * gst_v4lsrc_hard_sync_frame(GstV4lSrc *v4lsrc,gint num) - * sync a frame and set the timestamp correctly - * Requires queue_state lock to be held - *****************************************************/ - -static gboolean -gst_v4lsrc_sync_frame (GstV4lSrc * v4lsrc, gint num) -{ - GST_LOG_OBJECT (v4lsrc, "VIOIOCSYNC on frame %d", num); - - if (v4lsrc->frame_queue_state[num] != QUEUE_STATE_QUEUED) { - return FALSE; - } - - while (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, VIDIOCSYNC, &num) < 0) { - /* if the sync() got interrupted, we can retry */ - if (errno != EINTR) { - v4lsrc->frame_queue_state[num] = QUEUE_STATE_ERROR; - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, SYNC, (NULL), GST_ERROR_SYSTEM); - return FALSE; - } - GST_DEBUG_OBJECT (v4lsrc, "Sync got interrupted"); - } - GST_LOG_OBJECT (v4lsrc, "VIOIOCSYNC on frame %d done", num); - - v4lsrc->frame_queue_state[num] = QUEUE_STATE_SYNCED; - v4lsrc->num_queued--; - - return TRUE; -} - -/****************************************************** - * gst_v4lsrc_set_capture(): - * set capture parameters, palette = VIDEO_PALETTE_* - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_set_capture (GstV4lSrc * v4lsrc, - gint width, gint height, gint palette) -{ - GST_DEBUG_OBJECT (v4lsrc, - "capture properties set to %dx%d, palette %d", width, height, palette); - - v4lsrc->mmap.width = width; - v4lsrc->mmap.height = height; - v4lsrc->mmap.format = palette; - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_capture_init(): - * initialize the capture system - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_capture_init (GstV4lSrc * v4lsrc) -{ - GST_DEBUG_OBJECT (v4lsrc, "initting capture subsystem"); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_NOT_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - /* request the mmap buffer info: - * total size of mmap buffer, number of frames, offsets of frames */ - if (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, VIDIOCGMBUF, - &(v4lsrc->mbuf)) < 0) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, READ, (NULL), - ("Error getting buffer information: %s", g_strerror (errno))); - return FALSE; - } - - if (v4lsrc->mbuf.frames < MIN_BUFFERS_QUEUED) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, READ, (NULL), - ("Not enough buffers. We got %d, we want at least %d", - v4lsrc->mbuf.frames, MIN_BUFFERS_QUEUED)); - return FALSE; - } - - GST_INFO_OBJECT (v4lsrc, "Got %d buffers (\'%s\') with total size %d KB", - v4lsrc->mbuf.frames, v4l_palette_name[v4lsrc->mmap.format], - v4lsrc->mbuf.size / (v4lsrc->mbuf.frames * 1024)); - - /* keep track of queued buffers */ - v4lsrc->frame_queue_state = (gint8 *) - g_malloc (sizeof (gint8) * v4lsrc->mbuf.frames); - - /* lock for the frame_state */ - v4lsrc->mutex_queue_state = g_mutex_new (); - v4lsrc->cond_queue_state = g_cond_new (); - - /* Map the buffers */ - GST_V4LELEMENT (v4lsrc)->buffer = mmap (NULL, v4lsrc->mbuf.size, - PROT_READ | PROT_WRITE, MAP_SHARED, GST_V4LELEMENT (v4lsrc)->video_fd, 0); - if (GST_V4LELEMENT (v4lsrc)->buffer == MAP_FAILED) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, OPEN_READ_WRITE, (NULL), - ("Error mapping video buffers: %s", g_strerror (errno))); - GST_V4LELEMENT (v4lsrc)->buffer = NULL; - return FALSE; - } - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_capture_start(): - * start streaming capture - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_capture_start (GstV4lSrc * v4lsrc) -{ - int n; - - GST_DEBUG_OBJECT (v4lsrc, "starting capture"); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - g_mutex_lock (v4lsrc->mutex_queue_state); - - v4lsrc->quit = FALSE; - v4lsrc->num_queued = 0; - v4lsrc->sync_frame = 0; - v4lsrc->queue_frame = 0; - - /* set all buffers ready to queue, and queue captures to the device. - * This starts streaming capture */ - for (n = 0; n < v4lsrc->mbuf.frames; n++) { - v4lsrc->frame_queue_state[n] = QUEUE_STATE_READY_FOR_QUEUE; - if (!gst_v4lsrc_queue_frame (v4lsrc, n)) { - g_mutex_unlock (v4lsrc->mutex_queue_state); - gst_v4lsrc_capture_stop (v4lsrc); - return FALSE; - } - } - - v4lsrc->is_capturing = TRUE; - g_mutex_unlock (v4lsrc->mutex_queue_state); - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_grab_frame(): - * capture one frame during streaming capture - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_grab_frame (GstV4lSrc * v4lsrc, gint * num) -{ - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - GST_LOG_OBJECT (v4lsrc, "grabbing frame"); - - g_mutex_lock (v4lsrc->mutex_queue_state); - - /* do we have enough frames? */ - while (v4lsrc->num_queued < MIN_BUFFERS_QUEUED || - v4lsrc->frame_queue_state[v4lsrc->queue_frame] == - QUEUE_STATE_READY_FOR_QUEUE) { - while (v4lsrc->frame_queue_state[v4lsrc->queue_frame] != - QUEUE_STATE_READY_FOR_QUEUE && !v4lsrc->quit) { - GST_DEBUG_OBJECT (v4lsrc, - "Waiting for frames to become available (queued %d < minimum %d)", - v4lsrc->num_queued, MIN_BUFFERS_QUEUED); - g_cond_wait (v4lsrc->cond_queue_state, v4lsrc->mutex_queue_state); - } - if (v4lsrc->quit) { - g_mutex_unlock (v4lsrc->mutex_queue_state); - return FALSE; - } - if (!gst_v4lsrc_queue_frame (v4lsrc, v4lsrc->queue_frame)) { - g_mutex_unlock (v4lsrc->mutex_queue_state); - return FALSE; - } - v4lsrc->queue_frame = (v4lsrc->queue_frame + 1) % v4lsrc->mbuf.frames; - } - - /* syncing on the buffer grabs it */ - *num = v4lsrc->sync_frame; - if (!gst_v4lsrc_sync_frame (v4lsrc, *num)) { - g_mutex_unlock (v4lsrc->mutex_queue_state); - return FALSE; - } - v4lsrc->sync_frame = (v4lsrc->sync_frame + 1) % v4lsrc->mbuf.frames; - - g_mutex_unlock (v4lsrc->mutex_queue_state); - - GST_LOG_OBJECT (v4lsrc, "grabbed frame %d", *num); - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_get_buffer(): - * get the address of the given frame number in the mmap'd buffer - * return value: the buffer's address or NULL - ******************************************************/ - -guint8 * -gst_v4lsrc_get_buffer (GstV4lSrc * v4lsrc, gint num) -{ - if (!GST_V4L_IS_ACTIVE (GST_V4LELEMENT (v4lsrc)) || - !GST_V4L_IS_OPEN (GST_V4LELEMENT (v4lsrc))) - return NULL; - - if (num < 0 || num >= v4lsrc->mbuf.frames) - return NULL; - - return GST_V4LELEMENT (v4lsrc)->buffer + v4lsrc->mbuf.offsets[num]; -} - - -/****************************************************** - * gst_v4lsrc_requeue_frame(): - * re-queue a frame after we're done with the buffer - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_requeue_frame (GstV4lSrc * v4lsrc, gint num) -{ - GST_LOG_OBJECT (v4lsrc, "requeueing frame %d", num); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - /* mark frame as 'ready to requeue' */ - g_mutex_lock (v4lsrc->mutex_queue_state); - - if (v4lsrc->frame_queue_state[num] != QUEUE_STATE_SYNCED) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, TOO_LAZY, (NULL), - ("Invalid state %d (expected %d), can't requeue", - v4lsrc->frame_queue_state[num], QUEUE_STATE_SYNCED)); - return FALSE; - } - - v4lsrc->frame_queue_state[num] = QUEUE_STATE_READY_FOR_QUEUE; - - /* let an optional wait know */ - g_cond_broadcast (v4lsrc->cond_queue_state); - - g_mutex_unlock (v4lsrc->mutex_queue_state); - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_capture_stop(): - * stop streaming capture - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_capture_stop (GstV4lSrc * v4lsrc) -{ - GST_DEBUG_OBJECT (v4lsrc, "stopping capture"); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - g_mutex_lock (v4lsrc->mutex_queue_state); - v4lsrc->is_capturing = FALSE; - - /* make an optional pending wait stop */ - v4lsrc->quit = TRUE; - g_cond_broadcast (v4lsrc->cond_queue_state); - - /* sync on remaining frames */ - while (1) { - if (v4lsrc->frame_queue_state[v4lsrc->sync_frame] == QUEUE_STATE_QUEUED) { - gst_v4lsrc_sync_frame (v4lsrc, v4lsrc->sync_frame); - v4lsrc->sync_frame = (v4lsrc->sync_frame + 1) % v4lsrc->mbuf.frames; - } else { - break; - } - } - - g_mutex_unlock (v4lsrc->mutex_queue_state); - - return TRUE; -} - - -/****************************************************** - * gst_v4lsrc_capture_deinit(): - * deinitialize the capture system - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_capture_deinit (GstV4lSrc * v4lsrc) -{ - GST_DEBUG_OBJECT (v4lsrc, "quitting capture subsystem"); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - /* free buffer tracker */ - g_mutex_free (v4lsrc->mutex_queue_state); - v4lsrc->mutex_queue_state = NULL; - g_cond_free (v4lsrc->cond_queue_state); - v4lsrc->cond_queue_state = NULL; - g_free (v4lsrc->frame_queue_state); - v4lsrc->frame_queue_state = NULL; - - /* unmap the buffer */ - if (munmap (GST_V4LELEMENT (v4lsrc)->buffer, v4lsrc->mbuf.size) == -1) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, CLOSE, (NULL), - ("error munmap'ing capture buffer: %s", g_strerror (errno))); - return FALSE; - } - GST_V4LELEMENT (v4lsrc)->buffer = NULL; - - return TRUE; -} - -/****************************************************** - * gst_v4lsrc_try_capture(): - * try out a capture on the device - * This has to be done before initializing the - * actual capture system, to make sure we don't - * mess up anything. So we need to mini-mmap() - * a buffer here, queue and sync on one buffer, - * and unmap it. - * This is ugly, yes, I know - but it's a major - * design flaw of v4l1 that you don't know in - * advance which formats will be supported... - * This is better than "just assuming that it'll - * work"... - * return value: TRUE on success, FALSE on error - ******************************************************/ - -gboolean -gst_v4lsrc_try_capture (GstV4lSrc * v4lsrc, gint width, gint height, - gint palette) -{ - /* so, we need a buffer and some more stuff */ - int frame = 0; - guint8 *buffer; - struct video_mbuf vmbuf; - struct video_mmap vmmap; - - GST_DEBUG_OBJECT (v4lsrc, "try out %dx%d, palette format %d (%s)", - width, height, palette, v4l_palette_name[palette]); - GST_V4L_CHECK_OPEN (GST_V4LELEMENT (v4lsrc)); - GST_V4L_CHECK_NOT_ACTIVE (GST_V4LELEMENT (v4lsrc)); - - /* let's start by requesting a buffer and mmap()'ing it */ - if (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, VIDIOCGMBUF, &vmbuf) < 0) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, READ, (NULL), - ("Error getting buffer information: %s", g_strerror (errno))); - return FALSE; - } - /* Map the buffers */ - buffer = mmap (NULL, vmbuf.size, PROT_READ | PROT_WRITE, - MAP_SHARED, GST_V4LELEMENT (v4lsrc)->video_fd, 0); - if (buffer == MAP_FAILED) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, OPEN_READ_WRITE, (NULL), - ("Error mapping our try-out buffer: %s", g_strerror (errno))); - return FALSE; - } - - /* now that we have a buffer, let's try out our format */ - vmmap.width = width; - vmmap.height = height; - vmmap.format = palette; - vmmap.frame = frame; - if (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, VIDIOCMCAPTURE, &vmmap) < 0) { - if (errno != EINVAL) /* our format failed! */ - GST_ERROR_OBJECT (v4lsrc, - "Error queueing our try-out buffer: %s", g_strerror (errno)); - munmap (buffer, vmbuf.size); - return FALSE; - } - - if (ioctl (GST_V4LELEMENT (v4lsrc)->video_fd, VIDIOCSYNC, &frame) < 0) { - GST_ELEMENT_ERROR (v4lsrc, RESOURCE, SYNC, (NULL), GST_ERROR_SYSTEM); - munmap (buffer, vmbuf.size); - return FALSE; - } - - munmap (buffer, vmbuf.size); - - /* if we got here, it worked! woohoo, the format is supported! */ - return TRUE; -} - -#ifndef GST_DISABLE_GST_DEBUG -const char * -gst_v4lsrc_palette_name (int i) -{ - return v4l_palette_name[i]; -} -#endif - -gboolean -gst_v4lsrc_get_fps (GstV4lSrc * v4lsrc, gint * fps_n, gint * fps_d) -{ - gint norm; - gint fps_index; - struct video_window *vwin = &GST_V4LELEMENT (v4lsrc)->vwin; - - /* check if we have vwin window properties giving a framerate, - * as is done for webcams - * See http://www.smcc.demon.nl/webcam/api.html - * which is used for the Philips and qce-ga drivers */ - fps_index = (vwin->flags >> 16) & 0x3F; /* 6 bit index for framerate */ - - /* webcams have a non-zero fps_index */ - if (fps_index != 0) { - /* index of 16 corresponds to 15 fps */ - GST_DEBUG_OBJECT (v4lsrc, "device reports fps of %d/%d (%.4f)", - fps_index * 15, 16, fps_index * 15.0 / 16); - - if (fps_n) - *fps_n = fps_index * 15; - if (fps_d) - *fps_d = 16; - - return TRUE; - } - - /* removed fps estimation code here */ - - /* if that failed ... */ - - if (!GST_V4L_IS_OPEN (GST_V4LELEMENT (v4lsrc))) - return FALSE; - - if (!gst_v4l_get_chan_norm (GST_V4LELEMENT (v4lsrc), NULL, &norm)) - return FALSE; - - if (norm == VIDEO_MODE_NTSC) { - if (fps_n) - *fps_n = 30000; - if (fps_d) - *fps_d = 1001; - } else { - if (fps_n) - *fps_n = 25; - if (fps_d) - *fps_d = 1; - } - - return TRUE; -} - -/* get a list of possible framerates - * this is only done for webcams; - * other devices return NULL here. - * this function takes a LONG time to execute. - */ -GValue * -gst_v4lsrc_get_fps_list (GstV4lSrc * v4lsrc) -{ - gint fps_index; - struct video_window *vwin = &GST_V4LELEMENT (v4lsrc)->vwin; - GstV4lElement *v4lelement = GST_V4LELEMENT (v4lsrc); - - /* check if we have vwin window properties giving a framerate, - * as is done for webcams - * See http://www.smcc.demon.nl/webcam/api.html - * which is used for the Philips and qce-ga drivers */ - fps_index = (vwin->flags >> 16) & 0x3F; /* 6 bit index for framerate */ - - /* webcams have a non-zero fps_index */ - if (fps_index == 0) { - GST_DEBUG_OBJECT (v4lsrc, "fps_index is 0, no webcam"); - return NULL; - } - GST_DEBUG_OBJECT (v4lsrc, "fps_index is %d, so webcam", fps_index); - - { - int i; - GValue *list = NULL; - GValue value = { 0 }; - - /* webcam detected, so try all framerates and return a list */ - - list = g_new0 (GValue, 1); - g_value_init (list, GST_TYPE_LIST); - - /* index of 16 corresponds to 15 fps */ - GST_DEBUG_OBJECT (v4lsrc, "device reports fps of %d/%d (%.4f)", - fps_index * 15, 16, fps_index * 15.0 / 16); - for (i = 0; i < 63; ++i) { - /* set bits 16 to 21 to 0 */ - vwin->flags &= (0x3F00 - 1); - /* set bits 16 to 21 to the index */ - vwin->flags |= i << 16; - if (gst_v4l_set_window_properties (v4lelement)) { - /* setting it succeeded. FIXME: get it and check. */ - g_value_init (&value, GST_TYPE_FRACTION); - gst_value_set_fraction (&value, i * 15, 16); - gst_value_list_append_value (list, &value); - g_value_unset (&value); - } - } - /* FIXME: set back the original fps_index */ - vwin->flags &= (0x3F00 - 1); - vwin->flags |= fps_index << 16; - gst_v4l_set_window_properties (v4lelement); - return list; - } -} - -#define GST_TYPE_V4LSRC_BUFFER (gst_v4lsrc_buffer_get_type()) -#define GST_IS_V4LSRC_BUFFER(obj) (G_TYPE_CHECK_INSTANCE_TYPE ((obj), GST_TYPE_V4LSRC_BUFFER)) -#define GST_V4LSRC_BUFFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GST_TYPE_V4LSRC_BUFFER, GstV4lSrcBuffer)) - -typedef struct _GstV4lSrcBuffer -{ - GstBuffer buffer; - - GstV4lSrc *v4lsrc; - - gint num; -} GstV4lSrcBuffer; - -static void gst_v4lsrc_buffer_class_init (gpointer g_class, - gpointer class_data); -static void gst_v4lsrc_buffer_init (GTypeInstance * instance, gpointer g_class); -static void gst_v4lsrc_buffer_finalize (GstV4lSrcBuffer * v4lsrc_buffer); - -static GstBufferClass *v4lbuffer_parent_class = NULL; - -static GType -gst_v4lsrc_buffer_get_type (void) -{ - static GType _gst_v4lsrc_buffer_type; - - if (G_UNLIKELY (_gst_v4lsrc_buffer_type == 0)) { - static const GTypeInfo v4lsrc_buffer_info = { - sizeof (GstBufferClass), - NULL, - NULL, - gst_v4lsrc_buffer_class_init, - NULL, - NULL, - sizeof (GstV4lSrcBuffer), - 0, - gst_v4lsrc_buffer_init, - NULL - }; - _gst_v4lsrc_buffer_type = g_type_register_static (GST_TYPE_BUFFER, - "GstV4lSrcBuffer", &v4lsrc_buffer_info, 0); - } - return _gst_v4lsrc_buffer_type; -} - -static void -gst_v4lsrc_buffer_class_init (gpointer g_class, gpointer class_data) -{ - GstMiniObjectClass *mini_object_class = GST_MINI_OBJECT_CLASS (g_class); - - v4lbuffer_parent_class = g_type_class_peek_parent (g_class); - - mini_object_class->finalize = (GstMiniObjectFinalizeFunction) - gst_v4lsrc_buffer_finalize; -} - -static void -gst_v4lsrc_buffer_init (GTypeInstance * instance, gpointer g_class) -{ - -} - -static void -gst_v4lsrc_buffer_finalize (GstV4lSrcBuffer * v4lsrc_buffer) -{ - GstMiniObjectClass *miniobject_class; - GstV4lSrc *v4lsrc; - gint num; - - v4lsrc = v4lsrc_buffer->v4lsrc; - num = v4lsrc_buffer->num; - - GST_LOG_OBJECT (v4lsrc, "freeing buffer %p for frame %d", v4lsrc_buffer, num); - - /* only requeue if we still have an mmap buffer */ - if (GST_V4LELEMENT (v4lsrc)->buffer) { - GST_LOG_OBJECT (v4lsrc, "requeueing frame %d", num); - gst_v4lsrc_requeue_frame (v4lsrc, num); - } - - gst_object_unref (v4lsrc); - - miniobject_class = (GstMiniObjectClass *) v4lbuffer_parent_class; - miniobject_class->finalize (GST_MINI_OBJECT_CAST (v4lsrc_buffer)); -} - -/* Create a V4lSrc buffer from our mmap'd data area */ -GstBuffer * -gst_v4lsrc_buffer_new (GstV4lSrc * v4lsrc, gint num) -{ - GstClockTime duration, timestamp, latency; - GstBuffer *buf; - GstClock *clock; - gint fps_n, fps_d; - - GST_DEBUG_OBJECT (v4lsrc, "creating buffer for frame %d", num); - - if (!(gst_v4lsrc_get_fps (v4lsrc, &fps_n, &fps_d))) - return NULL; - - buf = (GstBuffer *) gst_mini_object_new (GST_TYPE_V4LSRC_BUFFER); - - GST_V4LSRC_BUFFER (buf)->num = num; - GST_V4LSRC_BUFFER (buf)->v4lsrc = gst_object_ref (v4lsrc); - - GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_READONLY); - GST_BUFFER_DATA (buf) = gst_v4lsrc_get_buffer (v4lsrc, num); - GST_BUFFER_SIZE (buf) = v4lsrc->buffer_size; - GST_BUFFER_OFFSET (buf) = v4lsrc->offset++; - GST_BUFFER_OFFSET_END (buf) = v4lsrc->offset; - - /* timestamps, LOCK to get clock and base time. */ - GST_OBJECT_LOCK (v4lsrc); - if ((clock = GST_ELEMENT_CLOCK (v4lsrc))) { - /* we have a clock, get base time and ref clock */ - timestamp = GST_ELEMENT_CAST (v4lsrc)->base_time; - gst_object_ref (clock); - } else { - /* no clock, can't set timestamps */ - timestamp = GST_CLOCK_TIME_NONE; - } - GST_OBJECT_UNLOCK (v4lsrc); - - duration = - gst_util_uint64_scale_int (GST_SECOND, fps_d * v4lsrc->offset, fps_n) - - gst_util_uint64_scale_int (GST_SECOND, fps_d * (v4lsrc->offset - 1), - fps_n); - - latency = gst_util_uint64_scale_int (GST_SECOND, fps_d, fps_n); - - if (clock) { - /* the time now is the time of the clock minus the base time */ - timestamp = gst_clock_get_time (clock) - timestamp; - gst_object_unref (clock); - - /* adjust timestamp for frame latency (we assume we have a framerate) */ - if (timestamp > latency) - timestamp -= latency; - else - timestamp = 0; - } - - GST_BUFFER_TIMESTAMP (buf) = timestamp; - GST_BUFFER_DURATION (buf) = duration; - - return buf; -} |