|
|
@@ -15,7 +15,6 @@ import (
|
|
|
"v2ray.com/core/common/net"
|
|
|
"v2ray.com/core/common/protocol"
|
|
|
"v2ray.com/core/common/session"
|
|
|
- "v2ray.com/core/common/vio"
|
|
|
"v2ray.com/core/features/outbound"
|
|
|
"v2ray.com/core/features/policy"
|
|
|
"v2ray.com/core/features/routing"
|
|
|
@@ -151,7 +150,7 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
|
|
|
if p.Stats.UserUplink {
|
|
|
name := "user>>>" + user.Email + ">>>traffic>>>uplink"
|
|
|
if c, _ := stats.GetOrRegisterCounter(d.stats, name); c != nil {
|
|
|
- inboundLink.Writer = &vio.SizeStatWriter{
|
|
|
+ inboundLink.Writer = &SizeStatWriter{
|
|
|
Counter: c,
|
|
|
Writer: inboundLink.Writer,
|
|
|
}
|
|
|
@@ -160,7 +159,7 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
|
|
|
if p.Stats.UserDownlink {
|
|
|
name := "user>>>" + user.Email + ">>>traffic>>>downlink"
|
|
|
if c, _ := stats.GetOrRegisterCounter(d.stats, name); c != nil {
|
|
|
- outboundLink.Writer = &vio.SizeStatWriter{
|
|
|
+ outboundLink.Writer = &SizeStatWriter{
|
|
|
Counter: c,
|
|
|
Writer: outboundLink.Writer,
|
|
|
}
|