Jelajahi Sumber

refactor: use conf.Log for maxprocs.Set (#2026)

* refactor: use conf.Log for maxprocs.Set

Signed-off-by: xjasonlyu <xjasonlyu@gmail.com>

* avoid panic when error occurs

Signed-off-by: xjasonlyu <xjasonlyu@gmail.com>

---------

Signed-off-by: xjasonlyu <xjasonlyu@gmail.com>
Jason Lyu 1 tahun lalu
induk
melakukan
fbbf34e888
2 mengubah file dengan 5 tambahan dan 2 penghapusan
  1. 0 2
      cmd/kuiperd/main.go
  2. 5 0
      internal/server/server.go

+ 0 - 2
cmd/kuiperd/main.go

@@ -15,8 +15,6 @@
 package main
 package main
 
 
 import (
 import (
-	_ "go.uber.org/automaxprocs"
-
 	"github.com/lf-edge/ekuiper/internal/server"
 	"github.com/lf-edge/ekuiper/internal/server"
 )
 )
 
 

+ 5 - 0
internal/server/server.go

@@ -26,6 +26,8 @@ import (
 	"syscall"
 	"syscall"
 	"time"
 	"time"
 
 
+	"go.uber.org/automaxprocs/maxprocs"
+
 	"github.com/lf-edge/ekuiper/internal/binder/function"
 	"github.com/lf-edge/ekuiper/internal/binder/function"
 	"github.com/lf-edge/ekuiper/internal/binder/io"
 	"github.com/lf-edge/ekuiper/internal/binder/io"
 	"github.com/lf-edge/ekuiper/internal/binder/meta"
 	"github.com/lf-edge/ekuiper/internal/binder/meta"
@@ -87,6 +89,9 @@ func StartUp(Version, LoadFileType string) {
 	conf.InitConf()
 	conf.InitConf()
 	factory.InitClientsFactory()
 	factory.InitClientsFactory()
 
 
+	undo, _ := maxprocs.Set(maxprocs.Logger(conf.Log.Infof))
+	defer undo()
+
 	err := store.SetupWithKuiperConfig(conf.Config)
 	err := store.SetupWithKuiperConfig(conf.Config)
 	if err != nil {
 	if err != nil {
 		panic(err)
 		panic(err)