20841N/A@@ -740,6 +740,24 @@ AG_GST_CHECK_FEATURE(CAIRO_GOBJECT,
20841N/A AG_GST_PKG_CHECK_MODULES(CAIRO_GOBJECT, cairo-gobject >= 1.10.0)
15635N/A+translit(dnm, m, l) AM_CONDITIONAL(USE_CDDA2WAV, true)
15635N/A+AG_GST_CHECK_FEATURE(CDDA2WAV, [HAL libraries], cdda2wav, [
15635N/A+ AG_GST_PKG_CHECK_MODULES(CDDA2WAV, [hal >= 0.5.8, hal-storage >= 0.5.8, dbus-1 >= 0.32])
15722N/A+ AC_PATH_PROG(CDDA2WAVBIN, cdda2wav, no)
15722N/A+ if test x$CDDA2WAVBIN = xno; then
15722N/A+ CDDA_VERSION=`$CDDA2WAVBIN --version | grep Schilling`
15722N/A+ if test -z "$CDDA_VERSION"; then
10819N/A translit(dnm, m, l) AM_CONDITIONAL(USE_ESD, true)
10819N/A AG_GST_CHECK_FEATURE(ESD, [ESounD sound daemon], esdsink, [
20841N/A@@ -1058,6 +1076,7 @@ AM_CONDITIONAL(USE_CAIRO_GOBJECT, false)
15256N/A AM_CONDITIONAL(USE_DIRECTSOUND, false)
15256N/A AM_CONDITIONAL(USE_DV1394, false)
15635N/A+AM_CONDITIONAL(USE_CDDA2WAV, false)
10828N/A AM_CONDITIONAL(USE_FLAC, false)
10828N/A AM_CONDITIONAL(USE_GCONF, false)
15256N/A AM_CONDITIONAL(USE_GCONFTOOL, false)
12239N/A+ $(GST_PLUGINS_BASE_LIBS) -lgstcdda-$(GST_MAJORMINOR) \
15635N/A+libgstcdda2wav_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
15635N/A+ * Copyright (C) 2007 Brian Cameron <Brian.Cameron@sun.com> and
10819N/A+ * Artem Kachitchkine <Artem.Kachitchkine@sun.com>
16148N/A+ * Copyright (C) 2008 J�rg Schilling <Joerg.Schilling@fokus.fraunhofer.de>
10819N/A+ * This library is free software; you can redistribute it
and/or 10819N/A+ * modify it under the terms of the GNU Library General Public
10819N/A+ * License as published by the Free Software Foundation; either
10819N/A+ * version 2 of the License, or (at your option) any later version.
10819N/A+ * This library is distributed in the hope that it will be useful,
10819N/A+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
10819N/A+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
10819N/A+ * Library General Public License for more details.
10819N/A+ * You should have received a copy of the GNU Library General Public
10819N/A+ * License along with this library; if not, write to the
10819N/A+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
15635N/A+#define GST_TYPE_CDDA2WAV (gst_cdda2wav_get_type())
15635N/A+#define GST_CDDA2WAV(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CDDA2WAV,GstCdda2Wav))
15635N/A+#define GST_CDDA2WAV_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CDDA2WAV,GstCdda2WavClass))
15635N/A+#define GST_IS_CDDA2WAV(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CDDA2WAV))
15635N/A+#define GST_IS_CDDA2WAV_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CDDA2WAV))
15635N/A+#define GST_CDDA2WAV_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GST_TYPE_CDDA2WAV, GstCdda2WavClass))
15635N/A+typedef struct _GstCdda2Wav GstCdda2Wav;
15635N/A+typedef struct _GstCdda2WavClass GstCdda2WavClass;
15635N/A+ * The cdda2wav object structure.
10819N/A+ GstCddaBaseSrcClass parent_class;
15635N/A+GType gst_cdda2wav_get_type (void);
15635N/A+#endif /* __GST_CDDA2WAV_H__ */
15635N/A+ * Copyright (C) <2007> Brian Cameron <Brian.Cameron@sun.com> and
15635N/A+ * Artem Kachitchkine <Artem.Kachitchkine@sun.com>
16148N/A+ * Copyright (C) 2008 J�rg Schilling <Joerg.Schilling@fokus.fraunhofer.de>
10819N/A+ * This library is free software; you can redistribute it
and/or 10819N/A+ * modify it under the terms of the GNU Library General Public
10819N/A+ * License as published by the Free Software Foundation; either
10819N/A+ * version 2 of the License, or (at your option) any later version.
10819N/A+ * This library is distributed in the hope that it will be useful,
10819N/A+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
10819N/A+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
10819N/A+ * Library General Public License for more details.
10819N/A+ * You should have received a copy of the GNU Library General Public
10819N/A+ * License along with this library; if not, write to the
10819N/A+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
10819N/A+ * @short_description: Reads raw audio from an Audio CD
15635N/A+ * cdda2wav reads and extracts raw audio from Audio CDs using cdda2wav.
10819N/A+ * <title>Example launch line</title>
15635N/A+ * gst-launch cdda2wav track=5 ! audioconvert ! vorbisenc ! oggmux ! filesink location=
track5.ogg 10819N/A+ * This pipeline extracts track 5 of the audio CD and encodes it into an
15635N/A+#define HAVE_POLL /* XXX Need autoconf test */
15635N/A+GST_DEBUG_CATEGORY_STATIC (gst_cdda2wav_debug);
15635N/A+#define GST_CAT_DEFAULT gst_cdda2wav_debug
15635N/A+GST_BOILERPLATE (GstCdda2Wav, gst_cdda2wav, GstCddaBaseSrc,
15635N/A+static void gst_cdda2wav_finalize (GObject * obj);
15635N/A+static GstBuffer *gst_cdda2wav_read_sector (GstCddaBaseSrc * src,
15635N/A+static gboolean gst_cdda2wav_open (GstCddaBaseSrc * src,
15635N/A+static void gst_cdda2wav_close (GstCddaBaseSrc * src);
15635N/A+static gchar **gst_cdda2wav_probe_devices (GstCddaBaseSrc * cddabasesrc);
15635N/A+static gchar *gst_cdda2wav_get_default_device (GstCddaBaseSrc * cddabasesrc);
15635N/A+static void gst_cdda2wav_set_property (GObject * object, guint prop_id,
10819N/A+ const GValue * value, GParamSpec * pspec);
15635N/A+static void gst_cdda2wav_get_property (GObject * object, guint prop_id,
10819N/A+ GValue * value, GParamSpec * pspec);
15635N/A+static void gst_cdda2wav_hal_find_cdroms (GstCdda2Wav *);
15635N/A+static pid_t xpopen(FILE **pfpin, FILE **pfpout, FILE **pfperr, const char *cmd);
15635N/A+static int xpclose(FILE *fpin, FILE *fpout, FILE *fperr, pid_t child);
15635N/A+static const GstElementDetails cdda2wav_details =
10819N/A+GST_ELEMENT_DETAILS ("CD Audio (cdda) Source",
15635N/A+ "Brian Cameron <Brian.Cameron@sun.com>, " "Artem Kachitchkine <Artem.Kachitchkine@sun.com>, "
15635N/A+ "Joerg Schilling <Joerg.Schilling@fokus.fraunhofer.de>");
15635N/A+gst_cdda2wav_base_init (gpointer g_class)
10819N/A+ GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
15635N/A+ gst_element_class_set_details (element_class, &cdda2wav_details);
15635N/A+gst_cdda2wav_init (GstCdda2Wav * src, GstCdda2WavClass * klass)
15635N/A+gst_cdda2wav_class_init (GstCdda2WavClass * klass)
10819N/A+ GstCddaBaseSrcClass *cddabasesrc_class = GST_CDDA_BASE_SRC_CLASS (klass);
10819N/A+ GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
15635N/A+ gobject_class->set_property = gst_cdda2wav_set_property;
15635N/A+ gobject_class->get_property = gst_cdda2wav_get_property;
15635N/A+ gobject_class->finalize = gst_cdda2wav_finalize;
15635N/A+ cddabasesrc_class->open = gst_cdda2wav_open;
15635N/A+ cddabasesrc_class->close = gst_cdda2wav_close;
15635N/A+ cddabasesrc_class->read_sector = gst_cdda2wav_read_sector;
15635N/A+ cddabasesrc_class->get_default_device = gst_cdda2wav_get_default_device;
15635N/A+ cddabasesrc_class->probe_devices = gst_cdda2wav_probe_devices;
15635N/A+gst_cdda2wav_probe_devices (GstCddaBaseSrc * cddabasesrc)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (cddabasesrc);
15635N/A+ gst_cdda2wav_hal_find_cdroms (src);
15635N/A+gst_cdda2wav_get_default_device (GstCddaBaseSrc * cddabasesrc)
15635N/A+ src = GST_CDDA2WAV (cddabasesrc);
15635N/A+ gst_cdda2wav_probe_devices (cddabasesrc);
10819N/A+ /* prefer a drive with an audio disc, otherwise pick first */
10819N/A+ for (i = 0; src->devices[i] != NULL; i++) {
10819N/A+ GST_LOG_OBJECT (src, "returning default device: %s", GST_STR_NULL (ret));
15635N/A+cdda2wav_read_toc (GstCdda2Wav *src)
15635N/A+ GstCddaBaseSrcTrack tracks[100];
15635N/A+ /* Open the connection to cdda2wav */
15635N/A+ while (fgets (buf, BUFSIZ, f) != NULL) {
15635N/A+ track_num = buf[2] - '0' + (buf[1] - '0') * 10;
15635N/A+ tracks[i].is_audio = strstr((buf + 4), "audio") != 0;
15635N/A+ tracks[i].num = buf[2] - '0' + (buf[1] - '0') * 10;
15635N/A+ tracks[i].start = (guint) (g_ascii_strtod ((buf + 4), &endptr));
15635N/A+ fprintf(stderr, "Track %2.2d %2.2d audio %d start %u\n",
15635N/A+ i, tracks[i].num, tracks[i].is_audio, tracks[i].start);
15635N/A+ if (strncmp (buf, "Leadout:", 8) == 0) {
15635N/A+ leadout = (guint) (g_ascii_strtod ((buf + 8), &endptr));
15635N/A+ for (i=0; i < track_num; i++) {
10819N/A+ GstCddaBaseSrcTrack track = { 0, };
10819N/A+ gst_cdda_base_src_add_track (GST_CDDA_BASE_SRC (src), &track);
15635N/A+ src->track_count = track_num + 1;
15635N/A+gst_cdda2wav_open (GstCddaBaseSrc * cddabasesrc, const gchar * device)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (cddabasesrc);
15635N/A+ GST_LOG_OBJECT (src, "Trying to open device %s", device);
15635N/A+ src->current_device = g_strdup (device);
15635N/A+ ret = cdda2wav_read_toc (src);
15635N/A+gst_cdda_close (GstCdda2Wav * src)
15635N/A+ rc = xpclose (src->cdda2wav_in, src->cdda2wav_out, src->cdda2wav_err,
15635N/A+gst_cdda2wav_close (GstCddaBaseSrc * cddabasesrc)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (cddabasesrc);
15635N/A+ if (src->cdda2wav_err == NULL)
15635N/A+ pfd[0].fd = fileno(src->cdda2wav_err);
15635N/A+ if (poll(pfd, 1, 5000) < 1) /* Give up after 5s */
15635N/A+ p = fgets(buf, sizeof (buf), src->cdda2wav_err);
15635N/A+ fprintf(stderr, "ERR: '%s'\n", buf);
15635N/A+ if (buf[0] >= '0' && buf[0] <= '9' &&
15635N/A+ buf[1] >= '0' && buf[1] <= '9' &&
15635N/A+ buf[2] >= '0' && buf[2] <= '9' &&
15635N/A+ fprintf(stderr, "ERR: %s\n", buf);
15635N/A+ ioctl(fileno(f), FIONREAD, &nread);
15635N/A+ if (fread(fbuf, amt, 1, f) != 1)
15635N/A+sendcmd(GstCdda2Wav *src, const char *fmt, uint_t addr)
15635N/A+ sigaction(SIGPIPE, &my, &old);
15635N/A+ fprintf(src->cdda2wav_in, fmt, addr);
15635N/A+ sigaction(SIGPIPE, &old, NULL);
15635N/A+ if (ferror(src->cdda2wav_in)) {
16148N/A+#if G_BYTE_ORDER == G_LITTLE_ENDIAN
16148N/A+#define CDDA2WAV_BYTE_ORDER "little"
16148N/A+#elif G_BYTE_ORDER == G_BIG_ENDIAN
16148N/A+#define CDDA2WAV_BYTE_ORDER "big"
16148N/A+#error "G_BYTE_ORDER should be big or little endian."
15635N/A+cdda2wav_read (GstCdda2Wav *src, void *buf, uint_t addr, uint_t len)
15635N/A+ gboolean do_paranoia = FALSE; /* Need to be parameterized from elsewhere */
16148N/A+ CDDA2WAV_BYTE_ORDER, src->current_device,
16148N/A+ do_paranoia ? "-paranoia -paraopts=minoverlap=2":"");
15635N/A+ src->cdda2wav_pid = xpopen (&src->cdda2wav_in, &src->cdda2wav_out,
15635N/A+ fprintf(stderr, "PID %d\n", src->cdda2wav_pid);
15635N/A+ if (!sendcmd(src, "read sectors %u\n", addr))
15635N/A+ } else if (addr != (last_addr + 1)) { /* Check whether we need to seek */
15635N/A+ if (!sendcmd(src, "stop\n", 0))
15635N/A+ if (!sendcmd(src, "stop\n", 0))
15635N/A+ ioctl(fileno(src->cdda2wav_out), FIONREAD, &nread);
15635N/A+ if (!sendcmd(src, "read sectors %u\n", addr))
15635N/A+ if (fread (buf, CDDA2WAV_BSIZE, len, src->cdda2wav_out) != len) {
15635N/A+ if (feof(src->cdda2wav_out)) {
15635N/A+ if (gst_cdda_close (src) == 0)
15635N/A+gst_cdda2wav_read_sector (GstCddaBaseSrc * cddabasesrc, gint sector)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (cddabasesrc);
15635N/A+ buf = gst_buffer_new_and_alloc (CDDA2WAV_BSIZE);
15635N/A+ if (!cdda2wav_read (src, GST_BUFFER_DATA (buf), sector, 1)) {
15635N/A+gst_cdda2wav_finalize (GObject * obj)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (obj);
10819N/A+ G_OBJECT_CLASS (parent_class)->finalize (obj);
10819N/A+plugin_init (GstPlugin * plugin)
15635N/A+ GST_DEBUG_CATEGORY_INIT (gst_cdda2wav_debug, "cdda2wav", 0,
15635N/A+ if (!gst_element_register (plugin, "cdda2wav", GST_RANK_SECONDARY,
10819N/A+ GST_DEBUG ("binding text domain %s to locale dir %s", GETTEXT_PACKAGE,
10819N/A+ bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
15635N/A+gst_cdda2wav_set_property (GObject * object, guint prop_id,
10819N/A+ const GValue * value, GParamSpec * pspec)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (object);
10819N/A+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
15635N/A+gst_cdda2wav_get_property (GObject * object, guint prop_id,
10819N/A+ GValue * value, GParamSpec * pspec)
15635N/A+ GstCdda2Wav *src = GST_CDDA2WAV (object);
10819N/A+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
10819N/A+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
10819N/A+ plugin_init, VERSION, "GPL", GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)
15635N/A+gst_cdda2wav_hal_init (GstCdda2Wav *src)
10819N/A+ LibHalContext *hal_ctx = NULL;
10819N/A+ if ((hal_ctx = libhal_ctx_new ()) == NULL) {
10819N/A+ GST_ELEMENT_ERROR (src, LIBRARY, INIT,
10819N/A+ ("failed to initialize HAL"), ("failed to initialize HAL"));
10819N/A+ if (!libhal_ctx_set_dbus_connection(hal_ctx,
10819N/A+ dbus_bus_get (DBUS_BUS_SYSTEM, &error))) {
10819N/A+ GST_ELEMENT_ERROR (src, LIBRARY, INIT,
10819N/A+ if (!libhal_ctx_init(hal_ctx, &error)) {
10819N/A+ GST_ELEMENT_ERROR (src, LIBRARY, INIT,
15635N/A+gst_cdda2wav_hal_fini (LibHalContext *hal_ctx)
10819N/A+ libhal_ctx_shutdown (hal_ctx, &error);
15635N/A+gst_cdda2wav_hal_find_cdroms (GstCdda2Wav *src)
10819N/A+ char **drive_udis, **volume_udis;
15635N/A+ if ((hal_ctx = gst_cdda2wav_hal_init (src)) == NULL) {
10819N/A+ if (dbus_error_is_set (&error) || drive_udis == NULL) {
10819N/A+ src->devices = calloc (num_drives + 1, sizeof (char *));
10819N/A+ src->has_audio = calloc (num_drives + 1, sizeof (boolean_t));
10819N/A+ for (i = j = 0; i < num_drives; i++) {
10819N/A+ raw_device = libhal_device_get_property_string (hal_ctx,
10819N/A+ if ((raw_device == NULL) || (strlen (raw_device) == 0)) {
10819N/A+ libhal_free_string (raw_device);
10819N/A+ src->devices[j] = strdup (raw_device);
10819N/A+ libhal_free_string (raw_device);
10819N/A+ /* check for audio disc in this drive */
10819N/A+ if ((drive = libhal_drive_from_udi (hal_ctx, drive_udis[i])) != NULL) {
10819N/A+ if ((volume_udis = libhal_drive_find_all_volumes (hal_ctx,
10819N/A+ drive, &num_volumes)) != NULL) {
10819N/A+ for (k = 0; k < num_volumes; k++) {
10819N/A+ src->has_audio[j] = (boolean_t)
10819N/A+ libhal_device_get_property_bool (hal_ctx,
10819N/A+ libhal_free_string_array (volume_udis);
10819N/A+ libhal_free_string_array (drive_udis);
15635N/A+ gst_cdda2wav_hal_fini (hal_ctx);
15635N/A+#define HAVE_SYS_FORK_H /* XXX Need autoconf test */
15635N/A+xpopen(FILE **pfpin, FILE **pfpout, FILE **pfperr, const char *cmd)
15635N/A+ pid = vforkx(FORK_NOSIGCHLD|FORK_WAITPID);
15635N/A+ pid = vfork(); /* Need to find a way to deal with SIGCHLD and wait */
15722N/A+ xpclose(NULL, NULL, NULL, pid);
15635N/A+ *pfpout = fdopen(out[0], "r");
15722N/A+ xpclose(*pfpin, NULL, NULL, pid);
15635N/A+ *pfperr = fdopen(err[0], "r");
15722N/A+ xpclose(*pfpin, *pfpout, NULL, pid);
15635N/A+ if (out[1] != STDOUT_FILENO) {
15635N/A+ if (err[1] != STDERR_FILENO) {
15635N/A+xpclose(FILE *fpin, FILE *fpout, FILE *fperr, pid_t child)
15635N/A+ if (waitpid(child, &status, WNOHANG) == child)
15635N/A+ while (waitpid(child, &status, 0) < 0) {