gstfilesrc.c 23.4 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
/* GStreamer
 * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
 *                    2000 Wim Taymans <wtay@chello.be>
 *
 * gstfilesrc.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 <gst/gst.h>

25 26
#include "gstfilesrc.h"

27
#include <stdio.h>
28 29 30 31
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <sys/mman.h>
32
#include <errno.h>
33
#include <string.h>
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80


/**********************************************************************
 * GStreamer Default File Source
 * Theory of Operation
 *
 * This source uses mmap(2) to efficiently load data from a file.
 * To do this without seriously polluting the applications' memory
 * space, it must do so in smaller chunks, say 1-4MB at a time.
 * Buffers are then subdivided from these mmap'd chunks, to directly
 * make use of the mmap.
 *
 * To handle refcounting so that the mmap can be freed at the appropriate
 * time, a buffer will be created for each mmap'd region, and all new
 * buffers will be sub-buffers of this top-level buffer.  As they are 
 * freed, the refcount goes down on the mmap'd buffer and its free()
 * function is called, which will call munmap(2) on itself.
 *
 * If a buffer happens to cross the boundaries of an mmap'd region, we
 * have to decide whether it's more efficient to copy the data into a
 * new buffer, or mmap() just that buffer.  There will have to be a
 * breakpoint size to determine which will be done.  The mmap() size
 * has a lot to do with this as well, because you end up in double-
 * jeopardy: the larger the outgoing buffer, the more data to copy when
 * it overlaps, *and* the more frequently you'll have buffers that *do*
 * overlap.
 *
 * Seeking is another tricky aspect to do efficiently.  The initial
 * implementation of this source won't make use of these features, however.
 * The issue is that if an application seeks backwards in a file, *and*
 * that region of the file is covered by an mmap that hasn't been fully
 * deallocated, we really should re-use it.  But keeping track of these
 * regions is tricky because we have to lock the structure that holds
 * them.  We need to settle on a locking primitive (GMutex seems to be
 * a really good option...), then we can do that.
 */


GstElementDetails gst_filesrc_details = {
  "File Source",
  "Source/File",
  "Read from arbitrary point in a file",
  VERSION,
  "Erik Walthinsen <omega@cse.ogi.edu>",
  "(C) 1999",
};

81
/*#define fs_print(format,args...) g_print(format, ## args) */
82 83
#define fs_print(format,args...)

84 85 86 87 88 89 90 91
/* FileSrc signals and args */
enum {
  /* FILL ME */
  LAST_SIGNAL
};

enum {
  ARG_0,
92
  ARG_OFFSET,
93
  ARG_LOCATION,
94 95
  ARG_FILESIZE,
  ARG_FD,
96
  ARG_BLOCKSIZE,
97
  ARG_MAPSIZE,
98
  ARG_TOUCH,
99 100 101
};


Wim Taymans's avatar
Wim Taymans committed
102 103
static void		gst_filesrc_class_init		(GstFileSrcClass *klass);
static void		gst_filesrc_init		(GstFileSrc *filesrc);
Wim Taymans's avatar
Wim Taymans committed
104
static void 		gst_filesrc_dispose 		(GObject *object);
105

Wim Taymans's avatar
Wim Taymans committed
106 107 108 109
static void		gst_filesrc_set_property	(GObject *object, guint prop_id, 
							 const GValue *value, GParamSpec *pspec);
static void		gst_filesrc_get_property	(GObject *object, guint prop_id, 
							 GValue *value, GParamSpec *pspec);
110

Wim Taymans's avatar
Wim Taymans committed
111 112
static GstBuffer *	gst_filesrc_get			(GstPad *pad);
static gboolean 	gst_filesrc_srcpad_event 	(GstPad *pad, GstEvent *event);
113 114
static gboolean 	gst_filesrc_srcpad_query 	(GstPad *pad, GstPadQueryType type,
		         				 GstSeekType *format, gint64 *value);
115 116 117 118 119

static GstElementStateReturn	gst_filesrc_change_state	(GstElement *element);


