Home
last modified time | relevance | path

Searched refs:numStreams (Results 1 – 25 of 378) sorted by relevance

12345678910>>...16

/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/integrationtests/self/
H A Dcancelation_test.go22 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 Dstream_test.go20 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 Dcancelation_test.go21 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go21 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go20 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go20 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go20 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go21 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dcancelation_test.go21 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 Dstream_test.go18 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 Duni_stream_test.go18 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 Dstream_id.go9 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 Dstream_id.go9 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)

12345678910>>...16