libdemuxer...

git-svn-id: svn://svn.mplayerhq.hu/mplayer/trunk@2311 b3059339-0415-0410-9bf9-f77b7e298cf2

1 files changed, 141 insertions, 0 deletions

diff --git a/libmpdemux/stream.h b/libmpdemux/stream.h
new file mode 100644
index 0000000000..2859b68bc4
--- /dev/null
+++ b/libmpdemux/stream.h
@@ -0,0 +1,141 @@
+#ifndef __STREAM_H
+#define __STREAM_H
+
+#define STREAM_BUFFER_SIZE 2048
+
+#define STREAMTYPE_FILE 0
+#define STREAMTYPE_VCD  1
+#define STREAMTYPE_STREAM 2    // same as FILE but no seeking (for stdin)
+#define STREAMTYPE_DVD  3
+#define STREAMTYPE_MEMORY  4
+
+#define VCD_SECTOR_SIZE 2352
+#define VCD_SECTOR_OFFS 24
+#define VCD_SECTOR_DATA 2324
+
+int vcd_seek_to_track(int fd,int track);
+void vcd_read_toc(int fd);
+
+#ifdef VCD_CACHE
+void vcd_cache_init(int s);
+#endif
+
+typedef struct {
+  int fd;
+  off_t pos;
+  int eof;
+  int type; // 0=file 1=VCD
+  unsigned int buf_pos,buf_len;
+  off_t start_pos,end_pos;
+  void* priv; // used for DVD
+  unsigned char buffer[STREAM_BUFFER_SIZE>VCD_SECTOR_SIZE?STREAM_BUFFER_SIZE:VCD_SECTOR_SIZE];
+} stream_t;
+
+int stream_fill_buffer(stream_t *s);
+
+int stream_seek_long(stream_t *s,off_t pos);
+
+inline static int stream_read_char(stream_t *s){
+  return (s->buf_pos<s->buf_len)?s->buffer[s->buf_pos++]:
+    (stream_fill_buffer(s)?s->buffer[s->buf_pos++]:-256);
+//  if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
+//  stream_fill_buffer(s);
+//  if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
+//  return 0; // EOF
+}
+
+inline static unsigned int stream_read_word(stream_t *s){
+  int x,y;
+  x=stream_read_char(s);
+  y=stream_read_char(s);
+  return (x<<8)|y;
+}
+
+inline static unsigned int stream_read_dword(stream_t *s){
+  unsigned int y;
+  y=stream_read_char(s);
+  y=(y<<8)|stream_read_char(s);
+  y=(y<<8)|stream_read_char(s);
+  y=(y<<8)|stream_read_char(s);
+  return y;
+}
+
+inline static unsigned int stream_read_word_le(stream_t *s){
+  int x,y;
+  x=stream_read_char(s);
+  y=stream_read_char(s);
+  return (y<<8)|x;
+}
+
+inline static unsigned int stream_read_dword_le(stream_t *s){
+  unsigned int y;
+  y=stream_read_char(s);
+  y|=stream_read_char(s)<<8;
+  y|=stream_read_char(s)<<16;
+  y|=stream_read_char(s)<<24;
+  return y;
+}
+
+inline static void stream_read(stream_t *s,char* mem,int len){
+  while(len>0){
+    int x;
+    x=s->buf_len-s->buf_pos;
+    if(x==0){
+      if(!stream_fill_buffer(s)) return; // EOF
+      x=s->buf_len-s->buf_pos;
+    }
+    if(s->buf_pos>s->buf_len) printf("stream_read: WARNING! s->buf_pos>s->buf_len\n");
+    if(x>len) x=len;
+    memcpy(mem,&s->buffer[s->buf_pos],x);
+    s->buf_pos+=x; mem+=x; len-=x;
+  }
+}
+
+inline static int stream_eof(stream_t *s){
+  return s->eof;
+}
+
+inline static off_t stream_tell(stream_t *s){
+  return s->pos+s->buf_pos-s->buf_len;
+}
+
+inline static int stream_seek(stream_t *s,off_t pos){
+
+//  if(verbose>=3) printf("seek to 0x%qX\n",(long long)pos);
+
+  if(pos<s->pos){
+    off_t x=pos-(s->pos-s->buf_len);
+    if(x>=0){
+      s->buf_pos=x;
+//      putchar('*');fflush(stdout);
+      return 1;
+    }
+  }
+  
+  return stream_seek_long(s,pos);
+}
+
+inline static int stream_skip(stream_t *s,int len){
+  if(len<0 || (len>2*STREAM_BUFFER_SIZE && s->type!=STREAMTYPE_STREAM)){
+    // negative or big skip!
+    return stream_seek(s,stream_tell(s)+len);
+  }
+  while(len>0){
+    int x=s->buf_len-s->buf_pos;
+    if(x==0){
+      if(!stream_fill_buffer(s)) return 0; // EOF
+      x=s->buf_len-s->buf_pos;
+    }
+    if(x>len) x=len;
+    //memcpy(mem,&s->buf[s->buf_pos],x);
+    s->buf_pos+=x; len-=x;
+  }
+  return 1;
+}
+
+void stream_reset(stream_t *s);
+stream_t* new_stream(int fd,int type);
+void free_stream(stream_t *s);
+stream_t* new_memory_stream(unsigned char* data,int len);
+
+#endif // __STREAM_H