summaryrefslogtreecommitdiff
path: root/jstests/repl/repl11.js
blob: aef9872f7d02a675a431fcf16b9d7cb15a29ba22 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
// Test repl with auth enabled

var baseName = "jstests_repl11test";

setAdmin = function( n ) {
    n.getDB( "admin" ).addUser( "super", "super" );
    n.getDB( "local" ).addUser( "repl", "foo" );
    n.getDB( "local" ).system.users.findOne();
}

auth = function( n ) {
    return n.getDB( baseName ).auth( "test", "test" );
}

doTest = function( signal ) {

    rt = new ReplTest( baseName );
    
    m = rt.start( true, {}, false, true );
    m.getDB( baseName ).addUser( "test", "test" );
    setAdmin( m );
    rt.stop( true );
    
    s = rt.start( false, {}, false, true );
    setAdmin( s );
    rt.stop( false );
    
    m = rt.start( true, { auth:null }, true );
    auth( m );
    s = rt.start( false, { auth:null }, true );
    assert.soon( function() { return auth( s ); } );
    
    ma = m.getDB( baseName ).a;    
    ma.save( {} );
    sa = s.getDB( baseName ).a;
    assert.soon( function() { return 1 == sa.count(); } );
    
    s.getDB( "local" ).auth( "repl", "foo" );
    assert.commandWorked( s.getDB( "admin" )._adminCommand( {serverStatus:1,repl:1} ) );
    assert.commandWorked( s.getDB( "admin" )._adminCommand( {serverStatus:1,repl:2} ) );
    
    rt.stop( false, signal );
    
    ma.save( {} );
    s = rt.start( false, { auth:null }, true );
    assert.soon( function() { return auth( s ); } );
    sa = s.getDB( baseName ).a;
    assert.soon( function() { return 2 == sa.count(); } );
    
    ma.save( {a:1} );
    assert.soon( function() { return 1 == sa.count( {a:1} ); } );
    
    ma.update( {a:1}, {b:2} );
    assert.soon( function() { return 1 == sa.count( {b:2} ); } );
    
    ma.remove( {b:2} );
    assert.soon( function() { return 0 == sa.count( {b:2} ); } );
    
    rt.stop();
}

doTest( 15 ); // SIGTERM
doTest( 9 );  // SIGKILL