mqtt/src/mqtt_pub.c - diff

Return to mqtt_pub.c CVS log

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

version 1.2, 2012/01/27 15:05:38	version 1.2.2.2, 2012/04/11 15:08:27
Line 53 Publish(int sock)	Line 53 Publish(int sock)
int siz = 0;	int siz = 0;

siz = mqtt_msgPUBLISH(args->msg, AIT_GET_STR(&args->Publish), args->MsgID, args->Dup,	siz = mqtt_msgPUBLISH(args->msg, AIT_GET_STR(&args->Publish), args->MsgID, args->Dup,
args->QoS, args->Retain, AIT_GET_PTR2(&args->Value), AIT_LEN(&args->Value));	args->QoS, args->Retain, AIT_ADDR(&args->Value), AIT_LEN(&args->Value));
if (siz == -1) {	if (siz == -1) {
printf("Error:: msgPUBLISH #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());	printf("Error:: msgPUBLISH #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
return -1;	return -1;
Line 224 main(int argc, char **argv)	Line 224 main(int argc, char **argv)
}	}
if (args->QoS && !args->MsgID)	if (args->QoS && !args->MsgID)
args->MsgID = MQTT_DEFAULT_MSGID;	args->MsgID = MQTT_DEFAULT_MSGID;
ioVERBOSE(1) printf("Connecting to %s:%d ...\n", io_n2addr(&args->addr, &val), io_n2port(&args->addr));	printf("Connecting to %s:%d ... ", io_n2addr(&args->addr, &val), io_n2port(&args->addr));
	AIT_FREE_VAL(&val);

if ((sock = InitClient()) == -1) {	if ((sock = InitClient()) == -1) {
args->free(args);	args->free(args);
Line 238 main(int argc, char **argv)	Line 239 main(int argc, char **argv)
return 3;	return 3;
}	}

printf("Connected ... ");
switch ((ret = ConnectClient(sock))) {	switch ((ret = ConnectClient(sock))) {
case -1:	case -1:
printf(">> FAILED!\n");	printf(">> FAILED!\n");