1proc start_bg_complex_data {host port db ops} {
2    set tclsh [info nameofexecutable]
3    exec $tclsh tests/helpers/bg_complex_data.tcl $host $port $db $ops &
4}
5
6proc stop_bg_complex_data {handle} {
7    catch {exec /bin/kill -9 $handle}
8}
9
10start_server {tags {"repl"}} {
11    start_server {} {
12
13        set master [srv -1 client]
14        set master_host [srv -1 host]
15        set master_port [srv -1 port]
16        set slave [srv 0 client]
17
18        set load_handle0 [start_bg_complex_data $master_host $master_port 9 100000]
19        set load_handle1 [start_bg_complex_data $master_host $master_port 11 100000]
20        set load_handle2 [start_bg_complex_data $master_host $master_port 12 100000]
21
22        test {First server should have role slave after SLAVEOF} {
23            $slave slaveof $master_host $master_port
24            after 1000
25            s 0 role
26        } {slave}
27
28        test {Test replication with parallel clients writing in differnet DBs} {
29            after 5000
30            stop_bg_complex_data $load_handle0
31            stop_bg_complex_data $load_handle1
32            stop_bg_complex_data $load_handle2
33            set retry 10
34            while {$retry && ([$master debug digest] ne [$slave debug digest])}\
35            {
36                after 1000
37                incr retry -1
38            }
39            assert {[$master dbsize] > 0}
40
41            if {[$master debug digest] ne [$slave debug digest]} {
42                set csv1 [csvdump r]
43                set csv2 [csvdump {r -1}]
44                set fd [open /tmp/repldump1.txt w]
45                puts -nonewline $fd $csv1
46                close $fd
47                set fd [open /tmp/repldump2.txt w]
48                puts -nonewline $fd $csv2
49                close $fd
50                puts "Master - Slave inconsistency"
51                puts "Run diff -u against /tmp/repldump*.txt for more info"
52            }
53            assert_equal [r debug digest] [r -1 debug digest]
54        }
55    }
56}
57