OrgUCloud
/
ucloud-iot-device-sdk-c
mirror of https://github.com/ucloud/ucloud-iot-device-sdk-c.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

modify disconnect flag

This commit is contained in:
ethan.du 2021-01-08 14:27:01 +08:00
parent d20db71caa
commit adf5ccec18
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mqtt/src/mqtt_client_connect.c
View File

@ -365,8 +365,7 @@ int uiot_mqtt_disconnect(UIoT_Client *pClient) {
HAL_MutexLock(pClient->lock_write_buf); HAL_MutexLock(pClient->lock_write_buf);
ret = serialize_packet_with_zero_payload(pClient->write_buf, pClient->write_buf_size, DISCONNECT, &serialized_len); ret = serialize_packet_with_zero_payload(pClient->write_buf, pClient->write_buf_size, DISCONNECT, &serialized_len);
if (ret != SUCCESS_RET) { if (ret != SUCCESS_RET) {
HAL_MutexUnlock(pClient->lock_write_buf); goto end;
return ret;
} }
init_timer(&timer); init_timer(&timer);
@ -376,13 +375,13 @@ int uiot_mqtt_disconnect(UIoT_Client *pClient) {
if (serialized_len > 0) { if (serialized_len > 0) {
ret = send_mqtt_packet(pClient, serialized_len, &timer); ret = send_mqtt_packet(pClient, serialized_len, &timer);
if (ret != SUCCESS_RET) { if (ret != SUCCESS_RET) {
HAL_MutexUnlock(pClient->lock_write_buf); goto end;
return ret;
} }
} }
HAL_MutexUnlock(pClient->lock_write_buf);
// 3. 断开底层TCP连接, 并修改相关标识位 // 3. 断开底层TCP连接, 并修改相关标识位
end:
HAL_MutexUnlock(pClient->lock_write_buf);
pClient->network_stack.disconnect(&(pClient->network_stack)); pClient->network_stack.disconnect(&(pClient->network_stack));
set_client_conn_state(pClient, DISCONNECTED); set_client_conn_state(pClient, DISCONNECTED);
pClient->was_manually_disconnected = 1; pClient->was_manually_disconnected = 1;