remove code

This commit is contained in:
Chaoguang Lin 2021-06-17 00:35:44 +00:00
parent ecff680b47
commit 563bc681a0
1 changed files with 5 additions and 8 deletions

View File

@ -47,7 +47,6 @@
#include "fdbcli/FlowLineNoise.h"
#include "fdbcli/fdbcli.actor.h"
#include "flow/ThreadHelper.actor.h"
#include <cinttypes>
#include <type_traits>
@ -3605,8 +3604,8 @@ ACTOR Future<int> cli(CLIOptions opt, LineNoise* plinenoise) {
printf("Unlocking the database is a potentially dangerous operation.\n");
printf("%s\n", passPhrase.c_str());
fflush(stdout);
Optional<std::string> input = wait(linenoise.read(
format("Repeat the above passphrase if you would like to proceed:")));
Optional<std::string> input =
wait(linenoise.read(format("Repeat the above passphrase if you would like to proceed:")));
warn = checkStatus(timeWarning(5.0, "\nWARNING: Long delay (Ctrl-C to interrupt)\n"), db);
if (input.present() && input.get() == passPhrase) {
UID unlockUID = UID::fromString(tokens[1].toString());
@ -3768,11 +3767,9 @@ ACTOR Future<int> cli(CLIOptions opt, LineNoise* plinenoise) {
printf("\n");
} else if (tokencmp(tokens[1], "all")) {
for (auto it : address_interface) {
if (db->apiVersionAtLeast(700)) {
wait(success(safeThreadFutureToFuture(db2->rebootWorker(it.second.first, false, 0))));
// BinaryReader::fromStringRef<ClientWorkerInterface>(it.second.first, IncludeVersion())
// .reboot.send(RebootRequest());
}
if (db->apiVersionAtLeast(700))
BinaryReader::fromStringRef<ClientWorkerInterface>(it.second.first, IncludeVersion())
.reboot.send(RebootRequest());
else
tr->set(LiteralStringRef("\xff\xff/reboot_worker"), it.second.first);
}