commit fc45b0db132efac6f4c9cf9721d29e605553bc9e
author Shalini Manjunatha <shalma@codeaurora.org> Tue Oct 13 18:09:51 2020 +0530
committer Shalini Manjunatha <shalma@codeaurora.org> Wed Oct 21 11:01:06 2020 +0530
tree 383dc3648ce85d713868036a0a20b3b8db9d06b8
parent f4495355958f588e07347a6aca2aefe76882c47a

st-hal: Restart ST Session during buffering for erroneous scenarios

In erroneous scenarios when buffering is stopped internally
before successfully processing the detection and sending it
to client, recover to next detection by restarting the session.

Change-Id: Ia28eb5b070870f2c9f11169c1534099bbed0a2bf

st_session.c

diff --git a/st_session.c b/st_session.c
index bbe83f7..3f09fcb 100644
--- a/st_session.c
+++ b/st_session.c
@@ -236,20 +236,23 @@
                  (st_ses->current_state == buffering_state_fn) &&
                  !st_ses->stdev->ssr_offline_received);
 
-        if (st_ses->det_stc_ses->pending_stop)
+        if (st_ses->det_stc_ses->pending_stop) {
             ALOGV("%s:[%d] pending stop already queued, ignore event",
                 __func__, st_ses->sm_handle);
-        else if (!st_ses->det_stc_ses->detection_sent)
-            ALOGV("%s:[%d] client callback hasn't been called, ignore event",
-                __func__, st_ses->sm_handle);
-        else if (st_ses->current_state != buffering_state_fn)
+        } else if (!st_ses->det_stc_ses->detection_sent) {
+                ev.ev_id = ST_SES_EV_RESTART;
+                DISPATCH_EVENT(st_ses, ev, status);
+                ALOGV("%s:[%d] client callback hasn't been called, restart detection evt_id(%d)",
+                   __func__, st_ses->sm_handle, ev.ev_id);
+        } else if (st_ses->current_state != buffering_state_fn) {
             ALOGV("%s:[%d] session already stopped buffering, ignore event",
                 __func__, st_ses->sm_handle);
-        else if (st_ses->stdev->ssr_offline_received)
+        } else if (st_ses->stdev->ssr_offline_received) {
             ALOGV("%s:[%d] SSR handling in progress, ignore event",
                   __func__, st_ses->sm_handle);
-        else if (!lock_status)
+        } else if (!lock_status) {
             DISPATCH_EVENT(st_ses, ev, status);
+        }
 
         if (!lock_status)
             pthread_mutex_unlock(&st_ses->lock);