|
|
@@ -154,15 +154,12 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
|
|
|
|
|
|
if user != nil && len(user.Email) > 0 {
|
|
|
p := d.policy.ForLevel(user.Level)
|
|
|
- accessMessage := log.AccessMessageFromContext(ctx)
|
|
|
-
|
|
|
if p.Stats.UserUplink {
|
|
|
name := "user>>>" + user.Email + ">>>traffic>>>uplink"
|
|
|
if c, _ := stats.GetOrRegisterCounter(d.stats, name); c != nil {
|
|
|
inboundLink.Writer = &SizeStatWriter{
|
|
|
Counter: c,
|
|
|
Writer: inboundLink.Writer,
|
|
|
- Record: &accessMessage.BytesSent,
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -172,7 +169,6 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
|
|
|
outboundLink.Writer = &SizeStatWriter{
|
|
|
Counter: c,
|
|
|
Writer: outboundLink.Writer,
|
|
|
- Record: &accessMessage.BytesReceived,
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -289,12 +285,12 @@ func (d *DefaultDispatcher) routedDispatch(ctx context.Context, link *transport.
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- handler.Dispatch(ctx, link)
|
|
|
-
|
|
|
if accessMessage := log.AccessMessageFromContext(ctx); accessMessage != nil {
|
|
|
if tag := handler.Tag(); tag != "" {
|
|
|
accessMessage.Detour = tag
|
|
|
}
|
|
|
log.Record(accessMessage)
|
|
|
}
|
|
|
+
|
|
|
+ handler.Dispatch(ctx, link)
|
|
|
}
|