fixed missing error codes
This commit is contained in:
@ -744,6 +744,7 @@ void ObLogDeliver::handle(void *task)
|
|||||||
ret = OB_NOT_INIT;
|
ret = OB_NOT_INIT;
|
||||||
SERVER_LOG(WARN, "ObLogDeliver not init", K(ret));
|
SERVER_LOG(WARN, "ObLogDeliver not init", K(ret));
|
||||||
} else if (OB_ISNULL(task)) {
|
} else if (OB_ISNULL(task)) {
|
||||||
|
ret = OB_ERR_UNEXPECTED;
|
||||||
SERVER_LOG(WARN, "invalid argument", KP(task));
|
SERVER_LOG(WARN, "invalid argument", KP(task));
|
||||||
} else {
|
} else {
|
||||||
rpc::ObRequest *req = static_cast<rpc::ObRequest *>(task);
|
rpc::ObRequest *req = static_cast<rpc::ObRequest *>(task);
|
||||||
|
@ -76,6 +76,7 @@ public:
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (OB_ISNULL(log_service)) {
|
if (OB_ISNULL(log_service)) {
|
||||||
|
ret = OB_ERR_UNEXPECTED;
|
||||||
CLOG_LOG(ERROR, "get_log_service failed");
|
CLOG_LOG(ERROR, "get_log_service failed");
|
||||||
} else if (FALSE_IT(rpc_proxy = log_service->get_rpc_proxy())) {
|
} else if (FALSE_IT(rpc_proxy = log_service->get_rpc_proxy())) {
|
||||||
} else if (FALSE_IT(self = log_service->get_self())) {
|
} else if (FALSE_IT(self = log_service->get_self())) {
|
||||||
|
Reference in New Issue
Block a user