find.c revision 1.23 1 1.23 apb /* $NetBSD: find.c,v 1.23 2006/10/11 19:51:10 apb Exp $ */
2 1.8 tls
3 1.1 cgd /*-
4 1.10 mrg * Copyright (c) 1991, 1993, 1994
5 1.5 jtc * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * This code is derived from software contributed to Berkeley by
8 1.1 cgd * Cimarron D. Taylor of the University of California, Berkeley.
9 1.1 cgd *
10 1.1 cgd * Redistribution and use in source and binary forms, with or without
11 1.1 cgd * modification, are permitted provided that the following conditions
12 1.1 cgd * are met:
13 1.1 cgd * 1. Redistributions of source code must retain the above copyright
14 1.1 cgd * notice, this list of conditions and the following disclaimer.
15 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 cgd * notice, this list of conditions and the following disclaimer in the
17 1.1 cgd * documentation and/or other materials provided with the distribution.
18 1.18 agc * 3. Neither the name of the University nor the names of its contributors
19 1.1 cgd * may be used to endorse or promote products derived from this software
20 1.1 cgd * without specific prior written permission.
21 1.1 cgd *
22 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.1 cgd * SUCH DAMAGE.
33 1.1 cgd */
34 1.1 cgd
35 1.9 lukem #include <sys/cdefs.h>
36 1.1 cgd #ifndef lint
37 1.9 lukem #if 0
38 1.10 mrg static char sccsid[] = "from: @(#)find.c 8.5 (Berkeley) 8/5/94";
39 1.9 lukem #else
40 1.23 apb __RCSID("$NetBSD: find.c,v 1.23 2006/10/11 19:51:10 apb Exp $");
41 1.9 lukem #endif
42 1.1 cgd #endif /* not lint */
43 1.1 cgd
44 1.1 cgd #include <sys/types.h>
45 1.1 cgd #include <sys/stat.h>
46 1.5 jtc
47 1.5 jtc #include <err.h>
48 1.5 jtc #include <errno.h>
49 1.1 cgd #include <fts.h>
50 1.17 yamt #include <signal.h>
51 1.1 cgd #include <stdio.h>
52 1.1 cgd #include <string.h>
53 1.1 cgd #include <stdlib.h>
54 1.5 jtc
55 1.1 cgd #include "find.h"
56 1.1 cgd
57 1.23 apb static int ftscompare(const FTSENT **, const FTSENT **);
58 1.12 itohy
59 1.23 apb static void sig_lock(sigset_t *);
60 1.23 apb static void sig_unlock(const sigset_t *);
61 1.17 yamt
62 1.1 cgd /*
63 1.1 cgd * find_formplan --
64 1.1 cgd * process the command line and create a "plan" corresponding to the
65 1.1 cgd * command arguments.
66 1.1 cgd */
67 1.1 cgd PLAN *
68 1.23 apb find_formplan(char **argv)
69 1.1 cgd {
70 1.1 cgd PLAN *plan, *tail, *new;
71 1.1 cgd
72 1.1 cgd /*
73 1.1 cgd * for each argument in the command line, determine what kind of node
74 1.1 cgd * it is, create the appropriate node type and add the new plan node
75 1.1 cgd * to the end of the existing plan. The resulting plan is a linked
76 1.1 cgd * list of plan nodes. For example, the string:
77 1.1 cgd *
78 1.1 cgd * % find . -name foo -newer bar -print
79 1.1 cgd *
80 1.1 cgd * results in the plan:
81 1.1 cgd *
82 1.1 cgd * [-name foo]--> [-newer bar]--> [-print]
83 1.1 cgd *
84 1.1 cgd * in this diagram, `[-name foo]' represents the plan node generated
85 1.1 cgd * by c_name() with an argument of foo and `-->' represents the
86 1.1 cgd * plan->next pointer.
87 1.1 cgd */
88 1.5 jtc for (plan = tail = NULL; *argv;) {
89 1.1 cgd if (!(new = find_create(&argv)))
90 1.1 cgd continue;
91 1.1 cgd if (plan == NULL)
92 1.1 cgd tail = plan = new;
93 1.1 cgd else {
94 1.1 cgd tail->next = new;
95 1.1 cgd tail = new;
96 1.1 cgd }
97 1.1 cgd }
98 1.12 itohy
99 1.1 cgd /*
100 1.21 jschauma * if the user didn't specify one of -print, -ok, -fprint, -exec, or
101 1.21 jschauma * -exit, then -print is assumed so we bracket the current expression
102 1.21 jschauma * with parens, if necessary, and add a -print node on the end.
103 1.1 cgd */
104 1.1 cgd if (!isoutput) {
105 1.6 cgd if (plan == NULL) {
106 1.11 christos new = c_print(NULL, 0);
107 1.1 cgd tail = plan = new;
108 1.6 cgd } else {
109 1.11 christos new = c_openparen(NULL, 0);
110 1.6 cgd new->next = plan;
111 1.6 cgd plan = new;
112 1.11 christos new = c_closeparen(NULL, 0);
113 1.6 cgd tail->next = new;
114 1.6 cgd tail = new;
115 1.11 christos new = c_print(NULL, 0);
116 1.1 cgd tail->next = new;
117 1.1 cgd tail = new;
118 1.1 cgd }
119 1.1 cgd }
120 1.12 itohy
121 1.1 cgd /*
122 1.1 cgd * the command line has been completely processed into a search plan
123 1.1 cgd * except for the (, ), !, and -o operators. Rearrange the plan so
124 1.1 cgd * that the portions of the plan which are affected by the operators
125 1.1 cgd * are moved into operator nodes themselves. For example:
126 1.1 cgd *
127 1.1 cgd * [!]--> [-name foo]--> [-print]
128 1.1 cgd *
129 1.1 cgd * becomes
130 1.1 cgd *
131 1.1 cgd * [! [-name foo] ]--> [-print]
132 1.1 cgd *
133 1.1 cgd * and
134 1.1 cgd *
135 1.1 cgd * [(]--> [-depth]--> [-name foo]--> [)]--> [-print]
136 1.1 cgd *
137 1.1 cgd * becomes
138 1.1 cgd *
139 1.1 cgd * [expr [-depth]-->[-name foo] ]--> [-print]
140 1.1 cgd *
141 1.1 cgd * operators are handled in order of precedence.
142 1.1 cgd */
143 1.1 cgd
144 1.1 cgd plan = paren_squish(plan); /* ()'s */
145 1.1 cgd plan = not_squish(plan); /* !'s */
146 1.1 cgd plan = or_squish(plan); /* -o's */
147 1.5 jtc return (plan);
148 1.1 cgd }
149 1.12 itohy
150 1.12 itohy static int
151 1.23 apb ftscompare(const FTSENT **e1, const FTSENT **e2)
152 1.12 itohy {
153 1.14 enami
154 1.14 enami return (strcoll((*e1)->fts_name, (*e2)->fts_name));
155 1.12 itohy }
156 1.12 itohy
157 1.17 yamt static void
158 1.23 apb sig_lock(sigset_t *s)
159 1.17 yamt {
160 1.17 yamt sigset_t new;
161 1.17 yamt
162 1.17 yamt sigemptyset(&new);
163 1.17 yamt sigaddset(&new, SIGINFO); /* block SIGINFO */
164 1.17 yamt sigprocmask(SIG_BLOCK, &new, s);
165 1.17 yamt }
166 1.17 yamt
167 1.17 yamt static void
168 1.23 apb sig_unlock(const sigset_t *s)
169 1.17 yamt {
170 1.17 yamt
171 1.17 yamt sigprocmask(SIG_SETMASK, s, NULL);
172 1.17 yamt }
173 1.17 yamt
174 1.1 cgd FTS *tree; /* pointer to top of FTS hierarchy */
175 1.16 yamt FTSENT *g_entry; /* shared with SIGINFO handler */
176 1.1 cgd
177 1.1 cgd /*
178 1.1 cgd * find_execute --
179 1.1 cgd * take a search plan and an array of search paths and executes the plan
180 1.1 cgd * over all FTSENT's returned for the given search paths.
181 1.1 cgd */
182 1.10 mrg int
183 1.23 apb find_execute(PLAN *plan, char **paths)
184 1.1 cgd {
185 1.1 cgd PLAN *p;
186 1.22 apb int r, rval, cval;
187 1.17 yamt sigset_t s;
188 1.12 itohy
189 1.21 jschauma cval = 1;
190 1.21 jschauma
191 1.12 itohy if (!(tree = fts_open(paths, ftsoptions, issort ? ftscompare : NULL)))
192 1.5 jtc err(1, "ftsopen");
193 1.1 cgd
194 1.17 yamt sig_lock(&s);
195 1.21 jschauma for (rval = 0; cval && (g_entry = fts_read(tree)) != NULL; sig_lock(&s)) {
196 1.17 yamt sig_unlock(&s);
197 1.16 yamt switch (g_entry->fts_info) {
198 1.1 cgd case FTS_D:
199 1.1 cgd if (isdepth)
200 1.1 cgd continue;
201 1.1 cgd break;
202 1.1 cgd case FTS_DP:
203 1.1 cgd if (!isdepth)
204 1.1 cgd continue;
205 1.1 cgd break;
206 1.1 cgd case FTS_DNR:
207 1.1 cgd case FTS_ERR:
208 1.1 cgd case FTS_NS:
209 1.5 jtc (void)fflush(stdout);
210 1.10 mrg warnx("%s: %s",
211 1.16 yamt g_entry->fts_path, strerror(g_entry->fts_errno));
212 1.10 mrg rval = 1;
213 1.1 cgd continue;
214 1.1 cgd }
215 1.1 cgd #define BADCH " \t\n\\'\""
216 1.16 yamt if (isxargs && strpbrk(g_entry->fts_path, BADCH)) {
217 1.5 jtc (void)fflush(stdout);
218 1.16 yamt warnx("%s: illegal path", g_entry->fts_path);
219 1.10 mrg rval = 1;
220 1.1 cgd continue;
221 1.1 cgd }
222 1.12 itohy
223 1.1 cgd /*
224 1.10 mrg * Call all the functions in the execution plan until one is
225 1.1 cgd * false or all have been executed. This is where we do all
226 1.1 cgd * the work specified by the user on the command line.
227 1.1 cgd */
228 1.16 yamt for (p = plan; p && (p->eval)(p, g_entry); p = p->next)
229 1.21 jschauma if (p->type == N_EXIT) {
230 1.21 jschauma rval = p->exit_val;
231 1.21 jschauma cval = 0;
232 1.21 jschauma }
233 1.1 cgd }
234 1.21 jschauma
235 1.17 yamt sig_unlock(&s);
236 1.10 mrg if (errno)
237 1.10 mrg err(1, "fts_read");
238 1.1 cgd (void)fts_close(tree);
239 1.22 apb
240 1.22 apb /*
241 1.22 apb * Cleanup any plans with leftover state.
242 1.22 apb * Keep the last non-zero return value.
243 1.22 apb */
244 1.22 apb if ((r = find_traverse(plan, plan_cleanup, NULL)) != 0)
245 1.22 apb rval = r;
246 1.22 apb
247 1.10 mrg return (rval);
248 1.1 cgd }
249 1.22 apb
250 1.22 apb /*
251 1.22 apb * find_traverse --
252 1.22 apb * traverse the plan tree and execute func() on all plans. This
253 1.22 apb * does not evaluate each plan's eval() function; it is intended
254 1.22 apb * for operations that must run on all plans, such as state
255 1.22 apb * cleanup.
256 1.22 apb *
257 1.22 apb * If any func() returns non-zero, then so will find_traverse().
258 1.22 apb */
259 1.22 apb int
260 1.22 apb find_traverse(plan, func, arg)
261 1.22 apb PLAN *plan;
262 1.23 apb int (*func)(PLAN *, void *);
263 1.22 apb void *arg;
264 1.22 apb {
265 1.22 apb PLAN *p;
266 1.22 apb int r, rval;
267 1.22 apb
268 1.22 apb rval = 0;
269 1.22 apb for (p = plan; p; p = p->next) {
270 1.22 apb if ((r = func(p, arg)) != 0)
271 1.22 apb rval = r;
272 1.22 apb if (p->type == N_EXPR || p->type == N_OR) {
273 1.22 apb if (p->p_data[0])
274 1.22 apb if ((r = find_traverse(p->p_data[0],
275 1.22 apb func, arg)) != 0)
276 1.22 apb rval = r;
277 1.22 apb if (p->p_data[1])
278 1.22 apb if ((r = find_traverse(p->p_data[1],
279 1.22 apb func, arg)) != 0)
280 1.22 apb rval = r;
281 1.22 apb }
282 1.22 apb }
283 1.22 apb return rval;
284 1.22 apb }
285