Function RsyncWriteResp

src/rsync_server.cc:23–31

using namespace RsyncService;

void RsyncWriteResp(RsyncService::RsyncResponse& response, std::shared_ptr<net::PbConn> conn) {
  std::string reply_str;
  if (!response.SerializeToString(&reply_str) || (conn->WriteResp(reply_str) != 0)) {
    LOG(WARNING) << "Process FileRsync request serialization failed";
    conn->NotifyClose();
    return;
  }
  conn->NotifyWrite();
}

RsyncServer::RsyncServer(const std::set<std::string>& ips, const int port) {
  work_thread_ = std::make_unique<net::ThreadPool>(2, 100000, "RsyncServerWork");