Lines Matching refs:HAL_MutexLock
106 HAL_MutexLock(pClient->lock_generic); in iotx_mc_set_client_state()
114 HAL_MutexLock(pClient->lock_generic); in iotx_mc_get_client_state()
446 HAL_MutexLock(pClient->lock_write_buf); in MQTTConnect()
537 HAL_MutexLock(c->lock_read_buf); in iotx_mc_read_packet()
707 HAL_MutexLock(c->lock_read_buf); in iotx_mc_wait_CONNACK()
715 HAL_MutexLock(c->lock_read_buf); in iotx_mc_wait_CONNACK()
721 HAL_MutexLock(c->lock_read_buf); in iotx_mc_wait_CONNACK()
904 HAL_MutexLock(c->lock_list_pub); in iotx_mc_mask_pubInfo_from()
934 HAL_MutexLock(c->lock_write_buf); in MQTTRePublish()
959 HAL_MutexLock(pClient->lock_list_pub); in MQTTPubInfoProc()
1083 HAL_MutexLock(client->lock_generic); in _iotx_mqtt_event_handle_sub()
1261 HAL_MutexLock(c->lock_generic); in iotx_mc_deliver_message()
1278 HAL_MutexLock(c->lock_generic); in iotx_mc_deliver_message()
1298 HAL_MutexLock(c->lock_generic); in iotx_mc_deliver_message()
1331 HAL_MutexLock(c->lock_write_buf); in MQTTPuback()
1534 HAL_MutexLock(c->lock_read_buf); in iotx_mc_cycle()
1546 HAL_MutexLock(c->lock_read_buf); in iotx_mc_cycle()
1554 HAL_MutexLock(c->lock_read_buf); in iotx_mc_cycle()
1635 HAL_MutexLock(pClient->lock_yield); in _mqtt_cycle()
1673 HAL_MutexLock(pClient->lock_write_buf); in MQTTKeepalive()
2108 HAL_MutexLock(c->lock_generic); in MQTTSubscribe()
2160 HAL_MutexLock(c->lock_write_buf); in MQTTSubscribe()
2218 HAL_MutexLock(c->lock_generic); in MQTTSubscribe()
2280 HAL_MutexLock(c->lock_generic); in iotx_mc_get_next_packetid()
2475 HAL_MutexLock(c->lock_write_buf); in MQTTUnsubscribe()
2523 HAL_MutexLock(c->lock_generic); in MQTTUnsubscribe()
2578 HAL_MutexLock(c->lock_list_pub); in MQTTPublish()
2579 HAL_MutexLock(c->lock_write_buf); in MQTTPublish()
2663 HAL_MutexLock(c->lock_write_buf); in MQTTDisconnect()
2877 HAL_MutexLock(pClient->lock_yield); in wrapper_mqtt_yield()
3032 HAL_MutexLock(client->lock_generic); in wrapper_mqtt_subscribe_sync()
3041 HAL_MutexLock(client->lock_generic); in wrapper_mqtt_subscribe_sync()
3105 HAL_MutexLock(client->lock_generic); in wrapper_mqtt_subscribe_sync()
3242 HAL_MutexLock(pClient->lock_yield); in wrapper_mqtt_nwk_event_handler()