Merge branch 'v4-0-test' of ssh://git.samba.org/data/git/samba into v4-0-gmake3
[mat/samba.git] / source4 / torture / smbtorture.c
index bdd7f0ed8491d859710042d234953bb794215e22..5c5f96c5058da758de0f943dbd4d2c0eb16735cb 100644 (file)
@@ -6,7 +6,7 @@
    
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; either version 2 of the License, or
+   the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.
    
    This program is distributed in the hope that it will be useful,
@@ -15,8 +15,7 @@
    GNU General Public License for more details.
    
    You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+   along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
 #include "includes.h"
 #include "system/time.h"
 #include "system/wait.h"
 #include "system/filesys.h"
+#include "system/readline.h"
+#include "lib/smbreadline/smbreadline.h"
 #include "libcli/libcli.h"
 #include "lib/ldb/include/ldb.h"
 #include "lib/events/events.h"
+#include "dynconfig.h"
 
 #include "torture/torture.h"
-#include "torture/ui.h"
-#include "build.h"
-#include "dlinklist.h"
+#include "lib/util/dlinklist.h"
 #include "librpc/rpc/dcerpc.h"
+#include "param/param.h"
+
+#include "auth/credentials/credentials.h"
+
+static bool run_matching(struct torture_context *torture,
+                                                const char *prefix, 
+                                                const char *expr,
+                                                struct torture_suite *suite,
+                                                bool *matched)
+{
+       bool ret = true;
+
+       if (suite == NULL) {
+               struct torture_suite *o;
+
+               for (o = torture_root->children; o; o = o->next) {
+                       if (gen_fnmatch(expr, o->name) == 0) {
+                               *matched = true;
+                               reload_charcnv(torture->lp_ctx);
+                               ret &= torture_run_suite(torture, o);
+                               continue;
+                       }
+
+                       ret &= run_matching(torture, o->name, expr, o, matched);
+               }
+       } else {
+               char *name;
+               struct torture_suite *c;
+               struct torture_tcase *t;
+
+               for (c = suite->children; c; c = c->next) {
+                       asprintf(&name, "%s-%s", prefix, c->name);
+
+                       if (gen_fnmatch(expr, name) == 0) {
+                               *matched = true;
+                               reload_charcnv(torture->lp_ctx);
+                               torture->active_testname = talloc_strdup(torture, prefix);
+                               ret &= torture_run_suite(torture, c);
+                               free(name);
+                               continue;
+                       }
+                       
+                       ret &= run_matching(torture, name, expr, c, matched);
+
+                       free(name);
+               }
+
+               for (t = suite->testcases; t; t = t->next) {
+                       asprintf(&name, "%s-%s", prefix, t->name);
+                       if (gen_fnmatch(expr, name) == 0) {
+                               *matched = true;
+                               reload_charcnv(torture->lp_ctx);
+                               torture->active_testname = talloc_strdup(torture, prefix);
+                               ret &= torture_run_tcase(torture, t);
+                               talloc_free(torture->active_testname);
+                       }
+                       free(name);
+               }
+       }
+
+       return ret;
+}
 
 #define MAX_COLS 80 /* FIXME: Determine this at run-time */
 
 /****************************************************************************
 run a specified test or "ALL"
 ****************************************************************************/
