Changeset b66d43b in mainline

Timestamp:

2013-03-17T19:09:56Z (11 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

6bd0216

Parents:

bd5860f

Message:

libhound: Make protocol.h public, add server side iface skeleton.

Implement few more client side functions.

Location:

uspace/lib/hound

Files:

• include/hound/protocol.h (moved) (moved from uspace/lib/hound/src/protocol.h ) (2 diffs)
• include/hound/server.h (modified) (1 diff)
• src/protocol.c (modified) (4 diffs)

uspace/lib/hound/include/hound/protocol.h

@@ -49 +49 @@
 
 hound_context_id_t hound_service_register_context(hound_sess_t *sess,
-    const char *name);
+    const char *name, bool record);
 int hound_service_unregister_context(hound_sess_t *sess, hound_context_id_t id);
 
@@ -60 +60 @@
 int hound_service_stream_read(async_exch_t *exch, void *data, size_t size);
 
+/* Server */
+typedef struct hound_server_iface {
+        int (*add_context)(void *, hound_context_id_t *, const char *, bool);
+        int (*rem_context)(void *, hound_context_id_t);
+        int (*add_stream)(void *, hound_context_id_t, int, pcm_format_t, size_t,
+            void **);
+        int (*rem_stream)(void *, void *);
+        int (*stream_data_write)(void *, const void *, size_t);
+        int (*stream_data_read)(void *, void *, size_t);
+        void *server;
+} hound_server_iface_t;
+
+void hound_service_set_server_iface(hound_server_iface_t *iface);
+
+void hound_connection_handler(ipc_callid_t iid, ipc_call_t *icall, void *arg);
 
 #endif

uspace/lib/hound/include/hound/server.h

@@ -40 +40 @@
 #include <stdbool.h>
 #include <loc.h>
-#include <pcm/sample_format.h>
+#include <pcm/format.h>
+
+
 
 enum {

uspace/lib/hound/src/protocol.c

@@ -49 +49 @@
         IPC_M_HOUND_CONTEXT_REGISTER = IPC_FIRST_USER_METHOD,
         IPC_M_HOUND_CONTEXT_UNREGISTER,
-        IPC_M_HOUND_STREAM_START,
-        IPC_M_HOUND_STREAM_STOP,
+        IPC_M_HOUND_STREAM_ENTER,
+        IPC_M_HOUND_STREAM_EXIT,
         IPC_M_HOUND_STREAM_DRAIN,
-        IPC_M_HOUND_STREAM_WRITE,
-        IPC_M_HOUND_STREAM_READ,
 };
+
+/****
+ * CLIENT
+ ****/
 
 const char *HOUND_SERVICE = "audio/hound";
@@ -75 +77 @@
 
 hound_context_id_t hound_service_register_context(hound_sess_t *sess,
-    const char *name)
+    const char *name, bool record)
 {
         assert(sess);
         assert(name);
         async_exch_t *exch = async_exchange_begin(sess);
-        const int ret =
-            async_req_1_0(exch, IPC_M_HOUND_CONTEXT_REGISTER, str_size(name));
-        //TODO send the string
+        sysarg_t id;
+        int ret =
+            async_req_1_1(exch, IPC_M_HOUND_CONTEXT_REGISTER, record, &id);
+        if (ret == EOK)
+                ret = async_data_write_start(exch, name, str_size(name));
         async_exchange_end(exch);
-        return ret;
+        return ret == EOK ? (hound_context_id_t)id : ret;
 }
 
@@ -100 +104 @@
     int flags, pcm_format_t format, size_t bsize)
 {
+        union {
+                sysarg_t arg;
+                pcm_format_t format;
+        } convert = { .format = format };
+        return async_req_4_0(exch, IPC_M_HOUND_STREAM_ENTER, id, flags,
+            convert.arg, bsize);
+}
+
+int hound_service_stream_exit(async_exch_t *exch)
+{
+        return async_req_0_0(exch, IPC_M_HOUND_STREAM_EXIT);
+}
+
+int hound_service_stream_drain(async_exch_t *exch)
+{
+        //TODO implement
         return ENOTSUP;
 }
 
