diff options
author | toma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da> | 2009-11-25 17:56:58 +0000 |
---|---|---|
committer | toma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da> | 2009-11-25 17:56:58 +0000 |
commit | e2de64d6f1beb9e492daf5b886e19933c1fa41dd (patch) | |
tree | 9047cf9e6b5c43878d5bf82660adae77ceee097a /mpeglib/lib/decoder/commandPipe.h | |
download | tdemultimedia-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 'mpeglib/lib/decoder/commandPipe.h')
-rw-r--r-- | mpeglib/lib/decoder/commandPipe.h | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/mpeglib/lib/decoder/commandPipe.h b/mpeglib/lib/decoder/commandPipe.h new file mode 100644 index 00000000..4ecf84eb --- /dev/null +++ b/mpeglib/lib/decoder/commandPipe.h @@ -0,0 +1,78 @@ +/* + thread safe fifo queue for commands + 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 __COMMAND_PIPE_H +#define __COMMAND_PIPE_H + + + +#include "command.h" + +/** + This queue deals with the ugly deadlock problem. + We insert all commands in a queue and the thread + polls this queue for next commands. +*/ + +class CommandPipe { + + Command** commandArray; + int entries; + int readPos; + int writePos; + + abs_thread_mutex_t pipeMut; + abs_thread_cond_t spaceCond; + abs_thread_cond_t emptyCond; + abs_thread_cond_t dataCond; + + public: + CommandPipe(); + ~CommandPipe(); + + // writer thread: + void sendCommand(Command& cmd); + void sendCommandNoWait(Command& cmd); + + void waitForEmptyQueue(); + + // reader thread + int hasCommand(Command* dest); + void waitForCommand(); + + + + + private: + void sendCommand(Command& cmd,int lWait); + + void lockCommandPipe(); + void unlockCommandPipe(); + + + // writer thread wait here + void waitForSpace(); + void waitForEmpty(); + void waitForData(); + + // reader thread signals this + void signalSpace(); + void signalEmpty(); + void signalData(); + + + + +}; + +#endif |