mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 11:41:09 +00:00
Code Issues 1 Projects Releases Wiki Activity

removed httpsrc from core

Browse source 
Original commit message from CVS:
removed httpsrc from core
This commit is contained in:
Andy Wingo 2001-12-24 21:33:03 +00:00
parent 107feed0de
commit aa9bc272af
8 changed files with 2 additions and 766 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
gst/elements/Makefile.am
View file

@ -2,12 +2,6 @@ filterdir = $(libdir)/gst
filter_LTLIBRARIES = libgstelements.la
if USE_LIBGHTTP
GSTHTTPSRC=gsthttpsrc.c
else
GSTHTTPSRC=
endif
libgstelements_la_DEPENDENCIES = ../libgst.la
libgstelements_la_SOURCES = \
gstelements.c \
@ -22,8 +16,7 @@ libgstelements_la_SOURCES = \
gstpipefilter.c \
gsttee.c \
gstaggregator.c \
gststatistics.c \
$(GSTHTTPSRC)
gststatistics.c
noinst_HEADERS = \
gstfakesrc.h \
@ -32,7 +25,6 @@ noinst_HEADERS = \
gstdisksink.h \
gstfdsrc.h \
gstmultidisksrc.h \
gsthttpsrc.h \
gstfdsink.h \
gstpipefilter.h \
gsttee.h \

9
gst/elements/gstelements.c
View file

