DVD

Development Platform:
Unix_Linux

mpeg2buff.hh：Code Content
							/*
   File: mpeg2buff.hh
   By: Alex Theo de Jong
   Created: February 1996
   Description:
   "Multi-Threading Save" read/write buffer
*/
#ifndef __mpeg2buff_hh
#define __mpeg2buff_hh
#ifdef __GNUG__
#pragma interface
#endif
#include <unistd.h>
#include <sys/time.h>
class Memory {
 private:
  // Normal memory space
  unsigned char *mem_min, *mem_max, *mem_begin, *mem_end;
  short end_ahead;
 protected:
  int mem_size;
 protected:
  Memory(int size);
  ~Memory();
  int unused();
  int put(unsigned char* data, int size);
  int get(unsigned char* data, int size);
  int reset();
  unsigned char getchr() ;
  int mem_skip(int bytes);
 public:
  int used();
  // USE THESE IN COMBINATION WITH waitforbytes!!!!
  unsigned int getbyte();
#if defined(IRIX) && !defined(__GNUG__)
  // Only with Native SGI C++ Compiler
  unsigned int value; // used in getbits32
  unsigned int getbits32(){ 
    return (((((value=getchr()<<24)) |= (getchr()<<16)) |= (getchr()<<8)) |= getchr());
  }
#else
  // unsigned int getword(){ return ((getchr() << 8) | getchr()); }
  // unsigned int getbits24(){ return ((getchr() << 16) | (getchr() << 8) | getchar()); }
  unsigned int getbits32();
#endif
};
class Mpeg2Buffer : public Memory {
 private:
  int rsize;  // variable to be used in waitforbytes
  Condition memory_in_cond, memory_out_cond;
  MutexLock mem_lock;
 protected:
  void lock();
  void unlock();
  void wait_write();
  void wait_read();
  void signal_write();
  void signal_read();
  int completed;
 public:
  Mpeg2Buffer(int size);
  ~Mpeg2Buffer();
  int close();
  int waitforbytes(int size);
  int available();
  int maximum() ;
  void signal_buffer();
  // Normal read/write operations
  int read(unsigned char* data, int size);
  int write(unsigned char* data, int size);
  int skipbytes(int size);
};
class Mpeg2Input : public Mpeg2Buffer {
  int fd;
  int buffer_size, bitrate;
  athr_t id;
 public:
  Mpeg2Input(const char* filename, int size, int bitrate=0);
  ~Mpeg2Input(){ athr_join(id); ::close(fd); }
  static void* filereader(Mpeg2Input*);
};
class Mpeg2Timer {
  MutexLock timer_lock;
  Condition timer_cond;
  timespec time;
  timeval time_new;
  timeval time_out;
 protected:
  void lock();
  void unlock();
 public:
  Mpeg2Timer();
  ~Mpeg2Timer();
  int wait(int interval_usec);     // use while and yield
  int waitcond(int interval_usec); // use condition
};
#endif // __mpeg2buff_hh

						