alexk / rpms / rpm

Forked from rpms/rpm 2 years ago
Clone
2a5b6a
diff --git a/rpmio/rpmio.c b/rpmio/rpmio.c
2a5b6a
index cd223e8..f23fc11 100644
2a5b6a
--- a/rpmio/rpmio.c
2a5b6a
+++ b/rpmio/rpmio.c
2a5b6a
@@ -5,6 +5,7 @@
2a5b6a
 #include "system.h"
2a5b6a
 #include <stdarg.h>
2a5b6a
 #include <errno.h>
2a5b6a
+#include <ctype.h>
2a5b6a
 
2a5b6a
 #include <rpm/rpmlog.h>
2a5b6a
 #include <rpm/rpmmacro.h>
2a5b6a
@@ -873,7 +874,12 @@ static const char * getFdErrstr (FD_t fd)
2a5b6a
 
2a5b6a
 #include <sys/types.h>
2a5b6a
 #include <inttypes.h>
2a5b6a
+#define LZMA_UNSTABLE
2a5b6a
 #include <lzma.h>
2a5b6a
+/* Multithreading support in stable API since xz 5.2.0 */
2a5b6a
+#if LZMA_VERSION >= 50010020
2a5b6a
+#define HAVE_LZMA_MT
2a5b6a
+#endif
2a5b6a
 
2a5b6a
 #define kBufferSize (1 << 15)
2a5b6a
 
2a5b6a
@@ -897,7 +902,10 @@ static LZFILE *lzopen_internal(const char *path, const char *mode, int fd, int x
2a5b6a
     LZFILE *lzfile;
2a5b6a
     lzma_ret ret;
2a5b6a
     lzma_stream init_strm = LZMA_STREAM_INIT;
2a5b6a
-
2a5b6a
+    uint64_t mem_limit = rpmExpandNumeric("%{_xz_memlimit}");
2a5b6a
+#ifdef HAVE_LZMA_MT
2a5b6a
+    int threads = 0;
2a5b6a
+#endif
2a5b6a
     for (; *mode; mode++) {
2a5b6a
 	if (*mode == 'w')
2a5b6a
 	    encoding = 1;
2a5b6a
@@ -905,6 +913,21 @@ static LZFILE *lzopen_internal(const char *path, const char *mode, int fd, int x
2a5b6a
 	    encoding = 0;
2a5b6a
 	else if (*mode >= '1' && *mode <= '9')
2a5b6a
 	    level = *mode - '0';
2a5b6a
+	else if (*mode == 'T') {
2a5b6a
+	    if (isdigit(*(mode+1))) {
2a5b6a
+#ifdef HAVE_LZMA_MT
2a5b6a
+		threads = atoi(++mode);
2a5b6a
+#endif
2a5b6a
+		/* skip past rest of digits in string that atoi()
2a5b6a
+		 * should've processed
2a5b6a
+		 * */
2a5b6a
+		while(isdigit(*++mode));
2a5b6a
+	    }
2a5b6a
+#ifdef HAVE_LZMA_MT
2a5b6a
+	    else
2a5b6a
+		threads = -1;
2a5b6a
+#endif
2a5b6a
+	}
2a5b6a
     }
2a5b6a
     if (fd != -1)
2a5b6a
 	fp = fdopen(fd, encoding ? "w" : "r");
2a5b6a
@@ -924,16 +947,48 @@ static LZFILE *lzopen_internal(const char *path, const char *mode, int fd, int x
2a5b6a
     lzfile->strm = init_strm;
2a5b6a
     if (encoding) {
2a5b6a
 	if (xz) {
2a5b6a
-	    ret = lzma_easy_encoder(&lzfile->strm, level, LZMA_CHECK_SHA256);
2a5b6a
+#ifdef HAVE_LZMA_MT
2a5b6a
+	    if (!threads) {
2a5b6a
+#endif
2a5b6a
+		ret = lzma_easy_encoder(&lzfile->strm, level, LZMA_CHECK_SHA256);
2a5b6a
+#ifdef HAVE_LZMA_MT
2a5b6a
+	    } else {
2a5b6a
+		if (threads == -1)
2a5b6a
+		    threads = sysconf(_SC_NPROCESSORS_ONLN);
2a5b6a
+		lzma_mt mt_options = {
2a5b6a
+		    .flags = 0,
2a5b6a
+		    .threads = threads,
2a5b6a
+		    .block_size = 0,
2a5b6a
+		    .timeout = 0,
2a5b6a
+		    .preset = level,
2a5b6a
+		    .filters = NULL,
2a5b6a
+		    .check = LZMA_CHECK_SHA256 };
2a5b6a
+
2a5b6a
+		ret = lzma_stream_encoder_mt(&lzfile->strm, &mt_options);
2a5b6a
+	    }
2a5b6a
+#endif
2a5b6a
 	} else {
2a5b6a
 	    lzma_options_lzma options;
2a5b6a
 	    lzma_lzma_preset(&options, level);
2a5b6a
 	    ret = lzma_alone_encoder(&lzfile->strm, &options);
2a5b6a
 	}
2a5b6a
-    } else {	/* lzma_easy_decoder_memusage(level) is not ready yet, use hardcoded limit for now */
2a5b6a
-	ret = lzma_auto_decoder(&lzfile->strm, 100<<20, 0);
2a5b6a
+    } else {   /* lzma_easy_decoder_memusage(level) is not ready yet, use hardcoded limit for now */
2a5b6a
+	ret = lzma_auto_decoder(&lzfile->strm, mem_limit ? mem_limit : 100<<20, 0);
2a5b6a
     }
2a5b6a
     if (ret != LZMA_OK) {
2a5b6a
+	switch (ret) {
2a5b6a
+	    case LZMA_MEM_ERROR:
2a5b6a
+		rpmlog(RPMLOG_ERR, "liblzma: Memory allocation failed");
2a5b6a
+		break;
2a5b6a
+
2a5b6a
+	    case LZMA_DATA_ERROR:
2a5b6a
+		rpmlog(RPMLOG_ERR, "liblzma: File size limits exceeded");
2a5b6a
+		break;
2a5b6a
+
2a5b6a
+	    default:
2a5b6a
+		rpmlog(RPMLOG_ERR, "liblzma: 
2a5b6a
+		break;
2a5b6a
+	}
2a5b6a
 	fclose(fp);
2a5b6a
 	free(lzfile);
2a5b6a
 	return 0;