mqtt/src/client.c - diff

Return to client.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

-version 1.1.2.2, 2011/12/13 09:51:35
+version 1.1.2.4, 2011/12/13 14:57:15
  Line 21  InitClient(void)
  }
  int
-SendConnect(int sock)
+try2Connect(int sock)
  {
+         int siz = 0;
+         siz = mqtt_msgCONNECT(args->msg, AIT_GET_STR(&args->ConnID), AIT_GET_STR(&args->User),
+                         AIT_GET_STR(&args->Pass), args->Will.Topic.val.string,
+                         args->Will.Msg.val.string, args->Clear, args->QoS, args->Retain);
+         if (siz == -1) {
+                 printf("Error:: msgCONNECT #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
+                 return -1;
+         }
+         siz = send(sock, args->msg->msg_base, siz, 0);
+         if (siz == -1) {
+                 printf("Error:: send() #%d - %s\n", errno, strerror(errno));
+                 return -1;
+         } else
+                 VERB(3) printf("Sended CONNECT %d bytes\n", siz);
+         return siz;
  }