937913f3e1105007666cf66ddc44a34dcefa1707
[libguestfs.git] / daemon / stubs.c
1 /* libguestfs generated file
2  * WARNING: THIS FILE IS GENERATED BY 'src/generator.ml'.
3  * ANY CHANGES YOU MAKE TO THIS FILE WILL BE LOST.
4  *
5  * Copyright (C) 2009 Red Hat Inc.
6  *
7  * This program is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License as published by
9  * the Free Software Foundation; either version 2 of the License, or
10  * (at your option) any later version.
11  *
12  * This program is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  * GNU General Public License for more details.
16  *
17  * You should have received a copy of the GNU General Public License along
18  * with this program; if not, write to the Free Software Foundation, Inc.,
19  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
20  */
21
22 #include <config.h>
23
24 #include <stdio.h>
25 #include <stdlib.h>
26 #include <string.h>
27 #include <inttypes.h>
28 #include <ctype.h>
29 #include <rpc/types.h>
30 #include <rpc/xdr.h>
31
32 #include "daemon.h"
33 #include "../src/guestfs_protocol.h"
34 #include "actions.h"
35
36 static void mount_stub (XDR *xdr_in)
37 {
38   int r;
39   struct guestfs_mount_args args;
40   const char *device;
41   const char *mountpoint;
42
43   memset (&args, 0, sizeof args);
44
45   if (!xdr_guestfs_mount_args (xdr_in, &args)) {
46     reply_with_error ("%s: daemon failed to decode procedure arguments", "mount");
47     return;
48   }
49   device = args.device;
50   mountpoint = args.mountpoint;
51
52   r = do_mount (device, mountpoint);
53   if (r == -1)
54     /* do_mount has already called reply_with_error */
55     goto done;
56
57   reply (NULL, NULL);
58 done:
59   xdr_free ((xdrproc_t) xdr_guestfs_mount_args, (char *) &args);
60 }
61
62 static void sync_stub (XDR *xdr_in)
63 {
64   int r;
65
66   r = do_sync ();
67   if (r == -1)
68     /* do_sync has already called reply_with_error */
69     goto done;
70
71   reply (NULL, NULL);
72 done: ;
73 }
74
75 static void touch_stub (XDR *xdr_in)
76 {
77   int r;
78   struct guestfs_touch_args args;
79   const char *path;
80
81   memset (&args, 0, sizeof args);
82
83   if (!xdr_guestfs_touch_args (xdr_in, &args)) {
84     reply_with_error ("%s: daemon failed to decode procedure arguments", "touch");
85     return;
86   }
87   path = args.path;
88
89   r = do_touch (path);
90   if (r == -1)
91     /* do_touch has already called reply_with_error */
92     goto done;
93
94   reply (NULL, NULL);
95 done:
96   xdr_free ((xdrproc_t) xdr_guestfs_touch_args, (char *) &args);
97 }
98
99 static void cat_stub (XDR *xdr_in)
100 {
101   char *r;
102   struct guestfs_cat_args args;
103   const char *path;
104
105   memset (&args, 0, sizeof args);
106
107   if (!xdr_guestfs_cat_args (xdr_in, &args)) {
108     reply_with_error ("%s: daemon failed to decode procedure arguments", "cat");
109     return;
110   }
111   path = args.path;
112
113   r = do_cat (path);
114   if (r == NULL)
115     /* do_cat has already called reply_with_error */
116     goto done;
117
118   struct guestfs_cat_ret ret;
119   ret.content = r;
120   reply ((xdrproc_t) &xdr_guestfs_cat_ret, (char *) &ret);
121   free (r);
122 done:
123   xdr_free ((xdrproc_t) xdr_guestfs_cat_args, (char *) &args);
124 }
125
126 static void ll_stub (XDR *xdr_in)
127 {
128   char *r;
129   struct guestfs_ll_args args;
130   const char *directory;
131
132   memset (&args, 0, sizeof args);
133
134   if (!xdr_guestfs_ll_args (xdr_in, &args)) {
135     reply_with_error ("%s: daemon failed to decode procedure arguments", "ll");
136     return;
137   }
138   directory = args.directory;
139
140   r = do_ll (directory);
141   if (r == NULL)
142     /* do_ll has already called reply_with_error */
143     goto done;
144
145   struct guestfs_ll_ret ret;
146   ret.listing = r;
147   reply ((xdrproc_t) &xdr_guestfs_ll_ret, (char *) &ret);
148   free (r);
149 done:
150   xdr_free ((xdrproc_t) xdr_guestfs_ll_args, (char *) &args);
151 }
152
153 static void ls_stub (XDR *xdr_in)
154 {
155   char **r;
156   struct guestfs_ls_args args;
157   const char *directory;
158
159   memset (&args, 0, sizeof args);
160
161   if (!xdr_guestfs_ls_args (xdr_in, &args)) {
162     reply_with_error ("%s: daemon failed to decode procedure arguments", "ls");
163     return;
164   }
165   directory = args.directory;
166
167   r = do_ls (directory);
168   if (r == NULL)
169     /* do_ls has already called reply_with_error */
170     goto done;
171
172   struct guestfs_ls_ret ret;
173   ret.listing.listing_len = count_strings (r);
174   ret.listing.listing_val = r;
175   reply ((xdrproc_t) &xdr_guestfs_ls_ret, (char *) &ret);
176   free_strings (r);
177 done:
178   xdr_free ((xdrproc_t) xdr_guestfs_ls_args, (char *) &args);
179 }
180
181 static void list_devices_stub (XDR *xdr_in)
182 {
183   char **r;
184
185   r = do_list_devices ();
186   if (r == NULL)
187     /* do_list_devices has already called reply_with_error */
188     goto done;
189
190   struct guestfs_list_devices_ret ret;
191   ret.devices.devices_len = count_strings (r);
192   ret.devices.devices_val = r;
193   reply ((xdrproc_t) &xdr_guestfs_list_devices_ret, (char *) &ret);
194   free_strings (r);
195 done: ;
196 }
197
198 static void list_partitions_stub (XDR *xdr_in)
199 {
200   char **r;
201
202   r = do_list_partitions ();
203   if (r == NULL)
204     /* do_list_partitions has already called reply_with_error */
205     goto done;
206
207   struct guestfs_list_partitions_ret ret;
208   ret.partitions.partitions_len = count_strings (r);
209   ret.partitions.partitions_val = r;
210   reply ((xdrproc_t) &xdr_guestfs_list_partitions_ret, (char *) &ret);
211   free_strings (r);
212 done: ;
213 }
214
215 static void pvs_stub (XDR *xdr_in)
216 {
217   char **r;
218
219   r = do_pvs ();
220   if (r == NULL)
221     /* do_pvs has already called reply_with_error */
222     goto done;
223
224   struct guestfs_pvs_ret ret;
225   ret.physvols.physvols_len = count_strings (r);
226   ret.physvols.physvols_val = r;
227   reply ((xdrproc_t) &xdr_guestfs_pvs_ret, (char *) &ret);
228   free_strings (r);
229 done: ;
230 }
231
232 static void vgs_stub (XDR *xdr_in)
233 {
234   char **r;
235
236   r = do_vgs ();
237   if (r == NULL)
238     /* do_vgs has already called reply_with_error */
239     goto done;
240
241   struct guestfs_vgs_ret ret;
242   ret.volgroups.volgroups_len = count_strings (r);
243   ret.volgroups.volgroups_val = r;
244   reply ((xdrproc_t) &xdr_guestfs_vgs_ret, (char *) &ret);
245   free_strings (r);
246 done: ;
247 }
248
249 static void lvs_stub (XDR *xdr_in)
250 {
251   char **r;
252
253   r = do_lvs ();
254   if (r == NULL)
255     /* do_lvs has already called reply_with_error */
256     goto done;
257
258   struct guestfs_lvs_ret ret;
259   ret.logvols.logvols_len = count_strings (r);
260   ret.logvols.logvols_val = r;
261   reply ((xdrproc_t) &xdr_guestfs_lvs_ret, (char *) &ret);
262   free_strings (r);
263 done: ;
264 }
265
266 static void pvs_full_stub (XDR *xdr_in)
267 {
268   guestfs_lvm_int_pv_list *r;
269
270   r = do_pvs_full ();
271   if (r == NULL)
272     /* do_pvs_full has already called reply_with_error */
273     goto done;
274
275   struct guestfs_pvs_full_ret ret;
276   ret.physvols = *r;
277   reply ((xdrproc_t) xdr_guestfs_pvs_full_ret, (char *) &ret);
278   xdr_free ((xdrproc_t) xdr_guestfs_pvs_full_ret, (char *) &ret);
279 done: ;
280 }
281
282 static void vgs_full_stub (XDR *xdr_in)
283 {
284   guestfs_lvm_int_vg_list *r;
285
286   r = do_vgs_full ();
287   if (r == NULL)
288     /* do_vgs_full has already called reply_with_error */
289     goto done;
290
291   struct guestfs_vgs_full_ret ret;
292   ret.volgroups = *r;
293   reply ((xdrproc_t) xdr_guestfs_vgs_full_ret, (char *) &ret);
294   xdr_free ((xdrproc_t) xdr_guestfs_vgs_full_ret, (char *) &ret);
295 done: ;
296 }
297
298 static void lvs_full_stub (XDR *xdr_in)
299 {
300   guestfs_lvm_int_lv_list *r;
301
302   r = do_lvs_full ();
303   if (r == NULL)
304     /* do_lvs_full has already called reply_with_error */
305     goto done;
306
307   struct guestfs_lvs_full_ret ret;
308   ret.logvols = *r;
309   reply ((xdrproc_t) xdr_guestfs_lvs_full_ret, (char *) &ret);
310   xdr_free ((xdrproc_t) xdr_guestfs_lvs_full_ret, (char *) &ret);
311 done: ;
312 }
313
314 static void read_lines_stub (XDR *xdr_in)
315 {
316   char **r;
317   struct guestfs_read_lines_args args;
318   const char *path;
319
320   memset (&args, 0, sizeof args);
321
322   if (!xdr_guestfs_read_lines_args (xdr_in, &args)) {
323     reply_with_error ("%s: daemon failed to decode procedure arguments", "read_lines");
324     return;
325   }
326   path = args.path;
327
328   r = do_read_lines (path);
329   if (r == NULL)
330     /* do_read_lines has already called reply_with_error */
331     goto done;
332
333   struct guestfs_read_lines_ret ret;
334   ret.lines.lines_len = count_strings (r);
335   ret.lines.lines_val = r;
336   reply ((xdrproc_t) &xdr_guestfs_read_lines_ret, (char *) &ret);
337   free_strings (r);
338 done:
339   xdr_free ((xdrproc_t) xdr_guestfs_read_lines_args, (char *) &args);
340 }
341
342 static void aug_init_stub (XDR *xdr_in)
343 {
344   int r;
345   struct guestfs_aug_init_args args;
346   const char *root;
347   int flags;
348
349   memset (&args, 0, sizeof args);
350
351   if (!xdr_guestfs_aug_init_args (xdr_in, &args)) {
352     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_init");
353     return;
354   }
355   root = args.root;
356   flags = args.flags;
357
358   r = do_aug_init (root, flags);
359   if (r == -1)
360     /* do_aug_init has already called reply_with_error */
361     goto done;
362
363   reply (NULL, NULL);
364 done:
365   xdr_free ((xdrproc_t) xdr_guestfs_aug_init_args, (char *) &args);
366 }
367
368 static void aug_close_stub (XDR *xdr_in)
369 {
370   int r;
371
372   r = do_aug_close ();
373   if (r == -1)
374     /* do_aug_close has already called reply_with_error */
375     goto done;
376
377   reply (NULL, NULL);
378 done: ;
379 }
380
381 static void aug_defvar_stub (XDR *xdr_in)
382 {
383   int r;
384   struct guestfs_aug_defvar_args args;
385   const char *name;
386   const char *expr;
387
388   memset (&args, 0, sizeof args);
389
390   if (!xdr_guestfs_aug_defvar_args (xdr_in, &args)) {
391     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_defvar");
392     return;
393   }
394   name = args.name;
395   expr = args.expr ? *args.expr : NULL;
396
397   r = do_aug_defvar (name, expr);
398   if (r == -1)
399     /* do_aug_defvar has already called reply_with_error */
400     goto done;
401
402   struct guestfs_aug_defvar_ret ret;
403   ret.nrnodes = r;
404   reply ((xdrproc_t) &xdr_guestfs_aug_defvar_ret, (char *) &ret);
405 done:
406   xdr_free ((xdrproc_t) xdr_guestfs_aug_defvar_args, (char *) &args);
407 }
408
409 static void aug_defnode_stub (XDR *xdr_in)
410 {
411   guestfs_aug_defnode_ret *r;
412   struct guestfs_aug_defnode_args args;
413   const char *name;
414   const char *expr;
415   const char *val;
416
417   memset (&args, 0, sizeof args);
418
419   if (!xdr_guestfs_aug_defnode_args (xdr_in, &args)) {
420     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_defnode");
421     return;
422   }
423   name = args.name;
424   expr = args.expr;
425   val = args.val;
426
427   r = do_aug_defnode (name, expr, val);
428   if (r == NULL)
429     /* do_aug_defnode has already called reply_with_error */
430     goto done;
431
432   reply ((xdrproc_t) xdr_guestfs_aug_defnode_ret, (char *) r);
433   xdr_free ((xdrproc_t) xdr_guestfs_aug_defnode_ret, (char *) r);
434 done:
435   xdr_free ((xdrproc_t) xdr_guestfs_aug_defnode_args, (char *) &args);
436 }
437
438 static void aug_get_stub (XDR *xdr_in)
439 {
440   char *r;
441   struct guestfs_aug_get_args args;
442   const char *path;
443
444   memset (&args, 0, sizeof args);
445
446   if (!xdr_guestfs_aug_get_args (xdr_in, &args)) {
447     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_get");
448     return;
449   }
450   path = args.path;
451
452   r = do_aug_get (path);
453   if (r == NULL)
454     /* do_aug_get has already called reply_with_error */
455     goto done;
456
457   struct guestfs_aug_get_ret ret;
458   ret.val = r;
459   reply ((xdrproc_t) &xdr_guestfs_aug_get_ret, (char *) &ret);
460   free (r);
461 done:
462   xdr_free ((xdrproc_t) xdr_guestfs_aug_get_args, (char *) &args);
463 }
464
465 static void aug_set_stub (XDR *xdr_in)
466 {
467   int r;
468   struct guestfs_aug_set_args args;
469   const char *path;
470   const char *val;
471
472   memset (&args, 0, sizeof args);
473
474   if (!xdr_guestfs_aug_set_args (xdr_in, &args)) {
475     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_set");
476     return;
477   }
478   path = args.path;
479   val = args.val;
480
481   r = do_aug_set (path, val);
482   if (r == -1)
483     /* do_aug_set has already called reply_with_error */
484     goto done;
485
486   reply (NULL, NULL);
487 done:
488   xdr_free ((xdrproc_t) xdr_guestfs_aug_set_args, (char *) &args);
489 }
490
491 static void aug_insert_stub (XDR *xdr_in)
492 {
493   int r;
494   struct guestfs_aug_insert_args args;
495   const char *path;
496   const char *label;
497   int before;
498
499   memset (&args, 0, sizeof args);
500
501   if (!xdr_guestfs_aug_insert_args (xdr_in, &args)) {
502     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_insert");
503     return;
504   }
505   path = args.path;
506   label = args.label;
507   before = args.before;
508
509   r = do_aug_insert (path, label, before);
510   if (r == -1)
511     /* do_aug_insert has already called reply_with_error */
512     goto done;
513
514   reply (NULL, NULL);
515 done:
516   xdr_free ((xdrproc_t) xdr_guestfs_aug_insert_args, (char *) &args);
517 }
518
519 static void aug_rm_stub (XDR *xdr_in)
520 {
521   int r;
522   struct guestfs_aug_rm_args args;
523   const char *path;
524
525   memset (&args, 0, sizeof args);
526
527   if (!xdr_guestfs_aug_rm_args (xdr_in, &args)) {
528     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_rm");
529     return;
530   }
531   path = args.path;
532
533   r = do_aug_rm (path);
534   if (r == -1)
535     /* do_aug_rm has already called reply_with_error */
536     goto done;
537
538   struct guestfs_aug_rm_ret ret;
539   ret.nrnodes = r;
540   reply ((xdrproc_t) &xdr_guestfs_aug_rm_ret, (char *) &ret);
541 done:
542   xdr_free ((xdrproc_t) xdr_guestfs_aug_rm_args, (char *) &args);
543 }
544
545 static void aug_mv_stub (XDR *xdr_in)
546 {
547   int r;
548   struct guestfs_aug_mv_args args;
549   const char *src;
550   const char *dest;
551
552   memset (&args, 0, sizeof args);
553
554   if (!xdr_guestfs_aug_mv_args (xdr_in, &args)) {
555     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_mv");
556     return;
557   }
558   src = args.src;
559   dest = args.dest;
560
561   r = do_aug_mv (src, dest);
562   if (r == -1)
563     /* do_aug_mv has already called reply_with_error */
564     goto done;
565
566   reply (NULL, NULL);
567 done:
568   xdr_free ((xdrproc_t) xdr_guestfs_aug_mv_args, (char *) &args);
569 }
570
571 static void aug_match_stub (XDR *xdr_in)
572 {
573   char **r;
574   struct guestfs_aug_match_args args;
575   const char *path;
576
577   memset (&args, 0, sizeof args);
578
579   if (!xdr_guestfs_aug_match_args (xdr_in, &args)) {
580     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_match");
581     return;
582   }
583   path = args.path;
584
585   r = do_aug_match (path);
586   if (r == NULL)
587     /* do_aug_match has already called reply_with_error */
588     goto done;
589
590   struct guestfs_aug_match_ret ret;
591   ret.matches.matches_len = count_strings (r);
592   ret.matches.matches_val = r;
593   reply ((xdrproc_t) &xdr_guestfs_aug_match_ret, (char *) &ret);
594   free_strings (r);
595 done:
596   xdr_free ((xdrproc_t) xdr_guestfs_aug_match_args, (char *) &args);
597 }
598
599 static void aug_save_stub (XDR *xdr_in)
600 {
601   int r;
602
603   r = do_aug_save ();
604   if (r == -1)
605     /* do_aug_save has already called reply_with_error */
606     goto done;
607
608   reply (NULL, NULL);
609 done: ;
610 }
611
612 static void aug_load_stub (XDR *xdr_in)
613 {
614   int r;
615
616   r = do_aug_load ();
617   if (r == -1)
618     /* do_aug_load has already called reply_with_error */
619     goto done;
620
621   reply (NULL, NULL);
622 done: ;
623 }
624
625 static void aug_ls_stub (XDR *xdr_in)
626 {
627   char **r;
628   struct guestfs_aug_ls_args args;
629   const char *path;
630
631   memset (&args, 0, sizeof args);
632
633   if (!xdr_guestfs_aug_ls_args (xdr_in, &args)) {
634     reply_with_error ("%s: daemon failed to decode procedure arguments", "aug_ls");
635     return;
636   }
637   path = args.path;
638
639   r = do_aug_ls (path);
640   if (r == NULL)
641     /* do_aug_ls has already called reply_with_error */
642     goto done;
643
644   struct guestfs_aug_ls_ret ret;
645   ret.matches.matches_len = count_strings (r);
646   ret.matches.matches_val = r;
647   reply ((xdrproc_t) &xdr_guestfs_aug_ls_ret, (char *) &ret);
648   free_strings (r);
649 done:
650   xdr_free ((xdrproc_t) xdr_guestfs_aug_ls_args, (char *) &args);
651 }
652
653 static void rm_stub (XDR *xdr_in)
654 {
655   int r;
656   struct guestfs_rm_args args;
657   const char *path;
658
659   memset (&args, 0, sizeof args);
660
661   if (!xdr_guestfs_rm_args (xdr_in, &args)) {
662     reply_with_error ("%s: daemon failed to decode procedure arguments", "rm");
663     return;
664   }
665   path = args.path;
666
667   r = do_rm (path);
668   if (r == -1)
669     /* do_rm has already called reply_with_error */
670     goto done;
671
672   reply (NULL, NULL);
673 done:
674   xdr_free ((xdrproc_t) xdr_guestfs_rm_args, (char *) &args);
675 }
676
677 static void rmdir_stub (XDR *xdr_in)
678 {
679   int r;
680   struct guestfs_rmdir_args args;
681   const char *path;
682
683   memset (&args, 0, sizeof args);
684
685   if (!xdr_guestfs_rmdir_args (xdr_in, &args)) {
686     reply_with_error ("%s: daemon failed to decode procedure arguments", "rmdir");
687     return;
688   }
689   path = args.path;
690
691   r = do_rmdir (path);
692   if (r == -1)
693     /* do_rmdir has already called reply_with_error */
694     goto done;
695
696   reply (NULL, NULL);
697 done:
698   xdr_free ((xdrproc_t) xdr_guestfs_rmdir_args, (char *) &args);
699 }
700
701 static void rm_rf_stub (XDR *xdr_in)
702 {
703   int r;
704   struct guestfs_rm_rf_args args;
705   const char *path;
706
707   memset (&args, 0, sizeof args);
708
709   if (!xdr_guestfs_rm_rf_args (xdr_in, &args)) {
710     reply_with_error ("%s: daemon failed to decode procedure arguments", "rm_rf");
711     return;
712   }
713   path = args.path;
714
715   r = do_rm_rf (path);
716   if (r == -1)
717     /* do_rm_rf has already called reply_with_error */
718     goto done;
719
720   reply (NULL, NULL);
721 done:
722   xdr_free ((xdrproc_t) xdr_guestfs_rm_rf_args, (char *) &args);
723 }
724
725 static void mkdir_stub (XDR *xdr_in)
726 {
727   int r;
728   struct guestfs_mkdir_args args;
729   const char *path;
730
731   memset (&args, 0, sizeof args);
732
733   if (!xdr_guestfs_mkdir_args (xdr_in, &args)) {
734     reply_with_error ("%s: daemon failed to decode procedure arguments", "mkdir");
735     return;
736   }
737   path = args.path;
738
739   r = do_mkdir (path);
740   if (r == -1)
741     /* do_mkdir has already called reply_with_error */
742     goto done;
743
744   reply (NULL, NULL);
745 done:
746   xdr_free ((xdrproc_t) xdr_guestfs_mkdir_args, (char *) &args);
747 }
748
749 static void mkdir_p_stub (XDR *xdr_in)
750 {
751   int r;
752   struct guestfs_mkdir_p_args args;
753   const char *path;
754
755   memset (&args, 0, sizeof args);
756
757   if (!xdr_guestfs_mkdir_p_args (xdr_in, &args)) {
758     reply_with_error ("%s: daemon failed to decode procedure arguments", "mkdir_p");
759     return;
760   }
761   path = args.path;
762
763   r = do_mkdir_p (path);
764   if (r == -1)
765     /* do_mkdir_p has already called reply_with_error */
766     goto done;
767
768   reply (NULL, NULL);
769 done:
770   xdr_free ((xdrproc_t) xdr_guestfs_mkdir_p_args, (char *) &args);
771 }
772
773 static void chmod_stub (XDR *xdr_in)
774 {
775   int r;
776   struct guestfs_chmod_args args;
777   int mode;
778   const char *path;
779
780   memset (&args, 0, sizeof args);
781
782   if (!xdr_guestfs_chmod_args (xdr_in, &args)) {
783     reply_with_error ("%s: daemon failed to decode procedure arguments", "chmod");
784     return;
785   }
786   mode = args.mode;
787   path = args.path;
788
789   r = do_chmod (mode, path);
790   if (r == -1)
791     /* do_chmod has already called reply_with_error */
792     goto done;
793
794   reply (NULL, NULL);
795 done:
796   xdr_free ((xdrproc_t) xdr_guestfs_chmod_args, (char *) &args);
797 }
798
799 static void chown_stub (XDR *xdr_in)
800 {
801   int r;
802   struct guestfs_chown_args args;
803   int owner;
804   int group;
805   const char *path;
806
807   memset (&args, 0, sizeof args);
808
809   if (!xdr_guestfs_chown_args (xdr_in, &args)) {
810     reply_with_error ("%s: daemon failed to decode procedure arguments", "chown");
811     return;
812   }
813   owner = args.owner;
814   group = args.group;
815   path = args.path;
816
817   r = do_chown (owner, group, path);
818   if (r == -1)
819     /* do_chown has already called reply_with_error */
820     goto done;
821
822   reply (NULL, NULL);
823 done:
824   xdr_free ((xdrproc_t) xdr_guestfs_chown_args, (char *) &args);
825 }
826
827 static void exists_stub (XDR *xdr_in)
828 {
829   int r;
830   struct guestfs_exists_args args;
831   const char *path;
832
833   memset (&args, 0, sizeof args);
834
835   if (!xdr_guestfs_exists_args (xdr_in, &args)) {
836     reply_with_error ("%s: daemon failed to decode procedure arguments", "exists");
837     return;
838   }
839   path = args.path;
840
841   r = do_exists (path);
842   if (r == -1)
843     /* do_exists has already called reply_with_error */
844     goto done;
845
846   struct guestfs_exists_ret ret;
847   ret.existsflag = r;
848   reply ((xdrproc_t) &xdr_guestfs_exists_ret, (char *) &ret);
849 done:
850   xdr_free ((xdrproc_t) xdr_guestfs_exists_args, (char *) &args);
851 }
852
853 static void is_file_stub (XDR *xdr_in)
854 {
855   int r;
856   struct guestfs_is_file_args args;
857   const char *path;
858
859   memset (&args, 0, sizeof args);
860
861   if (!xdr_guestfs_is_file_args (xdr_in, &args)) {
862     reply_with_error ("%s: daemon failed to decode procedure arguments", "is_file");
863     return;
864   }
865   path = args.path;
866
867   r = do_is_file (path);
868   if (r == -1)
869     /* do_is_file has already called reply_with_error */
870     goto done;
871
872   struct guestfs_is_file_ret ret;
873   ret.fileflag = r;
874   reply ((xdrproc_t) &xdr_guestfs_is_file_ret, (char *) &ret);
875 done:
876   xdr_free ((xdrproc_t) xdr_guestfs_is_file_args, (char *) &args);
877 }
878
879 static void is_dir_stub (XDR *xdr_in)
880 {
881   int r;
882   struct guestfs_is_dir_args args;
883   const char *path;
884
885   memset (&args, 0, sizeof args);
886
887   if (!xdr_guestfs_is_dir_args (xdr_in, &args)) {
888     reply_with_error ("%s: daemon failed to decode procedure arguments", "is_dir");
889     return;
890   }
891   path = args.path;
892
893   r = do_is_dir (path);
894   if (r == -1)
895     /* do_is_dir has already called reply_with_error */
896     goto done;
897
898   struct guestfs_is_dir_ret ret;
899   ret.dirflag = r;
900   reply ((xdrproc_t) &xdr_guestfs_is_dir_ret, (char *) &ret);
901 done:
902   xdr_free ((xdrproc_t) xdr_guestfs_is_dir_args, (char *) &args);
903 }
904
905 static void pvcreate_stub (XDR *xdr_in)
906 {
907   int r;
908   struct guestfs_pvcreate_args args;
909   const char *device;
910
911   memset (&args, 0, sizeof args);
912
913   if (!xdr_guestfs_pvcreate_args (xdr_in, &args)) {
914     reply_with_error ("%s: daemon failed to decode procedure arguments", "pvcreate");
915     return;
916   }
917   device = args.device;
918
919   r = do_pvcreate (device);
920   if (r == -1)
921     /* do_pvcreate has already called reply_with_error */
922     goto done;
923
924   reply (NULL, NULL);
925 done:
926   xdr_free ((xdrproc_t) xdr_guestfs_pvcreate_args, (char *) &args);
927 }
928
929 static void vgcreate_stub (XDR *xdr_in)
930 {
931   int r;
932   struct guestfs_vgcreate_args args;
933   const char *volgroup;
934   char **physvols;
935
936   memset (&args, 0, sizeof args);
937
938   if (!xdr_guestfs_vgcreate_args (xdr_in, &args)) {
939     reply_with_error ("%s: daemon failed to decode procedure arguments", "vgcreate");
940     return;
941   }
942   volgroup = args.volgroup;
943   physvols = realloc (args.physvols.physvols_val,
944                 sizeof (char *) * (args.physvols.physvols_len+1));
945   if (physvols == NULL) {
946     reply_with_perror ("realloc");
947     goto done;
948   }
949   physvols[args.physvols.physvols_len] = NULL;
950   args.physvols.physvols_val = physvols;
951
952   r = do_vgcreate (volgroup, physvols);
953   if (r == -1)
954     /* do_vgcreate has already called reply_with_error */
955     goto done;
956
957   reply (NULL, NULL);
958 done:
959   xdr_free ((xdrproc_t) xdr_guestfs_vgcreate_args, (char *) &args);
960 }
961
962 static void lvcreate_stub (XDR *xdr_in)
963 {
964   int r;
965   struct guestfs_lvcreate_args args;
966   const char *logvol;
967   const char *volgroup;
968   int mbytes;
969
970   memset (&args, 0, sizeof args);
971
972   if (!xdr_guestfs_lvcreate_args (xdr_in, &args)) {
973     reply_with_error ("%s: daemon failed to decode procedure arguments", "lvcreate");
974     return;
975   }
976   logvol = args.logvol;
977   volgroup = args.volgroup;
978   mbytes = args.mbytes;
979
980   r = do_lvcreate (logvol, volgroup, mbytes);
981   if (r == -1)
982     /* do_lvcreate has already called reply_with_error */
983     goto done;
984
985   reply (NULL, NULL);
986 done:
987   xdr_free ((xdrproc_t) xdr_guestfs_lvcreate_args, (char *) &args);
988 }
989
990 static void mkfs_stub (XDR *xdr_in)
991 {
992   int r;
993   struct guestfs_mkfs_args args;
994   const char *fstype;
995   const char *device;
996
997   memset (&args, 0, sizeof args);
998
999   if (!xdr_guestfs_mkfs_args (xdr_in, &args)) {
1000     reply_with_error ("%s: daemon failed to decode procedure arguments", "mkfs");
1001     return;
1002   }
1003   fstype = args.fstype;
1004   device = args.device;
1005
1006   r = do_mkfs (fstype, device);
1007   if (r == -1)
1008     /* do_mkfs has already called reply_with_error */
1009     goto done;
1010
1011   reply (NULL, NULL);
1012 done:
1013   xdr_free ((xdrproc_t) xdr_guestfs_mkfs_args, (char *) &args);
1014 }
1015
1016 static void sfdisk_stub (XDR *xdr_in)
1017 {
1018   int r;
1019   struct guestfs_sfdisk_args args;
1020   const char *device;
1021   int cyls;
1022   int heads;
1023   int sectors;
1024   char **lines;
1025
1026   memset (&args, 0, sizeof args);
1027
1028   if (!xdr_guestfs_sfdisk_args (xdr_in, &args)) {
1029     reply_with_error ("%s: daemon failed to decode procedure arguments", "sfdisk");
1030     return;
1031   }
1032   device = args.device;
1033   cyls = args.cyls;
1034   heads = args.heads;
1035   sectors = args.sectors;
1036   lines = realloc (args.lines.lines_val,
1037                 sizeof (char *) * (args.lines.lines_len+1));
1038   if (lines == NULL) {
1039     reply_with_perror ("realloc");
1040     goto done;
1041   }
1042   lines[args.lines.lines_len] = NULL;
1043   args.lines.lines_val = lines;
1044
1045   r = do_sfdisk (device, cyls, heads, sectors, lines);
1046   if (r == -1)
1047     /* do_sfdisk has already called reply_with_error */
1048     goto done;
1049
1050   reply (NULL, NULL);
1051 done:
1052   xdr_free ((xdrproc_t) xdr_guestfs_sfdisk_args, (char *) &args);
1053 }
1054
1055 static void write_file_stub (XDR *xdr_in)
1056 {
1057   int r;
1058   struct guestfs_write_file_args args;
1059   const char *path;
1060   const char *content;
1061   int size;
1062
1063   memset (&args, 0, sizeof args);
1064
1065   if (!xdr_guestfs_write_file_args (xdr_in, &args)) {
1066     reply_with_error ("%s: daemon failed to decode procedure arguments", "write_file");
1067     return;
1068   }
1069   path = args.path;
1070   content = args.content;
1071   size = args.size;
1072
1073   r = do_write_file (path, content, size);
1074   if (r == -1)
1075     /* do_write_file has already called reply_with_error */
1076     goto done;
1077
1078   reply (NULL, NULL);
1079 done:
1080   xdr_free ((xdrproc_t) xdr_guestfs_write_file_args, (char *) &args);
1081 }
1082
1083 static void umount_stub (XDR *xdr_in)
1084 {
1085   int r;
1086   struct guestfs_umount_args args;
1087   const char *pathordevice;
1088
1089   memset (&args, 0, sizeof args);
1090
1091   if (!xdr_guestfs_umount_args (xdr_in, &args)) {
1092     reply_with_error ("%s: daemon failed to decode procedure arguments", "umount");
1093     return;
1094   }
1095   pathordevice = args.pathordevice;
1096
1097   r = do_umount (pathordevice);
1098   if (r == -1)
1099     /* do_umount has already called reply_with_error */
1100     goto done;
1101
1102   reply (NULL, NULL);
1103 done:
1104   xdr_free ((xdrproc_t) xdr_guestfs_umount_args, (char *) &args);
1105 }
1106
1107 static void mounts_stub (XDR *xdr_in)
1108 {
1109   char **r;
1110
1111   r = do_mounts ();
1112   if (r == NULL)
1113     /* do_mounts has already called reply_with_error */
1114     goto done;
1115
1116   struct guestfs_mounts_ret ret;
1117   ret.devices.devices_len = count_strings (r);
1118   ret.devices.devices_val = r;
1119   reply ((xdrproc_t) &xdr_guestfs_mounts_ret, (char *) &ret);
1120   free_strings (r);
1121 done: ;
1122 }
1123
1124 static void umount_all_stub (XDR *xdr_in)
1125 {
1126   int r;
1127
1128   r = do_umount_all ();
1129   if (r == -1)
1130     /* do_umount_all has already called reply_with_error */
1131     goto done;
1132
1133   reply (NULL, NULL);
1134 done: ;
1135 }
1136
1137 static void lvm_remove_all_stub (XDR *xdr_in)
1138 {
1139   int r;
1140
1141   r = do_lvm_remove_all ();
1142   if (r == -1)
1143     /* do_lvm_remove_all has already called reply_with_error */
1144     goto done;
1145
1146   reply (NULL, NULL);
1147 done: ;
1148 }
1149
1150 static void file_stub (XDR *xdr_in)
1151 {
1152   char *r;
1153   struct guestfs_file_args args;
1154   const char *path;
1155
1156   memset (&args, 0, sizeof args);
1157
1158   if (!xdr_guestfs_file_args (xdr_in, &args)) {
1159     reply_with_error ("%s: daemon failed to decode procedure arguments", "file");
1160     return;
1161   }
1162   path = args.path;
1163
1164   r = do_file (path);
1165   if (r == NULL)
1166     /* do_file has already called reply_with_error */
1167     goto done;
1168
1169   struct guestfs_file_ret ret;
1170   ret.description = r;
1171   reply ((xdrproc_t) &xdr_guestfs_file_ret, (char *) &ret);
1172   free (r);
1173 done:
1174   xdr_free ((xdrproc_t) xdr_guestfs_file_args, (char *) &args);
1175 }
1176
1177 static void command_stub (XDR *xdr_in)
1178 {
1179   char *r;
1180   struct guestfs_command_args args;
1181   char **arguments;
1182
1183   memset (&args, 0, sizeof args);
1184
1185   if (!xdr_guestfs_command_args (xdr_in, &args)) {
1186     reply_with_error ("%s: daemon failed to decode procedure arguments", "command");
1187     return;
1188   }
1189   arguments = realloc (args.arguments.arguments_val,
1190                 sizeof (char *) * (args.arguments.arguments_len+1));
1191   if (arguments == NULL) {
1192     reply_with_perror ("realloc");
1193     goto done;
1194   }
1195   arguments[args.arguments.arguments_len] = NULL;
1196   args.arguments.arguments_val = arguments;
1197
1198   r = do_command (arguments);
1199   if (r == NULL)
1200     /* do_command has already called reply_with_error */
1201     goto done;
1202
1203   struct guestfs_command_ret ret;
1204   ret.output = r;
1205   reply ((xdrproc_t) &xdr_guestfs_command_ret, (char *) &ret);
1206   free (r);
1207 done:
1208   xdr_free ((xdrproc_t) xdr_guestfs_command_args, (char *) &args);
1209 }
1210
1211 static void command_lines_stub (XDR *xdr_in)
1212 {
1213   char **r;
1214   struct guestfs_command_lines_args args;
1215   char **arguments;
1216
1217   memset (&args, 0, sizeof args);
1218
1219   if (!xdr_guestfs_command_lines_args (xdr_in, &args)) {
1220     reply_with_error ("%s: daemon failed to decode procedure arguments", "command_lines");
1221     return;
1222   }
1223   arguments = realloc (args.arguments.arguments_val,
1224                 sizeof (char *) * (args.arguments.arguments_len+1));
1225   if (arguments == NULL) {
1226     reply_with_perror ("realloc");
1227     goto done;
1228   }
1229   arguments[args.arguments.arguments_len] = NULL;
1230   args.arguments.arguments_val = arguments;
1231
1232   r = do_command_lines (arguments);
1233   if (r == NULL)
1234     /* do_command_lines has already called reply_with_error */
1235     goto done;
1236
1237   struct guestfs_command_lines_ret ret;
1238   ret.lines.lines_len = count_strings (r);
1239   ret.lines.lines_val = r;
1240   reply ((xdrproc_t) &xdr_guestfs_command_lines_ret, (char *) &ret);
1241   free_strings (r);
1242 done:
1243   xdr_free ((xdrproc_t) xdr_guestfs_command_lines_args, (char *) &args);
1244 }
1245
1246 static void stat_stub (XDR *xdr_in)
1247 {
1248   guestfs_int_stat *r;
1249   struct guestfs_stat_args args;
1250   const char *path;
1251
1252   memset (&args, 0, sizeof args);
1253
1254   if (!xdr_guestfs_stat_args (xdr_in, &args)) {
1255     reply_with_error ("%s: daemon failed to decode procedure arguments", "stat");
1256     return;
1257   }
1258   path = args.path;
1259
1260   r = do_stat (path);
1261   if (r == NULL)
1262     /* do_stat has already called reply_with_error */
1263     goto done;
1264
1265   struct guestfs_stat_ret ret;
1266   ret.statbuf = *r;
1267   reply ((xdrproc_t) xdr_guestfs_stat_ret, (char *) &ret);
1268   xdr_free ((xdrproc_t) xdr_guestfs_stat_ret, (char *) &ret);
1269 done:
1270   xdr_free ((xdrproc_t) xdr_guestfs_stat_args, (char *) &args);
1271 }
1272
1273 static void lstat_stub (XDR *xdr_in)
1274 {
1275   guestfs_int_stat *r;
1276   struct guestfs_lstat_args args;
1277   const char *path;
1278
1279   memset (&args, 0, sizeof args);
1280
1281   if (!xdr_guestfs_lstat_args (xdr_in, &args)) {
1282     reply_with_error ("%s: daemon failed to decode procedure arguments", "lstat");
1283     return;
1284   }
1285   path = args.path;
1286
1287   r = do_lstat (path);
1288   if (r == NULL)
1289     /* do_lstat has already called reply_with_error */
1290     goto done;
1291
1292   struct guestfs_lstat_ret ret;
1293   ret.statbuf = *r;
1294   reply ((xdrproc_t) xdr_guestfs_lstat_ret, (char *) &ret);
1295   xdr_free ((xdrproc_t) xdr_guestfs_lstat_ret, (char *) &ret);
1296 done:
1297   xdr_free ((xdrproc_t) xdr_guestfs_lstat_args, (char *) &args);
1298 }
1299
1300 static void statvfs_stub (XDR *xdr_in)
1301 {
1302   guestfs_int_statvfs *r;
1303   struct guestfs_statvfs_args args;
1304   const char *path;
1305
1306   memset (&args, 0, sizeof args);
1307
1308   if (!xdr_guestfs_statvfs_args (xdr_in, &args)) {
1309     reply_with_error ("%s: daemon failed to decode procedure arguments", "statvfs");
1310     return;
1311   }
1312   path = args.path;
1313
1314   r = do_statvfs (path);
1315   if (r == NULL)
1316     /* do_statvfs has already called reply_with_error */
1317     goto done;
1318
1319   struct guestfs_statvfs_ret ret;
1320   ret.statbuf = *r;
1321   reply ((xdrproc_t) xdr_guestfs_statvfs_ret, (char *) &ret);
1322   xdr_free ((xdrproc_t) xdr_guestfs_statvfs_ret, (char *) &ret);
1323 done:
1324   xdr_free ((xdrproc_t) xdr_guestfs_statvfs_args, (char *) &args);
1325 }
1326
1327 static void tune2fs_l_stub (XDR *xdr_in)
1328 {
1329   char **r;
1330   struct guestfs_tune2fs_l_args args;
1331   const char *device;
1332
1333   memset (&args, 0, sizeof args);
1334
1335   if (!xdr_guestfs_tune2fs_l_args (xdr_in, &args)) {
1336     reply_with_error ("%s: daemon failed to decode procedure arguments", "tune2fs_l");
1337     return;
1338   }
1339   device = args.device;
1340
1341   r = do_tune2fs_l (device);
1342   if (r == NULL)
1343     /* do_tune2fs_l has already called reply_with_error */
1344     goto done;
1345
1346   struct guestfs_tune2fs_l_ret ret;
1347   ret.superblock.superblock_len = count_strings (r);
1348   ret.superblock.superblock_val = r;
1349   reply ((xdrproc_t) &xdr_guestfs_tune2fs_l_ret, (char *) &ret);
1350   free_strings (r);
1351 done:
1352   xdr_free ((xdrproc_t) xdr_guestfs_tune2fs_l_args, (char *) &args);
1353 }
1354
1355 static void blockdev_setro_stub (XDR *xdr_in)
1356 {
1357   int r;
1358   struct guestfs_blockdev_setro_args args;
1359   const char *device;
1360
1361   memset (&args, 0, sizeof args);
1362
1363   if (!xdr_guestfs_blockdev_setro_args (xdr_in, &args)) {
1364     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_setro");
1365     return;
1366   }
1367   device = args.device;
1368
1369   r = do_blockdev_setro (device);
1370   if (r == -1)
1371     /* do_blockdev_setro has already called reply_with_error */
1372     goto done;
1373
1374   reply (NULL, NULL);
1375 done:
1376   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_setro_args, (char *) &args);
1377 }
1378
1379 static void blockdev_setrw_stub (XDR *xdr_in)
1380 {
1381   int r;
1382   struct guestfs_blockdev_setrw_args args;
1383   const char *device;
1384
1385   memset (&args, 0, sizeof args);
1386
1387   if (!xdr_guestfs_blockdev_setrw_args (xdr_in, &args)) {
1388     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_setrw");
1389     return;
1390   }
1391   device = args.device;
1392
1393   r = do_blockdev_setrw (device);
1394   if (r == -1)
1395     /* do_blockdev_setrw has already called reply_with_error */
1396     goto done;
1397
1398   reply (NULL, NULL);
1399 done:
1400   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_setrw_args, (char *) &args);
1401 }
1402
1403 static void blockdev_getro_stub (XDR *xdr_in)
1404 {
1405   int r;
1406   struct guestfs_blockdev_getro_args args;
1407   const char *device;
1408
1409   memset (&args, 0, sizeof args);
1410
1411   if (!xdr_guestfs_blockdev_getro_args (xdr_in, &args)) {
1412     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_getro");
1413     return;
1414   }
1415   device = args.device;
1416
1417   r = do_blockdev_getro (device);
1418   if (r == -1)
1419     /* do_blockdev_getro has already called reply_with_error */
1420     goto done;
1421
1422   struct guestfs_blockdev_getro_ret ret;
1423   ret.ro = r;
1424   reply ((xdrproc_t) &xdr_guestfs_blockdev_getro_ret, (char *) &ret);
1425 done:
1426   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_getro_args, (char *) &args);
1427 }
1428
1429 static void blockdev_getss_stub (XDR *xdr_in)
1430 {
1431   int r;
1432   struct guestfs_blockdev_getss_args args;
1433   const char *device;
1434
1435   memset (&args, 0, sizeof args);
1436
1437   if (!xdr_guestfs_blockdev_getss_args (xdr_in, &args)) {
1438     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_getss");
1439     return;
1440   }
1441   device = args.device;
1442
1443   r = do_blockdev_getss (device);
1444   if (r == -1)
1445     /* do_blockdev_getss has already called reply_with_error */
1446     goto done;
1447
1448   struct guestfs_blockdev_getss_ret ret;
1449   ret.sectorsize = r;
1450   reply ((xdrproc_t) &xdr_guestfs_blockdev_getss_ret, (char *) &ret);
1451 done:
1452   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_getss_args, (char *) &args);
1453 }
1454
1455 static void blockdev_getbsz_stub (XDR *xdr_in)
1456 {
1457   int r;
1458   struct guestfs_blockdev_getbsz_args args;
1459   const char *device;
1460
1461   memset (&args, 0, sizeof args);
1462
1463   if (!xdr_guestfs_blockdev_getbsz_args (xdr_in, &args)) {
1464     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_getbsz");
1465     return;
1466   }
1467   device = args.device;
1468
1469   r = do_blockdev_getbsz (device);
1470   if (r == -1)
1471     /* do_blockdev_getbsz has already called reply_with_error */
1472     goto done;
1473
1474   struct guestfs_blockdev_getbsz_ret ret;
1475   ret.blocksize = r;
1476   reply ((xdrproc_t) &xdr_guestfs_blockdev_getbsz_ret, (char *) &ret);
1477 done:
1478   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_getbsz_args, (char *) &args);
1479 }
1480
1481 static void blockdev_setbsz_stub (XDR *xdr_in)
1482 {
1483   int r;
1484   struct guestfs_blockdev_setbsz_args args;
1485   const char *device;
1486   int blocksize;
1487
1488   memset (&args, 0, sizeof args);
1489
1490   if (!xdr_guestfs_blockdev_setbsz_args (xdr_in, &args)) {
1491     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_setbsz");
1492     return;
1493   }
1494   device = args.device;
1495   blocksize = args.blocksize;
1496
1497   r = do_blockdev_setbsz (device, blocksize);
1498   if (r == -1)
1499     /* do_blockdev_setbsz has already called reply_with_error */
1500     goto done;
1501
1502   reply (NULL, NULL);
1503 done:
1504   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_setbsz_args, (char *) &args);
1505 }
1506
1507 static void blockdev_getsz_stub (XDR *xdr_in)
1508 {
1509   int64_t r;
1510   struct guestfs_blockdev_getsz_args args;
1511   const char *device;
1512
1513   memset (&args, 0, sizeof args);
1514
1515   if (!xdr_guestfs_blockdev_getsz_args (xdr_in, &args)) {
1516     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_getsz");
1517     return;
1518   }
1519   device = args.device;
1520
1521   r = do_blockdev_getsz (device);
1522   if (r == -1)
1523     /* do_blockdev_getsz has already called reply_with_error */
1524     goto done;
1525
1526   struct guestfs_blockdev_getsz_ret ret;
1527   ret.sizeinsectors = r;
1528   reply ((xdrproc_t) &xdr_guestfs_blockdev_getsz_ret, (char *) &ret);
1529 done:
1530   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_getsz_args, (char *) &args);
1531 }
1532
1533 static void blockdev_getsize64_stub (XDR *xdr_in)
1534 {
1535   int64_t r;
1536   struct guestfs_blockdev_getsize64_args args;
1537   const char *device;
1538
1539   memset (&args, 0, sizeof args);
1540
1541   if (!xdr_guestfs_blockdev_getsize64_args (xdr_in, &args)) {
1542     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_getsize64");
1543     return;
1544   }
1545   device = args.device;
1546
1547   r = do_blockdev_getsize64 (device);
1548   if (r == -1)
1549     /* do_blockdev_getsize64 has already called reply_with_error */
1550     goto done;
1551
1552   struct guestfs_blockdev_getsize64_ret ret;
1553   ret.sizeinbytes = r;
1554   reply ((xdrproc_t) &xdr_guestfs_blockdev_getsize64_ret, (char *) &ret);
1555 done:
1556   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_getsize64_args, (char *) &args);
1557 }
1558
1559 static void blockdev_flushbufs_stub (XDR *xdr_in)
1560 {
1561   int r;
1562   struct guestfs_blockdev_flushbufs_args args;
1563   const char *device;
1564
1565   memset (&args, 0, sizeof args);
1566
1567   if (!xdr_guestfs_blockdev_flushbufs_args (xdr_in, &args)) {
1568     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_flushbufs");
1569     return;
1570   }
1571   device = args.device;
1572
1573   r = do_blockdev_flushbufs (device);
1574   if (r == -1)
1575     /* do_blockdev_flushbufs has already called reply_with_error */
1576     goto done;
1577
1578   reply (NULL, NULL);
1579 done:
1580   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_flushbufs_args, (char *) &args);
1581 }
1582
1583 static void blockdev_rereadpt_stub (XDR *xdr_in)
1584 {
1585   int r;
1586   struct guestfs_blockdev_rereadpt_args args;
1587   const char *device;
1588
1589   memset (&args, 0, sizeof args);
1590
1591   if (!xdr_guestfs_blockdev_rereadpt_args (xdr_in, &args)) {
1592     reply_with_error ("%s: daemon failed to decode procedure arguments", "blockdev_rereadpt");
1593     return;
1594   }
1595   device = args.device;
1596
1597   r = do_blockdev_rereadpt (device);
1598   if (r == -1)
1599     /* do_blockdev_rereadpt has already called reply_with_error */
1600     goto done;
1601
1602   reply (NULL, NULL);
1603 done:
1604   xdr_free ((xdrproc_t) xdr_guestfs_blockdev_rereadpt_args, (char *) &args);
1605 }
1606
1607 static void upload_stub (XDR *xdr_in)
1608 {
1609   int r;
1610   struct guestfs_upload_args args;
1611   const char *remotefilename;
1612
1613   memset (&args, 0, sizeof args);
1614
1615   if (!xdr_guestfs_upload_args (xdr_in, &args)) {
1616     reply_with_error ("%s: daemon failed to decode procedure arguments", "upload");
1617     return;
1618   }
1619   remotefilename = args.remotefilename;
1620
1621   r = do_upload (remotefilename);
1622   if (r == -1)
1623     /* do_upload has already called reply_with_error */
1624     goto done;
1625
1626   reply (NULL, NULL);
1627 done:
1628   xdr_free ((xdrproc_t) xdr_guestfs_upload_args, (char *) &args);
1629 }
1630
1631 static void download_stub (XDR *xdr_in)
1632 {
1633   int r;
1634   struct guestfs_download_args args;
1635   const char *remotefilename;
1636
1637   memset (&args, 0, sizeof args);
1638
1639   if (!xdr_guestfs_download_args (xdr_in, &args)) {
1640     reply_with_error ("%s: daemon failed to decode procedure arguments", "download");
1641     return;
1642   }
1643   remotefilename = args.remotefilename;
1644
1645   r = do_download (remotefilename);
1646   if (r == -1)
1647     /* do_download has already called reply_with_error */
1648     goto done;
1649
1650   /* do_download has already sent a reply */
1651 done:
1652   xdr_free ((xdrproc_t) xdr_guestfs_download_args, (char *) &args);
1653 }
1654
1655 static void checksum_stub (XDR *xdr_in)
1656 {
1657   char *r;
1658   struct guestfs_checksum_args args;
1659   const char *csumtype;
1660   const char *path;
1661
1662   memset (&args, 0, sizeof args);
1663
1664   if (!xdr_guestfs_checksum_args (xdr_in, &args)) {
1665     reply_with_error ("%s: daemon failed to decode procedure arguments", "checksum");
1666     return;
1667   }
1668   csumtype = args.csumtype;
1669   path = args.path;
1670
1671   r = do_checksum (csumtype, path);
1672   if (r == NULL)
1673     /* do_checksum has already called reply_with_error */
1674     goto done;
1675
1676   struct guestfs_checksum_ret ret;
1677   ret.checksum = r;
1678   reply ((xdrproc_t) &xdr_guestfs_checksum_ret, (char *) &ret);
1679   free (r);
1680 done:
1681   xdr_free ((xdrproc_t) xdr_guestfs_checksum_args, (char *) &args);
1682 }
1683
1684 static void tar_in_stub (XDR *xdr_in)
1685 {
1686   int r;
1687   struct guestfs_tar_in_args args;
1688   const char *directory;
1689
1690   memset (&args, 0, sizeof args);
1691
1692   if (!xdr_guestfs_tar_in_args (xdr_in, &args)) {
1693     reply_with_error ("%s: daemon failed to decode procedure arguments", "tar_in");
1694     return;
1695   }
1696   directory = args.directory;
1697
1698   r = do_tar_in (directory);
1699   if (r == -1)
1700     /* do_tar_in has already called reply_with_error */
1701     goto done;
1702
1703   reply (NULL, NULL);
1704 done:
1705   xdr_free ((xdrproc_t) xdr_guestfs_tar_in_args, (char *) &args);
1706 }
1707
1708 static void tar_out_stub (XDR *xdr_in)
1709 {
1710   int r;
1711   struct guestfs_tar_out_args args;
1712   const char *directory;
1713
1714   memset (&args, 0, sizeof args);
1715
1716   if (!xdr_guestfs_tar_out_args (xdr_in, &args)) {
1717     reply_with_error ("%s: daemon failed to decode procedure arguments", "tar_out");
1718     return;
1719   }
1720   directory = args.directory;
1721
1722   r = do_tar_out (directory);
1723   if (r == -1)
1724     /* do_tar_out has already called reply_with_error */
1725     goto done;
1726
1727   /* do_tar_out has already sent a reply */
1728 done:
1729   xdr_free ((xdrproc_t) xdr_guestfs_tar_out_args, (char *) &args);
1730 }
1731
1732 static void tgz_in_stub (XDR *xdr_in)
1733 {
1734   int r;
1735   struct guestfs_tgz_in_args args;
1736   const char *directory;
1737
1738   memset (&args, 0, sizeof args);
1739
1740   if (!xdr_guestfs_tgz_in_args (xdr_in, &args)) {
1741     reply_with_error ("%s: daemon failed to decode procedure arguments", "tgz_in");
1742     return;
1743   }
1744   directory = args.directory;
1745
1746   r = do_tgz_in (directory);
1747   if (r == -1)
1748     /* do_tgz_in has already called reply_with_error */
1749     goto done;
1750
1751   reply (NULL, NULL);
1752 done:
1753   xdr_free ((xdrproc_t) xdr_guestfs_tgz_in_args, (char *) &args);
1754 }
1755
1756 static void tgz_out_stub (XDR *xdr_in)
1757 {
1758   int r;
1759   struct guestfs_tgz_out_args args;
1760   const char *directory;
1761
1762   memset (&args, 0, sizeof args);
1763
1764   if (!xdr_guestfs_tgz_out_args (xdr_in, &args)) {
1765     reply_with_error ("%s: daemon failed to decode procedure arguments", "tgz_out");
1766     return;
1767   }
1768   directory = args.directory;
1769
1770   r = do_tgz_out (directory);
1771   if (r == -1)
1772     /* do_tgz_out has already called reply_with_error */
1773     goto done;
1774
1775   /* do_tgz_out has already sent a reply */
1776 done:
1777   xdr_free ((xdrproc_t) xdr_guestfs_tgz_out_args, (char *) &args);
1778 }
1779
1780 static void mount_ro_stub (XDR *xdr_in)
1781 {
1782   int r;
1783   struct guestfs_mount_ro_args args;
1784   const char *device;
1785   const char *mountpoint;
1786
1787   memset (&args, 0, sizeof args);
1788
1789   if (!xdr_guestfs_mount_ro_args (xdr_in, &args)) {
1790     reply_with_error ("%s: daemon failed to decode procedure arguments", "mount_ro");
1791     return;
1792   }
1793   device = args.device;
1794   mountpoint = args.mountpoint;
1795
1796   r = do_mount_ro (device, mountpoint);
1797   if (r == -1)
1798     /* do_mount_ro has already called reply_with_error */
1799     goto done;
1800
1801   reply (NULL, NULL);
1802 done:
1803   xdr_free ((xdrproc_t) xdr_guestfs_mount_ro_args, (char *) &args);
1804 }
1805
1806 static void mount_options_stub (XDR *xdr_in)
1807 {
1808   int r;
1809   struct guestfs_mount_options_args args;
1810   const char *options;
1811   const char *device;
1812   const char *mountpoint;
1813
1814   memset (&args, 0, sizeof args);
1815
1816   if (!xdr_guestfs_mount_options_args (xdr_in, &args)) {
1817     reply_with_error ("%s: daemon failed to decode procedure arguments", "mount_options");
1818     return;
1819   }
1820   options = args.options;
1821   device = args.device;
1822   mountpoint = args.mountpoint;
1823
1824   r = do_mount_options (options, device, mountpoint);
1825   if (r == -1)
1826     /* do_mount_options has already called reply_with_error */
1827     goto done;
1828
1829   reply (NULL, NULL);
1830 done:
1831   xdr_free ((xdrproc_t) xdr_guestfs_mount_options_args, (char *) &args);
1832 }
1833
1834 static void mount_vfs_stub (XDR *xdr_in)
1835 {
1836   int r;
1837   struct guestfs_mount_vfs_args args;
1838   const char *options;
1839   const char *vfstype;
1840   const char *device;
1841   const char *mountpoint;
1842
1843   memset (&args, 0, sizeof args);
1844
1845   if (!xdr_guestfs_mount_vfs_args (xdr_in, &args)) {
1846     reply_with_error ("%s: daemon failed to decode procedure arguments", "mount_vfs");
1847     return;
1848   }
1849   options = args.options;
1850   vfstype = args.vfstype;
1851   device = args.device;
1852   mountpoint = args.mountpoint;
1853
1854   r = do_mount_vfs (options, vfstype, device, mountpoint);
1855   if (r == -1)
1856     /* do_mount_vfs has already called reply_with_error */
1857     goto done;
1858
1859   reply (NULL, NULL);
1860 done:
1861   xdr_free ((xdrproc_t) xdr_guestfs_mount_vfs_args, (char *) &args);
1862 }
1863
1864 static void debug_stub (XDR *xdr_in)
1865 {
1866   char *r;
1867   struct guestfs_debug_args args;
1868   const char *subcmd;
1869   char **extraargs;
1870
1871   memset (&args, 0, sizeof args);
1872
1873   if (!xdr_guestfs_debug_args (xdr_in, &args)) {
1874     reply_with_error ("%s: daemon failed to decode procedure arguments", "debug");
1875     return;
1876   }
1877   subcmd = args.subcmd;
1878   extraargs = realloc (args.extraargs.extraargs_val,
1879                 sizeof (char *) * (args.extraargs.extraargs_len+1));
1880   if (extraargs == NULL) {
1881     reply_with_perror ("realloc");
1882     goto done;
1883   }
1884   extraargs[args.extraargs.extraargs_len] = NULL;
1885   args.extraargs.extraargs_val = extraargs;
1886
1887   r = do_debug (subcmd, extraargs);
1888   if (r == NULL)
1889     /* do_debug has already called reply_with_error */
1890     goto done;
1891
1892   struct guestfs_debug_ret ret;
1893   ret.result = r;
1894   reply ((xdrproc_t) &xdr_guestfs_debug_ret, (char *) &ret);
1895   free (r);
1896 done:
1897   xdr_free ((xdrproc_t) xdr_guestfs_debug_args, (char *) &args);
1898 }
1899
1900 static void lvremove_stub (XDR *xdr_in)
1901 {
1902   int r;
1903   struct guestfs_lvremove_args args;
1904   const char *device;
1905
1906   memset (&args, 0, sizeof args);
1907
1908   if (!xdr_guestfs_lvremove_args (xdr_in, &args)) {
1909     reply_with_error ("%s: daemon failed to decode procedure arguments", "lvremove");
1910     return;
1911   }
1912   device = args.device;
1913
1914   r = do_lvremove (device);
1915   if (r == -1)
1916     /* do_lvremove has already called reply_with_error */
1917     goto done;
1918
1919   reply (NULL, NULL);
1920 done:
1921   xdr_free ((xdrproc_t) xdr_guestfs_lvremove_args, (char *) &args);
1922 }
1923
1924 static void vgremove_stub (XDR *xdr_in)
1925 {
1926   int r;
1927   struct guestfs_vgremove_args args;
1928   const char *vgname;
1929
1930   memset (&args, 0, sizeof args);
1931
1932   if (!xdr_guestfs_vgremove_args (xdr_in, &args)) {
1933     reply_with_error ("%s: daemon failed to decode procedure arguments", "vgremove");
1934     return;
1935   }
1936   vgname = args.vgname;
1937
1938   r = do_vgremove (vgname);
1939   if (r == -1)
1940     /* do_vgremove has already called reply_with_error */
1941     goto done;
1942
1943   reply (NULL, NULL);
1944 done:
1945   xdr_free ((xdrproc_t) xdr_guestfs_vgremove_args, (char *) &args);
1946 }
1947
1948 static void pvremove_stub (XDR *xdr_in)
1949 {
1950   int r;
1951   struct guestfs_pvremove_args args;
1952   const char *device;
1953
1954   memset (&args, 0, sizeof args);
1955
1956   if (!xdr_guestfs_pvremove_args (xdr_in, &args)) {
1957     reply_with_error ("%s: daemon failed to decode procedure arguments", "pvremove");
1958     return;
1959   }
1960   device = args.device;
1961
1962   r = do_pvremove (device);
1963   if (r == -1)
1964     /* do_pvremove has already called reply_with_error */
1965     goto done;
1966
1967   reply (NULL, NULL);
1968 done:
1969   xdr_free ((xdrproc_t) xdr_guestfs_pvremove_args, (char *) &args);
1970 }
1971
1972 static void set_e2label_stub (XDR *xdr_in)
1973 {
1974   int r;
1975   struct guestfs_set_e2label_args args;
1976   const char *device;
1977   const char *label;
1978
1979   memset (&args, 0, sizeof args);
1980
1981   if (!xdr_guestfs_set_e2label_args (xdr_in, &args)) {
1982     reply_with_error ("%s: daemon failed to decode procedure arguments", "set_e2label");
1983     return;
1984   }
1985   device = args.device;
1986   label = args.label;
1987
1988   r = do_set_e2label (device, label);
1989   if (r == -1)
1990     /* do_set_e2label has already called reply_with_error */
1991     goto done;
1992
1993   reply (NULL, NULL);
1994 done:
1995   xdr_free ((xdrproc_t) xdr_guestfs_set_e2label_args, (char *) &args);
1996 }
1997
1998 static void get_e2label_stub (XDR *xdr_in)
1999 {
2000   char *r;
2001   struct guestfs_get_e2label_args args;
2002   const char *device;
2003
2004   memset (&args, 0, sizeof args);
2005
2006   if (!xdr_guestfs_get_e2label_args (xdr_in, &args)) {
2007     reply_with_error ("%s: daemon failed to decode procedure arguments", "get_e2label");
2008     return;
2009   }
2010   device = args.device;
2011
2012   r = do_get_e2label (device);
2013   if (r == NULL)
2014     /* do_get_e2label has already called reply_with_error */
2015     goto done;
2016
2017   struct guestfs_get_e2label_ret ret;
2018   ret.label = r;
2019   reply ((xdrproc_t) &xdr_guestfs_get_e2label_ret, (char *) &ret);
2020   free (r);
2021 done:
2022   xdr_free ((xdrproc_t) xdr_guestfs_get_e2label_args, (char *) &args);
2023 }
2024
2025 static void set_e2uuid_stub (XDR *xdr_in)
2026 {
2027   int r;
2028   struct guestfs_set_e2uuid_args args;
2029   const char *device;
2030   const char *uuid;
2031
2032   memset (&args, 0, sizeof args);
2033
2034   if (!xdr_guestfs_set_e2uuid_args (xdr_in, &args)) {
2035     reply_with_error ("%s: daemon failed to decode procedure arguments", "set_e2uuid");
2036     return;
2037   }
2038   device = args.device;
2039   uuid = args.uuid;
2040
2041   r = do_set_e2uuid (device, uuid);
2042   if (r == -1)
2043     /* do_set_e2uuid has already called reply_with_error */
2044     goto done;
2045
2046   reply (NULL, NULL);
2047 done:
2048   xdr_free ((xdrproc_t) xdr_guestfs_set_e2uuid_args, (char *) &args);
2049 }
2050
2051 static void get_e2uuid_stub (XDR *xdr_in)
2052 {
2053   char *r;
2054   struct guestfs_get_e2uuid_args args;
2055   const char *device;
2056
2057   memset (&args, 0, sizeof args);
2058
2059   if (!xdr_guestfs_get_e2uuid_args (xdr_in, &args)) {
2060     reply_with_error ("%s: daemon failed to decode procedure arguments", "get_e2uuid");
2061     return;
2062   }
2063   device = args.device;
2064
2065   r = do_get_e2uuid (device);
2066   if (r == NULL)
2067     /* do_get_e2uuid has already called reply_with_error */
2068     goto done;
2069
2070   struct guestfs_get_e2uuid_ret ret;
2071   ret.uuid = r;
2072   reply ((xdrproc_t) &xdr_guestfs_get_e2uuid_ret, (char *) &ret);
2073   free (r);
2074 done:
2075   xdr_free ((xdrproc_t) xdr_guestfs_get_e2uuid_args, (char *) &args);
2076 }
2077
2078 static void fsck_stub (XDR *xdr_in)
2079 {
2080   int r;
2081   struct guestfs_fsck_args args;
2082   const char *fstype;
2083   const char *device;
2084
2085   memset (&args, 0, sizeof args);
2086
2087   if (!xdr_guestfs_fsck_args (xdr_in, &args)) {
2088     reply_with_error ("%s: daemon failed to decode procedure arguments", "fsck");
2089     return;
2090   }
2091   fstype = args.fstype;
2092   device = args.device;
2093
2094   r = do_fsck (fstype, device);
2095   if (r == -1)
2096     /* do_fsck has already called reply_with_error */
2097     goto done;
2098
2099   struct guestfs_fsck_ret ret;
2100   ret.status = r;
2101   reply ((xdrproc_t) &xdr_guestfs_fsck_ret, (char *) &ret);
2102 done:
2103   xdr_free ((xdrproc_t) xdr_guestfs_fsck_args, (char *) &args);
2104 }
2105
2106 static void zero_stub (XDR *xdr_in)
2107 {
2108   int r;
2109   struct guestfs_zero_args args;
2110   const char *device;
2111
2112   memset (&args, 0, sizeof args);
2113
2114   if (!xdr_guestfs_zero_args (xdr_in, &args)) {
2115     reply_with_error ("%s: daemon failed to decode procedure arguments", "zero");
2116     return;
2117   }
2118   device = args.device;
2119
2120   r = do_zero (device);
2121   if (r == -1)
2122     /* do_zero has already called reply_with_error */
2123     goto done;
2124
2125   reply (NULL, NULL);
2126 done:
2127   xdr_free ((xdrproc_t) xdr_guestfs_zero_args, (char *) &args);
2128 }
2129
2130 void dispatch_incoming_message (XDR *xdr_in)
2131 {
2132   switch (proc_nr) {
2133     case GUESTFS_PROC_MOUNT:
2134       mount_stub (xdr_in);
2135       break;
2136     case GUESTFS_PROC_SYNC:
2137       sync_stub (xdr_in);
2138       break;
2139     case GUESTFS_PROC_TOUCH:
2140       touch_stub (xdr_in);
2141       break;
2142     case GUESTFS_PROC_CAT:
2143       cat_stub (xdr_in);
2144       break;
2145     case GUESTFS_PROC_LL:
2146       ll_stub (xdr_in);
2147       break;
2148     case GUESTFS_PROC_LS:
2149       ls_stub (xdr_in);
2150       break;
2151     case GUESTFS_PROC_LIST_DEVICES:
2152       list_devices_stub (xdr_in);
2153       break;
2154     case GUESTFS_PROC_LIST_PARTITIONS:
2155       list_partitions_stub (xdr_in);
2156       break;
2157     case GUESTFS_PROC_PVS:
2158       pvs_stub (xdr_in);
2159       break;
2160     case GUESTFS_PROC_VGS:
2161       vgs_stub (xdr_in);
2162       break;
2163     case GUESTFS_PROC_LVS:
2164       lvs_stub (xdr_in);
2165       break;
2166     case GUESTFS_PROC_PVS_FULL:
2167       pvs_full_stub (xdr_in);
2168       break;
2169     case GUESTFS_PROC_VGS_FULL:
2170       vgs_full_stub (xdr_in);
2171       break;
2172     case GUESTFS_PROC_LVS_FULL:
2173       lvs_full_stub (xdr_in);
2174       break;
2175     case GUESTFS_PROC_READ_LINES:
2176       read_lines_stub (xdr_in);
2177       break;
2178     case GUESTFS_PROC_AUG_INIT:
2179       aug_init_stub (xdr_in);
2180       break;
2181     case GUESTFS_PROC_AUG_CLOSE:
2182       aug_close_stub (xdr_in);
2183       break;
2184     case GUESTFS_PROC_AUG_DEFVAR:
2185       aug_defvar_stub (xdr_in);
2186       break;
2187     case GUESTFS_PROC_AUG_DEFNODE:
2188       aug_defnode_stub (xdr_in);
2189       break;
2190     case GUESTFS_PROC_AUG_GET:
2191       aug_get_stub (xdr_in);
2192       break;
2193     case GUESTFS_PROC_AUG_SET:
2194       aug_set_stub (xdr_in);
2195       break;
2196     case GUESTFS_PROC_AUG_INSERT:
2197       aug_insert_stub (xdr_in);
2198       break;
2199     case GUESTFS_PROC_AUG_RM:
2200       aug_rm_stub (xdr_in);
2201       break;
2202     case GUESTFS_PROC_AUG_MV:
2203       aug_mv_stub (xdr_in);
2204       break;
2205     case GUESTFS_PROC_AUG_MATCH:
2206       aug_match_stub (xdr_in);
2207       break;
2208     case GUESTFS_PROC_AUG_SAVE:
2209       aug_save_stub (xdr_in);
2210       break;
2211     case GUESTFS_PROC_AUG_LOAD:
2212       aug_load_stub (xdr_in);
2213       break;
2214     case GUESTFS_PROC_AUG_LS:
2215       aug_ls_stub (xdr_in);
2216       break;
2217     case GUESTFS_PROC_RM:
2218       rm_stub (xdr_in);
2219       break;
2220     case GUESTFS_PROC_RMDIR:
2221       rmdir_stub (xdr_in);
2222       break;
2223     case GUESTFS_PROC_RM_RF:
2224       rm_rf_stub (xdr_in);
2225       break;
2226     case GUESTFS_PROC_MKDIR:
2227       mkdir_stub (xdr_in);
2228       break;
2229     case GUESTFS_PROC_MKDIR_P:
2230       mkdir_p_stub (xdr_in);
2231       break;
2232     case GUESTFS_PROC_CHMOD:
2233       chmod_stub (xdr_in);
2234       break;
2235     case GUESTFS_PROC_CHOWN:
2236       chown_stub (xdr_in);
2237       break;
2238     case GUESTFS_PROC_EXISTS:
2239       exists_stub (xdr_in);
2240       break;
2241     case GUESTFS_PROC_IS_FILE:
2242       is_file_stub (xdr_in);
2243       break;
2244     case GUESTFS_PROC_IS_DIR:
2245       is_dir_stub (xdr_in);
2246       break;
2247     case GUESTFS_PROC_PVCREATE:
2248       pvcreate_stub (xdr_in);
2249       break;
2250     case GUESTFS_PROC_VGCREATE:
2251       vgcreate_stub (xdr_in);
2252       break;
2253     case GUESTFS_PROC_LVCREATE:
2254       lvcreate_stub (xdr_in);
2255       break;
2256     case GUESTFS_PROC_MKFS:
2257       mkfs_stub (xdr_in);
2258       break;
2259     case GUESTFS_PROC_SFDISK:
2260       sfdisk_stub (xdr_in);
2261       break;
2262     case GUESTFS_PROC_WRITE_FILE:
2263       write_file_stub (xdr_in);
2264       break;
2265     case GUESTFS_PROC_UMOUNT:
2266       umount_stub (xdr_in);
2267       break;
2268     case GUESTFS_PROC_MOUNTS:
2269       mounts_stub (xdr_in);
2270       break;
2271     case GUESTFS_PROC_UMOUNT_ALL:
2272       umount_all_stub (xdr_in);
2273       break;
2274     case GUESTFS_PROC_LVM_REMOVE_ALL:
2275       lvm_remove_all_stub (xdr_in);
2276       break;
2277     case GUESTFS_PROC_FILE:
2278       file_stub (xdr_in);
2279       break;
2280     case GUESTFS_PROC_COMMAND:
2281       command_stub (xdr_in);
2282       break;
2283     case GUESTFS_PROC_COMMAND_LINES:
2284       command_lines_stub (xdr_in);
2285       break;
2286     case GUESTFS_PROC_STAT:
2287       stat_stub (xdr_in);
2288       break;
2289     case GUESTFS_PROC_LSTAT:
2290       lstat_stub (xdr_in);
2291       break;
2292     case GUESTFS_PROC_STATVFS:
2293       statvfs_stub (xdr_in);
2294       break;
2295     case GUESTFS_PROC_TUNE2FS_L:
2296       tune2fs_l_stub (xdr_in);
2297       break;
2298     case GUESTFS_PROC_BLOCKDEV_SETRO:
2299       blockdev_setro_stub (xdr_in);
2300       break;
2301     case GUESTFS_PROC_BLOCKDEV_SETRW:
2302       blockdev_setrw_stub (xdr_in);
2303       break;
2304     case GUESTFS_PROC_BLOCKDEV_GETRO:
2305       blockdev_getro_stub (xdr_in);
2306       break;
2307     case GUESTFS_PROC_BLOCKDEV_GETSS:
2308       blockdev_getss_stub (xdr_in);
2309       break;
2310     case GUESTFS_PROC_BLOCKDEV_GETBSZ:
2311       blockdev_getbsz_stub (xdr_in);
2312       break;
2313     case GUESTFS_PROC_BLOCKDEV_SETBSZ:
2314       blockdev_setbsz_stub (xdr_in);
2315       break;
2316     case GUESTFS_PROC_BLOCKDEV_GETSZ:
2317       blockdev_getsz_stub (xdr_in);
2318       break;
2319     case GUESTFS_PROC_BLOCKDEV_GETSIZE64:
2320       blockdev_getsize64_stub (xdr_in);
2321       break;
2322     case GUESTFS_PROC_BLOCKDEV_FLUSHBUFS:
2323       blockdev_flushbufs_stub (xdr_in);
2324       break;
2325     case GUESTFS_PROC_BLOCKDEV_REREADPT:
2326       blockdev_rereadpt_stub (xdr_in);
2327       break;
2328     case GUESTFS_PROC_UPLOAD:
2329       upload_stub (xdr_in);
2330       break;
2331     case GUESTFS_PROC_DOWNLOAD:
2332       download_stub (xdr_in);
2333       break;
2334     case GUESTFS_PROC_CHECKSUM:
2335       checksum_stub (xdr_in);
2336       break;
2337     case GUESTFS_PROC_TAR_IN:
2338       tar_in_stub (xdr_in);
2339       break;
2340     case GUESTFS_PROC_TAR_OUT:
2341       tar_out_stub (xdr_in);
2342       break;
2343     case GUESTFS_PROC_TGZ_IN:
2344       tgz_in_stub (xdr_in);
2345       break;
2346     case GUESTFS_PROC_TGZ_OUT:
2347       tgz_out_stub (xdr_in);
2348       break;
2349     case GUESTFS_PROC_MOUNT_RO:
2350       mount_ro_stub (xdr_in);
2351       break;
2352     case GUESTFS_PROC_MOUNT_OPTIONS:
2353       mount_options_stub (xdr_in);
2354       break;
2355     case GUESTFS_PROC_MOUNT_VFS:
2356       mount_vfs_stub (xdr_in);
2357       break;
2358     case GUESTFS_PROC_DEBUG:
2359       debug_stub (xdr_in);
2360       break;
2361     case GUESTFS_PROC_LVREMOVE:
2362       lvremove_stub (xdr_in);
2363       break;
2364     case GUESTFS_PROC_VGREMOVE:
2365       vgremove_stub (xdr_in);
2366       break;
2367     case GUESTFS_PROC_PVREMOVE:
2368       pvremove_stub (xdr_in);
2369       break;
2370     case GUESTFS_PROC_SET_E2LABEL:
2371       set_e2label_stub (xdr_in);
2372       break;
2373     case GUESTFS_PROC_GET_E2LABEL:
2374       get_e2label_stub (xdr_in);
2375       break;
2376     case GUESTFS_PROC_SET_E2UUID:
2377       set_e2uuid_stub (xdr_in);
2378       break;
2379     case GUESTFS_PROC_GET_E2UUID:
2380       get_e2uuid_stub (xdr_in);
2381       break;
2382     case GUESTFS_PROC_FSCK:
2383       fsck_stub (xdr_in);
2384       break;
2385     case GUESTFS_PROC_ZERO:
2386       zero_stub (xdr_in);
2387       break;
2388     default:
2389       reply_with_error ("dispatch_incoming_message: unknown procedure number %d", proc_nr);
2390   }
2391 }
2392
2393 static const char *lvm_pv_cols = "pv_name,pv_uuid,pv_fmt,pv_size,dev_size,pv_free,pv_used,pv_attr,pv_pe_count,pv_pe_alloc_count,pv_tags,pe_start,pv_mda_count,pv_mda_free";
2394
2395 static int lvm_tokenize_pv (char *str, struct guestfs_lvm_int_pv *r)
2396 {
2397   char *tok, *p, *next;
2398   int i, j;
2399
2400   if (!str) {
2401     fprintf (stderr, "%s: failed: passed a NULL string\n", __func__);
2402     return -1;
2403   }
2404   if (!*str || isspace (*str)) {
2405     fprintf (stderr, "%s: failed: passed a empty string or one beginning with whitespace\n", __func__);
2406     return -1;
2407   }
2408   tok = str;
2409   if (!tok) {
2410     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_name");
2411     return -1;
2412   }
2413   p = strchrnul (tok, ',');
2414   if (*p) next = p+1; else next = NULL;
2415   *p = '\0';
2416   r->pv_name = strdup (tok);
2417   if (r->pv_name == NULL) {
2418     perror ("strdup");
2419     return -1;
2420   }
2421   tok = next;
2422   if (!tok) {
2423     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_uuid");
2424     return -1;
2425   }
2426   p = strchrnul (tok, ',');
2427   if (*p) next = p+1; else next = NULL;
2428   *p = '\0';
2429   for (i = j = 0; i < 32; ++j) {
2430     if (tok[j] == '\0') {
2431       fprintf (stderr, "%s: failed to parse UUID from '%s'\n", __func__, tok);
2432       return -1;
2433     } else if (tok[j] != '-')
2434       r->pv_uuid[i++] = tok[j];
2435   }
2436   tok = next;
2437   if (!tok) {
2438     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_fmt");
2439     return -1;
2440   }
2441   p = strchrnul (tok, ',');
2442   if (*p) next = p+1; else next = NULL;
2443   *p = '\0';
2444   r->pv_fmt = strdup (tok);
2445   if (r->pv_fmt == NULL) {
2446     perror ("strdup");
2447     return -1;
2448   }
2449   tok = next;
2450   if (!tok) {
2451     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_size");
2452     return -1;
2453   }
2454   p = strchrnul (tok, ',');
2455   if (*p) next = p+1; else next = NULL;
2456   *p = '\0';
2457   if (sscanf (tok, "%"SCNu64, &r->pv_size) != 1) {
2458     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "pv_size");
2459     return -1;
2460   }
2461   tok = next;
2462   if (!tok) {
2463     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "dev_size");
2464     return -1;
2465   }
2466   p = strchrnul (tok, ',');
2467   if (*p) next = p+1; else next = NULL;
2468   *p = '\0';
2469   if (sscanf (tok, "%"SCNu64, &r->dev_size) != 1) {
2470     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "dev_size");
2471     return -1;
2472   }
2473   tok = next;
2474   if (!tok) {
2475     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_free");
2476     return -1;
2477   }
2478   p = strchrnul (tok, ',');
2479   if (*p) next = p+1; else next = NULL;
2480   *p = '\0';
2481   if (sscanf (tok, "%"SCNu64, &r->pv_free) != 1) {
2482     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "pv_free");
2483     return -1;
2484   }
2485   tok = next;
2486   if (!tok) {
2487     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_used");
2488     return -1;
2489   }
2490   p = strchrnul (tok, ',');
2491   if (*p) next = p+1; else next = NULL;
2492   *p = '\0';
2493   if (sscanf (tok, "%"SCNu64, &r->pv_used) != 1) {
2494     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "pv_used");
2495     return -1;
2496   }
2497   tok = next;
2498   if (!tok) {
2499     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_attr");
2500     return -1;
2501   }
2502   p = strchrnul (tok, ',');
2503   if (*p) next = p+1; else next = NULL;
2504   *p = '\0';
2505   r->pv_attr = strdup (tok);
2506   if (r->pv_attr == NULL) {
2507     perror ("strdup");
2508     return -1;
2509   }
2510   tok = next;
2511   if (!tok) {
2512     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_pe_count");
2513     return -1;
2514   }
2515   p = strchrnul (tok, ',');
2516   if (*p) next = p+1; else next = NULL;
2517   *p = '\0';
2518   if (sscanf (tok, "%"SCNi64, &r->pv_pe_count) != 1) {
2519     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "pv_pe_count");
2520     return -1;
2521   }
2522   tok = next;
2523   if (!tok) {
2524     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_pe_alloc_count");
2525     return -1;
2526   }
2527   p = strchrnul (tok, ',');
2528   if (*p) next = p+1; else next = NULL;
2529   *p = '\0';
2530   if (sscanf (tok, "%"SCNi64, &r->pv_pe_alloc_count) != 1) {
2531     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "pv_pe_alloc_count");
2532     return -1;
2533   }
2534   tok = next;
2535   if (!tok) {
2536     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_tags");
2537     return -1;
2538   }
2539   p = strchrnul (tok, ',');
2540   if (*p) next = p+1; else next = NULL;
2541   *p = '\0';
2542   r->pv_tags = strdup (tok);
2543   if (r->pv_tags == NULL) {
2544     perror ("strdup");
2545     return -1;
2546   }
2547   tok = next;
2548   if (!tok) {
2549     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pe_start");
2550     return -1;
2551   }
2552   p = strchrnul (tok, ',');
2553   if (*p) next = p+1; else next = NULL;
2554   *p = '\0';
2555   if (sscanf (tok, "%"SCNu64, &r->pe_start) != 1) {
2556     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "pe_start");
2557     return -1;
2558   }
2559   tok = next;
2560   if (!tok) {
2561     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_mda_count");
2562     return -1;
2563   }
2564   p = strchrnul (tok, ',');
2565   if (*p) next = p+1; else next = NULL;
2566   *p = '\0';
2567   if (sscanf (tok, "%"SCNi64, &r->pv_mda_count) != 1) {
2568     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "pv_mda_count");
2569     return -1;
2570   }
2571   tok = next;
2572   if (!tok) {
2573     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_mda_free");
2574     return -1;
2575   }
2576   p = strchrnul (tok, ',');
2577   if (*p) next = p+1; else next = NULL;
2578   *p = '\0';
2579   if (sscanf (tok, "%"SCNu64, &r->pv_mda_free) != 1) {
2580     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "pv_mda_free");
2581     return -1;
2582   }
2583   tok = next;
2584   if (tok != NULL) {
2585     fprintf (stderr, "%s: failed: extra tokens at end of string\n", __func__);
2586     return -1;
2587   }
2588   return 0;
2589 }
2590
2591 guestfs_lvm_int_pv_list *
2592 parse_command_line_pvs (void)
2593 {
2594   char *out, *err;
2595   char *p, *pend;
2596   int r, i;
2597   guestfs_lvm_int_pv_list *ret;
2598   void *newp;
2599
2600   ret = malloc (sizeof *ret);
2601   if (!ret) {
2602     reply_with_perror ("malloc");
2603     return NULL;
2604   }
2605
2606   ret->guestfs_lvm_int_pv_list_len = 0;
2607   ret->guestfs_lvm_int_pv_list_val = NULL;
2608
2609   r = command (&out, &err,
2610                "/sbin/lvm", "pvs",
2611                "-o", lvm_pv_cols, "--unbuffered", "--noheadings",
2612                "--nosuffix", "--separator", ",", "--units", "b", NULL);
2613   if (r == -1) {
2614     reply_with_error ("%s", err);
2615     free (out);
2616     free (err);
2617     free (ret);
2618     return NULL;
2619   }
2620
2621   free (err);
2622
2623   /* Tokenize each line of the output. */
2624   p = out;
2625   i = 0;
2626   while (p) {
2627     pend = strchr (p, '\n');    /* Get the next line of output. */
2628     if (pend) {
2629       *pend = '\0';
2630       pend++;
2631     }
2632
2633     while (*p && isspace (*p))  /* Skip any leading whitespace. */
2634       p++;
2635
2636     if (!*p) {                  /* Empty line?  Skip it. */
2637       p = pend;
2638       continue;
2639     }
2640
2641     /* Allocate some space to store this next entry. */
2642     newp = realloc (ret->guestfs_lvm_int_pv_list_val,
2643                     sizeof (guestfs_lvm_int_pv) * (i+1));
2644     if (newp == NULL) {
2645       reply_with_perror ("realloc");
2646       free (ret->guestfs_lvm_int_pv_list_val);
2647       free (ret);
2648       free (out);
2649       return NULL;
2650     }
2651     ret->guestfs_lvm_int_pv_list_val = newp;
2652
2653     /* Tokenize the next entry. */
2654     r = lvm_tokenize_pv (p, &ret->guestfs_lvm_int_pv_list_val[i]);
2655     if (r == -1) {
2656       reply_with_error ("failed to parse output of 'pvs' command");
2657       free (ret->guestfs_lvm_int_pv_list_val);
2658       free (ret);
2659       free (out);
2660       return NULL;
2661     }
2662
2663     ++i;
2664     p = pend;
2665   }
2666
2667   ret->guestfs_lvm_int_pv_list_len = i;
2668
2669   free (out);
2670   return ret;
2671 }
2672 static const char *lvm_vg_cols = "vg_name,vg_uuid,vg_fmt,vg_attr,vg_size,vg_free,vg_sysid,vg_extent_size,vg_extent_count,vg_free_count,max_lv,max_pv,pv_count,lv_count,snap_count,vg_seqno,vg_tags,vg_mda_count,vg_mda_free";
2673
2674 static int lvm_tokenize_vg (char *str, struct guestfs_lvm_int_vg *r)
2675 {
2676   char *tok, *p, *next;
2677   int i, j;
2678
2679   if (!str) {
2680     fprintf (stderr, "%s: failed: passed a NULL string\n", __func__);
2681     return -1;
2682   }
2683   if (!*str || isspace (*str)) {
2684     fprintf (stderr, "%s: failed: passed a empty string or one beginning with whitespace\n", __func__);
2685     return -1;
2686   }
2687   tok = str;
2688   if (!tok) {
2689     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_name");
2690     return -1;
2691   }
2692   p = strchrnul (tok, ',');
2693   if (*p) next = p+1; else next = NULL;
2694   *p = '\0';
2695   r->vg_name = strdup (tok);
2696   if (r->vg_name == NULL) {
2697     perror ("strdup");
2698     return -1;
2699   }
2700   tok = next;
2701   if (!tok) {
2702     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_uuid");
2703     return -1;
2704   }
2705   p = strchrnul (tok, ',');
2706   if (*p) next = p+1; else next = NULL;
2707   *p = '\0';
2708   for (i = j = 0; i < 32; ++j) {
2709     if (tok[j] == '\0') {
2710       fprintf (stderr, "%s: failed to parse UUID from '%s'\n", __func__, tok);
2711       return -1;
2712     } else if (tok[j] != '-')
2713       r->vg_uuid[i++] = tok[j];
2714   }
2715   tok = next;
2716   if (!tok) {
2717     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_fmt");
2718     return -1;
2719   }
2720   p = strchrnul (tok, ',');
2721   if (*p) next = p+1; else next = NULL;
2722   *p = '\0';
2723   r->vg_fmt = strdup (tok);
2724   if (r->vg_fmt == NULL) {
2725     perror ("strdup");
2726     return -1;
2727   }
2728   tok = next;
2729   if (!tok) {
2730     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_attr");
2731     return -1;
2732   }
2733   p = strchrnul (tok, ',');
2734   if (*p) next = p+1; else next = NULL;
2735   *p = '\0';
2736   r->vg_attr = strdup (tok);
2737   if (r->vg_attr == NULL) {
2738     perror ("strdup");
2739     return -1;
2740   }
2741   tok = next;
2742   if (!tok) {
2743     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_size");
2744     return -1;
2745   }
2746   p = strchrnul (tok, ',');
2747   if (*p) next = p+1; else next = NULL;
2748   *p = '\0';
2749   if (sscanf (tok, "%"SCNu64, &r->vg_size) != 1) {
2750     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "vg_size");
2751     return -1;
2752   }
2753   tok = next;
2754   if (!tok) {
2755     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_free");
2756     return -1;
2757   }
2758   p = strchrnul (tok, ',');
2759   if (*p) next = p+1; else next = NULL;
2760   *p = '\0';
2761   if (sscanf (tok, "%"SCNu64, &r->vg_free) != 1) {
2762     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "vg_free");
2763     return -1;
2764   }
2765   tok = next;
2766   if (!tok) {
2767     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_sysid");
2768     return -1;
2769   }
2770   p = strchrnul (tok, ',');
2771   if (*p) next = p+1; else next = NULL;
2772   *p = '\0';
2773   r->vg_sysid = strdup (tok);
2774   if (r->vg_sysid == NULL) {
2775     perror ("strdup");
2776     return -1;
2777   }
2778   tok = next;
2779   if (!tok) {
2780     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_extent_size");
2781     return -1;
2782   }
2783   p = strchrnul (tok, ',');
2784   if (*p) next = p+1; else next = NULL;
2785   *p = '\0';
2786   if (sscanf (tok, "%"SCNu64, &r->vg_extent_size) != 1) {
2787     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "vg_extent_size");
2788     return -1;
2789   }
2790   tok = next;
2791   if (!tok) {
2792     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_extent_count");
2793     return -1;
2794   }
2795   p = strchrnul (tok, ',');
2796   if (*p) next = p+1; else next = NULL;
2797   *p = '\0';
2798   if (sscanf (tok, "%"SCNi64, &r->vg_extent_count) != 1) {
2799     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "vg_extent_count");
2800     return -1;
2801   }
2802   tok = next;
2803   if (!tok) {
2804     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_free_count");
2805     return -1;
2806   }
2807   p = strchrnul (tok, ',');
2808   if (*p) next = p+1; else next = NULL;
2809   *p = '\0';
2810   if (sscanf (tok, "%"SCNi64, &r->vg_free_count) != 1) {
2811     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "vg_free_count");
2812     return -1;
2813   }
2814   tok = next;
2815   if (!tok) {
2816     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "max_lv");
2817     return -1;
2818   }
2819   p = strchrnul (tok, ',');
2820   if (*p) next = p+1; else next = NULL;
2821   *p = '\0';
2822   if (sscanf (tok, "%"SCNi64, &r->max_lv) != 1) {
2823     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "max_lv");
2824     return -1;
2825   }
2826   tok = next;
2827   if (!tok) {
2828     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "max_pv");
2829     return -1;
2830   }
2831   p = strchrnul (tok, ',');
2832   if (*p) next = p+1; else next = NULL;
2833   *p = '\0';
2834   if (sscanf (tok, "%"SCNi64, &r->max_pv) != 1) {
2835     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "max_pv");
2836     return -1;
2837   }
2838   tok = next;
2839   if (!tok) {
2840     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "pv_count");
2841     return -1;
2842   }
2843   p = strchrnul (tok, ',');
2844   if (*p) next = p+1; else next = NULL;
2845   *p = '\0';
2846   if (sscanf (tok, "%"SCNi64, &r->pv_count) != 1) {
2847     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "pv_count");
2848     return -1;
2849   }
2850   tok = next;
2851   if (!tok) {
2852     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_count");
2853     return -1;
2854   }
2855   p = strchrnul (tok, ',');
2856   if (*p) next = p+1; else next = NULL;
2857   *p = '\0';
2858   if (sscanf (tok, "%"SCNi64, &r->lv_count) != 1) {
2859     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "lv_count");
2860     return -1;
2861   }
2862   tok = next;
2863   if (!tok) {
2864     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "snap_count");
2865     return -1;
2866   }
2867   p = strchrnul (tok, ',');
2868   if (*p) next = p+1; else next = NULL;
2869   *p = '\0';
2870   if (sscanf (tok, "%"SCNi64, &r->snap_count) != 1) {
2871     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "snap_count");
2872     return -1;
2873   }
2874   tok = next;
2875   if (!tok) {
2876     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_seqno");
2877     return -1;
2878   }
2879   p = strchrnul (tok, ',');
2880   if (*p) next = p+1; else next = NULL;
2881   *p = '\0';
2882   if (sscanf (tok, "%"SCNi64, &r->vg_seqno) != 1) {
2883     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "vg_seqno");
2884     return -1;
2885   }
2886   tok = next;
2887   if (!tok) {
2888     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_tags");
2889     return -1;
2890   }
2891   p = strchrnul (tok, ',');
2892   if (*p) next = p+1; else next = NULL;
2893   *p = '\0';
2894   r->vg_tags = strdup (tok);
2895   if (r->vg_tags == NULL) {
2896     perror ("strdup");
2897     return -1;
2898   }
2899   tok = next;
2900   if (!tok) {
2901     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_mda_count");
2902     return -1;
2903   }
2904   p = strchrnul (tok, ',');
2905   if (*p) next = p+1; else next = NULL;
2906   *p = '\0';
2907   if (sscanf (tok, "%"SCNi64, &r->vg_mda_count) != 1) {
2908     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "vg_mda_count");
2909     return -1;
2910   }
2911   tok = next;
2912   if (!tok) {
2913     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "vg_mda_free");
2914     return -1;
2915   }
2916   p = strchrnul (tok, ',');
2917   if (*p) next = p+1; else next = NULL;
2918   *p = '\0';
2919   if (sscanf (tok, "%"SCNu64, &r->vg_mda_free) != 1) {
2920     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "vg_mda_free");
2921     return -1;
2922   }
2923   tok = next;
2924   if (tok != NULL) {
2925     fprintf (stderr, "%s: failed: extra tokens at end of string\n", __func__);
2926     return -1;
2927   }
2928   return 0;
2929 }
2930
2931 guestfs_lvm_int_vg_list *
2932 parse_command_line_vgs (void)
2933 {
2934   char *out, *err;
2935   char *p, *pend;
2936   int r, i;
2937   guestfs_lvm_int_vg_list *ret;
2938   void *newp;
2939
2940   ret = malloc (sizeof *ret);
2941   if (!ret) {
2942     reply_with_perror ("malloc");
2943     return NULL;
2944   }
2945
2946   ret->guestfs_lvm_int_vg_list_len = 0;
2947   ret->guestfs_lvm_int_vg_list_val = NULL;
2948
2949   r = command (&out, &err,
2950                "/sbin/lvm", "vgs",
2951                "-o", lvm_vg_cols, "--unbuffered", "--noheadings",
2952                "--nosuffix", "--separator", ",", "--units", "b", NULL);
2953   if (r == -1) {
2954     reply_with_error ("%s", err);
2955     free (out);
2956     free (err);
2957     free (ret);
2958     return NULL;
2959   }
2960
2961   free (err);
2962
2963   /* Tokenize each line of the output. */
2964   p = out;
2965   i = 0;
2966   while (p) {
2967     pend = strchr (p, '\n');    /* Get the next line of output. */
2968     if (pend) {
2969       *pend = '\0';
2970       pend++;
2971     }
2972
2973     while (*p && isspace (*p))  /* Skip any leading whitespace. */
2974       p++;
2975
2976     if (!*p) {                  /* Empty line?  Skip it. */
2977       p = pend;
2978       continue;
2979     }
2980
2981     /* Allocate some space to store this next entry. */
2982     newp = realloc (ret->guestfs_lvm_int_vg_list_val,
2983                     sizeof (guestfs_lvm_int_vg) * (i+1));
2984     if (newp == NULL) {
2985       reply_with_perror ("realloc");
2986       free (ret->guestfs_lvm_int_vg_list_val);
2987       free (ret);
2988       free (out);
2989       return NULL;
2990     }
2991     ret->guestfs_lvm_int_vg_list_val = newp;
2992
2993     /* Tokenize the next entry. */
2994     r = lvm_tokenize_vg (p, &ret->guestfs_lvm_int_vg_list_val[i]);
2995     if (r == -1) {
2996       reply_with_error ("failed to parse output of 'vgs' command");
2997       free (ret->guestfs_lvm_int_vg_list_val);
2998       free (ret);
2999       free (out);
3000       return NULL;
3001     }
3002
3003     ++i;
3004     p = pend;
3005   }
3006
3007   ret->guestfs_lvm_int_vg_list_len = i;
3008
3009   free (out);
3010   return ret;
3011 }
3012 static const char *lvm_lv_cols = "lv_name,lv_uuid,lv_attr,lv_major,lv_minor,lv_kernel_major,lv_kernel_minor,lv_size,seg_count,origin,snap_percent,copy_percent,move_pv,lv_tags,mirror_log,modules";
3013
3014 static int lvm_tokenize_lv (char *str, struct guestfs_lvm_int_lv *r)
3015 {
3016   char *tok, *p, *next;
3017   int i, j;
3018
3019   if (!str) {
3020     fprintf (stderr, "%s: failed: passed a NULL string\n", __func__);
3021     return -1;
3022   }
3023   if (!*str || isspace (*str)) {
3024     fprintf (stderr, "%s: failed: passed a empty string or one beginning with whitespace\n", __func__);
3025     return -1;
3026   }
3027   tok = str;
3028   if (!tok) {
3029     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_name");
3030     return -1;
3031   }
3032   p = strchrnul (tok, ',');
3033   if (*p) next = p+1; else next = NULL;
3034   *p = '\0';
3035   r->lv_name = strdup (tok);
3036   if (r->lv_name == NULL) {
3037     perror ("strdup");
3038     return -1;
3039   }
3040   tok = next;
3041   if (!tok) {
3042     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_uuid");
3043     return -1;
3044   }
3045   p = strchrnul (tok, ',');
3046   if (*p) next = p+1; else next = NULL;
3047   *p = '\0';
3048   for (i = j = 0; i < 32; ++j) {
3049     if (tok[j] == '\0') {
3050       fprintf (stderr, "%s: failed to parse UUID from '%s'\n", __func__, tok);
3051       return -1;
3052     } else if (tok[j] != '-')
3053       r->lv_uuid[i++] = tok[j];
3054   }
3055   tok = next;
3056   if (!tok) {
3057     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_attr");
3058     return -1;
3059   }
3060   p = strchrnul (tok, ',');
3061   if (*p) next = p+1; else next = NULL;
3062   *p = '\0';
3063   r->lv_attr = strdup (tok);
3064   if (r->lv_attr == NULL) {
3065     perror ("strdup");
3066     return -1;
3067   }
3068   tok = next;
3069   if (!tok) {
3070     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_major");
3071     return -1;
3072   }
3073   p = strchrnul (tok, ',');
3074   if (*p) next = p+1; else next = NULL;
3075   *p = '\0';
3076   if (sscanf (tok, "%"SCNi64, &r->lv_major) != 1) {
3077     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "lv_major");
3078     return -1;
3079   }
3080   tok = next;
3081   if (!tok) {
3082     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_minor");
3083     return -1;
3084   }
3085   p = strchrnul (tok, ',');
3086   if (*p) next = p+1; else next = NULL;
3087   *p = '\0';
3088   if (sscanf (tok, "%"SCNi64, &r->lv_minor) != 1) {
3089     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "lv_minor");
3090     return -1;
3091   }
3092   tok = next;
3093   if (!tok) {
3094     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_kernel_major");
3095     return -1;
3096   }
3097   p = strchrnul (tok, ',');
3098   if (*p) next = p+1; else next = NULL;
3099   *p = '\0';
3100   if (sscanf (tok, "%"SCNi64, &r->lv_kernel_major) != 1) {
3101     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "lv_kernel_major");
3102     return -1;
3103   }
3104   tok = next;
3105   if (!tok) {
3106     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_kernel_minor");
3107     return -1;
3108   }
3109   p = strchrnul (tok, ',');
3110   if (*p) next = p+1; else next = NULL;
3111   *p = '\0';
3112   if (sscanf (tok, "%"SCNi64, &r->lv_kernel_minor) != 1) {
3113     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "lv_kernel_minor");
3114     return -1;
3115   }
3116   tok = next;
3117   if (!tok) {
3118     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_size");
3119     return -1;
3120   }
3121   p = strchrnul (tok, ',');
3122   if (*p) next = p+1; else next = NULL;
3123   *p = '\0';
3124   if (sscanf (tok, "%"SCNu64, &r->lv_size) != 1) {
3125     fprintf (stderr, "%s: failed to parse size '%s' from token %s\n", __func__, tok, "lv_size");
3126     return -1;
3127   }
3128   tok = next;
3129   if (!tok) {
3130     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "seg_count");
3131     return -1;
3132   }
3133   p = strchrnul (tok, ',');
3134   if (*p) next = p+1; else next = NULL;
3135   *p = '\0';
3136   if (sscanf (tok, "%"SCNi64, &r->seg_count) != 1) {
3137     fprintf (stderr, "%s: failed to parse int '%s' from token %s\n", __func__, tok, "seg_count");
3138     return -1;
3139   }
3140   tok = next;
3141   if (!tok) {
3142     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "origin");
3143     return -1;
3144   }
3145   p = strchrnul (tok, ',');
3146   if (*p) next = p+1; else next = NULL;
3147   *p = '\0';
3148   r->origin = strdup (tok);
3149   if (r->origin == NULL) {
3150     perror ("strdup");
3151     return -1;
3152   }
3153   tok = next;
3154   if (!tok) {
3155     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "snap_percent");
3156     return -1;
3157   }
3158   p = strchrnul (tok, ',');
3159   if (*p) next = p+1; else next = NULL;
3160   *p = '\0';
3161   if (tok[0] == '\0')
3162     r->snap_percent = -1;
3163   else if (sscanf (tok, "%f", &r->snap_percent) != 1) {
3164     fprintf (stderr, "%s: failed to parse float '%s' from token %s\n", __func__, tok, "snap_percent");
3165     return -1;
3166   }
3167   tok = next;
3168   if (!tok) {
3169     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "copy_percent");
3170     return -1;
3171   }
3172   p = strchrnul (tok, ',');
3173   if (*p) next = p+1; else next = NULL;
3174   *p = '\0';
3175   if (tok[0] == '\0')
3176     r->copy_percent = -1;
3177   else if (sscanf (tok, "%f", &r->copy_percent) != 1) {
3178     fprintf (stderr, "%s: failed to parse float '%s' from token %s\n", __func__, tok, "copy_percent");
3179     return -1;
3180   }
3181   tok = next;
3182   if (!tok) {
3183     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "move_pv");
3184     return -1;
3185   }
3186   p = strchrnul (tok, ',');
3187   if (*p) next = p+1; else next = NULL;
3188   *p = '\0';
3189   r->move_pv = strdup (tok);
3190   if (r->move_pv == NULL) {
3191     perror ("strdup");
3192     return -1;
3193   }
3194   tok = next;
3195   if (!tok) {
3196     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "lv_tags");
3197     return -1;
3198   }
3199   p = strchrnul (tok, ',');
3200   if (*p) next = p+1; else next = NULL;
3201   *p = '\0';
3202   r->lv_tags = strdup (tok);
3203   if (r->lv_tags == NULL) {
3204     perror ("strdup");
3205     return -1;
3206   }
3207   tok = next;
3208   if (!tok) {
3209     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "mirror_log");
3210     return -1;
3211   }
3212   p = strchrnul (tok, ',');
3213   if (*p) next = p+1; else next = NULL;
3214   *p = '\0';
3215   r->mirror_log = strdup (tok);
3216   if (r->mirror_log == NULL) {
3217     perror ("strdup");
3218     return -1;
3219   }
3220   tok = next;
3221   if (!tok) {
3222     fprintf (stderr, "%s: failed: string finished early, around token %s\n", __func__, "modules");
3223     return -1;
3224   }
3225   p = strchrnul (tok, ',');
3226   if (*p) next = p+1; else next = NULL;
3227   *p = '\0';
3228   r->modules = strdup (tok);
3229   if (r->modules == NULL) {
3230     perror ("strdup");
3231     return -1;
3232   }
3233   tok = next;
3234   if (tok != NULL) {
3235     fprintf (stderr, "%s: failed: extra tokens at end of string\n", __func__);
3236     return -1;
3237   }
3238   return 0;
3239 }
3240
3241 guestfs_lvm_int_lv_list *
3242 parse_command_line_lvs (void)
3243 {
3244   char *out, *err;
3245   char *p, *pend;
3246   int r, i;
3247   guestfs_lvm_int_lv_list *ret;
3248   void *newp;
3249
3250   ret = malloc (sizeof *ret);
3251   if (!ret) {
3252     reply_with_perror ("malloc");
3253     return NULL;
3254   }
3255
3256   ret->guestfs_lvm_int_lv_list_len = 0;
3257   ret->guestfs_lvm_int_lv_list_val = NULL;
3258
3259   r = command (&out, &err,
3260                "/sbin/lvm", "lvs",
3261                "-o", lvm_lv_cols, "--unbuffered", "--noheadings",
3262                "--nosuffix", "--separator", ",", "--units", "b", NULL);
3263   if (r == -1) {
3264     reply_with_error ("%s", err);
3265     free (out);
3266     free (err);
3267     free (ret);
3268     return NULL;
3269   }
3270
3271   free (err);
3272
3273   /* Tokenize each line of the output. */
3274   p = out;
3275   i = 0;
3276   while (p) {
3277     pend = strchr (p, '\n');    /* Get the next line of output. */
3278     if (pend) {
3279       *pend = '\0';
3280       pend++;
3281     }
3282
3283     while (*p && isspace (*p))  /* Skip any leading whitespace. */
3284       p++;
3285
3286     if (!*p) {                  /* Empty line?  Skip it. */
3287       p = pend;
3288       continue;
3289     }
3290
3291     /* Allocate some space to store this next entry. */
3292     newp = realloc (ret->guestfs_lvm_int_lv_list_val,
3293                     sizeof (guestfs_lvm_int_lv) * (i+1));
3294     if (newp == NULL) {
3295       reply_with_perror ("realloc");
3296       free (ret->guestfs_lvm_int_lv_list_val);
3297       free (ret);
3298       free (out);
3299       return NULL;
3300     }
3301     ret->guestfs_lvm_int_lv_list_val = newp;
3302
3303     /* Tokenize the next entry. */
3304     r = lvm_tokenize_lv (p, &ret->guestfs_lvm_int_lv_list_val[i]);
3305     if (r == -1) {
3306       reply_with_error ("failed to parse output of 'lvs' command");
3307       free (ret->guestfs_lvm_int_lv_list_val);
3308       free (ret);
3309       free (out);
3310       return NULL;
3311     }
3312
3313     ++i;
3314     p = pend;
3315   }
3316
3317   ret->guestfs_lvm_int_lv_list_len = i;
3318
3319   free (out);
3320   return ret;
3321 }