/dports/devel/godot/godot-3.2.3-stable/modules/websocket/ |
H A D | packet_buffer.h | 46 RingBuffer<_Packet> _packets; variable 57 if (p_info && _packets.space_left() < 1) { in write_packet() 63 ERR_FAIL_COND_V(p_info && _packets.space_left() < 1, ERR_OUT_OF_MEMORY); in write_packet() 71 _packets.write(p); in write_packet() 83 ERR_FAIL_COND_V(_packets.data_left() < 1, ERR_UNAVAILABLE); in read_packet() 85 _packets.read(&p, 1); in read_packet() 96 _packets.decrease_write(p_size); in discard_payload() 100 _packets.resize(p_pkt_shift); in resize() 105 return _packets.data_left(); in packets_left() 110 _packets.resize(0); in clear()
|
/dports/devel/godot-tools/godot-3.2.3-stable/modules/websocket/ |
H A D | packet_buffer.h | 46 RingBuffer<_Packet> _packets; variable 57 if (p_info && _packets.space_left() < 1) { in write_packet() 63 ERR_FAIL_COND_V(p_info && _packets.space_left() < 1, ERR_OUT_OF_MEMORY); in write_packet() 71 _packets.write(p); in write_packet() 83 ERR_FAIL_COND_V(_packets.data_left() < 1, ERR_UNAVAILABLE); in read_packet() 85 _packets.read(&p, 1); in read_packet() 96 _packets.decrease_write(p_size); in discard_payload() 100 _packets.resize(p_pkt_shift); in resize() 105 return _packets.data_left(); in packets_left() 110 _packets.resize(0); in clear()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/src/System/Data/SqlClient/ |
H A D | TdsParserSafeHandles.cs | 244 private Stack<SNIPacket> _packets; field in System.Data.SqlClient.WritePacketCache 249 _packets = new Stack<SNIPacket>(); in WritePacketCache() 255 if (_packets.Count > 0) in Take() 258 packet = _packets.Pop(); in Take() 273 _packets.Push(packet); in Add() 284 while (_packets.Count > 0) in Clear() 286 _packets.Pop().Dispose(); in Clear()
|
H A D | TdsParserStateObjectManaged.cs | 251 private Stack<SNIPacket> _packets; field in System.Data.SqlClient.SNI.TdsParserStateObjectManaged.WritePacketCache 256 _packets = new Stack<SNIPacket>(); in WritePacketCache() 262 if (_packets.Count > 0) in Take() 265 packet = _packets.Pop(); in Take() 280 _packets.Push(packet); in Add() 291 while (_packets.Count > 0) in Clear() 293 _packets.Pop().Dispose(); in Clear()
|
H A D | TdsParserStateObjectNative.cs | 299 private Stack<SNIPacket> _packets; field in System.Data.SqlClient.TdsParserStateObjectNative.WritePacketCache 304 _packets = new Stack<SNIPacket>(); in WritePacketCache() 310 if (_packets.Count > 0) in Take() 313 packet = _packets.Pop(); in Take() 328 _packets.Push(packet); in Add() 339 while (_packets.Count > 0) in Clear() 341 _packets.Pop().Dispose(); in Clear()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/System/Data/SqlClient/ |
H A D | TdsParserSafeHandles.cs | 219 private Stack<SNIPacket> _packets; field in System.Data.SqlClient.WritePacketCache 223 _packets = new Stack<SNIPacket>(); in WritePacketCache() 228 if (_packets.Count > 0) { in Take() 230 packet = _packets.Pop(); in Take() 242 _packets.Push(packet); in Add() 251 while (_packets.Count > 0) { in Clear() 252 _packets.Pop().Dispose(); in Clear()
|
/dports/devel/py-aiortc/aiortc-1.2.1/src/aiortc/ |
H A D | jitterbuffer.py | 22 self._packets: List[Optional[RtpPacket]] = [None for i in range(capacity)] 59 self._packets[pos] = packet 72 packet = self._packets[pos] 103 self._packets[pos] = None 114 packet = self._packets[pos] 119 self._packets[pos] = None
|
/dports/net/py-pyshark/pyshark-0.4.3/pyshark/capture/ |
H A D | file_capture.py | 60 elif self._current_packet >= len(self._packets): 62 self._packets += [packet] 69 while packet_index >= len(self._packets): 84 … return "<%s %s (%d packets)>" % (self.__class__.__name__, self.input_filename, len(self._packets))
|
H A D | capture.py | 57 self._packets = [] 94 return self._packets[item] 97 return len(self._packets) 105 if self._current_packet >= len(self._packets): 107 cur_packet = self._packets[self._current_packet] 113 self._packets = [] 128 initial_packet_amount = len(self._packets) 131 self._packets.append(pkt) 133 if packet_count != 0 and len(self._packets) - initial_packet_amount >= packet_count: 498 return iter(self._packets) [all …]
|
H A D | inmem_capture.py | 177 self._packets.append(pkt) 190 self._packets.extend(parsed_packets)
|
/dports/net/opal/opal-3.10.10/plugins/video/THEORA/ |
H A D | theora_frame.cxx | 193 _packets.clear(); in disassembleRTPFrame() 233 _packets.push_back(packet); in disassembleRTPFrame() 287 _packets.push_back(packet); in disassembleRTPFrame() 358 else if ((_encodedData.len > 0) && (!_packets.empty())) { in GetOggPacket() 360 packet = _packets.front(); in GetOggPacket() 364 _packets.erase(_packets.begin()); in GetOggPacket() 365 if (_packets.empty()) { in GetOggPacket()
|
H A D | theora_frame.h | 118 std::vector<packet_t> _packets; variable
|
/dports/net/pktanon/pktanon-1.4.0-dev/src/ |
H A D | StatisticEngine.h | 68 void addPackets (int _packets = 1); 82 _MEASURE_MARK (time_t _time, unsigned long long _packets, unsigned long long _bytes) { in _MEASURE_MARK() 84 packets = _packets; in _MEASURE_MARK()
|
H A D | StatisticEngine.cpp | 188 void StatisticEngine::addPackets (int _packets) in addPackets() argument 190 packets += _packets; in addPackets()
|
/dports/net/ipsumdump/ipsumdump-1.86/libclick-2.1/include/click/ |
H A D | element.hh | 224 unsigned npackets() const { return _packets; } in npackets() 241 mutable unsigned _packets; // How many packets have we moved? member in Element::Port 519 # define PORT_ASSIGN(o) _packets = 0; _owner = (o) 521 # define PORT_ASSIGN(o) _packets = 0; (void) (o) 613 ++_packets; in push() 616 ++_e->input(_port)._packets; in push() 667 _e->output(_port)._packets += 1; in pull() 682 ++_packets; in pull()
|
/dports/net/samba412/samba-4.12.15/source4/torture/smb2/ |
H A D | block.h | 44 #define torture_list_tcp_transport(_tctx, _t, _packets) \ argument 45 torture_list_tcp_transport_name(_tctx, #_t, _packets)
|
H A D | block.c | 258 uint32_t *_packets) in torture_list_tcp_transport_name() argument 287 if (_packets != NULL) { in torture_list_tcp_transport_name() 288 *_packets = packets; in torture_list_tcp_transport_name()
|
/dports/net/ipsumdump/ipsumdump-1.86/src/ |
H A D | aggregateipflows.hh | 198 uint32_t _packets[2]; member 199 …orts, FlowInfo *next, uint32_t agg) : FlowInfo(ports, next, agg) { _packets[0] = _packets[1] = 0; } in StatFlowInfo()
|
/dports/net-mgmt/nfdump/nfdump-1.6.20/bin/ |
H A D | sflow_nfdump.c | 401 uint64_t _bytes, _packets, _t; // tmp buffers in StoreSflowRecord() local 512 _packets = val->val; in StoreSflowRecord() 638 stat_record->numpackets_icmp += _packets; in StoreSflowRecord() 643 stat_record->numpackets_tcp += _packets; in StoreSflowRecord() 648 stat_record->numpackets_udp += _packets; in StoreSflowRecord() 653 stat_record->numpackets_other += _packets; in StoreSflowRecord() 658 stat_record->numpackets += _packets; in StoreSflowRecord()
|
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
H A D | packet_builder.py | 88 self._packets: List[QuicSentPacket] = [] 154 packets = self._packets 156 self._packets = [] 343 self._packets.append(self._packet)
|
/dports/www/py-aioquic/aioquic-0.9.17/src/aioquic/quic/ |
H A D | packet_builder.py | 88 self._packets: List[QuicSentPacket] = [] 154 packets = self._packets 156 self._packets = [] 337 self._packets.append(self._packet)
|
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
H A D | packet_builder.py | 88 self._packets: List[QuicSentPacket] = [] 154 packets = self._packets 156 self._packets = [] 343 self._packets.append(self._packet)
|
/dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
H A D | packet_builder.py | 88 self._packets: List[QuicSentPacket] = [] 154 packets = self._packets 156 self._packets = [] 343 self._packets.append(self._packet)
|
/dports/sysutils/munin-contrib/contrib-c31cb28/plugins/network/ |
H A D | tc_packets_ | 45 echo "graph_order `mytc $DEVICE | awk '{ print $2 "_" $3 "_packets" }' | tr "\n" " "`"
|
/dports/devel/py-aiortc/aiortc-1.2.1/tests/ |
H A D | test_jitterbuffer.py | 9 found = [x.sequence_number if x else None for x in jbuffer._packets] 14 self.assertEqual(jbuffer._packets, [None, None]) 18 self.assertEqual(jbuffer._packets, [None, None, None, None])
|