89ef2e98923fe6f19666f94c893ece77b58f1b2f
[obnox/samba/samba-obnox.git] / selftest / target / Samba3.pm
1 #!/usr/bin/perl
2 # Bootstrap Samba and run a number of tests against it.
3 # Copyright (C) 2005-2007 Jelmer Vernooij <jelmer@samba.org>
4 # Published under the GNU GPL, v3 or later.
5
6 package Samba3;
7
8 use strict;
9 use Cwd qw(abs_path);
10 use FindBin qw($RealBin);
11 use POSIX;
12 use target::Samba;
13
14 sub new($$) {
15         my ($classname, $bindir, $binary_mapping, $srcdir, $exeext, $server_maxtime) = @_;
16         $exeext = "" unless defined($exeext);
17         my $self = { vars => {},
18                      bindir => $bindir,
19                      binary_mapping => $binary_mapping,
20                      srcdir => $srcdir,
21                      exeext => $exeext,
22                      server_maxtime => $server_maxtime
23         };
24         bless $self;
25         return $self;
26 }
27
28 sub teardown_env($$)
29 {
30         my ($self, $envvars) = @_;
31
32         my $smbdpid = read_pid($envvars, "smbd");
33         my $nmbdpid = read_pid($envvars, "nmbd");
34         my $winbinddpid = read_pid($envvars, "winbindd");
35         my $ctdbdpid = read_pid($envvars, "ctdbd");
36
37         $self->stop_sig_term($smbdpid);
38         $self->stop_sig_term($nmbdpid);
39         $self->stop_sig_term($winbinddpid);
40         $self->stop_sig_term($ctdbdpid);
41
42         sleep(2);
43
44         $self->stop_sig_kill($smbdpid);
45         $self->stop_sig_kill($nmbdpid);
46         $self->stop_sig_kill($winbinddpid);
47         $self->stop_sig_kill($ctdbdpid);
48
49         return 0;
50 }
51
52 sub getlog_env_app($$$)
53 {
54         my ($self, $envvars, $name) = @_;
55
56         my $title = "$name LOG of: $envvars->{NETBIOSNAME}\n";
57         my $out = $title;
58
59         unless (exists($envvars->{$name."_TEST_LOG"})) {
60                 die "getlog_env_app: \$envvars->{".$name."_TEST_LOG} not set\n";
61         }
62
63         open(LOG, "<".$envvars->{$name."_TEST_LOG"});
64
65         seek(LOG, $envvars->{$name."_TEST_LOG_POS"}, SEEK_SET);
66         while (<LOG>) {
67                 $out .= $_;
68         }
69         $envvars->{$name."_TEST_LOG_POS"} = tell(LOG);
70         close(LOG);
71
72         return "" if $out eq $title;
73  
74         return $out;
75 }
76
77 sub getlog_env($$)
78 {
79         my ($self, $envvars) = @_;
80         my $ret = "";
81
82         $ret .= $self->getlog_env_app($envvars, "SMBD");
83         $ret .= $self->getlog_env_app($envvars, "NMBD");
84         $ret .= $self->getlog_env_app($envvars, "WINBINDD");
85
86         return $ret;
87 }
88
89 sub getlog_env_ctdb($$)
90 {
91         my ($self, $envvars) = @_;
92         my $ret = "";
93
94         $ret .= $self->getlog_env_app($envvars, "CTDBD");
95 }
96
97 sub check_env($$)
98 {
99         my ($self, $envvars) = @_;
100
101         # TODO ...
102         return 1;
103 }
104
105 sub setup_env($$$)
106 {
107         my ($self, $envname, $path) = @_;
108         
109         if ($envname eq "s3dc") {
110                 return $self->setup_s3dc("$path/s3dc");
111         } elsif ($envname eq "secshare") {
112                 return $self->setup_secshare("$path/secshare");
113         } elsif ($envname eq "maptoguest") {
114                 return $self->setup_maptoguest("$path/maptoguest");
115         } elsif ($envname eq "ktest") {
116                 return $self->setup_ktest("$path/ktest");
117         } elsif ($envname eq "secserver") {
118                 if (not defined($self->{vars}->{s3dc})) {
119                         if (not defined($self->setup_s3dc("$path/s3dc"))) {
120                                 return undef;
121                         }
122                 }
123                 return $self->setup_secserver("$path/secserver", $self->{vars}->{s3dc});
124         } elsif ($envname eq "member") {
125                 if (not defined($self->{vars}->{s3dc})) {
126                         if (not defined($self->setup_s3dc("$path/s3dc"))) {
127                                 return undef;
128                         }
129                 }
130                 return $self->setup_member("$path/member", $self->{vars}->{s3dc});
131         } elsif ($envname eq "clusteredmember") {
132                 if (not defined($self->{vars}->{s3dc})) {
133                         if (not defined($self->setup_s3dc("$path/s3dc"))) {
134                                 return undef;
135                         }
136                 }
137                 return $self->setup_clusteredmember("$path/clusteredmember",
138                                                     $self->{vars}->{s3dc},
139                                                     "$path/ctdb");
140         } else {
141                 return undef;
142         }
143 }
144
145 sub setup_s3dc($$)
146 {
147         my ($self, $path) = @_;
148
149         print "PROVISIONING S3DC...";
150
151         my $s3dc_options = "
152         domain master = yes
153         domain logons = yes
154         lanman auth = yes
155 ";
156
157         my $vars = $self->provision($path,
158                                     "LOCALS3DC2",
159                                     2,
160                                     "locals3dc2pass",
161                                     $s3dc_options);
162
163         $vars or return undef;
164
165         $self->check_or_start($vars,
166                                "yes", "yes", "yes");
167
168         if (not $self->wait_for_start($vars)) {
169                return undef;
170         }
171
172         $vars->{DC_SERVER} = $vars->{SERVER};
173         $vars->{DC_SERVER_IP} = $vars->{SERVER_IP};
174         $vars->{DC_NETBIOSNAME} = $vars->{NETBIOSNAME};
175         $vars->{DC_USERNAME} = $vars->{USERNAME};
176         $vars->{DC_PASSWORD} = $vars->{PASSWORD};
177
178         $self->{vars}->{s3dc} = $vars;
179
180         return $vars;
181 }
182
183 sub setup_member($$$)
184 {
185         my ($self, $prefix, $s3dcvars) = @_;
186
187         print "PROVISIONING MEMBER...";
188
189         my $member_options = "
190         security = domain
191         server signing = on
192 ";
193         my $ret = $self->provision($prefix,
194                                    "LOCALMEMBER3",
195                                    3,
196                                    "localmember3pass",
197                                    $member_options);
198
199         $ret or return undef;
200
201         my $net = Samba::bindir_path($self, "net");
202         my $cmd = "";
203         $cmd .= "SOCKET_WRAPPER_DEFAULT_IFACE=\"$ret->{SOCKET_WRAPPER_DEFAULT_IFACE}\" ";
204         $cmd .= "$net join $ret->{CONFIGURATION} $s3dcvars->{DOMAIN} member";
205         $cmd .= " -U$s3dcvars->{USERNAME}\%$s3dcvars->{PASSWORD}";
206
207         if (system($cmd) != 0) {
208             warn("Join failed\n$cmd");
209             return undef;
210         }
211
212         $self->check_or_start($ret, "yes", "yes", "yes");
213
214         if (not $self->wait_for_start($ret)) {
215                return undef;
216         }
217
218         $ret->{DC_SERVER} = $s3dcvars->{SERVER};
219         $ret->{DC_SERVER_IP} = $s3dcvars->{SERVER_IP};
220         $ret->{DC_NETBIOSNAME} = $s3dcvars->{NETBIOSNAME};
221         $ret->{DC_USERNAME} = $s3dcvars->{USERNAME};
222         $ret->{DC_PASSWORD} = $s3dcvars->{PASSWORD};
223
224         return $ret;
225 }
226
227 sub setup_clusteredmember($$$$)
228 {
229         my ($self, $prefix, $s3dcvars, $ctdbprefix) = @_;
230         my $public_if = 8;
231
232         my $ctdb_vars = $self->setup_ctdb($ctdbprefix, $public_if);
233
234         $ctdb_vars or return undef;
235
236         print "PROVISIONING CLUSTEREDMEMBER...";
237
238         my $member_options = "
239         security = domain
240         server signing = on
241         clustering = yes
242         ctdbd socket = $ctdb_vars->{SOCKET_FILE}
243 ";
244         my $ret = $self->provision($prefix,
245                                    "LOCALMEMBER3CLUSTERED",
246                                    $public_if,
247                                    "localmember3pass",
248                                    $member_options);
249
250         $ret or return undef;
251
252         my $net = Samba::bindir_path($self, "net");
253         my $cmd = "";
254         $cmd .= "SOCKET_WRAPPER_DEFAULT_IFACE=\"$ret->{SOCKET_WRAPPER_DEFAULT_IFACE}\" ";
255         $cmd .= "$net join $ret->{CONFIGURATION} $s3dcvars->{DOMAIN} member";
256         $cmd .= " -U$s3dcvars->{USERNAME}\%$s3dcvars->{PASSWORD}";
257
258         if (system($cmd) != 0) {
259             warn("Join failed\n$cmd");
260             return undef;
261         }
262
263         $self->check_or_start($ret, "yes", "yes", "yes");
264
265         if (not $self->wait_for_start($ret)) {
266                return undef;
267         }
268
269         $ret->{DC_SERVER} = $s3dcvars->{SERVER};
270         $ret->{DC_SERVER_IP} = $s3dcvars->{SERVER_IP};
271         $ret->{DC_NETBIOSNAME} = $s3dcvars->{NETBIOSNAME};
272         $ret->{DC_USERNAME} = $s3dcvars->{USERNAME};
273         $ret->{DC_PASSWORD} = $s3dcvars->{PASSWORD};
274
275         $ret->{CTDB_SOCKET_FILE} = $ctdb_vars->{SOCKET_FILE};
276
277         return $ret;
278 }
279
280 sub setup_admember($$$$)
281 {
282         my ($self, $prefix, $dcvars, $iface) = @_;
283
284         print "PROVISIONING S3 AD MEMBER$iface...";
285
286         my $member_options = "
287         security = ads
288         server signing = on
289         workgroup = $dcvars->{DOMAIN}
290         realm = $dcvars->{REALM}
291 ";
292
293         my $ret = $self->provision($prefix,
294                                    "LOCALADMEMBER$iface",
295                                    $iface,
296                                    "loCalMember${iface}Pass",
297                                    $member_options);
298
299         $ret or return undef;
300
301         close(USERMAP);
302         $ret->{DOMAIN} = $dcvars->{DOMAIN};
303         $ret->{REALM} = $dcvars->{REALM};
304
305         my $ctx;
306         my $prefix_abs = abs_path($prefix);
307         $ctx = {};
308         $ctx->{krb5_conf} = "$prefix_abs/lib/krb5.conf";
309         $ctx->{domain} = $dcvars->{DOMAIN};
310         $ctx->{realm} = $dcvars->{REALM};
311         $ctx->{dnsname} = lc($dcvars->{REALM});
312         $ctx->{kdc_ipv4} = $dcvars->{SERVER_IP};
313         Samba::mk_krb5_conf($ctx, "");
314
315         $ret->{KRB5_CONFIG} = $ctx->{krb5_conf};
316
317         my $net = Samba::bindir_path($self, "net");
318         my $cmd = "";
319         $cmd .= "SOCKET_WRAPPER_DEFAULT_IFACE=\"$ret->{SOCKET_WRAPPER_DEFAULT_IFACE}\" ";
320         $cmd .= "KRB5_CONFIG=\"$ret->{KRB5_CONFIG}\" ";
321         $cmd .= "$net join $ret->{CONFIGURATION}";
322         $cmd .= " -U$dcvars->{USERNAME}\%$dcvars->{PASSWORD}";
323
324         if (system($cmd) != 0) {
325             warn("Join failed\n$cmd");
326             return undef;
327         }
328
329         # We need world access to this share, as otherwise the domain
330         # administrator from the AD domain provided by Samba4 can't
331         # access the share for tests.
332         chmod 0777, "$prefix/share";
333
334         $self->check_or_start($ret,
335                               "yes", "yes", "yes");
336
337         $self->wait_for_start($ret);
338
339         $ret->{DC_SERVER} = $dcvars->{SERVER};
340         $ret->{DC_SERVER_IP} = $dcvars->{SERVER_IP};
341         $ret->{DC_NETBIOSNAME} = $dcvars->{NETBIOSNAME};
342         $ret->{DC_USERNAME} = $dcvars->{USERNAME};
343         $ret->{DC_PASSWORD} = $dcvars->{PASSWORD};
344
345         # Special case, this is called from Samba4.pm but needs to use the Samba3 check_env and get_log_env
346         $ret->{target} = $self;
347
348         return $ret;
349 }
350
351 sub setup_plugin_s4_dc($$$$)
352 {
353         my ($self, $prefix, $dcvars, $iface) = @_;
354
355         print "PROVISIONING S4 PLUGIN AD DC$iface...";
356
357         my $plugin_s4_dc_options = "
358         workgroup = $dcvars->{DOMAIN}
359         realm = $dcvars->{REALM}
360
361         security = ads
362         domain logons = yes
363         passdb backend = samba4
364         auth methods = guest samba4
365         server signing = on
366
367         rpc_server:epmapper = disabled
368         rpc_server:rpcecho = disabled
369         rpc_server:dssetup = disabled
370         rpc_server:svctl = disabled
371         rpc_server:ntsvcs = disabled
372         rpc_server:eventlog = disabled
373         rpc_server:initshutdown = disabled
374
375         rpc_server:winreg = embedded
376         rpc_server:srvsvc = embedded
377         rpc_server:netdfs = embedded
378         rpc_server:wkssvc = embedded
379         rpc_server:spoolss = embedded
380
381         rpc_server:lsarpc = external
382         rpc_server:netlogon = external
383         rpc_server:samr = external
384
385         rpc_daemon:epmd = disabled
386         rpc_daemon:lsasd = disabled
387         rpc_daemon:spoolssd = disabled
388
389         rpc_server:tcpip = no
390
391 [IPC\$]
392         vfs objects = dfs_samba4
393 ";
394
395         my $ret = $self->provision($prefix,
396                                    "plugindc",
397                                    $iface,
398                                    "pluGin${iface}Pass",
399                                    $plugin_s4_dc_options, 1);
400
401         $ret or return undef;
402
403         close(USERMAP);
404         $ret->{DOMAIN} = $dcvars->{DOMAIN};
405         $ret->{REALM} = $dcvars->{REALM};
406         $ret->{KRB5_CONFIG} = $dcvars->{KRB5_CONFIG};
407
408         # We need world access to this share, as otherwise the domain
409         # administrator from the AD domain provided by Samba4 can't
410         # access the share for tests.
411         chmod 0777, "$prefix/share";
412
413         $self->check_or_start($ret,
414                               "no", "no", "yes");
415
416         $self->wait_for_start($ret);
417
418         # Special case, this is called from Samba4.pm but needs to use the Samba3 check_env and get_log_env
419         $ret->{target} = $self;
420
421         return $ret;
422 }
423
424 sub setup_secshare($$)
425 {
426         my ($self, $path) = @_;
427
428         print "PROVISIONING server with security=share...";
429
430         my $secshare_options = "
431         security = share
432         lanman auth = yes
433 ";
434
435         my $vars = $self->provision($path,
436                                     "LOCALSHARE4",
437                                     4,
438                                     "local4pass",
439                                     $secshare_options);
440
441         $vars or return undef;
442
443         $self->check_or_start($vars, "yes", "no", "yes");
444
445         if (not $self->wait_for_start($vars)) {
446                return undef;
447         }
448
449         $self->{vars}->{secshare} = $vars;
450
451         return $vars;
452 }
453
454 sub setup_secserver($$$)
455 {
456         my ($self, $prefix, $s3dcvars) = @_;
457
458         print "PROVISIONING server with security=server...";
459
460         my $secserver_options = "
461         security = server
462         password server = $s3dcvars->{SERVER_IP}
463 ";
464
465         my $ret = $self->provision($prefix,
466                                    "LOCALSERVER5",
467                                    5,
468                                    "localserver5pass",
469                                    $secserver_options);
470
471         $ret or return undef;
472
473         $self->check_or_start($ret, "yes", "no", "yes");
474
475         if (not $self->wait_for_start($ret)) {
476                return undef;
477         }
478
479         $ret->{DC_SERVER} = $s3dcvars->{SERVER};
480         $ret->{DC_SERVER_IP} = $s3dcvars->{SERVER_IP};
481         $ret->{DC_NETBIOSNAME} = $s3dcvars->{NETBIOSNAME};
482         $ret->{DC_USERNAME} = $s3dcvars->{USERNAME};
483         $ret->{DC_PASSWORD} = $s3dcvars->{PASSWORD};
484
485         return $ret;
486 }
487
488 sub setup_ktest($$$)
489 {
490         my ($self, $prefix) = @_;
491
492         print "PROVISIONING server with security=ads...";
493
494         my $ktest_options = "
495         workgroup = KTEST
496         realm = ktest.samba.example.com
497         security = ads
498         username map = $prefix/lib/username.map
499 ";
500
501         my $ret = $self->provision($prefix,
502                                    "LOCALKTEST6",
503                                    6,
504                                    "localktest6pass",
505                                    $ktest_options);
506
507         $ret or return undef;
508
509         my $ctx;
510         my $prefix_abs = abs_path($prefix);
511         $ctx = {};
512         $ctx->{krb5_conf} = "$prefix_abs/lib/krb5.conf";
513         $ctx->{domain} = "KTEST";
514         $ctx->{realm} = "KTEST.SAMBA.EXAMPLE.COM";
515         $ctx->{dnsname} = lc($ctx->{realm});
516         $ctx->{kdc_ipv4} = "0.0.0.0";
517         Samba::mk_krb5_conf($ctx, "");
518
519         $ret->{KRB5_CONFIG} = $ctx->{krb5_conf};
520
521         open(USERMAP, ">$prefix/lib/username.map") or die("Unable to open $prefix/lib/username.map");
522         print USERMAP "
523 $ret->{USERNAME} = KTEST\\Administrator
524 ";
525         close(USERMAP);
526
527 #This is the secrets.tdb created by 'net ads join' from Samba3 to a
528 #Samba4 DC with the same parameters as are being used here.  The
529 #domain SID is S-1-5-21-1071277805-689288055-3486227160
530
531         if (defined($ENV{BUILD_TDB2})) {
532             system("cp $self->{srcdir}/source3/selftest/ktest-secrets.tdb2 $prefix/private/secrets.tdb");
533         } else {
534             system("cp $self->{srcdir}/source3/selftest/ktest-secrets.tdb $prefix/private/secrets.tdb");
535         }
536         chmod 0600, "$prefix/private/secrets.tdb";
537
538 #This uses a pre-calculated krb5 credentials cache, obtained by running Samba4 with:
539 # "--option=kdc:service ticket lifetime=239232" "--option=kdc:user ticket lifetime=239232" "--option=kdc:renewal lifetime=239232"
540 #
541 #and having in krb5.conf:
542 # ticket_lifetime = 799718400
543 # renew_lifetime = 799718400
544 #
545 # The commands for the -2 keytab where were:
546 # kinit administrator@KTEST.SAMBA.EXAMPLE.COM
547 # kvno host/localktest6@KTEST.SAMBA.EXAMPLE.COM
548 # kvno cifs/localktest6@KTEST.SAMBA.EXAMPLE.COM
549 # kvno host/LOCALKTEST6@KTEST.SAMBA.EXAMPLE.COM
550 # kvno cifs/LOCALKTEST6@KTEST.SAMBA.EXAMPLE.COM
551 #
552 # and then for the -3 keytab, I did
553 #
554 # net changetrustpw; kdestroy and the same again.
555 #
556 # This creates a credential cache with a very long lifetime (2036 at
557 # at 2011-04), and shows that running 'net changetrustpw' does not
558 # break existing logins (for the secrets.tdb method at least).
559 #
560
561         $ret->{KRB5_CCACHE}="FILE:$prefix/krb5_ccache";
562
563         system("cp $self->{srcdir}/source3/selftest/ktest-krb5_ccache-2 $prefix/krb5_ccache-2");
564         chmod 0600, "$prefix/krb5_ccache-2";
565
566         system("cp $self->{srcdir}/source3/selftest/ktest-krb5_ccache-3 $prefix/krb5_ccache-3");
567         chmod 0600, "$prefix/krb5_ccache-3";
568
569         $self->check_or_start($ret, "yes", "no", "yes");
570
571         if (not $self->wait_for_start($ret)) {
572                return undef;
573         }
574         return $ret;
575 }
576
577 sub setup_maptoguest($$)
578 {
579         my ($self, $path) = @_;
580
581         print "PROVISIONING maptoguest...";
582
583         my $options = "
584 map to guest = bad user
585 ";
586
587         my $vars = $self->provision($path,
588                                     "maptoguest",
589                                     7,
590                                     "maptoguestpass",
591                                     $options);
592
593         $vars or return undef;
594
595         $self->check_or_start($vars,
596                                "yes", "no", "yes");
597
598         if (not $self->wait_for_start($vars)) {
599                return undef;
600         }
601
602         $self->{vars}->{s3maptoguest} = $vars;
603
604         return $vars;
605 }
606
607 sub stop_sig_term($$) {
608         my ($self, $pid) = @_;
609         kill("USR1", $pid) or kill("ALRM", $pid) or warn("Unable to kill $pid: $!");
610 }
611
612 sub stop_sig_kill($$) {
613         my ($self, $pid) = @_;
614         kill("ALRM", $pid) or warn("Unable to kill $pid: $!");
615 }
616
617 sub write_pid($$$)
618 {
619         my ($env_vars, $app, $pid) = @_;
620
621         open(PID, ">$env_vars->{PIDDIR}/timelimit.$app.pid");
622         print PID $pid;
623         close(PID);
624 }
625
626 sub read_pid($$)
627 {
628         my ($env_vars, $app) = @_;
629
630         open(PID, "<$env_vars->{PIDDIR}/timelimit.$app.pid");
631         my $pid = <PID>;
632         close(PID);
633         return $pid;
634 }
635
636 sub check_or_start($$$$) {
637         my ($self, $env_vars, $nmbd, $winbindd, $smbd) = @_;
638
639         unlink($env_vars->{NMBD_TEST_LOG});
640         print "STARTING NMBD...";
641         my $pid = fork();
642         if ($pid == 0) {
643                 open STDOUT, ">$env_vars->{NMBD_TEST_LOG}";
644                 open STDERR, '>&STDOUT';
645
646                 SocketWrapper::set_default_iface($env_vars->{SOCKET_WRAPPER_DEFAULT_IFACE});
647
648                 $ENV{KRB5_CONFIG} = $env_vars->{KRB5_CONFIG};
649                 $ENV{WINBINDD_SOCKET_DIR} = $env_vars->{WINBINDD_SOCKET_DIR};
650                 $ENV{NMBD_SOCKET_DIR} = $env_vars->{NMBD_SOCKET_DIR};
651
652                 $ENV{NSS_WRAPPER_PASSWD} = $env_vars->{NSS_WRAPPER_PASSWD};
653                 $ENV{NSS_WRAPPER_GROUP} = $env_vars->{NSS_WRAPPER_GROUP};
654                 $ENV{NSS_WRAPPER_WINBIND_SO_PATH} = $env_vars->{NSS_WRAPPER_WINBIND_SO_PATH};
655
656                 $ENV{UID_WRAPPER} = "1";
657
658                 if ($nmbd ne "yes") {
659                         $SIG{USR1} = $SIG{ALRM} = $SIG{INT} = $SIG{QUIT} = $SIG{TERM} = sub {
660                                 my $signame = shift;
661                                 print("Skip nmbd received signal $signame");
662                                 exit 0;
663                         };
664                         sleep($self->{server_maxtime});
665                         exit 0;
666                 }
667
668                 my @optargs = ("-d0");
669                 if (defined($ENV{NMBD_OPTIONS})) {
670                         @optargs = split(/ /, $ENV{NMBD_OPTIONS});
671                 }
672
673                 $ENV{MAKE_TEST_BINARY} = Samba::bindir_path($self, "nmbd");
674
675                 my @preargs = (Samba::bindir_path($self, "timelimit"), $self->{server_maxtime});
676                 if(defined($ENV{NMBD_VALGRIND})) { 
677                         @preargs = split(/ /, $ENV{NMBD_VALGRIND});
678                 }
679
680                 exec(@preargs, Samba::bindir_path($self, "nmbd"), "-F", "--no-process-group", "--log-stdout", "-s", $env_vars->{SERVERCONFFILE}, @optargs) or die("Unable to start nmbd: $!");
681         }
682         write_pid($env_vars, "nmbd", $pid);
683         print "DONE\n";
684
685         unlink($env_vars->{WINBINDD_TEST_LOG});
686         print "STARTING WINBINDD...";
687         $pid = fork();
688         if ($pid == 0) {
689                 open STDOUT, ">$env_vars->{WINBINDD_TEST_LOG}";
690                 open STDERR, '>&STDOUT';
691
692                 SocketWrapper::set_default_iface($env_vars->{SOCKET_WRAPPER_DEFAULT_IFACE});
693
694                 $ENV{KRB5_CONFIG} = $env_vars->{KRB5_CONFIG};
695                 $ENV{WINBINDD_SOCKET_DIR} = $env_vars->{WINBINDD_SOCKET_DIR};
696                 $ENV{NMBD_SOCKET_DIR} = $env_vars->{NMBD_SOCKET_DIR};
697
698                 $ENV{NSS_WRAPPER_PASSWD} = $env_vars->{NSS_WRAPPER_PASSWD};
699                 $ENV{NSS_WRAPPER_GROUP} = $env_vars->{NSS_WRAPPER_GROUP};
700                 $ENV{NSS_WRAPPER_WINBIND_SO_PATH} = $env_vars->{NSS_WRAPPER_WINBIND_SO_PATH};
701
702                 $ENV{UID_WRAPPER} = "1";
703
704                 if ($winbindd ne "yes") {
705                         $SIG{USR1} = $SIG{ALRM} = $SIG{INT} = $SIG{QUIT} = $SIG{TERM} = sub {
706                                 my $signame = shift;
707                                 print("Skip winbindd received signal $signame");
708                                 exit 0;
709                         };
710                         sleep($self->{server_maxtime});
711                         exit 0;
712                 }
713
714                 my @optargs = ("-d0");
715                 if (defined($ENV{WINBINDD_OPTIONS})) {
716                         @optargs = split(/ /, $ENV{WINBINDD_OPTIONS});
717                 }
718
719                 $ENV{MAKE_TEST_BINARY} = Samba::bindir_path($self, "winbindd");
720
721                 my @preargs = (Samba::bindir_path($self, "timelimit"), $self->{server_maxtime});
722                 if(defined($ENV{WINBINDD_VALGRIND})) {
723                         @preargs = split(/ /, $ENV{WINBINDD_VALGRIND});
724                 }
725
726                 print "Starting winbindd with config $env_vars->{SERVERCONFFILE}\n";
727
728                 exec(@preargs, Samba::bindir_path($self, "winbindd"), "-F", "--no-process-group", "--stdout", "-s", $env_vars->{SERVERCONFFILE}, @optargs) or die("Unable to start winbindd: $!");
729         }
730         write_pid($env_vars, "winbindd", $pid);
731         print "DONE\n";
732
733         unlink($env_vars->{SMBD_TEST_LOG});
734         print "STARTING SMBD...";
735         $pid = fork();
736         if ($pid == 0) {
737                 open STDOUT, ">$env_vars->{SMBD_TEST_LOG}";
738                 open STDERR, '>&STDOUT';
739
740                 SocketWrapper::set_default_iface($env_vars->{SOCKET_WRAPPER_DEFAULT_IFACE});
741
742                 $ENV{KRB5_CONFIG} = $env_vars->{KRB5_CONFIG};
743                 $ENV{WINBINDD_SOCKET_DIR} = $env_vars->{WINBINDD_SOCKET_DIR};
744                 $ENV{NMBD_SOCKET_DIR} = $env_vars->{NMBD_SOCKET_DIR};
745
746                 $ENV{NSS_WRAPPER_PASSWD} = $env_vars->{NSS_WRAPPER_PASSWD};
747                 $ENV{NSS_WRAPPER_GROUP} = $env_vars->{NSS_WRAPPER_GROUP};
748                 $ENV{NSS_WRAPPER_WINBIND_SO_PATH} = $env_vars->{NSS_WRAPPER_WINBIND_SO_PATH};
749
750                 $ENV{UID_WRAPPER} = "1";
751
752                 if ($smbd ne "yes") {
753                         $SIG{USR1} = $SIG{ALRM} = $SIG{INT} = $SIG{QUIT} = $SIG{TERM} = sub {
754                                 my $signame = shift;
755                                 print("Skip smbd received signal $signame");
756                                 exit 0;
757                         };
758                         sleep($self->{server_maxtime});
759                         exit 0;
760                 }
761
762                 $ENV{MAKE_TEST_BINARY} = Samba::bindir_path($self, "smbd");
763                 my @optargs = ("-d0");
764                 if (defined($ENV{SMBD_OPTIONS})) {
765                         @optargs = split(/ /, $ENV{SMBD_OPTIONS});
766                 }
767                 my @preargs = (Samba::bindir_path($self, "timelimit"), $self->{server_maxtime});
768                 if(defined($ENV{SMBD_VALGRIND})) {
769                         @preargs = split(/ /,$ENV{SMBD_VALGRIND});
770                 }
771                 exec(@preargs, Samba::bindir_path($self, "smbd"), "-F", "--no-process-group", "--log-stdout", "-s", $env_vars->{SERVERCONFFILE}, @optargs) or die("Unable to start smbd: $!");
772         }
773         write_pid($env_vars, "smbd", $pid);
774         print "DONE\n";
775
776         return 0;
777 }
778
779 sub provision($$$$$$$)
780 {
781         my ($self, $prefix, $server, $swiface, $password, $extra_options, $no_delete_prefix) = @_;
782
783         ##
784         ## setup the various environment variables we need
785         ##
786
787         my %ret = ();
788         my $server_ip = "127.0.0.$swiface";
789         my $domain = "SAMBA-TEST";
790
791         my $unix_name = ($ENV{USER} or $ENV{LOGNAME} or `PATH=/usr/ucb:$ENV{PATH} whoami`);
792         chomp $unix_name;
793         my $unix_uid = $>;
794         my $unix_gids_str = $);
795         my @unix_gids = split(" ", $unix_gids_str);
796
797         my $prefix_abs = abs_path($prefix);
798         my $bindir_abs = abs_path($self->{bindir});
799         my $vfs_modulesdir_abs = ($ENV{VFSLIBDIR} or $bindir_abs);
800
801         my $dns_host_file = "$ENV{SELFTEST_PREFIX}/dns_host_file";
802
803         my @dirs = ();
804
805         my $shrdir="$prefix_abs/share";
806         push(@dirs,$shrdir);
807
808         my $libdir="$prefix_abs/lib";
809         push(@dirs,$libdir);
810
811         my $piddir="$prefix_abs/pid";
812         push(@dirs,$piddir);
813
814         my $privatedir="$prefix_abs/private";
815         push(@dirs,$privatedir);
816
817         my $lockdir="$prefix_abs/lockdir";
818         push(@dirs,$lockdir);
819
820         my $eventlogdir="$prefix_abs/lockdir/eventlog";
821         push(@dirs,$eventlogdir);
822
823         my $logdir="$prefix_abs/logs";
824         push(@dirs,$logdir);
825
826         my $driver32dir="$shrdir/W32X86";
827         push(@dirs,$driver32dir);
828
829         my $driver64dir="$shrdir/x64";
830         push(@dirs,$driver64dir);
831
832         my $driver40dir="$shrdir/WIN40";
833         push(@dirs,$driver40dir);
834
835         my $ro_shrdir="$shrdir/root-tmp";
836         push(@dirs,$ro_shrdir);
837
838         my $msdfs_shrdir="$shrdir/msdfsshare";
839         push(@dirs,$msdfs_shrdir);
840
841         my $msdfs_deeppath="$msdfs_shrdir/deeppath";
842         push(@dirs,$msdfs_deeppath);
843
844         # this gets autocreated by winbindd
845         my $wbsockdir="$prefix_abs/winbindd";
846         my $wbsockprivdir="$lockdir/winbindd_privileged";
847
848         my $nmbdsockdir="$prefix_abs/nmbd";
849         unlink($nmbdsockdir);
850
851         ## 
852         ## create the test directory layout
853         ##
854         die ("prefix_abs = ''") if $prefix_abs eq "";
855         die ("prefix_abs = '/'") if $prefix_abs eq "/";
856
857         mkdir($prefix_abs, 0777);
858         print "CREATE TEST ENVIRONMENT IN '$prefix'...";
859         if (not defined($no_delete_prefix) or not $no_delete_prefix) {
860             system("rm -rf $prefix_abs/*");
861         }
862         mkdir($_, 0777) foreach(@dirs);
863
864         ##
865         ## create ro and msdfs share layout
866         ##
867
868         chmod 0755, $ro_shrdir;
869         my $unreadable_file = "$ro_shrdir/unreadable_file";
870         unless (open(UNREADABLE_FILE, ">$unreadable_file")) {
871                 warn("Unable to open $unreadable_file");
872                 return undef;
873         }
874         close(UNREADABLE_FILE);
875         chmod 0600, $unreadable_file;
876
877         my $msdfs_target = "$ro_shrdir/msdfs-target";
878         unless (open(MSDFS_TARGET, ">$msdfs_target")) {
879                 warn("Unable to open $msdfs_target");
880                 return undef;
881         }
882         close(MSDFS_TARGET);
883         chmod 0666, $msdfs_target;
884         symlink "msdfs:$server_ip\\ro-tmp", "$msdfs_shrdir/msdfs-src1";
885         symlink "msdfs:$server_ip\\ro-tmp", "$msdfs_shrdir/deeppath/msdfs-src2";
886
887         my $conffile="$libdir/server.conf";
888
889         my $nss_wrapper_pl = "$ENV{PERL} $self->{srcdir}/lib/nss_wrapper/nss_wrapper.pl";
890         my $nss_wrapper_passwd = "$privatedir/passwd";
891         my $nss_wrapper_group = "$privatedir/group";
892
893         my $mod_printer_pl = "$ENV{PERL} $self->{srcdir}/source3/script/tests/printing/modprinter.pl";
894
895         my @eventlog_list = ("dns server", "application");
896
897         ##
898         ## calculate uids and gids
899         ##
900
901         my ($max_uid, $max_gid);
902         my ($uid_nobody, $uid_root);
903         my ($gid_nobody, $gid_nogroup, $gid_root, $gid_domusers);
904
905         if ($unix_uid < 0xffff - 2) {
906                 $max_uid = 0xffff;
907         } else {
908                 $max_uid = $unix_uid;
909         }
910
911         $uid_root = $max_uid - 1;
912         $uid_nobody = $max_uid - 2;
913
914         if ($unix_gids[0] < 0xffff - 3) {
915                 $max_gid = 0xffff;
916         } else {
917                 $max_gid = $unix_gids[0];
918         }
919
920         $gid_nobody = $max_gid - 1;
921         $gid_nogroup = $max_gid - 2;
922         $gid_root = $max_gid - 3;
923         $gid_domusers = $max_gid - 4;
924
925         ##
926         ## create conffile
927         ##
928
929         unless (open(CONF, ">$conffile")) {
930                 warn("Unable to open $conffile");
931                 return undef;
932         }
933         print CONF "
934 [global]
935         netbios name = $server
936         interfaces = $server_ip/8
937         bind interfaces only = yes
938         panic action = $self->{srcdir}/selftest/gdb_backtrace %d %\$(MAKE_TEST_BINARY)
939
940         workgroup = $domain
941
942         private dir = $privatedir
943         pid directory = $piddir
944         lock directory = $lockdir
945         log file = $logdir/log.\%m
946         log level = 0
947         debug pid = yes
948         max log size = 0
949
950         state directory = $lockdir
951         cache directory = $lockdir
952
953         passdb backend = tdbsam
954
955         time server = yes
956
957         add user script =               $nss_wrapper_pl --passwd_path $nss_wrapper_passwd --type passwd --action add --name %u --gid $gid_nogroup
958         add group script =              $nss_wrapper_pl --group_path  $nss_wrapper_group  --type group  --action add --name %g
959         add machine script =            $nss_wrapper_pl --passwd_path $nss_wrapper_passwd --type passwd --action add --name %u --gid $gid_nogroup
960         add user to group script =      $nss_wrapper_pl --passwd_path $nss_wrapper_passwd --type member --action add --member %u --name %g --group_path $nss_wrapper_group
961         delete user script =            $nss_wrapper_pl --passwd_path $nss_wrapper_passwd --type passwd --action delete --name %u
962         delete group script =           $nss_wrapper_pl --group_path  $nss_wrapper_group  --type group  --action delete --name %g
963         delete user from group script = $nss_wrapper_pl --passwd_path $nss_wrapper_passwd --type member --action delete --member %u --name %g --group_path $nss_wrapper_group
964
965         addprinter command =            $mod_printer_pl -a -s $conffile --
966         deleteprinter command =         $mod_printer_pl -d -s $conffile --
967
968         eventlog list = application \"dns server\"
969
970         kernel oplocks = no
971         kernel change notify = no
972
973         syslog = no
974         printing = bsd
975         printcap name = /dev/null
976
977         winbindd:socket dir = $wbsockdir
978         nmbd:socket dir = $nmbdsockdir
979         idmap config * : range = 100000-200000
980         winbind enum users = yes
981         winbind enum groups = yes
982
983 #       min receivefile size = 4000
984
985         max protocol = SMB2
986         read only = no
987         server signing = auto
988
989         smbd:sharedelay = 100000
990 #       smbd:writetimeupdatedelay = 500000
991         map hidden = no
992         map system = no
993         map readonly = no
994         store dos attributes = yes
995         create mask = 755
996         vfs objects = $vfs_modulesdir_abs/xattr_tdb.so $vfs_modulesdir_abs/streams_depot.so
997
998         printing = vlp
999         print command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb print %p %s
1000         lpq command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb lpq %p
1001         lp rm command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb lprm %p %j
1002         lp pause command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb lppause %p %j
1003         lp resume command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb lpresume %p %j
1004         queue pause command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb queuepause %p
1005         queue resume command = $bindir_abs/vlp tdbfile=$lockdir/vlp.tdb queueresume %p
1006         lpq cache time = 0
1007
1008         ncalrpc dir = $prefix_abs/ncalrpc
1009         rpc_server:epmapper = external
1010         rpc_server:spoolss = external
1011         rpc_server:lsarpc = external
1012         rpc_server:samr = external
1013         rpc_server:netlogon = external
1014         rpc_server:tcpip = yes
1015
1016         rpc_daemon:epmd = fork
1017         rpc_daemon:spoolssd = fork
1018         rpc_daemon:lsasd = fork
1019
1020         resolv:host file = $dns_host_file
1021
1022         # The samba3.blackbox.smbclient_s3 test uses this to test that
1023         # sending messages works, and that the %m sub works.
1024         message command = mv %s $shrdir/message.%m
1025
1026         # Begin extra options
1027         $extra_options
1028         # End extra options
1029
1030         #Include user defined custom parameters if set
1031 ";
1032
1033         if (defined($ENV{INCLUDE_CUSTOM_CONF})) {
1034                 print CONF "\t$ENV{INCLUDE_CUSTOM_CONF}\n";
1035         }
1036
1037         print CONF "
1038 [tmp]
1039         path = $shrdir
1040         comment = smb username is [%U]
1041 [tmpguest]
1042         path = $shrdir
1043         guest ok = yes
1044 [guestonly]
1045         path = $shrdir
1046         guest only = yes
1047         guest ok = yes
1048 [forceuser]
1049         path = $shrdir
1050         force user = $unix_name
1051         guest ok = yes
1052 [forcegroup]
1053         path = $shrdir
1054         force group = nogroup
1055         guest ok = yes
1056 [ro-tmp]
1057         path = $ro_shrdir
1058         guest ok = yes
1059 [msdfs-share]
1060         path = $msdfs_shrdir
1061         msdfs root = yes
1062         guest ok = yes
1063 [hideunread]
1064         copy = tmp
1065         hide unreadable = yes
1066 [tmpcase]
1067         copy = tmp
1068         case sensitive = yes
1069 [hideunwrite]
1070         copy = tmp
1071         hide unwriteable files = yes
1072 [print1]
1073         copy = tmp
1074         printable = yes
1075
1076 [print2]
1077         copy = print1
1078 [print3]
1079         copy = print1
1080 [lp]
1081         copy = print1
1082 [print\$]
1083         copy = tmp
1084         ";
1085         close(CONF);
1086
1087         ##
1088         ## create a test account
1089         ##
1090
1091         unless (open(PASSWD, ">$nss_wrapper_passwd")) {
1092            warn("Unable to open $nss_wrapper_passwd");
1093            return undef;
1094         } 
1095         print PASSWD "nobody:x:$uid_nobody:$gid_nobody:nobody gecos:$prefix_abs:/bin/false
1096 $unix_name:x:$unix_uid:$unix_gids[0]:$unix_name gecos:$prefix_abs:/bin/false
1097 ";
1098         if ($unix_uid != 0) {
1099                 print PASSWD "root:x:$uid_root:$gid_root:root gecos:$prefix_abs:/bin/false";
1100         }
1101         close(PASSWD);
1102
1103         unless (open(GROUP, ">$nss_wrapper_group")) {
1104              warn("Unable to open $nss_wrapper_group");
1105              return undef;
1106         }
1107         print GROUP "nobody:x:$gid_nobody:
1108 nogroup:x:$gid_nogroup:nobody
1109 $unix_name-group:x:$unix_gids[0]:
1110 domusers:X:$gid_domusers:
1111 ";
1112         if ($unix_gids[0] != 0) {
1113                 print GROUP "root:x:$gid_root:";
1114         }
1115
1116         close(GROUP);
1117
1118         foreach my $evlog (@eventlog_list) {
1119                 my $evlogtdb = "$eventlogdir/$evlog.tdb";
1120                 open(EVENTLOG, ">$evlogtdb") or die("Unable to open $evlogtdb");
1121                 close(EVENTLOG);
1122         }
1123
1124         $ENV{NSS_WRAPPER_PASSWD} = $nss_wrapper_passwd;
1125         $ENV{NSS_WRAPPER_GROUP} = $nss_wrapper_group;
1126
1127         my $cmd = Samba::bindir_path($self, "smbpasswd")." -c $conffile -L -s -a $unix_name > /dev/null";
1128         unless (open(PWD, "|$cmd")) {
1129              warn("Unable to set password for test account\n$cmd");
1130              return undef;
1131         }
1132         print PWD "$password\n$password\n";
1133         unless (close(PWD)) {
1134              warn("Unable to set password for test account\n$cmd");
1135              return undef; 
1136         }
1137         print "DONE\n";
1138
1139         open(HOSTS, ">>$ENV{SELFTEST_PREFIX}/dns_host_file") or die("Unable to open $ENV{SELFTEST_PREFIX}/dns_host_file");
1140         print HOSTS "A $server. $server_ip
1141 ";
1142         close(HOSTS);
1143
1144         $ret{SERVER_IP} = $server_ip;
1145         $ret{NMBD_TEST_LOG} = "$prefix/nmbd_test.log";
1146         $ret{NMBD_TEST_LOG_POS} = 0;
1147         $ret{WINBINDD_TEST_LOG} = "$prefix/winbindd_test.log";
1148         $ret{WINBINDD_TEST_LOG_POS} = 0;
1149         $ret{SMBD_TEST_LOG} = "$prefix/smbd_test.log";
1150         $ret{SMBD_TEST_LOG_POS} = 0;
1151         $ret{SERVERCONFFILE} = $conffile;
1152         $ret{CONFIGURATION} ="-s $conffile";
1153         $ret{SERVER} = $server;
1154         $ret{USERNAME} = $unix_name;
1155         $ret{USERID} = $unix_uid;
1156         $ret{DOMAIN} = $domain;
1157         $ret{NETBIOSNAME} = $server;
1158         $ret{PASSWORD} = $password;
1159         $ret{PIDDIR} = $piddir;
1160         $ret{WINBINDD_SOCKET_DIR} = $wbsockdir;
1161         $ret{WINBINDD_PRIV_PIPE_DIR} = $wbsockprivdir;
1162         $ret{NMBD_SOCKET_DIR} = $nmbdsockdir;
1163         $ret{SOCKET_WRAPPER_DEFAULT_IFACE} = $swiface;
1164         $ret{NSS_WRAPPER_PASSWD} = $nss_wrapper_passwd;
1165         $ret{NSS_WRAPPER_GROUP} = $nss_wrapper_group;
1166         $ret{NSS_WRAPPER_WINBIND_SO_PATH} = $ENV{NSS_WRAPPER_WINBIND_SO_PATH};
1167         if (not defined($ret{NSS_WRAPPER_WINBIND_SO_PATH})) {
1168                 $ret{NSS_WRAPPER_WINBIND_SO_PATH} = Samba::bindir_path($self, "default/nsswitch/libnss-winbind.so");
1169         }
1170         $ret{LOCAL_PATH} = "$shrdir";
1171
1172         return \%ret;
1173 }
1174
1175 sub wait_for_start($$)
1176 {
1177         my ($self, $envvars) = @_;
1178
1179         # give time for nbt server to register its names
1180         print "delaying for nbt name registration\n";
1181         sleep(10);
1182         # This will return quickly when things are up, but be slow if we need to wait for (eg) SSL init 
1183         system(Samba::bindir_path($self, "nmblookup3") ." $envvars->{CONFIGURATION} -U $envvars->{SERVER_IP} __SAMBA__");
1184         system(Samba::bindir_path($self, "nmblookup3") ." $envvars->{CONFIGURATION} __SAMBA__");
1185         system(Samba::bindir_path($self, "nmblookup3") ." $envvars->{CONFIGURATION} -U 127.255.255.255 __SAMBA__");
1186         system(Samba::bindir_path($self, "nmblookup3") ." $envvars->{CONFIGURATION} -U $envvars->{SERVER_IP} $envvars->{SERVER}");
1187         system(Samba::bindir_path($self, "nmblookup3") ." $envvars->{CONFIGURATION} $envvars->{SERVER}");
1188
1189         # make sure smbd is also up set
1190         print "wait for smbd\n";
1191
1192         my $count = 0;
1193         my $ret;
1194         do {
1195             $ret = system(Samba::bindir_path($self, "smbclient3") ." $envvars->{CONFIGURATION} -L $envvars->{SERVER} -U% -p 139");
1196             if ($ret != 0) {
1197                 sleep(2);
1198             }
1199             $count++
1200         } while ($ret != 0 && $count < 10);
1201         if ($count == 10) {
1202             print "SMBD failed to start up in a reasonable time (20sec)\n";
1203             teardown_env($self, $envvars);
1204             return 0;
1205         }
1206         # Ensure we have domain users mapped.
1207         $ret = system(Samba::bindir_path($self, "net") ." $envvars->{CONFIGURATION} groupmap add rid=513 unixgroup=domusers type=domain");
1208         if ($ret != 0) {
1209             return 1;
1210         }
1211
1212         print $self->getlog_env($envvars);
1213
1214         return 1;
1215 }
1216
1217
1218 ##
1219 ## provision and start of ctdb
1220 ##
1221
1222 sub setup_ctdb($$)
1223 {
1224         my ($self, $prefix, $public_if) = @_;
1225
1226         print "PROVISIONING CTDB...";
1227
1228         # Give it a high ip that is (hopfully) not used elsewhere.
1229         # What is the mechanism here?
1230         my $private_if = 100;
1231
1232         my $vars = $self->provision_ctdb($prefix, $public_if, $private_if);
1233
1234         $vars or return undef;
1235
1236         $self->check_or_start_ctdb($vars);
1237
1238         if (not $self->wait_for_start_ctdb($vars)) {
1239                 return undef;
1240         }
1241
1242         # TODO $vars->... ?
1243
1244         $self->{vars}->{ctdb} = $vars;
1245
1246         return $vars;
1247 }
1248
1249 sub check_or_start_ctdb($$) {
1250         my ($self, $env_vars) = @_;
1251
1252         unlink($env_vars->{CTDB_TEST_LOG});
1253         print "STARTING CTDB...";
1254         my $pid = fork();
1255         if ($pid == 0) {
1256                 open STDOUT, ">$env_vars->{CTDB_TEST_LOG}";
1257                 open STDERR, '>&STDOUT';
1258
1259                 my @preargs = (Samba::bindir_path($self, "timelimit"), $self->{server_maxtime});
1260                 if(defined($ENV{CTDBD_VALGRIND})) {
1261                         @preargs = split(/ /, $ENV{CTDBD_VALGRIND});
1262                 }
1263
1264                 exec(@preargs, "$env_vars->{BINDIR}/ctdbd",
1265                         "--socket=$env_vars->{SOCKET_FILE}",
1266                         "--reclock=$env_vars->{RECLOCK_FILE}",
1267                         "--nlist=$env_vars->{NODES_FILE}",
1268                         "--nopublicipcheck",
1269                         "--public-addresses=$env_vars->{PUBLIC_ADDRESSES_FILE}",
1270                         "--event-script-dir=$env_vars->{EVENT_SCRIPT_DIR}",
1271                         "--logfile=$env_vars->{LOG_FILE}",
1272                         "-d $env_vars->{DEBUG_LEVEL}",
1273                         "--dbdir=$env_vars->{DB_DIR}",
1274                         "--dbdir-persistent=$env_vars->{DB_DIR_PERSISTENT}",
1275                         "--dbdir-state=$env_vars->{DB_DIR_STATE}",
1276                         ) or die("Unable to start ctdbd: $!");
1277         }
1278         write_pid($env_vars, "ctdbd", $pid);
1279         print "DONE\n";
1280
1281         return 0;
1282 }
1283
1284 sub provision_ctdb($$$$$)
1285 {
1286         my ($self, $prefix, $priviface, $pubiface, $no_delete_prefix) = @_;
1287
1288         my %ret = ();
1289
1290         my $internal_ip = "127.0.0.$priviface";
1291         my $public_ip = "127.0.0.$pubiface";
1292
1293         my @dirs = ();
1294
1295         my $prefix_abs = abs_path($prefix);
1296
1297         my $bindir = "$prefix_abs/bin";
1298         push @dirs, $bindir;
1299
1300         my $var_dir = "$prefix_abs/var";
1301         push @dirs, $var_dir;
1302
1303         my $reclock_file = "$var_dir/reck.lock";
1304         my $socket_file = "$var_dir/ctdb.socket";
1305         my $log_file = "$var_dir/log.ctdb";
1306
1307         my $db_dir = "$var_dir/ctdb";
1308         push @dirs, $db_dir;
1309
1310         my $db_dir_persistent = "$db_dir/persistent";
1311         push @dirs, $db_dir_persistent;
1312
1313         my $db_dir_state = "$db_dir/state";
1314         push @dirs, $db_dir_state;
1315
1316         my $ctdb_dir = "$prefix_abs/etc/ctdb";
1317         push @dirs, $ctdb_dir;
1318
1319         my $nodes_file = "$ctdb_dir/nodes";
1320         my $public_addresses_file = "$ctdb_dir/public_addresses";
1321
1322         my $event_script_dir = "$ctdb_dir/events.d";
1323         push @dirs, $event_script_dir;
1324
1325         #
1326         # check / create directories:
1327         #
1328         die ("prefix_abs = ''") if $prefix_abs eq "";
1329         die ("prefix_abs = '/'") if $prefix_abs eq "/";
1330
1331         mkdir ($prefix_abs, 0777);
1332         print "CREATE CTDB TEST ENVIRONMENT in '$prefix_abs'...";
1333
1334         if (not defined($no_delete_prefix) or not $no_delete_prefix) {
1335                 system("rm -rf $prefix_abs/*");
1336         }
1337
1338         mkdir($_, 0777) foreach(@dirs);
1339
1340         # - setup nodes
1341         unless (open(NODES, ">$nodes_file")) {
1342                 warn("Unable to open nodesfile '$nodes_file'");
1343                 return undef;
1344         }
1345         print NODES "$internal_ip";
1346         close(NODES);
1347
1348         # - setup public-addresses
1349         unless(open(PUBLIC_ADDR, ">$public_addresses_file")) {
1350                 warn("Unable to open public addresses file '$public_addresses_file'");
1351                 return undef;
1352         }
1353         print PUBLIC_ADDR "$public_addresses_file/128 lo";
1354         close(PUBLIC_ADDR);
1355
1356
1357         $ret{CTDBD_TEST_LOG} = "$prefix/ctdbd_test.log";
1358         $ret{CTDBD_TEST_LOG_POS} = 0;
1359
1360         $ret{NODES_FILE} = $nodes_file;
1361         $ret{PUBLIC_ADDRESSES_FILE} = $public_addresses_file;
1362         $ret{RECLOCK_FILE} = $reclock_file;
1363         $ret{SOCKET_FILE} = $socket_file;
1364         $ret{DB_DIR} = $db_dir;
1365         $ret{DB_DIR_PERSISTENT} = $db_dir_persistent;
1366         $ret{DB_DIR_STATE} = $db_dir_state;
1367         $ret{LOG_FILE} = $log_file;
1368         $ret{EVENT_SCRIPT_DIR} = $event_script_dir;
1369         $ret{PUBLIC_INTERFACE} = "lo";
1370         $ret{DEBUG_LEVEL} = 0;
1371
1372         $ret{BINDIR} = $bindir;
1373
1374         return \%ret;
1375 }
1376
1377 sub wait_for_start_ctdb($$)
1378 {
1379         my ($self, $envvars) = @_;
1380
1381         print "wait for ctdbd\n";
1382
1383         sleep(5);
1384
1385         # TODO
1386
1387         # - run ctdb status...
1388
1389         print $self->getlog_env_ctdb($envvars);
1390
1391         return 1;
1392 }
1393
1394 1;