[apps] Examples: wait 1 sec until receiver completes (#2572).

Haivision · Dec 8, 2022 · b6f1e9c · b6f1e9c
1 parent ba67d36
commit b6f1e9c
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/examples/test-c-client.c b/examples/test-c-client.c
@@ -59,7 +59,11 @@ int main(int argc, char** argv)
     }
 
     printf("srt setsockflag\n");
-    srt_setsockflag(ss, SRTO_SENDER, &yes, sizeof yes);
+    if (SRT_ERROR == srt_setsockflag(ss, SRTO_SENDER, &yes, sizeof yes)
+    {
+        fprintf(stderr, "srt_setsockflag: %s\n", srt_getlasterror_str());
+        return 1;
+    }
 
     // Test deprecated
     //srt_setsockflag(ss, SRTO_STRICTENC, &yes, sizeof yes);
@@ -87,6 +91,7 @@ int main(int argc, char** argv)
     }
 
 
+    sleep(1); // 1 second to give it enough time to receive all messages
     printf("srt close\n");
     st = srt_close(ss);
     if (st == SRT_ERROR)

diff --git a/examples/test-c-server.c b/examples/test-c-server.c
@@ -54,7 +54,11 @@ int main(int argc, char** argv)
     }
 
     printf("srt setsockflag\n");
-    srt_setsockflag(ss, SRTO_RCVSYN, &yes, sizeof yes);
+    if (SRT_ERROR == srt_setsockflag(ss, SRTO_RCVSYN, &yes, sizeof yes)
+    {
+        fprintf(stderr, "srt_setsockflag: %s\n", srt_getlasterror_str());
+        return 1;
+    }
 
     printf("srt bind\n");
     st = srt_bind(ss, (struct sockaddr*)&sa, sizeof sa);
@@ -75,6 +79,11 @@ int main(int argc, char** argv)
     printf("srt accept\n");
     int addr_size = sizeof their_addr;
     int their_fd = srt_accept(ss, (struct sockaddr *)&their_addr, &addr_size);
+    if (their_fd == SRT_INVALID_SOCK)
+    {
+        fprintf(stderr, "srt_accept: %s\n", srt_getlasterror_str());
+        return 1;
+    }
 
     int i;
     for (i = 0; i < 100; i++)