transfer to other machine

main.c

@@ -26,30 +26,27 @@ pthread_mutex_t sendmut, receivemut;
 int sockfd, confd;
 
 void *input(void *arg) {
-  char *msg;
-  char *copy;
+  char msg[128];
   while (1) {
-    msg = malloc(30);
+    memset(msg, 0, 128);
     printf("Type a message: ");
     fgets(msg, sizeof(msg), stdin);
-    copy = malloc(30);
-    strcpy(copy, msg);
     pthread_mutex_lock(&sendmut);
-    ListAppend(sendlist, copy);
+    ListAppend(sendlist, msg);
     pthread_mutex_unlock(&sendmut);
   }	
 	return 0;
 }
 
 void *sender(void *arg) {
-  char *msg;
+  char msg[128];
   while (1) {
-   msg = malloc(30);
-   pthread_mutex_lock(&sendmut);
+    memset(msg, 0, 128);
+    /*pthread_mutex_lock(&sendmut);
     if (ListCount(sendlist) != 0) {
       ListFirst(sendlist);
       strcpy(msg, ListCurr(sendlist));
-     send(confd, &msg, 30, 0);
+      send(confd, msg, sizeof(msg), 0);
       ListRemove(sendlist);
     }
     else {
@@ -57,33 +54,47 @@ void *sender(void *arg) {
       continue;
     }
     pthread_mutex_unlock(&sendmut);
+  }*/
+    printf("Type a message: ");
+    fgets(msg, sizeof(msg), stdin);
+    pthread_mutex_lock(&sendmut);
+    printf("Msg to send: %s\n", msg);
+    pthread_mutex_unlock(&sendmut);
+    send(confd, msg, sizeof(msg), 0);
   }
   return 0;	
 }
 
 void *receiver(void *arg) {
-  char msg[30];
-  char *copy = malloc(31);
+  char buf[128];
+  int bytes;
   while (1) {
-    recv(sockfd, msg, 30, 0);
-    if (msg[0] != '\n' && msg[0] != '\0') {
-      pthread_mutex_lock(&receivemut);
-      ListAppend(receivelist, msg);
+    memset(buf, 0, 128);
+    bytes = recv(sockfd, buf, 128, 0);
+    /*pthread_mutex_lock(&receivemut);
+    ListAppend(receivelist, buf);
     pthread_mutex_unlock(&receivemut);
+    */
+    if (bytes != -1) {
+      printf("Received: %s\n", buf);
+    }
+    else {
+      perror("recv");
     }
   }
   return 0;
 }
 
 void *output(void *arg) {
-  char *msg;
+  char msg[128];
   while (1) {
+    memset(msg, 0, 128);
     pthread_mutex_lock(&receivemut);
     if (ListCount(receivelist) != 0) {
       ListFirst(receivelist);
-      msg = ListCurr(receivelist);
+      strcpy(msg, ListCurr(receivelist));
       ListRemove(receivelist);
-      printf("%s\n", (char*)msg); 
+      printf("%s\n", msg); 
     }
     pthread_mutex_unlock(&receivemut);
   }
@@ -190,7 +201,6 @@ int main(int argc, char* argv[]) {
             s,
         sizeof s);
     printf("Getting chatty with %s\n", s);
-    send(confd, "test", 4, 0); 
   }
 	else {
 		memset(&hints, 0, sizeof(hints));
@@ -211,7 +221,7 @@ int main(int argc, char* argv[]) {
 			}
 		      	inet_ntop(q->ai_family, get_in_addr((struct sockaddr *)q->ai_addr), 
 				  s, sizeof s);
-			printf("Client: attempting connection to %s\n", s);
+			printf("Connecting to %s\n", s);
 
 			if (connect(sockfd, q->ai_addr, q->ai_addrlen) == -1) {
 			  perror("Client: connect");
@@ -228,20 +238,18 @@ int main(int argc, char* argv[]) {
 		else {
 			servinfo = q;
 		}
-    recv(sockfd, buf, 4, 0); 
-    printf("%s\n", buf);
   }
-  /*
-  pthread_create(&input_thread, NULL, input, NULL);
 	pthread_create(&send_thread, NULL, sender, NULL);
 	pthread_create(&receive_thread, NULL, receiver,  NULL);
+  /*pthread_create(&input_thread, NULL, input, NULL);
   pthread_create(&output_thread, NULL, output, NULL);
   pthread_join(input_thread, NULL);
+  pthread_join(output_thread, NULL);
+  
+
+  */
   pthread_join(send_thread, NULL);
   pthread_join(receive_thread, NULL);
-  pthread_join(output_thread, NULL);
- */
-  
   
   close(sockfd);
   close(confd);