20 #include "JackPosixSemaphore.h" 21 #include "JackTools.h" 22 #include "JackConstants.h" 23 #include "JackError.h" 28 #include "promiscuous.h" 34 JackPosixSemaphore::JackPosixSemaphore() : JackSynchro(), fSemaphore(NULL)
36 const char* promiscuous = getenv(
"JACK_PROMISCUOUS_SERVER");
37 fPromiscuous = (promiscuous != NULL);
39 fPromiscuousGid = jack_group2gid(promiscuous);
43 void JackPosixSemaphore::BuildName(
const char* client_name,
const char* server_name,
char* res,
int size)
45 char ext_client_name[SYNC_MAX_NAME_SIZE + 1];
46 JackTools::RewriteName(client_name, ext_client_name);
47 #if __APPLE__ // POSIX semaphore names are limited to 32 characters... 48 snprintf(res, 32,
"js_%s", ext_client_name);
51 snprintf(res, size,
"jack_sem.%s_%s", server_name, ext_client_name);
53 snprintf(res, size,
"jack_sem.%d_%s_%s", JackTools::GetUID(), server_name, ext_client_name);
58 bool JackPosixSemaphore::Signal()
63 jack_error(
"JackPosixSemaphore::Signal name = %s already deallocated!!", fName);
71 if ((res = sem_post(fSemaphore)) != 0) {
72 jack_error(
"JackPosixSemaphore::Signal name = %s err = %s", fName, strerror(errno));
77 bool JackPosixSemaphore::SignalAll()
82 jack_error(
"JackPosixSemaphore::SignalAll name = %s already deallocated!!", fName);
90 if ((res = sem_post(fSemaphore)) != 0) {
91 jack_error(
"JackPosixSemaphore::SignalAll name = %s err = %s", fName, strerror(errno));
96 bool JackPosixSemaphore::Wait()
101 jack_error(
"JackPosixSemaphore::Wait name = %s already deallocated!!", fName);
105 while ((res = sem_wait(fSemaphore) < 0)) {
106 jack_error(
"JackPosixSemaphore::Wait name = %s err = %s", fName, strerror(errno));
107 if (errno != EINTR) {
114 #if (_POSIX_C_SOURCE >= 200112L || _XOPEN_SOURCE >= 600) // glibc feature test 116 bool JackPosixSemaphore::TimedWait(
long usec)
123 jack_error(
"JackPosixSemaphore::TimedWait name = %s already deallocated!!", fName);
126 gettimeofday(&now, 0);
127 time.tv_sec = now.tv_sec + usec / 1000000;
128 long tv_usec = (now.tv_usec + (usec % 1000000));
129 time.tv_sec += tv_usec / 1000000;
130 time.tv_nsec = (tv_usec % 1000000) * 1000;
132 while ((res = sem_timedwait(fSemaphore, &time)) < 0) {
133 jack_error(
"JackPosixSemaphore::TimedWait err = %s", strerror(errno));
134 jack_log(
"JackPosixSemaphore::TimedWait now : %ld %ld ", now.tv_sec, now.tv_usec);
135 jack_log(
"JackPosixSemaphore::TimedWait next : %ld %ld ", time.tv_sec, time.tv_nsec/1000);
136 if (errno != EINTR) {
144 #warning "JackPosixSemaphore::TimedWait is not supported: Jack in SYNC mode with JackPosixSemaphore will not run properly !!" 146 bool JackPosixSemaphore::TimedWait(
long usec)
153 bool JackPosixSemaphore::Allocate(
const char* name,
const char* server_name,
int value)
155 BuildName(name, server_name, fName,
sizeof(fName));
156 jack_log(
"JackPosixSemaphore::Allocate name = %s val = %ld", fName, value);
158 if ((fSemaphore = sem_open(fName, O_CREAT | O_RDWR, 0777, value)) == (sem_t*)SEM_FAILED) {
159 jack_error(
"Allocate: can't check in named semaphore name = %s err = %s", fName, strerror(errno));
164 char sempath[SYNC_MAX_NAME_SIZE+13];
165 snprintf(sempath,
sizeof(sempath),
"/dev/shm/sem.%s", fName);
166 if (jack_promiscuous_perms(-1, sempath, fPromiscuousGid) < 0)
175 bool JackPosixSemaphore::ConnectInput(
const char* name,
const char* server_name)
177 BuildName(name, server_name, fName,
sizeof(fName));
178 jack_log(
"JackPosixSemaphore::Connect name = %s", fName);
182 jack_log(
"Already connected name = %s", name);
186 if ((fSemaphore = sem_open(fName, O_RDWR)) == (sem_t*)SEM_FAILED) {
187 jack_error(
"Connect: can't connect named semaphore name = %s err = %s", fName, strerror(errno));
189 }
else if (fSemaphore) {
191 sem_getvalue(fSemaphore, &val);
192 jack_log(
"JackPosixSemaphore::Connect sem_getvalue %ld", val);
195 jack_error(
"Connect: fSemaphore not initialized!");
200 bool JackPosixSemaphore::Connect(
const char* name,
const char* server_name)
202 return ConnectInput(name, server_name);
205 bool JackPosixSemaphore::ConnectOutput(
const char* name,
const char* server_name)
207 return ConnectInput(name, server_name);
210 bool JackPosixSemaphore::Disconnect()
213 jack_log(
"JackPosixSemaphore::Disconnect name = %s", fName);
214 if (sem_close(fSemaphore) != 0) {
215 jack_error(
"Disconnect: can't disconnect named semaphore name = %s err = %s", fName, strerror(errno));
227 void JackPosixSemaphore::Destroy()
229 if (fSemaphore != NULL) {
230 jack_log(
"JackPosixSemaphore::Destroy name = %s", fName);
232 if (sem_close(fSemaphore) != 0) {
233 jack_error(
"Destroy: can't destroy semaphore name = %s err = %s", fName, strerror(errno));
237 jack_error(
"JackPosixSemaphore::Destroy semaphore == NULL");
SERVER_EXPORT void jack_error(const char *fmt,...)
SERVER_EXPORT void jack_log(const char *fmt,...)