27 lines
561 B
Go
27 lines
561 B
Go
package server
|
|
|
|
import (
|
|
"github.com/gokins/gokins/comm"
|
|
"github.com/gokins/gokins/engine"
|
|
hbtp "github.com/mgr9525/HyperByte-Transfer-Protocol"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
func runHbtp() {
|
|
defer func() {
|
|
if err := recover(); err != nil {
|
|
hbtp.Errorf("Hbtp recover:%v", err)
|
|
}
|
|
}()
|
|
if comm.Cfg.Server.HbtpHost == "" {
|
|
return
|
|
}
|
|
comm.HbtpEgn = hbtp.NewEngine(comm.Ctx)
|
|
comm.HbtpEgn.RegGrpcFun(10, engine.Mgr.HRun())
|
|
err := comm.HbtpEgn.Run(comm.Cfg.Server.HbtpHost)
|
|
if err != nil {
|
|
logrus.Errorf("Hbtp err:%v", err)
|
|
comm.Cancel()
|
|
}
|
|
}
|