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

fix misspelled word in issue#277 (#696)

Browse Source
This commit is contained in:
jiangmengmeng
2021-12-13 14:45:50 +08:00
committed by GitHub
parent 0822911e8c
commit 53650bb527
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/election/ob_election_rpc.cpp
View File

@ -159,9 +159,9 @@ int ObElectionRpc::post_election_msg(
ELECT_ASYNC_LOG(WARN, "serialize msg_type error", K(ret), "msg_type", msg.get_msg_type()); ELECT_ASYNC_LOG(WARN, "serialize msg_type error", K(ret), "msg_type", msg.get_msg_type());
} else if (OB_SUCCESS != } else if (OB_SUCCESS !=
(ret = partition.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) { (ret = partition.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) {
ELECT_ASYNC_LOG(WARN, "seralize partition error", K(ret), K(partition)); ELECT_ASYNC_LOG(WARN, "serialize partition error", K(ret), K(partition));
} else if (OB_SUCCESS != (ret = msg.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) { } else if (OB_SUCCESS != (ret = msg.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) {
ELECT_ASYNC_LOG(WARN, "seralize msg error", K(ret), K(msg)); ELECT_ASYNC_LOG(WARN, "serialize msg error", K(ret), K(msg));
} else { } else {
if (OB_SUCCESS != (ret = rpc_proxy_->to(server) if (OB_SUCCESS != (ret = rpc_proxy_->to(server)
@ -195,7 +195,7 @@ int ObElectionRpc::post_election_group_msg(const ObAddr& server, const int64_t c
msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position(), msg.get_msg_type()))) { msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position(), msg.get_msg_type()))) {
ELECT_ASYNC_LOG(WARN, "serialize msg_type error", K(ret), "msg_type", msg.get_msg_type()); ELECT_ASYNC_LOG(WARN, "serialize msg_type error", K(ret), "msg_type", msg.get_msg_type());
} else if (OB_FAIL(eg_id.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) { } else if (OB_FAIL(eg_id.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) {
ELECT_ASYNC_LOG(WARN, "seralize eg_id error", K(ret), K(eg_id)); ELECT_ASYNC_LOG(WARN, "serialize eg_id error", K(ret), K(eg_id));
} else if (OB_FAIL(serialization::encode_i64( } else if (OB_FAIL(serialization::encode_i64(
msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position(), part_array_buf.get_eg_version()))) { msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position(), part_array_buf.get_eg_version()))) {
ELECT_ASYNC_LOG(WARN, "serialize eg_version error", K(ret)); ELECT_ASYNC_LOG(WARN, "serialize eg_version error", K(ret));
@ -214,7 +214,7 @@ int ObElectionRpc::post_election_group_msg(const ObAddr& server, const int64_t c
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_FAIL(msg.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) { if (OB_FAIL(msg.serialize(msgbuf.get_data(), msgbuf.get_capacity(), msgbuf.get_position()))) {
ELECT_ASYNC_LOG(WARN, "seralize msg error", K(ret), K(msg)); ELECT_ASYNC_LOG(WARN, "serialize msg error", K(ret), K(msg));
} else { } else {
if (OB_FAIL(rpc_proxy_->to(server) if (OB_FAIL(rpc_proxy_->to(server)
.dst_cluster_id(cluster_id) .dst_cluster_id(cluster_id)