Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
oceanbase
obproxy
提交
02b73017
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看板
未验证
提交
02b73017
编写于
10月 12, 2022
作者:
LINGuanRen
提交者:
GitHub
10月 12, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #30 from xiaoleizi2016/issue_29
fix issue 29
上级
4cc2f2e1
00079e48
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
6 addition
and
6 deletion
+6
-6
src/obproxy/ob_proxy.cpp
src/obproxy/ob_proxy.cpp
+3
-3
src/obproxy/proxy/mysql/ob_mysql_sm.cpp
src/obproxy/proxy/mysql/ob_mysql_sm.cpp
+1
-1
src/obproxy/proxy/route/ob_tenant_server.cpp
src/obproxy/proxy/route/ob_tenant_server.cpp
+1
-1
src/obproxy/utils/ob_layout.cpp
src/obproxy/utils/ob_layout.cpp
+1
-1
未找到文件。
src/obproxy/ob_proxy.cpp
浏览文件 @
02b73017
...
...
@@ -262,7 +262,7 @@ int ObProxy::start()
}
else
if
(
OB_FAIL
(
ObMysqlProxyServerMain
::
start_mysql_proxy_server
(
*
mysql_config_params_
)))
{
LOG_ERROR
(
"fail to start mysql proxy server"
,
K
(
ret
));
}
else
if
(
OB_FAIL
(
ObProxyMain
::
get_instance
()
->
schedule_detect_task
()))
{
LOG_ERROR
(
"fail to schedule detec
h
task"
,
K
(
ret
));
LOG_ERROR
(
"fail to schedule detec
t
task"
,
K
(
ret
));
}
else
{
// we can't strongly dependent on the OCP.
...
...
@@ -326,7 +326,7 @@ int ObProxy::start()
}
else
if
(
OB_FAIL
(
ObCacheCleaner
::
schedule_cache_cleaner
()))
{
LOG_WARN
(
"fail to alloc and schedule cache cleaner"
,
K
(
ret
));
}
else
if
(
config_
->
is_metadb_used
()
&&
OB_FAIL
(
proxy_table_processor_
.
start_check_table_task
()))
{
LOG_WARN
(
"fail to start check table
chec
k"
,
K
(
ret
));
LOG_WARN
(
"fail to start check table
tas
k"
,
K
(
ret
));
}
else
if
(
OB_FAIL
(
hot_upgrade_processor_
.
start_hot_upgrade_task
()))
{
LOG_WARN
(
"fail to start hot upgrade task"
,
K
(
ret
));
}
else
if
(
OB_FAIL
(
log_file_processor_
->
start_cleanup_log_file
()))
{
...
...
@@ -338,7 +338,7 @@ int ObProxy::start()
}
else
if
(
OB_FAIL
(
tenant_stat_mgr_
->
start_tenant_stat_dump_task
()))
{
LOG_ERROR
(
"fail to start_tenant_stat_dump_task"
,
K
(
ret
));
}
else
if
(
OB_FAIL
(
g_ob_qos_stat_processor
.
start_qos_stat_clean_task
()))
{
LOG_ERROR
(
"fail to start_
tenant_stat_dump
_task"
,
K
(
ret
));
LOG_ERROR
(
"fail to start_
qos_stat_clean
_task"
,
K
(
ret
));
}
else
if
(
config_
->
enable_sharding
&&
config_
->
is_control_plane_used
()
&&
!
config_
->
use_local_dbconfig
...
...
src/obproxy/proxy/mysql/ob_mysql_sm.cpp
浏览文件 @
02b73017
...
...
@@ -2069,7 +2069,7 @@ int ObMysqlSM::analyze_login_request(ObRequestAnalyzeCtx &ctx, ObMysqlAnalyzeSta
ObUnixNetVConnection
*
unix_vc
=
static_cast
<
ObUnixNetVConnection
*>
(
client_session_
->
get_netvc
());
if
(
NULL
==
unix_vc
)
{
ret
=
OB_ERR_UNEXPECTED
;
LOG_WARN
(
"client
entry
vc is null"
,
K
(
ret
));
LOG_WARN
(
"client
unix
vc is null"
,
K
(
ret
));
}
else
if
(
hsr
.
response_
.
is_ssl_request
()
&&
!
unix_vc
->
ssl_connected
())
{
if
(
OB_FAIL
(
unix_vc
->
ssl_init
(
ObUnixNetVConnection
::
SSL_SERVER
,
client_session_
->
get_vip_cluster_name
(),
...
...
src/obproxy/proxy/route/ob_tenant_server.cpp
浏览文件 @
02b73017
...
...
@@ -43,7 +43,7 @@ int ObTenantServer::init(const ObIArray<ObProxyReplicaLocation> &locations)
LOG_WARN
(
"invalid replica location"
,
K
(
locations
),
K
(
ret
));
}
else
if
(
OB_UNLIKELY
(
NULL
!=
server_array_
))
{
ret
=
OB_ERR_UNEXPECTED
;
LOG_WARN
(
"server_
list
_ should be null here"
,
K
(
server_array_
),
K
(
ret
));
LOG_WARN
(
"server_
array
_ should be null here"
,
K
(
server_array_
),
K
(
ret
));
}
else
{
const
int64_t
alloc_size
=
static_cast
<
int64_t
>
(
sizeof
(
ObProxyReplicaLocation
))
*
locations
.
count
();
char
*
server_list_buf
=
NULL
;
...
...
src/obproxy/utils/ob_layout.cpp
浏览文件 @
02b73017
...
...
@@ -49,7 +49,7 @@ int ObLayout::init(const char *start_cmd)
MPRINT
(
"layout has already been inited, ret=%d"
,
ret
);
}
else
if
(
OB_ISNULL
(
start_cmd
))
{
ret
=
OB_ERR_UNEXPECTED
;
MPRINT
(
"start c
o
md is NULL, ret=%d"
,
ret
);
MPRINT
(
"start cmd is NULL, ret=%d"
,
ret
);
}
else
if
(
OB_ISNULL
(
cwd
=
arena
.
alloc
(
MAX_PATH_LENGTH
)))
{
ret
=
OB_ALLOCATE_MEMORY_FAILED
;
MPRINT
(
"fail to alloc memeory,alloc_size=%ld, ret=%d"
,
MAX_PATH_LENGTH
,
ret
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录