mirror of
https://github.com/SagerNet/sing-shadowsocks.git
synced 2025-04-04 12:27:39 +03:00
Cleanup unneeded deadline
This commit is contained in:
parent
e3930e4fe3
commit
54dd1546c6
1 changed files with 2 additions and 3 deletions
|
@ -10,7 +10,6 @@ import (
|
||||||
"github.com/sagernet/sing-shadowsocks"
|
"github.com/sagernet/sing-shadowsocks"
|
||||||
"github.com/sagernet/sing/common/auth"
|
"github.com/sagernet/sing/common/auth"
|
||||||
"github.com/sagernet/sing/common/buf"
|
"github.com/sagernet/sing/common/buf"
|
||||||
"github.com/sagernet/sing/common/bufio/deadline"
|
|
||||||
E "github.com/sagernet/sing/common/exceptions"
|
E "github.com/sagernet/sing/common/exceptions"
|
||||||
M "github.com/sagernet/sing/common/metadata"
|
M "github.com/sagernet/sing/common/metadata"
|
||||||
N "github.com/sagernet/sing/common/network"
|
N "github.com/sagernet/sing/common/network"
|
||||||
|
@ -126,11 +125,11 @@ func (s *MultiService[U]) newConnection(ctx context.Context, conn net.Conn, meta
|
||||||
metadata.Protocol = "shadowsocks"
|
metadata.Protocol = "shadowsocks"
|
||||||
metadata.Destination = destination
|
metadata.Destination = destination
|
||||||
|
|
||||||
return s.handler.NewConnection(auth.ContextWithUser(ctx, user), deadline.NewConn(&serverConn{
|
return s.handler.NewConnection(auth.ContextWithUser(ctx, user), &serverConn{
|
||||||
Method: method,
|
Method: method,
|
||||||
Conn: conn,
|
Conn: conn,
|
||||||
reader: reader,
|
reader: reader,
|
||||||
}), metadata)
|
}, metadata)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *MultiService[U]) WriteIsThreadUnsafe() {
|
func (s *MultiService[U]) WriteIsThreadUnsafe() {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue