admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 09:38:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Let param table init once (#11510)

Browse Source 
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
This commit is contained in:
Cai Yudong 2021-11-10 10:07:37 +08:00 committed by GitHub
parent e5f599b616
commit 124bd6c20a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cmd/roles/roles.go
View File

@ -93,7 +93,7 @@ func (mr *MilvusRoles) runRootCoord(ctx context.Context, localMsg bool) *compone
wg.Add(1) wg.Add(1)
go func() { go func() {
rootcoord.Params.Init() rootcoord.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
rootcoord.Params.SetLogConfig(f) rootcoord.Params.SetLogConfig(f)
@ -122,7 +122,7 @@ func (mr *MilvusRoles) runProxy(ctx context.Context, localMsg bool, alias string
wg.Add(1) wg.Add(1)
go func() { go func() {
proxy.Params.InitAlias(alias) proxy.Params.InitAlias(alias)
proxy.Params.Init() proxy.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
proxy.Params.SetLogConfig(f) proxy.Params.SetLogConfig(f)
@ -150,7 +150,7 @@ func (mr *MilvusRoles) runQueryCoord(ctx context.Context, localMsg bool) *compon
wg.Add(1) wg.Add(1)
go func() { go func() {
querycoord.Params.Init() querycoord.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
querycoord.Params.SetLogConfig(f) querycoord.Params.SetLogConfig(f)
@ -179,7 +179,7 @@ func (mr *MilvusRoles) runQueryNode(ctx context.Context, localMsg bool, alias st
wg.Add(1) wg.Add(1)
go func() { go func() {
querynode.Params.InitAlias(alias) querynode.Params.InitAlias(alias)
querynode.Params.Init() querynode.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
querynode.Params.SetLogConfig(f) querynode.Params.SetLogConfig(f)
@ -207,7 +207,7 @@ func (mr *MilvusRoles) runDataCoord(ctx context.Context, localMsg bool) *compone
wg.Add(1) wg.Add(1)
go func() { go func() {
datacoord.Params.Init() datacoord.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
datacoord.Params.SetLogConfig(f) datacoord.Params.SetLogConfig(f)
@ -236,7 +236,7 @@ func (mr *MilvusRoles) runDataNode(ctx context.Context, localMsg bool, alias str
wg.Add(1) wg.Add(1)
go func() { go func() {
datanode.Params.InitAlias(alias) datanode.Params.InitAlias(alias)
datanode.Params.Init() datanode.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
datanode.Params.SetLogConfig(f) datanode.Params.SetLogConfig(f)
factory := newMsgFactory(localMsg) factory := newMsgFactory(localMsg)
@ -263,7 +263,7 @@ func (mr *MilvusRoles) runIndexCoord(ctx context.Context, localMsg bool) *compon
wg.Add(1) wg.Add(1)
go func() { go func() {
indexcoord.Params.Init() indexcoord.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
indexcoord.Params.SetLogConfig(f) indexcoord.Params.SetLogConfig(f)
@ -291,7 +291,7 @@ func (mr *MilvusRoles) runIndexNode(ctx context.Context, localMsg bool, alias st
wg.Add(1) wg.Add(1)
go func() { go func() {
indexnode.Params.InitAlias(alias) indexnode.Params.InitAlias(alias)
indexnode.Params.Init() indexnode.Params.InitOnce()
f := setLoggerFunc(localMsg) f := setLoggerFunc(localMsg)
indexnode.Params.SetLogConfig(f) indexnode.Params.SetLogConfig(f)