Funkwhale/Clementine-audio-player-Mac-Linux-Windows
1
0
Fork 0
mirror of https://github.com/clementine-player/Clementine synced 2025-01-31 11:35:24 +01:00
Code Issues Releases Wiki Activity

Change tinysvcmdns to use sockets instead of pipe on windows.

Browse Source 
Should make it actually work on windows.
This commit is contained in:
John Maguire 2013-01-23 16:05:32 +01:00 committed by Andreas
parent 9472c5ace2
commit 66c0878b7e
1 changed files with 69 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
3rdparty/tinysvcmdns/mdnsd.c vendored
View File

@ -30,7 +30,6 @@
#include <winsock2.h> #include <winsock2.h>
#include <ws2tcpip.h> #include <ws2tcpip.h>
#define LOG_ERR 3 #define LOG_ERR 3
#define pipe(fds) _pipe(fds, 4096, _O_BINARY)
#else #else
#include <sys/select.h> #include <sys/select.h>
#include <sys/socket.h> #include <sys/socket.h>
@ -335,6 +334,71 @@ static int process_mdns_pkt(struct mdnsd *svr, struct mdns_pkt *pkt, struct mdns
return 0; return 0;
} }
int create_pipe(int handles[2]) {
#ifdef _WIN32
SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
if (sock == INVALID_SOCKET) {
return -1;
}
struct sockaddr_in serv_addr;
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(0);
serv_addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
if (bind(sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == SOCKET_ERROR) {
closesocket(sock);
return -1;
}
if (listen(sock, 1) == SOCKET_ERROR) {
closesocket(sock);
return -1;
}
int len = sizeof(serv_addr);
if (getsockname(sock, (SOCKADDR*)&serv_addr, &len) == SOCKET_ERROR) {
closesocket(sock);
return -1;
}
if ((handles[1] = socket(PF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) {
closesocket(sock);
return -1;
}
if (connect(handles[1], (struct sockaddr*)&serv_addr, len) == SOCKET_ERROR) {
closesocket(sock);
return -1;
}
if ((handles[0] = accept(sock, (struct sockaddr*)&serv_addr, &len)) == INVALID_SOCKET) {
closesocket((SOCKET)handles[1]);
handles[1] = INVALID_SOCKET;
closesocket(sock);
return -1;
}
closesocket(sock);
return 0;
#else
return pipe(handles);
#endif
}
int read_pipe(int s, char* buf, int len) {
#ifdef _WIN32
int ret = recv(s, buf, len, 0);
if (ret < 0 && WSAGetLastError() == WSAECONNRESET) {
ret = 0;
}
return ret;
#else
return read(s, buf, len);
#endif
}
int write_pipe(int s, char* buf, int len) {
#ifdef _WIN32
return send(s, buf, len, 0);
#else
return write(s, buf, len);
#endif
}
// main loop to receive, process and send out MDNS replies // main loop to receive, process and send out MDNS replies
// also handles MDNS service announces // also handles MDNS service announces
static void main_loop(struct mdnsd *svr) { static void main_loop(struct mdnsd *svr) {
@ -358,7 +422,7 @@ static void main_loop(struct mdnsd *svr) {
if (FD_ISSET(svr->notify_pipe[0], &sockfd_set)) { if (FD_ISSET(svr->notify_pipe[0], &sockfd_set)) {
// flush the notify_pipe // flush the notify_pipe
read(svr->notify_pipe[0], &notify_buf, 1); read_pipe(svr->notify_pipe[0], (char*)&notify_buf, 1);
} else if (FD_ISSET(svr->sockfd, &sockfd_set)) { } else if (FD_ISSET(svr->sockfd, &sockfd_set)) {
struct sockaddr_in fromaddr; struct sockaddr_in fromaddr;
socklen_t sockaddr_size = sizeof(struct sockaddr_in); socklen_t sockaddr_size = sizeof(struct sockaddr_in);
@ -533,7 +597,7 @@ struct mdns_service *mdnsd_register_svc(struct mdnsd *svr, const char *instance_
free(inst_nlabel); free(inst_nlabel);
// notify server // notify server
write(svr->notify_pipe[1], ".", 1); write_pipe(svr->notify_pipe[1], ".", 1);
return service; return service;
} }
@ -551,7 +615,7 @@ struct mdnsd *mdnsd_start() {
struct mdnsd *server = malloc(sizeof(struct mdnsd)); struct mdnsd *server = malloc(sizeof(struct mdnsd));
memset(server, 0, sizeof(struct mdnsd)); memset(server, 0, sizeof(struct mdnsd));
if (pipe(server->notify_pipe) != 0) { if (create_pipe(server->notify_pipe) != 0) {
log_message(LOG_ERR, "pipe(): %m\n"); log_message(LOG_ERR, "pipe(): %m\n");
free(server); free(server);
return NULL; return NULL;
@ -588,7 +652,7 @@ void mdnsd_stop(struct mdnsd *s) {
}; };
s->stop_flag = 1; s->stop_flag = 1;
write(s->notify_pipe[1], ".", 1); write_pipe(s->notify_pipe[1], ".", 1);
while (s->stop_flag != 2) while (s->stop_flag != 2)
select(0, NULL, NULL, NULL, &tv); select(0, NULL, NULL, NULL, &tv);