+2005-10-12 Stefan Kost <ensonic@users.sf.net>
+
+ * examples/indexing/indexmpeg.c: (main):
+ * ext/cdparanoia/gstcdparanoia.c: (cdparanoia_get),
+ (cdparanoia_open), (cdparanoia_close), (cdparanoia_event),
+ (cdparanoia_convert), (cdparanoia_query):
+ * ext/cdparanoia/gstcdparanoia.h:
+ * ext/gnomevfs/gstgnomevfssink.c: (gst_gnomevfssink_init),
+ (gst_gnomevfssink_open_file), (gst_gnomevfssink_close_file),
+ (gst_gnomevfssink_chain), (gst_gnomevfssink_change_state):
+ * ext/ogg/gstoggmux.c: (gst_ogg_mux_init):
+ * gst/audioscale/gstaudioscale.c: (gst_audioscale_init):
+ * gst/playback/gststreamselector.c: (gst_stream_selector_init):
+ * gst/tcp/gstmultifdsink.c: (gst_multifdsink_init),
+ (gst_multifdsink_render), (gst_multifdsink_start),
+ (gst_multifdsink_stop):
+ * gst/tcp/gstmultifdsink.h:
+ * gst/tcp/gsttcpclientsink.c: (gst_tcpclientsink_init),
+ (gst_tcpclientsink_render), (gst_tcpclientsink_start),
+ (gst_tcpclientsink_stop):
+ * gst/tcp/gsttcpclientsink.h:
+ * gst/tcp/gsttcpclientsrc.c: (gst_tcpclientsrc_init),
+ (gst_tcpclientsrc_getcaps), (gst_tcpclientsrc_create),
+ (gst_tcpclientsrc_start), (gst_tcpclientsrc_stop):
+ * gst/tcp/gsttcpclientsrc.h:
+ * gst/tcp/gsttcpserversink.h:
+ * gst/tcp/gsttcpserversrc.c: (gst_tcpserversrc_init),
+ (gst_tcpserversrc_create), (gst_tcpserversrc_start),
+ (gst_tcpserversrc_stop):
+ * gst/tcp/gsttcpserversrc.h:
+ * sys/v4l/gstv4lmjpegsink.c: (gst_v4lmjpegsink_init):
+ * sys/v4l/gstv4lmjpegsrc.c: (gst_v4lmjpegsrc_init):
+ * sys/ximage/ximagesink.c: (gst_ximagesink_init):
+ renamed GST_FLAGS macros to GST_OBJECT_FLAGS
+ moved bitshift from macro to enum definition
+
2005-10-12 Wim Taymans <wim@fluendo.com>
* examples/seeking/Makefile.am:
gst_element_set_state (pipeline, GST_STATE_PAUSED);
if (index)
- GST_FLAG_UNSET (index, GST_INDEX_WRITABLE);
+ GST_OBJECT_FLAG_UNSET (index, GST_INDEX_WRITABLE);
src = gst_bin_get_by_name (GST_BIN (pipeline), "video_decoder");
src = CDPARANOIA (gst_pad_get_parent (pad));
- g_return_val_if_fail (GST_FLAG_IS_SET (src, CDPARANOIA_OPEN), NULL);
+ g_return_val_if_fail (GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN), NULL);
if (src->seek_request != -1) {
gst_pad_send_event (src->srcpad,
gint i;
gint paranoia_mode;
- g_return_val_if_fail (!GST_FLAG_IS_SET (src, CDPARANOIA_OPEN), FALSE);
+ g_return_val_if_fail (!GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN), FALSE);
GST_DEBUG_OBJECT (src, "trying to open device...");
paranoia_seek (src->p, src->cur_sector, SEEK_SET);
GST_DEBUG ("successfully seek'd to beginning of disk");
- GST_FLAG_SET (src, CDPARANOIA_OPEN);
+ GST_OBJECT_FLAG_SET (src, CDPARANOIA_OPEN);
if (src->index && GST_INDEX_IS_WRITABLE (src->index)) {
add_index_associations (src);
static void
cdparanoia_close (CDParanoia * src)
{
- g_return_if_fail (GST_FLAG_IS_SET (src, CDPARANOIA_OPEN));
+ g_return_if_fail (GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN));
/* kill the paranoia state */
paranoia_free (src->p);
cdda_close (src->d);
src->d = NULL;
- GST_FLAG_UNSET (src, CDPARANOIA_OPEN);
+ GST_OBJECT_FLAG_UNSET (src, CDPARANOIA_OPEN);
}
static GstStateChangeReturn
src = CDPARANOIA (gst_pad_get_parent (pad));
- if (!GST_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
+ if (!GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
GST_DEBUG ("device not open, cannot handle event");
goto error;
}
src = CDPARANOIA (gst_pad_get_parent (pad));
- if (!GST_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
+ if (!GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
return FALSE;
}
src = CDPARANOIA (gst_pad_get_parent (pad));
- if (!GST_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
+ if (!GST_OBJECT_FLAG_IS_SET (src, CDPARANOIA_OPEN)) {
return FALSE;
}
/* NOTE: per-element flags start with 16 for now */
typedef enum {
- CDPARANOIA_OPEN = GST_ELEMENT_FLAG_LAST,
+ CDPARANOIA_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- CDPARANOIA_FLAG_LAST = GST_ELEMENT_FLAG_LAST+2,
+ CDPARANOIA_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2),
} CDParanoiaFlags;
typedef struct _CDParanoia CDParanoia;
{
GstPad *pad;
- GST_FLAG_SET (gnomevfssink, GST_ELEMENT_EVENT_AWARE);
+ GST_OBJECT_FLAG_SET (gnomevfssink, GST_ELEMENT_EVENT_AWARE);
pad = gst_pad_new ("sink", GST_PAD_SINK);
gst_element_add_pad (GST_ELEMENT (gnomevfssink), pad);
{
GnomeVFSResult result;
- g_return_val_if_fail (!GST_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN), FALSE);
+ g_return_val_if_fail (!GST_OBJECT_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN),
+ FALSE);
if (sink->uri) {
/* open the file */
sink->own_handle = FALSE;
}
- GST_FLAG_SET (sink, GST_GNOMEVFSSINK_OPEN);
+ GST_OBJECT_FLAG_SET (sink, GST_GNOMEVFSSINK_OPEN);
return TRUE;
}
{
GnomeVFSResult result;
- g_return_if_fail (GST_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN));
+ g_return_if_fail (GST_OBJECT_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN));
if (sink->own_handle) {
/* close the file */
sink->handle = NULL;
}
- GST_FLAG_UNSET (sink, GST_GNOMEVFSSINK_OPEN);
+ GST_OBJECT_FLAG_UNSET (sink, GST_GNOMEVFSSINK_OPEN);
}
/**
sink = GST_GNOMEVFSSINK (gst_pad_get_parent (pad));
- if (GST_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN)) {
+ if (GST_OBJECT_FLAG_IS_SET (sink, GST_GNOMEVFSSINK_OPEN)) {
if (GST_IS_EVENT (_data)) {
gst_gnomevfssink_handle_event (sink, GST_EVENT (_data));
return;
switch (transition) {
case GST_STATE_CHANGE_READY_TO_PAUSED:
- if (!GST_FLAG_IS_SET (element, GST_GNOMEVFSSINK_OPEN)) {
+ if (!GST_OBJECT_FLAG_IS_SET (element, GST_GNOMEVFSSINK_OPEN)) {
if (!gst_gnomevfssink_open_file (GST_GNOMEVFSSINK (element)))
return GST_STATE_CHANGE_FAILURE;
}
break;
case GST_STATE_CHANGE_PAUSED_TO_READY:
- if (GST_FLAG_IS_SET (element, GST_GNOMEVFSSINK_OPEN))
+ if (GST_OBJECT_FLAG_IS_SET (element, GST_GNOMEVFSSINK_OPEN))
gst_gnomevfssink_close_file (GST_GNOMEVFSSINK (element));
break;
default:
gst_pad_set_event_function (ogg_mux->srcpad, gst_ogg_mux_handle_src_event);
gst_element_add_pad (GST_ELEMENT (ogg_mux), ogg_mux->srcpad);
- GST_FLAG_SET (GST_ELEMENT (ogg_mux), GST_OGG_FLAG_BOS);
+ GST_OBJECT_FLAG_SET (GST_ELEMENT (ogg_mux), GST_OGG_FLAG_BOS);
/* seed random number generator for creation of serial numbers */
srand (time (NULL));
audioscale->gst_resample_offset = 0;
audioscale->increase = FALSE;
- GST_FLAG_SET (audioscale, GST_ELEMENT_EVENT_AWARE);
+ GST_OBJECT_FLAG_SET (audioscale, GST_ELEMENT_EVENT_AWARE);
}
static void
sel->last_active_sinkpad = NULL;
sel->nb_sinkpads = 0;
- //GST_FLAG_SET (sel, GST_ELEMENT_WORK_IN_PLACE);
+ //GST_OBJECT_FLAG_SET (sel, GST_ELEMENT_WORK_IN_PLACE);
}
static void
static void
gst_multifdsink_init (GstMultiFdSink * this)
{
- GST_FLAG_UNSET (this, GST_MULTIFDSINK_OPEN);
+ GST_OBJECT_FLAG_UNSET (this, GST_MULTIFDSINK_OPEN);
this->protocol = DEFAULT_PROTOCOL;
this->mode = DEFAULT_MODE;
/* since we keep this buffer out of the scope of this method */
gst_buffer_ref (buf);
- g_return_val_if_fail (GST_FLAG_IS_SET (sink, GST_MULTIFDSINK_OPEN),
+ g_return_val_if_fail (GST_OBJECT_FLAG_IS_SET (sink, GST_MULTIFDSINK_OPEN),
GST_FLOW_ERROR);
GST_LOG_OBJECT (sink, "received buffer %p", buf);
int control_socket[2];
GstMultiFdSink *this;
- if (GST_FLAG_IS_SET (bsink, GST_MULTIFDSINK_OPEN))
+ if (GST_OBJECT_FLAG_IS_SET (bsink, GST_MULTIFDSINK_OPEN))
return TRUE;
this = GST_MULTIFDSINK (bsink);
this->thread = g_thread_create ((GThreadFunc) gst_multifdsink_thread,
this, TRUE, NULL);
- GST_FLAG_SET (this, GST_MULTIFDSINK_OPEN);
+ GST_OBJECT_FLAG_SET (this, GST_MULTIFDSINK_OPEN);
return TRUE;
this = GST_MULTIFDSINK (bsink);
fclass = GST_MULTIFDSINK_GET_CLASS (this);
- if (!GST_FLAG_IS_SET (bsink, GST_MULTIFDSINK_OPEN))
+ if (!GST_OBJECT_FLAG_IS_SET (bsink, GST_MULTIFDSINK_OPEN))
return TRUE;
this->running = FALSE;
this->fdset = NULL;
}
g_hash_table_foreach_remove (this->fd_hash, multifdsink_hash_remove, this);
- GST_FLAG_UNSET (this, GST_MULTIFDSINK_OPEN);
+ GST_OBJECT_FLAG_UNSET (this, GST_MULTIFDSINK_OPEN);
return TRUE;
}
typedef struct _GstMultiFdSinkClass GstMultiFdSinkClass;
typedef enum {
- GST_MULTIFDSINK_OPEN = GST_ELEMENT_FLAG_LAST,
+ GST_MULTIFDSINK_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- GST_MULTIFDSINK_FLAG_LAST = GST_ELEMENT_FLAG_LAST + 2,
+ GST_MULTIFDSINK_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2),
} GstMultiFdSinkFlags;
typedef enum
this->sock_fd = -1;
this->protocol = GST_TCP_PROTOCOL_NONE;
- GST_FLAG_UNSET (this, GST_TCPCLIENTSINK_OPEN);
+ GST_OBJECT_FLAG_UNSET (this, GST_TCPCLIENTSINK_OPEN);
}
static void
sink = GST_TCPCLIENTSINK (bsink);
- g_return_val_if_fail (GST_FLAG_IS_SET (sink, GST_TCPCLIENTSINK_OPEN),
+ g_return_val_if_fail (GST_OBJECT_FLAG_IS_SET (sink, GST_TCPCLIENTSINK_OPEN),
GST_FLOW_WRONG_STATE);
size = GST_BUFFER_SIZE (buf);
int ret;
gchar *ip;
- if (GST_FLAG_IS_SET (this, GST_TCPCLIENTSINK_OPEN))
+ if (GST_OBJECT_FLAG_IS_SET (this, GST_TCPCLIENTSINK_OPEN))
return TRUE;
/* reset caps_sent flag */
}
}
- GST_FLAG_SET (this, GST_TCPCLIENTSINK_OPEN);
+ GST_OBJECT_FLAG_SET (this, GST_TCPCLIENTSINK_OPEN);
this->data_written = 0;
static gboolean
gst_tcpclientsink_stop (GstTCPClientSink * this)
{
- if (!GST_FLAG_IS_SET (this, GST_TCPCLIENTSINK_OPEN))
+ if (!GST_OBJECT_FLAG_IS_SET (this, GST_TCPCLIENTSINK_OPEN))
return TRUE;
if (this->sock_fd != -1) {
this->sock_fd = -1;
}
- GST_FLAG_UNSET (this, GST_TCPCLIENTSINK_OPEN);
+ GST_OBJECT_FLAG_UNSET (this, GST_TCPCLIENTSINK_OPEN);
return TRUE;
}
typedef struct _GstTCPClientSinkClass GstTCPClientSinkClass;
typedef enum {
- GST_TCPCLIENTSINK_OPEN = GST_ELEMENT_FLAG_LAST,
+ GST_TCPCLIENTSINK_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- GST_TCPCLIENTSINK_FLAG_LAST = GST_ELEMENT_FLAG_LAST + 2,
+ GST_TCPCLIENTSINK_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2),
} GstTCPClientSinkFlags;
struct _GstTCPClientSink {
gst_base_src_set_live (GST_BASE_SRC (this), TRUE);
- GST_FLAG_UNSET (this, GST_TCPCLIENTSRC_OPEN);
+ GST_OBJECT_FLAG_UNSET (this, GST_TCPCLIENTSRC_OPEN);
}
static void
src = GST_TCPCLIENTSRC (bsrc);
- if (!GST_FLAG_IS_SET (src, GST_TCPCLIENTSRC_OPEN))
+ if (!GST_OBJECT_FLAG_IS_SET (src, GST_TCPCLIENTSRC_OPEN))
caps = gst_caps_new_any ();
else if (src->caps)
caps = gst_caps_copy (src->caps);
src = GST_TCPCLIENTSRC (psrc);
- if (!GST_FLAG_IS_SET (src, GST_TCPCLIENTSRC_OPEN))
+ if (!GST_OBJECT_FLAG_IS_SET (src, GST_TCPCLIENTSRC_OPEN))
goto wrong_state;
GST_LOG_OBJECT (src, "asked for a buffer");
GST_DEBUG_OBJECT (src, "opened receiving client socket with fd %d",
src->sock_fd);
- GST_FLAG_SET (src, GST_TCPCLIENTSRC_OPEN);
+ GST_OBJECT_FLAG_SET (src, GST_TCPCLIENTSRC_OPEN);
/* look up name if we need to */
if (!(ip = gst_tcp_host_to_ip (GST_ELEMENT (src), src->host)))
gst_caps_unref (src->caps);
src->caps = NULL;
}
- GST_FLAG_UNSET (src, GST_TCPCLIENTSRC_OPEN);
+ GST_OBJECT_FLAG_UNSET (src, GST_TCPCLIENTSRC_OPEN);
close (READ_SOCKET (src));
close (WRITE_SOCKET (src));
typedef struct _GstTCPClientSrcClass GstTCPClientSrcClass;
typedef enum {
- GST_TCPCLIENTSRC_OPEN = GST_ELEMENT_FLAG_LAST,
+ GST_TCPCLIENTSRC_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- GST_TCPCLIENTSRC_FLAG_LAST,
+ GST_TCPCLIENTSRC_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2)
} GstTCPClientSrcFlags;
struct _GstTCPClientSrc {
typedef struct _GstTCPServerSinkClass GstTCPServerSinkClass;
typedef enum {
- GST_TCPSERVERSINK_OPEN = GST_ELEMENT_FLAG_LAST,
+ GST_TCPSERVERSINK_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- GST_TCPSERVERSINK_FLAG_LAST = GST_ELEMENT_FLAG_LAST + 2,
+ GST_TCPSERVERSINK_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2)
} GstTCPServerSinkFlags;
struct _GstTCPServerSink {
READ_SOCKET (src) = -1;
WRITE_SOCKET (src) = -1;
- GST_FLAG_UNSET (src, GST_TCPSERVERSRC_OPEN);
+ GST_OBJECT_FLAG_UNSET (src, GST_TCPSERVERSRC_OPEN);
}
static void
src = GST_TCPSERVERSRC (psrc);
- if (!GST_FLAG_IS_SET (src, GST_TCPSERVERSRC_OPEN))
+ if (!GST_OBJECT_FLAG_IS_SET (src, GST_TCPSERVERSRC_OPEN))
goto wrong_state;
restart:
GST_DEBUG_OBJECT (src, "received client");
- GST_FLAG_SET (src, GST_TCPSERVERSRC_OPEN);
+ GST_OBJECT_FLAG_SET (src, GST_TCPSERVERSRC_OPEN);
return TRUE;
close (src->client_sock_fd);
src->client_sock_fd = -1;
}
- GST_FLAG_UNSET (src, GST_TCPSERVERSRC_OPEN);
+ GST_OBJECT_FLAG_UNSET (src, GST_TCPSERVERSRC_OPEN);
close (READ_SOCKET (src));
close (WRITE_SOCKET (src));
typedef struct _GstTCPServerSrcClass GstTCPServerSrcClass;
typedef enum {
- GST_TCPSERVERSRC_OPEN = GST_ELEMENT_FLAG_LAST,
+ GST_TCPSERVERSRC_OPEN = (GST_ELEMENT_FLAG_LAST << 0),
- GST_TCPSERVERSRC_FLAG_LAST,
+ GST_TCPSERVERSRC_FLAG_LAST = (GST_ELEMENT_FLAG_LAST << 2)
} GstTCPServerSrcFlags;
struct _GstTCPServerSrc {
v4lmjpegsink->numbufs = 64;
v4lmjpegsink->bufsize = 256;
- GST_FLAG_SET (v4lmjpegsink, GST_ELEMENT_THREAD_SUGGESTED);
+ GST_OBJECT_FLAG_SET (v4lmjpegsink, GST_ELEMENT_THREAD_SUGGESTED);
}
{
GstElementClass *klass = GST_ELEMENT_GET_CLASS (v4lmjpegsrc);
- GST_FLAG_SET (GST_ELEMENT (v4lmjpegsrc), GST_ELEMENT_THREAD_SUGGESTED);
+ GST_OBJECT_FLAG_SET (GST_ELEMENT (v4lmjpegsrc), GST_ELEMENT_THREAD_SUGGESTED);
v4lmjpegsrc->srcpad =
gst_pad_new_from_template (gst_element_class_get_pad_template (klass,
ximagesink->pend_nav_events = NULL;
#if 0
- GST_FLAG_SET (ximagesink, GST_ELEMENT_THREAD_SUGGESTED);
- GST_FLAG_SET (ximagesink, GST_ELEMENT_EVENT_AWARE);
+ GST_OBJECT_FLAG_SET (ximagesink, GST_ELEMENT_THREAD_SUGGESTED);
+ GST_OBJECT_FLAG_SET (ximagesink, GST_ELEMENT_EVENT_AWARE);
#endif
}
gst_element_set_state (pipeline, GST_STATE_PAUSED);
if (index)
- GST_FLAG_UNSET (index, GST_INDEX_WRITABLE);
+ GST_OBJECT_FLAG_UNSET (index, GST_INDEX_WRITABLE);
src = gst_bin_get_by_name (GST_BIN (pipeline), "video_decoder");