-int hound_service_stream_exit(async_exch_t *exch)
-{
+int hound_service_stream_write(async_exch_t *exch, const void *data, size_t size)
+{
+        return async_data_write_start(exch, data, size);
+}
+
+int hound_service_stream_read(async_exch_t *exch, void *data, size_t size)
+{
+        //TODO implement
         return ENOTSUP;
 }
 
-int hound_service_stream_drain(async_exch_t *exch)
-{
-        return ENOTSUP;
-}
-
-int hound_service_stream_write(async_exch_t *exch, const void *data, size_t size)
-{
-        return ENOTSUP;
-}
-
-int hound_service_stream_read(async_exch_t *exch, void *data, size_t size)
-{
-        return ENOTSUP;
-}
-
+/****
+ * SERVER
+ ****/
+
+static int hound_server_read_data(void *stream);
+static hound_server_iface_t *server_iface;
+
+void hound_service_set_server_iface(hound_server_iface_t *iface)
+{
+        server_iface = iface;
+}
+
+void hound_connection_handler(ipc_callid_t iid, ipc_call_t *icall, void *arg)
+{
+        /* Accept connection if there is a valid iface*/
+        if (server_iface) {
+                async_answer_0(iid, EOK);
+        } else {
+                async_answer_0(iid, ENOTSUP);
+                return;
+        }
+
+        while (1) {
+                ipc_call_t call;
+                ipc_callid_t callid = async_get_call(&call);
+                switch(IPC_GET_IMETHOD(call)) {
+                case IPC_M_HOUND_CONTEXT_REGISTER: {
+                        if (!server_iface || !server_iface->add_context) {
+                                async_answer_0(callid, ENOTSUP);
+                                break;
+                        }
+                        bool record = IPC_GET_ARG1(call);
+                        void *name;
+                        int ret =
+                            async_data_write_accept(&name, true, 0, 0, 0, 0);
+                        if (ret != EOK) {
+                                async_answer_0(callid, ret);
+                                break;
+                        }
+                        hound_context_id_t id = 0;
+                        ret = server_iface->add_context(server_iface->server,
+                            &id, name, record);
+                        if (ret != EOK) {
+                                free(name);
+                                async_answer_0(callid, ret);
+                                break;
+                        }
+                        async_answer_1(callid, EOK, id);
+                }
+                case IPC_M_HOUND_STREAM_ENTER: {
+                        if (!server_iface || !server_iface->add_stream) {
+                                async_answer_0(callid, ENOTSUP);
+                                break;
+                        }
+
+                        hound_context_id_t id = IPC_GET_ARG1(call);
+                        int flags = IPC_GET_ARG2(call);
+                        union {
+                                sysarg_t arg;
+                                pcm_format_t format;
+                        } convert = { .arg = IPC_GET_ARG3(call) };
+                        size_t bsize = IPC_GET_ARG4(call);
+                        void *stream;
+                        int ret = server_iface->add_stream(server_iface->server,
+                            id, flags, convert.format, bsize, &stream);
+                        if (ret != EOK) {
+                                async_answer_0(callid, ret);
+                                break;
+                        }
+                        hound_server_read_data(stream);
+                        break;
+                }
+                case IPC_M_HOUND_CONTEXT_UNREGISTER:
+                case IPC_M_HOUND_STREAM_EXIT:
+                case IPC_M_HOUND_STREAM_DRAIN:
+                default:
+                        async_answer_0(callid, ENOTSUP);
+                        return;
+                }
+        }
+}
+
+static int hound_server_read_data(void *stream)
+{
+        if (!server_iface || !server_iface->stream_data_write)
+                return ENOTSUP;
+
+        ipc_callid_t callid;
+        size_t size = 0;
+        while (async_data_write_receive(&callid, &size)) {
+                char *buffer = malloc(size);
+                if (!buffer) {
+                        async_answer_0(callid, ENOMEM);
+                        continue;
+                }
+                int ret = async_data_write_finalize(callid, buffer, size);
+                if (ret == EOK) {
+                        server_iface->stream_data_write(stream, buffer, size);
+                } else {
+                        // TODO did answering fail?
+                        async_answer_0(callid, ret);
+                }
+        }
+        //TODO we assume that the fail was caused by IPC_M_HOUND_STREAM_EXIT
+        async_answer_0(callid, EOK);
+        return EOK;
+}
 
 /***
- * CLIENT SIDE
+ * CLIENT SIDE -DEPRECATED
  ***/
 
@@ -348 +466 @@
 
 /***
- * SERVER SIDE
+ * SERVER SIDE - DEPRECATED
  ***/
+
 static const char * get_name(void);