Method writePacket

src/base/Connection.cpp:45–73

}

void Connection::writePacket(const Packet& packet) {
  while (true) {
    {
      lock_guard<std::recursive_mutex> guard(connectionMutex);
      if (shuttingDown) {
        break;
      }
    }
    bool success = write(packet);
    if (success) {
      return;
    }
    bool hasConnection;
    {
      lock_guard<std::recursive_mutex> guard(connectionMutex);
      hasConnection = (socketFd != -1);
    }

    // Yield the processor
    if (hasConnection) {
      // Have a connection, sleep for 1ms
      std::this_thread::sleep_for(std::chrono::microseconds(1000));
    } else {
      // No connection, sleep for 100ms
      std::this_thread::sleep_for(std::chrono::microseconds(100 * 1000));
    }
    LOG_EVERY_N(1000, INFO) << "Waiting to write...";
  }
}

void Connection::closeSocket() {
  lock_guard<std::recursive_mutex> guard(connectionMutex);