blob: ec74816534c6eaf2ddfd5e7d64868158962ce782 [file] [log] [blame]
// SPDX-License-Identifier: GPL-2.0+
#include "decompress.h"
#if IS_ENABLED(CONFIG_ZLIB)
#include <u-boot/zlib.h>
/* report a zlib or i/o error */
static int zerr(int ret)
{
switch (ret) {
case Z_STREAM_ERROR:
return -EINVAL;
case Z_DATA_ERROR:
return -EIO;
case Z_MEM_ERROR:
return -ENOMEM;
case Z_ERRNO:
default:
return -EFAULT;
}
}
static int z_erofs_decompress_deflate(struct z_erofs_decompress_req *rq)
{
u8 *dest = (u8 *)rq->out;
u8 *src = (u8 *)rq->in;
u8 *buff = NULL;
unsigned int inputmargin = 0;
z_stream strm;
int ret;
while (!src[inputmargin & (erofs_blksiz() - 1)])
if (!(++inputmargin & (erofs_blksiz() - 1)))
break;
if (inputmargin >= rq->inputsize)
return -EFSCORRUPTED;
if (rq->decodedskip) {
buff = malloc(rq->decodedlength);
if (!buff)
return -ENOMEM;
dest = buff;
}
/* allocate inflate state */
strm.zalloc = Z_NULL;
strm.zfree = Z_NULL;
strm.opaque = Z_NULL;
strm.avail_in = 0;
strm.next_in = Z_NULL;
ret = inflateInit2(&strm, -15);
if (ret != Z_OK) {
free(buff);
return zerr(ret);
}
strm.next_in = src + inputmargin;
strm.avail_in = rq->inputsize - inputmargin;
strm.next_out = dest;
strm.avail_out = rq->decodedlength;
ret = inflate(&strm, rq->partial_decoding ? Z_SYNC_FLUSH : Z_FINISH);
if (ret != Z_STREAM_END || strm.total_out != rq->decodedlength) {
if (ret != Z_OK || !rq->partial_decoding) {
ret = zerr(ret);
goto out_inflate_end;
}
}
if (rq->decodedskip)
memcpy(rq->out, dest + rq->decodedskip,
rq->decodedlength - rq->decodedskip);
out_inflate_end:
inflateEnd(&strm);
if (buff)
free(buff);
return ret;
}
#endif
#if IS_ENABLED(CONFIG_LZ4)
#include <u-boot/lz4.h>
static int z_erofs_decompress_lz4(struct z_erofs_decompress_req *rq)
{
int ret = 0;
char *dest = rq->out;
char *src = rq->in;
char *buff = NULL;
bool support_0padding = false;
unsigned int inputmargin = 0;
if (erofs_sb_has_lz4_0padding()) {
support_0padding = true;
while (!src[inputmargin & (erofs_blksiz() - 1)])
if (!(++inputmargin & (erofs_blksiz() - 1)))
break;
if (inputmargin >= rq->inputsize)
return -EIO;
}
if (rq->decodedskip) {
buff = malloc(rq->decodedlength);
if (!buff)
return -ENOMEM;
dest = buff;
}
if (rq->partial_decoding || !support_0padding)
ret = LZ4_decompress_safe_partial(src + inputmargin, dest,
rq->inputsize - inputmargin,
rq->decodedlength, rq->decodedlength);
else
ret = LZ4_decompress_safe(src + inputmargin, dest,
rq->inputsize - inputmargin,
rq->decodedlength);
if (ret != (int)rq->decodedlength) {
erofs_err("failed to %s decompress %d in[%u, %u] out[%u]",
rq->partial_decoding ? "partial" : "full",
ret, rq->inputsize, inputmargin, rq->decodedlength);
ret = -EIO;
goto out;
}
if (rq->decodedskip)
memcpy(rq->out, dest + rq->decodedskip,
rq->decodedlength - rq->decodedskip);
out:
if (buff)
free(buff);
return ret;
}
#endif
int z_erofs_decompress(struct z_erofs_decompress_req *rq)
{
if (rq->alg == Z_EROFS_COMPRESSION_INTERLACED) {
unsigned int count, rightpart, skip;
/* XXX: should support inputsize >= erofs_blksiz() later */
if (rq->inputsize > erofs_blksiz())
return -EFSCORRUPTED;
if (rq->decodedlength > erofs_blksiz())
return -EFSCORRUPTED;
if (rq->decodedlength < rq->decodedskip)
return -EFSCORRUPTED;
count = rq->decodedlength - rq->decodedskip;
skip = erofs_blkoff(rq->interlaced_offset + rq->decodedskip);
rightpart = min(erofs_blksiz() - skip, count);
memcpy(rq->out, rq->in + skip, rightpart);
memcpy(rq->out + rightpart, rq->in, count - rightpart);
return 0;
} else if (rq->alg == Z_EROFS_COMPRESSION_SHIFTED) {
if (rq->decodedlength > rq->inputsize)
return -EFSCORRUPTED;
DBG_BUGON(rq->decodedlength < rq->decodedskip);
memcpy(rq->out, rq->in + rq->decodedskip,
rq->decodedlength - rq->decodedskip);
return 0;
}
#if IS_ENABLED(CONFIG_LZ4)
if (rq->alg == Z_EROFS_COMPRESSION_LZ4)
return z_erofs_decompress_lz4(rq);
#endif
#if IS_ENABLED(CONFIG_ZLIB)
if (rq->alg == Z_EROFS_COMPRESSION_DEFLATE)
return z_erofs_decompress_deflate(rq);
#endif
return -EOPNOTSUPP;
}