mirror of https://github.com/v2ray/v2ray-core
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
72 lines
1.9 KiB
72 lines
1.9 KiB
package session |
|
|
|
import "context" |
|
|
|
type sessionKey int |
|
|
|
const ( |
|
idSessionKey sessionKey = iota |
|
inboundSessionKey |
|
outboundSessionKey |
|
contentSessionKey |
|
muxPreferedSessionKey |
|
) |
|
|
|
// ContextWithID returns a new context with the given ID. |
|
func ContextWithID(ctx context.Context, id ID) context.Context { |
|
return context.WithValue(ctx, idSessionKey, id) |
|
} |
|
|
|
// IDFromContext returns ID in this context, or 0 if not contained. |
|
func IDFromContext(ctx context.Context) ID { |
|
if id, ok := ctx.Value(idSessionKey).(ID); ok { |
|
return id |
|
} |
|
return 0 |
|
} |
|
|
|
func ContextWithInbound(ctx context.Context, inbound *Inbound) context.Context { |
|
return context.WithValue(ctx, inboundSessionKey, inbound) |
|
} |
|
|
|
func InboundFromContext(ctx context.Context) *Inbound { |
|
if inbound, ok := ctx.Value(inboundSessionKey).(*Inbound); ok { |
|
return inbound |
|
} |
|
return nil |
|
} |
|
|
|
func ContextWithOutbound(ctx context.Context, outbound *Outbound) context.Context { |
|
return context.WithValue(ctx, outboundSessionKey, outbound) |
|
} |
|
|
|
func OutboundFromContext(ctx context.Context) *Outbound { |
|
if outbound, ok := ctx.Value(outboundSessionKey).(*Outbound); ok { |
|
return outbound |
|
} |
|
return nil |
|
} |
|
|
|
func ContextWithContent(ctx context.Context, content *Content) context.Context { |
|
return context.WithValue(ctx, contentSessionKey, content) |
|
} |
|
|
|
func ContentFromContext(ctx context.Context) *Content { |
|
if content, ok := ctx.Value(contentSessionKey).(*Content); ok { |
|
return content |
|
} |
|
return nil |
|
} |
|
|
|
// ContextWithMuxPrefered returns a new context with the given bool |
|
func ContextWithMuxPrefered(ctx context.Context, forced bool) context.Context { |
|
return context.WithValue(ctx, muxPreferedSessionKey, forced) |
|
} |
|
|
|
// MuxPreferedFromContext returns value in this context, or false if not contained. |
|
func MuxPreferedFromContext(ctx context.Context) bool { |
|
if val, ok := ctx.Value(muxPreferedSessionKey).(bool); ok { |
|
return val |
|
} |
|
return false |
|
}
|
|
|