static GstElementClass *parent_class = NULL;
120
/*static guint gst_filesrc_signals[LAST_SIGNAL] = { 0 };*/
121

122
GType
123 124
gst_filesrc_get_type(void)
{
125
  static GType filesrc_type = 0;
126 127

  if (!filesrc_type) {
128 129 130 131 132 133
    static const GTypeInfo filesrc_info = {
      sizeof(GstFileSrcClass),      NULL,
      NULL,
      (GClassInitFunc)gst_filesrc_class_init,
      NULL,
      NULL,
134
      sizeof(GstFileSrc),
135 136
      0,
      (GInstanceInitFunc)gst_filesrc_init,
137
    };
138
    filesrc_type = g_type_register_static (GST_TYPE_ELEMENT, "GstFileSrc", &filesrc_info, 0);
139 140 141 142 143 144 145
  }
  return filesrc_type;
}

static void
gst_filesrc_class_init (GstFileSrcClass *klass)
{
146
  GObjectClass *gobject_class;
147 148
  GstElementClass *gstelement_class;

149
  gobject_class = (GObjectClass*)klass;
150 151
  gstelement_class = (GstElementClass*)klass;

152 153
  parent_class = g_type_class_ref (GST_TYPE_ELEMENT);

154
  gst_element_class_install_std_props (
Wim Taymans's avatar
Wim Taymans committed
155 156 157 158 159 160 161 162 163
	  GST_ELEMENT_CLASS (klass),
	  "fd",           ARG_FD,           G_PARAM_READABLE,
	  "offset",       ARG_OFFSET,       G_PARAM_READWRITE,
	  "filesize",     ARG_FILESIZE,     G_PARAM_READABLE,
	  "location",     ARG_LOCATION,     G_PARAM_READWRITE,
	  "blocksize",    ARG_BLOCKSIZE,    G_PARAM_READWRITE,
	  "mmapsize",     ARG_MAPSIZE,      G_PARAM_READWRITE,
	  "touch",        ARG_TOUCH,        G_PARAM_READWRITE,
	  NULL);
164

Wim Taymans's avatar
Wim Taymans committed
165 166 167
  gobject_class->dispose 	= gst_filesrc_dispose;
  gobject_class->set_property 	= gst_filesrc_set_property;
  gobject_class->get_property 	= gst_filesrc_get_property;
168 169 170 171 172 173 174

  gstelement_class->change_state = gst_filesrc_change_state;
}

static gint
gst_filesrc_bufcmp (gconstpointer a, gconstpointer b)
{
175
/*  GstBuffer *bufa = (GstBuffer *)a, *bufb = (GstBuffer *)b;*/
176

177
  /* sort first by offset, then in reverse by size */
178 179 180 181 182 183 184 185 186 187 188
  if (GST_BUFFER_OFFSET(a) < GST_BUFFER_OFFSET(b)) return -1;
  else if (GST_BUFFER_OFFSET(a) > GST_BUFFER_OFFSET(b)) return 1;
  else if (GST_BUFFER_SIZE(a) > GST_BUFFER_SIZE(b)) return -1;
  else if (GST_BUFFER_SIZE(a) < GST_BUFFER_SIZE(b)) return 1;
  else return 0;
}

static void
gst_filesrc_init (GstFileSrc *src)
{
  src->srcpad = gst_pad_new ("src", GST_PAD_SRC);
189 190 191
  gst_pad_set_get_function (src->srcpad, gst_filesrc_get);
  gst_pad_set_event_function (src->srcpad, gst_filesrc_srcpad_event);
  gst_pad_set_query_function (src->srcpad, gst_filesrc_srcpad_query);
192 193
  gst_element_add_pad (GST_ELEMENT (src), src->srcpad);

194 195
  src->pagesize = getpagesize();

196 197 198 199 200
  src->filename = NULL;
  src->fd = 0;
  src->filelen = 0;

  src->curoffset = 0;
201 202
  src->block_size = 4096;
  src->touch = TRUE;
203 204

  src->mapbuf = NULL;
205
  src->mapsize = 4 * 1024 * 1024;		/* default is 4MB */
206

207
  src->map_regions = g_tree_new (gst_filesrc_bufcmp);
208
  src->map_regions_lock = g_mutex_new();
209 210

  src->seek_happened = FALSE;
211 212
}

