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[JACK_CLIENT_NAME_SIZE + 1];
34 JackTools::RewriteName(client_name, ext_client_name);
35 snprintf(res, size,
"jack_sem.%d_%s_%s", JackTools::GetUID(), server_name, ext_client_name);
38 bool JackPosixSemaphore::Signal()
43 jack_error(
"JackPosixSemaphore::Signal name = %s already deallocated!!", fName);
50 if ((res = sem_post(fSemaphore)) != 0) {
51 jack_error(
"JackPosixSemaphore::Signal name = %s err = %s", fName, strerror(errno));
56 bool JackPosixSemaphore::SignalAll()
61 jack_error(
"JackPosixSemaphore::SignalAll name = %s already deallocated!!", fName);
68 if ((res = sem_post(fSemaphore)) != 0) {
69 jack_error(
"JackPosixSemaphore::SignalAll name = %s err = %s", fName, strerror(errno));
91 bool JackPosixSemaphore::Wait()
95 while ((res = sem_wait(fSemaphore) < 0)) {
96 jack_error(
"JackPosixSemaphore::Wait name = %s err = %s", fName, strerror(errno));
103 #if (_POSIX_C_SOURCE >= 200112L || _XOPEN_SOURCE >= 600) // glibc feature test
105 bool JackPosixSemaphore::TimedWait(
long usec)
112 jack_error(
"JackPosixSemaphore::TimedWait name = %s already deallocated!!", fName);
115 gettimeofday(&now, 0);
116 time.tv_sec = now.tv_sec + usec / 1000000;
117 long tv_usec = (now.tv_usec + (usec % 1000000));
118 time.tv_sec += tv_usec / 1000000;
119 time.tv_nsec = (tv_usec % 1000000) * 1000;
121 while ((res = sem_timedwait(fSemaphore, &time)) < 0) {
122 jack_error(
"JackPosixSemaphore::TimedWait err = %s", strerror(errno));
123 jack_log(
"JackPosixSemaphore::TimedWait now : %ld %ld ", now.tv_sec, now.tv_usec);
124 jack_log(
"JackPosixSemaphore::TimedWait next : %ld %ld ", time.tv_sec, time.tv_nsec/1000);
132 #warning "JackPosixSemaphore::TimedWait is not supported: Jack in SYNC mode with JackPosixSemaphore will not run properly !!"
134 bool JackPosixSemaphore::TimedWait(
long usec)
141 bool JackPosixSemaphore::Allocate(
const char* name,
const char* server_name,
int value)
143 BuildName(name, server_name, fName,
sizeof(fName));
144 jack_log(
"JackPosixSemaphore::Allocate name = %s val = %ld", fName, value);
146 if ((fSemaphore = sem_open(fName, O_CREAT, 0777, value)) == (sem_t*)SEM_FAILED) {
147 jack_error(
"Allocate: can't check in named semaphore name = %s err = %s", fName, strerror(errno));
155 bool JackPosixSemaphore::ConnectInput(
const char* name,
const char* server_name)
157 BuildName(name, server_name, fName,
sizeof(fName));
158 jack_log(
"JackPosixSemaphore::Connect name = %s", fName);
162 jack_log(
"Already connected name = %s", name);
166 if ((fSemaphore = sem_open(fName, O_CREAT)) == (sem_t*)SEM_FAILED) {
167 jack_error(
"Connect: can't connect named semaphore name = %s err = %s", fName, strerror(errno));
171 sem_getvalue(fSemaphore, &val);
172 jack_log(
"JackPosixSemaphore::Connect sem_getvalue %ld", val);
177 bool JackPosixSemaphore::Connect(
const char* name,
const char* server_name)
179 return ConnectInput(name, server_name);
182 bool JackPosixSemaphore::ConnectOutput(
const char* name,
const char* server_name)
184 return ConnectInput(name, server_name);
187 bool JackPosixSemaphore::Disconnect()
190 jack_log(
"JackPosixSemaphore::Disconnect name = %s", fName);
191 if (sem_close(fSemaphore) != 0) {
192 jack_error(
"Disconnect: can't disconnect named semaphore name = %s err = %s", fName, strerror(errno));
204 void JackPosixSemaphore::Destroy()
206 if (fSemaphore != NULL) {
207 jack_log(
"JackPosixSemaphore::Destroy name = %s", fName);
209 if (sem_close(fSemaphore) != 0) {
210 jack_error(
"Destroy: can't destroy semaphore name = %s err = %s", fName, strerror(errno));
214 jack_error(
"JackPosixSemaphore::Destroy semaphore == NULL");
SERVER_EXPORT void jack_error(const char *fmt,...)
SERVER_EXPORT void jack_log(const char *fmt,...)