Changeset 222 for vtcross/trunk/src/lib/socketcomm/socketcomm.cpp

Timestamp:

03/30/09 21:38:53 (15 years ago)

Author:

trnewman

Message:

Added libvtcross functionality. Made socketcomm a little more robust. Added libvtcross demo application to illustrate how to use the lib.

Files:

• vtcross/trunk/src/lib/socketcomm/socketcomm.cpp (modified) (7 diffs)

vtcross/trunk/src/lib/socketcomm/socketcomm.cpp

@@ -41 +41 @@
     // Messages are termination with a "\0" to denote EOM.
     ssize_t msgLength = recv(socketFD, msgBuffer, 256, MSG_PEEK);
+    if (msgLength < 0)
+        ERROR(1, "Error reading from socket.\n");
+    if (msgLength == 0)
+        ERROR(1, "Remote component closed connection.\n");
 
     size_t i;
@@ -51 +55 @@
     msgLength = recv(socketFD, msgBuffer, i + 1, 0);
     if (msgLength < 0)
-        ERROR(1, "Error reading from socket");
+        ERROR(1, "Error reading from socket.\n");
+    if (msgLength == 0)
+        ERROR(1, "Remote component closed connection.\n");
 }
 
@@ -66 +72 @@
     server = gethostbyname(serverName);
     if(server == NULL)
-        ERROR(1, "No server found by that hostname.");
+        ERROR(1, "No server found by that hostname.\n");
 
     portNumber = atoi(serverPort);
@@ -72 +78 @@
     socketFD = socket(AF_INET, SOCK_STREAM, 0);
     if(socketFD < 0) 
-        ERROR(1, "Error opening socket");
+        ERROR(1, "Error opening socket\n");
 
     memset((void *) &serv_addr, 0, sizeof(serv_addr));
@@ -81 +87 @@
 
     if(connect(socketFD, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) 
-        ERROR(1, "Error connecting to remote socket.");
+        ERROR(1, "Error connecting to remote socket.\n");
 
     return socketFD;
@@ -117 +123 @@
 {
     ssize_t numSentBytes = send(socketFD, message, (strlen(message) + 1), 0);
-    if(numSentBytes < 0) {
-        ERROR(1, "Error sending to server.");
+        if(numSentBytes < 0) {
+        ERROR(1, "Error sending to server.\n");
     }
     else if(numSentBytes == 0) {
@@ -210 +216 @@
     int32_t clientSocket = accept(serverSock, NULL, NULL);
     if(clientSocket < 0) { 
-        WARNING("ALERT: Could not establish connection with client socket.\n");
+        //WARNING("ALERT: Could not establish connection with client socket.\n");
         return -1;
     }