mirrors/recycled-ni-libstb-hal
1
0
Fork 0
mirror of https://github.com/tuxbox-fork-migrations/recycled-ni-libstb-hal.git synced 2025-08-26 23:12:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix thread namespace

Browse Source 
Origin commit data
------------------
Branch: master
Commit: 3ef2eeb8aa
Author: smogm <smogm@vh0st.me>
Date: 2015-01-12 (Mon, 12 Jan 2015)


------------------
No further description and justification available within origin commit message!

------------------
This commit was generated by Migit
This commit is contained in:
smogm
2015-01-12 16:38:28 +01:00
parent 7f2f83b16e
commit 03a7525218
8 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
common/thread_abstraction.cpp
View File

@@ -1,12 +1,12 @@
#include "thread_abstraction.h" #include "thread_abstraction.h"
Thread::Thread() : SimpleThread::SimpleThread() :
mIsRunning(false), mIsRunning(false),
mThread() mThread()
{ {
} }
Thread::~Thread() SimpleThread::~SimpleThread()
{ {
// if thread is still running on object destruction, cancel thread the hard way: // if thread is still running on object destruction, cancel thread the hard way:
if (mIsRunning) if (mIsRunning)
@@ -15,20 +15,20 @@ Thread::~Thread()
} }
} }
void Thread::startThread() void SimpleThread::startThread()
{ {
mIsRunning = true; mIsRunning = true;
pthread_create(&mThread, 0, &Thread::runThread, this); pthread_create(&mThread, 0, &SimpleThread::runThread, this);
} }
void Thread::joinThread() void SimpleThread::joinThread()
{ {
pthread_join(mThread, 0); pthread_join(mThread, 0);
mIsRunning = false; mIsRunning = false;
} }
void* Thread::runThread(void* ptr) void* SimpleThread::runThread(void* ptr)
{ {
((Thread*)ptr)->run(); static_cast<SimpleThread*>(ptr)->run();
return 0; return 0;
} }

14
common/thread_abstraction.h
View File

@@ -1,20 +1,20 @@
#ifndef _THREAD_ABSTRACTION_H #ifndef _SIMPLETHREAD_ABSTRACTION_H
#define _THREAD_ABSTRACTION_H #define _SIMPLETHREAD_ABSTRACTION_H
#include <pthread.h> #include <pthread.h>
class Thread class SimpleThread
{ {
bool mIsRunning; bool mIsRunning;
pthread_t mThread; pthread_t mThread;
static void* runThread(void*); static void* runThread(void*);
Thread(const Thread&); SimpleThread(const SimpleThread&);
const Thread& operator=(const Thread&); const SimpleThread& operator=(const SimpleThread&);
public: public:
Thread(); SimpleThread();
~Thread(); ~SimpleThread();
void startThread(); void startThread();
void joinThread(); void joinThread();

4
generic-pc/audio.cpp
View File

@@ -103,7 +103,7 @@ int cAudio::Start(void)
{ {
lt_debug("%s >\n", __func__); lt_debug("%s >\n", __func__);
if (! HAL_nodec) if (! HAL_nodec)
startThread(); SimpleThread::startThread();
lt_debug("%s <\n", __func__); lt_debug("%s <\n", __func__);
return 0; return 0;
} }
@@ -114,7 +114,7 @@ int cAudio::Stop(void)
if (thread_started) if (thread_started)
{ {
thread_started = false; thread_started = false;
joinThread(); SimpleThread::joinThread();
} }
lt_debug("%s <\n", __func__); lt_debug("%s <\n", __func__);
return 0; return 0;

2
generic-pc/audio_lib.h
View File

@@ -38,7 +38,7 @@ typedef enum
AUDIO_FMT_ADVANCED = AUDIO_FMT_MLP AUDIO_FMT_ADVANCED = AUDIO_FMT_MLP
} AUDIO_FORMAT; } AUDIO_FORMAT;
class cAudio : public Thread class cAudio : public SimpleThread
{ {
friend class cPlayback; friend class cPlayback;
private: private:

4
generic-pc/glfb.cpp
View File

@@ -97,7 +97,7 @@ GLFramebuffer::GLFramebuffer(int x, int y): mReInit(true), mShutDown(false), mIn
if (input_fd < 0) if (input_fd < 0)
lt_info("%s: could not open /tmp/neutrino.input FIFO: %m\n", __func__); lt_info("%s: could not open /tmp/neutrino.input FIFO: %m\n", __func__);
initKeys(); initKeys();
startThread(); SimpleThread::startThread();
while (!mInitDone) while (!mInitDone)
usleep(1); usleep(1);
} }
@@ -105,7 +105,7 @@ GLFramebuffer::GLFramebuffer(int x, int y): mReInit(true), mShutDown(false), mIn
GLFramebuffer::~GLFramebuffer() GLFramebuffer::~GLFramebuffer()
{ {
mShutDown = true; mShutDown = true;
joinThread(); SimpleThread::joinThread();
if (input_fd >= 0) if (input_fd >= 0)
close(input_fd); close(input_fd);
} }

2
generic-pc/glfb.h
View File

@@ -31,7 +31,7 @@ extern "C" {
#include <libavutil/rational.h> #include <libavutil/rational.h>
} }
class GLFramebuffer : public Thread class GLFramebuffer : public SimpleThread
{ {
public: public:
GLFramebuffer(int x, int y); GLFramebuffer(int x, int y);

4
generic-pc/video.cpp
View File

@@ -141,7 +141,7 @@ int cVideo::Start(void *, unsigned short, unsigned short, void *)
{ {
lt_debug("%s running %d >\n", __func__, thread_running); lt_debug("%s running %d >\n", __func__, thread_running);
if (!thread_running && !HAL_nodec) if (!thread_running && !HAL_nodec)
startThread(); SimpleThread::startThread();
lt_debug("%s running %d <\n", __func__, thread_running); lt_debug("%s running %d <\n", __func__, thread_running);
return 0; return 0;
} }
@@ -151,7 +151,7 @@ int cVideo::Stop(bool)
lt_debug("%s running %d >\n", __func__, thread_running); lt_debug("%s running %d >\n", __func__, thread_running);
if (thread_running) { if (thread_running) {
thread_running = false; thread_running = false;
joinThread(); SimpleThread::joinThread();
} }
lt_debug("%s running %d <\n", __func__, thread_running); lt_debug("%s running %d <\n", __func__, thread_running);
return 0; return 0;

2
generic-pc/video_lib.h
View File

@@ -120,7 +120,7 @@ typedef enum
#define VDEC_MAXBUFS 0x30 #define VDEC_MAXBUFS 0x30
class cVideo : public Thread class cVideo : public SimpleThread
{ {
friend class GLFramebuffer; friend class GLFramebuffer;
friend class cDemux; friend class cDemux;