*
* 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.
+ * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
+ * Boston, MA 02110-1301, USA.
*/
/**
* SECTION:element-filesrc
+ * @title: filesrc
* @see_also: #GstFileSrc
*
* Read data from a file in the local file system.
*
- * <refsect2>
- * <title>Example launch line</title>
+ * ## Example launch line
* |[
- * gst-launch filesrc location=song.ogg ! decodebin2 ! autoaudiosink
- * ]| Play a song.ogg from local dir.
- * </refsect2>
+ * gst-launch-1.0 filesrc location=song.ogg ! decodebin ! audioconvert ! audioresample ! autoaudiosink
+ * ]| Play song.ogg audio file which must be in the current working directory.
+ *
*/
#ifdef HAVE_CONFIG_H
#include <stdio.h>
#include <sys/types.h>
+#include <sys/stat.h>
#ifdef G_OS_WIN32
#include <io.h> /* lseek, open, close, read */
/* On win32, stat* default to 32 bit; we need the 64-bit
* variants, so explicitly define it that way. */
+#undef stat
#define stat __stat64
+#undef fstat
#define fstat _fstat64
#undef lseek
#define lseek _lseeki64
* _stat*, since we're explicitly overriding that */
#undef _INC_STAT_INL
#endif
-#include <sys/stat.h>
#include <fcntl.h>
#ifdef HAVE_UNISTD_H
# include <unistd.h>
#endif
+#ifdef __BIONIC__ /* Android */
+#if defined(__ANDROID_API__) && __ANDROID_API__ >= 21
+#undef fstat
+#define fstat fstat64
+#endif
+#endif
+
#include <errno.h>
#include <string.h>
GST_PAD_ALWAYS,
GST_STATIC_CAPS_ANY);
-/* FIXME we should be using glib for this */
#ifndef S_ISREG
#define S_ISREG(mode) ((mode)&_S_IFREG)
#endif
errno = save_errno;
return retval;
+#elif defined (__BIONIC__)
+ return open (filename, flags | O_LARGEFILE, mode);
#else
return open (filename, flags, mode);
#endif
static gboolean gst_file_src_get_size (GstBaseSrc * src, guint64 * size);
static GstFlowReturn gst_file_src_fill (GstBaseSrc * src, guint64 offset,
guint length, GstBuffer * buf);
-static gboolean gst_file_src_query (GstBaseSrc * src, GstQuery * query);
static void gst_file_src_uri_handler_init (gpointer g_iface,
gpointer iface_data);
gobject_class->finalize = gst_file_src_finalize;
- gst_element_class_set_details_simple (gstelement_class,
+ gst_element_class_set_static_metadata (gstelement_class,
"File Source",
"Source/File",
"Read from arbitrary point in a file",
"Erik Walthinsen <omega@cse.ogi.edu>");
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&srctemplate));
+ gst_element_class_add_static_pad_template (gstelement_class, &srctemplate);
gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_file_src_start);
gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_file_src_stop);
gstbasesrc_class->is_seekable = GST_DEBUG_FUNCPTR (gst_file_src_is_seekable);
gstbasesrc_class->get_size = GST_DEBUG_FUNCPTR (gst_file_src_get_size);
gstbasesrc_class->fill = GST_DEBUG_FUNCPTR (gst_file_src_fill);
- gstbasesrc_class->query = GST_DEBUG_FUNCPTR (gst_file_src_query);
if (sizeof (off_t) < 8) {
GST_LOG ("No large file support, sizeof (off_t) = %" G_GSIZE_FORMAT "!",
src->uri = NULL;
src->is_regular = FALSE;
+
+ gst_base_src_set_blocksize (GST_BASE_SRC (src), DEFAULT_BLOCKSIZE);
}
static void
}
static gboolean
-gst_file_src_set_location (GstFileSrc * src, const gchar * location)
+gst_file_src_set_location (GstFileSrc * src, const gchar * location,
+ GError ** err)
{
GstState state;
g_free (src->filename);
g_free (src->uri);
- /* clear the filename if we get a NULL (is that possible?) */
+ /* clear the filename if we get a NULL */
if (location == NULL) {
src->filename = NULL;
src->uri = NULL;
GST_INFO ("uri : %s", src->uri);
}
g_object_notify (G_OBJECT (src), "location");
- /* FIXME 0.11: notify "uri" property once there is one */
+ /* FIXME 2.0: notify "uri" property once there is one */
return TRUE;
{
g_warning ("Changing the `location' property on filesrc when a file is "
"open is not supported.");
+ if (err)
+ g_set_error (err, GST_URI_ERROR, GST_URI_ERROR_BAD_STATE,
+ "Changing the `location' property on filesrc when a file is "
+ "open is not supported.");
GST_OBJECT_UNLOCK (src);
return FALSE;
}
switch (prop_id) {
case PROP_LOCATION:
- gst_file_src_set_location (src, g_value_get_string (value));
+ gst_file_src_set_location (src, g_value_get_string (value), NULL);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
src = GST_FILE_SRC_CAST (basesrc);
- if (G_UNLIKELY (src->read_position != offset)) {
+ if (G_UNLIKELY (offset != -1 && src->read_position != offset)) {
off_t res;
res = lseek (src->fd, offset, SEEK_SET);
src->read_position = offset;
}
- gst_buffer_map (buf, &info, GST_MAP_WRITE);
+ if (!gst_buffer_map (buf, &info, GST_MAP_WRITE))
+ goto buffer_write_fail;
data = info.data;
bytes_read = 0;
}
gst_buffer_unmap (buf, &info);
- gst_buffer_resize (buf, 0, bytes_read);
+ if (bytes_read != length)
+ gst_buffer_resize (buf, 0, bytes_read);
GST_BUFFER_OFFSET (buf) = offset;
GST_BUFFER_OFFSET_END (buf) = offset + bytes_read;
gst_buffer_resize (buf, 0, 0);
return GST_FLOW_EOS;
}
-}
-
-static gboolean
-gst_file_src_query (GstBaseSrc * basesrc, GstQuery * query)
-{
- gboolean ret = FALSE;
- GstFileSrc *src = GST_FILE_SRC (basesrc);
-
- switch (GST_QUERY_TYPE (query)) {
- case GST_QUERY_URI:
- gst_query_set_uri (query, src->uri);
- ret = TRUE;
- break;
- default:
- ret = FALSE;
- break;
+buffer_write_fail:
+ {
+ GST_ELEMENT_ERROR (src, RESOURCE, WRITE, (NULL), ("Can't write to buffer"));
+ return GST_FLOW_ERROR;
}
-
- if (!ret)
- ret = GST_BASE_SRC_CLASS (parent_class)->query (basesrc, query);
-
- return ret;
}
static gboolean
}
}
-/* open the file and mmap it, necessary to go to READY state */
+/* open the file, necessary to go to READY state */
static gboolean
gst_file_src_start (GstBaseSrc * basesrc)
{
off_t res = lseek (src->fd, 0, SEEK_END);
if (res < 0) {
- GST_LOG_OBJECT (src, "disabling seeking, not in mmap mode and lseek "
- "failed: %s", g_strerror (errno));
+ GST_LOG_OBJECT (src, "disabling seeking, lseek failed: %s",
+ g_strerror (errno));
src->seekable = FALSE;
} else {
+ res = lseek (src->fd, 0, SEEK_SET);
+
+ if (res < 0) {
+ /* We really don't like not being able to go back to 0 */
+ src->seekable = FALSE;
+ goto lseek_wonky;
+ }
+
src->seekable = TRUE;
}
- lseek (src->fd, 0, SEEK_SET);
}
/* We can only really do seeking on regular files - for other file types, we
(_("File \"%s\" is a socket."), src->filename), (NULL));
goto error_close;
}
+lseek_wonky:
+ {
+ GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ, (NULL),
+ ("Could not seek back to zero after seek test in file \"%s\"",
+ src->filename));
+ goto error_close;
+ }
error_close:
close (src->fd);
error_exit:
/* Special case for "file://" as this is used by some applications
* to test with gst_element_make_from_uri if there's an element
* that supports the URI protocol. */
- gst_file_src_set_location (src, NULL);
+ gst_file_src_set_location (src, NULL, NULL);
return TRUE;
}
#ifdef G_OS_WIN32
/* Unfortunately, g_filename_from_uri() doesn't handle some UNC paths
* correctly on windows, it leaves them with an extra backslash
- * at the start if they're of the mozilla-style file://///host/path/file
+ * at the start if they're of the mozilla-style file://///host/path/file
* form. Correct this.
*/
if (location[0] == '\\' && location[1] == '\\' && location[2] == '\\')
- g_memmove (location, location + 1, strlen (location + 1) + 1);
+ memmove (location, location + 1, strlen (location + 1) + 1);
#endif
- ret = gst_file_src_set_location (src, location);
+ ret = gst_file_src_set_location (src, location, err);
beach:
if (location)
projects / platform / upstream / gstreamer.git / blobdiff