Wim Taymans's avatar
Wim Taymans committed
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227
static void
gst_filesrc_dispose (GObject *object)
{
  GstFileSrc *src;

  src = GST_FILESRC (object);

  G_OBJECT_CLASS (parent_class)->dispose (object);

  g_tree_destroy (src->map_regions);
  g_mutex_free (src->map_regions_lock);
  if (src->filename)
    g_free (src->filename);
}

228 229

static void
230
gst_filesrc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
231 232 233 234 235 236 237 238
{
  GstFileSrc *src;

  /* it's not null if we got it, but it might not be ours */
  g_return_if_fail (GST_IS_FILESRC (object));

  src = GST_FILESRC (object);

239
  switch (prop_id) {
240 241 242 243 244 245
    case ARG_LOCATION:
      /* the element must be stopped in order to do this */
      g_return_if_fail (GST_STATE (src) < GST_STATE_PLAYING);

      if (src->filename) g_free (src->filename);
      /* clear the filename if we get a NULL (is that possible?) */
246
      if (g_value_get_string (value) == NULL) {
247 248 249 250
        gst_element_set_state (GST_ELEMENT (object), GST_STATE_NULL);
        src->filename = NULL;
      /* otherwise set the new filename */
      } else {
251
        src->filename = g_strdup (g_value_get_string (value));
252
      }
253
      g_object_notify (G_OBJECT (src), "location");
254 255
      break;
    case ARG_BLOCKSIZE:
256
      src->block_size = g_value_get_ulong (value);
257
      g_object_notify (G_OBJECT (src), "blocksize");
258 259
      break;
    case ARG_OFFSET:
260
      src->curoffset = g_value_get_int64 (value);
261
      g_object_notify (G_OBJECT (src), "offset");
262 263
      break;
    case ARG_MAPSIZE:
David I. Lehn's avatar
David I. Lehn committed
264
      if ((src->mapsize % src->pagesize) == 0) {
265
        src->mapsize = g_value_get_ulong (value);
266
        g_object_notify (G_OBJECT (src), "mmapsize");
David I. Lehn's avatar
David I. Lehn committed
267
      } else {
268
        GST_INFO(0, "invalid mapsize, must a multiple of pagesize, which is %d\n",src->pagesize);
David I. Lehn's avatar
David I. Lehn committed
269
      }
270
      break;
271 272
    case ARG_TOUCH:
      src->touch = g_value_get_boolean (value);
273
      g_object_notify (G_OBJECT (src), "touch");
274
      break;
275 276 277 278 279 280
    default:
      break;
  }
}

static void
281
gst_filesrc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
282 283 284 285 286 287 288 289
{
  GstFileSrc *src;

  /* it's not null if we got it, but it might not be ours */
  g_return_if_fail (GST_IS_FILESRC (object));

  src = GST_FILESRC (object);

290
  switch (prop_id) {
291
    case ARG_LOCATION:
292 293 294
      g_value_set_string (value, src->filename);
      break;
    case ARG_FILESIZE:
295
      g_value_set_int64 (value, src->filelen);
296 297 298
      break;
    case ARG_FD:
      g_value_set_int (value, src->fd);
299 300
      break;
    case ARG_BLOCKSIZE:
301
      g_value_set_ulong (value, src->block_size);
302 303
      break;
    case ARG_OFFSET:
304
      g_value_set_int64 (value, src->curoffset);
305
      break;
306 307
    case ARG_MAPSIZE:
      g_value_set_ulong (value, src->mapsize);
308
      break;
309 310 311
    case ARG_TOUCH:
      g_value_set_boolean (value, src->touch);
      break;
312
    default:
313
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
314 315 316 317 318 319 320 321 322
      break;
  }
}

