| 332 | } |
| 333 | |
| 334 | Status Server::AddSlave(redis::Connection *conn, rocksdb::SequenceNumber next_repl_seq) { |
| 335 | auto t = std::make_unique<FeedSlaveThread>(this, conn, next_repl_seq); |
| 336 | auto s = t->Start(); |
| 337 | if (!s.IsOK()) { |
| 338 | return s; |
| 339 | } |
| 340 | |
| 341 | std::unique_lock<std::shared_mutex> lg(slave_threads_mu_); |
| 342 | slave_threads_.emplace_back(std::move(t)); |
| 343 | return Status::OK(); |
| 344 | } |
| 345 | |
| 346 | void Server::DisconnectSlaves() { |
| 347 | std::unique_lock<std::shared_mutex> lg(slave_threads_mu_); |