Home
last modified time | relevance | path

Searched refs:canceledWrite (Results 1 – 16 of 16) sorted by relevance

/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go40 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
84 if s.canceledWrite {
117 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
160 if s.canceledWrite || s.closeForShutdownErr != nil {
232 if s.canceledWrite {
256 if s.canceledWrite || s.finishedWriting {
259 s.canceledWrite = true
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
349 if s.canceledWrite {
366 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
378 if s.canceledWrite {
398 if s.canceledWrite {
417 if s.canceledWrite {
422 s.canceledWrite = true
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
90 if s.canceledWrite {
123 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
204 if s.canceledWrite || s.closeForShutdownErr != nil {
296 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
320 if s.canceledWrite {
340 if s.canceledWrite {
345 s.canceledWrite = true
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
90 if s.canceledWrite {
123 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
204 if s.canceledWrite || s.closeForShutdownErr != nil {
296 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
320 if s.canceledWrite {
340 if s.canceledWrite {
345 s.canceledWrite = true
/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/
H A Dsend_stream.go40 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
84 if s.canceledWrite {
117 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
240 if s.canceledWrite {
265 if s.canceledWrite {
271 s.canceledWrite = true
/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/
H A Dsend_stream.go40 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
84 if s.canceledWrite {
117 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
240 if s.canceledWrite {
265 if s.canceledWrite {
271 s.canceledWrite = true
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
362 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
390 if s.canceledWrite {
409 if s.canceledWrite {
414 s.canceledWrite = true
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
362 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
390 if s.canceledWrite {
409 if s.canceledWrite {
414 s.canceledWrite = true
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/
H A Dsend_stream.go45 canceledWrite bool // set when CancelWrite() is called, or a STOP_SENDING frame is received member
93 if s.canceledWrite {
152 if s.dataForWriting == nil || s.canceledWrite || s.closedForShutdown {
214 if s.canceledWrite || s.closeForShutdownErr != nil {
362 …completed := (s.finSent || s.canceledWrite) && s.numOutstandingFrames == 0 && len(s.retransmission…
390 if s.canceledWrite {
409 if s.canceledWrite {
414 s.canceledWrite = true
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/h2quic/
H A Dresponse_writer_test.go26 canceledWrite bool member
48 func (s *mockStream) CancelWrite(quic.ErrorCode) { s.canceledWrite = true }
H A Dclient_test.go251 Expect(dataStream.canceledWrite).To(BeTrue())
272 Expect(dataStream.canceledWrite).To(BeTrue())
293 Expect(dataStream.canceledWrite).To(BeTrue())