diff options
Diffstat (limited to 'coreutils/head.c')
-rw-r--r-- | coreutils/head.c | 159 |
1 files changed, 132 insertions, 27 deletions
diff --git a/coreutils/head.c b/coreutils/head.c index ec4512765..291e1ce37 100644 --- a/coreutils/head.c +++ b/coreutils/head.c | |||
@@ -11,6 +11,9 @@ | |||
11 | /* BB_AUDIT GNU compatible -c, -q, and -v options in 'fancy' configuration. */ | 11 | /* BB_AUDIT GNU compatible -c, -q, and -v options in 'fancy' configuration. */ |
12 | /* http://www.opengroup.org/onlinepubs/007904975/utilities/head.html */ | 12 | /* http://www.opengroup.org/onlinepubs/007904975/utilities/head.html */ |
13 | 13 | ||
14 | //kbuild:lib-$(CONFIG_HEAD) += head.o | ||
15 | //kbuild:lib-$(CONFIG_HEAD) += head_tail.o | ||
16 | |||
14 | //usage:#define head_trivial_usage | 17 | //usage:#define head_trivial_usage |
15 | //usage: "[OPTIONS] [FILE]..." | 18 | //usage: "[OPTIONS] [FILE]..." |
16 | //usage:#define head_full_usage "\n\n" | 19 | //usage:#define head_full_usage "\n\n" |
@@ -18,7 +21,8 @@ | |||
18 | //usage: "With more than one FILE, precede each with a filename header.\n" | 21 | //usage: "With more than one FILE, precede each with a filename header.\n" |
19 | //usage: "\n -n N[kbm] Print first N lines" | 22 | //usage: "\n -n N[kbm] Print first N lines" |
20 | //usage: IF_FEATURE_FANCY_HEAD( | 23 | //usage: IF_FEATURE_FANCY_HEAD( |
21 | //usage: "\n -c N[kbm] Print first N bytes" | 24 | //usage: "\n -n -N[kbm] Print all except N last lines" |
25 | //usage: "\n -c [-]N[kbm] Print first N bytes" | ||
22 | //usage: "\n -q Never print headers" | 26 | //usage: "\n -q Never print headers" |
23 | //usage: "\n -v Always print headers" | 27 | //usage: "\n -v Always print headers" |
24 | //usage: ) | 28 | //usage: ) |
@@ -31,9 +35,114 @@ | |||
31 | //usage: "daemon:x:1:1:daemon:/usr/sbin:/bin/sh\n" | 35 | //usage: "daemon:x:1:1:daemon:/usr/sbin:/bin/sh\n" |
32 | 36 | ||
33 | #include "libbb.h" | 37 | #include "libbb.h" |
38 | #include "head_tail.h" | ||
34 | 39 | ||
35 | /* This is a NOEXEC applet. Be very careful! */ | 40 | /* This is a NOEXEC applet. Be very careful! */ |
36 | 41 | ||
42 | #if !ENABLE_FEATURE_FANCY_HEAD | ||
43 | # define print_first_N(fp,count,bytes) print_first_N(fp,count) | ||
44 | #endif | ||
45 | static void | ||
46 | print_first_N(FILE *fp, unsigned long count, bool count_bytes) | ||
47 | { | ||
48 | #if !ENABLE_FEATURE_FANCY_HEAD | ||
49 | const int count_bytes = 0; | ||
50 | #endif | ||
51 | while (count) { | ||
52 | int c = getc(fp); | ||
53 | if (c == EOF) | ||
54 | break; | ||
55 | if (count_bytes || (c == '\n')) | ||
56 | --count; | ||
57 | putchar(c); | ||
58 | } | ||
59 | } | ||
60 | |||
61 | #if ENABLE_FEATURE_FANCY_HEAD | ||
62 | static void | ||
63 | print_except_N_last_bytes(FILE *fp, unsigned count) | ||
64 | { | ||
65 | unsigned char *circle = xmalloc(++count); | ||
66 | unsigned head = 0; | ||
67 | for(;;) { | ||
68 | int c; | ||
69 | c = getc(fp); | ||
70 | if (c == EOF) | ||
71 | goto ret; | ||
72 | circle[head++] = c; | ||
73 | if (head == count) | ||
74 | break; | ||
75 | } | ||
76 | for (;;) { | ||
77 | int c; | ||
78 | if (head == count) | ||
79 | head = 0; | ||
80 | putchar(circle[head]); | ||
81 | c = getc(fp); | ||
82 | if (c == EOF) | ||
83 | goto ret; | ||
84 | circle[head] = c; | ||
85 | head++; | ||
86 | } | ||
87 | ret: | ||
88 | free(circle); | ||
89 | } | ||
90 | |||
91 | static void | ||
92 | print_except_N_last_lines(FILE *fp, unsigned count) | ||
93 | { | ||
94 | char **circle = xzalloc((++count) * sizeof(circle[0])); | ||
95 | unsigned head = 0; | ||
96 | for(;;) { | ||
97 | char *c; | ||
98 | c = xmalloc_fgets(fp); | ||
99 | if (!c) | ||
100 | goto ret; | ||
101 | circle[head++] = c; | ||
102 | if (head == count) | ||
103 | break; | ||
104 | } | ||
105 | for (;;) { | ||
106 | char *c; | ||
107 | if (head == count) | ||
108 | head = 0; | ||
109 | fputs(circle[head], stdout); | ||
110 | c = xmalloc_fgets(fp); | ||
111 | if (!c) | ||
112 | goto ret; | ||
113 | free(circle[head]); | ||
114 | circle[head++] = c; | ||
115 | } | ||
116 | ret: | ||
117 | head = 0; | ||
118 | for(;;) { | ||
119 | free(circle[head++]); | ||
120 | if (head == count) | ||
121 | break; | ||
122 | } | ||
123 | free(circle); | ||
124 | } | ||
125 | #else | ||
126 | /* Must never be called */ | ||
127 | void print_except_N_last_bytes(FILE *fp, unsigned count); | ||
128 | void print_except_N_last_lines(FILE *fp, unsigned count); | ||
129 | #endif | ||
130 | |||
131 | #if !ENABLE_FEATURE_FANCY_HEAD | ||
132 | # define eat_num(negative_N,p) eat_num(p) | ||
133 | #endif | ||
134 | static unsigned long | ||
135 | eat_num(bool *negative_N, const char *p) | ||
136 | { | ||
137 | #if ENABLE_FEATURE_FANCY_HEAD | ||
138 | if (*p == '-') { | ||
139 | *negative_N = 1; | ||
140 | p++; | ||
141 | } | ||
142 | #endif | ||
143 | return xatoul_sfx(p, head_tail_suffixes); | ||
144 | } | ||
145 | |||
37 | static const char head_opts[] ALIGN1 = | 146 | static const char head_opts[] ALIGN1 = |
38 | "n:" | 147 | "n:" |
39 | #if ENABLE_FEATURE_FANCY_HEAD | 148 | #if ENABLE_FEATURE_FANCY_HEAD |
@@ -41,29 +150,25 @@ static const char head_opts[] ALIGN1 = | |||
41 | #endif | 150 | #endif |
42 | ; | 151 | ; |
43 | 152 | ||
44 | static const struct suffix_mult head_suffixes[] = { | ||
45 | { "b", 512 }, | ||
46 | { "k", 1024 }, | ||
47 | { "m", 1024*1024 }, | ||
48 | { "", 0 } | ||
49 | }; | ||
50 | |||
51 | #define header_fmt_str "\n==> %s <==\n" | 153 | #define header_fmt_str "\n==> %s <==\n" |
52 | 154 | ||
53 | int head_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE; | 155 | int head_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE; |
54 | int head_main(int argc, char **argv) | 156 | int head_main(int argc, char **argv) |
55 | { | 157 | { |
56 | unsigned long count = 10; | 158 | unsigned long count = 10; |
57 | unsigned long i; | ||
58 | #if ENABLE_FEATURE_FANCY_HEAD | 159 | #if ENABLE_FEATURE_FANCY_HEAD |
59 | int count_bytes = 0; | ||
60 | int header_threshhold = 1; | 160 | int header_threshhold = 1; |
161 | bool count_bytes = 0; | ||
162 | bool negative_N = 0; | ||
163 | #else | ||
164 | # define header_threshhold 1 | ||
165 | # define count_bytes 0 | ||
166 | # define negative_N 0 | ||
61 | #endif | 167 | #endif |
62 | FILE *fp; | 168 | FILE *fp; |
63 | const char *fmt; | 169 | const char *fmt; |
64 | char *p; | 170 | char *p; |
65 | int opt; | 171 | int opt; |
66 | int c; | ||
67 | int retval = EXIT_SUCCESS; | 172 | int retval = EXIT_SUCCESS; |
68 | 173 | ||
69 | #if ENABLE_INCLUDE_SUSv2 || ENABLE_FEATURE_FANCY_HEAD | 174 | #if ENABLE_INCLUDE_SUSv2 || ENABLE_FEATURE_FANCY_HEAD |
@@ -73,7 +178,7 @@ int head_main(int argc, char **argv) | |||
73 | ) { | 178 | ) { |
74 | --argc; | 179 | --argc; |
75 | ++argv; | 180 | ++argv; |
76 | p = (*argv) + 1; | 181 | p = argv[0] + 1; |
77 | goto GET_COUNT; | 182 | goto GET_COUNT; |
78 | } | 183 | } |
79 | #endif | 184 | #endif |
@@ -97,7 +202,7 @@ int head_main(int argc, char **argv) | |||
97 | #if ENABLE_INCLUDE_SUSv2 || ENABLE_FEATURE_FANCY_HEAD | 202 | #if ENABLE_INCLUDE_SUSv2 || ENABLE_FEATURE_FANCY_HEAD |
98 | GET_COUNT: | 203 | GET_COUNT: |
99 | #endif | 204 | #endif |
100 | count = xatoul_sfx(p, head_suffixes); | 205 | count = eat_num(&negative_N, p); |
101 | break; | 206 | break; |
102 | default: | 207 | default: |
103 | bb_show_usage(); | 208 | bb_show_usage(); |
@@ -110,19 +215,17 @@ int head_main(int argc, char **argv) | |||
110 | *--argv = (char*)"-"; | 215 | *--argv = (char*)"-"; |
111 | 216 | ||
112 | fmt = header_fmt_str + 1; | 217 | fmt = header_fmt_str + 1; |
113 | #if ENABLE_FEATURE_FANCY_HEAD | ||
114 | if (argc <= header_threshhold) { | 218 | if (argc <= header_threshhold) { |
219 | #if ENABLE_FEATURE_FANCY_HEAD | ||
115 | header_threshhold = 0; | 220 | header_threshhold = 0; |
116 | } | ||
117 | #else | 221 | #else |
118 | if (argc <= 1) { | ||
119 | fmt += 11; /* "" */ | 222 | fmt += 11; /* "" */ |
120 | } | ||
121 | /* Now define some things here to avoid #ifdefs in the code below. | ||
122 | * These should optimize out of the if conditions below. */ | ||
123 | #define header_threshhold 1 | ||
124 | #define count_bytes 0 | ||
125 | #endif | 223 | #endif |
224 | } | ||
225 | if (negative_N) { | ||
226 | if (count >= INT_MAX / sizeof(char*)) | ||
227 | bb_error_msg("count is too big: %lu", count); | ||
228 | } | ||
126 | 229 | ||
127 | do { | 230 | do { |
128 | fp = fopen_or_warn_stdin(*argv); | 231 | fp = fopen_or_warn_stdin(*argv); |
@@ -133,18 +236,20 @@ int head_main(int argc, char **argv) | |||
133 | if (header_threshhold) { | 236 | if (header_threshhold) { |
134 | printf(fmt, *argv); | 237 | printf(fmt, *argv); |
135 | } | 238 | } |
136 | i = count; | 239 | if (negative_N) { |
137 | while (i && ((c = getc(fp)) != EOF)) { | 240 | if (count_bytes) { |
138 | if (count_bytes || (c == '\n')) { | 241 | print_except_N_last_bytes(fp, count); |
139 | --i; | 242 | } else { |
243 | print_except_N_last_lines(fp, count); | ||
140 | } | 244 | } |
141 | putchar(c); | 245 | } else { |
246 | print_first_N(fp, count, count_bytes); | ||
142 | } | 247 | } |
248 | die_if_ferror_stdout(); | ||
143 | if (fclose_if_not_stdin(fp)) { | 249 | if (fclose_if_not_stdin(fp)) { |
144 | bb_simple_perror_msg(*argv); | 250 | bb_simple_perror_msg(*argv); |
145 | retval = EXIT_FAILURE; | 251 | retval = EXIT_FAILURE; |
146 | } | 252 | } |
147 | die_if_ferror_stdout(); | ||
148 | } else { | 253 | } else { |
149 | retval = EXIT_FAILURE; | 254 | retval = EXIT_FAILURE; |
150 | } | 255 | } |