Muldersoft/Simple-x264-Launcher
Muldersoft/Simple-x264-Launcher
1
0
Fork 0
Code Releases 1 Activity

Removed an obsolete class.

Browse Source
This commit is contained in:
LoRd_MuldeR 2014-01-29 16:32:26 +01:00
parent 9848d78beb
commit 34a1cfff51
2 changed files with 0 additions and 187 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

129
src/thread_ipc.cpp
View File

@ -1,129 +0,0 @@
///////////////////////////////////////////////////////////////////////////////
// Simple x264 Launcher
// Copyright (C) 2004-2013 LoRd_MuldeR <MuldeR2@GMX.de>
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program 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 General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// http://www.gnu.org/licenses/gpl-2.0.txt
///////////////////////////////////////////////////////////////////////////////
#include "thread_ipc.h"
#include "global.h"
#include <QSystemSemaphore>
#include <QSharedMemory>
static const char* s_key[3] =
{
"{53F0CAC8-75BC-449A-91DF-2417B2867087}",
"{20BD6A5F-B510-4764-937D-EE6598271801}",
"{F09C3D10-EC27-4F4D-BF9C-9957A23B8A70}"
};
IPCThread::IPCThread(void)
{
m_ipcReady = m_firstInstance = m_abort = false;
m_semaphore_r = new QSystemSemaphore(QString::fromLatin1(s_key[0]), 0);
m_semaphore_w = new QSystemSemaphore(QString::fromLatin1(s_key[1]), 1);
m_sharedMem = new QSharedMemory(QString::fromLatin1(s_key[2]));
}
IPCThread::~IPCThread(void)
{
X264_DELETE(m_semaphore_r);
X264_DELETE(m_semaphore_w);
X264_DELETE(m_sharedMem);
}
bool IPCThread::initialize(bool *firstInstance)
{
if(!m_ipcReady)
{
if((m_semaphore_r->error() == 0) && (m_semaphore_w->error() == 0) && (m_sharedMem->error() == 0))
{
if(m_sharedMem->create(sizeof(size_t), QSharedMemory::ReadWrite))
{
m_firstInstance = m_ipcReady = true;
memset(m_sharedMem->data(), 0, sizeof(size_t));
}
else
{
if(m_sharedMem->attach(QSharedMemory::ReadWrite))
{
m_ipcReady = true;
}
}
}
}
if(firstInstance)
{
*firstInstance = m_firstInstance;
}
return m_ipcReady;
}
void IPCThread::start(Priority priority)
{
m_abort = false;
if(!m_ipcReady)
{
throw "IPC not initialized yet !!!";
return;
}
QThread::start(priority);
}
void IPCThread::setAbort(void)
{
m_abort = true;
if(m_semaphore_r)
{
m_semaphore_r->release();
}
}
void IPCThread::run(void)
{
if(!m_firstInstance)
{
m_semaphore_w->acquire();
size_t *pidPtr = reinterpret_cast<size_t*>(m_sharedMem->data());
*pidPtr = x264_process_id();
m_semaphore_r->release();
return;
}
forever
{
if(!m_semaphore_r->acquire())
{
qWarning("IPCThread: System error !!!");
qWarning("IPCThread: %s\n", m_semaphore_r->errorString().toLatin1().constData());
break;
}
if(m_abort)
{
break;
}
const size_t procId = *reinterpret_cast<const size_t*>(m_sharedMem->constData());
m_semaphore_w->release();
emit instanceCreated(procId);
}
}

58
src/thread_ipc.h
View File

@ -1,58 +0,0 @@
///////////////////////////////////////////////////////////////////////////////
// Simple x264 Launcher
// Copyright (C) 2004-2013 LoRd_MuldeR <MuldeR2@GMX.de>
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program 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 General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// http://www.gnu.org/licenses/gpl-2.0.txt
///////////////////////////////////////////////////////////////////////////////
#pragma once
#include "global.h"
#include <QThread>
class QSystemSemaphore;
class QSharedMemory;
class IPCThread : public QThread
{
Q_OBJECT
public:
IPCThread(void);
~IPCThread(void);
void setAbort(void);
bool initialize(bool *firstInstance = NULL);
signals:
void instanceCreated(unsigned int pid);
public slots:
void start(Priority priority = InheritPriority);
protected:
volatile bool m_abort;
QSystemSemaphore *m_semaphore_r;
QSystemSemaphore *m_semaphore_w;
QSharedMemory *m_sharedMem;
bool m_ipcReady;
bool m_firstInstance;
virtual void run(void);
};