windows/JackWinThread.cpp

   1 /*
   2 Copyright (C) 2001 Paul Davis
   3 Copyright (C) 2004-2006 Grame
   4
   5 This program is free software; you can redistribute it and/or modify
   6 it under the terms of the GNU General Public License as published by
   7 the Free Software Foundation; either version 2 of the License, or
   8 (at your option) any later version.
   9
  10 This program is distributed in the hope that it will be useful,
  11 but WITHOUT ANY WARRANTY; without even the implied warranty of
  12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13 GNU General Public License for more details.
  14
  15 You should have received a copy of the GNU General Public License
  16 along with this program; if not, write to the Free Software
  17 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  18
  19 */
  20
  21 #include "JackWinThread.h"
  22 #include "JackError.h"
  23 #include <assert.h>
  24
  25 namespace Jack
  26 {
  27
  28 DWORD WINAPI JackWinThread::ThreadHandler(void* arg)
  29 {
  30     JackWinThread* obj = (JackWinThread*)arg;
  31     JackRunnableInterface* runnable = obj->fRunnable;
  32
  33     // Call Init method
  34     if (!runnable->Init()) {
  35         jack_error("Thread init fails: thread quits");
  36         return 0;
  37     }
  38
  39     // Signal creation thread when started with StartSync
  40     if (!obj->fRunning) {
  41         obj->fRunning = true;
  42         SetEvent(obj->fEvent);
  43     }
  44
  45     JackLog("ThreadHandler: start\n");
  46
  47     // If Init succeed, start the thread loop
  48     bool res = true;
  49     while (obj->fRunning && res) {
  50         res = runnable->Execute();
  51     }
  52
  53     SetEvent(obj->fEvent);
  54     JackLog("ThreadHandler: exit\n");
  55     return 0;
  56 }
  57
  58 JackWinThread::JackWinThread(JackRunnableInterface* runnable)
  59         : JackThread(runnable, 0, false, 0)
  60 {
  61          fEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  62          fThread = NULL;
  63          assert(fEvent);
  64 }
  65
  66 JackWinThread::~JackWinThread()
  67 {
  68         CloseHandle(fEvent);
  69 }
  70
  71 int JackWinThread::Start()
  72 {
  73         fEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  74     if (fEvent == NULL) {
  75         jack_error("Cannot create event error = %d", GetLastError());
  76         return -1;
  77     }
  78
  79         fRunning = true;
  80
  81         // Check if the thread was correctly started
  82         if (StartImp(&fThread, fPriority, fRealTime, ThreadHandler, this) < 0) {
  83                 fRunning = false;
  84                 return -1;
  85         } else {
  86                 return 0;
  87         }
  88 }
  89
  90 int JackWinThread::StartImp(pthread_t* thread, int priority, int realtime, ThreadCallback start_routine, void* arg)
  91 {
  92     DWORD id;
  93
  94     if (realtime) {
  95
  96         JackLog("Create RT thread\n");
  97         *thread = CreateThread(NULL, 0, start_routine, arg, 0, &id);
  98
  99         if (*thread == NULL) {
 100             jack_error("Cannot create thread error = %d", GetLastError());
 101             return -1;
 102         }
 103
 104         if (!SetThreadPriority(*thread, THREAD_PRIORITY_TIME_CRITICAL)) {
 105             jack_error("Cannot set priority class = %d", GetLastError());
 106             return -1;
 107         }
 108
 109         return 0;
 110
 111     } else {
 112
 113         JackLog("Create non RT thread\n");
 114         *thread = CreateThread(NULL, 0, start_routine, arg, 0, &id);
 115
 116         if (thread == NULL) {
 117             jack_error("Cannot create thread error = %d", GetLastError());
 118             return -1;
 119         }
 120
 121         return 0;
 122     }
 123 }
 124
 125 int JackWinThread::StartSync()
 126 {
 127     DWORD id;
 128
 129     fEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
 130     if (fEvent == NULL) {
 131         jack_error("Cannot create event error = %d", GetLastError());
 132         return -1;
 133     }
 134
 135     if (fRealTime) {
 136
 137         JackLog("Create RT thread\n");
 138         fThread = CreateThread(NULL, 0, ThreadHandler, (void*)this, 0, &id);
 139
 140         if (fThread == NULL) {
 141             jack_error("Cannot create thread error = %d", GetLastError());
 142             return -1;
 143         }
 144
 145         if (WaitForSingleObject(fEvent, 3000) != WAIT_OBJECT_0) { // wait 3 sec
 146             jack_error("Thread has not started");
 147             return -1;
 148         }
 149
 150         if (!SetThreadPriority(fThread, THREAD_PRIORITY_TIME_CRITICAL)) {
 151             jack_error("Cannot set priority class = %d", GetLastError());
 152             return -1;
 153         }
 154
 155         return 0;
 156
 157     } else {
 158
 159         JackLog("Create non RT thread\n");
 160         fThread = CreateThread(NULL, 0, ThreadHandler, (void*)this, 0, &id);
 161
 162         if (fThread == NULL) {
 163             jack_error("Cannot create thread error = %d", GetLastError());
 164             return -1;
 165         }
 166
 167         if (WaitForSingleObject(fEvent, 3000) != WAIT_OBJECT_0) { // wait 3 sec
 168             jack_error("Thread has not started");
 169             return -1;
 170         }
 171
 172         return 0;
 173     }
 174 }
 175
 176 // voir http://www.microsoft.com/belux/msdn/nl/community/columns/ldoc/multithread1.mspx
 177
 178 int JackWinThread::Kill()
 179 {
 180     if (fThread) { // If thread has been started
 181         TerminateThread(fThread, 0);
 182                 WaitForSingleObject(fThread, INFINITE);
 183         CloseHandle(fThread);
 184                 JackLog("JackWinThread::Kill 2\n");
 185                 fThread = NULL;
 186                 fRunning = false;
 187         return 0;
 188     } else {
 189         return -1;
 190     }
 191 }
 192
 193 int JackWinThread::Stop()
 194 {
 195     if (fThread) { // If thread has been started
 196         JackLog("JackWinThread::Stop\n");
 197         fRunning = false; // Request for the thread to stop
 198         WaitForSingleObject(fEvent, INFINITE);
 199         CloseHandle(fThread);
 200                 fThread = NULL;
 201         return 0;
 202     } else {
 203         return -1;
 204     }
 205 }
 206
 207 int JackWinThread::AcquireRealTime()
 208 {
 209         return (fThread) ? AcquireRealTimeImp(fThread, fPriority) : -1;
 210 }
 211
 212 int JackWinThread::AcquireRealTime(int priority)
 213 {
 214         fPriority = priority;
 215         return AcquireRealTime();
 216 }
 217
 218 int JackWinThread::AcquireRealTimeImp(pthread_t thread, int priority)
 219 {
 220     JackLog("JackWinThread::AcquireRealTime\n");
 221
 222         if (SetThreadPriority(thread, THREAD_PRIORITY_TIME_CRITICAL)) {
 223                 JackLog("JackWinThread::AcquireRealTime OK\n");
 224                 return 0;
 225         } else {
 226                 jack_error("Cannot set thread priority = %d", GetLastError());
 227                 return -1;
 228         }
 229 }
 230 int JackWinThread::DropRealTime()
 231 {
 232         return DropRealTimeImp(fThread);
 233 }
 234
 235 int JackWinThread::DropRealTimeImp(pthread_t thread)
 236 {
 237         if (SetThreadPriority(thread, THREAD_PRIORITY_NORMAL)) {
 238                 return 0;
 239         } else {
 240                 jack_error("Cannot set thread priority = %d", GetLastError());
 241                 return -1;
 242         }
 243 }
 244
 245 pthread_t JackWinThread::GetThreadID()
 246 {
 247     return fThread;
 248 }
 249
 250 } // end of namespace
 251