@ -35,10 +35,6 @@
#include "gstaggregator.h"
#include "gststatistics.h"
#if HAVE_LIBGHTTP
#include <gsthttpsrc.h>
#endif /* HAVE_LIBGHTTP */
struct _elements_entry {
gchar *name;
@ -64,11 +60,6 @@ static struct _elements_entry _elements[] = {
{ "tee", gst_tee_get_type, &gst_tee_details, gst_tee_factory_init },
{ "aggregator", gst_aggregator_get_type, &gst_aggregator_details, gst_aggregator_factory_init },
{ "statistics", gst_statistics_get_type, &gst_statistics_details, NULL },
#if HAVE_LIBGHTTP
{ "httpsrc", gst_httpsrc_get_type, &gst_httpsrc_details, NULL },
#endif /* HAVE_LIBGHTTP */
{ NULL, 0 },
};

279
gst/elements/gsthttpsrc.c
View file

@ -1,279 +0,0 @@
/* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be>
*
* gsthttpsrc.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 <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>
#include <unistd.h>
#include <gsthttpsrc.h>
GstElementDetails gst_httpsrc_details = {
"HTTP Source",
"Source/Network",
"Read data from an HTTP stream",
VERSION,
"Erik Walthinsen <omega@cse.ogi.edu>",
"(C) 1999",
};
/* HttpSrc signals and args */
enum {
/* FILL ME */
LAST_SIGNAL
};
enum {
ARG_0,
ARG_LOCATION,
ARG_BYTESPERREAD,
ARG_OFFSET
};
static void gst_httpsrc_class_init (GstHttpSrcClass *klass);
static void gst_httpsrc_init (GstHttpSrc *httpsrc);
static void gst_httpsrc_set_property (GObject *object, guint prop_id,
const GValue *value, GParamSpec *pspec);
static void gst_httpsrc_get_property (GObject *object, guint prop_id,
GValue *value, GParamSpec *pspec);
static GstElementStateReturn gst_httpsrc_change_state (GstElement *element);
static GstBuffer * gst_httpsrc_get (GstPad *pad);
static gboolean gst_httpsrc_open_url (GstHttpSrc *src);
static void gst_httpsrc_close_url (GstHttpSrc *src);
static GstElementClass *parent_class = NULL;
/*static guint gst_httpsrc_signals[LAST_SIGNAL] = { 0 };*/
GType
gst_httpsrc_get_type (void)
{
static GType httpsrc_type = 0;
if (!httpsrc_type) {
static const GTypeInfo httpsrc_info = {
sizeof(GstHttpSrcClass), NULL,
NULL,
(GClassInitFunc)gst_httpsrc_class_init,
NULL,
NULL,
sizeof(GstHttpSrc),
0,
(GInstanceInitFunc)gst_httpsrc_init,
};
httpsrc_type = g_type_register_static (GST_TYPE_ELEMENT, "GstHttpSrc", &httpsrc_info, 0);
}
return httpsrc_type;
}
static void
gst_httpsrc_class_init (GstHttpSrcClass *klass)
{
GObjectClass *gobject_class;
GstElementClass *gstelement_class;
gobject_class = (GObjectClass*)klass;
gstelement_class = (GstElementClass*)klass;
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
gst_element_install_std_props (
GST_ELEMENT_CLASS (klass),
"location", ARG_LOCATION, G_PARAM_READWRITE,
"bytesperread", ARG_BYTESPERREAD, G_PARAM_READWRITE,
NULL);
gobject_class->set_property = gst_httpsrc_set_property;
gobject_class->get_property = gst_httpsrc_get_property;
gstelement_class->change_state = gst_httpsrc_change_state;
}
static void gst_httpsrc_init(GstHttpSrc *httpsrc) {
httpsrc->srcpad = gst_pad_new("src",GST_PAD_SRC);
gst_pad_set_get_function(httpsrc->srcpad,gst_httpsrc_get);
gst_element_add_pad(GST_ELEMENT(httpsrc),httpsrc->srcpad);
httpsrc->url = NULL;
httpsrc->request = NULL;
httpsrc->fd = 0;
httpsrc->curoffset = 0;
httpsrc->bytes_per_read = 4096;
}
static GstBuffer *
gst_httpsrc_get(GstPad *pad)
{
GstHttpSrc *src;
GstBuffer *buf;
glong readbytes;
g_return_val_if_fail (pad != NULL, NULL);
src = GST_HTTPSRC(gst_pad_get_parent (pad));
buf = gst_buffer_new();
GST_BUFFER_DATA(buf) = (gpointer)malloc(src->bytes_per_read);
readbytes = read(src->fd,GST_BUFFER_DATA(buf),src->bytes_per_read);
if (readbytes == 0) {
gst_element_signal_eos(GST_ELEMENT(src));
return NULL;
}
/*g_print ("%ld\n", readbytes);*/
if (readbytes < src->bytes_per_read) {
/* FIXME: set the buffer's EOF bit here */
}
GST_BUFFER_OFFSET(buf) = src->curoffset;
GST_BUFFER_SIZE(buf) = readbytes;
src->curoffset += readbytes;
return buf;
}
static gboolean
gst_httpsrc_open_url (GstHttpSrc *httpsrc)
{
gint status;
g_return_val_if_fail (!GST_FLAG_IS_SET (httpsrc, GST_HTTPSRC_OPEN), FALSE);
g_return_val_if_fail (httpsrc->url != NULL, FALSE);
httpsrc->request = ghttp_request_new ();
ghttp_set_uri (httpsrc->request, httpsrc->url);
ghttp_set_sync (httpsrc->request, ghttp_async);
ghttp_set_chunksize (httpsrc->request, httpsrc->bytes_per_read);
ghttp_set_header (httpsrc->request, "User-Agent", "GstHttpSrc");
ghttp_prepare (httpsrc->request);
/* process everything up to the actual data stream */
/* FIXME: should be in preroll, but hey */
status = 0;
while ((ghttp_get_status (httpsrc->request).proc != ghttp_proc_response)
&& (status >= 0)) {
status = ghttp_process (httpsrc->request);
}
/* get the fd so we can read data ourselves */
httpsrc->fd = ghttp_get_socket (httpsrc->request);
GST_FLAG_SET (httpsrc, GST_HTTPSRC_OPEN);
return TRUE;
}
/* unmap and close the file */
static void
gst_httpsrc_close_url (GstHttpSrc *src)
{
g_return_if_fail (GST_FLAG_IS_SET (src, GST_HTTPSRC_OPEN));
g_return_if_fail (src->fd > 0);
close(src->fd);
src->fd = 0;
GST_FLAG_UNSET (src, GST_HTTPSRC_OPEN);
}
static void
gst_httpsrc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
{
GstHttpSrc *src;
/* it's not null if we got it, but it might not be ours */
g_return_if_fail (GST_IS_HTTPSRC (object));
src = GST_HTTPSRC (object);
switch (prop_id) {
case ARG_LOCATION:
/* the element must not be playing in order to do this */
g_return_if_fail (GST_STATE (src) < GST_STATE_PLAYING);
if (src->url) g_free (src->url);
/* clear the url if we get a NULL (is that possible?) */
if (g_value_get_string (value) == NULL) {
gst_element_set_state (GST_ELEMENT (object),GST_STATE_NULL);
src->url = NULL;
/* otherwise set the new url */
} else {
src->url = g_strdup (g_value_get_string (value));
}
break;
case ARG_BYTESPERREAD:
src->bytes_per_read = g_value_get_int (value);
break;
default:
break;
}
}
static void
gst_httpsrc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
{
GstHttpSrc *httpsrc;
/* it's not null if we got it, but it might not be ours */
g_return_if_fail (GST_IS_HTTPSRC (object));
httpsrc = GST_HTTPSRC (object);
switch (prop_id) {
case ARG_LOCATION:
g_value_set_string (value, httpsrc->url);
break;
case ARG_BYTESPERREAD:
g_value_set_int (value, httpsrc->bytes_per_read);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
static GstElementStateReturn
gst_httpsrc_change_state (GstElement *element)
{
g_return_val_if_fail (GST_IS_HTTPSRC (element), GST_STATE_FAILURE);
if (GST_STATE_PENDING (element) == GST_STATE_NULL) {
if (GST_FLAG_IS_SET (element, GST_HTTPSRC_OPEN))
gst_httpsrc_close_url (GST_HTTPSRC (element));
} else {
if (!GST_FLAG_IS_SET (element, GST_HTTPSRC_OPEN)) {
if (!gst_httpsrc_open_url (GST_HTTPSRC (element)))
return GST_STATE_FAILURE;
}
}
if (GST_ELEMENT_CLASS (parent_class)->change_state)
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
return GST_STATE_SUCCESS;
}

86
gst/elements/gsthttpsrc.h
View file

@ -1,86 +0,0 @@
/* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be>
*
* gsthttpsrc.h:
*
* 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.
*/
#ifndef __GST_HTTPSRC_H__
#define __GST_HTTPSRC_H__
#include <config.h>
#include <gst/gst.h>
#include <ghttp.h>
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
GstElementDetails gst_httpsrc_details;
#define GST_TYPE_HTTPSRC \
(gst_httpsrc_get_type())
#define GST_HTTPSRC(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_HTTPSRC,GstHttpSrc))
#define GST_HTTPSRC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_HTTPSRC,GstHttpSrcClass))
#define GST_IS_HTTPSRC(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_HTTPSRC))
#define GST_IS_HTTPSRC_CLASS(obj) \
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_HTTPSRC))
typedef enum {
GST_HTTPSRC_OPEN = GST_ELEMENT_FLAG_LAST,
GST_HTTPSRC_FLAG_LAST = GST_ELEMENT_FLAG_LAST+2,
} GstHttpSrcFlags;
typedef struct _GstHttpSrc GstHttpSrc;
typedef struct _GstHttpSrcClass GstHttpSrcClass;
struct _GstHttpSrc {
GstElement element;
/* pads */
GstPad *srcpad;
gchar *url;
ghttp_request *request;
int fd;
gulong curoffset; /* current offset in file */
gulong bytes_per_read; /* bytes per read */
};
struct _GstHttpSrcClass {
GstElementClass parent_class;
};
GType gst_httpsrc_get_type(void);
#ifdef __cplusplus
}
#endif /* __cplusplus */
#endif /* __GST_HTTPSRC_H__ */

