windows/JackWinEvent.cpp

   1 /*
   2 Copyright (C) 2004-2005 Grame
   3
   4 This program is free software; you can redistribute it and/or modify
   5   it under the terms of the GNU General Public License as published by
   6   the Free Software Foundation; either version 2 of the License, or
   7   (at your option) any later version.
   8
   9   This program is distributed in the hope that it will be useful,
  10   but WITHOUT ANY WARRANTY; without even the implied warranty of
  11   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12   GNU General Public License for more details.
  13
  14   You should have received a copy of the GNU General Public License
  15   along with this program; if not, write to the Free Software
  16   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  17
  18 */
  19
  20 #include "JackWinEvent.h"
  21 #include "JackError.h"
  22
  23 // http://www.codeproject.com/win32/Win32_Event_Handling.asp
  24 // http://www.codeproject.com/threads/Synchronization.asp
  25
  26 namespace Jack
  27 {
  28
  29 void JackWinEvent::BuildName(const char* name, char* res)
  30 {
  31     sprintf(res, "jack_pipe.%s", name);
  32 }
  33
  34 bool JackWinEvent::Signal()
  35 {
  36     BOOL res;
  37     assert(fEvent);
  38
  39     if (fFlush)
  40         return true;
  41
  42     if (!(res = SetEvent(fEvent))) {
  43         jack_error("JackWinEvent::Signal name = %s err = %ld", fName, GetLastError());
  44     }
  45
  46     return res;
  47 }
  48
  49 bool JackWinEvent::SignalAll()
  50 {
  51     BOOL res;
  52     assert(fEvent);
  53
  54     if (fFlush)
  55         return true;
  56
  57     if (!(res = SetEvent(fEvent))) {
  58         jack_error("JackWinEvent::SignalAll name = %s err = %ld", fName, GetLastError());
  59     }
  60
  61     return res;
  62 }
  63
  64 bool JackWinEvent::Wait()
  65 {
  66     DWORD res;
  67
  68     if ((res = WaitForSingleObject(fEvent, INFINITE)) == WAIT_TIMEOUT) {
  69         jack_error("JackWinEvent::TimedWait name = %s time_out", fName);
  70     }
  71
  72     return (res == WAIT_OBJECT_0);
  73 }
  74
  75 bool JackWinEvent::TimedWait(long usec)
  76 {
  77     DWORD res;
  78
  79     if ((res = WaitForSingleObject(fEvent, usec / 1000)) == WAIT_TIMEOUT) {
  80                 jack_error("JackWinEvent::TimedWait name = %s time_out", fName);
  81     }
  82
  83     return (res == WAIT_OBJECT_0);
  84 }
  85
  86 // Client side : get the published semaphore from server
  87 bool JackWinEvent::ConnectInput(const char* name)
  88 {
  89     BuildName(name, fName);
  90     JackLog("JackWinEvent::Connect %s\n", fName);
  91
  92     // Temporary...
  93     if (fEvent) {
  94         JackLog("Already connected name = %s\n", name);
  95         return true;
  96     }
  97
  98     if ((fEvent = OpenEvent(EVENT_ALL_ACCESS, FALSE, fName)) == NULL) {
  99                 jack_error("Connect: can't check in named event name = %s err = %ld", fName, GetLastError());
 100         return false;
 101     } else {
 102         return true;
 103     }
 104 }
 105
 106 bool JackWinEvent::Connect(const char* name)
 107 {
 108     return ConnectInput(name);
 109 }
 110
 111 bool JackWinEvent::ConnectOutput(const char* name)
 112 {
 113     return ConnectInput(name);
 114 }
 115
 116 bool JackWinEvent::Disconnect()
 117 {
 118     if (fEvent) {
 119         JackLog("JackWinEvent::Disconnect %s\n", fName);
 120         CloseHandle(fEvent);
 121         fEvent = NULL;
 122         return true;
 123     } else {
 124         return false;
 125     }
 126 }
 127
 128 bool JackWinEvent::Allocate(const char* name, int value)
 129 {
 130     BuildName(name, fName);
 131     JackLog("JackWinEvent::Allocate name = %s val = %ld\n", fName, value);
 132
 133     /* create an auto reset event */
 134     if ((fEvent = CreateEvent(NULL, FALSE, FALSE, fName)) == NULL) {
 135         jack_error("Allocate: can't check in named event name = %s err = %ld", fName, GetLastError());
 136         return false;
 137     } else {
 138         return true;
 139     }
 140 }
 141
 142 void JackWinEvent::Destroy()
 143 {
 144     if (fEvent != NULL) {
 145                 JackLog("JackWinEvent::Destroy %s\n", fName);
 146         CloseHandle(fEvent);
 147         fEvent = NULL;
 148     } else {
 149         jack_error("JackWinEvent::Destroy synchro == NULL");
 150     }
 151 }
 152
 153
 154 } // end of namespace
 155