2 * Copyright (c) 1999 Theo de Raadt. All rights reserved.
3 * Copyright (c) 1999 Aaron Campbell. All rights reserved.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
14 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
15 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
16 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
17 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
18 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
19 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
20 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
21 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
23 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 * Copyright (c) 1997-2003 The NetBSD Foundation, Inc.
28 * All rights reserved.
30 * This code is derived from software contributed to The NetBSD Foundation
33 * This code is derived from software contributed to The NetBSD Foundation
34 * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
35 * NASA Ames Research Center.
37 * Redistribution and use in source and binary forms, with or without
38 * modification, are permitted provided that the following conditions
40 * 1. Redistributions of source code must retain the above copyright
41 * notice, this list of conditions and the following disclaimer.
42 * 2. Redistributions in binary form must reproduce the above copyright
43 * notice, this list of conditions and the following disclaimer in the
44 * documentation and/or other materials provided with the distribution.
45 * 3. All advertising materials mentioning features or use of this software
46 * must display the following acknowledgement:
47 * This product includes software developed by the NetBSD
48 * Foundation, Inc. and its contributors.
49 * 4. Neither the name of The NetBSD Foundation nor the names of its
50 * contributors may be used to endorse or promote products derived
51 * from this software without specific prior written permission.
53 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
54 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
55 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
56 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
57 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
58 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
59 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
60 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
61 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
62 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
63 * POSSIBILITY OF SUCH DAMAGE.
67 RCSID("$OpenBSD: progressmeter.c,v 1.7 2003/06/10 22:20:52 deraadt Exp $");
74 #include "progressmeter.h"
77 /* Number of seconds before xfer considered "stalled". */
79 /* alarm() interval for updating progress meter. */
80 #define PROGRESSTIME 1
82 /* Signal handler used for updating the progress meter. */
83 static void update_progress_meter(int);
85 /* Returns non-zero if we are the foreground process. */
86 static int foregroundproc(void);
88 /* Returns width of the terminal (for progress meter calculations). */
89 static int get_tty_width(void);
91 /* Visual statistics about files as they are transferred. */
92 static void draw_progress_meter(void);
94 /* Time a transfer started. */
95 static struct timeval start;
97 /* Number of bytes of current file transferred so far. */
98 static volatile off_t *statbytes;
100 /* Total size of current file. */
101 static off_t totalbytes;
103 /* Name of current file being transferred. */
104 static char *curfile;
106 /* Time of last update. */
107 static struct timeval lastupdate;
109 /* Size at the time of the last update. */
110 static off_t lastsize;
113 start_progress_meter(char *file, off_t filesize, off_t *counter)
115 if ((curfile = basename(file)) == NULL)
118 totalbytes = filesize;
120 (void) gettimeofday(&start, (struct timezone *) 0);
124 draw_progress_meter();
125 mysignal(SIGALRM, update_progress_meter);
130 stop_progress_meter(void)
133 draw_progress_meter();
134 if (foregroundproc() != 0)
135 atomicio(write, fileno(stdout), "\n", 1);
139 update_progress_meter(int ignore)
141 int save_errno = errno;
143 draw_progress_meter();
144 mysignal(SIGALRM, update_progress_meter);
152 static pid_t pgrp = -1;
158 #ifdef HAVE_TCGETPGRP
159 return ((ctty_pgrp = tcgetpgrp(STDOUT_FILENO)) != -1 &&
162 return ((ioctl(STDOUT_FILENO, TIOCGPGRP, &ctty_pgrp) != -1 &&
168 draw_progress_meter(void)
170 static const char spaces[] = " "
176 static const char prefixes[] = " KMGTP";
177 struct timeval now, td, wait;
178 off_t cursize, abbrevsize, bytespersec;
180 int ratio, remaining, i, ai, bi, nspaces;
183 if (foregroundproc() == 0)
186 (void) gettimeofday(&now, (struct timezone *) 0);
187 cursize = *statbytes;
188 if (totalbytes != 0) {
189 ratio = 100.0 * cursize / totalbytes;
190 ratio = MAX(ratio, 0);
191 ratio = MIN(ratio, 100);
195 abbrevsize = cursize;
196 for (ai = 0; abbrevsize >= 10000 && ai < sizeof(prefixes); ai++)
199 timersub(&now, &lastupdate, &wait);
200 if (cursize > lastsize) {
205 timersub(&now, &start, &td);
206 elapsed = td.tv_sec + (td.tv_usec / 1000000.0);
210 bytespersec = cursize;
212 bytespersec /= elapsed;
214 for (bi = 1; bytespersec >= 1024000 && bi < sizeof(prefixes); bi++)
217 nspaces = MIN(get_tty_width() - 79, sizeof(spaces) - 1);
219 snprintf(buf, sizeof(buf),
220 "\r%-45.45s%.*s%3d%% %4lld%c%c %3lld.%01d%cB/s",
228 (int64_t)(bytespersec / 1024),
229 (int)((bytespersec % 1024) * 10 / 1024),
233 if (cursize <= 0 || elapsed <= 0.0 || cursize > totalbytes) {
234 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
236 } else if (wait.tv_sec >= STALLTIME) {
237 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
240 if (cursize != totalbytes)
241 remaining = (int)(totalbytes / (cursize / elapsed) -
246 i = remaining / 3600;
248 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
251 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
253 i = remaining % 3600;
254 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
255 "%02d:%02d%s", i / 60, i % 60,
256 (cursize != totalbytes) ? " ETA" : " ");
258 atomicio(write, fileno(stdout), buf, strlen(buf));
264 struct winsize winsize;
266 if (ioctl(fileno(stdout), TIOCGWINSZ, &winsize) != -1)
267 return (winsize.ws_col ? winsize.ws_col : 80);