static void
gst_filesrc_free_parent_mmap (GstBuffer *buf)
{
  GstFileSrc *src = GST_FILESRC(GST_BUFFER_POOL_PRIVATE(buf));

323
  fs_print ("freeing mmap()d buffer at %d+%d\n",GST_BUFFER_OFFSET(buf),GST_BUFFER_SIZE(buf));
324

325
  /* remove the buffer from the list of available mmap'd regions */
326 327
  g_mutex_lock(src->map_regions_lock);
  g_tree_remove(src->map_regions,buf);
328
  /* check to see if the tree is empty */
329
  if (g_tree_nnodes(src->map_regions) == 0) {
330
    /* we have to free the bufferpool we don't have yet */
331 332 333
  }
  g_mutex_unlock(src->map_regions_lock);

334
#ifdef MADV_DONTNEED
335
  /* madvise to tell the kernel what to do with it */
336 337
  madvise(GST_BUFFER_DATA(buf),GST_BUFFER_SIZE(buf),MADV_DONTNEED);
#endif
338
  /* now unmap the memory */
339 340 341 342
  munmap(GST_BUFFER_DATA(buf),GST_BUFFER_MAXSIZE(buf));
}

static GstBuffer *
343
gst_filesrc_map_region (GstFileSrc *src, off_t offset, size_t size)
344 345
{
  GstBuffer *buf;
346
  gint retval;
347

348 349 350
  g_return_val_if_fail (offset >= 0, NULL);

  fs_print  ("mapping region %08lx+%08lx from file into memory\n",offset,size);
351

352
  /* time to allocate a new mapbuf */
353
  buf = gst_buffer_new();
354
  /* mmap() the data into this new buffer */
355 356
  GST_BUFFER_DATA(buf) = mmap (NULL, size, PROT_READ, MAP_SHARED, src->fd, offset);
  if (GST_BUFFER_DATA(buf) == NULL) {
357
    gst_element_error (GST_ELEMENT (src), "couldn't map file");
358
  } else if (GST_BUFFER_DATA(buf) == MAP_FAILED) {
359 360
    gst_element_error (GST_ELEMENT (src), "mmap (0x%x, %d, 0x%llx) : %s",
 	     size, src->fd, offset, strerror (errno));
361
  }
362
#ifdef MADV_SEQUENTIAL
363
  /* madvise to tell the kernel what to do with it */
364
  retval = madvise(GST_BUFFER_DATA(buf),GST_BUFFER_SIZE(buf),MADV_SEQUENTIAL);
365
#endif
366
  /* fill in the rest of the fields */
Wim Taymans's avatar
Wim Taymans committed
367 368
  GST_BUFFER_FLAG_SET(buf, GST_BUFFER_READONLY);
  GST_BUFFER_FLAG_SET(buf, GST_BUFFER_ORIGINAL);
369 370 371 372 373 374 375 376 377 378 379 380 381 382 383
  GST_BUFFER_SIZE(buf) = size;
  GST_BUFFER_MAXSIZE(buf) = size;
  GST_BUFFER_OFFSET(buf) = offset;
  GST_BUFFER_TIMESTAMP(buf) = -1LL;
  GST_BUFFER_POOL_PRIVATE(buf) = src;
  GST_BUFFER_FREE_FUNC(buf) = gst_filesrc_free_parent_mmap;

  g_mutex_lock(src->map_regions_lock);
  g_tree_insert(src->map_regions,buf,buf);
  g_mutex_unlock(src->map_regions_lock);

  return buf;
}

