20 #include "JackSocket.h"
21 #include "JackConstants.h"
22 #include "JackTools.h"
23 #include "JackError.h"
32 static void BuildName(
const char* client_name,
char* res,
const char* dir,
int which,
int size)
34 char ext_client_name[SYNC_MAX_NAME_SIZE + 1];
35 JackTools::RewriteName(client_name, ext_client_name);
36 if (getenv(
"JACK_PROMISCUOUS_SERVER")) {
37 snprintf(res, size,
"%s/jack_%s_%d", dir, ext_client_name, which);
39 snprintf(res, size,
"%s/jack_%s_%d_%d", dir, ext_client_name, JackTools::GetUID(), which);
43 JackClientSocket::JackClientSocket(
int socket): JackClientRequestInterface(), fSocket(socket),fTimeOut(0)
46 #if defined(__sun__) || defined(sun)
48 void JackClientSocket::SetReadTimeOut(
long sec)
53 if ((flags = fcntl(fSocket, F_GETFL, 0)) < 0) {
54 jack_error(
"JackClientSocket::SetReadTimeOut error in fcntl F_GETFL");
59 if (fcntl(fSocket, F_SETFL, flags) < 0) {
60 jack_error(
"JackClientSocket::SetReadTimeOut error in fcntl F_SETFL");
65 void JackClientSocket::SetWriteTimeOut(
long sec)
70 if ((flags = fcntl(fSocket, F_GETFL, 0)) < 0) {
71 jack_error(
"JackClientSocket::SetWriteTimeOut error in fcntl F_GETFL");
76 if (fcntl(fSocket, F_SETFL, flags) < 0) {
77 jack_error(
"JackClientSocket::SetWriteTimeOut error in fcntl F_SETFL");
84 void JackClientSocket::SetReadTimeOut(
long sec)
86 struct timeval timout;
89 if (setsockopt(fSocket, SOL_SOCKET, SO_RCVTIMEO, (
const char*)&timout,
sizeof(timeval)) < 0) {
90 jack_error(
"SetReadTimeOut fd = %ld err = %s", fSocket, strerror(errno));
94 void JackClientSocket::SetWriteTimeOut(
long sec)
96 struct timeval timout;
99 if (setsockopt(fSocket, SOL_SOCKET, SO_SNDTIMEO, (
const char*)&timout,
sizeof(timeval)) < 0) {
100 jack_error(
"SetWriteTimeOut fd = %ld err = %s", fSocket, strerror(errno));
106 void JackClientSocket::SetNonBlocking(
bool onoff)
110 if (fcntl(fSocket, F_SETFL, flags | O_NONBLOCK) < 0) {
111 jack_error(
"SetNonBlocking fd = %ld err = %s", fSocket, strerror(errno));
116 int JackClientSocket::Connect(
const char* dir,
const char* name,
int which)
118 struct sockaddr_un addr;
120 if ((fSocket = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
121 jack_error(
"Cannot create socket err = %s", strerror(errno));
125 addr.sun_family = AF_UNIX;
126 BuildName(name, addr.sun_path, dir, which,
sizeof(addr.sun_path));
127 jack_log(
"JackClientSocket::Connect : addr.sun_path %s", addr.sun_path);
129 if (connect(fSocket, (
struct sockaddr*)&addr,
sizeof(addr)) < 0) {
130 jack_error(
"Cannot connect to server socket err = %s", strerror(errno));
137 if (setsockopt(fSocket, SOL_SOCKET, SO_NOSIGPIPE, (
const char*)&on,
sizeof(on)) < 0) {
138 jack_log(
"setsockopt SO_NOSIGPIPE fd = %ld err = %s", fSocket, strerror(errno));
145 int JackClientSocket::Close()
147 jack_log(
"JackClientSocket::Close");
149 shutdown(fSocket, SHUT_RDWR);
158 int JackClientSocket::Read(
void* data,
int len)
162 #if defined(__sun__) || defined(sun)
169 tv.tv_sec = fTimeOut;
173 FD_SET(fSocket, &fdset);
176 res = select(fSocket + 1, &fdset, NULL, NULL, &tv);
177 }
while (res < 0 && errno == EINTR);
181 }
else if (res == 0) {
187 if ((res = read(fSocket, data, len)) != len) {
188 if (errno == EWOULDBLOCK || errno == EAGAIN) {
189 jack_error(
"JackClientSocket::Read time out");
191 }
else if (res != 0) {
192 jack_error(
"Cannot read socket fd = %d err = %s", fSocket, strerror(errno));
196 jack_error(
"Cannot read socket fd = %d err = %s", fSocket, strerror(errno));
204 int JackClientSocket::Write(
void* data,
int len)
208 #if defined(__sun__) || defined(sun)
215 tv.tv_sec = fTimeOut;
219 FD_SET(fSocket, &fdset);
222 res = select(fSocket + 1, NULL, &fdset, NULL, &tv);
223 }
while (res < 0 && errno == EINTR);
227 }
else if (res == 0) {
233 if ((res = write(fSocket, data, len)) != len) {
234 if (errno == EWOULDBLOCK || errno == EAGAIN) {
235 jack_log(
"JackClientSocket::Write time out");
237 }
else if (res != 0) {
238 jack_error(
"Cannot write socket fd = %ld err = %s", fSocket, strerror(errno));
242 jack_error(
"Cannot write socket fd = %ld err = %s", fSocket, strerror(errno));
250 int JackServerSocket::Bind(
const char* dir,
const char* name,
int which)
252 struct sockaddr_un addr;
254 if ((fSocket = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
255 jack_error(
"Cannot create server socket err = %s", strerror(errno));
259 addr.sun_family = AF_UNIX;
261 BuildName(name, fName, dir, which,
sizeof(addr.sun_path));
262 strncpy(addr.sun_path, fName,
sizeof(addr.sun_path) - 1);
264 jack_log(
"JackServerSocket::Bind : addr.sun_path %s", addr.sun_path);
267 if (bind(fSocket, (
struct sockaddr*)&addr,
sizeof(addr)) < 0) {
268 jack_error(
"Cannot bind server to socket err = %s", strerror(errno));
272 if (listen(fSocket, 100) < 0) {
273 jack_error(
"Cannot enable listen on server socket err = %s", strerror(errno));
285 JackClientSocket* JackServerSocket::Accept()
287 struct sockaddr_un client_addr;
288 socklen_t client_addrlen;
290 memset(&client_addr, 0,
sizeof(client_addr));
291 client_addrlen =
sizeof(client_addr);
293 int fd = accept(fSocket, (
struct sockaddr*)&client_addr, &client_addrlen);
295 jack_error(
"Cannot accept new connection err = %s", strerror(errno));
298 return new JackClientSocket(fd);
302 int JackServerSocket::Close()
305 jack_log(
"JackServerSocket::Close %s", fName);
306 shutdown(fSocket, SHUT_RDWR);