esound protocol

[pulseaudio] / src / module-protocol-stub.c

diff --git a/src/module-protocol-stub.c b/src/module-protocol-stub.c
index 905594c6136ee04d337a593df7499eacd1662179..29ce6b18c482b8002d336a1e2367f2c83c11cfcf 100644 (file)
--- a/src/module-protocol-stub.c
+++ b/src/module-protocol-stub.c
@@ -1,19 +1,47 @@
+#include <stdio.h>
 #include <assert.h>
 #include <arpa/inet.h>
+#include <unistd.h>
 
 #include "module.h"
 #include "socket-server.h"
+#include "util.h"
 
 #ifdef USE_PROTOCOL_SIMPLE
   #include "protocol-simple.h"
-  #define protocol_free protcol_simple_free
+  #define protocol_free protocol_simple_free
+  #define IPV4_PORT 4711
+  #define UNIX_SOCKET_DIR "/tmp/polypaudio"
+  #define UNIX_SOCKET "/tmp/polypaudio/simple"
 #else
   #ifdef USE_PROTOCOL_CLI
     #include "protocol-cli.h" 
     #define protocol_new protocol_cli_new
     #define protocol_free protocol_cli_free
+    #define IPV4_PORT 4712
+    #define UNIX_SOCKET_DIR "/tmp/polypaudio"
+    #define UNIX_SOCKET "/tmp/polypaudio/cli"
   #else
-    #error "Broken build system"
+    #ifdef USE_PROTOCOL_NATIVE
+      #include "protocol-native.h"
+      #define protocol_new protocol_native_new
+      #define protocol_free protocol_native_free
+      #define IPV4_PORT 4713
+      #define UNIX_SOCKET_DIR "/tmp/polypaudio"
+      #define UNIX_SOCKET "/tmp/polypaudio/native"
+    #else
+      #ifdef USE_PROTOCOL_ESOUND
+        #include "protocol-esound.h"
+        #include "esound-spec.h"
+        #define protocol_new protocol_esound_new
+        #define protocol_free protocol_esound_free
+        #define IPV4_PORT ESD_DEFAULT_PORT
+        #define UNIX_SOCKET_DIR ESD_UNIX_SOCKET_DIR
+        #define UNIX_SOCKET ESD_UNIX_SOCKET_NAME
+      #else
+        #error "Broken build system" 
+      #endif
+    #endif 
   #endif
 #endif
 
@@ -22,11 +50,18 @@ int module_init(struct core *c, struct module*m) {
     assert(c && m);
 
 #ifdef USE_TCP_SOCKETS
-    if (!(s = socket_server_new_ipv4(c->mainloop, INADDR_LOOPBACK, 4712)))
+    if (!(s = socket_server_new_ipv4(c->mainloop, INADDR_LOOPBACK, IPV4_PORT)))
         return -1;
 #else
-    if (!(s = socket_server_new_unix(c->mainloop, "/tmp/polypsimple")))
+    if (make_secure_dir(UNIX_SOCKET_DIR) < 0) {
+        fprintf(stderr, "Failed to create secure socket directory.\n");
         return -1;
+    }
+    
+    if (!(s = socket_server_new_unix(c->mainloop, UNIX_SOCKET))) {
+        rmdir(UNIX_SOCKET_DIR);
+        return -1;
+    }
 #endif
 
 #ifdef USE_PROTOCOL_SIMPLE
@@ -42,5 +77,9 @@ int module_init(struct core *c, struct module*m) {
 void module_done(struct core *c, struct module*m) {
     assert(c && m);
 
-    protocol_simple_free(m->userdata);
+    protocol_free(m->userdata);
+
+#ifndef USE_TCP_SOCKETS
+    rmdir(UNIX_SOCKET_DIR);
+#endif
 }