mirror of https://github.com/milvus-io/milvus.git
parent
afeaade2d3
commit
2b7cdfc8e4
|
@ -56,7 +56,6 @@ type Server struct {
|
||||||
|
|
||||||
// Run initializes and starts IndexNode's grpc service.
|
// Run initializes and starts IndexNode's grpc service.
|
||||||
func (s *Server) Run() error {
|
func (s *Server) Run() error {
|
||||||
|
|
||||||
if err := s.init(); err != nil {
|
if err := s.init(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -69,7 +68,6 @@ func (s *Server) Run() error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Server) startGrpcLoop(grpcPort int) {
|
func (s *Server) startGrpcLoop(grpcPort int) {
|
||||||
|
|
||||||
defer s.loopWg.Done()
|
defer s.loopWg.Done()
|
||||||
|
|
||||||
log.Debug("IndexNode", zap.String("network address", Params.Address), zap.Int("network port: ", grpcPort))
|
log.Debug("IndexNode", zap.String("network address", Params.Address), zap.Int("network port: ", grpcPort))
|
||||||
|
@ -94,7 +92,6 @@ func (s *Server) startGrpcLoop(grpcPort int) {
|
||||||
if err := s.grpcServer.Serve(lis); err != nil {
|
if err := s.grpcServer.Serve(lis); err != nil {
|
||||||
s.grpcErrChan <- err
|
s.grpcErrChan <- err
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// init initializes IndexNode's grpc service.
|
// init initializes IndexNode's grpc service.
|
||||||
|
|
Loading…
Reference in New Issue