summaryrefslogtreecommitdiffstats
path: root/akode_artsplugin/arts_inputstream.h
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commite2de64d6f1beb9e492daf5b886e19933c1fa41dd (patch)
tree9047cf9e6b5c43878d5bf82660adae77ceee097a /akode_artsplugin/arts_inputstream.h
downloadtdemultimedia-e2de64d6f1beb9e492daf5b886e19933c1fa41dd.tar.gz
tdemultimedia-e2de64d6f1beb9e492daf5b886e19933c1fa41dd.zip
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
Diffstat (limited to 'akode_artsplugin/arts_inputstream.h')
-rw-r--r--akode_artsplugin/arts_inputstream.h152
1 files changed, 152 insertions, 0 deletions
diff --git a/akode_artsplugin/arts_inputstream.h b/akode_artsplugin/arts_inputstream.h
new file mode 100644
index 00000000..71f8797d
--- /dev/null
+++ b/akode_artsplugin/arts_inputstream.h
@@ -0,0 +1,152 @@
+/* aKode: aRts InputStream
+
+ Copyright (C) 2004 Allan Sandfeld Jensen <kde@carewolf.com>
+
+ 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; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+*/
+
+#ifndef _AKODE_ARTS_INPUTSTREAM_H
+#define _AKODE_ARTS_INPUTSTREAM_H
+
+extern "C" {
+#include <stdio.h>
+#include <fcntl.h>
+}
+
+#include <arts/dispatcher.h>
+
+#include <akode/file.h>
+#include <akode/bytebuffer.h>
+
+class Arts_InputStream : public aKode::File
+{
+protected:
+ // m_instream is mutable because Arts::InputStream has not marked const functions
+ mutable Arts::InputStream m_instream;
+ aKode::ByteBuffer *m_buffer;
+ bool m_open, m_seekable;
+ long m_pos;
+ long m_len;
+public:
+ Arts_InputStream(Arts::InputStream inputstream, aKode::ByteBuffer *buffer)
+ : File("arts_inputstream"),
+ m_instream(inputstream), m_buffer(buffer),
+ m_open(false), m_seekable(false),
+ m_pos(-1), m_len(-1)
+ {
+ m_instream.streamInit();
+ };
+ virtual ~Arts_InputStream() {
+ }
+ bool openRO() {
+ m_open = true;
+ m_pos = 0;
+// Arts::Dispatcher::lock();
+ m_len = m_instream.size();
+ m_seekable = m_instream.seekOk();
+ m_instream.streamStart();
+// Arts::Dispatcher::unlock();
+ return true;
+ }
+ void close() {
+ m_open = false;
+ m_instream.streamEnd();
+ }
+ long read(char* ptr, long num) {
+ if (!m_open) return -1;
+ if (num<=0) return 0;
+ long n = m_buffer->read(ptr,num,true);
+ m_pos += n;
+ return n;
+ }
+ long write(const char*, long) {
+ return -1;
+ }
+ bool seek(long to, int whence) {
+ if(!m_open || !seekable()) return false;
+
+ arts_debug("akode: InputStream seeking");
+
+ long newpos = 0;
+ switch (whence) {
+ case SEEK_SET:
+ newpos = to;
+ break;
+ case SEEK_CUR:
+ newpos = m_pos + to;
+ break;
+ case SEEK_END:
+ if (m_len < 0) return false;
+ newpos = m_len + to;
+ break;
+ default:
+ return false;
+ }
+
+ long s = m_instream.seek(newpos);
+ if (s >= 0) {
+ m_pos = s;
+ m_buffer->flush();
+ return true;
+ }
+ else
+ return false;
+ }
+
+ long position() const {
+ if(!m_open) return -1;
+ return m_pos;
+ }
+
+ long length() const {
+ if(!m_open) return -1;
+ return m_len;
+ }
+
+ bool seekable() const {
+ return m_seekable;
+ }
+
+ bool readable() const {
+ return true;
+ }
+
+ bool writeable() const {
+ return false;
+ }
+ // Arts-call needs to be protected since
+ // the member-functions here are called by another thread
+ bool eof() const {
+ if(!m_open) return true;
+ bool res = false;
+ if (m_buffer->empty()) {
+ Arts::Dispatcher::lock();
+ res = m_instream.eof();
+ Arts::Dispatcher::unlock();
+ }
+ return res;
+ }
+
+ bool error() const {
+ return (!m_open);
+ }
+
+ void fadvise() {
+ return;
+ }
+};
+
+#endif