version 1.1.2.6, 2012/05/09 13:48:31
|
version 1.1.2.7, 2012/05/10 09:06:42
|
Line 170 mqtt_cli_Subscribe(mqtt_cli_t * __restrict cli, mqtt_s
|
Line 170 mqtt_cli_Subscribe(mqtt_cli_t * __restrict cli, mqtt_s
|
return NULL; |
return NULL; |
if (msgID != mid) { |
if (msgID != mid) { |
free(qoses); |
free(qoses); |
mqtt_SetErr(EBADMSG, "Receive different message ID %hu != %hu", msgID, mid); | mqtt_SetErr(ECANCELED, "Receive different message ID %hu != %hu", msgID, mid); |
return NULL; |
return NULL; |
} |
} |
|
|
Line 221 mqtt_cli_Unsubscribe(mqtt_cli_t * __restrict cli, mqtt
|
Line 221 mqtt_cli_Unsubscribe(mqtt_cli_t * __restrict cli, mqtt
|
if (siz == -1) |
if (siz == -1) |
return -1; |
return -1; |
if (msgID != siz) { |
if (msgID != siz) { |
mqtt_SetErr(EBADMSG, "Receive different message ID %hu != %hu", msgID, siz); | mqtt_SetErr(ECANCELED, "Receive different message ID %hu != %hu", msgID, siz); |
return -1; |
return -1; |
} |
} |
|
|
Line 280 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
Line 280 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
if (siz == -1) |
if (siz == -1) |
return -1; |
return -1; |
if (msgID != siz) { |
if (msgID != siz) { |
mqtt_SetErr(EBADMSG, "Receive different message ID %hu != %hu", msgID, siz); | mqtt_SetErr(ECANCELED, "Receive different message ID %hu != %hu", msgID, siz); |
return -1; |
return -1; |
} |
} |
goto end; |
goto end; |
Line 289 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
Line 289 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
if (siz == -1) |
if (siz == -1) |
return -1; |
return -1; |
if (msgID != siz) { |
if (msgID != siz) { |
mqtt_SetErr(EBADMSG, "Receive different message ID %hu != %hu", msgID, siz); | mqtt_SetErr(ECANCELED, "Receive different message ID %hu != %hu", msgID, siz); |
return -1; |
return -1; |
} |
} |
} |
} |
Line 319 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
Line 319 mqtt_cli_Publish(mqtt_cli_t * __restrict cli, u_short
|
if (siz == -1) |
if (siz == -1) |
return -1; |
return -1; |
if (msgID != siz) { |
if (msgID != siz) { |
mqtt_SetErr(EBADMSG, "Receive different message ID %hu != %hu", msgID, siz); | mqtt_SetErr(ECANCELED, "Receive different message ID %hu != %hu", msgID, siz); |
if (Dup++ > 1) |
if (Dup++ > 1) |
return -1; |
return -1; |
else |
else |