10
plugins/elements/Makefile.am
View file

@ -2,12 +2,6 @@ filterdir = $(libdir)/gst
filter_LTLIBRARIES = libgstelements.la
if USE_LIBGHTTP
GSTHTTPSRC=gsthttpsrc.c
else
GSTHTTPSRC=
endif
libgstelements_la_DEPENDENCIES = ../libgst.la
libgstelements_la_SOURCES = \
gstelements.c \
@ -22,8 +16,7 @@ libgstelements_la_SOURCES = \
gstpipefilter.c \
gsttee.c \
gstaggregator.c \
gststatistics.c \
$(GSTHTTPSRC)
gststatistics.c
noinst_HEADERS = \
gstfakesrc.h \
@ -32,7 +25,6 @@ noinst_HEADERS = \
gstdisksink.h \
gstfdsrc.h \
gstmultidisksrc.h \
gsthttpsrc.h \
gstfdsink.h \
gstpipefilter.h \
gsttee.h \

9
plugins/elements/gstelements.c
View file

@ -35,10 +35,6 @@
#include "gstaggregator.h"
#include "gststatistics.h"
#if HAVE_LIBGHTTP
#include <gsthttpsrc.h>
#endif /* HAVE_LIBGHTTP */
struct _elements_entry {
gchar *name;
@ -64,11 +60,6 @@ static struct _elements_entry _elements[] = {
{ "tee", gst_tee_get_type, &gst_tee_details, gst_tee_factory_init },
{ "aggregator", gst_aggregator_get_type, &gst_aggregator_details, gst_aggregator_factory_init },
{ "statistics", gst_statistics_get_type, &gst_statistics_details, NULL },
#if HAVE_LIBGHTTP
{ "httpsrc", gst_httpsrc_get_type, &gst_httpsrc_details, NULL },
#endif /* HAVE_LIBGHTTP */
{ NULL, 0 },
};

279
plugins/elements/gsthttpsrc.c
View file

@ -1,279 +0,0 @@
/* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be>
*
* gsthttpsrc.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 <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>
#include <unistd.h>
#include <gsthttpsrc.h>
GstElementDetails gst_httpsrc_details = {
"HTTP Source",
"Source/Network",
"Read data from an HTTP stream",
VERSION,
"Erik Walthinsen <omega@cse.ogi.edu>",
"(C) 1999",
};
/* HttpSrc signals and args */
enum {
/* FILL ME */
LAST_SIGNAL
};
enum {
ARG_0,
ARG_LOCATION,
ARG_BYTESPERREAD,
ARG_OFFSET
};
static void gst_httpsrc_class_init (GstHttpSrcClass *klass);
static void gst_httpsrc_init (GstHttpSrc *httpsrc);
static void gst_httpsrc_set_property (GObject *object, guint prop_id,
const GValue *value, GParamSpec *pspec);
static void gst_httpsrc_get_property (GObject *object, guint prop_id,
GValue *value, GParamSpec *pspec);
static GstElementStateReturn gst_httpsrc_change_state (GstElement *element);
static GstBuffer * gst_httpsrc_get (GstPad *pad);
static gboolean gst_httpsrc_open_url (GstHttpSrc *src);
static void gst_httpsrc_close_url (GstHttpSrc *src);
static GstElementClass *parent_class = NULL;
/*static guint gst_httpsrc_signals[LAST_SIGNAL] = { 0 };*/
GType
gst_httpsrc_get_type (void)
{
static GType httpsrc_type = 0;
if (!httpsrc_type) {
static const GTypeInfo httpsrc_info = {
sizeof(GstHttpSrcClass), NULL,
NULL,
(GClassInitFunc)gst_httpsrc_class_init,
NULL,
NULL,
sizeof(GstHttpSrc),
0,
(GInstanceInitFunc)gst_httpsrc_init,
};
httpsrc_type = g_type_register_static (GST_TYPE_ELEMENT, "GstHttpSrc", &httpsrc_info, 0);
}
return httpsrc_type;
}
static void
gst_httpsrc_class_init (GstHttpSrcClass *klass)
{
GObjectClass *gobject_class;
GstElementClass *gstelement_class;
gobject_class = (GObjectClass*)klass;
gstelement_class = (GstElementClass*)klass;
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
gst_element_install_std_props (
GST_ELEMENT_CLASS (klass),
"location", ARG_LOCATION, G_PARAM_READWRITE,
"bytesperread", ARG_BYTESPERREAD, G_PARAM_READWRITE,
NULL);
gobject_class->set_property = gst_httpsrc_set_property;
gobject_class->get_property = gst_httpsrc_get_property;
gstelement_class->change_state = gst_httpsrc_change_state;
}
static void gst_httpsrc_init(GstHttpSrc *httpsrc) {
httpsrc->srcpad = gst_pad_new("src",GST_PAD_SRC);
gst_pad_set_get_function(httpsrc->srcpad,gst_httpsrc_get);
gst_element_add_pad(GST_ELEMENT(httpsrc),httpsrc->srcpad);
httpsrc->url = NULL;
httpsrc->request = NULL;
httpsrc->fd = 0;
httpsrc->curoffset = 0;
httpsrc->bytes_per_read = 4096;
}
static GstBuffer *
gst_httpsrc_get(GstPad *pad)
{
GstHttpSrc *src;
GstBuffer *buf;
glong readbytes;
g_return_val_if_fail (pad != NULL, NULL);
src = GST_HTTPSRC(gst_pad_get_parent (pad));
buf = gst_buffer_new();
GST_BUFFER_DATA(buf) = (gpointer)malloc(src->bytes_per_read);
readbytes = read(src->fd,GST_BUFFER_DATA(buf),src->bytes_per_read);
if (readbytes == 0) {
gst_element_signal_eos(GST_ELEMENT(src));
return NULL;
}
/*g_print ("%ld\n", readbytes);*/
if (readbytes < src->bytes_per_read) {
/* FIXME: set the buffer's EOF bit here */
}
GST_BUFFER_OFFSET(buf) = src->curoffset;
GST_BUFFER_SIZE(buf) = readbytes;
src->curoffset += readbytes;
return buf;
}
static gboolean
gst_httpsrc_open_url (GstHttpSrc *httpsrc)
{
gint status;
g_return_val_if_fail (!GST_FLAG_IS_SET (httpsrc, GST_HTTPSRC_OPEN), FALSE);
g_return_val_if_fail (httpsrc->url != NULL, FALSE);
httpsrc->request = ghttp_request_new ();
ghttp_set_uri (httpsrc->request, httpsrc->url);
ghttp_set_sync (httpsrc->request, ghttp_async);
ghttp_set_chunksize (httpsrc->request, httpsrc->bytes_per_read);
ghttp_set_header (httpsrc->request, "User-Agent", "GstHttpSrc");
ghttp_prepare (httpsrc->request);
/* process everything up to the actual data stream */
/* FIXME: should be in preroll, but hey */
status = 0;
while ((ghttp_get_status (httpsrc->request).proc != ghttp_proc_response)
&& (status >= 0)) {
status = ghttp_process (httpsrc->request);
}
/* get the fd so we can read data ourselves */
httpsrc->fd = ghttp_get_socket (httpsrc->request);
GST_FLAG_SET (httpsrc, GST_HTTPSRC_OPEN);
return TRUE;
}
/* unmap and close the file */
static void
gst_httpsrc_close_url (GstHttpSrc *src)
{
g_return_if_fail (GST_FLAG_IS_SET (src, GST_HTTPSRC_OPEN));
g_return_if_fail (src->fd > 0);
close(src->fd);
src->fd = 0;
GST_FLAG_UNSET (src, GST_HTTPSRC_OPEN);
}
static void
gst_httpsrc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
{
GstHttpSrc *src;
/* it's not null if we got it, but it might not be ours */
g_return_if_fail (GST_IS_HTTPSRC (object));
src = GST_HTTPSRC (object);
switch (prop_id) {
case ARG_LOCATION:
/* the element must not be playing in order to do this */
g_return_if_fail (GST_STATE (src) < GST_STATE_PLAYING);
if (src->url) g_free (src->url);
/* clear the url if we get a NULL (is that possible?) */
if (g_value_get_string (value) == NULL) {
gst_element_set_state (GST_ELEMENT (object),GST_STATE_NULL);
src->url = NULL;
/* otherwise set the new url */
} else {
src->url = g_strdup (g_value_get_string (value));
}
break;
case ARG_BYTESPERREAD:
src->bytes_per_read = g_value_get_int (value);
break;
default:
break;
}
}
static void
gst_httpsrc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
{
GstHttpSrc *httpsrc;
/* it's not null if we got it, but it might not be ours */
g_return_if_fail (GST_IS_HTTPSRC (object));
httpsrc = GST_HTTPSRC (object);
switch (prop_id) {
case ARG_LOCATION:
g_value_set_string (value, httpsrc->url);
break;
case ARG_BYTESPERREAD:
g_value_set_int (value, httpsrc->bytes_per_read);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
static GstElementStateReturn
gst_httpsrc_change_state (GstElement *element)
{
g_return_val_if_fail (GST_IS_HTTPSRC (element), GST_STATE_FAILURE);
if (GST_STATE_PENDING (element) == GST_STATE_NULL) {
if (GST_FLAG_IS_SET (element, GST_HTTPSRC_OPEN))
gst_httpsrc_close_url (GST_HTTPSRC (element));
} else {
if (!GST_FLAG_IS_SET (element, GST_HTTPSRC_OPEN)) {
if (!gst_httpsrc_open_url (GST_HTTPSRC (element)))
return GST_STATE_FAILURE;
}
}
if (GST_ELEMENT_CLASS (parent_class)->change_state)
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
return GST_STATE_SUCCESS;
}

86
plugins/elements/gsthttpsrc.h
View file

@ -1,86 +0,0 @@
/* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be>
*
* gsthttpsrc.h:
*
* 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.
*/
#ifndef __GST_HTTPSRC_H__
#define __GST_HTTPSRC_H__
#include <config.h>
#include <gst/gst.h>
#include <ghttp.h>
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
GstElementDetails gst_httpsrc_details;
#define GST_TYPE_HTTPSRC \
(gst_httpsrc_get_type())
#define GST_HTTPSRC(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_HTTPSRC,GstHttpSrc))
#define GST_HTTPSRC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_HTTPSRC,GstHttpSrcClass))
#define GST_IS_HTTPSRC(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_HTTPSRC))
#define GST_IS_HTTPSRC_CLASS(obj) \
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_HTTPSRC))
typedef enum {
GST_HTTPSRC_OPEN = GST_ELEMENT_FLAG_LAST,
GST_HTTPSRC_FLAG_LAST = GST_ELEMENT_FLAG_LAST+2,
} GstHttpSrcFlags;
typedef struct _GstHttpSrc GstHttpSrc;
typedef struct _GstHttpSrcClass GstHttpSrcClass;
struct _GstHttpSrc {
GstElement element;
/* pads */
GstPad *srcpad;
gchar *url;
ghttp_request *request;
int fd;
gulong curoffset; /* current offset in file */
gulong bytes_per_read; /* bytes per read */
};
struct _GstHttpSrcClass {
GstElementClass parent_class;
};
GType gst_httpsrc_get_type(void);
#ifdef __cplusplus
}
#endif /* __cplusplus */
#endif /* __GST_HTTPSRC_H__ */