| /dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/ |
| H A D | QUICIncomingFrameBuffer.cc | 43 while (!this->_recv_buffer.empty()) { in clear()
44 delete this->_recv_buffer.front(); in clear()
45 this->_recv_buffer.pop(); in clear()
68 if (this->_recv_buffer.empty()) { in pop()
73 this->_recv_buffer.push(frame); in pop()
80 if (!this->_recv_buffer.empty()) { in pop()
82 this->_recv_buffer.pop(); in pop()
206 if (this->_recv_buffer.empty()) { in pop()
211 this->_recv_buffer.push(frame); in pop()
218 if (!this->_recv_buffer.empty()) { in pop()
[all …]
|
| H A D | QUICIncomingFrameBuffer.h | 45 std::queue<const QUICFrame *> _recv_buffer; variable
|
| /dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
| H A D | stream.py | 22 self._recv_buffer = bytearray()
62 if pos == 0 and count and not self._recv_buffer:
79 gap = pos - len(self._recv_buffer)
81 self._recv_buffer += bytearray(gap)
82 self._recv_buffer[pos : pos + count] = frame.data
107 data = bytes(self._recv_buffer[:pos])
108 del self._recv_buffer[:pos]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
| H A D | stream.py | 22 self._recv_buffer = bytearray()
62 if pos == 0 and count and not self._recv_buffer:
79 gap = pos - len(self._recv_buffer)
81 self._recv_buffer += bytearray(gap)
82 self._recv_buffer[pos : pos + count] = frame.data
107 data = bytes(self._recv_buffer[:pos])
108 del self._recv_buffer[:pos]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/aioquic/src/aioquic/quic/ |
| H A D | stream.py | 22 self._recv_buffer = bytearray()
62 if pos == 0 and count and not self._recv_buffer:
79 gap = pos - len(self._recv_buffer)
81 self._recv_buffer += bytearray(gap)
82 self._recv_buffer[pos : pos + count] = frame.data
107 data = bytes(self._recv_buffer[:pos])
108 del self._recv_buffer[:pos]
|
| /dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
| H A D | test_stream.py | 12 self.assertEqual(bytes(stream._recv_buffer), b"")
18 self.assertEqual(bytes(stream._recv_buffer), b"")
30 self.assertEqual(bytes(stream._recv_buffer), b"")
39 self.assertEqual(bytes(stream._recv_buffer), b"")
48 self.assertEqual(bytes(stream._recv_buffer), b"")
70 self.assertEqual(bytes(stream._recv_buffer), b"")
79 self.assertEqual(bytes(stream._recv_buffer), b"")
86 bytes(stream._recv_buffer), b"\x00\x00\x00\x00\x00\x00\x00\x00"
99 self.assertEqual(bytes(stream._recv_buffer), b"")
107 self.assertEqual(bytes(stream._recv_buffer), b"")
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
| H A D | test_stream.py | 12 self.assertEqual(bytes(stream._recv_buffer), b"")
18 self.assertEqual(bytes(stream._recv_buffer), b"")
30 self.assertEqual(bytes(stream._recv_buffer), b"")
39 self.assertEqual(bytes(stream._recv_buffer), b"")
48 self.assertEqual(bytes(stream._recv_buffer), b"")
70 self.assertEqual(bytes(stream._recv_buffer), b"")
79 self.assertEqual(bytes(stream._recv_buffer), b"")
86 bytes(stream._recv_buffer), b"\x00\x00\x00\x00\x00\x00\x00\x00"
99 self.assertEqual(bytes(stream._recv_buffer), b"")
107 self.assertEqual(bytes(stream._recv_buffer), b"")
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
| H A D | test_stream.py | 12 self.assertEqual(bytes(stream._recv_buffer), b"")
18 self.assertEqual(bytes(stream._recv_buffer), b"")
30 self.assertEqual(bytes(stream._recv_buffer), b"")
39 self.assertEqual(bytes(stream._recv_buffer), b"")
48 self.assertEqual(bytes(stream._recv_buffer), b"")
70 self.assertEqual(bytes(stream._recv_buffer), b"")
79 self.assertEqual(bytes(stream._recv_buffer), b"")
86 bytes(stream._recv_buffer), b"\x00\x00\x00\x00\x00\x00\x00\x00"
99 self.assertEqual(bytes(stream._recv_buffer), b"")
107 self.assertEqual(bytes(stream._recv_buffer), b"")
[all …]
|
| /dports/www/novnc-websockify/websockify-0.9.0/websockify/ |
| H A D | websocket.py | 92 self._recv_buffer = ''.encode("ascii")
199 if self._recv_buffer.find('\r\n\r\n'.encode("ascii")) == -1:
202 (request, self._recv_buffer) = self._recv_buffer.split('\r\n'.encode("ascii"), 1)
211 (headers, self._recv_buffer) = self._recv_buffer.split('\r\n\r\n'.encode("ascii"), 1)
521 self._recv_buffer += data
543 frame = self._decode_hybi(self._recv_buffer)
546 self._recv_buffer = self._recv_buffer[frame['length']:]
|
| /dports/devel/py-websockify/websockify-0.10.0/websockify/ |
| H A D | websocket.py | 78 self._recv_buffer = b''
185 if self._recv_buffer.find(b'\r\n\r\n') == -1:
188 (request, self._recv_buffer) = self._recv_buffer.split(b'\r\n', 1)
197 (headers, self._recv_buffer) = self._recv_buffer.split(b'\r\n\r\n', 1)
566 self._recv_buffer += data
588 frame = self._decode_hybi(self._recv_buffer)
591 self._recv_buffer = self._recv_buffer[frame['length']:]
|
| /dports/net/p5-Beanstalk-Client/Beanstalk-Client-1.06/lib/Beanstalk/ |
| H A D | Client.pm | 77 $self->{_recv_buffer} = substr($buffer, 2 + length($1));
99 my $offset = length($self->{_recv_buffer});
103 my $read = sysread($sock, $self->{_recv_buffer}, $more, $offset);
116 warn substr($self->{_recv_buffer}, 0, $bytes),"\n" if $self->debug;
117 return substr($self->{_recv_buffer}, 0, $bytes);
189 $self->{_recv_buffer} = '';
|
| /dports/devel/grpc/grpc-1.42.0/test/http2_test/ |
| H A D | http2_base_server.py | 34 self._recv_buffer = {}
102 self._recv_buffer[event.stream_id] += event.data
105 self._recv_buffer[event.stream_id] = ''
221 recv_buffer = self._recv_buffer[stream_id]
|
| /dports/devel/grpc130/grpc-1.30.2/test/http2_test/ |
| H A D | http2_base_server.py | 34 self._recv_buffer = {}
102 self._recv_buffer[event.stream_id] += event.data
105 self._recv_buffer[event.stream_id] = ''
221 recv_buffer = self._recv_buffer[stream_id]
|
| /dports/devel/grpc134/grpc-1.34.1/test/http2_test/ |
| H A D | http2_base_server.py | 34 self._recv_buffer = {}
102 self._recv_buffer[event.stream_id] += event.data
105 self._recv_buffer[event.stream_id] = ''
221 recv_buffer = self._recv_buffer[stream_id]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/http2_test/ |
| H A D | http2_base_server.py | 32 self._recv_buffer = {}
93 self._recv_buffer[event.stream_id] += event.data
96 self._recv_buffer[event.stream_id] = ''
190 recv_buffer = self._recv_buffer[stream_id]
|
| /dports/devel/py-uvloop/uvloop-0.16.0/uvloop/ |
| H A D | loop.pxd | 88 char _recv_buffer[UV_STREAM_RECV_BUF_SIZE]
|
| H A D | loop.pyx | 3197 buf.base = loop._recv_buffer
3198 buf.len = sizeof(loop._recv_buffer)
|
| H A D | loop.c | 1316 char _recv_buffer[0x3E800]; member
56919 __pyx_t_3 = __pyx_v_loop->_recv_buffer; in __pyx_f_6uvloop_4loop___loop_alloc_buffer()
56930 __pyx_v_buf->len = (sizeof(__pyx_v_loop->_recv_buffer)); in __pyx_f_6uvloop_4loop___loop_alloc_buffer()
95903 …__pyx_t_7 = __Pyx_PyBytes_FromStringAndSize(((const char*)__pyx_v_loop->_recv_buffer) + 0, __pyx_v… in __pyx_f_6uvloop_4loop___uv_stream_on_read_impl()
143246 …__pyx_t_9 = __Pyx_PyBytes_FromStringAndSize(((const char*)__pyx_v_loop->_recv_buffer) + 0, __pyx_v… in __pyx_f_6uvloop_4loop___uv_udp_on_receive()
|
| /dports/devel/py-uvloop/uvloop-0.16.0/uvloop/handles/ |
| H A D | udp.pyx | 370 data = loop._recv_buffer[:nread]
|
| H A D | stream.pyx | 832 loop._recv_buffer[:nread],
|