20 #include "JackPosixSemaphore.h"
21 #include "JackTools.h"
22 #include "JackConstants.h"
23 #include "JackError.h"
31 void JackPosixSemaphore::BuildName(
const char* client_name,
const char* server_name,
char* res,
int size)
33 char ext_client_name[SYNC_MAX_NAME_SIZE + 1];
34 JackTools::RewriteName(client_name, ext_client_name);
35 if (getenv(
"JACK_PROMISCUOUS_SERVER")) {
36 snprintf(res, size,
"jack_sem.%s_%s", server_name, ext_client_name);
38 snprintf(res, size,
"jack_sem.%d_%s_%s", JackTools::GetUID(), server_name, ext_client_name);
42 bool JackPosixSemaphore::Signal()
47 jack_error(
"JackPosixSemaphore::Signal name = %s already deallocated!!", fName);
54 if ((res = sem_post(fSemaphore)) != 0) {
55 jack_error(
"JackPosixSemaphore::Signal name = %s err = %s", fName, strerror(errno));
60 bool JackPosixSemaphore::SignalAll()
65 jack_error(
"JackPosixSemaphore::SignalAll name = %s already deallocated!!", fName);
72 if ((res = sem_post(fSemaphore)) != 0) {
73 jack_error(
"JackPosixSemaphore::SignalAll name = %s err = %s", fName, strerror(errno));
95 bool JackPosixSemaphore::Wait()
99 while ((res = sem_wait(fSemaphore) < 0)) {
100 jack_error(
"JackPosixSemaphore::Wait name = %s err = %s", fName, strerror(errno));
101 if (errno != EINTR) {
108 #if (_POSIX_C_SOURCE >= 200112L || _XOPEN_SOURCE >= 600) // glibc feature test
110 bool JackPosixSemaphore::TimedWait(
long usec)
117 jack_error(
"JackPosixSemaphore::TimedWait name = %s already deallocated!!", fName);
120 gettimeofday(&now, 0);
121 time.tv_sec = now.tv_sec + usec / 1000000;
122 long tv_usec = (now.tv_usec + (usec % 1000000));
123 time.tv_sec += tv_usec / 1000000;
124 time.tv_nsec = (tv_usec % 1000000) * 1000;
126 while ((res = sem_timedwait(fSemaphore, &time)) < 0) {
127 jack_error(
"JackPosixSemaphore::TimedWait err = %s", strerror(errno));
128 jack_log(
"JackPosixSemaphore::TimedWait now : %ld %ld ", now.tv_sec, now.tv_usec);
129 jack_log(
"JackPosixSemaphore::TimedWait next : %ld %ld ", time.tv_sec, time.tv_nsec/1000);
130 if (errno != EINTR) {
138 #warning "JackPosixSemaphore::TimedWait is not supported: Jack in SYNC mode with JackPosixSemaphore will not run properly !!"
140 bool JackPosixSemaphore::TimedWait(
long usec)
147 bool JackPosixSemaphore::Allocate(
const char* name,
const char* server_name,
int value)
149 BuildName(name, server_name, fName,
sizeof(fName));
150 jack_log(
"JackPosixSemaphore::Allocate name = %s val = %ld", fName, value);
152 if ((fSemaphore = sem_open(fName, O_CREAT | O_RDWR, 0777, value)) == (sem_t*)SEM_FAILED) {
153 jack_error(
"Allocate: can't check in named semaphore name = %s err = %s", fName, strerror(errno));
161 bool JackPosixSemaphore::ConnectInput(
const char* name,
const char* server_name)
163 BuildName(name, server_name, fName,
sizeof(fName));
164 jack_log(
"JackPosixSemaphore::Connect name = %s", fName);
168 jack_log(
"Already connected name = %s", name);
172 if ((fSemaphore = sem_open(fName, O_RDWR)) == (sem_t*)SEM_FAILED) {
173 jack_error(
"Connect: can't connect named semaphore name = %s err = %s", fName, strerror(errno));
177 sem_getvalue(fSemaphore, &val);
178 jack_log(
"JackPosixSemaphore::Connect sem_getvalue %ld", val);
183 bool JackPosixSemaphore::Connect(
const char* name,
const char* server_name)
185 return ConnectInput(name, server_name);
188 bool JackPosixSemaphore::ConnectOutput(
const char* name,
const char* server_name)
190 return ConnectInput(name, server_name);
193 bool JackPosixSemaphore::Disconnect()
196 jack_log(
"JackPosixSemaphore::Disconnect name = %s", fName);
197 if (sem_close(fSemaphore) != 0) {
198 jack_error(
"Disconnect: can't disconnect named semaphore name = %s err = %s", fName, strerror(errno));
210 void JackPosixSemaphore::Destroy()
212 if (fSemaphore != NULL) {
213 jack_log(
"JackPosixSemaphore::Destroy name = %s", fName);
215 if (sem_close(fSemaphore) != 0) {
216 jack_error(
"Destroy: can't destroy semaphore name = %s err = %s", fName, strerror(errno));
220 jack_error(
"JackPosixSemaphore::Destroy semaphore == NULL");