-static BOOL run_test(struct torture_context *torture, const char *name)
+static bool run_test(struct torture_context *torture, const char *name)
 {
-       BOOL ret = True;
-       struct torture_op *o;
-       BOOL matched = False;
-
-       if (strequal(name,"ALL")) {
-               for (o = torture_ops; o; o = o->next) {
-                       if (!run_test(torture, o->name)) {
-                               ret = False;
-                       }
+       bool ret = true;
+       bool matched = false;
+       struct torture_suite *o;
+
+       if (strequal(name, "ALL")) {
+               for (o = torture_root->children; o; o = o->next) {
+                       ret &= torture_run_suite(torture, o);
                }
                return ret;
        }
 
-       for (o = torture_ops; o; o = o->next) {
-               if (gen_fnmatch(name, o->name) == 0) {
-                       double t;
-                       matched = True;
-                       init_iconv();
-                       printf("Running %s\n", o->name);
-                       if (o->multi_fn) {
-                               BOOL result = False;
-                               t = torture_create_procs(o->multi_fn, 
-                                                        &result);
-                               if (!result) { 
-                                       ret = False;
-                                       printf("TEST %s FAILED!\n", o->name);
-                               }
-                                        
-                       } else {
-                               struct timeval tv = timeval_current();
-                               if (!o->fn(torture)) {
-                                       ret = False;
-                                       printf("TEST %s FAILED!\n", o->name);
-                               }
-                               t = timeval_elapsed(&tv);
-                       }
-                       printf("%s took %g secs\n\n", o->name, t);
-               }
-       }
+       ret = run_matching(torture, NULL, name, NULL, &matched);
 
        if (!matched) {
                printf("Unknown torture operation '%s'\n", name);
-               ret = False;
+               return false;
        }
 
        return ret;
 }
 
-static void parse_dns(const char *dns)
+static bool parse_target(struct loadparm_context *lp_ctx, const char *target)
+{
+       char *host = NULL, *share = NULL;
+       struct dcerpc_binding *binding_struct;
+       NTSTATUS status;
+
+       /* see if its a RPC transport specifier */
+       if (!smbcli_parse_unc(target, NULL, &host, &share)) {
+               status = dcerpc_parse_binding(talloc_autofree_context(), target, &binding_struct);
+               if (NT_STATUS_IS_ERR(status)) {
+                       d_printf("Invalid option: %s is not a valid torture target (share or binding string)\n\n", target);
+                       return false;
+               }
+               lp_set_cmdline(lp_ctx, "torture:host", binding_struct->host);
+               if (lp_parm_string(lp_ctx, NULL, "torture", "share") == NULL)
+                       lp_set_cmdline(lp_ctx, "torture:share", "IPC$");
+               lp_set_cmdline(lp_ctx, "torture:binding", target);
+       } else {
+               lp_set_cmdline(lp_ctx, "torture:host", host);
+               lp_set_cmdline(lp_ctx, "torture:share", share);
+               lp_set_cmdline(lp_ctx, "torture:binding", host);
+       }
+
+       return true;
+}
+
+static void parse_dns(struct loadparm_context *lp_ctx, const char *dns)
 {
        char *userdn, *basedn, *secret;
        char *p, *d;
@@ -97,42 +158,63 @@ static void parse_dns(const char *dns)
        /* retrievieng the userdn */
        p = strchr_m(dns, '#');
        if (!p) {
-               lp_set_cmdline("torture:ldap_userdn", "");
-               lp_set_cmdline("torture:ldap_basedn", "");
-               lp_set_cmdline("torture:ldap_secret", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_userdn", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_basedn", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_secret", "");
                return;
        }
        userdn = strndup(dns, p - dns);
-       lp_set_cmdline("torture:ldap_userdn", userdn);
+       lp_set_cmdline(lp_ctx, "torture:ldap_userdn", userdn);
 
        /* retrieve the basedn */
        d = p + 1;
        p = strchr_m(d, '#');
        if (!p) {
-               lp_set_cmdline("torture:ldap_basedn", "");
-               lp_set_cmdline("torture:ldap_secret", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_basedn", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_secret", "");
                return;
        }
        basedn = strndup(d, p - d);
-       lp_set_cmdline("torture:ldap_basedn", basedn);
+       lp_set_cmdline(lp_ctx, "torture:ldap_basedn", basedn);
 
        /* retrieve the secret */
        p = p + 1;
        if (!p) {
-               lp_set_cmdline("torture:ldap_secret", "");
+               lp_set_cmdline(lp_ctx, "torture:ldap_secret", "");
                return;
        }
        secret = strdup(p);
-       lp_set_cmdline("torture:ldap_secret", secret);
+       lp_set_cmdline(lp_ctx, "torture:ldap_secret", secret);
 
        printf ("%s - %s - %s\n", userdn, basedn, secret);
 
 }
 
-static void usage(poptContext pc)
+static void print_test_list(void)
+{
+       struct torture_suite *o;
+       struct torture_suite *s;
+       struct torture_tcase *t;
+
+       if (torture_root == NULL)
+               return;
+
+       for (o = torture_root->children; o; o = o->next) {
+               for (s = o->children; s; s = s->next) {
+                       printf("%s-%s\n", o->name, s->name);
+               }
+
+               for (t = o->testcases; t; t = t->next) {
+                       printf("%s-%s\n", o->name, t->name);
+               }
+       }
+}
+
+_NORETURN_ static void usage(poptContext pc)
 {
-       struct torture_op *o;
-       char last_prefix[64];
+       struct torture_suite *o;
+       struct torture_suite *s;
+       struct torture_tcase *t;
        int i;
 
        poptPrintUsage(pc, stdout, 0);
@@ -187,68 +269,64 @@ static void usage(poptContext pc)
 
        printf("Tests are:");
 
-       i = 0;
-       last_prefix[0] = '\0';
-       for (o = torture_ops; o; o = o->next) {
-               const char * sep;
-
-               if ((sep = strchr(o->name, '-'))) {
-                       if (strncmp(o->name, last_prefix, sep - o->name) != 0) {
-                               strncpy(last_prefix, o->name,
-                                       MIN(sizeof(last_prefix),
-                                           sep - o->name));
-                               printf("\n\n  ");
+       if (torture_root == NULL) {
+           printf("NO TESTS LOADED\n");
+           exit(1);
+       }
+
+       for (o = torture_root->children; o; o = o->next) {
+               printf("\n%s (%s):\n  ", o->description, o->name);
+
+               i = 0;
+               for (s = o->children; s; s = s->next) {
+                       if (i + strlen(o->name) + strlen(s->name) >= (MAX_COLS - 3)) {
+                               printf("\n  ");
                                i = 0;
                        }
+                       i+=printf("%s-%s ", o->name, s->name);
                }
 
-               if (i + strlen(o->name) >= (MAX_COLS - 2)) {
-                       printf("\n  ");
-                       i = 0;
+               for (t = o->testcases; t; t = t->next) {
+                       if (i + strlen(o->name) + strlen(t->name) >= (MAX_COLS - 3)) {
+                               printf("\n  ");
+                               i = 0;
+                       }
+                       i+=printf("%s-%s ", o->name, t->name);
                }
-               i+=printf("%s ", o->name);
+
+               if (i) printf("\n");
        }
-       printf("\n\n");
 
-       printf("The default test is ALL.\n");
+       printf("\nThe default test is ALL.\n");
 
        exit(1);
 }
 
-static BOOL is_binding_string(const char *binding_string)
-{
-       TALLOC_CTX *mem_ctx = talloc_init("is_binding_string");
-       struct dcerpc_binding *binding_struct;
-       NTSTATUS status;
-       
-       status = dcerpc_parse_binding(mem_ctx, binding_string, &binding_struct);
-
-       talloc_free(mem_ctx);
-       return NT_STATUS_IS_OK(status);
-}
-
-static void max_runtime_handler(int sig)
+_NORETURN_ static void max_runtime_handler(int sig)
 {
        DEBUG(0,("maximum runtime exceeded for smbtorture - terminating\n"));
        exit(1);
 }
 
-static void simple_tcase_start (struct torture_context *ctx, 
-                                                          struct torture_tcase *tcase,
-                                                          struct torture_test *test)
+struct timeval last_suite_started;
+
+static void simple_suite_start(struct torture_context *ctx,
+                              struct torture_suite *suite)
 {
-       printf("Testing %s...\n", tcase->name);
+       last_suite_started = timeval_current();
+       printf("Running %s\n", suite->name);
 }
 
-static void simple_test_start (struct torture_context *ctx, 
-                                                          struct torture_tcase *tcase,
-                                                          struct torture_test *test)
+static void simple_suite_finish(struct torture_context *ctx,
+                               struct torture_suite *suite)
 {
-       printf("Testing %s/%s...\n", tcase->name, test->name);
+
+       printf("%s took %g secs\n\n", suite->name, 
+                  timeval_elapsed(&last_suite_started));
 }
 
-static void simple_test_result (struct torture_context *context, 
-                                                               enum torture_result res, const char *reason)
+static void simple_test_result(struct torture_context *context, 
+                              enum torture_result res, const char *reason)
 {
        switch (res) {
        case TORTURE_OK:
@@ -256,138 +334,220 @@ static void simple_test_result (struct torture_context *context,
                        printf("OK: %s\n", reason);
                break;
        case TORTURE_FAIL:
-               printf("ERROR: %s - %s\n", context->active_test->name, reason);
+               printf("TEST %s FAILED! - %s\n", context->active_test->name, reason);
                break;
-       case TORTURE_TODO:
-               printf("TODO: %s - %s\n", context->active_test->name, reason);
+       case TORTURE_ERROR:
+               printf("ERROR IN TEST %s! - %s\n", context->active_test->name, reason); 
                break;
        case TORTURE_SKIP:
                printf("SKIP: %s - %s\n", context->active_test->name, reason);
                break;
-
        }
 }
 
-static void simple_comment (struct torture_context *test, const char *comment)
+static void simple_comment(struct torture_context *test, 
+                          const char *comment)
 {
-       printf("# %s\n", comment);
+       printf("%s", comment);
+}
+
+static void simple_warning(struct torture_context *test, 
+                          const char *comment)
+{
+       fprintf(stderr, "WARNING: %s\n", comment);
 }
 
 const static struct torture_ui_ops std_ui_ops = {
        .comment = simple_comment,
-       .test_start = simple_test_start,
-       .tcase_start = simple_tcase_start,
+       .warning = simple_warning,
+       .suite_start = simple_suite_start,
+       .suite_finish = simple_suite_finish,
        .test_result = simple_test_result
 };
 
+static void subunit_init(struct torture_context *ctx) 
+{
+       /* FIXME: register segv and bus handler */
+}
+
+static void subunit_suite_start(struct torture_context *ctx,
+                               struct torture_suite *suite)
+{
+}
 
-static void subunit_test_start (struct torture_context *ctx, 
-                                                           struct torture_tcase *tcase,
-                                                               struct torture_test *test)
+static void subunit_test_start(struct torture_context *ctx, 
+                              struct torture_tcase *tcase,
+                              struct torture_test *test)
 {
        printf("test: %s\n", test->name);
 }
 
-static void subunit_test_result (struct torture_context *context, 
-                                                                enum torture_result res, const char *reason)
+static void subunit_test_result(struct torture_context *context, 
+                               enum torture_result res, const char *reason)
 {
        switch (res) {
        case TORTURE_OK:
-               printf("success: %s\n", context->active_test->name);
+               printf("success: %s", context->active_test->name);
                break;
        case TORTURE_FAIL:
-               printf("failure: %s [ %s ]\n", context->active_test->name, reason);
+               printf("failure: %s", context->active_test->name);
                break;
-       case TORTURE_TODO:
-               printf("todo: %s\n", context->active_test->name);
+       case TORTURE_ERROR:
+               printf("error: %s", context->active_test->name);
                break;
        case TORTURE_SKIP:
-               printf("skip: %s\n", context->active_test->name);
+               printf("skip: %s", context->active_test->name);
                break;
        }
+       if (reason)
+               printf(" [\n%s\n]", reason);
+       printf("\n");
 }
 
-static void subunit_comment (struct torture_context *test, const char *comment)
+static void subunit_comment(struct torture_context *test,
+                           const char *comment)
 {
-       printf("# %s\n", comment);
+       fprintf(stderr, "%s", comment);
+}
+
+static void subunit_warning(struct torture_context *test,
+                           const char *comment)
+{
+       fprintf(stderr, "WARNING!: %s\n", comment);
 }
 
 const static struct torture_ui_ops subunit_ui_ops = {
+       .init = subunit_init,
        .comment = subunit_comment,
+       .warning = subunit_warning,
        .test_start = subunit_test_start,
-       .test_result = subunit_test_result
+       .test_result = subunit_test_result,
+       .suite_start = subunit_suite_start
 };
 
-static void harness_test_start (struct torture_context *ctx, 
-                                                           struct torture_tcase *tcase,
-                                                               struct torture_test *test)
+static void quiet_suite_start(struct torture_context *ctx,
+                             struct torture_suite *suite)
 {
+       int i;
+       ctx->quiet = true;
+       for (i = 1; i < ctx->level; i++) putchar('\t');
+       printf("%s: ", suite->name);
+       fflush(stdout);
 }
 
-static void harness_test_result (struct torture_context *context, 
-                                                                enum torture_result res, const char *reason)
+static void quiet_suite_finish(struct torture_context *ctx,
+                              struct torture_suite *suite)
 {
-       switch (res) {
-       case TORTURE_OK:
-               printf("ok %s - %s\n", context->active_test->name, reason);
-               break;
-       case TORTURE_FAIL:
-               printf("not ok %s - %s\n", context->active_test->name, reason);
-               break;
-       case TORTURE_TODO:
-               printf("todo %s - %s\n", context->active_test->name, reason);
-               break;
-       case TORTURE_SKIP:
-               printf("skip %s - %s\n", context->active_test->name, reason);
-               break;
-       }
+       putchar('\n');
 }
 
-static void harness_comment (struct torture_context *test, const char *comment)
+static void quiet_test_result(struct torture_context *context, 
+                             enum torture_result res, const char *reason)
 {
-       printf("# %s\n", comment);
+       fflush(stdout);
+       switch (res) {
+       case TORTURE_OK: putchar('.'); break;
+       case TORTURE_FAIL: putchar('F'); break;
+       case TORTURE_ERROR: putchar('E'); break;
+       case TORTURE_SKIP: putchar('I'); break;
+       }
 }
 
-const static struct torture_ui_ops harness_ui_ops = {
-       .comment = harness_comment,
-       .test_start = harness_test_start,
-       .test_result = harness_test_result
+const static struct torture_ui_ops quiet_ui_ops = {
+       .suite_start = quiet_suite_start,
+       .suite_finish = quiet_suite_finish,
+       .test_result = quiet_test_result
 };
 
+void run_shell(struct torture_context *tctx)
+{
+       char *cline;
+       int argc;
+       const char **argv;
+       int ret;
+
+       while (1) {
+               cline = smb_readline("torture> ", NULL, NULL);
+
+               if (cline == NULL)
+                       return;
+       
+               ret = poptParseArgvString(cline, &argc, &argv);
+               if (ret != 0) {
+                       fprintf(stderr, "Error parsing line\n");
+                       continue;
+               }
+
+               if (!strcmp(argv[0], "quit")) {
+                       return;
+               } else if (!strcmp(argv[0], "set")) {
+                       if (argc < 3) {
+                               fprintf(stderr, "Usage: set <variable> <value>\n");
+                       } else {
+                               char *name = talloc_asprintf(NULL, "torture:%s", argv[1]);
+                               lp_set_cmdline(tctx->lp_ctx, name, argv[2]);
+                               talloc_free(name);
+                       }
+               } else if (!strcmp(argv[0], "help")) {
+                       fprintf(stderr, "Available commands:\n"
+                                                       " help - This help command\n"
+                                                       " run - Run test\n"
+                                                       " set - Change variables\n"
+                                                       "\n");
+               } else if (!strcmp(argv[0], "run")) {
+                       if (argc < 2) {
+                               fprintf(stderr, "Usage: run TEST-NAME [OPTIONS...]\n");
+                       } else {
+                               run_test(tctx, argv[1]);
+                       }
+               }
+               free(cline);
+       }
+}
+
 /****************************************************************************
   main program
 ****************************************************************************/
- int main(int argc,char *argv[])
+int main(int argc,char *argv[])
 {
        int opt, i;
-       char *p;
-       BOOL correct = True;
+       bool correct = true;
        int max_runtime=0;
        int argc_new;
        struct torture_context *torture;
+       const struct torture_ui_ops *ui_ops;
        char **argv_new;
        poptContext pc;
+       static const char *target = "other";
+       NTSTATUS status;
+       int shell = false;
        static const char *ui_ops_name = "simple";
-       enum {OPT_LOADFILE=1000,OPT_UNCLIST,OPT_TIMELIMIT,OPT_DNS,
-             OPT_DANGEROUS,OPT_SMB_PORTS,OPT_ASYNC};
+       const char *basedir = NULL;
+       const char *extra_module = NULL;
+       static int list_tests = 0;
+       enum {OPT_LOADFILE=1000,OPT_UNCLIST,OPT_TIMELIMIT,OPT_DNS, OPT_LIST,
+             OPT_DANGEROUS,OPT_SMB_PORTS,OPT_ASYNC,OPT_NUMPROGS};
        
        struct poptOption long_options[] = {
                POPT_AUTOHELP
-               {"format", 0, POPT_ARG_STRING, &ui_ops_name, 0, "Output format (one of: simple, subunit, harness)", NULL },
+               {"format", 0, POPT_ARG_STRING, &ui_ops_name, 0, "Output format (one of: simple, subunit)", NULL },
                {"smb-ports",   'p', POPT_ARG_STRING, NULL,     OPT_SMB_PORTS,  "SMB ports",    NULL},
-               {"seed",          0, POPT_ARG_INT,  &torture_seed,      0,      "seed",         NULL},
-               {"num-progs",     0, POPT_ARG_INT,  &torture_nprocs,    0,      "num progs",    NULL},
+               {"basedir",       0, POPT_ARG_STRING, &basedir, 0, "base directory", "BASEDIR" },
+               {"seed",          0, POPT_ARG_INT,  &torture_seed,      0,      "Seed to use for randomizer",   NULL},
+               {"num-progs",     0, POPT_ARG_INT,  NULL,       OPT_NUMPROGS,   "num progs",    NULL},
                {"num-ops",       0, POPT_ARG_INT,  &torture_numops,    0,      "num ops",      NULL},
                {"entries",       0, POPT_ARG_INT,  &torture_entries,   0,      "entries",      NULL},
-               {"use-oplocks", 'L', POPT_ARG_NONE, &use_oplocks,       0,      "use oplocks",  NULL},
-               {"show-all",      0, POPT_ARG_NONE, &torture_showall,   0,      "show all",     NULL},
-               {"loadfile",      0, POPT_ARG_STRING,   NULL,   OPT_LOADFILE,   "loadfile",     NULL},
+               {"loadfile",      0, POPT_ARG_STRING,   NULL,   OPT_LOADFILE,   "NBench load file to use",      NULL},
+               {"list",          0, POPT_ARG_NONE, &list_tests, 0, "List available tests and exit", NULL },
                {"unclist",       0, POPT_ARG_STRING,   NULL,   OPT_UNCLIST,    "unclist",      NULL},
-               {"timelimit",   't', POPT_ARG_STRING,   NULL,   OPT_TIMELIMIT,  "timelimit",    NULL},
+               {"timelimit",   't', POPT_ARG_INT,      NULL,   OPT_TIMELIMIT,  "Set time limit (in seconds)",  NULL},
                {"failures",    'f', POPT_ARG_INT,  &torture_failures,  0,      "failures",     NULL},
                {"parse-dns",   'D', POPT_ARG_STRING,   NULL,   OPT_DNS,        "parse-dns",    NULL},
                {"dangerous",   'X', POPT_ARG_NONE,     NULL,   OPT_DANGEROUS,
                 "run dangerous tests (eg. wiping out password database)", NULL},
+               {"load-module",  0,  POPT_ARG_STRING, &extra_module,     0, "load tests from DSO file",    "SOFILE"},
+               {"shell",               0, POPT_ARG_NONE, &shell, true, "Run shell", NULL},
+               {"target",              'T', POPT_ARG_STRING, &target, 0, "samba3|samba4|other", NULL},
                {"async",       'a', POPT_ARG_NONE,     NULL,   OPT_ASYNC,
                 "run async tests", NULL},
                {"num-async",    0, POPT_ARG_INT,  &torture_numasync,  0,
@@ -398,15 +558,13 @@ const static struct torture_ui_ops harness_ui_ops = {
                POPT_COMMON_CONNECTION
                POPT_COMMON_CREDENTIALS
                POPT_COMMON_VERSION
-               POPT_TABLEEND
+               { NULL }
        };
 
-#ifdef HAVE_SETBUFFER
-       setbuffer(stdout, NULL, 0);
-#endif
+       setlinebuf(stdout);
 
        /* we are never interested in SIGPIPE */
-       BlockSignals(True,SIGPIPE);
+       BlockSignals(true, SIGPIPE);
 
        pc = poptGetContext("smbtorture", argc, (const char **) argv, long_options, 
                            POPT_CONTEXT_KEEP_FIRST);
@@ -416,35 +574,38 @@ const static struct torture_ui_ops harness_ui_ops = {
        while((opt = poptGetNextOpt(pc)) != -1) {
                switch (opt) {
                case OPT_LOADFILE:
-                       lp_set_cmdline("torture:loadfile", poptGetOptArg(pc));
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:loadfile", poptGetOptArg(pc));
                        break;
                case OPT_UNCLIST:
-                       lp_set_cmdline("torture:unclist", poptGetOptArg(pc));
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:unclist", poptGetOptArg(pc));
                        break;
                case OPT_TIMELIMIT:
-                       lp_set_cmdline("torture:timelimit", poptGetOptArg(pc));
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:timelimit", poptGetOptArg(pc));
+                       break;
+               case OPT_NUMPROGS:
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:nprocs", poptGetOptArg(pc));
                        break;
                case OPT_DNS:
-                       parse_dns(poptGetOptArg(pc));
+                       parse_dns(cmdline_lp_ctx, poptGetOptArg(pc));
                        break;
                case OPT_DANGEROUS:
-                       lp_set_cmdline("torture:dangerous", "Yes");
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:dangerous", "Yes");
                        break;
                case OPT_ASYNC:
-                       lp_set_cmdline("torture:async", "Yes");
+                       lp_set_cmdline(cmdline_lp_ctx, "torture:async", "Yes");
                        break;
                case OPT_SMB_PORTS:
-                       lp_set_cmdline("smb ports", poptGetOptArg(pc));
+                       lp_set_cmdline(cmdline_lp_ctx, "smb ports", poptGetOptArg(pc));
                        break;
-               default:
-                       d_printf("Invalid option %s: %s\n", 
-                                poptBadOption(pc, 0), poptStrerror(opt));
-                       torture_init();
-                       usage(pc);
-                       exit(1);
                }
        }
 
+       if (strcmp(target, "samba3") == 0) {
+               lp_set_cmdline(cmdline_lp_ctx, "torture:samba3", "true");
+       } else if (strcmp(target, "samba4") == 0) {
+               lp_set_cmdline(cmdline_lp_ctx, "torture:samba4", "true");
+       }
+
        if (max_runtime) {
                /* this will only work if nobody else uses alarm(),
                   which means it won't work for some tests, but we
@@ -455,8 +616,26 @@ const static struct torture_ui_ops harness_ui_ops = {
                alarm(max_runtime);
        }
 
-       torture_init();
-       ldb_global_init();
+       if (extra_module != NULL) {
+           init_module_fn fn = load_module(talloc_autofree_context(), poptGetOptArg(pc));
+
+           if (fn == NULL) 
+               d_printf("Unable to load module from %s\n", poptGetOptArg(pc));
+           else {
+               status = fn();
+               if (NT_STATUS_IS_ERR(status)) {
+                   d_printf("Error initializing module %s: %s\n", 
+                            poptGetOptArg(pc), nt_errstr(status));
+               }
+           }
+       } else { 
+               torture_init();
+       }
+
+       if (list_tests) {
+               print_test_list();
+               return 0;
+       }
 
        if (torture_seed == 0) {
                torture_seed = time(NULL);
@@ -474,59 +653,58 @@ const static struct torture_ui_ops harness_ui_ops = {
                }
        }
 
-       if (argc_new < 3) {
+       if (!(argc_new >= 3 || (shell && argc_new >= 2))) {
                usage(pc);
                exit(1);
        }
 
-        for(p = argv_new[1]; *p; p++) {
-               if(*p == '\\')
-                       *p = '/';
-       }
-
-       /* see if its a RPC transport specifier */
-       if (is_binding_string(argv_new[1])) {
-               lp_set_cmdline("torture:binding", argv_new[1]);
-       } else {
-               char *binding = NULL;
-               char *host = NULL, *share = NULL;
-
-               if (!smbcli_parse_unc(argv_new[1], NULL, &host, &share)) {
-                       d_printf("Invalid option: %s is not a valid torture target (share or binding string)\n\n", argv_new[1]);
-                       usage(pc);
-               }
-
-               lp_set_cmdline("torture:host", host);
-               lp_set_cmdline("torture:share", share);
-               asprintf(&binding, "ncacn_np:%s", host);
-               lp_set_cmdline("torture:binding", binding);
+       if (!parse_target(cmdline_lp_ctx, argv_new[1])) {
+               usage(pc);
+               exit(1);
        }
 
-       torture = talloc_zero(NULL, struct torture_context);
        if (!strcmp(ui_ops_name, "simple")) {
-               torture->ui_ops = &std_ui_ops;
+               ui_ops = &std_ui_ops;
        } else if (!strcmp(ui_ops_name, "subunit")) {
-               torture->ui_ops = &subunit_ui_ops;
-       } else if (!strcmp(ui_ops_name, "harness")) {
-               torture->ui_ops = &harness_ui_ops;
+               ui_ops = &subunit_ui_ops;
+       } else if (!strcmp(ui_ops_name, "quiet")) {
+               ui_ops = &quiet_ui_ops;
        } else {
                printf("Unknown output format '%s'\n", ui_ops_name);
                exit(1);
        }
 
+       torture = torture_context_init(event_context_init(NULL), ui_ops);
+       if (basedir != NULL) {
+               if (basedir[0] != '/') {
+                       fprintf(stderr, "Please specify an absolute path to --basedir\n");
+                       return 1;
+               }
+               torture->outputdir = basedir;
+       } else {
+               char *pwd = talloc_size(torture, PATH_MAX);
+               if (!getcwd(pwd, PATH_MAX)) {
+                       fprintf(stderr, "Unable to determine current working directory\n");
+                       return 1;
+               }
+               torture->outputdir = pwd;
+       }
+
+       torture->lp_ctx = cmdline_lp_ctx;
+
        if (argc_new == 0) {
                printf("You must specify a test to run, or 'ALL'\n");
+       } else if (shell) {
+               run_shell(torture);
        } else {
                for (i=2;i<argc_new;i++) {
                        if (!run_test(torture, argv_new[i])) {
-                               correct = False;
+                               correct = false;
                        }
                }
        }
 
-       talloc_free(torture);
-
-       if (correct) {
+       if (torture->returncode && correct) {
                return(0);
        } else {
                return(1);