From a222f27c4a17ed8f9809cda7861fe5f23d4cc0c1 Mon Sep 17 00:00:00 2001 From: Michael Sevakis Date: Sat, 29 Dec 2007 19:46:35 +0000 Subject: mpegplayer: Make playback engine fully seekable and frame-accurate and split into logical parts. Be sure to have all current features work. Actual UI for seeking will be added soon. Recommended GOP size is about 15-30 frames depending on target or seeking can be slow with really long GOPs (nature of MPEG video). More refined encoding recommendations for a particular player should be posted soon. git-svn-id: svn://svn.rockbox.org/rockbox/trunk@15977 a1c6a512-1295-4272-9138-f99709370657 --- apps/plugins/mpegplayer/disk_buf.h | 132 +++++++++++++++++++++++++++++++++++++ 1 file changed, 132 insertions(+) create mode 100644 apps/plugins/mpegplayer/disk_buf.h (limited to 'apps/plugins/mpegplayer/disk_buf.h') diff --git a/apps/plugins/mpegplayer/disk_buf.h b/apps/plugins/mpegplayer/disk_buf.h new file mode 100644 index 0000000000..90e72fac2f --- /dev/null +++ b/apps/plugins/mpegplayer/disk_buf.h @@ -0,0 +1,132 @@ +/*************************************************************************** + * __________ __ ___. + * Open \______ \ ____ ____ | | _\_ |__ _______ ___ + * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ / + * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < < + * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \ + * \/ \/ \/ \/ \/ + * $Id$ + * + * AV disk buffer declarations + * + * Copyright (c) 2007 Michael Sevakis + * + * All files in this archive are subject to the GNU General Public License. + * See the file COPYING in the source tree root for full license agreement. + * + * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY + * KIND, either express or implied. + * + ****************************************************************************/ +#ifndef DISK_BUF_H +#define DISK_BUF_H + +#define DISK_BUF_PAGE_SHIFT 15 /* 32KB cache lines */ +#define DISK_BUF_PAGE_SIZE (1 << DISK_BUF_PAGE_SHIFT) +#define DISK_BUF_PAGE_MASK (DISK_BUF_PAGE_SIZE-1) + +enum +{ + DISK_BUF_NOTIFY_ERROR = -1, + DISK_BUF_NOTIFY_NULL = 0, + DISK_BUF_NOTIFY_OK, + DISK_BUF_NOTIFY_TIMEDOUT, + DISK_BUF_NOTIFY_PROCESS_EVENT, + DISK_BUF_NOTIFY_REGISTERED, +}; + +/** Macros to map file offsets to cached data **/ + +/* Returns a cache tag given a file offset */ +#define MAP_OFFSET_TO_TAG(o) \ + ((o) >> DISK_BUF_PAGE_SHIFT) + +/* Returns the cache page number given a file offset */ +#define MAP_OFFSET_TO_PAGE(o) \ + (MAP_OFFSET_TO_TAG(o) % disk_buf.pgcount) + +/* Returns the buffer offset given a file offset */ +#define MAP_OFFSET_TO_BUFFER(o) \ + (MAP_OFFSET_TO_PAGE(o) * DISK_BUF_PAGE_SIZE) + +struct dbuf_range +{ + uint32_t tag_start; + uint32_t tag_end; + int pg_start; +}; + +/* This object is an extension of the stream manager and handles some + * playback events as well as buffering */ +struct disk_buf +{ + struct thread_entry *thread; + struct event_queue *q; + uint8_t *start; /* Start pointer */ + uint8_t *end; /* End of buffer pointer less MPEG_GUARDBUF_SIZE. The + guard space is used to wrap data at the buffer start to + pass continuous data packets */ + uint8_t *tail; /* Location of last data + 1 filled into the buffer */ + ssize_t size; /* The buffer length _not_ including the guard space (end-start) */ + int pgcount; /* Total number of available cached pages */ + uint32_t *cache; /* Pointer to cache structure - allocated on buffer */ + int in_file; /* File being read */ + ssize_t filesize; /* Size of file in_file in bytes */ + int file_pages; /* Number of pages in file (rounded up) */ + off_t offset; /* Current position (random access) */ + off_t win_left; /* Left edge of buffer window (streaming) */ + off_t win_right; /* Right edge of buffer window (streaming) */ + uint32_t time_last; /* Last time watermark was checked */ + off_t pos_last; /* Last position at watermark check time */ + ssize_t low_wm; /* The low watermark for automatic rebuffering */ + int status; /* Status as stream */ + int state; /* Current thread state */ + bool need_seek; /* Need to seek because a read was not contiguous */ +}; + +extern struct disk_buf disk_buf NOCACHEBSS_ATTR; + +static inline bool disk_buf_is_data_ready(struct stream_hdr *sh, + ssize_t margin) +{ + /* Data window available? */ + off_t right = sh->win_right; + + /* Margins past end-of-file can still return true */ + if (right > disk_buf.filesize - margin) + right = disk_buf.filesize - margin; + + return sh->win_left >= disk_buf.win_left && + right + margin <= disk_buf.win_right; +} + + +bool disk_buf_init(void); +void disk_buf_exit(void); + +int disk_buf_open(const char *filename); +void disk_buf_close(void); +ssize_t _disk_buf_getbuffer(size_t size, void **pp, void **pwrap, + size_t *sizewrap); +#define disk_buf_getbuffer(size, pp, pwrap, sizewrap) \ + _disk_buf_getbuffer((size), PUN_PTR(void **, (pp)), \ + PUN_PTR(void **, (pwrap)), (sizewrap)) +ssize_t disk_buf_read(void *buffer, size_t size); +ssize_t disk_buf_lseek(off_t offset, int whence); + +static inline off_t disk_buf_ftell(void) + { return disk_buf.offset; } + +static inline ssize_t disk_buf_filesize(void) + { return disk_buf.filesize; } + +ssize_t disk_buf_prepare_streaming(off_t pos, size_t len); +ssize_t disk_buf_set_streaming_window(off_t left, off_t right); +void * disk_buf_offset2ptr(off_t offset); +int disk_buf_check_streaming_window(off_t left, off_t right); + +intptr_t disk_buf_send_msg(long id, intptr_t data); +void disk_buf_post_msg(long id, intptr_t data); +void disk_buf_reply_msg(intptr_t retval); + +#endif /* DISK_BUF_H */ -- cgit v1.2.3