anygatecloud/strom
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

working srv status

Browse Source
This commit is contained in:
adman
2026-03-20 22:19:07 +01:00
parent 254b75e76b
commit a6102b7ec9
3 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/handshake_packet.go
+6 -2
View File
@@ -9,10 +9,14 @@ import (
"github.com/admin-else/strom/proto_generated/v1_21_8"
)
func MakeHandshakePacket(s *proto.Conn, nextState proto_base.State) (p *v1_21_8.HandshakingToServerPacketSetProtocol, err error) {
func MakeHandshakePacket(c *proto.Conn, nextState proto_base.State) (p *v1_21_8.HandshakingToServerPacketSetProtocol, err error) {
return MakeHandshakePacketAddr(c, nextState, c.RemoteAddr().String())
}
func MakeHandshakePacketAddr(s *proto.Conn, nextState proto_base.State, addr string) (p *v1_21_8.HandshakingToServerPacketSetProtocol, err error) {
p = &v1_21_8.HandshakingToServerPacketSetProtocol{NextState: int32(nextState), ProtocolVersion: s.ProtocolVersion}
var portStr string
p.ServerHost, portStr, err = net.SplitHostPort(s.RemoteAddr().String())
p.ServerHost, portStr, err = net.SplitHostPort(addr)
if err != nil {
return
}
client/status.go
+1 -1
View File
@@ -59,7 +59,7 @@ func StatusRaw(addr string) (s *StatusClient, err error) {
s.RegisterUntilLatest(s.OnStatus)
s.RegisterUntilLatest(s.OnPong)
p, err := MakeHandshakePacket(s.Conn, proto_base.Status)
p, err := MakeHandshakePacketAddr(s.Conn, proto_base.Status, addr)
if err != nil {
return
}