Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
oceanbase
obproxy
提交
31023a93
O
obproxy
项目概览
oceanbase
/
obproxy
1 年多 前同步成功
通知
11
Star
100
Fork
70
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
O
obproxy
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
提交
31023a93
编写于
10月 19, 2022
作者:
X
xiaoleizi2016
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix annotation error 1019
上级
00079e48
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
5 addition
and
5 deletion
+5
-5
src/obproxy/dbconfig/ob_proxy_db_config_processor.cpp
src/obproxy/dbconfig/ob_proxy_db_config_processor.cpp
+1
-1
src/obproxy/ob_proxy_main.cpp
src/obproxy/ob_proxy_main.cpp
+1
-1
src/obproxy/obutils/ob_config_server_processor.cpp
src/obproxy/obutils/ob_config_server_processor.cpp
+1
-1
src/obproxy/obutils/ob_log_file_processor.cpp
src/obproxy/obutils/ob_log_file_processor.cpp
+2
-2
未找到文件。
src/obproxy/dbconfig/ob_proxy_db_config_processor.cpp
浏览文件 @
31023a93
...
...
@@ -76,7 +76,7 @@ int ObDbConfigProcessor::init(const int64_t client_count, int64_t startup_time_u
if
(
OB_SUCC
(
ret
))
{
if
(
get_global_proxy_config
().
use_local_dbconfig
&&
OB_FAIL
(
get_global_inotify_processor
().
init
()))
{
LOG_WARN
(
"fail to init in
i
tify processor"
,
K
(
ret
));
LOG_WARN
(
"fail to init in
o
tify processor"
,
K
(
ret
));
}
}
return
ret
;
...
...
src/obproxy/ob_proxy_main.cpp
浏览文件 @
31023a93
...
...
@@ -311,7 +311,7 @@ int ObProxyMain::parse_cmd_line(const int argc, char *const argv[], ObProxyOptio
if
(
0
==
c
)
{
if
(
OB_FAIL
(
parse_short_opt
(
long_opts
[
long_opts_idx
].
val
,
optarg
,
opts
)))
{
MPRINT
(
"fail to parse
long
opt, ret=%d"
,
ret
);
MPRINT
(
"fail to parse
short
opt, ret=%d"
,
ret
);
break
;
}
}
else
{
...
...
src/obproxy/obutils/ob_config_server_processor.cpp
浏览文件 @
31023a93
...
...
@@ -1868,7 +1868,7 @@ int ObConfigServerProcessor::parse_json_config_info(const ObString &json, const
bool
is_metadb_changed
=
false
;
if
(
OB_ISNULL
(
json_info
=
op_alloc
(
ObProxyJsonConfigInfo
)))
{
ret
=
OB_ALLOCATE_MEMORY_FAILED
;
LOG_ERROR
(
"fail to alloc mem fo
t
json config info"
,
K
(
ret
));
LOG_ERROR
(
"fail to alloc mem fo
r
json config info"
,
K
(
ret
));
}
else
if
(
OB_FAIL
(
json_info
->
parse
(
root
)))
{
LOG_WARN
(
"fail to parse json info"
,
K
(
ret
));
}
else
if
(
!
json_info
->
is_valid
())
{
...
...
src/obproxy/obutils/ob_log_file_processor.cpp
浏览文件 @
31023a93
...
...
@@ -90,7 +90,7 @@ int ObLogFileProcessor::start_cleanup_log_file()
LOG_WARN
(
"log file processor is not inited"
,
K
(
ret
));
}
else
if
(
OB_UNLIKELY
(
NULL
!=
cleanup_cont_
))
{
ret
=
OB_ERR_UNEXPECTED
;
LOG_WARN
(
"log file cleanup task has already been sch
u
duled"
,
K_
(
cleanup_cont
),
K
(
ret
));
LOG_WARN
(
"log file cleanup task has already been sch
e
duled"
,
K_
(
cleanup_cont
),
K
(
ret
));
}
else
{
int64_t
interval_us
=
get_global_proxy_config
().
log_cleanup_interval
;
if
(
OB_ISNULL
(
cleanup_cont_
=
ObAsyncCommonTask
::
create_and_start_repeat_task
(
interval_us
,
...
...
@@ -98,7 +98,7 @@ int ObLogFileProcessor::start_cleanup_log_file()
ObLogFileProcessor
::
do_repeat_task
,
ObLogFileProcessor
::
update_interval
)))
{
ret
=
OB_ERR_UNEXPECTED
;
LOG_WARN
(
"fail to create and start cleanup task"
,
K
(
interval_us
),
K
(
ret
));
LOG_WARN
(
"fail to create and start
log
cleanup task"
,
K
(
interval_us
),
K
(
ret
));
}
else
{
LOG_INFO
(
"succ to create and start log cleanup task"
,
K
(
interval_us
));
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录