static GstBuffer *
384
gst_filesrc_map_small_region (GstFileSrc *src, off_t offset, size_t size)
385
{
386 387
  size_t mapsize;
  off_t mod, mapbase;
388 389
  GstBuffer *map;

390
/*  printf("attempting to map a small buffer at %d+%d\n",offset,size); */
391

392
  /* if the offset starts at a non-page boundary, we have to special case */
393
  if ((mod = offset % src->pagesize)) {
394 395
    GstBuffer *ret;

396
    mapbase = offset - mod;
397
    mapsize = ((size + mod + src->pagesize - 1) / src->pagesize) * src->pagesize;
398
/*    printf("not on page boundaries, resizing map to %d+%d\n",mapbase,mapsize);*/
399
    map = gst_filesrc_map_region(src, mapbase, mapsize);
400 401 402 403 404
    ret = gst_buffer_create_sub (map, offset - mapbase, size);

    gst_buffer_unref (map);

    return ret;
405 406 407 408 409 410 411 412 413 414
  }

  return gst_filesrc_map_region(src,offset,size);
}

typedef struct {
  off_t offset;
  off_t size;
} GstFileSrcRegion;

415
/* This allows us to search for a potential mmap region. */
416 417 418 419 420
static gint
gst_filesrc_search_region_match (gpointer a, gpointer b)
{
  GstFileSrcRegion *r = (GstFileSrcRegion *)b;

421
  /* trying to walk b down the tree, current node is a */
422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439
  if (r->offset < GST_BUFFER_OFFSET(a)) return -1;
  else if (r->offset >= (GST_BUFFER_OFFSET(a) + GST_BUFFER_SIZE(a))) return 1;
  else if ((r->offset + r->size) <= (GST_BUFFER_OFFSET(a) + GST_BUFFER_SIZE(a))) return 0;

  return -2;
}

/**
 * gst_filesrc_get:
 * @pad: #GstPad to push a buffer from
 *
 * Push a new buffer from the filesrc at the current offset.
 */
