Added "--discard" option.

src/include/options.h

@@ -45,6 +45,7 @@ struct opts_s {           /* structure describing run-time options */
 	bool stop_at_size;             /* set if we stop at "size" bytes */
 	bool sync_after_write;         /* set if we sync after every write */
 	bool direct_io;                /* set if O_DIRECT is to be used */
+	bool discard_input;            /* set to write nothing to stdout */
 	double interval;               /* interval between updates */
 	double delay_start;            /* delay before first display */
 	unsigned int watch_pid;	       /* process to watch fds of */

src/include/pv-internal.h

@@ -97,6 +97,7 @@ struct pvstate_s {
 	bool direct_io;                  /* set if O_DIRECT is to be used */
 	bool direct_io_changed;          /* set when direct_io is changed */
 	bool no_splice;                  /* never use splice() */
+	bool discard_input;              /* write nothing to stdout */
 	unsigned long long rate_limit;   /* rate limit, in bytes per second */
 	unsigned long long target_buffer_size;  /* buffer size (0=default) */
 	unsigned long long size;         /* total size of data */

src/include/pv.h

@@ -116,6 +116,7 @@ extern void pv_state_direct_io_set(pvstate_t, bool);
 extern void pv_state_rate_limit_set(pvstate_t, unsigned long long);
 extern void pv_state_target_buffer_size_set(pvstate_t, unsigned long long);
 extern void pv_state_no_splice_set(pvstate_t, bool);
+extern void pv_state_discard_input_set(pvstate_t, bool);
 extern void pv_state_size_set(pvstate_t, unsigned long long);
 extern void pv_state_interval_set(pvstate_t, double);
 extern void pv_state_width_set(pvstate_t, unsigned int);

src/main/help.c

@@ -377,6 +377,9 @@ void display_help(void)
 		{ "-K", "--direct-io", NULL,
 		 N_("use direct I/O to bypass cache"),
 		 { 0, 0, 0, 0} },
+		{ "-X", "--discard", NULL,
+		 N_("discard input instead of writing to output"),
+		 { 0, 0, 0, 0} },
 #ifdef HAVE_IPC
 		{ "-R", "--remote", N_("PID"),
 		 N_("update settings of process PID"),

src/main/main.c

@@ -273,6 +273,7 @@ int main(int argc, char **argv)
 	pv_state_stop_at_size_set(state, opts->stop_at_size);
 	pv_state_sync_after_write_set(state, opts->sync_after_write);
 	pv_state_direct_io_set(state, opts->direct_io);
+	pv_state_discard_input_set(state, opts->discard_input);
 	pv_state_rate_limit_set(state, opts->rate_limit);
 	pv_state_target_buffer_size_set(state, opts->buffer_size);
 	pv_state_no_splice_set(state, opts->no_splice);

src/main/options.c

@@ -172,6 +172,7 @@ opts_t opts_parse(unsigned int argc, char **argv)
 		{ "stop-at-size", 0, NULL, (int) 'S' },
 		{ "sync", 0, NULL, (int) 'Y' },
 		{ "direct-io", 0, NULL, (int) 'K' },
+		{ "discard", 0, NULL, (int) 'X' },
 		{ "remote", 1, NULL, (int) 'R' },
 		{ "pidfile", 1, NULL, (int) 'P' },
 		{ "watchfd", 1, NULL, (int) 'd' },
@@ -184,7 +185,7 @@ opts_t opts_parse(unsigned int argc, char **argv)
 	/*@+nullassign@ */
 	int option_index = 0;
 #endif				/* HAVE_GETOPT_LONG */
-	char *short_options = "hVpteIrab8TA:fnqcWD:s:l0i:w:H:N:F:L:B:CESYKR:P:d:m:"
+	char *short_options = "hVpteIrab8TA:fnqcWD:s:l0i:w:H:N:F:L:B:CESYKXR:P:d:m:"
 #ifdef ENABLE_DEBUGGING
 	    "!:"
 #endif
@@ -464,6 +465,10 @@ opts_t opts_parse(unsigned int argc, char **argv)
 		case 'K':
 			opts->direct_io = true;
 			break;
+		case 'X':
+			opts->discard_input = true;
+			opts->no_splice = true;
+			break;
 		case 'R':
 			opts->remote = pv_getnum_ui(optarg);
 			break;

src/pv/state.c

@@ -223,6 +223,11 @@ void pv_state_direct_io_set(pvstate_t state, bool val)
 	state->direct_io_changed = true;
 };
 
+void pv_state_discard_input_set(pvstate_t state, bool val)
+{
+	state->discard_input = val;
+};
+
 void pv_state_rate_limit_set(pvstate_t state, unsigned long long val)
 {
 	state->rate_limit = val;

src/pv/transfer.c

@@ -493,19 +493,23 @@ static int pv__transfer_read(pvstate_t state, int fd, int *eof_in, int *eof_out,
  *
  * On error, sets *eof_out to 1, sets state->written to -1, and updates
  * state->exit_status.
+ *
+ * If state->discard_input is true, does not actually write anything.
  */
 static int pv__transfer_write(pvstate_t state, int *eof_in, int *eof_out, long *lineswritten)
 {
 	ssize_t nwritten;
 
-	signal(SIGALRM, SIG_IGN);
-	alarm(1);
-
-	nwritten = pv__transfer_write_repeated(STDOUT_FILENO,
-					       state->transfer_buffer +
-					       state->write_position, state->to_write, state->sync_after_write);
-
-	alarm(0);
+	if (state->discard_input) {
+		nwritten = state->to_write;
+	} else {
+		signal(SIGALRM, SIG_IGN);
+		alarm(1);
+		nwritten = pv__transfer_write_repeated(STDOUT_FILENO,
+						       state->transfer_buffer +
+						       state->write_position, state->to_write, state->sync_after_write);
+		alarm(0);
+	}
 
 	if (0 == nwritten) {
 		/*