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_alias_flag, 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   update_alias_flag = 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             update_alias_flag++;
 218           }
 219           else if (argis("d", "aliasdelete")) {
 220             if (arg - argv < argc - 1) {
 221               arg++;
 222               alias_remove_queue=add_to_string_list(alias_remove_queue, *arg);
 223             } else
 224               usage(argv);
 225             update_alias_flag++;
 226           }
 227           else if (argis("am", "addmap")) {
 228             if (arg - argv < argc - 1) {
 229               arg++;
 230               map_add_queue=add_to_string_list(map_add_queue, *arg);
 231             } else
 232               usage(argv);
 233             update_map_flag++;
 234           }
 235           else if (argis("dm", "deletemap")) {
 236             if (arg - argv < argc - 1) {
 237               arg++;
 238               map_remove_queue=add_to_string_list(map_remove_queue, *arg);
 239             } else
 240               usage(argv);
 241             update_map_flag++;
 242           }
 243           else if (argis("lm", "listmap"))
 244             list_map_flag++;
 245           else if (argis("n", "noauth"))
 246             noauth++;
 247           else if (argis("v", "verbose"))
 248             verbose++;
 249           else if (argis("db", "database"))
 250             {
 251               if (arg - argv < argc - 1)
 252                 {
 253                   ++arg;
 254                   server = *arg;
 255                 }
 256               else
 257                 usage(argv);
 258             }
 259           else
 260             usage(argv);
 261         }
 262       else if (hostname == NULL)
 263         hostname = *arg;
 264       else
 265         usage(argv);
 266     }
 267   if (hostname == NULL)
 268     usage(argv);
 269
 270   /* default to info_flag if nothing else was specified */
 271   if(!(info_flag   || update_flag   || create_flag     || \
 272        delete_flag || list_map_flag || update_map_flag || \
 273        update_alias_flag)) {
 274     info_flag++;
 275   }
 276
 277   /* fire up Moira */
 278   status = mrcl_connect(server, "stella", 2, !noauth);
 279   if (status == MRCL_AUTH_ERROR)
 280     {
 281       com_err(whoami, 0, "Try the -noauth flag if you don't "
 282               "need authentication.");
 283     }
 284   if (status)
 285     exit(2);
 286
 287   /* create if needed */
 288   if (create_flag)
 289     {
 290       char *argv[30];
 291       int cnt;
 292
 293       for (cnt = 0; cnt < 15; cnt++) {
 294         argv[cnt] = "";
 295       }
 296
 297       argv[0] = canonicalize_hostname(strdup(hostname));
 298
 299       if (vendor)
 300         argv[1] = vendor;
 301       if (model)
 302         argv[2] = model;
 303       if (os)
 304         argv[3] = os;
 305       if (location)
 306         argv[4] = location;
 307       if (contact)
 308         argv[5] = contact;
 309       /* The use field always gets set to "0" */
 310       argv[6] = "0";
 311       if (h_status)
 312         argv[7] = h_status;
 313       else
 314         argv[7] = "1";
 315       if (network)
 316         argv[8] = network;
 317       if (address)
 318         argv[9] = address;
 319       else
 320         argv[9] = "unique";
 321       if (adm_cmt)
 322         argv[12] = adm_cmt;
 323       if (op_cmt)
 324         argv[13] = op_cmt;
 325
 326       if (owner)
 327         {
 328           argv[11] = owner->name;
 329           switch (owner->type)
 330             {
 331             case M_ANY:
 332             case M_USER:
 333               argv[10] = "USER";
 334               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 335               if (owner->type != M_ANY || status != MR_USER)
 336                 break;
 337
 338             case M_LIST:
 339               argv[10] = "LIST";
 340               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 341               break;
 342
 343             case M_KERBEROS:
 344               argv[10] = "KERBEROS";
 345               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 346               break;
 347
 348             case M_NONE:
 349               argv[10] = "NONE";
 350               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 351               break;
 352             }
 353         }
 354       else
 355         {
 356           argv[10] = "NONE";
 357           argv[11] = "NONE";
 358
 359           status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
 360         }
 361
 362       if (status)
 363         {
 364           com_err(whoami, status, "while creating host.");
 365           exit(1);
 366         }
 367
 368     }
 369   else if (update_flag)
 370     {
 371       char *old_argv[30];
 372       char *argv[16];
 373       char *args[5];
 374
 375       args[0] = canonicalize_hostname(strdup(hostname));
 376       args[1] = args[2] = args[3] = "*";
 377
 378       status = wrap_mr_query("get_host", 4, args, store_host_info, old_argv);
 379       if (status)
 380         {
 381           com_err(whoami, status, "while getting list information");
 382           exit(1);
 383         }
 384
 385       argv[1] = old_argv[0];
 386       argv[2] = old_argv[1];
 387       argv[3] = old_argv[2];
 388       argv[4] = old_argv[3];
 389       argv[5] = old_argv[4];
 390       argv[6] = old_argv[5];
 391       argv[7] = old_argv[6];
 392       argv[8] = old_argv[7];
 393       argv[9] = old_argv[9];
 394       argv[10] = old_argv[10];
 395       argv[11] = old_argv[11];
 396       argv[12] = old_argv[12];
 397       argv[13] = old_argv[13];
 398       argv[14] = old_argv[14];
 399
 400       argv[0] = canonicalize_hostname(strdup(hostname));
 401       if (newname)
 402         argv[1] = canonicalize_hostname(strdup(newname));
 403       if (vendor)
 404         argv[2] = vendor;
 405       if (model)
 406         argv[3] = model;
 407       if (os)
 408         argv[4] = os;
 409       if (location)
 410         argv[5] = location;
 411       if (contact)
 412         argv[6] = contact;
 413       if (h_status)
 414         argv[8] = h_status;
 415       if (network)
 416         argv[9] = network;
 417       if (address)
 418         argv[10] = address;
 419       if (adm_cmt)
 420         argv[13] = adm_cmt;
 421       if (op_cmt)
 422         argv[14] = op_cmt;
 423
 424       if (owner)
 425         {
 426           argv[12] = owner->name;
 427           switch (owner->type)
 428             {
 429             case M_ANY:
 430             case M_USER:
 431               argv[11] = "USER";
 432               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 433               if (owner->type != M_ANY || status != MR_USER)
 434                 break;
 435
 436             case M_LIST:
 437               argv[11] = "LIST";
 438               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 439               break;
 440
 441             case M_KERBEROS:
 442               argv[11] = "KERBEROS";
 443               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 444               break;
 445
 446             case M_NONE:
 447               argv[11] = "NONE";
 448               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 449               break;
 450             }
 451         }
 452       else
 453         status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
 454
 455       if (status)
 456         com_err(whoami, status, "while updating host.");
 457       else if (newname)
 458         hostname = newname;
 459     }
 460
 461   /* create aliases if necessary */
 462   if (alias_add_queue) {
 463     struct string_list *q = alias_add_queue;
 464
 465     while(q) {
 466       char *alias = q->string;
 467       char *args[2];
 468
 469       args[0] = partial_canonicalize_hostname(strdup(alias));
 470       args[1] = canonicalize_hostname(strdup(hostname));
 471       status = wrap_mr_query("add_hostalias", 2, args, NULL, NULL);
 472       if (status) {
 473         com_err(whoami, status, "while adding host alias");
 474         exit(1);
 475       }
 476
 477       q = q->next;
 478     }
 479   }
 480
 481   /* delete aliases if necessary */
 482   if (alias_remove_queue) {
 483     struct string_list *q = alias_remove_queue;
 484
 485     while(q) {
 486       char *alias = q->string;
 487       char *args[2];
 488
 489       args[0] = partial_canonicalize_hostname(strdup(alias));
 490       args[1] = canonicalize_hostname(strdup(hostname));
 491       status = wrap_mr_query("delete_hostalias", 2, args, NULL, NULL);
 492       if (status) {
 493         com_err(whoami, status, "while deleting host alias");
 494         exit(1);
 495       }
 496
 497       q = q->next;
 498     }
 499   }
 500
 501   /* create cluster mappings */
 502   if (map_add_queue) {
 503     struct string_list *q = map_add_queue;
 504
 505     while(q) {
 506       char *clustername = q->string;
 507       char *args[2];
 508
 509       args[0] = canonicalize_hostname(strdup(hostname));
 510       args[1] = clustername;
 511       status = wrap_mr_query("add_machine_to_cluster", 2, args, NULL, NULL);
 512       if (status) {
 513         com_err(whoami, status, "while adding cluster mapping");
 514         exit(1);
 515       }
 516
 517       q = q->next;
 518     }
 519   }
 520
 521   /* delete cluster mappings */
 522   if (map_remove_queue) {
 523     struct string_list *q = map_remove_queue;
 524
 525     while(q) {
 526       char *clustername = q->string;
 527       char *args[2];
 528
 529       args[0] = canonicalize_hostname(strdup(hostname));
 530       args[1] = clustername;
 531       status = wrap_mr_query("delete_machine_from_cluster", 2, args,
 532                              NULL, NULL);
 533       if (status) {
 534         com_err(whoami, status, "while deleting cluster mapping");
 535         exit(1);
 536       }
 537
 538       q = q->next;
 539     }
 540   }
 541
 542   /* display list info if requested to */
 543   if (info_flag) {
 544     struct mqelem *elem = NULL;
 545     char *args[5];
 546     char *argv[30];
 547
 548     args[0] = canonicalize_hostname(strdup(hostname));
 549     args[1] = args[2] = args[3] = "*";
 550     status = wrap_mr_query("get_host", 4, args, store_host_info, argv);
 551     if (status) {
 552       com_err(whoami, status, "while getting host information");
 553       exit(1);
 554     }
 555     show_host_info(argv);
 556   }
 557
 558   /* list cluster mappings if needed */
 559   if (list_map_flag) {
 560     char *args[3];
 561
 562     args[0] = canonicalize_hostname(strdup(hostname));
 563     args[1] = "*";
 564     status = wrap_mr_query("get_machine_to_cluster_map", 2, args,
 565                       show_machine_in_cluster, NULL);
 566     if (status)
 567       if (status != MR_NO_MATCH) {
 568         com_err(whoami, status, "while getting cluster mappings");
 569         exit(1);
 570       }
 571   }
 572
 573   if (delete_flag) {
 574     char *argv[1];
 575
 576     argv[0] = canonicalize_hostname(strdup(hostname));
 577     status = wrap_mr_query("delete_host", 1, argv, NULL, NULL);
 578     if (status) {
 579       com_err(whoami, status, "while deleting host");
 580       exit(1);
 581     }
 582   }
 583
 584   /* We're done! */
 585   mr_disconnect();
 586   exit(success ? 0 : 1);
 587 }
 588
 589 void usage(char **argv)
 590 {
 591 #define USAGE_OPTIONS_FORMAT "  %-39s%s\n"
 592   fprintf(stderr, "Usage: %s hostname [options]\n", argv[0]);
 593   fprintf(stderr, "Options are\n");
 594   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-C   | -create",
 595           "-O   | -owner owner");
 596   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-D   | -delete",
 597           "-S   | -status status");
 598   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-R   | -rename newname",
 599           "-V   | -vendor vendor");
 600   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-a   | -addalias alias",
 601           "-M   | -model model");
 602   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-d   | -deletealias alias",
 603           "-L   | -location location");
 604   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-i   | -info",
 605           "-o   | -os os");
 606   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-oc  | -opcmt op_cmt",
 607           "-c   | -contact contact");
 608   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-ac  | -admcmt adm_cmt",
 609           "-A   | -address address");
 610   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-am  | -addmap cluster",
 611           "-N   | -network network");
 612   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-dm  | -deletemap cluster",
 613           "-lm  | -listmap");
 614   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-db  | -database host[:port]",
 615           "-n   | -noauth");
 616   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-v   | -verbose",
 617           "");
 618   exit(1);
 619 }
 620
 621 /* Show alias information */
 622
 623 static int show_has_aliases;
 624
 625 int show_alias_info(int argc, char **argv, void *hint)
 626 {
 627   if(!show_has_aliases++)
 628     printf("Aliases:  %s", argv[0]);
 629   else
 630     printf(", %s", argv[0]);
 631
 632   return MR_CONT;
 633 }
 634
 635 static char *states[] = {
 636   "Reserved (0)",
 637   "Active (1)",
 638   "None (2)",
 639   "Deleted (3)"
 640 };
 641
 642 static char *MacState(int state)
 643 {
 644   static char buf[BUFSIZ];
 645
 646   if (state < 0 || state > 3)
 647     {
 648       sprintf(buf, "Unknown (%d)", state);
 649       return buf;
 650     }
 651   return states[state];
 652 }
 653
 654 /* Retrieve information about a host */
 655
 656 int store_host_info(int argc, char **argv, void *hint)
 657 {
 658   int i;
 659   char **nargv = hint;
 660
 661   for(i=0; i<argc; i++)
 662     nargv[i] = strdup(argv[i]);
 663
 664   return MR_CONT;
 665 }
 666
 667 void show_host_info(char **argv)
 668 {
 669   char tbuf[256];
 670   char *args[3];
 671   struct mqelem *elem = NULL;
 672   int stat;
 673
 674   printf("Machine:  %s\n", argv[M_NAME]);
 675   args[0] = "*";
 676   args[1] = argv[M_NAME];
 677   show_has_aliases = 0;
 678   stat = wrap_mr_query("get_hostalias", 2, args, show_alias_info, &elem);
 679   printf("\n");
 680   if (stat) {
 681     if (stat != MR_NO_MATCH)
 682       com_err(whoami, stat, "while getting aliases");
 683   } else {
 684     printf("\n");
 685   }
 686   sprintf(tbuf, "%s %s", argv[M_OWNER_TYPE],
 687           strcmp(argv[M_OWNER_TYPE], "NONE") ? argv[M_OWNER_NAME] : "");
 688   printf("Address:  %-16s    Network:    %-16s\n",
 689           argv[M_ADDR], argv[M_SUBNET]);
 690   printf("Owner:    %-16s    Use data:   %s\n", tbuf, argv[M_INUSE]);
 691   printf("Status:   %-16s    Changed:    %s\n",
 692           MacState(atoi(argv[M_STAT])), argv[M_STAT_CHNG]);
 693   printf("\n");
 694
 695   printf("Vendor:   %-16s    Model:      %-20s  OS:  %s\n",
 696           argv[M_VENDOR], argv[M_MODEL], argv[M_OS]);
 697   printf("Location: %-16s    Contact:    %-20s  Opt: %s\n",
 698           argv[M_LOC], argv[M_CONTACT], argv[M_USE]);
 699   printf("\nAdm cmt: %s\n", argv[M_ACOMMENT]);
 700   printf("Op cmt:  %s\n", argv[M_OCOMMENT]);
 701   printf("\n");
 702   printf("Created  by %s on %s\n", argv[M_CREATOR], argv[M_CREATED]);
 703   printf("Last mod by %s at %s with %s.\n", argv[M_MODBY], argv[M_MODTIME], argv[M_MODWITH]);
 704 }
 705
 706 int show_machine_in_cluster(int argc, char **argv, void *hint)
 707 {
 708   printf("Machine: %-30s Cluster: %-30s\n", argv[0], argv[1]);
 709
 710   return MR_CONT;
 711 }
 712
 713 /* Parse a line of input, fetching a member.  NULL is returned if a member
 714  * is not found.  ';' is a comment character.
 715  */
 716
 717 struct owner_type *parse_member(char *s)
 718 {
 719   struct owner_type *m;
 720   char *p, *lastchar;
 721
 722   while (*s && isspace(*s))
 723     s++;
 724   lastchar = p = s;
 725   while (*p && *p != '\n' && *p != ';')
 726     {
 727       if (isprint(*p) && !isspace(*p))
 728         lastchar = p++;
 729       else
 730         p++;
 731     }
 732   lastchar++;
 733   *lastchar = '\0';
 734   if (p == s || strlen(s) == 0)
 735     return NULL;
 736
 737   if (!(m = malloc(sizeof(struct owner_type))))
 738     return NULL;
 739
 740   if ((p = strchr(s, ':')))
 741     {
 742       *p = '\0';
 743       m->name = ++p;
 744       if (!strcasecmp("user", s))
 745         m->type = M_USER;
 746       else if (!strcasecmp("list", s))
 747         m->type = M_LIST;
 748       else if (!strcasecmp("kerberos", s))
 749         m->type = M_KERBEROS;
 750       else if (!strcasecmp("none", s))
 751         m->type = M_NONE;
 752       else
 753         {
 754           m->type = M_ANY;
 755           *(--p) = ':';
 756           m->name = s;
 757         }
 758       m->name = strdup(m->name);
 759     }
 760   else
 761     {
 762       m->name = strdup(s);
 763       m->type = strcasecmp(s, "none") ? M_ANY : M_NONE;
 764     }
 765   return m;
 766 }
 767
 768 struct string_list *add_to_string_list(struct string_list *old_list, char *s) {
 769   struct string_list *new_list;
 770
 771   new_list = (struct string_list *)malloc(sizeof(struct string_list *));
 772   new_list->next = old_list;
 773   new_list->string = s;
 774
 775   return new_list;
 776 }
 777
 778 int wrap_mr_query(char *handle, int argc, char **argv,
 779                   int (*callback)(int, char **, void *), void *callarg) {
 780   if (verbose)
 781     print_query(handle, argc, argv);
 782
 783   return mr_query(handle, argc, argv, callback, callarg);
 784 }
 785
 786 void print_query(char *query_name, int argc, char **argv) {
 787   int cnt;
 788
 789   printf("qy %s", query_name);
 790   for(cnt=0; cnt<argc; cnt++)
 791     printf(" <%s>", argv[cnt]);
 792   printf("\n");
 793 }