version 1.1.2.1, 2011/12/13 08:43:51
|
version 1.1.2.4, 2011/12/13 14:57:15
|
Line 19 InitClient(void)
|
Line 19 InitClient(void)
|
|
|
return sock; |
return sock; |
} |
} |
|
|
|
int |
|
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; |
|
} |