srt: Make logging regarding callers more useful

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/1273>

diff --git a/ext/srt/gstsrtobject.c b/ext/srt/gstsrtobject.c
index 2328728..c8cc421 100644 (file)
--- a/ext/srt/gstsrtobject.c
+++ b/ext/srt/gstsrtobject.c
@@ -744,6 +744,9 @@ thread_func (gpointer data)
         continue;
       }
 
+      GST_DEBUG_OBJECT (srtobject->element, "Accept to connect %d",
+          caller->sock);
+
       g_mutex_lock (&srtobject->sock_lock);
       srtobject->callers = g_list_append (srtobject->callers, caller);
       g_cond_signal (&srtobject->sock_cond);
@@ -753,8 +756,6 @@ thread_func (gpointer data)
       g_signal_emit_by_name (srtobject->element, "caller-added", caller->sock,
           caller->sockaddr);
 
-      GST_DEBUG_OBJECT (srtobject->element, "Accept to connect");
-
       if (gst_uri_handler_get_uri_type (GST_URI_HANDLER (srtobject->element)) ==
           GST_URI_SRC)
         return NULL;
@@ -1146,20 +1147,28 @@ static gboolean
 gst_srt_object_wait_caller (GstSRTObject * srtobject,
     GCancellable * cancellable, GError ** errorj)
 {
-  gboolean ret = FALSE;
-
-  GST_DEBUG_OBJECT (srtobject->element, "Waiting connection from caller");
+  gboolean ret;
 
   g_mutex_lock (&srtobject->sock_lock);
-  while (!g_cancellable_is_cancelled (cancellable)) {
-    ret = (srtobject->callers != NULL);
-    if (ret)
-      break;
-    g_cond_wait (&srtobject->sock_cond, &srtobject->sock_lock);
+
+  if (srtobject->callers == NULL) {
+    GST_INFO_OBJECT (srtobject->element, "Waiting for connection");
+
+    while (!g_cancellable_is_cancelled (cancellable)) {
+      ret = (srtobject->callers != NULL);
+      if (ret)
+        break;
+
+      g_cond_wait (&srtobject->sock_cond, &srtobject->sock_lock);
+    }
+
+    GST_DEBUG_OBJECT (srtobject->element, "Got %s connection",
+        ret ? "a" : "no");
+  } else {
+    ret = TRUE;
   }
-  g_mutex_unlock (&srtobject->sock_lock);
 
-  GST_DEBUG_OBJECT (srtobject->element, "got %s connection", ret ? "a" : "no");
+  g_mutex_unlock (&srtobject->sock_lock);
 
   return ret;
 }
@@ -1374,6 +1383,8 @@ gst_srt_object_write_to_callers (GstSRTObject * srtobject,
       gint rest = MIN (mapinfo->size - len, payload_size);
       sent = srt_sendmsg2 (caller->sock, (char *) (msg + len), rest, 0);
       if (sent < 0) {
+        GST_WARNING_OBJECT (srtobject->element, "Dropping caller %d: %s",
+            caller->sock, srt_getlasterror_str ());
         goto err;
       }
       len += sent;