user_recv_handle_cb;
STAILQ_INSERT_TAIL(lhead, &process_func, next);
p_recv_msg = NULL;
}
static OSStatus...mqtt_client_release(Client *c, Network *n){
OSStatus err = kNoErr;
if (c->isconnected) MQTTDisconnect...", err);
mqtt_client_release(&c, &n);
pthread_exit(NULL);
}
static OSStatus mqtt_msg_publish(Client *...c, const char* topic, char qos, char retained,
const unsigned char* msg,
uint32_t msg_len){
OSStatus...= NULL){
free(p_send_msg);
p_send_msg = NULL;
}
}
int main(void){
// void *rval;
OSStatus err = kNoErr