|
|
@@ -12,14 +12,13 @@ import (
|
|
|
"sync"
|
|
|
"time"
|
|
|
|
|
|
- "github.com/v2fly/v2ray-core/v4/common/drain"
|
|
|
-
|
|
|
"golang.org/x/crypto/chacha20poly1305"
|
|
|
|
|
|
"github.com/v2fly/v2ray-core/v4/common"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/bitmask"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/buf"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/crypto"
|
|
|
+ "github.com/v2fly/v2ray-core/v4/common/drain"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/net"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/protocol"
|
|
|
"github.com/v2fly/v2ray-core/v4/common/task"
|
|
|
@@ -141,7 +140,6 @@ func (s *ServerSession) DecodeRequestHeader(reader io.Reader) (*protocol.Request
|
|
|
buffer := buf.New()
|
|
|
|
|
|
drainer, err := drain.NewBehaviorSeedLimitedDrainer(int64(s.userValidator.GetBehaviorSeed()), 16+38, 3266, 64)
|
|
|
-
|
|
|
if err != nil {
|
|
|
return nil, newError("failed to initialize drainer").Base(err)
|
|
|
}
|