]>
code.delx.au - pulseaudio/blob - polyp/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 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 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
34 #include <netinet/in.h>
37 #include <sys/types.h>
38 #include <netinet/tcp.h>
39 #include <netinet/ip.h>
42 #include "socket-util.h"
47 void pa_socket_peer_to_string(int fd
, char *c
, size_t l
) {
50 assert(c
&& l
&& fd
>= 0);
52 if (fstat(fd
, &st
) < 0) {
53 snprintf(c
, l
, "Invalid client fd");
57 if (S_ISSOCK(st
.st_mode
)) {
60 struct sockaddr_in in
;
61 struct sockaddr_un un
;
63 socklen_t sa_len
= sizeof(sa
);
65 if (getpeername(fd
, &sa
.sa
, &sa_len
) >= 0) {
67 if (sa
.sa
.sa_family
== AF_INET
) {
68 uint32_t ip
= ntohl(sa
.in
.sin_addr
.s_addr
);
70 snprintf(c
, l
, "TCP/IP client from %i.%i.%i.%i:%u",
75 ntohs(sa
.in
.sin_port
));
77 } else if (sa
.sa
.sa_family
== AF_LOCAL
) {
78 snprintf(c
, l
, "UNIX socket client");
83 snprintf(c
, l
, "Unknown network client");
85 } else if (S_ISCHR(st
.st_mode
) && (fd
== 0 || fd
== 1)) {
86 snprintf(c
, l
, "STDIN/STDOUT client");
90 snprintf(c
, l
, "Unknown client");
93 int pa_socket_low_delay(int fd
) {
98 if (setsockopt(fd
, SOL_SOCKET
, SO_PRIORITY
, &priority
, sizeof(priority
)) < 0)
104 int pa_socket_tcp_low_delay(int fd
) {
109 ret
= pa_socket_low_delay(fd
);
112 if (setsockopt(fd
, SOL_TCP
, TCP_NODELAY
, &on
, sizeof(on
)) < 0)
115 tos
= IPTOS_LOWDELAY
;
116 if (setsockopt(fd
, SOL_IP
, IP_TOS
, &tos
, sizeof(tos
)) < 0)
123 int pa_socket_set_rcvbuf(int fd
, size_t l
) {
126 /* if (setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &l, sizeof(l)) < 0) { */
127 /* pa_log(__FILE__": SO_RCVBUF: %s\n", strerror(errno)); */
134 int pa_socket_set_sndbuf(int fd
, size_t l
) {
137 /* if (setsockopt(fd, SOL_SOCKET, SO_SNDBUF, &l, sizeof(l)) < 0) { */
138 /* pa_log(__FILE__": SO_SNDBUF: %s\n", strerror(errno)); */
145 int pa_unix_socket_is_stale(const char *fn
) {
146 struct sockaddr_un sa
;
147 int fd
= -1, ret
= -1;
149 if ((fd
= socket(PF_LOCAL
, SOCK_STREAM
, 0)) < 0) {
150 pa_log(__FILE__
": socket(): %s\n", strerror(errno
));
154 sa
.sun_family
= AF_LOCAL
;
155 strncpy(sa
.sun_path
, fn
, sizeof(sa
.sun_path
)-1);
156 sa
.sun_path
[sizeof(sa
.sun_path
) - 1] = 0;
158 if (connect(fd
, (struct sockaddr
*) &sa
, sizeof(sa
)) < 0) {
159 if (errno
== ECONNREFUSED
)
171 int pa_unix_socket_remove_stale(const char *fn
) {
174 if ((r
= pa_unix_socket_is_stale(fn
)) < 0)
175 return errno
!= ENOENT
? -1 : 0;
180 /* Yes, here is a race condition. But who cares? */
187 int pa_unix_socket_make_secure_dir(const char *fn
) {
189 char *slash
, *dir
= pa_xstrdup(fn
);
191 if (!(slash
= strrchr(dir
, '/')))
195 if (pa_make_secure_dir(dir
) < 0)
205 int pa_unix_socket_remove_secure_dir(const char *fn
) {
207 char *slash
, *dir
= pa_xstrdup(fn
);
209 if (!(slash
= strrchr(dir
, '/')))
223 struct sockaddr
*pa_resolve_server(const char *server
, size_t *len
, uint16_t nport
) {
225 struct addrinfo hints
, *result
= NULL
;
226 char *port
, host
[256], tmp
[16];
227 assert(server
&& len
);
229 snprintf(host
, sizeof(host
), "%s", server
);
230 host
[strcspn(host
, ":")] = 0;
232 if ((port
= strrchr(server
, ':')))
236 snprintf(port
= tmp
, sizeof(tmp
), "%u", nport
);
238 memset(&hints
, 0, sizeof(hints
));
239 hints
.ai_family
= PF_UNSPEC
;
240 hints
.ai_socktype
= SOCK_STREAM
;
241 hints
.ai_protocol
= 0;
243 if (getaddrinfo(host
, port
, &hints
, &result
) != 0)
247 sa
= pa_xmalloc(*len
= result
->ai_addrlen
);
248 memcpy(sa
, result
->ai_addr
, *len
);
250 freeaddrinfo(result
);