Skip to content

Commit

Permalink
fix: config
Browse files Browse the repository at this point in the history
  • Loading branch information
icey-yu committed Dec 25, 2024
1 parent b783da2 commit 54c6397
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 5 deletions.
1 change: 0 additions & 1 deletion internal/msggateway/ws_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,6 @@ func (ws *WsServer) Run(done chan error) error {
return errs.WrapMsg(sErr, "shutdown err")
}
close(shutdownDone)
fmt.Println("SSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSSS")
return nil
}
etcd.RegisterShutDown(shutDown)
Expand Down
3 changes: 0 additions & 3 deletions pkg/common/discovery/etcd/config_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ package etcd

import (
"context"
"fmt"
"os"
"os/exec"
"runtime"
Expand Down Expand Up @@ -95,12 +94,10 @@ func restartServer(ctx context.Context) error {
}
log.ZInfo(ctx, "shutdown server")
for _, f := range ShutDowns {
log.ZInfo(ctx, "shutdown ffff")
if err = f(); err != nil {
log.ZError(ctx, "shutdown fail", err)
}
}
fmt.Println("HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH")

log.ZInfo(ctx, "restart server")
err = cmd.Start()
Expand Down
2 changes: 1 addition & 1 deletion pkg/common/startrpc/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -188,7 +188,7 @@ func Start[T any](ctx context.Context, discovery *conf.Discovery, prometheusConf

go func() {
err := srv.Serve(listener)
if err != nil {
if err != nil && !errors.Is(err, http.ErrServerClosed) {
netErr = errs.WrapMsg(err, "rpc start err: ", rpcTcpAddr)
netDone <- struct{}{}
}
Expand Down

0 comments on commit 54c6397

Please sign in to comment.