MCPcopy
hub / github.com/cloudflare/cloudflared / NewSessionManager

Function NewSessionManager

quic/v3/manager.go:49–57  ·  view source on GitHub ↗
(metrics Metrics, log *zerolog.Logger, originDialer ingress.OriginUDPDialer, limiter cfdflow.Limiter)

Source from the content-addressed store, hash-verified

47}
48
49func NewSessionManager(metrics Metrics, log *zerolog.Logger, originDialer ingress.OriginUDPDialer, limiter cfdflow.Limiter) SessionManager {
50 return &sessionManager{
51 sessions: make(map[RequestID]Session),
52 originDialer: originDialer,
53 limiter: limiter,
54 metrics: metrics,
55 log: log,
56 }
57}
58
59func (s *sessionManager) RegisterSession(request *UDPSessionRegistrationDatagram, conn DatagramConn) (Session, error) {
60 s.mutex.Lock()

Calls

no outgoing calls