Northern_Lights/nekoray_Mahdi-zarei
1
0
Fork 0
mirror of https://github.com/Mahdi-zarei/nekoray.git synced 2025-12-26 03:11:21 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix start core signal

Browse Source
This commit is contained in:
Nova 2025-08-05 14:18:24 +03:30
parent 17d5499035
commit 902a15e85c
2 changed files with 22 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
core/server/main.go
View File

@ -7,6 +7,7 @@ import (
"flag"
"fmt"
"log"
"net"
"os"
"runtime"
runtimeDebug "runtime/debug"
@ -45,7 +46,17 @@ func RunCore() {
boxmain.DisableColor()
// RPC
fmt.Printf("Core listening at %v\n", "127.0.0.1:"+strconv.Itoa(*_port))
go func() {
for {
time.Sleep(100 * time.Millisecond)
conn, err := net.Dial("tcp", "127.0.0.1:"+strconv.Itoa(*_port))
if err == nil {
conn.Close()
fmt.Printf("Core listening at %v\n", "127.0.0.1:"+strconv.Itoa(*_port))
return
}
}
}()
err := gen.ListenAndServeLibcoreService("tcp", "127.0.0.1:"+strconv.Itoa(*_port), new(server))
if err != nil {
log.Fatalf("failed to listen: %v", err)

20
core/server/server.go
View File

@ -49,7 +49,7 @@ func (s *server) Start(in *gen.LoadConfigReq, out *gen.ErrorResp) (_ error) {
}()
if debug {
log.Println("Start:", in.CoreConfig)
log.Println("Start:", *in.CoreConfig)
}
if boxInstance != nil {
@ -420,15 +420,15 @@ func (s *server) QuerySpeedTest(in *gen.EmptyReq, out *gen.QuerySpeedTestRespons
errStr = res.Error.Error()
}
out.Result = &gen.SpeedTestResult{
DlSpeed: To(res.DlSpeed),
UlSpeed: To(res.UlSpeed),
Latency: To(res.Latency),
OutboundTag: To(res.Tag),
Error: To(errStr),
ServerName: To(res.ServerName),
ServerCountry: To(res.ServerCountry),
Cancelled: To(res.Cancelled),
}
DlSpeed: To(res.DlSpeed),
UlSpeed: To(res.UlSpeed),
Latency: To(res.Latency),
OutboundTag: To(res.Tag),
Error: To(errStr),
ServerName: To(res.ServerName),
ServerCountry: To(res.ServerCountry),
Cancelled: To(res.Cancelled),
}
out.IsRunning = To(isRunning)
return nil
}