/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/ |
H A D | server.go | 82 sessionQueueLen int32 // to be used as an atomic member 285 atomic.AddInt32(&s.sessionQueueLen, -1) 408 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 491 atomic.AddInt32(&s.sessionQueueLen, 1) 496 atomic.AddInt32(&s.sessionQueueLen, -1)
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/ |
H A D | server.go | 82 sessionQueueLen int32 // to be used as an atomic member 285 atomic.AddInt32(&s.sessionQueueLen, -1) 408 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 491 atomic.AddInt32(&s.sessionQueueLen, 1) 496 atomic.AddInt32(&s.sessionQueueLen, -1)
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 268 atomic.AddInt32(&s.sessionQueueLen, -1) 436 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 539 atomic.AddInt32(&s.sessionQueueLen, 1) 544 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1107 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 272 atomic.AddInt32(&s.sessionQueueLen, -1) 439 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 521 atomic.AddInt32(&s.sessionQueueLen, 1) 526 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1089 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 272 atomic.AddInt32(&s.sessionQueueLen, -1) 439 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 521 atomic.AddInt32(&s.sessionQueueLen, 1) 526 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1089 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 272 atomic.AddInt32(&s.sessionQueueLen, -1) 439 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 521 atomic.AddInt32(&s.sessionQueueLen, 1) 526 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1089 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 100 sessionQueueLen int32 // to be used as an atomic member 271 atomic.AddInt32(&s.sessionQueueLen, -1) 436 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 512 atomic.AddInt32(&s.sessionQueueLen, 1) 517 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1059 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 268 atomic.AddInt32(&s.sessionQueueLen, -1) 436 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 539 atomic.AddInt32(&s.sessionQueueLen, 1) 544 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1107 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 272 atomic.AddInt32(&s.sessionQueueLen, -1) 439 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 521 atomic.AddInt32(&s.sessionQueueLen, 1) 526 atomic.AddInt32(&s.sessionQueueLen, -1)
|
H A D | server_test.go | 1089 …Eventually(func() int32 { return atomic.LoadInt32(&serv.sessionQueueLen) }).Should(BeEquivalentTo(…
|
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 268 atomic.AddInt32(&s.sessionQueueLen, -1) 436 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 539 atomic.AddInt32(&s.sessionQueueLen, 1) 544 atomic.AddInt32(&s.sessionQueueLen, -1)
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 101 sessionQueueLen int32 // to be used as an atomic member 272 atomic.AddInt32(&s.sessionQueueLen, -1) 439 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize { 521 atomic.AddInt32(&s.sessionQueueLen, 1) 526 atomic.AddInt32(&s.sessionQueueLen, -1)
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/ |
H A D | server.go | 99 sessionQueueLen int32 // to be used as an atomic member 178 atomic.AddInt32(&s.sessionQueueLen, 1) 179 defer atomic.AddInt32(&s.sessionQueueLen, -1) 406 if queueLen := atomic.LoadInt32(&s.sessionQueueLen); queueLen >= protocol.MaxAcceptQueueSize {
|