Changeset 8de7ef2 in mainline for uspace/lib/drv/generic/remote_audio_pcm_buffer.c

Timestamp:

2012-07-05T19:31:39Z (12 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

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

Children:

7ca22e5

Parents:

f8608f2

Message:

libdrv,audio: Add event callback creation to audio iface.

File:

• uspace/lib/drv/generic/remote_audio_pcm_buffer.c (modified) (6 diffs)

uspace/lib/drv/generic/remote_audio_pcm_buffer.c

@@ -83 +83 @@
 /*----------------------------------------------------------------------------*/
 int audio_pcm_buffer_get_buffer(async_exch_t *exch, void **buffer, size_t *size,
-    unsigned *id)
+    unsigned *id, async_client_conn_t event_rec, void* arg)
 {
         if (!exch || !buffer || !size || !id)
@@ -95 +95 @@
                 void *dst = NULL;
                 // FIXME Do we need to know the flags?
-                const int ret = async_share_in_start_0_0(exch, buffer_size, &dst);
+                int ret = async_share_in_start_0_0(exch, buffer_size, &dst);
                 if (ret != EOK) {
                         return ret;
                 }
+                ret = async_connect_to_me(exch, 0, 0, 0, event_rec, arg);
+                if (ret != EOK) {
+                        return ret;
+                }
+
                 *buffer = dst;
                 *size = buffer_size;
@@ -115 +120 @@
 /*----------------------------------------------------------------------------*/
 int audio_pcm_buffer_start_playback(async_exch_t *exch, unsigned id,
-    unsigned sample_rate, uint16_t sample_size, uint8_t channels, bool sign)
+    unsigned parts, unsigned sample_rate, uint16_t sample_size,
+    uint8_t channels, bool sign)
 {
         if (!exch)
                 return EINVAL;
-        sysarg_t packed =
-            (sample_size << 16) | (channels << 8) | (sign ? 1 : 0);
+        const sysarg_t packed =
+            (sample_size << 16) | (channels << 8) |
+            (parts & 0x7f << 1) | (sign ? 1 : 0);
         return async_req_4_0(exch, DEV_IFACE_ID(AUDIO_PCM_BUFFER_IFACE),
             IPC_M_AUDIO_PCM_START_PLAYBACK, id, sample_rate, packed);
@@ -214 +221 @@
         const audio_pcm_buffer_iface_t *pcm_iface = iface;
 
-        if (!pcm_iface->get_buffer) {
+        if (!pcm_iface->get_buffer ||
+            !pcm_iface->release_buffer ||
+            !pcm_iface->set_event_session) {
                 async_answer_0(callid, ENOTSUP);
                 return;
@@ -221 +230 @@
         size_t size = DEV_IPC_GET_ARG1(*call);
         unsigned id = 0;
-        const int ret = pcm_iface->get_buffer(fun, &buffer, &size, &id);
+        int ret = pcm_iface->get_buffer(fun, &buffer, &size, &id);
         async_answer_2(callid, ret, size, id);
+        if (ret != EOK || size == 0)
+                return;
+
         /* Share the buffer. */
-        if (ret == EOK && size > 0) {
-                size_t share_size = 0;
-                ipc_callid_t share_id = 0;
-                ddf_msg(LVL_DEBUG2, "Calling share receive.");
-                if (!async_share_in_receive(&share_id, &share_size)) {
-                        ddf_msg(LVL_DEBUG, "Failed to share pcm buffer.");
-                        if (pcm_iface->release_buffer)
-                                pcm_iface->release_buffer(fun, id);
-                        async_answer_0(share_id, EPARTY);
-                        return;
-                }
-                ddf_msg(LVL_DEBUG2, "Checking requested share size");
-                if (share_size != size) {
-                        ddf_msg(LVL_DEBUG, "Incorrect pcm buffer size requested.");
-                        if (pcm_iface->release_buffer)
-                                pcm_iface->release_buffer(fun, id);
-                        async_answer_0(share_id, ELIMIT);
-                        return;
-                }
-                ddf_msg(LVL_DEBUG2, "Calling share finalize");
-                const int ret = async_share_in_finalize(share_id, buffer, 0);
+        size_t share_size = 0;
+        ipc_callid_t share_id = 0;
+        ddf_msg(LVL_DEBUG2, "Calling share receive.");
+        if (!async_share_in_receive(&share_id, &share_size)) {
+                ddf_msg(LVL_DEBUG, "Failed to share pcm buffer.");
+                if (pcm_iface->release_buffer)
+                        pcm_iface->release_buffer(fun, id);
+                async_answer_0(share_id, EPARTY);
+                return;
+        }
+        ddf_msg(LVL_DEBUG2, "Checking requested share size");
+        if (share_size != size) {
+                ddf_msg(LVL_DEBUG, "Incorrect pcm buffer size requested.");
+                if (pcm_iface->release_buffer)
+                        pcm_iface->release_buffer(fun, id);
+                async_answer_0(share_id, ELIMIT);
+                return;
+        }
+        ddf_msg(LVL_DEBUG2, "Calling share finalize");
+        ret = async_share_in_finalize(share_id, buffer, 0);
+        if (ret != EOK) {
+                ddf_msg(LVL_DEBUG, "Failed to share buffer");
+                if (pcm_iface->release_buffer)
+                        pcm_iface->release_buffer(fun, id);
+                return;
+
+        }
+        ddf_msg(LVL_DEBUG2, "Buffer shared with size %zu, creating callback.",
+            share_size);
+        {
+                ipc_call_t call;
+                ipc_callid_t callid = async_get_call(&call);
+                async_sess_t *sess =
+                    async_callback_receive_start(EXCHANGE_ATOMIC, &call);
+                if (sess == NULL) {
+                        ddf_msg(LVL_DEBUG, "Failed to create event callback");
+                        pcm_iface->release_buffer(fun, id);
+                        async_answer_0(callid, EAGAIN);
+                        return;
+                }
+                ret = pcm_iface->set_event_session(fun, id, sess);
                 if (ret != EOK) {
-                        ddf_msg(LVL_DEBUG, "Failed to share buffer");
-                        if (pcm_iface->release_buffer)
-                                pcm_iface->release_buffer(fun, id);
-                        return;
-
-                }
-                ddf_msg(LVL_DEBUG2, "Buffer shared ok with size %zu.",
-                    share_size);
+                        ddf_msg(LVL_DEBUG, "Failed to set event callback.");
+                        pcm_iface->release_buffer(fun, id);
+                }
+                async_answer_0(callid, ret);
         }
 }
@@ -276 +304 @@
         const unsigned rate = DEV_IPC_GET_ARG2(*call);
         const unsigned size = DEV_IPC_GET_ARG3(*call) >> 16;
-        const unsigned channels = (DEV_IPC_GET_ARG3(*call) >> 8) && UINT8_MAX;
+        const unsigned channels = (DEV_IPC_GET_ARG3(*call) >> 8) & UINT8_MAX;
+        const unsigned parts = (DEV_IPC_GET_ARG3(*call) >> 1) & 0x7f;
         const bool sign = (bool)(DEV_IPC_GET_ARG3(*call) & 1);
 
         const int ret = pcm_iface->start_playback
-            ? pcm_iface->start_playback(fun, id, rate, size, channels, sign)
+            ? pcm_iface->start_playback(fun, id, parts, rate, size, channels, sign)
             : ENOTSUP;
         async_answer_0(callid, ret);