static GstBuffer *
gst_filesrc_get (GstPad *pad)
{
  GstFileSrc *src;
  GstBuffer *buf = NULL, *map;
440 441
  size_t readsize;
  off_t readend,mapstart,mapend;
442
  GstFileSrcRegion region;
443
  int i;
444 445 446 447 448

  g_return_val_if_fail (pad != NULL, NULL);
  src = GST_FILESRC (gst_pad_get_parent (pad));
  g_return_val_if_fail (GST_FLAG_IS_SET (src, GST_FILESRC_OPEN), NULL);

449
  /* check for seek */
450
  if (src->seek_happened) {
451 452
    GstEvent *event;

453
    src->seek_happened = FALSE;
454 455
    GST_DEBUG (GST_CAT_EVENT, "filesrc sending discont\n");
    event = gst_event_new_discontinuous (FALSE, GST_FORMAT_BYTES, src->curoffset, NULL);
Wim Taymans's avatar
Wim Taymans committed
456
    GST_EVENT_DISCONT_NEW_MEDIA (event) = FALSE;
457 458
    src->need_flush = FALSE;
    return GST_BUFFER (event);
Wim Taymans's avatar
Wim Taymans committed
459 460 461 462
  }
  /* check for flush */
  if (src->need_flush) {
    src->need_flush = FALSE;
463
    GST_DEBUG (GST_CAT_EVENT, "filesrc sending flush\n");
Wim Taymans's avatar
Wim Taymans committed
464
    return GST_BUFFER (gst_event_new_flush ());
465 466
  }

467
  /* check for EOF */
468
  if (src->curoffset == src->filelen) {
469
    GST_DEBUG (0, "filesrc eos %lld %lld\n", src->curoffset, src->filelen);
470
    gst_element_set_eos (GST_ELEMENT (src));
Wim Taymans's avatar
Wim Taymans committed
471
    return GST_BUFFER (gst_event_new (GST_EVENT_EOS));
472 473
  }

474
  /* calculate end pointers so we don't have to do so repeatedly later */
475
  readsize = src->block_size;
476
  readend = src->curoffset + src->block_size;		/* note this is the byte *after* the read */
477
  mapstart = GST_BUFFER_OFFSET(src->mapbuf);
478
  mapend = mapstart + GST_BUFFER_SIZE(src->mapbuf);	/* note this is the byte *after* the map */
479

480
  /* check to see if we're going to overflow the end of the file */
481 482 483 484 485
  if (readend > src->filelen) {
    readsize = src->filelen - src->curoffset;
    readend = src->curoffset;
  }

486
  /* if the start is past the mapstart */
487
  if (src->curoffset >= mapstart) {
488 489
    /* if the end is before the mapend, the buffer is in current mmap region... */
    /* ('cause by definition if readend is in the buffer, so's readstart) */
490
    if (readend <= mapend) {
491 492
      fs_print ("read buf %d+%d lives in current mapbuf %d+%d, creating subbuffer of mapbuf\n",
             src->curoffset,readsize,GST_BUFFER_OFFSET(src->mapbuf),GST_BUFFER_SIZE(src->mapbuf));
493
      buf = gst_buffer_create_sub (src->mapbuf, src->curoffset - GST_BUFFER_OFFSET(src->mapbuf),
494
                                   readsize);
495

496
    /* if the start actually is within the current mmap region, map an overlap buffer */
497
    } else if (src->curoffset < mapend) {
498 499
      fs_print ("read buf %d+%d starts in mapbuf %d+%d but ends outside, creating new mmap\n",
             src->curoffset,readsize,GST_BUFFER_OFFSET(src->mapbuf),GST_BUFFER_SIZE(src->mapbuf));
500
      buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
501 502
    }

503
    /* the only other option is that buffer is totally outside, which means we search for it */
504

505 506
  /* now we can assume that the start is *before* the current mmap region */
  /* if the readend is past mapstart, we have two options */
507
  } else if (readend >= mapstart) {
508 509 510
    /* either the read buffer overlaps the start of the mmap region */
    /* or the read buffer fully contains the current mmap region    */
    /* either way, it's really not relevant, we just create a new region anyway*/
511 512
    fs_print ("read buf %d+%d starts before mapbuf %d+%d, but overlaps it\n",
             src->curoffset,readsize,GST_BUFFER_OFFSET(src->mapbuf),GST_BUFFER_SIZE(src->mapbuf));
513
    buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
514 515
  }

516
  /* then deal with the case where the read buffer is totally outside */
517
  if (buf == NULL) {
518
    /* first check to see if there's a map that covers the right region already */
519
    fs_print ("searching for mapbuf to cover %d+%d\n",src->curoffset,readsize);
520
    region.offset = src->curoffset;
521
    region.size = readsize;
522
    map = g_tree_search (src->map_regions,
523
			 (GCompareFunc) gst_filesrc_search_region_match,
524
			 (gpointer)&region);
525

526
    /* if we found an exact match, subbuffer it */
527
    if (map != NULL) {
528
      fs_print ("found mapbuf at %d+%d, creating subbuffer\n",GST_BUFFER_OFFSET(map),GST_BUFFER_SIZE(map));
529
      buf = gst_buffer_create_sub (map, src->curoffset - GST_BUFFER_OFFSET(map), readsize);
530

531
    /* otherwise we need to create something out of thin air */
532
    } else {
533
      /* if the read buffer crosses a mmap region boundary, create a one-off region */
534
      if ((src->curoffset / src->mapsize) != (readend / src->mapsize)) {
535 536
        fs_print ("read buf %d+%d crosses a %d-byte boundary, creating a one-off\n",
               src->curoffset,readsize,src->mapsize);
537
        buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
538

539
      /* otherwise we will create a new mmap region and set it to the default */
540 541
      } else {
        off_t nextmap = src->curoffset - (src->curoffset % src->mapsize);
542 543
        fs_print ("read buf %d+%d in new mapbuf at %d+%d, mapping and subbuffering\n",
               src->curoffset,readsize,nextmap,src->mapsize);
544
        /* first, we're done with the old mapbuf */
545
        gst_buffer_unref(src->mapbuf);
546
        /* create a new one */
547
        src->mapbuf = gst_filesrc_map_region (src, nextmap, src->mapsize);
548
        /* subbuffer it */
549
        buf = gst_buffer_create_sub (src->mapbuf, src->curoffset - GST_BUFFER_OFFSET(src->mapbuf), readsize);
550 551 552 553
      }
    }
  }

554 555
  /* if we need to touch the buffer (to bring it into memory), do so */
  if (src->touch) {
556
    volatile guchar *p = GST_BUFFER_DATA (buf), c;
557
    for (i=0;i<GST_BUFFER_SIZE(buf);i+=src->pagesize)
558
      c = p[i];
559 560
  }

561 562
  /* we're done, return the buffer */
  src->curoffset += GST_BUFFER_SIZE(buf);
563
  g_object_notify (G_OBJECT (src), "offset");
564 565 566 567 568 569 570 571 572
  return buf;
}

