/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 22 const numStreams = 80 37 wg.Add(numStreams) 75 wg.Add(numStreams) 104 Expect(numStreams - clientCanceledCounter).To(BeNumerically(">", numStreams/10)) 119 wg.Add(numStreams) 167 wg.Add(numStreams) 188 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 269 wg.Add(numStreams) 303 wg.Add(numStreams) 343 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 20 const numStreams = 300 49 wg.Add(numStreams) 50 for i := 0; i < numStreams; i++ { 73 wg.Add(numStreams) 74 for i := 0; i < numStreams; i++ { 92 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 111 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 130 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 21 const numStreams = 80 38 wg.Add(numStreams) 80 wg.Add(numStreams) 124 wg.Add(numStreams) 172 wg.Add(numStreams) 193 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 274 wg.Add(numStreams) 311 wg.Add(numStreams) 390 wg.Add(numStreams) 466 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 21 const numStreams = 80 38 wg.Add(numStreams) 83 wg.Add(numStreams) 127 wg.Add(numStreams) 175 wg.Add(numStreams) 199 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 280 wg.Add(numStreams) 320 wg.Add(numStreams) 405 wg.Add(numStreams) 484 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 20 const numStreams = 80 38 wg.Add(numStreams) 83 wg.Add(numStreams) 127 wg.Add(numStreams) 176 wg.Add(numStreams) 220 wg.Add(numStreams) 244 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 365 wg.Add(numStreams) 450 wg.Add(numStreams) 529 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 20 const numStreams = 80 38 wg.Add(numStreams) 83 wg.Add(numStreams) 127 wg.Add(numStreams) 176 wg.Add(numStreams) 220 wg.Add(numStreams) 244 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 365 wg.Add(numStreams) 450 wg.Add(numStreams) 529 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 20 const numStreams = 80 38 wg.Add(numStreams) 83 wg.Add(numStreams) 127 wg.Add(numStreams) 176 wg.Add(numStreams) 220 wg.Add(numStreams) 244 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 365 wg.Add(numStreams) 450 wg.Add(numStreams) 529 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 21 const numStreams = 80 38 wg.Add(numStreams) 80 wg.Add(numStreams) 124 wg.Add(numStreams) 172 wg.Add(numStreams) 193 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 274 wg.Add(numStreams) 311 wg.Add(numStreams) 390 wg.Add(numStreams) 466 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/ |
H A D | cancelation_test.go | 21 const numStreams = 80 38 wg.Add(numStreams) 80 wg.Add(numStreams) 124 wg.Add(numStreams) 172 wg.Add(numStreams) 193 Expect(numStreams - streamCount).To(BeNumerically(">", numStreams/10)) 274 wg.Add(numStreams) 311 wg.Add(numStreams) 390 wg.Add(numStreams) 466 wg.Add(numStreams) [all …]
|
H A D | stream_test.go | 18 const numStreams = 300 47 wg.Add(numStreams) 48 for i := 0; i < numStreams; i++ { 71 wg.Add(numStreams) 72 for i := 0; i < numStreams; i++ { 90 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 109 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 128 …It(fmt.Sprintf("client and server opening %d each and sending data to the peer", numStreams), func…
|
H A D | uni_stream_test.go | 18 const numStreams = 500 43 for i := 0; i < numStreams; i++ { 57 wg.Add(numStreams) 58 for i := 0; i < numStreams; i++ { 72 It(fmt.Sprintf("client opening %d streams to a server", numStreams), func() { 91 It(fmt.Sprintf("server opening %d streams to a client", numStreams), func() { 108 …ntf("client and server opening %d streams each and sending data to the peer", numStreams), func() {
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/internal/protocol/ |
H A D | stream_id.go | 9 func MaxBidiStreamID(numStreams int, pers Perspective) StreamID { 10 if numStreams == 0 { 19 return first + 4*StreamID(numStreams-1) 25 func MaxUniStreamID(numStreams int, pers Perspective) StreamID { 26 if numStreams == 0 { 35 return first + 4*StreamID(numStreams-1)
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/internal/protocol/ |
H A D | stream_id.go | 9 func MaxBidiStreamID(numStreams int, pers Perspective) StreamID { 10 if numStreams == 0 { 19 return first + 4*StreamID(numStreams-1) 25 func MaxUniStreamID(numStreams int, pers Perspective) StreamID { 26 if numStreams == 0 { 35 return first + 4*StreamID(numStreams-1)
|