添加注释

zhangmeng

2022-12-13 ba9e213d3f01555d823aaf453798a148dade45a4

 cbhomeclient.cpp

@@ -324,12 +324,17 @@
    return bus_send_reply(cli->bus, src, pbstr.data(), pbstr.size());

}







////////////////////////////////////////////////////

int bus_client_publish(void* handle, const char* topic, const size_t topicl, const char* data, const size_t size){

    MsgPublish pbmsg;

    pbmsg.set_topic(topic, topicl);

    pbmsg.set_data(data, size);

    auto pbstr = pbmsg.SerializeAsString();

    return bus_client_pubmsg(handle, pbstr.data(), pbstr.size());

}



// test

int bus_client_pubmsg(void* handle, void* data, const size_t size){

int bus_client_pubmsg(void* handle, const char* data, const size_t size){

    client* cli = ptr(handle);

    bus_publish(cli->bus, data, size, 100);

    return 0;

    return bus_publish(cli->bus, data, size, 100);

}