lbajardsilogic@0: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */
lbajardsilogic@0: 
lbajardsilogic@0: /*
lbajardsilogic@0:     Sonic Visualiser
lbajardsilogic@0:     An audio file viewer and annotation editor.
lbajardsilogic@0:     Centre for Digital Music, Queen Mary, University of London.
lbajardsilogic@0:     This file copyright 2006 Chris Cannam.
lbajardsilogic@0:     
lbajardsilogic@0:     This program is free software; you can redistribute it and/or
lbajardsilogic@0:     modify it under the terms of the GNU General Public License as
lbajardsilogic@0:     published by the Free Software Foundation; either version 2 of the
lbajardsilogic@0:     License, or (at your option) any later version.  See the file
lbajardsilogic@0:     COPYING included with this distribution for more information.
lbajardsilogic@0: */
lbajardsilogic@0: 
lbajardsilogic@0: #include "Thread.h"
lbajardsilogic@0: 
lbajardsilogic@0: #ifndef _WIN32
lbajardsilogic@0: #include <pthread.h>
lbajardsilogic@0: #endif
lbajardsilogic@0: 
lbajardsilogic@0: //#define DEBUG_MUTEX_LOCKER 1
lbajardsilogic@0: 
lbajardsilogic@0: #include <iostream>
lbajardsilogic@0: 
lbajardsilogic@0: Thread::Thread(Type type, QObject *parent) :
lbajardsilogic@0:     QThread(parent),
lbajardsilogic@0:     m_type(type)
lbajardsilogic@0: {
lbajardsilogic@0:     setStackSize(512 * 1024);
lbajardsilogic@0: }
lbajardsilogic@0: 
lbajardsilogic@0: void
lbajardsilogic@0: Thread::start()
lbajardsilogic@0: {
lbajardsilogic@0:     QThread::start();
lbajardsilogic@0: 
lbajardsilogic@0: #ifndef _WIN32
lbajardsilogic@0:     struct sched_param param;
lbajardsilogic@0:     ::memset(&param, 0, sizeof(param));
lbajardsilogic@0: 
lbajardsilogic@0:     if (m_type == RTThread) {
lbajardsilogic@0: 
lbajardsilogic@0:         param.sched_priority = 5;
lbajardsilogic@0: 
lbajardsilogic@0:         if (::pthread_setschedparam(pthread_self(), SCHED_FIFO, &param)) {
lbajardsilogic@0:             ::perror("INFO: pthread_setschedparam to SCHED_FIFO failed");
lbajardsilogic@0:         }
lbajardsilogic@0: 
lbajardsilogic@0:     } else {
lbajardsilogic@0: 
lbajardsilogic@0:         if (::pthread_setschedparam(pthread_self(), SCHED_OTHER, &param)) {
lbajardsilogic@0:             ::perror("WARNING: pthread_setschedparam to SCHED_OTHER failed");
lbajardsilogic@0:         }
lbajardsilogic@0:     }        
lbajardsilogic@0: 
lbajardsilogic@0: #endif
lbajardsilogic@0: }
lbajardsilogic@0: 
lbajardsilogic@0: MutexLocker::MutexLocker(QMutex *mutex, const char *name) :
lbajardsilogic@0:     m_printer(name),
lbajardsilogic@0:     m_locker(mutex)
lbajardsilogic@0: {
lbajardsilogic@0: #ifdef DEBUG_MUTEX_LOCKER
lbajardsilogic@0:     std::cerr << "... locked mutex " << mutex << std::endl;
lbajardsilogic@0: #endif
lbajardsilogic@0: }
lbajardsilogic@0: 
lbajardsilogic@0: MutexLocker::~MutexLocker()
lbajardsilogic@0: {
lbajardsilogic@0: }
lbajardsilogic@0: 
lbajardsilogic@0: MutexLocker::Printer::Printer(const char *name) :
lbajardsilogic@0:     m_name(name)
lbajardsilogic@0: {
lbajardsilogic@0: #ifdef DEBUG_MUTEX_LOCKER
lbajardsilogic@0:     std::cerr << "MutexLocker: Locking   \"" << m_name << "\" in "
lbajardsilogic@0:               << (void *)QThread::currentThreadId() << std::endl;
lbajardsilogic@0: #endif
lbajardsilogic@0: }
lbajardsilogic@0: 
lbajardsilogic@0: MutexLocker::Printer::~Printer()
lbajardsilogic@0: {
lbajardsilogic@0: #ifdef DEBUG_MUTEX_LOCKER
lbajardsilogic@0:     std::cerr << "MutexLocker: Unlocking \"" << m_name
lbajardsilogic@0:               << "\" in " << (void *)QThread::currentThreadId() << std::endl;
lbajardsilogic@0: #endif
lbajardsilogic@0: }
lbajardsilogic@0: