| /external/lzma/CPP/7zip/Compress/ |
| D | Bcj2Coder.cpp | 244 size_t curSize = enc.bufs[enc.state] - _bufs[enc.state]; in CodeReal() local
246 RINOK(WriteStream(outStreams[enc.state], _bufs[enc.state], curSize)); in CodeReal()
248 outSizeRc += curSize; in CodeReal()
272 UInt32 curSize = _bufsCurSizes[BCJ2_NUM_STREAMS]; in CodeReal() local
273 RINOK(inStreams[0]->Read(_bufs[BCJ2_NUM_STREAMS], curSize, &curSize)); in CodeReal()
276 if (curSize == 0) in CodeReal()
282 numBytes_in_ReadBuf = curSize; in CodeReal()
397 UInt32 curSize = _bufsCurSizes[dec.state] - (UInt32)totalRead; in Code() local
408 HRESULT res2 = inStreams[dec.state]->Read(_bufs[dec.state] + totalRead, curSize, &curSize); in Code()
410 if (curSize == 0) in Code()
[all …]
|
| D | CopyCoder.cpp | 55 UInt32 curSize = size - pos; in Code() local
56 HRESULT res = outStream->Write(_buf + pos, curSize, &curSize); in Code()
57 pos += curSize; in Code()
58 TotalSize += curSize; in Code()
60 if (curSize == 0) in Code()
|
| /external/lzma/CPP/7zip/Common/ |
| D | CWrappers.cpp | 79 UInt32 curSize = ((*size < kStreamStepSize) ? (UInt32)*size : kStreamStepSize); in MyRead() local
80 p->Res = (p->Stream->Read(data, curSize, &curSize)); in MyRead()
81 *size = curSize; in MyRead()
82 p->Processed += curSize; in MyRead()
124 UInt32 curSize = ((*size < kStreamStepSize) ? (UInt32)*size : kStreamStepSize); in InStreamWrap_Read() local
125 p->Res = p->Stream->Read(data, curSize, &curSize); in InStreamWrap_Read()
126 *size = curSize; in InStreamWrap_Read()
|
| D | StreamUtils.cpp | 15 UInt32 curSize = (size < kBlockSize) ? (UInt32)size : kBlockSize; in ReadStream() local
17 HRESULT res = stream->Read(data, curSize, &processedSizeLoc); in ReadStream()
46 UInt32 curSize = (size < kBlockSize) ? (UInt32)size : kBlockSize; in WriteStream() local
48 HRESULT res = stream->Write(data, curSize, &processedSizeLoc); in WriteStream()
|
| /external/lzma/CPP/Windows/ |
| D | Registry.cpp | 241 UInt32 curSize = 0; in QueryValue() local
242 LONG res = RegQueryValueEx(_object, (LPTSTR)name, NULL, &type, NULL, (DWORD *)&curSize); in QueryValue()
245 UInt32 curSize2 = curSize; in QueryValue()
246 res = QueryValue(name, value.GetBuf(curSize), curSize2); in QueryValue()
247 if (curSize > curSize2) in QueryValue()
248 curSize = curSize2; in QueryValue()
249 value.ReleaseBuf_CalcLen(curSize / sizeof(TCHAR)); in QueryValue()
268 UInt32 curSize = 0; in QueryValue() local
274 res = RegQueryValueExW(_object, name, NULL, &type, NULL, (DWORD *)&curSize); in QueryValue()
277 UInt32 curSize2 = curSize; in QueryValue()
[all …]
|
| /external/lzma/CS/7zip/Compress/LZ/ |
| D | LzOutWindow.cs | 48 uint curSize = _windowSize - _pos; in Train()
49 if (size < curSize) in Train()
50 curSize = size; in Train()
51 int numReadBytes = stream.Read(_buffer, (int)_pos, (int)curSize); in Train()
|
| /external/deqp/framework/delibs/dethread/win32/ |
| D | deThreadWin32.c | 121 deUint32 curSize = (deUint32)sizeof(PSYSTEM_LOGICAL_PROCESSOR_INFORMATION)*8; in getWin32ProcessorInfo() local
122 …TEM_LOGICAL_PROCESSOR_INFORMATION* info = (SYSTEM_LOGICAL_PROCESSOR_INFORMATION*)deMalloc(curSize); in getWin32ProcessorInfo()
126 DWORD inOutLen = curSize; in getWin32ProcessorInfo()
140 curSize <<= 1; in getWin32ProcessorInfo()
141 info = deRealloc(info, curSize); in getWin32ProcessorInfo()
|
| /external/lzma/C/ |
| D | 7zDec.c | 258 size_t curSize = (1 << 18); in SzDecodeCopy() local
259 if (curSize > inSize) in SzDecodeCopy()
260 curSize = (size_t)inSize; in SzDecodeCopy()
261 RINOK(ILookInStream_Look(inStream, &inBuf, &curSize)); in SzDecodeCopy()
262 if (curSize == 0) in SzDecodeCopy()
264 memcpy(outBuffer, inBuf, curSize); in SzDecodeCopy()
265 outBuffer += curSize; in SzDecodeCopy()
266 inSize -= curSize; in SzDecodeCopy()
267 RINOK(ILookInStream_Skip(inStream, curSize)); in SzDecodeCopy()
|
| D | 7zFile.c | 110 DWORD curSize = (originalSize > kChunkSizeMax) ? kChunkSizeMax : (DWORD)originalSize; in File_Read() local
112 BOOL res = ReadFile(p->handle, data, curSize, &processed, NULL); in File_Read()
145 DWORD curSize = (originalSize > kChunkSizeMax) ? kChunkSizeMax : (DWORD)originalSize; in File_Write() local
147 BOOL res = WriteFile(p->handle, data, curSize, &processed, NULL); in File_Write()
|
| D | LzFind.c | 67 UInt32 curSize = 0xFFFFFFFF - (p->streamPos - p->pos); in MatchFinder_ReadBlock() local
68 if (curSize > p->directInputRem) in MatchFinder_ReadBlock()
69 curSize = (UInt32)p->directInputRem; in MatchFinder_ReadBlock()
70 p->directInputRem -= curSize; in MatchFinder_ReadBlock()
71 p->streamPos += curSize; in MatchFinder_ReadBlock()
|
| /external/angle/src/libANGLE/renderer/d3d/ |
| D | IndexBuffer.cpp | 173 unsigned int curSize = getBufferSize(); in reserveBufferSpace() local
174 if (curSize == 0) in reserveBufferSpace()
179 ASSERT(curSize >= size && indexType == getIndexType()); in reserveBufferSpace()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | SharedFlow.kt | 397 val curSize = totalSize in enqueueLocked() constant
400 …else -> if (curSize >= curBuffer.size) growBuffer(curBuffer, curSize,curBuffer.size * 2) else curB… in enqueueLocked()
402 buffer.setBufferAt(head + curSize, item) in enqueueLocked()
405 private fun growBuffer(curBuffer: Array<Any?>?, curSize: Int, newSize: Int): Array<Any?> { in growBuffer()
410 for (i in 0 until curSize) { in growBuffer()
|
| /external/deqp/executor/ |
| D | xeTcpIpLink.cpp | 312 size_t curSize = hasHeader ? messageSize : (size_t)xs::MESSAGE_HEADER_SIZE; in run() local
313 size_t bytesToRecv = curSize-m_curMsgPos; in run()
317 if (m_curMsgBuf.size() < curSize) in run()
318 m_curMsgBuf.resize(curSize); in run()
|
| D | xeCallQueue.cpp | 30 static inline int getNextQueueSize (int curSize, int minNewSize) in getNextQueueSize() argument
32 return de::max(curSize*2, 1<<deLog2Ceil32(minNewSize)); in getNextQueueSize()
|
| D | xeContainerFormatParser.cpp | 35 static int getNextBufferSize (int curSize, int minNewSize) in getNextBufferSize() argument
37 return de::max(curSize*2, 1<<deLog2Ceil32(minNewSize)); in getNextBufferSize()
|
| /external/deqp/framework/xexml/ |
| D | xeXMLParser.cpp | 52 static int getNextBufferSize (int curSize, int minNewSize) in getNextBufferSize() argument
54 return de::max(curSize*2, 1<<deLog2Ceil32(minNewSize)); in getNextBufferSize()
|
| /external/lzma/CPP/7zip/UI/Common/ |
| D | Bench.cpp | 328 size_t curSize = BufferSize - Pos; in Write() local
329 if (curSize > size) in Write()
330 curSize = size; in Write()
331 if (curSize != 0) in Write()
334 memcpy(Buffer + Pos, data, curSize); in Write()
336 Crc = CrcUpdate(Crc, data, curSize); in Write()
337 Pos += curSize; in Write()
340 *processedSize = (UInt32)curSize; in Write()
341 if (curSize != size) in Write()
|
| D | Update.cpp | 211 UInt32 curSize = (UInt32)MyMin((UInt64)size, volSize - altStream.Pos); in Write() local
213 RINOK(altStream.Stream->Write(data, curSize, &realProcessed)); in Write()
230 if (realProcessed == 0 && curSize != 0) in Write()
|
| /external/deqp/modules/gles2/performance/ |
| D | es2pShaderOperatorTests.cpp | 2198 for (int curSize = genTypeFirstSize; curSize <= genTypeLastSize; curSize++) in init() local
2212 int inSize = (funcTypes[i] & VALUE_ANY_GENTYPE) ? curSize in init()
|
| /external/webrtc/examples/objc/AppRTCMobile/third_party/SocketRocket/ |
| D | SRWebSocket.m | 1188 size_t curSize = _readBuffer.length - _readBufferOffset;
1189 if (!curSize) {
1203 if (curSize >= bytesNeeded) {
1206 foundSize = curSize;
|
| /external/deqp/modules/gles3/performance/ |
| D | es3pShaderOperatorTests.cpp | 2241 for (int curSize = genTypeFirstSize; curSize <= genTypeLastSize; curSize++) in init() local
2255 int inSize = (funcTypes[i] & VALUE_ANY_GENTYPE) ? curSize in init()
|
| /external/angle/src/libANGLE/ |
| D | Framebuffer.cpp | 624 const auto &curSize = attachment.getSize(); in attachmentsHaveSameDimensions() local
625 return (curSize.width != prevSize.width || curSize.height != prevSize.height); in attachmentsHaveSameDimensions()
|