oceanbase

1
/**
2
 * Copyright (c) 2021 OceanBase
3
 * OceanBase CE is licensed under Mulan PubL v2.
4
 * You can use this software according to the terms and conditions of the Mulan PubL v2.
5
 * You may obtain a copy of Mulan PubL v2 at:
6
 *          http://license.coscl.org.cn/MulanPubL-2.0
7
 * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
8
 * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
9
 * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
10
 * See the Mulan PubL v2 for more details.
11
 */
12

13
#define USING_LOG_PREFIX SERVER
14

15
#include "ob_dbms_job_rpc_proxy.h"
16

17
#include "share/inner_table/ob_inner_table_schema_constants.h"
18
#include "observer/ob_server.h"
19

20
#include "ob_dbms_job_rpc_processor.h"
21

22
using namespace oceanbase::common;
23
using namespace oceanbase::share;
24
using namespace oceanbase::observer;
25

26
namespace oceanbase
27
{
28
namespace obrpc
29
{
30

31
OB_SERIALIZE_MEMBER(ObDBMSJobArg, tenant_id_, job_id_, server_addr_, master_addr_);
32
OB_SERIALIZE_MEMBER(ObDBMSJobResult, tenant_id_, job_id_, server_addr_, status_code_);
33

34
int ObDBMSJobRpcProxy::run_dbms_job(
35
  uint64_t tenant_id, uint64_t job_id, ObAddr server_addr, ObAddr master_addr)
36
{
37
  int ret = OB_SUCCESS;
38
  ObDBMSJobArg arg(tenant_id, job_id, server_addr, master_addr);
39
  ObRpcAPDBMSJobCB cb;
40
  CK (arg.is_valid());
41
  OZ (this->to(arg.server_addr_).by(arg.tenant_id_).run_dbms_job(arg, &cb), arg);
42
  return ret;
43
}
44

45
}/* ns obrpc*/
46
}/* ns oceanbase */
47