Home
last modified time | relevance | path

Searched refs:_packets (Results 1 – 25 of 50) sorted by relevance

12

/dports/devel/godot/godot-3.2.3-stable/modules/websocket/
H A Dpacket_buffer.h46 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 Dpacket_buffer.h46 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 DTdsParserSafeHandles.cs244 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 DTdsParserStateObjectManaged.cs251 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 DTdsParserStateObjectNative.cs299 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 DTdsParserSafeHandles.cs219 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 Djitterbuffer.py22 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 Dfile_capture.py60 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 Dcapture.py57 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 Dinmem_capture.py177 self._packets.append(pkt)
190 self._packets.extend(parsed_packets)
/dports/net/opal/opal-3.10.10/plugins/video/THEORA/
H A Dtheora_frame.cxx193 _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 Dtheora_frame.h118 std::vector<packet_t> _packets; variable
/dports/net/pktanon/pktanon-1.4.0-dev/src/
H A DStatisticEngine.h68 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 DStatisticEngine.cpp188 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 Delement.hh224 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 Dblock.h44 #define torture_list_tcp_transport(_tctx, _t, _packets) \ argument
45 torture_list_tcp_transport_name(_tctx, #_t, _packets)
H A Dblock.c258 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 Daggregateipflows.hh198 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 Dsflow_nfdump.c401 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 Dpacket_builder.py88 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 Dpacket_builder.py88 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 Dpacket_builder.py88 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 Dpacket_builder.py88 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 Dtc_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 Dtest_jitterbuffer.py9 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])

12