Whamcloud - gitweb
LU-16977 utils: access_log_reader accesses beyond batch array
[fs/lustre-release.git] / lustre / utils / gss / svcgssd.c
1 /*
2  * gssd.c
3  *
4  * Copyright (c) 2000 The Regents of the University of Michigan.
5  * All rights reserved.
6  *
7  * Copyright (c) 2000 Dug Song <dugsong@UMICH.EDU>.
8  * Copyright (c) 2002 Andy Adamson <andros@UMICH.EDU>.
9  * Copyright (c) 2002 Marius Aamodt Eriksen <marius@UMICH.EDU>.
10  * Copyright (c) 2002 J. Bruce Fields <bfields@UMICH.EDU>.
11  *
12  * Copyright (c) 2016, Intel Corporation.
13  *
14  * All rights reserved, all wrongs reversed.
15  *
16  * Redistribution and use in source and binary forms, with or without
17  * modification, are permitted provided that the following conditions
18  * are met:
19  *
20  * 1. Redistributions of source code must retain the above copyright
21  *    notice, this list of conditions and the following disclaimer.
22  * 2. Redistributions in binary form must reproduce the above copyright
23  *    notice, this list of conditions and the following disclaimer in the
24  *    documentation and/or other materials provided with the distribution.
25  * 3. Neither the name of the University nor the names of its
26  *    contributors may be used to endorse or promote products derived
27  *    from this software without specific prior written permission.
28  *
29  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
30  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
31  * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
32  * DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
33  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
34  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
35  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
36  * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
37  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
38  * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
39  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
40  */
41
42 #include "config.h"
43
44 #include <sys/param.h>
45 #include <sys/types.h>
46 #include <sys/stat.h>
47 #include <sys/socket.h>
48 #include <fcntl.h>
49 #include <errno.h>
50
51 #include <unistd.h>
52 #include <err.h>
53 #include <stdio.h>
54 #include <stdlib.h>
55 #include <string.h>
56 #include <signal.h>
57 #include <dirent.h>
58 #include "svcgssd.h"
59 #include "gss_util.h"
60 #include "err_util.h"
61 #include "lsupport.h"
62 #include <linux/lustre/lustre_ver.h>
63
64 int null_enabled;
65 int krb_enabled;
66 int sk_enabled;
67
68 void
69 closeall(int min)
70 {
71         DIR *dir = opendir("/proc/self/fd");
72         if (dir != NULL) {
73                 int dfd = dirfd(dir);
74                 struct dirent *d;
75
76                 while ((d = readdir(dir)) != NULL) {
77                         char *endp;
78                         long n = strtol(d->d_name, &endp, 10);
79                         if (*endp != '\0' && n >= min && n != dfd)
80                                 (void) close(n);
81                 }
82                 closedir(dir);
83         } else {
84                 int fd = sysconf(_SC_OPEN_MAX);
85                 while (--fd >= min)
86                         (void) close(fd);
87         }
88 }
89
90 /*
91  * mydaemon creates a pipe between the partent and child
92  * process. The parent process will wait until the
93  * child dies or writes a '1' on the pipe signaling
94  * that it started successfully.
95  */
96 int pipefds[2] = { -1, -1};
97
98 static void
99 mydaemon(int nochdir, int noclose)
100 {
101         int pid, status, tempfd;
102
103         if (pipe(pipefds) < 0) {
104                 printerr(LL_ERR, "%s: pipe() failed: errno %d (%s)\n",
105                          __func__, errno, strerror(errno));
106                 exit(1);
107         }
108         if ((pid = fork ()) < 0) {
109                 printerr(LL_ERR, "%s: fork() failed: errno %d (%s)\n",
110                          __func__, errno, strerror(errno));
111                 exit(1);
112         }
113
114         if (pid != 0) {
115                 /*
116                  * Parent. Wait for status from child.
117                  */
118                 close(pipefds[1]);
119                 if (read(pipefds[0], &status, 1) != 1)
120                         exit(1);
121                 exit (0);
122         }
123         /* Child.       */
124         close(pipefds[0]);
125         setsid ();
126         if (nochdir == 0) {
127                 if (chdir ("/") == -1) {
128                         printerr(LL_ERR,
129                                  "%s: chdir() failed: errno %d (%s)\n",
130                                  __func__, errno, strerror(errno));
131                         exit(1);
132                 }
133         }
134
135         while (pipefds[1] <= 2) {
136                 pipefds[1] = dup(pipefds[1]);
137                 if (pipefds[1] < 0) {
138                         printerr(LL_ERR, "%s: dup() failed: errno %d (%s)\n",
139                                  __func__, errno, strerror(errno));
140                         exit(1);
141                 }
142         }
143
144         if (noclose == 0) {
145                 tempfd = open("/dev/null", O_RDWR);
146                 dup2(tempfd, 0);
147                 dup2(tempfd, 1);
148                 dup2(tempfd, 2);
149                 closeall(3);
150         }
151 }
152
153 static void
154 release_parent()
155 {
156         int status;
157         ssize_t sret __attribute__ ((unused));
158
159         if (pipefds[1] > 0) {
160                 sret = write(pipefds[1], &status, 1);
161                 close(pipefds[1]);
162                 pipefds[1] = -1;
163         }
164 }
165
166 void
167 sig_die(int signal)
168 {
169         /* destroy krb5 machine creds */
170         cleanup_mapping();
171         printerr(LL_WARN, "exiting on signal %d\n", signal);
172         exit(1);
173 }
174
175 void
176 sig_hup(int signal)
177 {
178         /* don't exit on SIGHUP */
179         printerr(LL_WARN, "Received SIGHUP... Ignoring.\n");
180 }
181
182 static void
183 usage(FILE *fp, char *progname)
184 {
185         fprintf(fp, "usage: %s [ -fnvmogk ]\n",
186                 progname);
187         fprintf(stderr, "-f      - Run in foreground\n");
188         fprintf(stderr, "-n      - Don't establish kerberos credentials\n");
189         fprintf(stderr, "-v      - Verbosity\n");
190         fprintf(stderr, "-m      - Service MDS\n");
191         fprintf(stderr, "-o      - Service OSS\n");
192         fprintf(stderr, "-g      - Service MGS\n");
193         fprintf(stderr, "-k      - Enable kerberos support\n");
194 #ifdef HAVE_OPENSSL_SSK
195         fprintf(stderr, "-s      - Enable shared secret key support\n");
196 #endif
197         fprintf(stderr, "-z      - Enable gssnull support\n");
198
199         exit(fp == stderr);
200 }
201
202 int
203 main(int argc, char *argv[])
204 {
205         int get_creds = 1;
206         int fg = 0;
207         int verbosity = 0;
208         int opt;
209         int must_srv_mds = 0, must_srv_oss = 0, must_srv_mgs = 0;
210         char *progname;
211
212         while ((opt = getopt(argc, argv, "fnvmogksz")) != -1) {
213                 switch (opt) {
214                 case 'f':
215                         fg = 1;
216                         break;
217                 case 'n':
218                         get_creds = 0;
219                         break;
220                 case 'v':
221                         verbosity++;
222                         break;
223                 case 'm':
224                         get_creds = 1;
225                         must_srv_mds = 1;
226                         break;
227                 case 'o':
228                         get_creds = 1;
229                         must_srv_oss = 1;
230                         break;
231                 case 'g':
232                         get_creds = 1;
233                         must_srv_mgs = 1;
234                         break;
235                 case 'k':
236                         krb_enabled = 1;
237                         break;
238                 case 'h':
239                         usage(stdout, argv[0]);
240                         break;
241                 case 's':
242 #ifdef HAVE_OPENSSL_SSK
243                         sk_enabled = 1;
244 #else
245                         fprintf(stderr, "error: request for SSK but service "
246                                 "support not enabled\n");
247                         usage(stderr, argv[0]);
248 #endif
249                         break;
250                 case 'z':
251                         null_enabled = 1;
252                         break;
253                 default:
254                         usage(stderr, argv[0]);
255                         break;
256                 }
257         }
258
259         if ((progname = strrchr(argv[0], '/')))
260                 progname++;
261         else
262                 progname = argv[0];
263
264         if (!sk_enabled && !krb_enabled && !null_enabled) {
265 #if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(3, 0, 53, 0)
266                 fprintf(stderr, "warning: no -k, -s, or -z option given, "
267                         "assume -k for backward compatibility\n");
268                 krb_enabled = 1;
269 #else
270                 fprintf(stderr, "error: need one of -k, -s, or -z options\n");
271                 usage(stderr, argv[0]);
272
273 #endif
274         }
275         initerr(progname, verbosity, fg);
276
277         /* For kerberos use gss mechanisms but ignore for sk and null */
278         if (krb_enabled) {
279                 if (gssd_check_mechs()) {
280                         printerr(LL_ERR,
281                                  "ERROR: problem with gssapi library\n");
282                         exit(1);
283                 }
284                 if (gssd_get_local_realm()) {
285                         printerr(LL_ERR,
286                                  "ERROR: Can't get Local Kerberos realm\n");
287                         exit(1);
288                 }
289
290                 if (get_creds &&
291                     gssd_prepare_creds(must_srv_mgs, must_srv_mds,
292                                        must_srv_oss)) {
293                         printerr(LL_ERR,
294                                  "unable to obtain root (machine) credentials\n");
295                         printerr(LL_ERR,
296                                  "do you have a keytab entry for <lustre_xxs>/<your.host>@<YOUR.REALM> in /etc/krb5.keytab?\n");
297                         exit(1);
298                 }
299         }
300
301         if (!fg)
302                 mydaemon(0, 0);
303
304         /*
305          * XXX: There is risk of memory leak for missing call
306          *      cleanup_mapping() for SIGKILL and SIGSTOP.
307          */
308         signal(SIGINT, sig_die);
309         signal(SIGTERM, sig_die);
310         signal(SIGHUP, sig_hup);
311
312         if (!fg)
313                 release_parent();
314
315         gssd_init_unique(GSSD_SVC);
316
317         svcgssd_run();
318         cleanup_mapping();
319         printerr(LL_ERR, "svcgssd_run returned!\n");
320         abort();
321 }