mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-12-27 02:30:35 +00:00
b5af832d7b
Original commit message from CVS: * ext/aalib/gstaasink.c: (gst_aasink_class_init): * ext/esd/esdsink.c: (gst_esdsink_class_init): * ext/flac/gstflactag.c: (gst_flac_tag_class_init): * ext/gdk_pixbuf/gstgdkpixbuf.c: (gst_gdk_pixbuf_class_init): * ext/jpeg/gstjpegenc.c: (gst_jpegenc_class_init): * ext/jpeg/gstsmokedec.c: (gst_smokedec_class_init): * ext/jpeg/gstsmokeenc.c: (gst_smokeenc_class_init): * ext/libcaca/gstcacasink.c: (gst_cacasink_class_init): * ext/libmng/gstmngdec.c: (gst_mngdec_class_init): * ext/libmng/gstmngenc.c: (gst_mngenc_class_init): * ext/libpng/gstpngdec.c: (gst_pngdec_class_init): * ext/libpng/gstpngenc.c: (gst_pngenc_class_init): * ext/mikmod/gstmikmod.c: (gst_mikmod_class_init): * ext/shout2/gstshout2.c: (gst_shout2send_class_init): * ext/speex/gstspeexenc.c: (gst_speexenc_class_init): * gst/alpha/gstalpha.c: (gst_alpha_class_init): * gst/avi/gstavimux.c: (gst_avimux_class_init): * gst/debug/efence.c: (gst_efence_class_init): * gst/debug/negotiation.c: (gst_negotiation_class_init): * gst/flx/gstflxdec.c: (gst_flxdec_class_init): * gst/goom/gstgoom.c: (gst_goom_class_init): * gst/id3demux/gstid3demux.c: (gst_id3demux_class_init): * gst/interleave/deinterleave.c: (deinterleave_class_init): * gst/interleave/interleave.c: (interleave_class_init): * gst/law/alaw-decode.c: (gst_alawdec_class_init): * gst/law/alaw-encode.c: (gst_alawenc_class_init): * gst/law/mulaw-encode.c: (gst_mulawenc_class_init): * gst/median/gstmedian.c: (gst_median_class_init): * gst/monoscope/gstmonoscope.c: (gst_monoscope_class_init): * gst/multipart/multipartmux.c: (gst_multipart_mux_class_init): * gst/rtp/gstasteriskh263.c: (gst_asteriskh263_class_init): * gst/rtp/gstrtpL16depay.c: (gst_rtp_L16depay_class_init): * gst/rtp/gstrtpL16pay.c: (gst_rtpL16pay_class_init): * gst/rtp/gstrtpamrdepay.c: (gst_rtp_amr_depay_class_init): * gst/rtp/gstrtpamrpay.c: (gst_rtp_amr_pay_class_init): * gst/rtp/gstrtpdepay.c: (gst_rtp_depay_class_init): * gst/rtp/gstrtpgsmdepay.c: (gst_rtp_gsm_depay_class_init): * gst/rtp/gstrtpgsmpay.c: (gst_rtp_gsm_pay_class_init): * gst/rtp/gstrtph263pay.c: (gst_rtp_h263_pay_class_init): * gst/rtp/gstrtph263pdepay.c: (gst_rtp_h263p_depay_class_init): * gst/rtp/gstrtph263ppay.c: (gst_rtp_h263p_pay_class_init): * gst/rtp/gstrtpmp4gpay.c: (gst_rtp_mp4g_pay_class_init): * gst/rtp/gstrtpmp4vdepay.c: (gst_rtp_mp4v_depay_class_init): * gst/rtp/gstrtpmp4vpay.c: (gst_rtp_mp4v_pay_class_init): * gst/rtp/gstrtpmpadepay.c: (gst_rtp_mpa_depay_class_init): * gst/rtp/gstrtpmpapay.c: (gst_rtp_mpa_pay_class_init): * gst/rtp/gstrtppcmadepay.c: (gst_rtp_pcma_depay_class_init): * gst/rtp/gstrtppcmapay.c: (gst_rtp_pcma_pay_class_init): * gst/rtp/gstrtppcmudepay.c: (gst_rtp_pcmu_depay_class_init): * gst/rtp/gstrtppcmupay.c: (gst_rtp_pcmu_pay_class_init): * gst/rtp/gstrtpspeexdepay.c: (gst_rtp_speex_depay_class_init): * gst/rtp/gstrtpspeexpay.c: (gst_rtp_speex_pay_class_init): * gst/rtsp/gstrtpdec.c: (gst_rtpdec_class_init): * gst/rtsp/gstrtspsrc.c: (gst_rtspsrc_class_init): * gst/smpte/gstsmpte.c: (gst_smpte_class_init): * gst/udp/gstdynudpsink.c: (gst_dynudpsink_class_init): * gst/udp/gstmultiudpsink.c: (gst_multiudpsink_class_init): * gst/udp/gstudpsink.c: (gst_udpsink_class_init): * gst/videomixer/videomixer.c: (gst_videomixer_class_init): * gst/wavenc/gstwavenc.c: (gst_wavenc_class_init): * sys/oss/gstossdmabuffer.c: (gst_ossdmabuffer_class_init): * sys/oss/gstosssink.c: (gst_oss_sink_class_init): * sys/osxaudio/gstosxaudioelement.c: (gst_osxaudioelement_class_init): * sys/osxaudio/gstosxaudiosink.c: (gst_osxaudiosink_class_init): * sys/osxaudio/gstosxaudiosrc.c: (gst_osxaudiosrc_class_init): * sys/sunaudio/gstsunaudiosink.c: (gst_sunaudiosink_class_init): Fix #337365 (g_type_class_ref <-> g_type_class_peek_parent)
333 lines
8.2 KiB
C
333 lines
8.2 KiB
C
/* GStreamer
|
|
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
|
|
* 2005 Wim Taymans <wim@fluendo.com>
|
|
*
|
|
* gstossdmabuffer.c:
|
|
*
|
|
* 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.
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#include <string.h>
|
|
#include <sys/types.h>
|
|
#include <sys/mman.h>
|
|
|
|
#ifdef HAVE_OSS_INCLUDE_IN_SYS
|
|
# include <sys/soundcard.h>
|
|
#else
|
|
# ifdef HAVE_OSS_INCLUDE_IN_ROOT
|
|
# include <soundcard.h>
|
|
# else
|
|
# ifdef HAVE_OSS_INCLUDE_IN_MACHINE
|
|
# include <machine/soundcard.h>
|
|
# else
|
|
# error "What to include?"
|
|
# endif /* HAVE_OSS_INCLUDE_IN_MACHINE */
|
|
# endif /* HAVE_OSS_INCLUDE_IN_ROOT */
|
|
#endif /* HAVE_OSS_INCLUDE_IN_SYS */
|
|
|
|
#include <sys/time.h>
|
|
#include <sys/ioctl.h>
|
|
#include <pthread.h>
|
|
|
|
#include "gstossdmabuffer.h"
|
|
|
|
GST_DEBUG_CATEGORY_EXTERN (oss_debug);
|
|
#define GST_CAT_DEFAULT oss_debug
|
|
|
|
static void gst_ossdmabuffer_class_init (GstOssDMABufferClass * klass);
|
|
static void gst_ossdmabuffer_init (GstOssDMABuffer * ossdmabuffer);
|
|
static void gst_ossdmabuffer_dispose (GObject * object);
|
|
static void gst_ossdmabuffer_finalize (GObject * object);
|
|
|
|
static gboolean gst_ossdmabuffer_acquire (GstRingBuffer * buf,
|
|
GstRingBufferSpec * spec);
|
|
static gboolean gst_ossdmabuffer_release (GstRingBuffer * buf);
|
|
static gboolean gst_ossdmabuffer_play (GstRingBuffer * buf);
|
|
static gboolean gst_ossdmabuffer_stop (GstRingBuffer * buf);
|
|
|
|
static GstRingBufferClass *parent_class = NULL;
|
|
|
|
GType
|
|
gst_ossdmabuffer_get_type (void)
|
|
{
|
|
static GType ossdmabuffer_type = 0;
|
|
|
|
if (!ossdmabuffer_type) {
|
|
static const GTypeInfo ossdmabuffer_info = {
|
|
sizeof (GstOssDMABufferClass),
|
|
NULL,
|
|
NULL,
|
|
(GClassInitFunc) gst_ossdmabuffer_class_init,
|
|
NULL,
|
|
NULL,
|
|
sizeof (GstOssDMABuffer),
|
|
0,
|
|
(GInstanceInitFunc) gst_ossdmabuffer_init,
|
|
NULL
|
|
};
|
|
|
|
ossdmabuffer_type =
|
|
g_type_register_static (GST_TYPE_RINGBUFFER, "GstOssDMABuffer",
|
|
&ossdmabuffer_info, 0);
|
|
}
|
|
return ossdmabuffer_type;
|
|
}
|
|
|
|
static void
|
|
gst_ossdmabuffer_class_init (GstOssDMABufferClass * klass)
|
|
{
|
|
GObjectClass *gobject_class;
|
|
GstObjectClass *gstobject_class;
|
|
GstRingBufferClass *gstringbuffer_class;
|
|
|
|
gobject_class = (GObjectClass *) klass;
|
|
gstobject_class = (GstObjectClass *) klass;
|
|
gstringbuffer_class = (GstRingBufferClass *) klass;
|
|
|
|
parent_class = g_type_class_peek_parent (klass);
|
|
|
|
gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_ossdmabuffer_dispose);
|
|
gobject_class->finalize = GST_DEBUG_FUNCPTR (gst_ossdmabuffer_finalize);
|
|
|
|
gstringbuffer_class->acquire = gst_ossdmabuffer_acquire;
|
|
gstringbuffer_class->release = gst_ossdmabuffer_release;
|
|
gstringbuffer_class->play = gst_ossdmabuffer_play;
|
|
gstringbuffer_class->stop = gst_ossdmabuffer_stop;
|
|
}
|
|
|
|
static void
|
|
gst_ossdmabuffer_init (GstOssDMABuffer * ossdmabuffer)
|
|
{
|
|
ossdmabuffer->cond = g_cond_new ();
|
|
ossdmabuffer->element = g_object_new (GST_TYPE_OSSELEMENT, NULL);
|
|
}
|
|
|
|
static void
|
|
gst_ossdmabuffer_dispose (GObject * object)
|
|
{
|
|
G_OBJECT_CLASS (parent_class)->dispose (object);
|
|
}
|
|
|
|
static void
|
|
gst_ossdmabuffer_finalize (GObject * object)
|
|
{
|
|
GstOssDMABuffer *obuf = (GstOssDMABuffer *) object;
|
|
|
|
g_cond_free (obuf->cond);
|
|
|
|
G_OBJECT_CLASS (parent_class)->finalize (object);
|
|
}
|
|
|
|
static void
|
|
gst_ossdmabuffer_func (GstRingBuffer * buf)
|
|
{
|
|
fd_set writeset;
|
|
struct count_info count;
|
|
GstOssDMABuffer *obuf = (GstOssDMABuffer *) buf;
|
|
|
|
GST_OBJECT_LOCK (buf);
|
|
while (obuf->running) {
|
|
if (buf->state == GST_RINGBUFFER_STATE_PLAYING) {
|
|
int segsize;
|
|
|
|
GST_OBJECT_UNLOCK (buf);
|
|
|
|
segsize = buf->spec.segsize;
|
|
|
|
FD_ZERO (&writeset);
|
|
FD_SET (obuf->fd, &writeset);
|
|
|
|
select (obuf->fd + 1, NULL, &writeset, NULL, NULL);
|
|
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_GETOPTR, &count) == -1) {
|
|
perror ("GETOPTR");
|
|
continue;
|
|
}
|
|
|
|
if (count.blocks > buf->spec.segtotal)
|
|
count.blocks = buf->spec.segtotal;
|
|
|
|
gst_ringbuffer_callback (buf, count.blocks);
|
|
|
|
GST_OBJECT_LOCK (buf);
|
|
} else {
|
|
GST_OSSDMABUFFER_SIGNAL (obuf);
|
|
GST_OSSDMABUFFER_WAIT (obuf);
|
|
}
|
|
}
|
|
GST_OBJECT_UNLOCK (buf);
|
|
}
|
|
|
|
static gboolean
|
|
gst_ossdmabuffer_acquire (GstRingBuffer * buf, GstRingBufferSpec * spec)
|
|
{
|
|
int tmp;
|
|
struct audio_buf_info info;
|
|
GstOssDMABuffer *obuf = (GstOssDMABuffer *) buf;;
|
|
caddr_t mmap_buf;
|
|
int mode;
|
|
gint size;
|
|
gboolean parsed;
|
|
|
|
parsed = gst_osselement_parse_caps (obuf->element, spec->caps);
|
|
if (!parsed)
|
|
return FALSE;
|
|
|
|
mode = O_RDWR;
|
|
mode |= O_NONBLOCK;
|
|
|
|
obuf->fd = open ("/dev/dsp", mode, 0);
|
|
if (obuf->fd == -1) {
|
|
perror ("OPEN");
|
|
return FALSE;
|
|
}
|
|
//obuf->frag = 0x00040008;
|
|
obuf->frag = 0xffff000a;
|
|
|
|
tmp = obuf->element->format;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SETFMT, &tmp) == -1) {
|
|
perror ("SETFMT");
|
|
return FALSE;
|
|
}
|
|
|
|
tmp = obuf->element->channels;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_STEREO, &tmp) == -1) {
|
|
perror ("STEREO");
|
|
return FALSE;
|
|
}
|
|
|
|
tmp = obuf->element->channels;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_CHANNELS, &tmp) == -1) {
|
|
perror ("CHANNELS");
|
|
return FALSE;
|
|
}
|
|
|
|
tmp = obuf->element->rate;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SPEED, &tmp) == -1) {
|
|
perror ("SPEED");
|
|
return FALSE;
|
|
}
|
|
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_GETCAPS, &obuf->caps) == -1) {
|
|
perror ("/dev/dsp");
|
|
fprintf (stderr, "Sorry but your sound driver is too old\n");
|
|
return FALSE;
|
|
}
|
|
|
|
if (!(obuf->caps & DSP_CAP_TRIGGER) || !(obuf->caps & DSP_CAP_MMAP)) {
|
|
fprintf (stderr, "Sorry but your soundcard can't do this\n");
|
|
return FALSE;
|
|
}
|
|
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SETFRAGMENT, &obuf->frag) == -1) {
|
|
perror ("SETFRAGMENT");
|
|
return FALSE;
|
|
}
|
|
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_GETOSPACE, &info) == -1) {
|
|
perror ("GETOSPACE");
|
|
return FALSE;
|
|
}
|
|
|
|
buf->spec.segsize = info.fragsize;
|
|
buf->spec.segtotal = info.fragstotal;
|
|
size = info.fragsize * info.fragstotal;
|
|
g_print ("segsize %d, segtotal %d\n", info.fragsize, info.fragstotal);
|
|
|
|
mmap_buf = (caddr_t) mmap (NULL, size, PROT_WRITE,
|
|
MAP_FILE | MAP_SHARED, obuf->fd, 0);
|
|
|
|
if ((caddr_t) mmap_buf == (caddr_t) - 1) {
|
|
perror ("mmap (write)");
|
|
return FALSE;
|
|
}
|
|
|
|
buf->data = gst_buffer_new ();
|
|
GST_BUFFER_DATA (buf->data) = mmap_buf;
|
|
GST_BUFFER_SIZE (buf->data) = size;
|
|
GST_BUFFER_FLAG_SET (buf->data, GST_BUFFER_DONTFREE);
|
|
|
|
tmp = 0;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SETTRIGGER, &tmp) == -1) {
|
|
perror ("SETTRIGGER");
|
|
return FALSE;
|
|
}
|
|
|
|
GST_OBJECT_LOCK (obuf);
|
|
obuf->running = TRUE;
|
|
obuf->thread = g_thread_create ((GThreadFunc) gst_ossdmabuffer_func,
|
|
buf, TRUE, NULL);
|
|
GST_OSSDMABUFFER_WAIT (obuf);
|
|
GST_OBJECT_UNLOCK (obuf);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
static gboolean
|
|
gst_ossdmabuffer_release (GstRingBuffer * buf)
|
|
{
|
|
GstOssDMABuffer *obuf = (GstOssDMABuffer *) buf;;
|
|
|
|
gst_buffer_unref (buf->data);
|
|
|
|
GST_OBJECT_LOCK (obuf);
|
|
obuf->running = FALSE;
|
|
GST_OSSDMABUFFER_SIGNAL (obuf);
|
|
GST_OBJECT_UNLOCK (obuf);
|
|
|
|
g_thread_join (obuf->thread);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
static gboolean
|
|
gst_ossdmabuffer_play (GstRingBuffer * buf)
|
|
{
|
|
int tmp;
|
|
GstOssDMABuffer *obuf;
|
|
|
|
obuf = (GstOssDMABuffer *) buf;
|
|
|
|
tmp = PCM_ENABLE_OUTPUT;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SETTRIGGER, &tmp) == -1) {
|
|
perror ("SETTRIGGER");
|
|
}
|
|
GST_OSSDMABUFFER_SIGNAL (obuf);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
static gboolean
|
|
gst_ossdmabuffer_stop (GstRingBuffer * buf)
|
|
{
|
|
int tmp;
|
|
GstOssDMABuffer *obuf;
|
|
|
|
obuf = (GstOssDMABuffer *) buf;
|
|
|
|
tmp = 0;
|
|
if (ioctl (obuf->fd, SNDCTL_DSP_SETTRIGGER, &tmp) == -1) {
|
|
perror ("SETTRIGGER");
|
|
}
|
|
GST_OSSDMABUFFER_WAIT (obuf);
|
|
buf->playseg = 0;
|
|
|
|
return TRUE;
|
|
}
|