| /dports/databases/arrow/apache-arrow-6.0.1/java/compression/src/main/java/org/apache/arrow/compression/ |
| H A D | ZstdCompressionCodec.java | 52 long decompressedLength = readUncompressedLength(compressedBuffer); in doDecompress() local
53 ArrowBuf uncompressedBuffer = allocator.buffer(decompressedLength); in doDecompress()
54 …ng decompressedSize = Zstd.decompressUnsafe(uncompressedBuffer.memoryAddress(), decompressedLength, in doDecompress()
59 throw new RuntimeException("Error decompressing: " + Zstd.getErrorName(decompressedLength)); in doDecompress()
61 if (decompressedLength != decompressedSize) { in doDecompress()
64 decompressedLength + " != " + decompressedSize); in doDecompress()
66 uncompressedBuffer.writerIndex(decompressedLength); in doDecompress()
|
| H A D | Lz4CompressionCodec.java | 68 long decompressedLength = readUncompressedLength(compressedBuffer); in doDecompress() local
72 ByteArrayOutputStream out = new ByteArrayOutputStream((int) decompressedLength); in doDecompress()
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/vector/src/main/java/org/apache/arrow/vector/compression/ |
| H A D | AbstractCompressionCodec.java | 63 long decompressedLength = readUncompressedLength(compressedBuffer); in decompress() local
65 if (decompressedLength == 0L) { in decompress()
71 if (decompressedLength == CompressionUtil.NO_COMPRESSION_LENGTH) { in decompress()
90 long decompressedLength = compressedBuffer.getLong(0); in readUncompressedLength() local
92 decompressedLength = Long.reverseBytes(decompressedLength); in readUncompressedLength()
94 return decompressedLength; in readUncompressedLength()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/ |
| H A D | Fetcher.java | 475 long decompressedLength = -1; in copyMapOutput() local
487 decompressedLength = header.uncompressedLength; in copyMapOutput()
499 decompressedLength -= CryptoUtils.cryptoPadding(jobConf); in copyMapOutput()
502 if (!verifySanity(compressedLength, decompressedLength, forReduce, in copyMapOutput()
509 ", decomp len: " + decompressedLength); in copyMapOutput()
514 mapOutput = merger.reserve(mapId, decompressedLength, id); in copyMapOutput()
535 + mapOutput.getMapId() + " decomp: " + decompressedLength in copyMapOutput()
568 decompressedLength + ", " + compressedLength, ioe); in copyMapOutput()
620 if (compressedLength < 0 || decompressedLength < 0) { in verifySanity()
624 decompressedLength); in verifySanity()
[all …]
|
| H A D | LocalFetcher.java | 128 long decompressedLength = ir.rawLength; in copyMapOutput() local
131 decompressedLength -= CryptoUtils.cryptoPadding(job); in copyMapOutput()
134 MapOutput<K, V> mapOutput = merger.reserve(mapTaskId, decompressedLength, in copyMapOutput()
146 decompressedLength + " len: " + compressedLength + " to " + in copyMapOutput()
157 … mapOutput.shuffle(LOCALHOST, inStream, compressedLength, decompressedLength, metrics, reporter); in copyMapOutput()
|
| H A D | MapOutput.java | 77 long decompressedLength, in shuffle() argument
|
| H A D | InMemoryMapOutput.java | 82 long compressedLength, long decompressedLength, in shuffle() argument
|
| H A D | OnDiskMapOutput.java | 93 long compressedLength, long decompressedLength, in shuffle() argument
|
| /dports/textproc/goldendict/goldendict-73ec1b5/ |
| H A D | chunkedstorage.cc | 148 unsigned long decompressedLength = chunk.size(); in getBlock() local
151 &decompressedLength, in getBlock()
154 decompressedLength != chunk.size() ) in getBlock()
|
| H A D | btreeidx.cc | 516 lzo_uint decompressedLength = out.size(); in readNode() local
519 (unsigned char *)&out.front(), &decompressedLength, 0 ) in readNode()
520 != LZO_E_OK || decompressedLength != out.size() ) in readNode()
525 unsigned long decompressedLength = out.size(); in readNode() local
528 &decompressedLength, in readNode()
531 decompressedLength != out.size() ) in readNode()
|
| H A D | bgl.cc | 1077 unsigned long decompressedLength = data.size(); in run() local
1080 &decompressedLength, in run()
1083 decompressedLength != data.size() ) in run()
|
| /dports/archivers/snappy-java/snappy-java-1.1.7.5/src/main/java/org/xerial/snappy/ |
| H A D | SnappyNative.cpp | 154 size_t decompressedLength; in Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_nio_ByteBuffer_2IILjava_nio_ByteBuffer_2I() local
155 snappy::GetUncompressedLength(compressedBuffer + cpos, (size_t) clen, &decompressedLength); in Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_nio_ByteBuffer_2IILjava_nio_ByteBuffer_2I()
162 return (jint) decompressedLength; in Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_nio_ByteBuffer_2IILjava_nio_ByteBuffer_2I()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | ReduceTask.java | 1520 long decompressedLength = in getMapOutput() local
1525 if (compressedLength < 0 || decompressedLength < 0) { in getMapOutput()
1528 ", decompressed len: " + decompressedLength); in getMapOutput()
1537 ", decompressed len: " + decompressedLength + in getMapOutput()
1543 ", decompressed len: " + decompressedLength); in getMapOutput()
1552 boolean shuffleInMemory = ramManager.canFitInMemory(decompressedLength); in getMapOutput()
1558 LOG.debug("Shuffling " + decompressedLength + " bytes (" + in getMapOutput()
1564 (int)decompressedLength, in getMapOutput()
1568 LOG.debug("Shuffling " + decompressedLength + " bytes (" + in getMapOutput()
1576 mapOutput.decompressedSize = decompressedLength; in getMapOutput()
|
| /dports/games/q2pro/q2pro/source/ |
| H A D | common.c | 1073 int compressedLength, decompressedLength; in MSG_ParseZPacket() local
1080 decompressedLength = MSG_ReadShort(); in MSG_ParseZPacket()
1084 decompressed.cursize != decompressedLength ) in MSG_ParseZPacket()
1088 compressedLength, decompressedLength ); in MSG_ParseZPacket()
|
| /dports/print/fontforge/fontforge-20201107/tests/ |
| H A D | test926.py | 1139 decompressedLength = len(decompressedData)
1140 if origLength != decompressedLength:
1141 …ot match the actual length of the decompressed data (%d)." % (tag, origLength, decompressedLength))
1350 decompressedLength = len(metadata)
1351 if metaOrigLength != decompressedLength:
1352 …oes not match the original metadata length (%d) in the header." % (decompressedLength, metaOrigLen…
|
| /dports/games/NBlood/NBlood-a1689a4/source/build/src/ |
| H A D | vfs.cpp | 1464 …int32_t decompressedLength = LZ4_decompress_safe(pCompressedData, (char*) buffer, leng, dasizeof*c… in kdfread_LZ4() local
1469 return decompressedLength/dasizeof; in kdfread_LZ4()
|