/* open the file and mmap it, necessary to go to READY state */
static gboolean 
gst_filesrc_open_file (GstFileSrc *src)
{
  g_return_val_if_fail (!GST_FLAG_IS_SET (src ,GST_FILESRC_OPEN), FALSE);

573
  GST_DEBUG(0, "opening file %s",src->filename);
574 575 576 577

  /* open the file */
  src->fd = open (src->filename, O_RDONLY);
  if (src->fd < 0) {
578 579
    gst_element_error (GST_ELEMENT (src), "opening file \"%s\" (%s)", 
    		       src->filename, strerror (errno), NULL);
580 581
    return FALSE;
  } else {
582 583 584 585 586 587 588 589 590 591 592
    /* check if it is a regular file, otherwise bail out */
    struct stat stat_results;

    fstat(src->fd, &stat_results);

    if (!S_ISREG(stat_results.st_mode)) {
      gst_element_error (GST_ELEMENT (src), "opening file \"%s\" failed. it isn't a regular file", 
      					src->filename, NULL);
      close(src->fd);
      return FALSE;
    }
593
		
594 595 596 597
    /* find the file length */
    src->filelen = lseek (src->fd, 0, SEEK_END);
    lseek (src->fd, 0, SEEK_SET);

598
    /* allocate the first mmap'd region */
599 600 601 602
    src->mapbuf = gst_filesrc_map_region (src, 0, src->mapsize);

    src->curoffset = 0;

603 604 605
    /* now notify of the changes */
    g_object_freeze_notify (G_OBJECT (src));
    g_object_notify (G_OBJECT (src), "filesize");
606
    g_object_notify (G_OBJECT (src), "offset");
607 608
    g_object_thaw_notify (G_OBJECT (src));

609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626
    GST_FLAG_SET (src, GST_FILESRC_OPEN);
  }
  return TRUE;
}

/* unmap and close the file */
static void
gst_filesrc_close_file (GstFileSrc *src)
{
  g_return_if_fail (GST_FLAG_IS_SET (src, GST_FILESRC_OPEN));

  /* close the file */
  close (src->fd);

  /* zero out a lot of our state */
  src->fd = 0;
  src->filelen = 0;
  src->curoffset = 0;
627 628 629
  /* and notify that things changed */
  g_object_freeze_notify (G_OBJECT (src));
  g_object_notify (G_OBJECT (src), "filesize");
630
  g_object_notify (G_OBJECT (src), "offset");
631 632
  g_object_thaw_notify (G_OBJECT (src));

633 634
  if (src->mapbuf)
    gst_buffer_unref (src->mapbuf);
635 636 637 638 639 640 641 642

  GST_FLAG_UNSET (src, GST_FILESRC_OPEN);
}


static GstElementStateReturn
gst_filesrc_change_state (GstElement *element)
{
643
  GstFileSrc *src = GST_FILESRC(element);
644

645 646
  switch (GST_STATE_TRANSITION (element)) {
    case GST_STATE_NULL_TO_READY:
647 648 649 650
      break;
    case GST_STATE_READY_TO_NULL:
      break;
    case GST_STATE_READY_TO_PAUSED:
651 652 653 654 655
      if (!GST_FLAG_IS_SET (element, GST_FILESRC_OPEN)) {
        if (!gst_filesrc_open_file (GST_FILESRC (element)))
          return GST_STATE_FAILURE;
      }
      break;
656
    case GST_STATE_PAUSED_TO_READY:
657 658
      if (GST_FLAG_IS_SET (element, GST_FILESRC_OPEN))
        gst_filesrc_close_file (GST_FILESRC (element));
659
      src->seek_happened = TRUE;
660
      break;
661 662
    default:
      break;
663 664 665 666 667 668 669
  }

  if (GST_ELEMENT_CLASS (parent_class)->change_state)
    return GST_ELEMENT_CLASS (parent_class)->change_state (element);

  return GST_STATE_SUCCESS;
}
670

