294 {
295 std::lock_guard<std::mutex> lock(publish_mutex);
296 if (writing.empty()) {
298 boost::asio::async_write(
299 socket, boost::asio::buffer(writing.data(), writing.size()),
300 boost::bind(&Client::handle_write, shared_from_this(),
301 boost::asio::placeholders::error));
302 } else if (pending.size() < MAX_PENDING_SIZE) {
304 } else {
305
306 AERROR <<
"Pending size too large. Discard message.";
307 }
308}
void fill_data(std::vector< uint8_t > *data, const std::string &channel, const std::string &msg)