]>
code.delx.au - pulseaudio/blob - src/polypcore/socket-util.c
4 This file is part of polypaudio.
6 polypaudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as published
8 by the Free Software Foundation; either version 2 of the License,
9 or (at your option) any later version.
11 polypaudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with polypaudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
33 #include <sys/types.h>
38 #ifdef HAVE_SYS_SOCKET_H
39 #include <sys/socket.h>
44 #ifdef HAVE_NETINET_IN_H
45 #include <netinet/in.h>
47 #ifdef HAVE_NETINET_IN_SYSTM_H
48 #include <netinet/in_systm.h>
50 #ifdef HAVE_NETINET_IP_H
51 #include <netinet/ip.h>
53 #ifdef HAVE_NETINET_TCP_H
54 #include <netinet/tcp.h>
62 #include <polyp/xmalloc.h>
64 #include <polypcore/core-util.h>
65 #include <polypcore/log.h>
67 #include "socket-util.h"
69 void pa_socket_peer_to_string(int fd
, char *c
, size_t l
) {
72 assert(c
&& l
&& fd
>= 0);
75 if (fstat(fd
, &st
) < 0) {
76 snprintf(c
, l
, "Invalid client fd");
82 if (S_ISSOCK(st
.st_mode
)) {
86 struct sockaddr_in in
;
88 struct sockaddr_un un
;
91 socklen_t sa_len
= sizeof(sa
);
93 if (getpeername(fd
, &sa
.sa
, &sa_len
) >= 0) {
95 if (sa
.sa
.sa_family
== AF_INET
) {
96 uint32_t ip
= ntohl(sa
.in
.sin_addr
.s_addr
);
98 snprintf(c
, l
, "TCP/IP client from %i.%i.%i.%i:%u",
103 ntohs(sa
.in
.sin_port
));
106 } else if (sa
.sa
.sa_family
== AF_UNIX
) {
107 snprintf(c
, l
, "UNIX socket client");
114 snprintf(c
, l
, "Unknown network client");
116 } else if (S_ISCHR(st
.st_mode
) && (fd
== 0 || fd
== 1)) {
117 snprintf(c
, l
, "STDIN/STDOUT client");
120 #endif /* OS_IS_WIN32 */
122 snprintf(c
, l
, "Unknown client");
125 int pa_socket_low_delay(int fd
) {
131 if (setsockopt(fd
, SOL_SOCKET
, SO_PRIORITY
, (void*)&priority
, sizeof(priority
)) < 0)
138 int pa_socket_tcp_low_delay(int fd
) {
143 ret
= pa_socket_low_delay(fd
);
148 #if defined(SOL_TCP) || defined(IPPROTO_TCP)
150 if (setsockopt(fd
, SOL_TCP
, TCP_NODELAY
, (void*)&on
, sizeof(on
)) < 0)
152 if (setsockopt(fd
, IPPROTO_TCP
, TCP_NODELAY
, (void*)&on
, sizeof(on
)) < 0)
157 #if defined(IPTOS_LOWDELAY) && defined(IP_TOS) && (defined(SOL_IP) || \
159 tos
= IPTOS_LOWDELAY
;
161 if (setsockopt(fd
, SOL_IP
, IP_TOS
, (void*)&tos
, sizeof(tos
)) < 0)
163 if (setsockopt(fd
, IPPROTO_IP
, IP_TOS
, (void*)&tos
, sizeof(tos
)) < 0)
172 int pa_socket_set_rcvbuf(int fd
, size_t l
) {
175 /* if (setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (void*)&l, sizeof(l)) < 0) { */
176 /* pa_log(__FILE__": SO_RCVBUF: %s", strerror(errno)); */
183 int pa_socket_set_sndbuf(int fd
, size_t l
) {
186 /* if (setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void*)&l, sizeof(l)) < 0) { */
187 /* pa_log(__FILE__": SO_SNDBUF: %s", strerror(errno)); */
196 int pa_unix_socket_is_stale(const char *fn
) {
197 struct sockaddr_un sa
;
198 int fd
= -1, ret
= -1;
200 if ((fd
= socket(PF_UNIX
, SOCK_STREAM
, 0)) < 0) {
201 pa_log(__FILE__
": socket(): %s", strerror(errno
));
205 sa
.sun_family
= AF_UNIX
;
206 strncpy(sa
.sun_path
, fn
, sizeof(sa
.sun_path
)-1);
207 sa
.sun_path
[sizeof(sa
.sun_path
) - 1] = 0;
209 if (connect(fd
, (struct sockaddr
*) &sa
, sizeof(sa
)) < 0) {
210 if (errno
== ECONNREFUSED
)
222 int pa_unix_socket_remove_stale(const char *fn
) {
225 if ((r
= pa_unix_socket_is_stale(fn
)) < 0)
226 return errno
!= ENOENT
? -1 : 0;
231 /* Yes, here is a race condition. But who cares? */
238 #else /* HAVE_SYS_UN_H */
240 int pa_unix_socket_is_stale(const char *fn
) {
244 int pa_unix_socket_remove_stale(const char *fn
) {
248 #endif /* HAVE_SYS_UN_H */