|
|
@ -399,9 +399,13 @@ func (d *DefaultDispatcher) routedDispatch(ctx context.Context, link *transport.
|
|
|
|
|
|
|
|
|
|
|
|
var handler outbound.Handler
|
|
|
|
var handler outbound.Handler
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
routingLink := routing_session.AsRoutingContext(ctx)
|
|
|
|
|
|
|
|
inTag := routingLink.GetInboundTag()
|
|
|
|
|
|
|
|
isPickRoute := 0
|
|
|
|
if forcedOutboundTag := session.GetForcedOutboundTagFromContext(ctx); forcedOutboundTag != "" {
|
|
|
|
if forcedOutboundTag := session.GetForcedOutboundTagFromContext(ctx); forcedOutboundTag != "" {
|
|
|
|
ctx = session.SetForcedOutboundTagToContext(ctx, "")
|
|
|
|
ctx = session.SetForcedOutboundTagToContext(ctx, "")
|
|
|
|
if h := d.ohm.GetHandler(forcedOutboundTag); h != nil {
|
|
|
|
if h := d.ohm.GetHandler(forcedOutboundTag); h != nil {
|
|
|
|
|
|
|
|
isPickRoute = 1
|
|
|
|
newError("taking platform initialized detour [", forcedOutboundTag, "] for [", destination, "]").WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
newError("taking platform initialized detour [", forcedOutboundTag, "] for [", destination, "]").WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
handler = h
|
|
|
|
handler = h
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -411,13 +415,14 @@ func (d *DefaultDispatcher) routedDispatch(ctx context.Context, link *transport.
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else if d.router != nil {
|
|
|
|
} else if d.router != nil {
|
|
|
|
if route, err := d.router.PickRoute(routing_session.AsRoutingContext(ctx)); err == nil {
|
|
|
|
if route, err := d.router.PickRoute(routingLink); err == nil {
|
|
|
|
tag := route.GetOutboundTag()
|
|
|
|
outTag := route.GetOutboundTag()
|
|
|
|
if h := d.ohm.GetHandler(tag); h != nil {
|
|
|
|
if h := d.ohm.GetHandler(outTag); h != nil {
|
|
|
|
newError("taking detour [", tag, "] for [", destination, "]").WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
isPickRoute = 2
|
|
|
|
|
|
|
|
newError("taking detour [", outTag, "] for [", destination, "]").WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
handler = h
|
|
|
|
handler = h
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
newError("non existing outTag: ", tag).AtWarning().WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
newError("non existing outTag: ", outTag).AtWarning().WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
newError("default route for ", destination).WriteToLog(session.ExportIDToError(ctx))
|
|
|
|
newError("default route for ", destination).WriteToLog(session.ExportIDToError(ctx))
|
|
|
@ -437,7 +442,15 @@ func (d *DefaultDispatcher) routedDispatch(ctx context.Context, link *transport.
|
|
|
|
|
|
|
|
|
|
|
|
if accessMessage := log.AccessMessageFromContext(ctx); accessMessage != nil {
|
|
|
|
if accessMessage := log.AccessMessageFromContext(ctx); accessMessage != nil {
|
|
|
|
if tag := handler.Tag(); tag != "" {
|
|
|
|
if tag := handler.Tag(); tag != "" {
|
|
|
|
accessMessage.Detour = tag
|
|
|
|
if inTag == "" {
|
|
|
|
|
|
|
|
accessMessage.Detour = tag
|
|
|
|
|
|
|
|
} else if isPickRoute == 1 {
|
|
|
|
|
|
|
|
accessMessage.Detour = inTag + " ==> " + tag
|
|
|
|
|
|
|
|
} else if isPickRoute == 2 {
|
|
|
|
|
|
|
|
accessMessage.Detour = inTag + " -> " + tag
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
accessMessage.Detour = inTag + " >> " + tag
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.Record(accessMessage)
|
|
|
|
log.Record(accessMessage)
|
|
|
|
}
|
|
|
|
}
|
|
|
|