aboutsummaryrefslogtreecommitdiff
path: root/src/xz
diff options
context:
space:
mode:
authorLasse Collin <lasse.collin@tukaani.org>2020-01-26 20:19:19 +0200
committerLasse Collin <lasse.collin@tukaani.org>2020-02-05 22:00:28 +0200
commitacc0ef3ac80f18e349c6d0252177707105c0a29c (patch)
tree2944d71bf48ef6c7ec2253a37c6fa9ffa26e4124 /src/xz
parentxz: coder.c: Make writing output a separate function. (diff)
downloadxz-acc0ef3ac80f18e349c6d0252177707105c0a29c.tar.xz
xz: Move flush_needed from mytime.h to file_pair struct in file_io.h.
Diffstat (limited to 'src/xz')
-rw-r--r--src/xz/coder.c3
-rw-r--r--src/xz/file_io.c3
-rw-r--r--src/xz/file_io.h3
-rw-r--r--src/xz/mytime.c3
-rw-r--r--src/xz/mytime.h4
5 files changed, 7 insertions, 9 deletions
diff --git a/src/xz/coder.c b/src/xz/coder.c
index 96f8e734..8bad038e 100644
--- a/src/xz/coder.c
+++ b/src/xz/coder.c
@@ -711,7 +711,7 @@ coder_normal(file_pair *pair)
action = LZMA_FULL_BARRIER;
}
- if (action == LZMA_RUN && flush_needed)
+ if (action == LZMA_RUN && pair->flush_needed)
action = LZMA_SYNC_FLUSH;
}
@@ -739,6 +739,7 @@ coder_normal(file_pair *pair)
// Mark that we haven't seen any new input
// since the previous flush.
pair->src_has_seen_input = false;
+ pair->flush_needed = false;
} else {
// Start a new Block after LZMA_FULL_BARRIER.
if (opt_block_list == NULL) {
diff --git a/src/xz/file_io.c b/src/xz/file_io.c
index 04e58c51..c891f3ca 100644
--- a/src/xz/file_io.c
+++ b/src/xz/file_io.c
@@ -750,6 +750,7 @@ io_open_src(const char *src_name)
.dest_fd = -1,
.src_eof = false,
.src_has_seen_input = false,
+ .flush_needed = false,
.dest_try_sparse = false,
.dest_pending_sparse = 0,
};
@@ -1150,7 +1151,7 @@ io_read(file_pair *pair, io_buf *buf, size_t size)
return SIZE_MAX;
case IO_WAIT_TIMEOUT:
- flush_needed = true;
+ pair->flush_needed = true;
return pos;
default:
diff --git a/src/xz/file_io.h b/src/xz/file_io.h
index 3989c701..c533d641 100644
--- a/src/xz/file_io.h
+++ b/src/xz/file_io.h
@@ -53,6 +53,9 @@ typedef struct {
/// since the previous flush or the start of the file.
bool src_has_seen_input;
+ /// For --flush-timeout: True when flushing is needed.
+ bool flush_needed;
+
/// If true, we look for long chunks of zeros and try to create
/// a sparse file.
bool dest_try_sparse;
diff --git a/src/xz/mytime.c b/src/xz/mytime.c
index 95138840..573b97de 100644
--- a/src/xz/mytime.c
+++ b/src/xz/mytime.c
@@ -17,7 +17,6 @@
#endif
uint64_t opt_flush_timeout = 0;
-bool flush_needed;
static uint64_t start_time;
static uint64_t next_flush;
@@ -53,7 +52,6 @@ mytime_set_start_time(void)
{
start_time = mytime_now();
next_flush = start_time + opt_flush_timeout;
- flush_needed = false;
return;
}
@@ -69,7 +67,6 @@ extern void
mytime_set_flush_time(void)
{
next_flush = mytime_now() + opt_flush_timeout;
- flush_needed = false;
return;
}
diff --git a/src/xz/mytime.h b/src/xz/mytime.h
index 4505724c..a7be2aa7 100644
--- a/src/xz/mytime.h
+++ b/src/xz/mytime.h
@@ -21,10 +21,6 @@
extern uint64_t opt_flush_timeout;
-/// \brief True when flushing is needed due to expired timeout
-extern bool flush_needed;
-
-
/// \brief Store the time when (de)compression was started
///
/// The start time is also stored as the time of the first flush.