/dports/net/h323plus/h323plus-1_27_2/src/ |
H A D | t38proto.cxx | 350 int lostPackets = (receivedSequenceNumber - expectedSequenceNumber)&0xffff; in Answer() local 351 if (lostPackets > 32767) { in Answer() 359 if (lostPackets > 0) { in Answer() 364 if (lostPackets >= nRedundancy) { in Answer() 365 if (!HandlePacketLost(lostPackets - nRedundancy)) { in Answer() 369 lostPackets = nRedundancy; in Answer() 371 while (lostPackets > 0) { in Answer() 372 if (!HandleRawIFP(secondary[lostPackets++])) { in Answer() 379 if (!HandlePacketLost(lostPackets)) { in Answer()
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/loss/test/ |
H A D | QuicLossFunctionsTest.cpp | 399 uint32_t lostPackets; member 450 EXPECT_EQ(lossEvent->lostPackets, fixture.lostPackets); in runDetectPMTUBlackholeTest() 698 EXPECT_TRUE(lostPackets.empty()); in TEST_F() 1261 EXPECT_TRUE(lostPackets.empty()); in TEST_F() 1287 EXPECT_EQ(1, lostPackets.size()); in TEST_F() 1316 EXPECT_TRUE(lostPackets.empty()); in TEST_F() 1351 EXPECT_EQ(0, lostPackets.size()); in TEST_F() 1636 uint32_t lostPackets = 0; in TEST_F() local 1640 lostPackets++; in TEST_F() 1669 std::vector<bool> lostPackets; in TEST_F() local [all …]
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 310 lostPackets, err := h.detectLostPackets(rcvTime, encLevel) 314 for _, p := range lostPackets { 524 var lostPackets []*Packet 534 lostPackets = append(lostPackets, packet) 539 lostPackets = append(lostPackets, packet) 556 if h.logger.Debug() && len(lostPackets) > 0 { 557 pns := make([]protocol.PacketNumber, len(lostPackets)) 558 for i, p := range lostPackets { 564 for _, p := range lostPackets { 585 return lostPackets, nil [all …]
|
H A D | sent_packet_handler_test.go | 21 lostPackets []protocol.PacketNumber 28 lostPackets = nil 56 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 206 for _, lostP := range lostPackets { 601 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 676 var lostPackets []protocol.PacketNumber 681 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 695 var lostPackets []protocol.PacketNumber 701 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 906 Expect(lostPackets).To(Equal([]protocol.PacketNumber{1, 2, 3})) [all …]
|
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 310 lostPackets, err := h.detectLostPackets(rcvTime, encLevel) 314 for _, p := range lostPackets { 524 var lostPackets []*Packet 534 lostPackets = append(lostPackets, packet) 539 lostPackets = append(lostPackets, packet) 556 if h.logger.Debug() && len(lostPackets) > 0 { 557 pns := make([]protocol.PacketNumber, len(lostPackets)) 558 for i, p := range lostPackets { 564 for _, p := range lostPackets { 585 return lostPackets, nil [all …]
|
H A D | sent_packet_handler_test.go | 21 lostPackets []protocol.PacketNumber 28 lostPackets = nil 56 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 206 for _, lostP := range lostPackets { 601 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 676 var lostPackets []protocol.PacketNumber 681 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 695 var lostPackets []protocol.PacketNumber 701 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 906 Expect(lostPackets).To(Equal([]protocol.PacketNumber{1, 2, 3})) [all …]
|
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 310 lostPackets, err := h.detectLostPackets(rcvTime, encLevel) 314 for _, p := range lostPackets { 524 var lostPackets []*Packet 534 lostPackets = append(lostPackets, packet) 539 lostPackets = append(lostPackets, packet) 556 if h.logger.Debug() && len(lostPackets) > 0 { 557 pns := make([]protocol.PacketNumber, len(lostPackets)) 558 for i, p := range lostPackets { 564 for _, p := range lostPackets { 585 return lostPackets, nil [all …]
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/test/ |
H A D | AckHandlersTest.cpp | 35 lostPackets.push_back(packetNum); in testLossHandler() 113 std::vector<PacketNum> lostPackets; in TEST_P() local 136 testLossHandler(lostPackets), in TEST_P() 196 std::vector<PacketNum> lostPackets; in TEST_P() local 221 testLossHandler(lostPackets), in TEST_P() 240 for (auto& pkt : lostPackets) { in TEST_P() 366 testLossHandler(lostPackets), in TEST_P() 411 lostPackets.begin(), in TEST_P() 412 lostPackets.end())); in TEST_P() 494 testLossHandler(lostPackets), in TEST_P() [all …]
|
/dports/net/cjdns/cjdns-cjdns-v21.1/crypto/ |
H A D | ReplayProtector.h | 34 uint32_t lostPackets; member 93 context->lostPackets += RelayProtector_lostInShift(context->bitfield, offset - 47); in ReplayProtector_checkNonce()
|
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | received_packet_history_test.go | 316 lostPackets := make([]protocol.PacketNumber, 0, numLostPackets) 317 for len(lostPackets) < numLostPackets { 320 lostPackets = append(lostPackets, p) 324 sort.Slice(lostPackets, func(i, j int) bool { return lostPackets[i] < lostPackets[j] }) 325 fmt.Fprintf(GinkgoWriter, "Losing packets: %v\n", lostPackets)
|
H A D | sent_packet_handler_test.go | 21 lostPackets []protocol.PacketNumber 28 lostPackets = nil 56 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 213 for _, lostP := range lostPackets { 606 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 682 var lostPackets []protocol.PacketNumber 687 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 701 var lostPackets []protocol.PacketNumber 707 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 1128 Expect(lostPackets).To(BeEmpty()) [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | received_packet_history_test.go | 316 lostPackets := make([]protocol.PacketNumber, 0, numLostPackets) 317 for len(lostPackets) < numLostPackets { 320 lostPackets = append(lostPackets, p) 324 sort.Slice(lostPackets, func(i, j int) bool { return lostPackets[i] < lostPackets[j] }) 325 fmt.Fprintf(GinkgoWriter, "Losing packets: %v\n", lostPackets)
|
H A D | sent_packet_handler_test.go | 23 lostPackets []protocol.PacketNumber 30 lostPackets = nil 58 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 248 for _, lostP := range lostPackets { 669 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 746 var lostPackets []protocol.PacketNumber 751 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 765 var lostPackets []protocol.PacketNumber 771 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 1246 Expect(lostPackets).To(BeEmpty()) [all …]
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | received_packet_history_test.go | 316 lostPackets := make([]protocol.PacketNumber, 0, numLostPackets) 317 for len(lostPackets) < numLostPackets { 320 lostPackets = append(lostPackets, p) 324 sort.Slice(lostPackets, func(i, j int) bool { return lostPackets[i] < lostPackets[j] }) 325 fmt.Fprintf(GinkgoWriter, "Losing packets: %v\n", lostPackets)
|
H A D | sent_packet_handler_test.go | 23 lostPackets []protocol.PacketNumber 30 lostPackets = nil 58 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 248 for _, lostP := range lostPackets { 669 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 746 var lostPackets []protocol.PacketNumber 751 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 765 var lostPackets []protocol.PacketNumber 771 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 1246 Expect(lostPackets).To(BeEmpty()) [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | received_packet_history_test.go | 316 lostPackets := make([]protocol.PacketNumber, 0, numLostPackets) 317 for len(lostPackets) < numLostPackets { 320 lostPackets = append(lostPackets, p) 324 sort.Slice(lostPackets, func(i, j int) bool { return lostPackets[i] < lostPackets[j] }) 325 fmt.Fprintf(GinkgoWriter, "Losing packets: %v\n", lostPackets)
|
H A D | sent_packet_handler_test.go | 23 lostPackets []protocol.PacketNumber 30 lostPackets = nil 58 …{Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, p.PacketNu… 248 for _, lostP := range lostPackets { 669 Expect(lostPackets).To(Equal([]protocol.PacketNumber{10})) 746 var lostPackets []protocol.PacketNumber 751 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 765 var lostPackets []protocol.PacketNumber 771 {Frame: &wire.PingFrame{}, OnLost: func(wire.Frame) { lostPackets = append(lostPackets, 1) }}, 1246 Expect(lostPackets).To(BeEmpty()) [all …]
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | received_packet_history_test.go | 316 lostPackets := make([]protocol.PacketNumber, 0, numLostPackets) 317 for len(lostPackets) < numLostPackets { 320 lostPackets = append(lostPackets, p) 324 sort.Slice(lostPackets, func(i, j int) bool { return lostPackets[i] < lostPackets[j] }) 325 fmt.Fprintf(GinkgoWriter, "Losing packets: %v\n", lostPackets)
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/congestion_control/test/ |
H A D | NewRenoTest.cpp | 23 std::vector<std::pair<PacketNum, size_t>> lostPackets) { in createLossEvent() argument 26 for (auto packetData : lostPackets) { in createLossEvent() 43 loss.lostPackets = lostPackets.size(); in createLossEvent()
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 379 var lostPackets []*Packet 386 lostPackets = append(lostPackets, packet) 398 if h.logger.Debug() && len(lostPackets) > 0 { 399 pns := make([]protocol.PacketNumber, len(lostPackets)) 400 for i, p := range lostPackets { 406 for _, p := range lostPackets {
|
/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/ackhandler/ |
H A D | sent_packet_handler.go | 334 var lostPackets []*Packet 342 lostPackets = append(lostPackets, packet) 352 if h.logger.Debug() && len(lostPackets) > 0 { 353 pns := make([]protocol.PacketNumber, len(lostPackets)) 354 for i, p := range lostPackets { 360 for _, p := range lostPackets {
|
/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/ackhandler/ |
H A D | sent_packet_handler.go | 334 var lostPackets []*Packet 342 lostPackets = append(lostPackets, packet) 352 if h.logger.Debug() && len(lostPackets) > 0 { 353 pns := make([]protocol.PacketNumber, len(lostPackets)) 354 for i, p := range lostPackets { 360 for _, p := range lostPackets {
|
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 379 var lostPackets []*Packet 386 lostPackets = append(lostPackets, packet) 398 if h.logger.Debug() && len(lostPackets) > 0 { 399 pns := make([]protocol.PacketNumber, len(lostPackets)) 400 for i, p := range lostPackets { 406 for _, p := range lostPackets {
|
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/internal/ackhandler/ |
H A D | sent_packet_handler.go | 344 var lostPackets []*Packet 352 lostPackets = append(lostPackets, packet) 363 if h.logger.Debug() && len(lostPackets) > 0 { 364 pns := make([]protocol.PacketNumber, len(lostPackets)) 365 for i, p := range lostPackets { 371 for _, p := range lostPackets {
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/api/ |
H A D | Observer.h | 128 return lostPackets.size() > 0; in hasPackets() 135 lostPackets.emplace_back(lostByTimeout, lostByReorder, packet); in addLostPacket() 138 std::vector<LostPacket> lostPackets; member
|