clients/stella/stella.c

   1 /*
   2  * Command line oriented Moira host tool.
   3  *
   4  * kolya@MIT.EDU, January 2000
   5  *
   6  * Somewhat based on blanche
   7  *
   8  * Copyright (C) 2000 by the Massachusetts Institute of Technology.
   9  * For copying and distribution information, please see the file
  10  * <mit-copyright.h>.
  11  */
  12
  13 #include <mit-copyright.h>
  14 #include <moira.h>
  15 #include <moira_site.h>
  16 #include <mrclient.h>
  17
  18 #include <ctype.h>
  19 #include <errno.h>
  20 #include <stdio.h>
  21 #include <stdlib.h>
  22 #include <string.h>
  23
  24 RCSID("$Header$");
  25
  26 struct owner_type {
  27   int type;
  28   char *name;
  29 };
  30
  31 struct mqelem {
  32   struct mqelem *q_forw;
  33   struct mqelem *q_back;
  34   void *q_data;
  35 };
  36
  37 struct string_list {
  38   char *string;
  39   struct string_list *next;
  40 };
  41
  42 #define M_ANY           0
  43 #define M_USER          1
  44 #define M_LIST          2
  45 #define M_KERBEROS      3
  46 #define M_NONE          4
  47
  48 /* argument parsing macro */
  49 #define argis(a, b) (!strcmp(*arg + 1, a) || !strcmp(*arg + 1, b))
  50
  51 /* flags from command line */
  52 int info_flag, update_flag, create_flag, delete_flag, list_map_flag;
  53 int update_map_flag, verbose, noauth;
  54
  55 struct string_list *alias_add_queue, *alias_remove_queue;
  56 struct string_list *map_add_queue, *map_remove_queue;
  57
  58 char *hostname, *whoami;
  59
  60 char *newname, *address, *network, *h_status, *vendor, *model;
  61 char *os, *location, *contact, *adm_cmt, *op_cmt;
  62
  63 struct owner_type *owner;
  64
  65 void usage(char **argv);
  66 int store_host_info(int argc, char **argv, void *hint);
  67 void show_host_info(char **argv);
  68 int show_machine_in_cluster(int argc, char **argv, void *hint);
  69 struct owner_type *parse_member(char *s);
  70 struct string_list *add_to_string_list(struct string_list *old_list, char *s);
  71 int wrap_mr_query(char *handle, int argc, char **argv,
  72                   int (*callback)(int, char **, void *), void *callarg);
  73 void print_query(char *query_name, int argc, char **argv);
  74
  75 int main(int argc, char **argv)
  76 {
  77   int status, success;
  78   char **arg = argv;
  79   char *server = NULL;
  80
  81   /* clear all flags & lists */
  82   info_flag = update_flag = create_flag = list_map_flag = update_map_flag = 0;
  83   verbose = noauth = 0;
  84   newname = address = network = h_status = vendor = model = NULL;
  85   os = location = contact = adm_cmt = op_cmt = NULL;
  86   owner = NULL;
  87   alias_add_queue = alias_remove_queue = NULL;
  88   map_add_queue = map_remove_queue = NULL;
  89   whoami = argv[0];
  90
  91   success = 1;
  92
  93   /* parse args, building addlist, dellist, & synclist */
  94   while (++arg - argv < argc)
  95     {
  96       if (**arg == '-')
  97         {
  98           if (argis("i", "info"))
  99             info_flag++;
 100           else if (argis("C", "create"))
 101             create_flag++;
 102           else if (argis("D", "delete"))
 103             delete_flag++;
 104           else if (argis("R", "rename")) {
 105             if (arg - argv < argc - 1) {
 106               arg++;
 107               update_flag++;
 108               newname = *arg;
 109             } else
 110               usage(argv);
 111           }
 112           else if (argis("A", "address")) {
 113             if (arg - argv < argc - 1) {
 114               arg++;
 115               update_flag++;
 116               address = *arg;
 117             } else
 118               usage(argv);
 119           }
 120           else if (argis("O", "owner")) {
 121             if (arg - argv < argc - 1) {
 122               arg++;
 123               update_flag++;
 124               owner = parse_member(*arg);
 125             } else
 126               usage(argv);
 127           }
 128           else if (argis("N", "network")) {
 129             if (arg - argv < argc - 1) {
 130               arg++;
 131               update_flag++;
 132               network = *arg;
 133             } else
 134               usage(argv);
 135           }
 136           else if (argis("S", "status")) {
 137             if (arg - argv < argc - 1) {
 138               int i;
 139               int len;
 140
 141               arg++;
 142               update_flag++;
 143               h_status = *arg;
 144
 145               len = strlen(h_status);
 146               for(i = 0; i < len; i++) {
 147                 if(!isdigit(h_status[i])) {
 148                   printf("Error: status code %s is not numeric.\n", h_status);
 149                   exit(1);
 150                 }
 151               }
 152             } else
 153               usage(argv);
 154           }
 155           else if (argis("V", "vendor")) {
 156             if (arg - argv < argc - 1) {
 157               arg++;
 158               update_flag++;
 159               vendor = *arg;
 160             } else
 161               usage(argv);
 162           }
 163           else if (argis("M", "model")) {
 164             if (arg - argv < argc - 1) {
 165               arg++;
 166               update_flag++;
 167               model = *arg;
 168             } else
 169               usage(argv);
 170           }
 171           else if (argis("o", "os")) {
 172             if (arg - argv < argc - 1) {
 173               arg++;
 174               update_flag++;
 175               os = *arg;
 176             } else
 177               usage(argv);
 178           }
 179           else if (argis("L", "location")) {
 180             if (arg - argv < argc - 1) {
 181               arg++;
 182               update_flag++;
 183               location = *arg;
 184             } else
 185               usage(argv);
 186           }
 187           else if (argis("c", "contact")) {
 188             if (arg - argv < argc - 1) {
 189               arg++;
 190               update_flag++;
 191               contact = *arg;
 192             } else
 193               usage(argv);
 194           }
 195           else if (argis("ac", "admcmt")) {
 196             if (arg - argv < argc - 1) {
 197               arg++;
 198               update_flag++;
 199               adm_cmt = *arg;
 200             } else
 201               usage(argv);
 202           }
 203           else if (argis("oc", "opcmt")) {
 204             if (arg - argv < argc - 1) {
 205               arg++;
 206               update_flag++;
 207               op_cmt = *arg;
 208             } else
 209               usage(argv);
 210           }
 211           else if (argis("a", "aliasadd")) {
 212             if (arg - argv < argc - 1) {
 213               arg++;
 214               alias_add_queue=add_to_string_list(alias_add_queue, *arg);
 215             } else
 216               usage(argv);
 217           }
 218           else if (argis("d", "aliasdelete")) {
 219             if (arg - argv < argc - 1) {
 220               arg++;
 221               alias_remove_queue=add_to_string_list(alias_remove_queue, *arg);
 222             } else
 223               usage(argv);
 224           }
 225           else if (argis("am", "addmap")) {
 226             if (arg - argv < argc - 1) {
 227               arg++;
 228               map_add_queue=add_to_string_list(map_add_queue, *arg);
 229             } else
 230               usage(argv);
 231             update_map_flag++;
 232           }
 233           else if (argis("dm", "deletemap")) {
 234             if (arg - argv < argc - 1) {
 235               arg++;
 236               map_remove_queue=add_to_string_list(map_remove_queue, *arg);
 237             } else
 238               usage(argv);
 239             update_map_flag++;
 240           }
 241           else if (argis("lm", "listmap"))
 242             list_map_flag++;
 243           else if (argis("n", "noauth"))
 244             noauth++;
 245           else if (argis("v", "verbose"))
 246             verbose++;
 247           else if (argis("db", "database"))
 248             {
 249               if (arg - argv < argc - 1)
 250                 {
 251                   ++arg;
 252                   server = *arg;
 253                 }
 254               else
 255                 usage(argv);
 256             }
 257           else
 258             usage(argv);
 259         }
 260       else if (hostname == NULL)
 261         hostname = *arg;
 262       else
 263         usage(argv);
 264     }
 265   if (hostname == NULL)
 266     usage(argv);
 267
 268   /* default to info_flag if nothing else was specified */
 269   if(!(info_flag   || update_flag   || create_flag     || \
 270        delete_flag || list_map_flag || update_map_flag )) {
 271     info_flag++;
 272   }
 273
 274   /* fire up Moira */
 275   status = mrcl_connect(server, "stella", 2, !noauth);
 276   if (status == MRCL_AUTH_ERROR)
 277     {
 278       com_err(whoami, 0, "Try the -noauth flag if you don't "
 279               "need authentication.");
 280     }
 281   if (status)
 282     exit(2);
 283
 284   /* create if needed */
 285   if (create_flag)
 286     {
 287       char *argv[30];
 288       int cnt;
 289
 290       for (cnt = 0; cnt < 15; cnt++) {
 291         argv[cnt] = "";
 292       }
 293
 294       argv[0] = canonicalize_hostname(strdup(hostname));
 295
 296       if (vendor)
 297         argv[1] = vendor;
 298       if (model)
 299         argv[2] = model;
 300       if (os)
 301         argv[3] = os;
 302       if (location)
 303         argv[4] = location;
 304       if (contact)
 305         argv[5] = contact;
 306       /* The use field always gets set to "0" */
 307       argv[6] = "0";
 308       if (h_status)
 309         argv[7] = h_status;
 310       else
 311         argv[7] = "1";
 312       if (network)
 313         argv[8] = network;
 314       if (address)
 315         argv[9] = address;
 316       if (adm_cmt)
 317         argv[12] = adm_cmt;
 318       if (op_cmt)
 319         argv[13] = op_cmt;
 320
 321       if (owner)
 322         {
 323           argv[11] = owner->name;
 324           switch (owner->type)
 325             {
 326             case M_ANY:
 327             case M_USER:
 328               argv[10] = "USER";
 329               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 330               if (owner->type != M_ANY || status != MR_USER)
 331                 break;
 332
 333             case M_LIST:
 334               argv[10] = "LIST";
 335               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 336               break;
 337
 338             case M_KERBEROS:
 339               argv[10] = "KERBEROS";
 340               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 341               break;
 342
 343             case M_NONE:
 344               argv[10] = "NONE";
 345               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 346               break;
 347             }
 348         }
 349       else
 350         {
 351           argv[10] = "NONE";
 352           argv[11] = "NONE";
 353
 354           status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 355         }
 356
 357       if (status)
 358         {
 359           com_err(whoami, status, "while creating host.");
 360           exit(1);
 361         }
 362
 363     }
 364   else if (update_flag)
 365     {
 366       char *old_argv[30];
 367       char *argv[16];
 368       char *args[5];
 369
 370       args[0] = canonicalize_hostname(strdup(hostname));
 371       args[1] = args[2] = args[3] = "*";
 372
 373       status = wrap_mr_query("get_host", 4, args, store_host_info, old_argv);
 374       if (status)
 375         {
 376           com_err(whoami, status, "while getting list information");
 377           exit(1);
 378         }
 379
 380       argv[1] = old_argv[0];
 381       argv[2] = old_argv[1];
 382       argv[3] = old_argv[2];
 383       argv[4] = old_argv[3];
 384       argv[5] = old_argv[4];
 385       argv[6] = old_argv[5];
 386       argv[7] = old_argv[6];
 387       argv[8] = old_argv[7];
 388       argv[9] = old_argv[9];
 389       argv[10] = old_argv[10];
 390       argv[11] = old_argv[11];
 391       argv[12] = old_argv[12];
 392       argv[13] = old_argv[13];
 393       argv[14] = old_argv[14];
 394
 395       argv[0] = canonicalize_hostname(strdup(hostname));
 396       if (newname)
 397         argv[1] = canonicalize_hostname(strdup(newname));
 398       if (vendor)
 399         argv[2] = vendor;
 400       if (model)
 401         argv[3] = model;
 402       if (os)
 403         argv[4] = os;
 404       if (location)
 405         argv[5] = location;
 406       if (contact)
 407         argv[6] = contact;
 408       if (h_status)
 409         argv[8] = h_status;
 410       if (network)
 411         argv[9] = network;
 412       if (address)
 413         argv[10] = address;
 414       if (adm_cmt)
 415         argv[13] = adm_cmt;
 416       if (op_cmt)
 417         argv[14] = op_cmt;
 418
 419       if (owner)
 420         {
 421           argv[12] = owner->name;
 422           switch (owner->type)
 423             {
 424             case M_ANY:
 425             case M_USER:
 426               argv[11] = "USER";
 427               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 428               if (owner->type != M_ANY || status != MR_USER)
 429                 break;
 430
 431             case M_LIST:
 432               argv[11] = "LIST";
 433               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 434               break;
 435
 436             case M_KERBEROS:
 437               argv[11] = "KERBEROS";
 438               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 439               break;
 440
 441             case M_NONE:
 442               argv[11] = "NONE";
 443               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 444               break;
 445             }
 446         }
 447       else
 448         status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 449
 450       if (status)
 451         com_err(whoami, status, "while updating host.");
 452       else if (newname)
 453         hostname = newname;
 454     }
 455
 456   /* create aliases if necessary */
 457   if (alias_add_queue) {
 458     struct string_list *q = alias_add_queue;
 459
 460     while(q) {
 461       char *alias = q->string;
 462       char *args[2];
 463
 464       args[0] = partial_canonicalize_hostname(strdup(alias));
 465       args[1] = canonicalize_hostname(strdup(hostname));
 466       status = wrap_mr_query("add_hostalias", 2, args, NULL, NULL);
 467       if (status) {
 468         com_err(whoami, status, "while adding host alias");
 469         exit(1);
 470       }
 471
 472       q = q->next;
 473     }
 474   }
 475
 476   /* delete aliases if necessary */
 477   if (alias_remove_queue) {
 478     struct string_list *q = alias_remove_queue;
 479
 480     while(q) {
 481       char *alias = q->string;
 482       char *args[2];
 483
 484       args[0] = partial_canonicalize_hostname(strdup(alias));
 485       args[1] = canonicalize_hostname(strdup(hostname));
 486       status = wrap_mr_query("delete_hostalias", 2, args, NULL, NULL);
 487       if (status) {
 488         com_err(whoami, status, "while deleting host alias");
 489         exit(1);
 490       }
 491
 492       q = q->next;
 493     }
 494   }
 495
 496   /* create cluster mappings */
 497   if (map_add_queue) {
 498     struct string_list *q = map_add_queue;
 499
 500     while(q) {
 501       char *clustername = q->string;
 502       char *args[2];
 503
 504       args[0] = canonicalize_hostname(strdup(hostname));
 505       args[1] = clustername;
 506       status = wrap_mr_query("add_machine_to_cluster", 2, args, NULL, NULL);
 507       if (status) {
 508         com_err(whoami, status, "while adding cluster mapping");
 509         exit(1);
 510       }
 511
 512       q = q->next;
 513     }
 514   }
 515
 516   /* delete cluster mappings */
 517   if (map_remove_queue) {
 518     struct string_list *q = map_remove_queue;
 519
 520     while(q) {
 521       char *clustername = q->string;
 522       char *args[2];
 523
 524       args[0] = canonicalize_hostname(strdup(hostname));
 525       args[1] = clustername;
 526       status = wrap_mr_query("delete_machine_from_cluster", 2, args,
 527                              NULL, NULL);
 528       if (status) {
 529         com_err(whoami, status, "while deleting cluster mapping");
 530         exit(1);
 531       }
 532
 533       q = q->next;
 534     }
 535   }
 536
 537   /* display list info if requested to */
 538   if (info_flag) {
 539     struct mqelem *elem = NULL;
 540     char *args[5];
 541     char *argv[30];
 542
 543     args[0] = canonicalize_hostname(strdup(hostname));
 544     args[1] = args[2] = args[3] = "*";
 545     status = wrap_mr_query("get_host", 4, args, store_host_info, argv);
 546     if (status) {
 547       com_err(whoami, status, "while getting host information");
 548       exit(1);
 549     }
 550     show_host_info(argv);
 551   }
 552
 553   /* list cluster mappings if needed */
 554   if (list_map_flag) {
 555     char *args[3];
 556
 557     args[0] = canonicalize_hostname(strdup(hostname));
 558     args[1] = "*";
 559     status = wrap_mr_query("get_machine_to_cluster_map", 2, args,
 560                       show_machine_in_cluster, NULL);
 561     if (status)
 562       if (status != MR_NO_MATCH) {
 563         com_err(whoami, status, "while getting cluster mappings");
 564         exit(1);
 565       }
 566   }
 567
 568   if (delete_flag) {
 569     char *argv[1];
 570
 571     argv[0] = canonicalize_hostname(strdup(hostname));
 572     status = wrap_mr_query("delete_host", 1, argv, NULL, NULL);
 573     if (status) {
 574       com_err(whoami, status, "while deleting host");
 575       exit(1);
 576     }
 577   }
 578
 579   /* We're done! */
 580   mr_disconnect();
 581   exit(success ? 0 : 1);
 582 }
 583
 584 void usage(char **argv)
 585 {
 586 #define USAGE_OPTIONS_FORMAT "  %-39s%s\n"
 587   fprintf(stderr, "Usage: %s hostname [options]\n", argv[0]);
 588   fprintf(stderr, "Options are\n");
 589   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-C   | -create",
 590           "-O   | -owner owner");
 591   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-D   | -delete",
 592           "-S   | -status status");
 593   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-R   | -rename newname",
 594           "-V   | -vendor vendor");
 595   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-a   | -addalias alias",
 596           "-M   | -model model");
 597   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-d   | -deletealias alias",
 598           "-L   | -location location");
 599   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-i   | -info",
 600           "-o   | -os os");
 601   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-oc  | -opcmt op_cmt",
 602           "-c   | -contact contact");
 603   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-ac  | -admcmt adm_cmt",
 604           "-A   | -address address");
 605   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-am  | -addmap cluster",
 606           "-N   | -network network");
 607   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-dm  | -deletemap cluster",
 608           "-lm  | -listmap");
 609   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-db  | -database host[:port]",
 610           "-n   | -noauth");
 611   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-v   | -verbose",
 612           "");
 613   exit(1);
 614 }
 615
 616 /* Show alias information */
 617
 618 static int show_has_aliases;
 619
 620 int show_alias_info(int argc, char **argv, void *hint)
 621 {
 622   if(!show_has_aliases++)
 623     printf("Aliases:  %s", argv[0]);
 624   else
 625     printf(", %s", argv[0]);
 626
 627   return MR_CONT;
 628 }
 629
 630 static char *states[] = {
 631   "Reserved (0)",
 632   "Active (1)",
 633   "None (2)",
 634   "Deleted (3)"
 635 };
 636
 637 static char *MacState(int state)
 638 {
 639   static char buf[BUFSIZ];
 640
 641   if (state < 0 || state > 3)
 642     {
 643       sprintf(buf, "Unknown (%d)", state);
 644       return buf;
 645     }
 646   return states[state];
 647 }
 648
 649 /* Retrieve information about a host */
 650
 651 int store_host_info(int argc, char **argv, void *hint)
 652 {
 653   int i;
 654   char **nargv = hint;
 655
 656   for(i=0; i<argc; i++)
 657     nargv[i] = strdup(argv[i]);
 658
 659   return MR_CONT;
 660 }
 661
 662 void show_host_info(char **argv)
 663 {
 664   char tbuf[256];
 665   char *args[3];
 666   struct mqelem *elem = NULL;
 667   int stat;
 668
 669   printf("Machine:  %s\n", argv[M_NAME]);
 670   args[0] = "*";
 671   args[1] = argv[M_NAME];
 672   show_has_aliases = 0;
 673   stat = wrap_mr_query("get_hostalias", 2, args, show_alias_info, &elem);
 674   printf("\n");
 675   if (stat) {
 676     if (stat != MR_NO_MATCH)
 677       com_err(whoami, stat, "while getting aliases");
 678   } else {
 679     printf("\n");
 680   }
 681   sprintf(tbuf, "%s %s", argv[M_OWNER_TYPE],
 682           strcmp(argv[M_OWNER_TYPE], "NONE") ? argv[M_OWNER_NAME] : "");
 683   printf("Address:  %-16s    Network:    %-16s\n",
 684           argv[M_ADDR], argv[M_SUBNET]);
 685   printf("Owner:    %-16s    Use data:   %s\n", tbuf, argv[M_INUSE]);
 686   printf("Status:   %-16s    Changed:    %s\n",
 687           MacState(atoi(argv[M_STAT])), argv[M_STAT_CHNG]);
 688   printf("\n");
 689
 690   printf("Vendor:   %-16s    Model:      %-20s  OS:  %s\n",
 691           argv[M_VENDOR], argv[M_MODEL], argv[M_OS]);
 692   printf("Location: %-16s    Contact:    %-20s  Opt: %s\n",
 693           argv[M_LOC], argv[M_CONTACT], argv[M_USE]);
 694   printf("\nAdm cmt: %s\n", argv[M_ACOMMENT]);
 695   printf("Op cmt:  %s\n", argv[M_OCOMMENT]);
 696   printf("\n");
 697   printf("Created  by %s on %s\n", argv[M_CREATOR], argv[M_CREATED]);
 698   printf("Last mod by %s at %s with %s.\n", argv[M_MODBY], argv[M_MODTIME], argv[M_MODWITH]);
 699 }
 700
 701 int show_machine_in_cluster(int argc, char **argv, void *hint)
 702 {
 703   printf("Machine: %-30s Cluster: %-30s\n", argv[0], argv[1]);
 704
 705   return MR_CONT;
 706 }
 707
 708 /* Parse a line of input, fetching a member.  NULL is returned if a member
 709  * is not found.  ';' is a comment character.
 710  */
 711
 712 struct owner_type *parse_member(char *s)
 713 {
 714   struct owner_type *m;
 715   char *p, *lastchar;
 716
 717   while (*s && isspace(*s))
 718     s++;
 719   lastchar = p = s;
 720   while (*p && *p != '\n' && *p != ';')
 721     {
 722       if (isprint(*p) && !isspace(*p))
 723         lastchar = p++;
 724       else
 725         p++;
 726     }
 727   lastchar++;
 728   *lastchar = '\0';
 729   if (p == s || strlen(s) == 0)
 730     return NULL;
 731
 732   if (!(m = malloc(sizeof(struct owner_type))))
 733     return NULL;
 734
 735   if ((p = strchr(s, ':')))
 736     {
 737       *p = '\0';
 738       m->name = ++p;
 739       if (!strcasecmp("user", s))
 740         m->type = M_USER;
 741       else if (!strcasecmp("list", s))
 742         m->type = M_LIST;
 743       else if (!strcasecmp("kerberos", s))
 744         m->type = M_KERBEROS;
 745       else if (!strcasecmp("none", s))
 746         m->type = M_NONE;
 747       else
 748         {
 749           m->type = M_ANY;
 750           *(--p) = ':';
 751           m->name = s;
 752         }
 753       m->name = strdup(m->name);
 754     }
 755   else
 756     {
 757       m->name = strdup(s);
 758       m->type = strcasecmp(s, "none") ? M_ANY : M_NONE;
 759     }
 760   return m;
 761 }
 762
 763 struct string_list *add_to_string_list(struct string_list *old_list, char *s) {
 764   struct string_list *new_list;
 765
 766   new_list = (struct string_list *)malloc(sizeof(struct string_list *));
 767   new_list->next = old_list;
 768   new_list->string = s;
 769
 770   return new_list;
 771 }
 772
 773 int wrap_mr_query(char *handle, int argc, char **argv,
 774                   int (*callback)(int, char **, void *), void *callarg) {
 775   if (verbose)
 776     print_query(handle, argc, argv);
 777
 778   return mr_query(handle, argc, argv, callback, callarg);
 779 }
 780
 781 void print_query(char *query_name, int argc, char **argv) {
 782   int cnt;
 783
 784   printf("qy %s", query_name);
 785   for(cnt=0; cnt<argc; cnt++)
 786     printf(" <%s>", argv[cnt]);
 787   printf("\n");
 788 }