| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/ |
| H A D | LearnerSender.java | 30 private final LinkedBlockingQueue<QuorumPacket> queuedPackets = new LinkedBlockingQueue<>(); field in LearnerSender
44 QuorumPacket p = queuedPackets.poll(); in run()
47 p = queuedPackets.take(); in run()
73 queuedPackets.add(pp); in queuePacket()
79 queuedPackets.clear(); in shutdown()
80 queuedPackets.add(proposalOfDeath); in shutdown()
|
| H A D | LearnerHandler.java | 305 sb.append(" queuedPacketLength:").append(queuedPackets.size()); in toString()
330 p = queuedPackets.poll(); in sendPackets()
333 p = queuedPackets.take(); in sendPackets()
600 queuedPackets.add(newLeaderQP); in run()
889 queuedPackets.clear(); in syncFollower()
1042 queuedPackets.clear(); in shutdown()
1043 queuedPackets.put(proposalOfDeath); in shutdown()
1090 queuedPackets.add(p); in queuePacket()
1093 queuedPackets.add(new MarkerQuorumPacket(System.nanoTime())); in queuePacket()
1117 info.put("queued_packets", queuedPackets.size()); in getLearnerHandlerInfo()
[all …]
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/google/gopacket/gopacket-1.1.18/reassembly/ |
| H A D | tcpassembly.go | 130 queuedPackets int member
189 QueuedPackets: rl.queuedPackets,
418 queuedPackets int member
857 half.queuedPackets++
991 a.cacheSG.queuedPackets = half.queuedPackets
992 half.queuedPackets = 0
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/google/gopacket/reassembly/ |
| H A D | tcpassembly.go | 130 queuedPackets int member
189 QueuedPackets: rl.queuedPackets,
418 queuedPackets int member
857 half.queuedPackets++
991 a.cacheSG.queuedPackets = half.queuedPackets
992 half.queuedPackets = 0
|
| /dports/misc/fq/fq-0.0.2/vendor/github.com/google/gopacket/reassembly/ |
| H A D | tcpassembly.go | 130 queuedPackets int member
189 QueuedPackets: rl.queuedPackets,
417 queuedPackets int member
856 half.queuedPackets++
989 a.cacheSG.queuedPackets = half.queuedPackets
990 half.queuedPackets = 0
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/google/gopacket/reassembly/ |
| H A D | tcpassembly.go | 130 queuedPackets int member
189 QueuedPackets: rl.queuedPackets,
418 queuedPackets int member
857 half.queuedPackets++
991 a.cacheSG.queuedPackets = half.queuedPackets
992 half.queuedPackets = 0
|
| /dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/github.com/google/gopacket/reassembly/ |
| H A D | tcpassembly.go | 130 queuedPackets int member
189 QueuedPackets: rl.queuedPackets,
418 queuedPackets int member
857 half.queuedPackets++
991 a.cacheSG.queuedPackets = half.queuedPackets
992 half.queuedPackets = 0
|
| /dports/games/libretro-scummvm/scummvm-7b1e929/video/ |
| H A D | mpegps_decoder.cpp | 257 int queuedPackets = 0; in loadStream() local
258 while (queueNextPacket() && queuedPackets < PREBUFFERED_PACKETS) { in loadStream()
259 queuedPackets++; in loadStream()
|
| /dports/games/scummvm/scummvm-2.5.1/video/ |
| H A D | mpegps_decoder.cpp | 267 int queuedPackets = 0; in loadStream() local
268 while (queueNextPacket() && queuedPackets < PREBUFFERED_PACKETS) { in loadStream()
269 queuedPackets++; in loadStream()
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/ThirdParty/libtgvoip/ |
| H A D | VoIPController.cpp | 2060 for(i=0;i<queuedPackets.size();i++){ in ProcessIncomingPacket()
2061 QueuedPacket& qp=queuedPackets[i]; in ProcessIncomingPacket()
2083 queuedPackets.erase(queuedPackets.begin()+i); in ProcessIncomingPacket()
3132 queuedPackets.push_back(move(pkt)); in SendPacketReliably()
3808 for(std::vector<QueuedPacket>::iterator qp=queuedPackets.begin(); qp!=queuedPackets.end();){ in UpdateQueuedPackets()
3811 qp=queuedPackets.erase(qp); in UpdateQueuedPackets()
|
| H A D | VoIPController.h | 673 std::vector<QueuedPacket> queuedPackets; variable
|
| /dports/graphics/opendx/dx-4.4.4/src/uipp/dxuilib/ |
| H A D | DXApplication.h | 250 List queuedPackets; member
|
| H A D | DXApplication.C | 3175 this->serverInfo.queuedPackets.deleteElement(
3176 this->serverInfo.queuedPackets.getPosition((const void *)p));
3361 this->serverInfo.queuedPackets.deleteElement(
3362 this->serverInfo.queuedPackets.getPosition((const void *)p));
3424 this->serverInfo.queuedPackets.insertElement((const void *)p, 1);
|