完善资料让更多小伙伴认识你,还能领取20积分哦, 立即完善>
我在zynq-7000上跑freertos (基于lwip),我起了一个任务建立mqtt连接,又在其中起了另一个任务去初始化一个GPIO的中断。现在遇到的问题是,只要我启动这个中断,mqtt的连接就总会断,大概5秒之内吧;而如果不起中断,则连接很稳定。我在中断中只是每10ms发送一个信号量给其他任务。
建立mqtt连接的代码如下:[C] 纯文本查看 复制代码 void mqtt_application_thread() { xil_printf("Enter into mqtt_application_thread...rn"); mqtt_client_t *client = mqtt_client_new(); if (client != NULL) { mqtt_example_do_connect(client, client_id_suffix); } xBinarySemaphore = xSemaphoreCreateBinary(); if (NULL != xBinarySemaphore) { //Init Gpio Interrupt xTaskCreate(Task_Gpio_Init, "Gpio_Init", 1024, NULL, DEFAULT_THREAD_PRIO, NULL); } for (;;) { xSemaphoreTake(xBinarySemaphore, portMAX_DELAY); xil_printf("In infinite mqtt_application_thread loop...rn"); u8_t state = mqtt_client_is_connected(client); xil_printf("Current mqtt connection state is %d...rn", state); //if mqtt disconnected, try to reconnect if (example_publish(client, mqtt_pub_request_cb) != 1) { free(client); client = NULL; client = mqtt_client_new(); client_id_suffix++; if (client != NULL) { mqtt_example_do_connect(client, client_id_suffix); } } }}初始化中断的代码如下: [C] 纯文本查看 复制代码 int InterruptInitialize(u16 DeviceId, XGpio * GpioInstancePtr) { XScuGic_Config * IntcConfigPtr; int status; // Interrupt controller initialization IntcConfigPtr = XScuGic_LookupConfig(DeviceId); if ((XScuGic_Config *) NULL == IntcConfigPtr) return XST_FAILURE; status = XScuGic_CfgInitialize(&InterruptInst, IntcConfigPtr, IntcConfigPtr->CpuBaseAddress); if (status != XST_SUCCESS) return XST_FAILURE; // Call interrupt setup function status = InterruptSystemSetup(&InterruptInst); if (status != XST_SUCCESS) return XST_FAILURE; // Register GPIO interrupt handler status = XScuGic_Connect(&InterruptInst, INTC_GPIO_INT_ID, (Xil_ExceptionHandler) InterruptHandler, (void*) GpioInstancePtr); if (status != XST_SUCCESS) return XST_FAILURE; // Enable GPIO interrupts XGpio_InterruptEnable(GpioInstancePtr, GPIO_INT_MASK); XGpio_InterruptGlobalEnable(GpioInstancePtr); // Enable GPIO interrupts in the controller XScuGic_Enable(&InterruptInst, INTC_GPIO_INT_ID); return XST_SUCCESS;} 中断处理函数如下: [C] 纯文本查看 复制代码 void InterruptHandler(void * InstancePtr) { BaseType_t xHigherPriorityTaskWoken; xHigherPriorityTaskWoken = pdFALSE; // Acknowledge GPIO interrupts (void) XGpio_InterruptClear(&GpioInst, GPIO_INT_MASK); // Enable GPIO interrupts XGpio_InterruptEnable(&GpioInst, GPIO_INT_MASK); xSemaphoreGiveFromISR( xBinarySemaphore, &xHigherPriorityTaskWoken ); portYIELD_FROM_ISR( xHigherPriorityTaskWoken );} 另一个奇怪的问题是,当我试图在mqtt的线程中重连时,通过mqtt_client_is_connected(client)读回来的连接状态永远是已连接,即使服务端都显示断开了也不会变。麻烦各位大神帮忙看看,谢谢。 |
|
相关推荐
2个回答
|
|
|
|
没有人可以帮忙吗?
|
|
|
|
只有小组成员才能发言,加入小组>>
702 浏览 0 评论
1111 浏览 1 评论
2476 浏览 5 评论
2811 浏览 9 评论
移植了freeRTOS到STMf103之后显示没有定义的原因?
2654 浏览 6 评论
使用eim外接fpga可是端口一点反应都没有有没有大哥指点一下啊
658浏览 9评论
659浏览 7评论
请教大神怎样去解决iMX6Q在linux3.0.35内核上做AP失败的问题呢
788浏览 6评论
633浏览 5评论
677浏览 5评论
小黑屋| 手机版| Archiver| 电子发烧友 ( 湘ICP备2023018690号 )
GMT+8, 2024-11-25 02:12 , Processed in 0.896172 second(s), Total 51, Slave 41 queries .
Powered by 电子发烧友网
© 2015 bbs.elecfans.com
关注我们的微信
下载发烧友APP
电子发烧友观察
版权所有 © 湖南华秋数字科技有限公司
电子发烧友 (电路图) 湘公网安备 43011202000918 号 电信与信息服务业务经营许可证:合字B2-20210191 工商网监 湘ICP备2023018690号