black-internet-days-ahead/sing-box
1
0
Fork 0
mirror of https://github.com/SagerNet/sing-box.git synced 2024-11-24 17:41:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

platform: Remove duplicated close

Browse source
This commit is contained in:
hiddify 2024-02-06 09:21:41 +01:00 committed by 世界
parent 3c24411e14
commit f8c400cffc
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
5 changed files with 0 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
experimental/libbox/command_clash_mode.go
View file

@ -30,7 +30,6 @@ func (c *CommandClient) SetClashMode(newMode string) error {
} }
func (s *CommandServer) handleSetClashMode(conn net.Conn) error { func (s *CommandServer) handleSetClashMode(conn net.Conn) error {
defer conn.Close()
newMode, err := rw.ReadVString(conn) newMode, err := rw.ReadVString(conn)
if err != nil { if err != nil {
return err return err
@ -61,7 +60,6 @@ func (c *CommandClient) handleModeConn(conn net.Conn) {
} }
func (s *CommandServer) handleModeConn(conn net.Conn) error { func (s *CommandServer) handleModeConn(conn net.Conn) error {
defer conn.Close()
ctx := connKeepAlive(conn) ctx := connKeepAlive(conn)
for s.service == nil { for s.service == nil {
select { select {
@ -73,7 +71,6 @@ func (s *CommandServer) handleModeConn(conn net.Conn) error {
} }
clashServer := s.service.instance.Router().ClashServer() clashServer := s.service.instance.Router().ClashServer()
if clashServer == nil { if clashServer == nil {
defer conn.Close()
return binary.Write(conn, binary.BigEndian, uint16(0)) return binary.Write(conn, binary.BigEndian, uint16(0))
} }
err := writeClashModeList(conn, clashServer) err := writeClashModeList(conn, clashServer)

2
experimental/libbox/command_group.go
View file

@ -58,7 +58,6 @@ func (c *CommandClient) handleGroupConn(conn net.Conn) {
} }
func (s *CommandServer) handleGroupConn(conn net.Conn) error { func (s *CommandServer) handleGroupConn(conn net.Conn) error {
defer conn.Close()
ctx := connKeepAlive(conn) ctx := connKeepAlive(conn)
for { for {
service := s.service service := s.service
@ -274,7 +273,6 @@ func (c *CommandClient) SetGroupExpand(groupTag string, isExpand bool) error {
} }
func (s *CommandServer) handleSetGroupExpand(conn net.Conn) error { func (s *CommandServer) handleSetGroupExpand(conn net.Conn) error {
defer conn.Close()
groupTag, err := rw.ReadVString(conn) groupTag, err := rw.ReadVString(conn)
if err != nil { if err != nil {
return err return err

1
experimental/libbox/command_select.go
View file

@ -31,7 +31,6 @@ func (c *CommandClient) SelectOutbound(groupTag string, outboundTag string) erro
} }
func (s *CommandServer) handleSelectOutbound(conn net.Conn) error { func (s *CommandServer) handleSelectOutbound(conn net.Conn) error {
defer conn.Close()
groupTag, err := rw.ReadVString(conn) groupTag, err := rw.ReadVString(conn)
if err != nil { if err != nil {
return err return err

2
experimental/libbox/command_system_proxy.go
View file

@ -35,7 +35,6 @@ func (c *CommandClient) GetSystemProxyStatus() (*SystemProxyStatus, error) {
} }
func (s *CommandServer) handleGetSystemProxyStatus(conn net.Conn) error { func (s *CommandServer) handleGetSystemProxyStatus(conn net.Conn) error {
defer conn.Close()
status := s.handler.GetSystemProxyStatus() status := s.handler.GetSystemProxyStatus()
err := binary.Write(conn, binary.BigEndian, status.Available) err := binary.Write(conn, binary.BigEndian, status.Available)
if err != nil { if err != nil {
@ -68,7 +67,6 @@ func (c *CommandClient) SetSystemProxyEnabled(isEnabled bool) error {
} }
func (s *CommandServer) handleSetSystemProxyEnabled(conn net.Conn) error { func (s *CommandServer) handleSetSystemProxyEnabled(conn net.Conn) error {
defer conn.Close()
var isEnabled bool var isEnabled bool
err := binary.Read(conn, binary.BigEndian, &isEnabled) err := binary.Read(conn, binary.BigEndian, &isEnabled)
if err != nil { if err != nil {

1
experimental/libbox/command_urltest.go
View file

@ -33,7 +33,6 @@ func (c *CommandClient) URLTest(groupTag string) error {
} }
func (s *CommandServer) handleURLTest(conn net.Conn) error { func (s *CommandServer) handleURLTest(conn net.Conn) error {
defer conn.Close()
groupTag, err := rw.ReadVString(conn) groupTag, err := rw.ReadVString(conn)
if err != nil { if err != nil {
return err return err