From e2de64d6f1beb9e492daf5b886e19933c1fa41dd Mon Sep 17 00:00:00 2001 From: toma Date: Wed, 25 Nov 2009 17:56:58 +0000 Subject: Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features. BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdemultimedia@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da --- mpeglib/lib/input/threadSafeInputStream.h | 56 +++++++++++++++++++++++++++++++ 1 file changed, 56 insertions(+) create mode 100644 mpeglib/lib/input/threadSafeInputStream.h (limited to 'mpeglib/lib/input/threadSafeInputStream.h') diff --git a/mpeglib/lib/input/threadSafeInputStream.h b/mpeglib/lib/input/threadSafeInputStream.h new file mode 100644 index 00000000..0a29637b --- /dev/null +++ b/mpeglib/lib/input/threadSafeInputStream.h @@ -0,0 +1,56 @@ +/* + thread safe wrapper for input Stream + Copyright (C) 2000 Martin Vogt + + This program 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. + + For more information look at the file COPYRIGHT in this package + + */ + + +#ifndef __THREADSAFEINPUTSTREAM_H +#define __THREADSAFEINPUTSTREAM_H + +// read INTRO in threadQueue.h +// This class makes the inputStream (given in constructor) +// threadsafe by wrapping each call with a threadqueue. +// +// Important NOTE: the input pointer is the owned by this class !!! +// which means: we call delete on it! + +#include "../util/abstract/threadQueue.h" +#include "inputStream.h" + + +class ThreadSafeInputStream : public InputStream { + + ThreadQueue* threadQueue; + InputStream* input; + + public: + ThreadSafeInputStream(InputStream* input); + ~ThreadSafeInputStream(); + + + int open(const char* dest); + void close(); + int isOpen(); + + int eof(); + int read(char* ptr,int size); + int seek(long bytePos); + void clear(); + + long getByteLength(); + long getBytePosition(); + + void insertTimeStamp(TimeStamp* src,long key,int len); + TimeStamp* getTimeStamp(long key); + int bytesUntilNext(long key); + void print(); + +}; +#endif -- cgit v1.2.1