Changes in pjproject/main/pjlib/src/pjlib-test/echo_clt.c [1:3]

File:

• pjproject/main/pjlib/src/pjlib-test/echo_clt.c (modified) (6 diffs, 1 prop)

pjproject/main/pjlib/src/pjlib-test/echo_clt.c

@@ -1 @@
-/* $Header: /pjproject-0.3/pjlib/src/pjlib-test/echo_clt.c 3     10/29/05 10:25p Bennylp $ */
+/* $Id$
+ *
+ */
 /*
  * $Log: /pjproject-0.3/pjlib/src/pjlib-test/echo_clt.c $
@@ -47 +49 @@
     PJ_FD_SET(sock, &fdset);
     
-    return pj_sock_select(1, &fdset, NULL, NULL, &timeout);
+    return pj_sock_select(FD_SETSIZE, &fdset, NULL, NULL, &timeout);
 }
 
@@ -83 +85 @@
         return -20;
     }
+
+    PJ_LOG(3,("", "...socket connected to %s:%d", 
+                  pj_inet_ntoa(addr.sin_addr),
+                  pj_ntohs(addr.sin_port)));
 
     pj_create_random_string(send_buf, BUF_SIZE);
@@ -116 +122 @@
         if (rc == 0) {
             PJ_LOG(3,("", "...timeout"));
+            bytes = 0;
+        } else if (rc < 0) {
+            rc = pj_get_netos_error();
+            app_perror("...select() error", rc);
+            break;
         } else {
             /* Receive back the original packet. */
@@ -130 +141 @@
                     }
                     bytes = 0;
+                    received = 0;
                     break;
                 }
                 bytes += received;
-            } while (bytes != BUF_SIZE);
+            } while (bytes != BUF_SIZE && bytes != 0);
         }
 
@@ -178 +190 @@
 
         if (pj_memcmp(send_buf, recv_buf, BUF_SIZE) != 0) {
-            PJ_LOG(3,("", "...error: buffer has changed!"));
+            //PJ_LOG(3,("", "...error: buffer has changed!"));
             break;
         }