671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696
static gboolean
gst_filesrc_srcpad_query (GstPad *pad, GstPadQueryType type,
		          GstFormat *format, gint64 *value)
{
  GstFileSrc *src = GST_FILESRC (GST_PAD_PARENT (pad));

  switch (type) {
    case GST_PAD_QUERY_TOTAL:
      if (*format != GST_FORMAT_BYTES) {
	return FALSE;
      }
      *value = src->filelen;
      break;
    case GST_PAD_QUERY_POSITION:
      if (*format != GST_FORMAT_BYTES) {
	return FALSE;
      }
      *value = src->curoffset;
      break;
    default:
      return FALSE;
      break;
  }
  return TRUE;
}

697
static gboolean
Wim Taymans's avatar
Wim Taymans committed
698
gst_filesrc_srcpad_event (GstPad *pad, GstEvent *event)
699
{
700
  GstFileSrc *src = GST_FILESRC (GST_PAD_PARENT (pad));
701

702 703
  GST_DEBUG(0, "event %d", GST_EVENT_TYPE (event));

Wim Taymans's avatar
Wim Taymans committed
704 705
  switch (GST_EVENT_TYPE (event)) {
    case GST_EVENT_SEEK:
706 707 708 709 710
      if (GST_EVENT_SEEK_FORMAT (event) != GST_FORMAT_BYTES) {
	return FALSE;
      }
      switch (GST_EVENT_SEEK_METHOD (event)) {
        case GST_SEEK_METHOD_SET:
711
          src->curoffset = (guint64) GST_EVENT_SEEK_OFFSET (event);
712
          GST_DEBUG(0, "seek set pending to %lld", src->curoffset);
713
	  break;
714
        case GST_SEEK_METHOD_CUR:
715
          src->curoffset += GST_EVENT_SEEK_OFFSET (event);
716
          GST_DEBUG(0, "seek cur pending to %lld", src->curoffset);
717
	  break;
718
        case GST_SEEK_METHOD_END:
719
          src->curoffset = src->filelen - ABS (GST_EVENT_SEEK_OFFSET (event));
720
          GST_DEBUG(0, "seek end pending to %lld", src->curoffset);
721 722 723 724 725
	  break;
	default:
          return FALSE;
	  break;
      }
726
      g_object_notify (G_OBJECT (src), "offset");  
Wim Taymans's avatar
Wim Taymans committed
727
      src->seek_happened = TRUE;
728
      src->need_flush = GST_EVENT_SEEK_FLAGS(event) & GST_SEEK_FLAG_FLUSH;
Wim Taymans's avatar
Wim Taymans committed
729
      break;
730 731 732 733 734 735 736
    case GST_EVENT_SIZE:
      if (GST_EVENT_SIZE_FORMAT (event) != GST_FORMAT_BYTES) {
	return FALSE;
      }
      src->block_size = GST_EVENT_SIZE_VALUE (event);
      g_object_notify (G_OBJECT (src), "blocksize");  
      break;
Wim Taymans's avatar
Wim Taymans committed
737 738 739
    case GST_EVENT_FLUSH:
      src->need_flush = TRUE;
      break;
Wim Taymans's avatar
Wim Taymans committed
740
    default:
741
      return FALSE;
Wim Taymans's avatar
Wim Taymans committed
742
      break;
743 744
  }

Wim Taymans's avatar
Wim Taymans committed
745
  return TRUE;
746
}