Home
last modified time | relevance | path

Searched refs:lostPackets (Results 1 – 25 of 68) sorted by relevance

123

/dports/net/h323plus/h323plus-1_27_2/src/
H A Dt38proto.cxx350 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 DQuicLossFunctionsTest.cpp399 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 Dsent_packet_handler.go310 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 Dsent_packet_handler_test.go21 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 Dsent_packet_handler.go310 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 Dsent_packet_handler_test.go21 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 Dsent_packet_handler.go310 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 DAckHandlersTest.cpp35 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 DReplayProtector.h34 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 Dreceived_packet_history_test.go316 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 Dsent_packet_handler_test.go21 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 Dreceived_packet_history_test.go316 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 Dsent_packet_handler_test.go23 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 Dreceived_packet_history_test.go316 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 Dsent_packet_handler_test.go23 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 Dreceived_packet_history_test.go316 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 Dsent_packet_handler_test.go23 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 Dreceived_packet_history_test.go316 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 DNewRenoTest.cpp23 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 Dsent_packet_handler.go379 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 Dsent_packet_handler.go334 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 Dsent_packet_handler.go334 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 Dsent_packet_handler.go379 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 Dsent_packet_handler.go344 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 DObserver.h128 return lostPackets.size() > 0; in hasPackets()
135 lostPackets.emplace_back(lostByTimeout, lostByReorder, packet); in addLostPacket()
138 std::vector<LostPacket> lostPackets; member

123