commit 7c09d5dd26e7b1d95b0e881aa166cacc363c9c67
author Harsh Bansal <hbansal@codeaurora.org> Fri Aug 04 14:20:37 2017 +0530
committer Garmond Leung <garmondl@codeaurora.org> Wed Sep 13 16:14:12 2017 -0700
tree b0f0ab138bd66f838c9926b3e682aff911599956
parent 2062f91106d97a0bb407ed30d3d2799570f259db

hal: qaf: send write ready for partially consumed buffer

-When buffer is partially consumed, need to send the write ready
to user as soon as module buffer gets free.

CRs-fixed: 2088425
Change-Id: Ia003db97bd90665a772933241da0ef33daff81ce

hal/audio_extn/qaf.c

diff --git a/hal/audio_extn/qaf.c b/hal/audio_extn/qaf.c
index 90b054c..e7ab846 100644
--- a/hal/audio_extn/qaf.c
+++ b/hal/audio_extn/qaf.c
@@ -765,8 +765,7 @@
     DEBUG_MSG_VV("ret [%d]", (int)ret);
 
     if (ret >= 0) {
-        bytes = ret;
-        out->written += bytes / ((popcount(out->channel_mask) * sizeof(short)));
+        out->written += ret / ((popcount(out->channel_mask) * sizeof(short)));
     }
 
 
@@ -786,6 +785,11 @@
                    / audio_stream_out_frame_size(stream)
                    / out->stream.common.get_sample_rate(&out->stream.common));
         }
+    } else if (ret < bytes) {
+        //partial buffer copied to the module.
+        DEBUG_MSG_VV("Not enough space available in mm module, post msg to cb thread");
+        (void)qaf_send_offload_cmd_l(out, OFFLOAD_CMD_WAIT_FOR_BUFFER);
+        bytes = ret;
     }
     return bytes;
 }
@@ -2136,7 +2140,7 @@
                         parms = str_parms_create_str(kvpairs);
                         ret = str_parms_get_int(parms, "buf_available", &value);
                         if (ret >= 0) {
-                            if (value >= (int)out->compr_config.fragment_size) {
+                            if (value > 0) {
                                 DEBUG_MSG_VV("buffer available");
                                 str_parms_destroy(parms);
                                 parms = NULL;