| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| D | WebSocketParserD00.java | 51 private Buffer _buffer; field in WebSocketParserD00
73 return _buffer==null || _buffer.length()==0; in isBufferEmpty()
79 return _buffer; in getBuffer()
92 if (_buffer==null) in parseNext()
93 _buffer=_buffers.getBuffer(); in parseNext()
100 int length=_buffer.length(); in parseNext()
106 _buffer.compact(); in parseNext()
109 if (_buffer.space() == 0) in parseNext()
115 int filled=_endp.isOpen()?_endp.fill(_buffer):-1; in parseNext()
119 length=_buffer.length(); in parseNext()
[all …]
|
| D | WebSocketGeneratorRFC6455.java | 44 private Buffer _buffer; field in WebSocketGeneratorRFC6455
66 return _buffer; in getBuffer()
86 if (_buffer == null) in addFrame()
87 _buffer = mask ? _buffers.getBuffer() : _buffers.getDirectBuffer(); in addFrame()
100 if (payload + space > _buffer.capacity()) in addFrame()
104 payload = _buffer.capacity() - space; in addFrame()
110 if (_buffer.space() <= space) in addFrame()
113 if (_buffer.space() <= space) in addFrame()
120 _buffer.put(new byte[]{ in addFrame()
134 _buffer.put(new byte[]{ in addFrame()
[all …]
|
| D | WebSocketGeneratorD08.java | 40 private Buffer _buffer; field in WebSocketGeneratorD08
62 return _buffer; in getBuffer()
82 if (_buffer == null) in addFrame()
83 _buffer = mask ? _buffers.getBuffer() : _buffers.getDirectBuffer(); in addFrame()
96 if (payload + space > _buffer.capacity()) in addFrame()
100 payload = _buffer.capacity() - space; in addFrame()
106 if (_buffer.space() <= space) in addFrame()
109 if (_buffer.space() <= space) in addFrame()
116 _buffer.put(new byte[]{ in addFrame()
130 _buffer.put(new byte[]{ in addFrame()
[all …]
|
| D | WebSocketGeneratorD00.java | 40 private Buffer _buffer; field in WebSocketGeneratorD00
52 if (_buffer==null) in addFrame()
53 _buffer=_buffers.getDirectBuffer(); in addFrame()
55 if (_buffer.space() == 0) in addFrame()
81 int chunk = remaining < _buffer.space() ? remaining : _buffer.space(); in addFrame()
82 _buffer.put(content, offset + (length - remaining), chunk); in addFrame()
84 if (_buffer.space() > 0) in addFrame()
87 _buffer.put((byte)0xFF); in addFrame()
98 _buffer.put((byte)0xFF); in addFrame()
113 if (_buffer==null)
[all …]
|
| D | WebSocketParserRFC6455.java | 62 private Buffer _buffer; field in WebSocketParserRFC6455
112 return _buffer==null || _buffer.length()==0; in isBufferEmpty()
118 return _buffer; in getBuffer()
131 if (_buffer==null) in parseNext()
132 _buffer=_buffers.getBuffer(); in parseNext()
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0)) in parseNext()
140 int available=_buffer.length(); in parseNext()
146 _buffer.compact(); in parseNext()
149 if (_buffer.space() == 0) in parseNext()
154 Buffer data =_buffer.get(4*(available/4)); in parseNext()
[all …]
|
| D | WebSocketParserD08.java | 62 private Buffer _buffer; field in WebSocketParserD08
112 return _buffer==null || _buffer.length()==0; in isBufferEmpty()
118 return _buffer; in getBuffer()
131 if (_buffer==null) in parseNext()
132 _buffer=_buffers.getBuffer(); in parseNext()
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0)) in parseNext()
140 int available=_buffer.length(); in parseNext()
146 _buffer.compact(); in parseNext()
149 if (_buffer.space() == 0) in parseNext()
154 Buffer data =_buffer.get(4*(available/4)); in parseNext()
[all …]
|
| D | WebSocketGeneratorD06.java | 39 private Buffer _buffer; field in WebSocketGeneratorD06
65 if (_buffer==null) in addFrame()
66 _buffer=(_maskGen!=null)?_buffers.getBuffer():_buffers.getDirectBuffer(); in addFrame()
79 if (payload+space>_buffer.capacity()) in addFrame()
83 payload=_buffer.capacity()-space; in addFrame()
89 if (_buffer.space() <= space) in addFrame()
97 _buffer.put(_mask); in addFrame()
133 _buffer.compact(); in addFrame()
134 int chunk = remaining < _buffer.space() ? remaining : _buffer.space(); in addFrame()
142 _buffer.put(content, offset + (payload - remaining), chunk); in addFrame()
[all …]
|
| D | WebSocketParserD06.java | 63 private Buffer _buffer; field in WebSocketParserD06
92 return _buffer==null || _buffer.length()==0; in isBufferEmpty()
98 return _buffer; in getBuffer()
111 if (_buffer==null) in parseNext()
112 _buffer=_buffers.getBuffer(); in parseNext()
120 int available=_buffer.length(); in parseNext()
126 _buffer.compact(); in parseNext()
129 if (_buffer.space() == 0) in parseNext()
130 … throw new IllegalStateException("FULL: "+_state+" "+_bytesNeeded+">"+_buffer.capacity()); in parseNext()
135 int filled=_endp.isOpen()?_endp.fill(_buffer):-1; in parseNext()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/http/ |
| D | HttpParser.java | 69 private Buffer _buffer; // The current buffer in use (either _header or _content) field in HttpParser
98 _buffer=buffer; in HttpParser()
238 while (!isComplete() && _buffer!=null && _buffer.length()>0 && !_contentView.hasContent()) in parseAvailable()
260 if (_buffer==null) in parseNext()
261 _buffer=getHeaderBuffer(); in parseNext()
271 int length=_buffer.length(); in parseNext()
281 LOG.debug("filled {}/{}",filled,_buffer.length()); in parseNext()
298 if (_buffer.length()>0 && !_headResponse) in parseNext()
300 Buffer chunk=_buffer.get(_buffer.length()); in parseNext()
335 length=_buffer.length(); in parseNext()
[all …]
|
| D | HttpGenerator.java | 147 if (_buffer!=null)
148 _buffer.clear();
223 …else if (_endp != null && (_buffer==null || _buffer.length()==0) && _content.length() > 0 && (_las…
230 if (_buffer == null)
231 _buffer = _buffers.getBuffer();
234 int len=_buffer.put(_content);
288 if (_buffer == null) in prepareUncheckedAddContent()
289 _buffer = _buffers.getBuffer(); in prepareUncheckedAddContent()
291 _contentWritten-=_buffer.length(); in prepareUncheckedAddContent()
297 return _buffer.space()-(_contentLength == HttpTokens.CHUNKED_CONTENT?CHUNK_SPACE:0); in prepareUncheckedAddContent()
[all …]
|
| D | AbstractGenerator.java | 74 protected Buffer _buffer; // Buffer for copy of passed _content field in AbstractGenerator
129 if (_buffer!=null && _buffer.length()==0) in returnBuffers()
131 _buffers.returnBuffer(_buffer); in returnBuffers()
132 _buffer=null; in returnBuffers()
153 if (_buffer!=null) in resetBuffer()
154 _buffer.clear(); in resetBuffer()
163 if (_buffer==null) in getContentBufferSize()
164 _buffer=_buffers.getBuffer(); in getContentBufferSize()
165 return _buffer.capacity(); in getContentBufferSize()
174 if (_buffer==null) in increaseContentBufferSize()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/io/ |
| D | SimpleBuffers.java | 30 final Buffer _buffer; field in SimpleBuffers
41 _buffer=buffer; in SimpleBuffers()
49 if (_buffer!=null && !_bufferOut) in getBuffer()
52 return _buffer; in getBuffer()
55 … if (_buffer!=null && _header!=null && _header.capacity()==_buffer.capacity() && !_headerOut) in getBuffer()
61 if (_buffer!=null) in getBuffer()
62 return new ByteArrayBuffer(_buffer.capacity()); in getBuffer()
78 … if (_buffer!=null && _header!=null && _header.capacity()==_buffer.capacity() && !_bufferOut) in getHeader()
81 return _buffer; in getHeader()
97 if (_buffer!=null && _buffer.capacity()==size) in getBuffer()
[all …]
|
| D | View.java | 30 Buffer _buffer; field in View
42 _buffer=buffer.buffer(); in View()
52 _buffer=buffer.buffer(); in View()
70 _buffer=buffer.buffer(); in update()
94 return _buffer.array(); in array()
103 return _buffer.buffer(); in buffer()
111 return _buffer.capacity(); in capacity()
122 setPutIndex(_buffer.getIndex()); in clear()
123 setGetIndex(_buffer.getIndex()); in clear()
152 return _buffer.isReadOnly(); in isReadOnly()
[all …]
|
| /external/lzma/CPP/7zip/Common/ |
| D | FilterCoder.cpp | 16 _buffer = (Byte *)::MidAlloc(kBufferSize); in CFilterCoder()
17 if (_buffer == 0) in CFilterCoder()
23 ::MidFree(_buffer); in ~CFilterCoder()
34 RINOK(WriteStream(outStream, _buffer, size)); in WriteWithLimit()
53 RINOK(ReadStream(inStream, _buffer + bufferPos, &processedSize)); in Code()
57 bufferPos = Filter->Filter(_buffer, endPos); in Code()
61 _buffer[endPos] = 0; in Code()
62 bufferPos = Filter->Filter(_buffer, endPos); in Code()
78 _buffer[i++] = _buffer[bufferPos++]; in Code()
105 memcpy(_buffer + _bufferPos, data, sizeTemp); in Write()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/util/ |
| D | Utf8StringBuilder.java | 37 final StringBuilder _buffer; field in Utf8StringBuilder
42 _buffer=(StringBuilder)_appendable; in Utf8StringBuilder()
48 _buffer=(StringBuilder)_appendable; in Utf8StringBuilder()
54 return _buffer.length(); in length()
61 _buffer.setLength(0); in reset()
67 return _buffer; in getStringBuilder()
74 return _buffer.toString(); in toString()
|
| D | Utf8StringBuffer.java | 36 final StringBuffer _buffer; field in Utf8StringBuffer
41 _buffer = (StringBuffer)_appendable; in Utf8StringBuffer()
47 _buffer = (StringBuffer)_appendable; in Utf8StringBuffer()
53 return _buffer.length(); in length()
60 _buffer.setLength(0); in reset()
66 return _buffer; in getStringBuffer()
73 return _buffer.toString(); in toString()
|
| /external/webrtc/webrtc/modules/video_coding/codecs/i420/ |
| D | i420.cc | 29 delete[] _encodedImage._buffer; in ~I420Encoder()
35 if (_encodedImage._buffer != NULL) { in Release()
36 delete[] _encodedImage._buffer; in Release()
37 _encodedImage._buffer = NULL; in Release()
54 if (_encodedImage._buffer != NULL) { in InitEncode()
55 delete[] _encodedImage._buffer; in InitEncode()
56 _encodedImage._buffer = NULL; in InitEncode()
67 _encodedImage._buffer = newBuffer; in InitEncode()
103 delete[] _encodedImage._buffer; in Encode()
105 _encodedImage._buffer = new uint8_t[req_length]; in Encode()
[all …]
|
| /external/lzma/Java/SevenZip/Compression/LZ/ |
| D | OutWindow.java | 9 byte[] _buffer; field in OutWindow
17 if (_buffer == null || _windowSize != windowSize) in Create()
18 _buffer = new byte[windowSize]; in Create()
50 _stream.write(_buffer, _streamPos, size); in Flush()
65 _buffer[_pos++] = _buffer[pos++]; in CopyBlock()
73 _buffer[_pos++] = b; in PutByte()
83 return _buffer[pos]; in GetByte()
|
| /external/webrtc/webrtc/modules/video_coding/ |
| D | encoded_frame.cc | 40 _buffer = NULL; in VCMEncodedFrame()
43 if (rhs._buffer != NULL) { in VCMEncodedFrame()
45 memcpy(_buffer, rhs._buffer, rhs._length); in VCMEncodedFrame()
59 _buffer = NULL; in VCMEncodedFrame()
62 if (rhs._buffer != NULL) { in VCMEncodedFrame()
64 memcpy(_buffer, rhs._buffer, rhs._length); in VCMEncodedFrame()
76 if (_buffer != NULL) { in Free()
77 delete[] _buffer; in Free()
78 _buffer = NULL; in Free()
215 if (_buffer) { in VerifyAndAllocate()
[all …]
|
| /external/lzma/CS/7zip/Compress/LZ/ |
| D | LzOutWindow.cs | 7 byte[] _buffer = null; field in SevenZip.Compression.LZ.OutWindow
20 _buffer = new byte[windowSize]; in Create()
51 int numReadBytes = stream.Read(_buffer, (int)_pos, (int)curSize); in Train()
74 _stream.Write(_buffer, (int)_streamPos, (int)size); in Flush()
89 _buffer[_pos++] = _buffer[pos++]; in CopyBlock()
97 _buffer[_pos++] = b; in PutByte()
107 return _buffer[pos]; in GetByte()
|
| /external/chromium-trace/catapult/perf_insights/third_party/cloudstorage/ |
| D | storage_api.py | 206 self._buffer = _Buffer()
221 self._buffer.reset(content)
260 self._buffer = _Buffer()
310 newline_offset = self._buffer.find_newline(size)
312 data = self._buffer.read(size)
318 self._buffer.reset(self._buffer_future.get_result())
320 newline_offset = self._buffer.find_newline(size)
322 data = self._buffer.read_to_offset(newline_offset + 1)
348 remaining = self._buffer.remaining()
350 data_list.append(self._buffer.read(size))
[all …]
|
| /external/zlib/src/contrib/dotzlib/DotZLib/ |
| D | CircularBuffer.cs | 24 private byte[] _buffer; field in DotZLib.CircularBuffer
30 _buffer = new byte[capacity]; in CircularBuffer()
44 _buffer[(_tail+i) % _capacity] = source[offset+i]; in Put()
55 _buffer[_tail++] = b; in Put()
65 destination[offset + i] = _buffer[(_head+i) % _capacity]; in Get()
77 int result = (int)_buffer[_head++ % _capacity]; in Get()
|
| /external/lzma/CPP/7zip/Compress/ |
| D | CopyCoder.cpp | 17 ::MidFree(_buffer); in ~CCopyCoder()
25 if (!_buffer) in Code()
27 _buffer = (Byte *)::MidAlloc(kBufferSize); in Code()
28 if (!_buffer) in Code()
38 RINOK(inStream->Read(_buffer, size, &size)); in Code()
43 RINOK(WriteStream(outStream, _buffer, size)); in Code()
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| D | resumable_streaming_upload.py | 54 self._buffer = collections.deque()
86 while pos_in_buffer + len(self._buffer[buffer_index]) < self._position:
90 pos_in_buffer += len(self._buffer[buffer_index])
95 buffer_len = len(self._buffer[buffer_index])
101 self._buffer[buffer_index]
137 self._buffer.append(new_data)
141 oldest_data = self._buffer.popleft()
147 self._buffer.appendleft(oldest_data[-refill_amount:])
|
| /external/curl/tests/ |
| D | http_pipe.py | 80 self._buffer = ""
106 self._buffer += data.replace('\r', '')
115 if len(self._buffer) > MAX_REQUEST_SIZE:
117 'Request is at least %d bytes' % len(self._buffer))
135 m = self.REQUEST_RE.match(self._buffer)
151 self._buffer = self._buffer[m.end():]
161 if self._buffer.startswith('\n'):
162 self._buffer = self._buffer[1:]
170 m = self.HEADER_RE.match(self._buffer)
178 self._buffer = self._buffer[m.end():]
|