my-mqtt无法重连问题

发布于 2023-08-05 16:35:52 浏览：560 订阅该版

my_mqtt 发生 can't recv Ping Response就无法再次重连

```c
  while (1)
  {
    int res;
    rt_tick_t tick_now;
    rt_tick_t time_diff;
    fd_set readset;
    struct timeval timeout;
    
    tick_now = rt_tick_get();
    time_diff = ((tick_now - c->tick_ping) / RT_TICK_PER_SECOND);
    if(time_diff >= c->keepalive_interval) {
      mqtt_client_lock(c);
      len = MQTTSerialize_pingreq(c->buf, c->buf_size);
      rc = send_packet(c, c->buf, len);
      mqtt_client_unlock(c);
      if (rc != 0)
      {
        LOG_E("[%d] send ping rc: %d ", rt_tick_get(), rc);
        goto __mqtt_disconnect;
      }
      timeout.tv_sec = 10;
      c->tick_ping = rt_tick_get();
      c->keepalive_counter++;
      if(c->keepalive_counter >= c->keepalive_count) {
        LOG_E("[%d] can't recv Ping Response");
        goto __mqtt_disconnect;
      }
    } else {
      timeout.tv_sec = c->keepalive_interval - time_diff;
      if(timeout.tv_sec == 0) {
        timeout.tv_sec = 1;
      }
    }
    timeout.tv_usec = 0;
    
    FD_ZERO(&readset);
    FD_SET(c->sock, &readset);
    /* int select(maxfdp1, readset, writeset, exceptset, timeout); */
    res = select(c->sock+ 1, &readset, RT_NULL, RT_NULL, &timeout);
    if (res < 0) {
      LOG_E("select res: %d", res);
      goto __mqtt_disconnect;
    }
    
    // 如果有接收到数据，则处理接收数据
    if (FD_ISSET(c->sock, &readset)) {
      rc_t = mqtt_cycle(c);
      if (rc_t < 0)    goto __mqtt_disconnect;
      
    }
    if(c->is_quit) {
      goto __mqtt_disconnect_exit;
    }
  } /* while (1) */
```