[core] Fixed group read-ready epoll events.

Haivision · Aug 4, 2023 · c639310 · c639310
1 parent 9f4e9b6
commit c639310
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/srtcore/group.cpp b/srtcore/group.cpp
@@ -2310,13 +2310,19 @@ int CUDTGroup::recv(char* buf, int len, SRT_MSGCTRL& w_mc)
                 }
             }
         }
+        bool canReadFurther = false;
         for (vector<CUDTSocket*>::const_iterator si = aliveMembers.begin(); si != aliveMembers.end(); ++si)
         {
             CUDTSocket* ps = *si;
             if (!ps->core().isRcvBufferReady())
                 m_Global.m_EPoll.update_events(ps->m_SocketID, ps->core().m_sPollID, SRT_EPOLL_IN, false);
+            else
+                canReadFurther = true;
         }
 
+        if (!canReadFurther)
+            m_Global.m_EPoll.update_events(id(), m_sPollID, SRT_EPOLL_IN, false);
+
         return res;
     }
     LOGC(grlog.Error, log << "grp/recv: UNEXPECTED RUN PATH, ABANDONING.");