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.
29 * Copyright (c) 1983, 1990, 1992, 1993, 1995
30 * The Regents of the University of California. All rights reserved.
32 * Redistribution and use in source and binary forms, with or without
33 * modification, are permitted provided that the following conditions
35 * 1. Redistributions of source code must retain the above copyright
36 * notice, this list of conditions and the following disclaimer.
37 * 2. Redistributions in binary form must reproduce the above copyright
38 * notice, this list of conditions and the following disclaimer in the
39 * documentation and/or other materials provided with the distribution.
40 * 3. All advertising materials mentioning features or use of this software
41 * must display the following acknowledgement:
42 * This product includes software developed by the University of
43 * California, Berkeley and its contributors.
44 * 4. Neither the name of the University nor the names of its contributors
45 * may be used to endorse or promote products derived from this software
46 * without specific prior written permission.
48 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
49 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
50 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
51 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
52 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
53 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
54 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
55 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
56 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
57 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
63 RCSID("$OpenBSD: progressmeter.c,v 1.2 2003/01/12 16:57:02 markus Exp $");
68 #include "progressmeter.h"
70 /* Number of seconds before xfer considered "stalled". */
72 /* alarm() interval for updating progress meter. */
73 #define PROGRESSTIME 1
75 /* Signal handler used for updating the progress meter. */
76 static void update_progress_meter(int);
78 /* Returns non-zero if we are the foreground process. */
79 static int foregroundproc(void);
81 /* Returns width of the terminal (for progress meter calculations). */
82 static int get_tty_width(void);
84 /* Visual statistics about files as they are transferred. */
85 static void draw_progress_meter(void);
87 /* Time a transfer started. */
88 static struct timeval start;
90 /* Number of bytes of current file transferred so far. */
91 static volatile off_t *statbytes;
93 /* Total size of current file. */
94 static off_t totalbytes;
96 /* Name of current file being transferred. */
99 /* Time of last update. */
100 static struct timeval lastupdate;
102 /* Size at the time of the last update. */
103 static off_t lastsize;
106 start_progress_meter(char *file, off_t filesize, off_t *counter)
108 if ((curfile = basename(file)) == NULL)
111 totalbytes = filesize;
113 (void) gettimeofday(&start, (struct timezone *) 0);
117 draw_progress_meter();
118 signal(SIGALRM, update_progress_meter);
123 stop_progress_meter()
126 draw_progress_meter();
127 atomicio(write, fileno(stdout), "\n", 1);
131 update_progress_meter(int ignore)
133 int save_errno = errno;
135 draw_progress_meter();
136 signal(SIGALRM, update_progress_meter);
144 static pid_t pgrp = -1;
150 return ((ioctl(STDOUT_FILENO, TIOCGPGRP, &ctty_pgrp) != -1 &&
155 draw_progress_meter()
157 static const char spaces[] = " "
163 static const char prefixes[] = " KMGTP";
164 struct timeval now, td, wait;
165 off_t cursize, abbrevsize, bytespersec;
167 int ratio, remaining, i, ai, bi, nspaces;
170 if (foregroundproc() == 0)
173 (void) gettimeofday(&now, (struct timezone *) 0);
174 cursize = *statbytes;
175 if (totalbytes != 0) {
176 ratio = 100.0 * cursize / totalbytes;
177 ratio = MAX(ratio, 0);
178 ratio = MIN(ratio, 100);
182 abbrevsize = cursize;
183 for (ai = 0; abbrevsize >= 10000 && ai < sizeof(prefixes); ai++)
186 timersub(&now, &lastupdate, &wait);
187 if (cursize > lastsize) {
192 timersub(&now, &start, &td);
193 elapsed = td.tv_sec + (td.tv_usec / 1000000.0);
197 bytespersec = cursize;
199 bytespersec /= elapsed;
201 for (bi = 1; bytespersec >= 1024000 && bi < sizeof(prefixes); bi++)
204 nspaces = MIN(get_tty_width() - 79, sizeof(spaces) - 1);
206 snprintf(buf, sizeof(buf),
207 "\r%-45.45s%.*s%3d%% %4lld%c%c %3lld.%01d%cB/s",
212 (long long)abbrevsize,
215 (long long)(bytespersec / 1024),
216 (int)((bytespersec % 1024) * 10 / 1024),
220 if (cursize <= 0 || elapsed <= 0.0 || cursize > totalbytes) {
221 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
223 } else if (wait.tv_sec >= STALLTIME) {
224 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
227 if (cursize != totalbytes)
228 remaining = (int)(totalbytes / (cursize / elapsed) -
233 i = remaining / 3600;
235 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
238 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
240 i = remaining % 3600;
241 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
242 "%02d:%02d%s", i / 60, i % 60,
243 (cursize != totalbytes) ? " ETA" : " ");
245 atomicio(write, fileno(stdout), buf, strlen(buf));
251 struct winsize winsize;
253 if (ioctl(fileno(stdout), TIOCGWINSZ, &winsize) != -1)
254 return (winsize.ws_col ? winsize.ws_col : 80);