SmartFrogFromChina

> if (FD_ISSET(c->pub_pipe[0], &readset)) > { > MQTTMessage *message; > MQTTString topic = MQTTString_initializer; > > ``` > LOG_D("pub_sock FD_ISSET"); > > len = read(c->pub_pipe[0], c->readbuf, c->readbuf_size); > ....... >...