fuse: Set UID and GID when performing FUSE tests.
[libguestfs.git] / fuse / guestmount.c
1 /* guestmount - mount guests using libguestfs and FUSE
2  * Copyright (C) 2009-2010 Red Hat Inc.
3  *
4  * This program is free software; you can redistribute it and/or modify
5  * it under the terms of the GNU General Public License as published by
6  * the Free Software Foundation; either version 2 of the License, or
7  * (at your option) any later version.
8  *
9  * This program is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write to the Free Software
16  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
17  *
18  * Derived from the example program 'fusexmp.c':
19  * Copyright (C) 2001-2007  Miklos Szeredi <miklos@szeredi.hu>
20  *
21  * This program can be distributed under the terms of the GNU GPL.
22  * See the file COPYING.
23  */
24
25 #define FUSE_USE_VERSION 26
26
27 #include <config.h>
28
29 #include <stdio.h>
30 #include <stdlib.h>
31 #include <stdint.h>
32 #include <inttypes.h>
33 #include <string.h>
34 #include <unistd.h>
35 #include <getopt.h>
36 #include <fcntl.h>
37 #include <dirent.h>
38 #include <errno.h>
39 #include <signal.h>
40 #include <time.h>
41 #include <assert.h>
42 #include <sys/time.h>
43 #include <sys/types.h>
44 #include <locale.h>
45
46 #include <fuse.h>
47 #include <guestfs.h>
48
49 #include "progname.h"
50
51 #include "guestmount.h"
52 #include "options.h"
53 #include "dircache.h"
54
55 /* See <attr/xattr.h> */
56 #ifndef ENOATTR
57 #define ENOATTR ENODATA
58 #endif
59
60 guestfs_h *g = NULL;
61 int read_only = 0;
62 int verbose = 0;
63 int inspector = 0;
64 int keys_from_stdin = 0;
65 int echo_keys = 0;
66 const char *libvirt_uri;
67 int dir_cache_timeout = 60;
68
69 static int
70 error (void)
71 {
72   return -guestfs_last_errno (g);
73 }
74
75 static struct guestfs_xattr_list *
76 copy_xattr_list (const struct guestfs_xattr *first, size_t num)
77 {
78   struct guestfs_xattr_list *xattrs;
79
80   xattrs = malloc (sizeof *xattrs);
81   if (xattrs == NULL) {
82     perror ("malloc");
83     return NULL;
84   }
85
86   xattrs->len = num;
87   xattrs->val = malloc (num * sizeof (struct guestfs_xattr));
88   if (xattrs->val == NULL) {
89     perror ("malloc");
90     free (xattrs);
91     return NULL;
92   }
93
94   size_t i;
95   for (i = 0; i < num; ++i) {
96     xattrs->val[i].attrname = strdup (first[i].attrname);
97     xattrs->val[i].attrval_len = first[i].attrval_len;
98     xattrs->val[i].attrval = malloc (first[i].attrval_len);
99     memcpy (xattrs->val[i].attrval, first[i].attrval, first[i].attrval_len);
100   }
101
102   return xattrs;
103 }
104
105 static int
106 fg_readdir (const char *path, void *buf, fuse_fill_dir_t filler,
107             off_t offset, struct fuse_file_info *fi)
108 {
109   time_t now;
110   time (&now);
111
112   dir_cache_remove_all_expired (now);
113
114   struct guestfs_dirent_list *ents;
115
116   ents = guestfs_readdir (g, path);
117   if (ents == NULL)
118     return error ();
119
120   size_t i;
121   for (i = 0; i < ents->len; ++i) {
122     struct stat stat;
123     memset (&stat, 0, sizeof stat);
124
125     stat.st_ino = ents->val[i].ino;
126     switch (ents->val[i].ftyp) {
127     case 'b': stat.st_mode = S_IFBLK; break;
128     case 'c': stat.st_mode = S_IFCHR; break;
129     case 'd': stat.st_mode = S_IFDIR; break;
130     case 'f': stat.st_mode = S_IFIFO; break;
131     case 'l': stat.st_mode = S_IFLNK; break;
132     case 'r': stat.st_mode = S_IFREG; break;
133     case 's': stat.st_mode = S_IFSOCK; break;
134     case 'u':
135     case '?':
136     default:  stat.st_mode = 0;
137     }
138
139     /* Copied from the example, which also ignores 'offset'.  I'm
140      * not quite sure how this is ever supposed to work on large
141      * directories. XXX
142      */
143     if (filler (buf, ents->val[i].name, &stat, 0))
144       break;
145   }
146
147   /* Now prepopulate the directory caches.  This step is just an
148    * optimization, don't worry if it fails.
149    */
150   char **names = malloc ((ents->len + 1) * sizeof (char *));
151   if (names) {
152     for (i = 0; i < ents->len; ++i)
153       names[i] = ents->val[i].name;
154     names[i] = NULL;
155
156     struct guestfs_stat_list *ss = guestfs_lstatlist (g, path, names);
157     if (ss) {
158       for (i = 0; i < ss->len; ++i) {
159         if (ss->val[i].ino >= 0) {
160           struct stat statbuf;
161
162           statbuf.st_dev = ss->val[i].dev;
163           statbuf.st_ino = ss->val[i].ino;
164           statbuf.st_mode = ss->val[i].mode;
165           statbuf.st_nlink = ss->val[i].nlink;
166           statbuf.st_uid = ss->val[i].uid;
167           statbuf.st_gid = ss->val[i].gid;
168           statbuf.st_rdev = ss->val[i].rdev;
169           statbuf.st_size = ss->val[i].size;
170           statbuf.st_blksize = ss->val[i].blksize;
171           statbuf.st_blocks = ss->val[i].blocks;
172           statbuf.st_atime = ss->val[i].atime;
173           statbuf.st_mtime = ss->val[i].mtime;
174           statbuf.st_ctime = ss->val[i].ctime;
175
176           lsc_insert (path, names[i], now, &statbuf);
177         }
178       }
179       guestfs_free_stat_list (ss);
180     }
181
182     struct guestfs_xattr_list *xattrs = guestfs_lxattrlist (g, path, names);
183     if (xattrs) {
184       size_t ni, num;
185       struct guestfs_xattr *first;
186       struct guestfs_xattr_list *copy;
187       for (i = 0, ni = 0; i < xattrs->len; ++i, ++ni) {
188         assert (strlen (xattrs->val[i].attrname) == 0);
189         if (xattrs->val[i].attrval_len > 0) {
190           ++i;
191           first = &xattrs->val[i];
192           num = 0;
193           for (; i < xattrs->len && strlen (xattrs->val[i].attrname) > 0; ++i)
194             num++;
195
196           copy = copy_xattr_list (first, num);
197           if (copy)
198             xac_insert (path, names[ni], now, copy);
199
200           i--;
201         }
202       }
203       guestfs_free_xattr_list (xattrs);
204     }
205
206     char **links = guestfs_readlinklist (g, path, names);
207     if (links) {
208       for (i = 0; names[i] != NULL; ++i) {
209         if (links[i][0])
210           /* Note that rlc_insert owns the string links[i] after this, */
211           rlc_insert (path, names[i], now, links[i]);
212         else
213           /* which is why we have to free links[i] here. */
214           free (links[i]);
215       }
216       free (links);             /* free the array, not the strings */
217     }
218
219     free (names);
220   }
221
222   guestfs_free_dirent_list (ents);
223
224   return 0;
225 }
226
227 static int
228 fg_getattr (const char *path, struct stat *statbuf)
229 {
230   const struct stat *buf;
231
232   buf = lsc_lookup (path);
233   if (buf) {
234     memcpy (statbuf, buf, sizeof *statbuf);
235     return 0;
236   }
237
238   struct guestfs_stat *r;
239
240   r = guestfs_lstat (g, path);
241   if (r == NULL)
242     return error ();
243
244   statbuf->st_dev = r->dev;
245   statbuf->st_ino = r->ino;
246   statbuf->st_mode = r->mode;
247   statbuf->st_nlink = r->nlink;
248   statbuf->st_uid = r->uid;
249   statbuf->st_gid = r->gid;
250   statbuf->st_rdev = r->rdev;
251   statbuf->st_size = r->size;
252   statbuf->st_blksize = r->blksize;
253   statbuf->st_blocks = r->blocks;
254   statbuf->st_atime = r->atime;
255   statbuf->st_mtime = r->mtime;
256   statbuf->st_ctime = r->ctime;
257
258   guestfs_free_stat (r);
259
260   return 0;
261 }
262
263 /* Nautilus loves to use access(2) to test everything about a file,
264  * such as whether it's executable.  Therefore treat this a lot like
265  * fg_getattr.
266  */
267 static int
268 fg_access (const char *path, int mask)
269 {
270   struct stat statbuf;
271   int r;
272
273   if (read_only && (mask & W_OK))
274     return -EROFS;
275
276   r = fg_getattr (path, &statbuf);
277   if (r < 0 || mask == F_OK)
278     return r;
279
280   struct fuse_context *fuse = fuse_get_context ();
281   int ok = 1;
282
283   if (mask & R_OK)
284     ok = ok &&
285       (  fuse->uid == statbuf.st_uid ? statbuf.st_mode & S_IRUSR
286        : fuse->gid == statbuf.st_gid ? statbuf.st_mode & S_IRGRP
287        : statbuf.st_mode & S_IROTH);
288   if (mask & W_OK)
289     ok = ok &&
290       (  fuse->uid == statbuf.st_uid ? statbuf.st_mode & S_IWUSR
291        : fuse->gid == statbuf.st_gid ? statbuf.st_mode & S_IWGRP
292        : statbuf.st_mode & S_IWOTH);
293   if (mask & X_OK)
294     ok = ok &&
295       (  fuse->uid == statbuf.st_uid ? statbuf.st_mode & S_IXUSR
296        : fuse->gid == statbuf.st_gid ? statbuf.st_mode & S_IXGRP
297        : statbuf.st_mode & S_IXOTH);
298
299   return ok ? 0 : -EACCES;
300 }
301
302 static int
303 fg_readlink (const char *path, char *buf, size_t size)
304 {
305   const char *r;
306   int free_it = 0;
307
308   r = rlc_lookup (path);
309   if (!r) {
310     r = guestfs_readlink (g, path);
311     if (r == NULL)
312       return error ();
313     free_it = 1;
314   }
315
316   /* Note this is different from the real readlink(2) syscall.  FUSE wants
317    * the string to be always nul-terminated, even if truncated.
318    */
319   size_t len = strlen (r);
320   if (len > size - 1)
321     len = size - 1;
322
323   memcpy (buf, r, len);
324   buf[len] = '\0';
325
326   if (free_it) {
327     char *tmp = (char *) r;
328     free (tmp);
329   }
330
331   return 0;
332 }
333
334 static int
335 fg_mknod (const char *path, mode_t mode, dev_t rdev)
336 {
337   int r;
338
339   if (read_only) return -EROFS;
340
341   dir_cache_invalidate (path);
342
343   r = guestfs_mknod (g, mode, major (rdev), minor (rdev), path);
344   if (r == -1)
345     return error ();
346
347   return 0;
348 }
349
350 static int
351 fg_mkdir (const char *path, mode_t mode)
352 {
353   int r;
354
355   if (read_only) return -EROFS;
356
357   dir_cache_invalidate (path);
358
359   r = guestfs_mkdir_mode (g, path, mode);
360   if (r == -1)
361     return error ();
362
363   return 0;
364 }
365
366 static int
367 fg_unlink (const char *path)
368 {
369   int r;
370
371   if (read_only) return -EROFS;
372
373   dir_cache_invalidate (path);
374
375   r = guestfs_rm (g, path);
376   if (r == -1)
377     return error ();
378
379   return 0;
380 }
381
382 static int
383 fg_rmdir (const char *path)
384 {
385   int r;
386
387   if (read_only) return -EROFS;
388
389   dir_cache_invalidate (path);
390
391   r = guestfs_rmdir (g, path);
392   if (r == -1)
393     return error ();
394
395   return 0;
396 }
397
398 static int
399 fg_symlink (const char *from, const char *to)
400 {
401   int r;
402
403   if (read_only) return -EROFS;
404
405   dir_cache_invalidate (to);
406
407   r = guestfs_ln_s (g, from, to);
408   if (r == -1)
409     return error ();
410
411   return 0;
412 }
413
414 static int
415 fg_rename (const char *from, const char *to)
416 {
417   int r;
418
419   if (read_only) return -EROFS;
420
421   dir_cache_invalidate (from);
422   dir_cache_invalidate (to);
423
424   /* XXX It's not clear how close the 'mv' command is to the
425    * rename syscall.  We might need to add the rename syscall
426    * to the guestfs(3) API.
427    */
428   r = guestfs_mv (g, from, to);
429   if (r == -1)
430     return error ();
431
432   return 0;
433 }
434
435 static int
436 fg_link (const char *from, const char *to)
437 {
438   int r;
439
440   if (read_only) return -EROFS;
441
442   dir_cache_invalidate (from);
443   dir_cache_invalidate (to);
444
445   r = guestfs_ln (g, from, to);
446   if (r == -1)
447     return error ();
448
449   return 0;
450 }
451
452 static int
453 fg_chmod (const char *path, mode_t mode)
454 {
455   int r;
456
457   if (read_only) return -EROFS;
458
459   dir_cache_invalidate (path);
460
461   r = guestfs_chmod (g, mode, path);
462   if (r == -1)
463     return error ();
464
465   return 0;
466 }
467
468 static int
469 fg_chown (const char *path, uid_t uid, gid_t gid)
470 {
471   int r;
472
473   if (read_only) return -EROFS;
474
475   dir_cache_invalidate (path);
476
477   r = guestfs_lchown (g, uid, gid, path);
478   if (r == -1)
479     return error ();
480
481   return 0;
482 }
483
484 static int
485 fg_truncate (const char *path, off_t size)
486 {
487   int r;
488
489   if (read_only) return -EROFS;
490
491   dir_cache_invalidate (path);
492
493   r = guestfs_truncate_size (g, path, size);
494   if (r == -1)
495     return error ();
496
497   return 0;
498 }
499
500 static int
501 fg_utimens (const char *path, const struct timespec ts[2])
502 {
503   int r;
504
505   if (read_only) return -EROFS;
506
507   dir_cache_invalidate (path);
508
509   time_t atsecs = ts[0].tv_sec;
510   long atnsecs = ts[0].tv_nsec;
511   time_t mtsecs = ts[1].tv_sec;
512   long mtnsecs = ts[1].tv_nsec;
513
514 #ifdef UTIME_NOW
515   if (atnsecs == UTIME_NOW)
516     atnsecs = -1;
517 #endif
518 #ifdef UTIME_OMIT
519   if (atnsecs == UTIME_OMIT)
520     atnsecs = -2;
521 #endif
522 #ifdef UTIME_NOW
523   if (mtnsecs == UTIME_NOW)
524     mtnsecs = -1;
525 #endif
526 #ifdef UTIME_OMIT
527   if (mtnsecs == UTIME_OMIT)
528     mtnsecs = -2;
529 #endif
530
531   r = guestfs_utimens (g, path, atsecs, atnsecs, mtsecs, mtnsecs);
532   if (r == -1)
533     return error ();
534
535   return 0;
536 }
537
538 /* All this function needs to do is to check that the requested open
539  * flags are valid.  See the notes in <fuse/fuse.h>.
540  */
541 static int
542 fg_open (const char *path, struct fuse_file_info *fi)
543 {
544   int flags = fi->flags & 3;
545
546   if (read_only && flags != O_RDONLY)
547     return -EROFS;
548
549   return 0;
550 }
551
552 static int
553 fg_read (const char *path, char *buf, size_t size, off_t offset,
554          struct fuse_file_info *fi)
555 {
556   char *r;
557   size_t rsize;
558
559   if (verbose)
560     fprintf (stderr, "fg_read: %s: size %zu offset %ju\n",
561              path, size, offset);
562
563   /* The guestfs protocol limits size to somewhere over 2MB.  We just
564    * reduce the requested size here accordingly and push the problem
565    * up to every user.  http://www.jwz.org/doc/worse-is-better.html
566    */
567   const size_t limit = 2 * 1024 * 1024;
568   if (size > limit)
569     size = limit;
570
571   r = guestfs_pread (g, path, size, offset, &rsize);
572   if (r == NULL)
573     return error ();
574
575   /* This should never happen, but at least it stops us overflowing
576    * the output buffer if it does happen.
577    */
578   if (rsize > size)
579     rsize = size;
580
581   memcpy (buf, r, rsize);
582   free (r);
583
584   return rsize;
585 }
586
587 static int
588 fg_write (const char *path, const char *buf, size_t size,
589           off_t offset, struct fuse_file_info *fi)
590 {
591   if (read_only) return -EROFS;
592
593   dir_cache_invalidate (path);
594
595   /* See fg_read. */
596   const size_t limit = 2 * 1024 * 1024;
597   if (size > limit)
598     size = limit;
599
600   int r;
601   r = guestfs_pwrite (g, path, buf, size, offset);
602   if (r == -1)
603     return error ();
604
605   return r;
606 }
607
608 static int
609 fg_statfs (const char *path, struct statvfs *stbuf)
610 {
611   struct guestfs_statvfs *r;
612
613   r = guestfs_statvfs (g, path);
614   if (r == NULL)
615     return error ();
616
617   stbuf->f_bsize = r->bsize;
618   stbuf->f_frsize = r->frsize;
619   stbuf->f_blocks = r->blocks;
620   stbuf->f_bfree = r->bfree;
621   stbuf->f_bavail = r->bavail;
622   stbuf->f_files = r->files;
623   stbuf->f_ffree = r->ffree;
624   stbuf->f_favail = r->favail;
625   stbuf->f_fsid = r->fsid;
626   stbuf->f_flag = r->flag;
627   stbuf->f_namemax = r->namemax;
628
629   guestfs_free_statvfs (r);
630
631   return 0;
632 }
633
634 static int
635 fg_release (const char *path, struct fuse_file_info *fi)
636 {
637   /* Just a stub. This method is optional and can safely be left
638    * unimplemented.
639    */
640   return 0;
641 }
642
643 /* Emulate this by calling sync. */
644 static int fg_fsync(const char *path, int isdatasync,
645                      struct fuse_file_info *fi)
646 {
647   int r;
648
649   r = guestfs_sync (g);
650   if (r == -1)
651     return error ();
652
653   return 0;
654 }
655
656 static int
657 fg_setxattr (const char *path, const char *name, const char *value,
658              size_t size, int flags)
659 {
660   int r;
661
662   if (read_only) return -EROFS;
663
664   dir_cache_invalidate (path);
665
666   /* XXX Underlying guestfs(3) API doesn't understand the flags. */
667   r = guestfs_lsetxattr (g, name, value, size, path);
668   if (r == -1)
669     return error ();
670
671   return 0;
672 }
673
674 /* The guestfs(3) API for getting xattrs is much easier to use
675  * than the real syscall.  Unfortunately we now have to emulate
676  * the real syscall using that API :-(
677  */
678 static int
679 fg_getxattr (const char *path, const char *name, char *value,
680              size_t size)
681 {
682   const struct guestfs_xattr_list *xattrs;
683   int free_attrs = 0;
684
685   xattrs = xac_lookup (path);
686   if (xattrs == NULL) {
687     xattrs = guestfs_lgetxattrs (g, path);
688     if (xattrs == NULL)
689       return error ();
690     free_attrs = 1;
691   }
692
693   size_t i;
694   int r = -ENOATTR;
695   for (i = 0; i < xattrs->len; ++i) {
696     if (STREQ (xattrs->val[i].attrname, name)) {
697       size_t sz = xattrs->val[i].attrval_len;
698       if (sz > size)
699         sz = size;
700       memcpy (value, xattrs->val[i].attrval, sz);
701       r = 0;
702       break;
703     }
704   }
705
706   if (free_attrs)
707     guestfs_free_xattr_list ((struct guestfs_xattr_list *) xattrs);
708
709   return r;
710 }
711
712 /* Ditto as above. */
713 static int
714 fg_listxattr (const char *path, char *list, size_t size)
715 {
716   const struct guestfs_xattr_list *xattrs;
717   int free_attrs = 0;
718
719   xattrs = xac_lookup (path);
720   if (xattrs == NULL) {
721     xattrs = guestfs_lgetxattrs (g, path);
722     if (xattrs == NULL)
723       return error ();
724     free_attrs = 1;
725   }
726
727   size_t i;
728   ssize_t copied = 0;
729   for (i = 0; i < xattrs->len; ++i) {
730     size_t len = strlen (xattrs->val[i].attrname) + 1;
731     if (size >= len) {
732       memcpy (list, xattrs->val[i].attrname, len);
733       size -= len;
734       list += len;
735       copied += len;
736     } else {
737       copied = -ERANGE;
738       break;
739     }
740   }
741
742   if (free_attrs)
743     guestfs_free_xattr_list ((struct guestfs_xattr_list *) xattrs);
744
745   return copied;
746 }
747
748 static int
749 fg_removexattr(const char *path, const char *name)
750 {
751   int r;
752
753   if (read_only) return -EROFS;
754
755   dir_cache_invalidate (path);
756
757   r = guestfs_lremovexattr (g, name, path);
758   if (r == -1)
759     return error ();
760
761   return 0;
762 }
763
764 static struct fuse_operations fg_operations = {
765   .getattr      = fg_getattr,
766   .access       = fg_access,
767   .readlink     = fg_readlink,
768   .readdir      = fg_readdir,
769   .mknod        = fg_mknod,
770   .mkdir        = fg_mkdir,
771   .symlink      = fg_symlink,
772   .unlink       = fg_unlink,
773   .rmdir        = fg_rmdir,
774   .rename       = fg_rename,
775   .link         = fg_link,
776   .chmod        = fg_chmod,
777   .chown        = fg_chown,
778   .truncate     = fg_truncate,
779   .utimens      = fg_utimens,
780   .open         = fg_open,
781   .read         = fg_read,
782   .write        = fg_write,
783   .statfs       = fg_statfs,
784   .release      = fg_release,
785   .fsync        = fg_fsync,
786   .setxattr     = fg_setxattr,
787   .getxattr     = fg_getxattr,
788   .listxattr    = fg_listxattr,
789   .removexattr  = fg_removexattr,
790 };
791
792 static void __attribute__((noreturn))
793 fuse_help (void)
794 {
795   const char *tmp_argv[] = { program_name, "--help", NULL };
796   fuse_main (2, (char **) tmp_argv, &fg_operations, NULL);
797   exit (EXIT_SUCCESS);
798 }
799
800 static void __attribute__((noreturn))
801 usage (int status)
802 {
803   if (status != EXIT_SUCCESS)
804     fprintf (stderr, _("Try `%s --help' for more information.\n"),
805              program_name);
806   else {
807     fprintf (stdout,
808            _("%s: FUSE module for libguestfs\n"
809              "%s lets you mount a virtual machine filesystem\n"
810              "Copyright (C) 2009-2010 Red Hat Inc.\n"
811              "Usage:\n"
812              "  %s [--options] [-- [--FUSE-options]] mountpoint\n"
813              "Options:\n"
814              "  -a|--add image       Add image\n"
815              "  -c|--connect uri     Specify libvirt URI for -d option\n"
816              "  --dir-cache-timeout  Set readdir cache timeout (default 5 sec)\n"
817              "  -d|--domain guest    Add disks from libvirt guest\n"
818              "  --echo-keys          Don't turn off echo for passphrases\n"
819              "  --format[=raw|..]    Force disk format for -a option\n"
820              "  --fuse-help          Display extra FUSE options\n"
821              "  -i|--inspector       Automatically mount filesystems\n"
822              "  --help               Display help message and exit\n"
823              "  --keys-from-stdin    Read passphrases from stdin\n"
824              "  -m|--mount dev[:mnt] Mount dev on mnt (if omitted, /)\n"
825              "  -n|--no-sync         Don't autosync\n"
826              "  -o|--option opt      Pass extra option to FUSE\n"
827              "  -r|--ro              Mount read-only\n"
828              "  --selinux            Enable SELinux support\n"
829              "  -v|--verbose         Verbose messages\n"
830              "  -V|--version         Display version and exit\n"
831              "  -x|--trace           Trace guestfs API calls\n"
832              ),
833              program_name, program_name, program_name);
834   }
835   exit (status);
836 }
837
838 int
839 main (int argc, char *argv[])
840 {
841   setlocale (LC_ALL, "");
842   bindtextdomain (PACKAGE, LOCALEBASEDIR);
843   textdomain (PACKAGE);
844
845   enum { HELP_OPTION = CHAR_MAX + 1 };
846
847   /* The command line arguments are broadly compatible with (a subset
848    * of) guestfish.  Thus we have to deal mainly with -a, -m and --ro.
849    */
850   static const char *options = "a:c:d:im:no:rv?Vwx";
851   static const struct option long_options[] = {
852     { "add", 1, 0, 'a' },
853     { "connect", 1, 0, 'c' },
854     { "dir-cache-timeout", 1, 0, 0 },
855     { "domain", 1, 0, 'd' },
856     { "echo-keys", 0, 0, 0 },
857     { "format", 2, 0, 0 },
858     { "fuse-help", 0, 0, 0 },
859     { "help", 0, 0, HELP_OPTION },
860     { "inspector", 0, 0, 'i' },
861     { "keys-from-stdin", 0, 0, 0 },
862     { "mount", 1, 0, 'm' },
863     { "no-sync", 0, 0, 'n' },
864     { "option", 1, 0, 'o' },
865     { "ro", 0, 0, 'r' },
866     { "rw", 0, 0, 'w' },
867     { "selinux", 0, 0, 0 },
868     { "trace", 0, 0, 'x' },
869     { "verbose", 0, 0, 'v' },
870     { "version", 0, 0, 'V' },
871     { 0, 0, 0, 0 }
872   };
873
874   struct drv *drvs = NULL;
875   struct drv *drv;
876   struct mp *mps = NULL;
877   struct mp *mp;
878   char *p;
879   const char *format = NULL;
880   int c, r;
881   int option_index;
882   struct sigaction sa;
883
884   int fuse_argc = 0;
885   const char **fuse_argv = NULL;
886
887 #define ADD_FUSE_ARG(str)                                               \
888   do {                                                                  \
889     fuse_argc ++;                                                       \
890     fuse_argv = realloc (fuse_argv, (1+fuse_argc) * sizeof (char *));   \
891     if (!fuse_argv) {                                                   \
892       perror ("realloc");                                               \
893       exit (EXIT_FAILURE);                                                         \
894     }                                                                   \
895     fuse_argv[fuse_argc-1] = (str);                                     \
896     fuse_argv[fuse_argc] = NULL;                                        \
897   } while (0)
898
899   /* LC_ALL=C is required so we can parse error messages. */
900   setenv ("LC_ALL", "C", 1);
901
902   /* Set global program name that is not polluted with libtool artifacts.  */
903   set_program_name (argv[0]);
904
905   memset (&sa, 0, sizeof sa);
906   sa.sa_handler = SIG_IGN;
907   sa.sa_flags = SA_RESTART;
908   sigaction (SIGPIPE, &sa, NULL);
909
910   /* Various initialization. */
911   init_dir_caches ();
912
913   g = guestfs_create ();
914   if (g == NULL) {
915     fprintf (stderr, _("guestfs_create: failed to create handle\n"));
916     exit (EXIT_FAILURE);
917   }
918
919   guestfs_set_recovery_proc (g, 0);
920
921   ADD_FUSE_ARG (program_name);
922   /* MUST be single-threaded.  You cannot have two threads accessing the
923    * same libguestfs handle, and opening more than one handle is likely
924    * to be very expensive.
925    */
926   ADD_FUSE_ARG ("-s");
927
928   /* If developing, add ./appliance to the path.  Note that libtools
929    * interferes with this because uninstalled guestfish is a shell
930    * script that runs the real program with an absolute path.  Detect
931    * that too.
932    *
933    * BUT if LIBGUESTFS_PATH environment variable is already set by
934    * the user, then don't override it.
935    */
936   if (getenv ("LIBGUESTFS_PATH") == NULL &&
937       argv[0] &&
938       (argv[0][0] != '/' || strstr (argv[0], "/.libs/lt-") != NULL))
939     guestfs_set_path (g, "appliance:" GUESTFS_DEFAULT_PATH);
940
941   for (;;) {
942     c = getopt_long (argc, argv, options, long_options, &option_index);
943     if (c == -1) break;
944
945     switch (c) {
946     case 0:                     /* options which are long only */
947       if (STREQ (long_options[option_index].name, "dir-cache-timeout"))
948         dir_cache_timeout = atoi (optarg);
949       else if (STREQ (long_options[option_index].name, "fuse-help"))
950         fuse_help ();
951       else if (STREQ (long_options[option_index].name, "selinux"))
952         guestfs_set_selinux (g, 1);
953       else if (STREQ (long_options[option_index].name, "format")) {
954         if (!optarg || STREQ (optarg, ""))
955           format = NULL;
956         else
957           format = optarg;
958       } else if (STREQ (long_options[option_index].name, "keys-from-stdin")) {
959         keys_from_stdin = 1;
960       } else if (STREQ (long_options[option_index].name, "echo-keys")) {
961         echo_keys = 1;
962       } else {
963         fprintf (stderr, _("%s: unknown long option: %s (%d)\n"),
964                  program_name, long_options[option_index].name, option_index);
965         exit (EXIT_FAILURE);
966       }
967       break;
968
969     case 'a':
970       OPTION_a;
971       break;
972
973     case 'c':
974       OPTION_c;
975       break;
976
977     case 'd':
978       OPTION_d;
979       break;
980
981     case 'i':
982       OPTION_i;
983       break;
984
985     case 'm':
986       OPTION_m;
987       break;
988
989     case 'n':
990       OPTION_n;
991       break;
992
993     case 'o':
994       ADD_FUSE_ARG ("-o");
995       ADD_FUSE_ARG (optarg);
996       break;
997
998     case 'r':
999       OPTION_r;
1000       break;
1001
1002     case 'v':
1003       OPTION_v;
1004       break;
1005
1006     case 'V':
1007       OPTION_V;
1008       break;
1009
1010     case 'w':
1011       OPTION_w;
1012       break;
1013
1014     case 'x':
1015       OPTION_x;
1016       ADD_FUSE_ARG ("-f");
1017       guestfs_set_recovery_proc (g, 1);
1018       break;
1019
1020     case HELP_OPTION:
1021       usage (EXIT_SUCCESS);
1022
1023     default:
1024       usage (EXIT_FAILURE);
1025     }
1026   }
1027
1028   /* Check we have the right options. */
1029   if (!drvs || !(mps || inspector)) {
1030     fprintf (stderr,
1031              _("%s: must have at least one -a/-d and at least one -m/-i option\n"),
1032              program_name);
1033     exit (EXIT_FAILURE);
1034   }
1035
1036   /* We'd better have a mountpoint. */
1037   if (optind+1 != argc) {
1038     fprintf (stderr,
1039              _("%s: you must specify a mountpoint in the host filesystem\n"),
1040              program_name);
1041     exit (EXIT_FAILURE);
1042   }
1043
1044   /* Do the guest drives and mountpoints. */
1045   add_drives (drvs, 'a');
1046   if (guestfs_launch (g) == -1)
1047     exit (EXIT_FAILURE);
1048   if (inspector)
1049     inspect_mount ();
1050   mount_mps (mps);
1051
1052   free_drives (drvs);
1053   free_mps (mps);
1054
1055   /* FUSE example does this, not clear if it's necessary, but ... */
1056   if (guestfs_umask (g, 0) == -1)
1057     exit (EXIT_FAILURE);
1058
1059   /* At the last minute, remove the libguestfs error handler.  In code
1060    * above this point, the default error handler has been used which
1061    * sends all errors to stderr.  Now before entering FUSE itself we
1062    * want to silence errors so we can convert them (see error()
1063    * function above).
1064    */
1065   guestfs_set_error_handler (g, NULL, NULL);
1066
1067   /* Finish off FUSE args. */
1068   ADD_FUSE_ARG (argv[optind]);
1069
1070   /*
1071     It says about the line containing the for-statement:
1072     error: assuming signed overflow does not occur when simplifying conditional to constant [-Wstrict-overflow]
1073
1074   if (verbose) {
1075     fprintf (stderr, "guestmount: invoking FUSE with args [");
1076     for (i = 0; i < fuse_argc; ++i) {
1077       if (i > 0) fprintf (stderr, ", ");
1078       fprintf (stderr, "%s", fuse_argv[i]);
1079     }
1080     fprintf (stderr, "]\n");
1081   }
1082   */
1083
1084   r = fuse_main (fuse_argc, (char **) fuse_argv, &fg_operations, NULL);
1085
1086   /* Cleanup. */
1087   guestfs_close (g);
1088   free_dir_caches ();
1089
1090   exit (r == -1 ? 1 : 0);
1091 }