mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-24 10:41:04 +00:00
8114fe3de9
Original commit message from CVS: cdparanoia added
656 lines
21 KiB
C
656 lines
21 KiB
C
/* Gnome-Streamer
|
|
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
|
*
|
|
* 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.
|
|
*/
|
|
|
|
//#define GST_DEBUG_ENABLED
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <time.h>
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#include <sys/ioctl.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/types.h>
|
|
#include <dirent.h>
|
|
#include <errno.h>
|
|
|
|
#include "gstcdparanoia.h"
|
|
|
|
|
|
static GstElementDetails cdparanoia_details = {
|
|
"CD Audio (cdda) Source, Paranoia IV",
|
|
"Source/File/CDDA",
|
|
"Read audio from CD in paranoid mode",
|
|
VERSION,
|
|
"Erik Walthinsen <omega@cse.ogi.edu>",
|
|
"(C) 2000",
|
|
};
|
|
|
|
GST_PADTEMPLATE_FACTORY (cdparanoia_src_factory,
|
|
"src",
|
|
GST_PAD_SRC,
|
|
GST_PAD_ALWAYS,
|
|
GST_CAPS_NEW (
|
|
"cdparanoia_src",
|
|
"audio/raw",
|
|
"format", GST_PROPS_STRING ("int"),
|
|
"law", GST_PROPS_INT (0),
|
|
"endianness", GST_PROPS_INT (G_BYTE_ORDER),
|
|
"signed", GST_PROPS_BOOLEAN (TRUE),
|
|
"width", GST_PROPS_INT (16),
|
|
"depth", GST_PROPS_INT (16),
|
|
"rate", GST_PROPS_INT (44100),
|
|
"channels", GST_PROPS_INT (2),
|
|
"chunksize", GST_PROPS_INT (CD_FRAMESIZE_RAW)
|
|
)
|
|
);
|
|
|
|
|
|
/********** Define useful types for non-programmatic interfaces **********/
|
|
#define GST_TYPE_PARANOIA_MODE (gst_lame_paranoia_get_type())
|
|
static GType
|
|
gst_lame_paranoia_get_type (void)
|
|
{
|
|
static GType paranoia_mode_type = 0;
|
|
static GEnumValue paranoia_modes[] = {
|
|
{ 0, "0", "Disable paranoid checking" },
|
|
{ 1, "1", "cdda2wav-style overlap checking" },
|
|
{ 2, "2", "Full paranoia" },
|
|
{ 0, NULL, NULL },
|
|
};
|
|
if (!paranoia_mode_type) {
|
|
paranoia_mode_type = g_enum_register_static ("GstParanoiaMode", paranoia_modes);
|
|
}
|
|
return paranoia_mode_type;
|
|
}
|
|
|
|
|
|
/********** Standard stuff for signals and arguments **********/
|
|
/* CDParanoia signals and args */
|
|
enum {
|
|
SMILIE_CHANGE,
|
|
TRANSPORT_ERROR,
|
|
UNCORRECTED_ERROR,
|
|
LAST_SIGNAL
|
|
};
|
|
|
|
enum {
|
|
ARG_0,
|
|
ARG_LOCATION,
|
|
ARG_GENERIC_DEVICE,
|
|
ARG_START_TRACK,
|
|
ARG_END_TRACK,
|
|
ARG_LAST_TRACK,
|
|
ARG_CUR_TRACK,
|
|
ARG_START_SECTOR,
|
|
ARG_END_SECTOR,
|
|
ARG_CUR_SECTOR,
|
|
ARG_DEFAULT_SECTORS,
|
|
ARG_SEARCH_OVERLAP,
|
|
ARG_ENDIAN,
|
|
ARG_READ_SPEED,
|
|
ARG_TOC_OFFSET,
|
|
ARG_TOC_BIAS,
|
|
ARG_NEVER_SKIP,
|
|
ARG_ABORT_ON_SKIP,
|
|
ARG_PARANOIA_MODE,
|
|
ARG_SMILIE,
|
|
};
|
|
|
|
|
|
static void cdparanoia_class_init (CDParanoiaClass *klass);
|
|
static void cdparanoia_init (CDParanoia *cdparanoia);
|
|
|
|
static void cdparanoia_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
|
|
static void cdparanoia_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
|
|
|
|
static GstBuffer* cdparanoia_get (GstPad *pad);
|
|
|
|
static GstElementStateReturn cdparanoia_change_state (GstElement *element);
|
|
|
|
|
|
static GstElementClass *parent_class = NULL;
|
|
static guint cdparanoia_signals[LAST_SIGNAL] = { 0 };
|
|
|
|
GType
|
|
cdparanoia_get_type (void)
|
|
{
|
|
static GType cdparanoia_type = 0;
|
|
|
|
if (!cdparanoia_type) {
|
|
static const GTypeInfo cdparanoia_info = {
|
|
sizeof(CDParanoiaClass), NULL,
|
|
NULL,
|
|
(GClassInitFunc)cdparanoia_class_init,
|
|
NULL,
|
|
NULL,
|
|
sizeof(CDParanoia),
|
|
0,
|
|
(GInstanceInitFunc)cdparanoia_init,
|
|
};
|
|
cdparanoia_type = g_type_register_static (GST_TYPE_ELEMENT, "CDParanoia", &cdparanoia_info, 0);
|
|
}
|
|
return cdparanoia_type;
|
|
}
|
|
|
|
static void
|
|
cdparanoia_class_init (CDParanoiaClass *klass)
|
|
{
|
|
GObjectClass *gobject_class;
|
|
GstElementClass *gstelement_class;
|
|
|
|
gobject_class = (GObjectClass*)klass;
|
|
gstelement_class = (GstElementClass*)klass;
|
|
|
|
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
|
|
|
|
cdparanoia_signals[SMILIE_CHANGE] =
|
|
g_signal_new ("smilie_change", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST,
|
|
G_STRUCT_OFFSET (CDParanoiaClass, smilie_change), NULL, NULL,
|
|
g_cclosure_marshal_VOID__STRING, G_TYPE_NONE, 1, G_TYPE_STRING);
|
|
cdparanoia_signals[TRANSPORT_ERROR] =
|
|
g_signal_new ("transport_error", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST,
|
|
G_STRUCT_OFFSET (CDParanoiaClass, transport_error), NULL, NULL,
|
|
g_cclosure_marshal_VOID__INT, G_TYPE_NONE, 1, G_TYPE_INT);
|
|
cdparanoia_signals[UNCORRECTED_ERROR] =
|
|
g_signal_new ("uncorrected_error", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST,
|
|
G_STRUCT_OFFSET (CDParanoiaClass, uncorrected_error), NULL, NULL,
|
|
g_cclosure_marshal_VOID__INT, G_TYPE_NONE, 1, G_TYPE_INT);
|
|
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_LOCATION,
|
|
g_param_spec_string("location","location","location",
|
|
NULL, G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_GENERIC_DEVICE,
|
|
g_param_spec_string("generic_device","generic_device","generic_device",
|
|
NULL, G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_START_TRACK,
|
|
g_param_spec_int("start_track","start_track","start_track",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_END_TRACK,
|
|
g_param_spec_int("end_track","end_track","end_track",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_LAST_TRACK,
|
|
g_param_spec_int("last_track","last_track","last_track",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READABLE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_CUR_TRACK,
|
|
g_param_spec_int("cur_track","cur_track","cur_track",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READABLE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_START_SECTOR,
|
|
g_param_spec_int("start_sector","start_sector","start_sector",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_END_SECTOR,
|
|
g_param_spec_int("end_sector","end_sector","end_sector",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_CUR_SECTOR,
|
|
g_param_spec_int("cur_sector","cur_sector","cur_sector",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READABLE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_DEFAULT_SECTORS,
|
|
g_param_spec_int("default_sectors","default_sectors","default_sectors",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_SEARCH_OVERLAP,
|
|
g_param_spec_int("search_overlap","search_overlap","search_overlap",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_ENDIAN,
|
|
g_param_spec_int("endian","endian","endian",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_READ_SPEED,
|
|
g_param_spec_int("read_speed","read_speed","read_speed",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_TOC_OFFSET,
|
|
g_param_spec_int("toc_offset","toc_offset","toc_offset",
|
|
G_MININT,G_MAXINT,0,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_TOC_BIAS,
|
|
g_param_spec_boolean("toc_bias","toc_bias","toc_bias",
|
|
TRUE,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_NEVER_SKIP,
|
|
g_param_spec_boolean("never_skip","never_skip","never_skip",
|
|
TRUE,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_ABORT_ON_SKIP,
|
|
g_param_spec_boolean("abort_on_skip","abort_on_skip","abort_on_skip",
|
|
TRUE,G_PARAM_READWRITE)); // CHECKME
|
|
g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_PARANOIA_MODE,
|
|
g_param_spec_enum("paranoia_mode","paranoia_mode","paranoia_mode",
|
|
GST_TYPE_PARANOIA_MODE,0,G_PARAM_READWRITE)); // CHECKME!
|
|
|
|
gobject_class->set_property = cdparanoia_set_property;
|
|
gobject_class->get_property = cdparanoia_get_property;
|
|
|
|
gstelement_class->change_state = cdparanoia_change_state;
|
|
}
|
|
|
|
static void
|
|
cdparanoia_init (CDParanoia *cdparanoia)
|
|
{
|
|
cdparanoia->srcpad = gst_pad_new_from_template (
|
|
GST_PADTEMPLATE_GET (cdparanoia_src_factory), "src");
|
|
gst_pad_set_get_function (cdparanoia->srcpad, cdparanoia_get);
|
|
gst_pad_set_caps (cdparanoia->srcpad, gst_pad_get_padtemplate_caps (cdparanoia->srcpad));
|
|
gst_element_add_pad (GST_ELEMENT (cdparanoia), cdparanoia->srcpad);
|
|
|
|
cdparanoia->device = "/dev/cdrom";
|
|
cdparanoia->generic_device = NULL;
|
|
cdparanoia->start_sector = -1;
|
|
cdparanoia->end_sector = -1;
|
|
cdparanoia->cur_sector = -1;
|
|
cdparanoia->start_track = -1;
|
|
cdparanoia->cur_track = -1;
|
|
cdparanoia->end_track = -1;
|
|
cdparanoia->last_track = -1;
|
|
cdparanoia->default_sectors = -1;
|
|
cdparanoia->search_overlap = -1;
|
|
cdparanoia->endian = -1;
|
|
cdparanoia->read_speed = -1;
|
|
cdparanoia->toc_offset = 0;
|
|
cdparanoia->toc_bias = FALSE;
|
|
cdparanoia->never_skip = FALSE;
|
|
cdparanoia->paranoia_mode = 2;
|
|
cdparanoia->abort_on_skip = FALSE;
|
|
|
|
cdparanoia->cur_sector = 0;
|
|
cdparanoia->seq = 0;
|
|
}
|
|
|
|
|
|
static void
|
|
cdparanoia_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
|
|
{
|
|
CDParanoia *src;
|
|
|
|
/* it's not null if we got it, but it might not be ours */
|
|
g_return_if_fail (GST_IS_CDPARANOIA (object));
|
|
|
|
src = CDPARANOIA (object);
|
|
|
|
switch (prop_id) {
|
|
case ARG_LOCATION:
|
|
/* the element must be stopped in order to do this */
|
|
// g_return_if_fail(!GST_FLAG_IS_SET(src,GST_STATE_RUNNING));
|
|
|
|
if (src->device) g_free (src->device);
|
|
/* clear the filename if we get a NULL (is that possible?) */
|
|
if (g_value_get_string (value) == NULL)
|
|
src->device = NULL;
|
|
/* otherwise set the new filename */
|
|
else
|
|
src->device = g_strdup (g_value_get_string (value));
|
|
break;
|
|
case ARG_GENERIC_DEVICE:
|
|
/* the element must be stopped in order to do this */
|
|
// g_return_if_fail(!GST_FLAG_IS_SET(src,GST_STATE_RUNNING));
|
|
|
|
if (src->generic_device) g_free (src->generic_device);
|
|
/* reset the device if we get a NULL (is that possible?) */
|
|
if (g_value_get_string (value) == NULL)
|
|
src->generic_device = NULL;
|
|
/* otherwise set the new filename */
|
|
else
|
|
src->generic_device = g_strdup (g_value_get_string (value));
|
|
break;
|
|
case ARG_START_SECTOR:
|
|
src->start_sector = g_value_get_int (value);
|
|
break;
|
|
case ARG_END_SECTOR:
|
|
src->end_sector = g_value_get_int (value);
|
|
break;
|
|
case ARG_START_TRACK:
|
|
src->start_track = g_value_get_int (value);
|
|
break;
|
|
case ARG_END_TRACK:
|
|
src->end_track = g_value_get_int (value);
|
|
break;
|
|
case ARG_DEFAULT_SECTORS:
|
|
src->default_sectors = g_value_get_int (value);
|
|
break;
|
|
case ARG_SEARCH_OVERLAP:
|
|
src->search_overlap = g_value_get_int (value);
|
|
break;
|
|
case ARG_ENDIAN:
|
|
src->endian = g_value_get_int (value);
|
|
break;
|
|
case ARG_READ_SPEED:
|
|
src->read_speed = g_value_get_int (value);
|
|
break;
|
|
case ARG_TOC_OFFSET:
|
|
src->toc_offset = g_value_get_int (value);
|
|
break;
|
|
case ARG_TOC_BIAS:
|
|
src->toc_bias = g_value_get_boolean (value);
|
|
break;
|
|
case ARG_NEVER_SKIP:
|
|
src->never_skip = g_value_get_boolean (value);
|
|
break;
|
|
case ARG_ABORT_ON_SKIP:
|
|
src->abort_on_skip = g_value_get_boolean (value);
|
|
break;
|
|
case ARG_PARANOIA_MODE:
|
|
src->paranoia_mode = g_value_get_int (value);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
}
|
|
|
|
static void
|
|
cdparanoia_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
|
|
{
|
|
CDParanoia *src;
|
|
|
|
/* it's not null if we got it, but it might not be ours */
|
|
g_return_if_fail (GST_IS_CDPARANOIA (object));
|
|
|
|
src = CDPARANOIA (object);
|
|
|
|
switch (prop_id) {
|
|
case ARG_LOCATION:
|
|
g_value_set_string (value, src->device);
|
|
break;
|
|
case ARG_GENERIC_DEVICE:
|
|
g_value_set_string (value, src->generic_device);
|
|
break;
|
|
case ARG_START_SECTOR:
|
|
g_value_set_int (value, src->start_sector);
|
|
break;
|
|
case ARG_END_SECTOR:
|
|
g_value_set_int (value, src->end_sector);
|
|
break;
|
|
case ARG_CUR_SECTOR:
|
|
g_value_set_int (value, src->cur_sector);
|
|
break;
|
|
case ARG_START_TRACK:
|
|
g_value_set_int (value, src->start_track);
|
|
break;
|
|
case ARG_END_TRACK:
|
|
g_value_set_int (value, src->end_track);
|
|
break;
|
|
case ARG_CUR_TRACK:
|
|
g_value_set_int (value, src->cur_track);
|
|
break;
|
|
case ARG_LAST_TRACK:
|
|
g_value_set_int (value, src->last_track);
|
|
break;
|
|
case ARG_DEFAULT_SECTORS:
|
|
g_value_set_int (value, src->default_sectors);
|
|
break;
|
|
case ARG_SEARCH_OVERLAP:
|
|
g_value_set_int (value, src->search_overlap);
|
|
break;
|
|
case ARG_ENDIAN:
|
|
g_value_set_int (value, src->endian);
|
|
break;
|
|
case ARG_READ_SPEED:
|
|
g_value_set_int (value, src->read_speed);
|
|
break;
|
|
case ARG_TOC_OFFSET:
|
|
g_value_set_int (value, src->toc_offset);
|
|
break;
|
|
case ARG_TOC_BIAS:
|
|
g_value_set_boolean (value, src->toc_bias);
|
|
break;
|
|
case ARG_NEVER_SKIP:
|
|
g_value_set_boolean (value, src->never_skip);
|
|
break;
|
|
case ARG_ABORT_ON_SKIP:
|
|
g_value_set_boolean (value, src->abort_on_skip);
|
|
break;
|
|
case ARG_PARANOIA_MODE:
|
|
g_value_set_int (value, src->paranoia_mode);
|
|
break;
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
break;
|
|
}
|
|
}
|
|
|
|
static void cdparanoia_callback(long inpos, int function) {
|
|
}
|
|
|
|
static GstBuffer*
|
|
cdparanoia_get (GstPad *pad)
|
|
{
|
|
CDParanoia *src;
|
|
GstBuffer *buf;
|
|
static gint16 *cdda_buf;
|
|
|
|
g_return_val_if_fail (pad != NULL, NULL);
|
|
src = CDPARANOIA (gst_pad_get_parent (pad));
|
|
g_return_val_if_fail (GST_FLAG_IS_SET (src, CDPARANOIA_OPEN), NULL);
|
|
|
|
// create a new buffer
|
|
buf = gst_buffer_new ();
|
|
g_return_val_if_fail (buf, NULL);
|
|
|
|
// read a sector
|
|
// NOTE: if you have a patched cdparanoia, set this to 1 to save cycles
|
|
#if 0
|
|
cdda_buf = paranoia_read (src->p, NULL);
|
|
#else
|
|
cdda_buf = paranoia_read (src->p, cdparanoia_callback);
|
|
#endif
|
|
|
|
// update current sector and stop things if appropriate
|
|
src->cur_sector++;
|
|
|
|
src->cur_track = cdda_sector_gettrack( src->d, src->cur_sector );
|
|
|
|
if (src->cur_sector == src->end_sector) {
|
|
GST_DEBUG (0,"setting EOS flag on outgoing buffer\n");
|
|
GST_BUFFER_FLAG_SET (buf,GST_BUFFER_EOS);
|
|
gst_element_signal_eos(GST_ELEMENT(src));
|
|
}
|
|
|
|
// have to copy the buffer for now since we don't own it...
|
|
// FIXME must ask monty about allowing ownership transfer
|
|
GST_BUFFER_DATA (buf) = g_malloc(CD_FRAMESIZE_RAW);
|
|
memcpy (GST_BUFFER_DATA (buf), cdda_buf, CD_FRAMESIZE_RAW);
|
|
GST_BUFFER_SIZE (buf) = CD_FRAMESIZE_RAW;
|
|
|
|
|
|
/* we're done, push the buffer off now */
|
|
return buf;
|
|
}
|
|
|
|
/* open the file, necessary to go to RUNNING state */
|
|
static gboolean
|
|
cdparanoia_open (CDParanoia *src)
|
|
{
|
|
gint i;
|
|
gint paranoia_mode;
|
|
|
|
g_return_val_if_fail (!GST_FLAG_IS_SET (src, CDPARANOIA_OPEN), FALSE);
|
|
|
|
GST_DEBUG_ENTER("(\"%s\",...)", gst_element_get_name (GST_ELEMENT (src)));
|
|
|
|
// find the device
|
|
if (src->generic_device != NULL) {
|
|
src->d = cdda_identify_scsi (src->generic_device, src->device, FALSE, NULL);
|
|
} else {
|
|
if (src->device != NULL) {
|
|
src->d = cdda_identify (src->device, FALSE, NULL);
|
|
} else {
|
|
src->d = cdda_identify ("/dev/cdrom", FALSE, NULL);
|
|
}
|
|
}
|
|
|
|
// fail if the device couldn't be found
|
|
if (src->d == NULL) {
|
|
GST_DEBUG (0,"couldn't open device\n");
|
|
return FALSE;
|
|
}
|
|
|
|
// set verbosity mode
|
|
cdda_verbose_set (src->d, CDDA_MESSAGE_FORGETIT, CDDA_MESSAGE_FORGETIT);
|
|
|
|
// set various other parameters
|
|
if (src->default_sectors != -1) {
|
|
if ((src->default_sectors < 0) || (src->default_sectors > 100)) {
|
|
GST_DEBUG (0,"default sector read size must be 1 <= n <= 100\n");
|
|
cdda_close (src->d);
|
|
src->d = NULL;
|
|
return FALSE;
|
|
} else {
|
|
src->d->nsectors = src->default_sectors;
|
|
src->d->bigbuff = src->default_sectors * CD_FRAMESIZE_RAW;
|
|
}
|
|
}
|
|
if (src->search_overlap != -1) {
|
|
if ((src->search_overlap < 0) || (src->search_overlap > 75)) {
|
|
GST_DEBUG (0,"search overlap must be 0 <= n <= 75\n");
|
|
cdda_close (src->d);
|
|
src->d = NULL;
|
|
return FALSE;
|
|
}
|
|
}
|
|
|
|
// open the disc
|
|
if (cdda_open (src->d)) {
|
|
GST_DEBUG (0,"couldn't open disc\n");
|
|
cdda_close (src->d);
|
|
src->d = NULL;
|
|
return FALSE;
|
|
}
|
|
|
|
// set up some more stuff
|
|
if (src->toc_bias) {
|
|
src->toc_offset -= cdda_track_firstsector (src->d, 1);
|
|
}
|
|
for (i=0;i<src->d->tracks + 1;i++) {
|
|
src->d->disc_toc[i].dwStartSector += src->toc_offset;
|
|
}
|
|
|
|
if (src->read_speed != -1) {
|
|
cdda_speed_set (src->d, src->read_speed);
|
|
}
|
|
|
|
// if the start_track is set, override the start_sector
|
|
if (src->start_track != -1) {
|
|
src->start_sector = cdda_track_firstsector (src->d, src->start_track);
|
|
// if neither start_track nor start_sector is set,
|
|
} else if (src->start_sector == -1) {
|
|
src->start_sector = cdda_disc_firstsector (src->d);
|
|
}
|
|
// if the end_track is set, override the end_sector
|
|
if (src->end_track != -1) {
|
|
src->end_sector = cdda_track_lastsector (src->d, src->end_track);
|
|
// if neither end_track nor end_sector is set,
|
|
} else if (src->end_sector == -1) {
|
|
src->end_sector = cdda_disc_lastsector (src->d);
|
|
}
|
|
|
|
// set last_track
|
|
src->last_track = cdda_tracks (src->d);
|
|
|
|
// create the paranoia struct and set it up
|
|
src->p = paranoia_init (src->d);
|
|
if (src->p == NULL) {
|
|
GST_DEBUG (0,"couldn't create paranoia struct\n");
|
|
return FALSE;
|
|
}
|
|
|
|
if (src->paranoia_mode == 0) paranoia_mode = PARANOIA_MODE_DISABLE;
|
|
else if (src->paranoia_mode == 1) paranoia_mode = PARANOIA_MODE_OVERLAP;
|
|
else paranoia_mode = PARANOIA_MODE_FULL;
|
|
if (src->never_skip) paranoia_mode |= PARANOIA_MODE_NEVERSKIP;
|
|
paranoia_modeset (src->p, paranoia_mode);
|
|
|
|
if (src->search_overlap != -1) {
|
|
paranoia_overlapset (src->p, src->search_overlap);
|
|
}
|
|
|
|
src->cur_sector = src->start_sector;
|
|
paranoia_seek (src->p, src->cur_sector, SEEK_SET);
|
|
GST_DEBUG (0,"successfully seek'd to beginning of disk\n");
|
|
|
|
GST_FLAG_SET (src, CDPARANOIA_OPEN);
|
|
|
|
GST_DEBUG_LEAVE("");
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
/* close the file */
|
|
static void
|
|
cdparanoia_close (CDParanoia *src)
|
|
{
|
|
g_return_if_fail (GST_FLAG_IS_SET (src, CDPARANOIA_OPEN));
|
|
|
|
// kill the paranoia state
|
|
paranoia_free (src->p);
|
|
src->p = NULL;
|
|
|
|
// close the disc
|
|
cdda_close (src->d);
|
|
src->d = NULL;
|
|
|
|
GST_FLAG_UNSET (src, CDPARANOIA_OPEN);
|
|
}
|
|
|
|
static GstElementStateReturn
|
|
cdparanoia_change_state (GstElement *element)
|
|
{
|
|
g_return_val_if_fail (GST_IS_CDPARANOIA (element), GST_STATE_FAILURE);
|
|
|
|
/* if going down into NULL state, close the file if it's open */
|
|
if (GST_STATE_PENDING (element) == GST_STATE_NULL) {
|
|
if (GST_FLAG_IS_SET (element, CDPARANOIA_OPEN))
|
|
cdparanoia_close (CDPARANOIA (element));
|
|
/* otherwise (READY or higher) we need to open the file */
|
|
} else {
|
|
if (!GST_FLAG_IS_SET (element, CDPARANOIA_OPEN)) {
|
|
if (!cdparanoia_open (CDPARANOIA (element))) {
|
|
g_print("failed opening cd\n");
|
|
return GST_STATE_FAILURE;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* if we haven't failed already, give the parent class a chance too ;-) */
|
|
if (GST_ELEMENT_CLASS (parent_class)->change_state)
|
|
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
|
|
|
|
return GST_STATE_SUCCESS;
|
|
}
|
|
|
|
static gboolean
|
|
plugin_init (GModule *module, GstPlugin *plugin)
|
|
{
|
|
GstElementFactory *factory;
|
|
|
|
/* create an elementfactory for the cdparanoia element */
|
|
factory = gst_elementfactory_new ("cdparanoia", GST_TYPE_CDPARANOIA,
|
|
&cdparanoia_details);
|
|
g_return_val_if_fail (factory != NULL, FALSE);
|
|
|
|
/* register the source's caps */
|
|
gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (cdparanoia_src_factory));
|
|
|
|
/* and add the cdparanoia element factory to the plugin */
|
|
gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
GstPluginDesc plugin_desc = {
|
|
GST_VERSION_MAJOR,
|
|
GST_VERSION_MINOR,
|
|
"cdparanoia",
|
|
plugin_init
|
|
};
|