hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[bugfix] add ob_admin function to deal with sys log stream only_in_member_list

Browse Source
This commit is contained in:
obdev 2022-11-30 02:38:09 +00:00 committed by ob-robot
parent f320ab99da
commit 69d9941a08
1 changed files with 69 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
tools/ob_admin/server_tool/ob_admin_routine.cpp
View File

@ -518,3 +518,72 @@ DEF_COMMAND(TRANS, kill_part_trans_ctx, 1,
{
return OB_NOT_SUPPORTED;
}
// ls_remove_member
// @params [in] tenant_id, which tenant to modify
// @params [in] ls_id, which log stream to modify
// @params [in] svr_ip, the server ip want to delete
// @params [in] svr_port, the server port want to delete
// @params [in] orig_paxos_number, paxos replica number before this deletion
// @params [in] new_paxos_number, paxos replica number after this deletion
// ATTENTION:
// Please make sure let log stream's leader to execute this command
// For permanant offline, orig_paxos_number should equals to new_paxos_number
DEF_COMMAND(TRANS, ls_remove_member, 1, "tenant_id ls_id svr_ip svr_port orig_paxos_number new_paxos_number # ls_remove_member")
{
int ret = OB_SUCCESS;
string arg_str;
ObLSDropPaxosReplicaArg arg;
int64_t tenant_id_to_set = OB_INVALID_TENANT_ID;
int64_t ls_id_to_set = 0;
int64_t orig_paxos_replica_number = 0;
int64_t new_paxos_replica_number = 0;
int32_t port = 0;
char ip[30];
if (cmd_ == action_name_) {
ret = OB_INVALID_ARGUMENT;
ADMIN_WARN("should provide tenant_id, ls_id ,member to remove, previous and new paxos replica number");
} else {
arg_str = cmd_.substr(action_name_.length() + 1);
}
if (OB_FAIL(ret)) {
} else if (6 != sscanf(arg_str.c_str(), "%ld %ld %s %d %ld %ld", &tenant_id_to_set, &ls_id_to_set,
ip, &port, &orig_paxos_replica_number, &new_paxos_replica_number)) {
ret = OB_INVALID_ARGUMENT;
COMMON_LOG(WARN, "invalid arg", K(ret), K(arg_str.c_str()), K(cmd_.c_str()),
K(tenant_id_to_set), K(ls_id_to_set),
K(port), K(orig_paxos_replica_number), K(new_paxos_replica_number));
} else {
common::ObAddr server_to_remove(common::ObAddr::VER::IPV4, ip, port);
common::ObReplicaMember remove_member(server_to_remove, 1);
share::ObTaskId task_id;
share::ObLSID ls_id(ls_id_to_set);
task_id.init(server_to_remove);
if (OB_ISNULL(client_)
|| OB_UNLIKELY(OB_INVALID_TENANT_ID == tenant_id_to_set
|| !ls_id.is_valid_with_tenant(tenant_id_to_set)
|| !server_to_remove.is_valid()
|| 1 < orig_paxos_replica_number - new_paxos_replica_number
|| 0 > orig_paxos_replica_number - new_paxos_replica_number)) {
ret = OB_INVALID_ARGUMENT;
COMMON_LOG(WARN, "invalid argument", K(ret), K(tenant_id_to_set), K(ls_id),
K(remove_member), K(task_id), K(orig_paxos_replica_number),
K(new_paxos_replica_number), K(port), K(ip), KP(client_));
} else if (OB_FAIL(arg.init(
task_id,
tenant_id_to_set,
ls_id,
remove_member,
orig_paxos_replica_number,
new_paxos_replica_number))) {
COMMON_LOG(WARN, "init arg failed", K(ret), K(task_id), K(tenant_id_to_set), K(ls_id),
K(remove_member), K(orig_paxos_replica_number), K(new_paxos_replica_number));
} else if (OB_FAIL(client_->ls_remove_paxos_replica(arg))) {
COMMON_LOG(ERROR, "send req fail", K(ret));
}
}
COMMON_LOG(INFO, "ls_remove_member", K(arg));
return ret;
}