| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/integrationtests/tools/proxy/ |
| H A D | proxy.go | 57 type DropCallback func(dir Direction, packetCount uint64) bool
65 type DelayCallback func(dir Direction, packetCount uint64) time.Duration
200 packetCount := atomic.AddUint64(&conn.incomingPacketCounter, 1)
202 if p.dropPacket(DirectionIncoming, packetCount) {
204 p.logger.Debugf("dropping incoming packet %d (%d bytes)", packetCount, n)
210 delay := p.delayPacket(DirectionIncoming, packetCount)
240 packetCount := atomic.AddUint64(&conn.outgoingPacketCounter, 1)
242 if p.dropPacket(DirectionOutgoing, packetCount) {
244 p.logger.Debugf("dropping outgoing packet %d (%d bytes)", packetCount, n)
249 delay := p.delayPacket(DirectionOutgoing, packetCount)
[all …]
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/ |
| H A D | AckHandlers.cpp | 55 const auto originalPacketCount = conn.outstandings.packetCount; in processAckFrame()
132 CHECK(conn.outstandings.packetCount[currentPacketNumberSpace]); in processAckFrame()
133 --conn.outstandings.packetCount[currentPacketNumberSpace]; in processAckFrame()
240 const auto& packetCount = conn.outstandings.packetCount; in processAckFrame() local
244 packetCount[PacketNumberSpace::Handshake] + in processAckFrame()
245 packetCount[PacketNumberSpace::Initial] + in processAckFrame()
246 packetCount[PacketNumberSpace::AppData]) in processAckFrame()
250 << packetCount[PacketNumberSpace::Initial] << "," in processAckFrame()
251 << packetCount[PacketNumberSpace::Handshake] << "," in processAckFrame()
252 << packetCount[PacketNumberSpace::AppData] << "}" in processAckFrame()
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/misc/concourse/vault-bdd38fca2cff/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/devel/gitlab-runner/vault-sdk-v0.1.13/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/gomplate/vault-sdk-v0.1.13/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/hashicorp/vault/vault-api-v1.0.4/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/istio/vault-sdk-v0.1.12/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/vault/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/SAP/go-hdb/internal/protocol/ |
| H A D | message.go | 32 packetCount int32 member
41 h.packetCount,
49 wr.WriteInt32(h.packetCount)
64 h.packetCount = rd.ReadInt32()
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/loss/ |
| H A D | QuicLossFunctions.h | 146 << conn.outstandings.packetCount[PacketNumberSpace::Handshake] in setLossDetectionAlarm()
169 << conn.outstandings.packetCount[PacketNumberSpace::Initial] in setLossDetectionAlarm()
171 << conn.outstandings.packetCount[PacketNumberSpace::Handshake] << " " in setLossDetectionAlarm()
186 << conn.outstandings.packetCount[PacketNumberSpace::Initial] in setLossDetectionAlarm()
188 << conn.outstandings.packetCount[PacketNumberSpace::Handshake] << " " in setLossDetectionAlarm()
288 CHECK(conn.outstandings.packetCount[currentPacketNumberSpace]); in detectLossPackets()
289 --conn.outstandings.packetCount[currentPacketNumberSpace]; in detectLossPackets()
393 << conn.outstandings.packetCount[PacketNumberSpace::Initial] in onLossDetectionAlarm()
436 << conn.outstandings.packetCount[PacketNumberSpace::Initial] in handleAckForLoss()
471 CHECK(conn.outstandings.packetCount[PacketNumberSpace::AppData]); in markZeroRttPacketsLost()
[all …]
|
| H A D | QuicLossFunctions.cpp | 67 auto& packetCount = conn.outstandings.packetCount; in onPTOAlarm() local
73 packetCount[PacketNumberSpace::Initial], kPacketToSendForPTO); in onPTOAlarm()
77 packetCount[PacketNumberSpace::Handshake], kPacketToSendForPTO); in onPTOAlarm()
81 packetCount[PacketNumberSpace::AppData], kPacketToSendForPTO); in onPTOAlarm()
|
| /dports/security/intel-ipsec-mb/intel-ipsec-mb-55179f0/lib/avx512/ |
| H A D | zuc_avx512_top.c | 475 while(packetCount >= 16) { in _zuc_eea3_n_buffer()
486 while(packetCount >= 8) { in _zuc_eea3_n_buffer()
487 packetCount -= 8; in _zuc_eea3_n_buffer()
496 while(packetCount >= 4) { in _zuc_eea3_n_buffer()
497 packetCount -= 4; in _zuc_eea3_n_buffer()
506 while(packetCount--) { in _zuc_eea3_n_buffer()
907 if (packetCount >= 8) { in _zuc_eia3_n_buffer()
908 packetCount -= 8; in _zuc_eia3_n_buffer()
917 if (packetCount >= 4) { in _zuc_eia3_n_buffer()
918 packetCount -= 4; in _zuc_eia3_n_buffer()
[all …]
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/test/ |
| H A D | AckHandlersTest.cpp | 55 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in emplacePackets()
91 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
174 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
321 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
431 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
452 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
751 .packetCount[regularPacket.header.getPacketNumberSpace()]++; in TEST_P()
973 conn.outstandings.packetCount[GetParam()]++; in TEST_P()
1176 conn.outstandings.packetCount[GetParam()]++; in TEST_P()
1517 conn.outstandings.packetCount[GetParam()] -= 4; in TEST_P()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | odm_CfoTracking.c | 162 if (pCfoTrack->packetCount == pCfoTrack->packetCount_pre) { in ODM_CfoTracking()
173 pCfoTrack->packetCount_pre = pCfoTrack->packetCount; in ODM_CfoTracking()
315 if (pCfoTrack->packetCount == 0xffffffff) in ODM_ParsingCFO()
316 pCfoTrack->packetCount = 0; in ODM_ParsingCFO()
318 pCfoTrack->packetCount++; in ODM_ParsingCFO()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | odm_CfoTracking.c | 162 if (pCfoTrack->packetCount == pCfoTrack->packetCount_pre) { in ODM_CfoTracking()
173 pCfoTrack->packetCount_pre = pCfoTrack->packetCount; in ODM_CfoTracking()
315 if (pCfoTrack->packetCount == 0xffffffff) in ODM_ParsingCFO()
316 pCfoTrack->packetCount = 0; in ODM_ParsingCFO()
318 pCfoTrack->packetCount++; in ODM_ParsingCFO()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | odm_CfoTracking.c | 162 if (pCfoTrack->packetCount == pCfoTrack->packetCount_pre) { in ODM_CfoTracking()
173 pCfoTrack->packetCount_pre = pCfoTrack->packetCount; in ODM_CfoTracking()
315 if (pCfoTrack->packetCount == 0xffffffff) in ODM_ParsingCFO()
316 pCfoTrack->packetCount = 0; in ODM_ParsingCFO()
318 pCfoTrack->packetCount++; in ODM_ParsingCFO()
|
| /dports/games/openbor4432/openbor-ba1eb4f/engine/source/webmlib/ |
| H A D | vorbis.c | 37 void vorbis_headerpacket(vorbis_context *ctx, void *data, size_t size, int packetCount) in vorbis_headerpacket() argument
43 op.b_o_s = (packetCount == 0); in vorbis_headerpacket()
46 op.packetno = packetCount; in vorbis_headerpacket()
|
| /dports/games/openbor/openbor-3caaddd5/engine/source/webmlib/ |
| H A D | vorbis.c | 37 void vorbis_headerpacket(vorbis_context *ctx, void *data, size_t size, int packetCount) in vorbis_headerpacket() argument
43 op.b_o_s = (packetCount == 0); in vorbis_headerpacket()
46 op.packetno = packetCount; in vorbis_headerpacket()
|