hyung-hwan/hodu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minotr message fix

Browse Source
This commit is contained in:
hyung-hwan
2025-08-12 16:40:18 +09:00
parent 41cd725c1c
commit 31a4223aab
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/main.go
View File

@ -536,7 +536,7 @@ func main() {
os.Exit(0) os.Exit(0)
wrong_usage: wrong_usage:
fmt.Fprintf(os.Stderr, "USAGE: %s server --rpc-on=addr:port --ctl-on=addr:port --pxy-on=addr:port --wpx-on=addr:port [--config-file=file] [--config-file-pattern=pattern]\n", os.Args[0]) fmt.Fprintf(os.Stderr, "USAGE: %s server --rpc-on=addr:port --ctl-on=addr:port --rpx-on=addr:port --pxy-on=addr:port --wpx-on=addr:port [--config-file=file] [--config-file-pattern=pattern]\n", os.Args[0])
fmt.Fprintf(os.Stderr, " %s client --rpc-to=addr:port --ctl-on=addr:port [--config-file=file] [--config-file-pattern=pattern] [peer-addr:peer-port ...]\n", os.Args[0]) fmt.Fprintf(os.Stderr, " %s client --rpc-to=addr:port --ctl-on=addr:port [--config-file=file] [--config-file-pattern=pattern] [peer-addr:peer-port ...]\n", os.Args[0])
fmt.Fprintf(os.Stderr, " %s version\n", os.Args[0]) fmt.Fprintf(os.Stderr, " %s version\n", os.Args[0])
os.Exit(1) os.Exit(1)

6
server.go
View File

@ -1932,7 +1932,7 @@ func (s *Server) RunRpxTask(wg *sync.WaitGroup) {
go func(i int, cs *http.Server) { go func(i int, cs *http.Server) {
var l net.Listener var l net.Listener
s.log.Write("", LOG_INFO, "rpx channel[%d] started on %s", i, s.Cfg.RpxAddrs[i]) s.log.Write("", LOG_INFO, "RPX channel[%d] started on %s", i, s.Cfg.RpxAddrs[i])
if s.stop_req.Load() == false { if s.stop_req.Load() == false {
l, err = net.Listen(TcpAddrStrClass(cs.Addr), cs.Addr) l, err = net.Listen(TcpAddrStrClass(cs.Addr), cs.Addr)
@ -1962,9 +1962,9 @@ func (s *Server) RunRpxTask(wg *sync.WaitGroup) {
err = fmt.Errorf("stop requested") err = fmt.Errorf("stop requested")
} }
if errors.Is(err, http.ErrServerClosed) { if errors.Is(err, http.ErrServerClosed) {
s.log.Write("", LOG_INFO, "rpx channel[%d] ended", i) s.log.Write("", LOG_INFO, "RPX channel[%d] ended", i)
} else { } else {
s.log.Write("", LOG_ERROR, "rpx channel[%d] error - %s", i, err.Error()) s.log.Write("", LOG_ERROR, "RPX channel[%d] error - %s", i, err.Error())
} }
l_wg.Done() l_wg.Done()
}(idx, rpx) }(idx, rpx)