Created
April 29, 2014 22:04
-
-
Save benbjohnson/e0fe56aed92c63b03d95 to your computer and use it in GitHub Desktop.
hashicorp/raft: race detection
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
$ go test -v -race | |
=== RUN TestFileSnapshotStoreImpl | |
--- PASS: TestFileSnapshotStoreImpl (0.00 seconds) | |
=== RUN TestFileSnapshotSinkImpl | |
--- PASS: TestFileSnapshotSinkImpl (0.00 seconds) | |
=== RUN TestFileSS_CreateSnapshot | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft166453656/snapshots/3-10-2014-04-29T16:03:28.194235901-06:00.tmp | |
2014/04/29 16:03:28 [WARN] snapshot: Found temporary snapshot: 3-10-2014-04-29T16:03:28.194235901-06:00.tmp | |
--- PASS: TestFileSS_CreateSnapshot (0.00 seconds) | |
=== RUN TestFileSS_CancelSnapshot | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft614393879/snapshots/3-10-2014-04-29T16:03:28.197887586-06:00.tmp | |
--- PASS: TestFileSS_CancelSnapshot (0.00 seconds) | |
=== RUN TestFileSS_Retention | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-10-2014-04-29T16:03:28.199131737-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-11-2014-04-29T16:03:28.200176006-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-12-2014-04-29T16:03:28.201376038-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: reaping snapshot /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-10-2014-04-29T16:03:28.199131737-06:00 | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-13-2014-04-29T16:03:28.203346163-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: reaping snapshot /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-11-2014-04-29T16:03:28.200176006-06:00 | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-14-2014-04-29T16:03:28.204967537-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: reaping snapshot /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft991497354/snapshots/3-12-2014-04-29T16:03:28.201376038-06:00 | |
--- PASS: TestFileSS_Retention (0.01 seconds) | |
=== RUN TestFileSS_BadPerm | |
--- PASS: TestFileSS_BadPerm (0.00 seconds) | |
=== RUN TestFileSS_Names | |
--- PASS: TestFileSS_Names (0.00 seconds) | |
=== RUN TestFileSS_Ordering | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft107346529/snapshots/5-130350-2014-04-29T16:03:28.208340748-06:00.tmp | |
2014/04/29 16:03:28 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft107346529/snapshots/36-204917-2014-04-29T16:03:28.209223391-06:00.tmp | |
--- PASS: TestFileSS_Ordering (0.00 seconds) | |
=== RUN TestInflight_StartCommit | |
--- PASS: TestInflight_StartCommit (0.00 seconds) | |
=== RUN TestInflight_Cancel | |
--- PASS: TestInflight_Cancel (0.00 seconds) | |
=== RUN TestInflight_CommitRange | |
--- PASS: TestInflight_CommitRange (0.00 seconds) | |
=== RUN TestInflight_NonContiguous | |
--- PASS: TestInflight_NonContiguous (0.00 seconds) | |
=== RUN TestInmemAddrImpl | |
--- PASS: TestInmemAddrImpl (0.00 seconds) | |
=== RUN TestInmemAddr | |
--- PASS: TestInmemAddr (0.00 seconds) | |
=== RUN TestInmemTransportImpl | |
--- PASS: TestInmemTransportImpl (0.00 seconds) | |
=== RUN TestRaft_Integ | |
--- SKIP: TestRaft_Integ (0.00 seconds) | |
=== RUN TestNetworkTransport_StartStop | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 22: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 21: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_StartStop() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:16 +0x18c | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 22 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_StartStop() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:12 +0x76 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 21 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_StartStop (0.00 seconds) | |
=== RUN TestNetworkTransport_AppendEntries | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57714 accepted connection from: 127.0.0.1:57716 | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 26: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 23: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_AppendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:82 +0xc33 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 26 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_AppendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:67 +0x6db | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 23 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_AppendEntries (0.00 seconds) | |
=== RUN TestNetworkTransport_RequestVote | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57717 accepted connection from: 127.0.0.1:57719 | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 32: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 29: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_RequestVote() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:139 +0xb93 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 32 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_RequestVote() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:124 +0x62e | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 29 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_RequestVote (0.00 seconds) | |
=== RUN TestNetworkTransport_InstallSnapshot | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57720 accepted connection from: 127.0.0.1:57722 | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 38: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 35: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_InstallSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:209 +0xde7 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 38 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_InstallSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:191 +0x664 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 35 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_InstallSnapshot (0.00 seconds) | |
=== RUN TestNetworkTransport_EncodeDecode | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 41: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 40: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_EncodeDecode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:226 +0x2a9 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 41 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_EncodeDecode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:213 +0x76 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 40 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_EncodeDecode (0.00 seconds) | |
=== RUN TestNetworkTransport_PooledConn | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57724 accepted connection from: 127.0.0.1:57726 | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57724 accepted connection from: 127.0.0.1:57727 | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57724 accepted connection from: 127.0.0.1:57728 | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57724 accepted connection from: 127.0.0.1:57729 | |
2014/04/29 16:03:28 [DEBUG] raft-net: 127.0.0.1:57724 accepted connection from: 127.0.0.1:57730 | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 45: | |
github.com/benbjohnson/raft.(*NetworkTransport).listen() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:277 +0xaa | |
Previous write by goroutine 42: | |
github.com/benbjohnson/raft.(*NetworkTransport).Close() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:118 +0x106 | |
github.com/benbjohnson/raft.TestNetworkTransport_PooledConn() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:313 +0xbff | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 45 (running) created at: | |
github.com/benbjohnson/raft.NewNetworkTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport.go:106 +0x2e2 | |
github.com/benbjohnson/raft.NewTCPTransport() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/tcp_transport.go:44 +0x2c0 | |
github.com/benbjohnson/raft.TestNetworkTransport_PooledConn() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/net_transport_test.go:277 +0x74b | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 42 (finished) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
--- PASS: TestNetworkTransport_PooledConn (0.00 seconds) | |
=== RUN TestJSONPeers | |
--- PASS: TestJSONPeers (0.00 seconds) | |
=== RUN TestRaft_StartStop | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
--- PASS: TestRaft_StartStop (0.01 seconds) | |
=== RUN TestRaft_AfterShutdown | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
--- PASS: TestRaft_AfterShutdown (0.01 seconds) | |
=== RUN TestRaft_SingleNode | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 90a72a7a-630c-3976-95f4-7605e776f2a6 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 90a72a7a-630c-3976-95f4-7605e776f2a6 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Node at 90a72a7a-630c-3976-95f4-7605e776f2a6 [Leader] entering Leader state | |
--- PASS: TestRaft_SingleNode (0.02 seconds) | |
=== RUN TestRaft_TripleNode | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 986cdd0b-5841-a3f7-0014-2a4709b0c438 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 6ed23dd1-cbf6-6791-6bab-e03b559cb9d7 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 062d42cf-8960-ff18-7e13-b3ea70af6187 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 062d42cf-8960-ff18-7e13-b3ea70af6187 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 062d42cf-8960-ff18-7e13-b3ea70af6187 [Leader] entering Leader state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 69: | |
github.com/benbjohnson/raft.(*cluster).EnsureLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:164 +0x113 | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:386 +0xdf | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 70: | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1062 +0x3ee | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 69 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 70 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:381 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 69: | |
github.com/benbjohnson/raft.(*InmemAddr).String() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:27 +0x35 | |
github.com/benbjohnson/raft.(*cluster).EnsureLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:174 +0x2eb | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:386 +0xdf | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 70: | |
github.com/benbjohnson/raft.(*InmemTransport).DecodePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:134 +0x47 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1062 +0x3ba | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 69 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 70 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:381 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 82: | |
github.com/benbjohnson/raft.(*Raft).replicateTo() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:158 +0x11cb | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:70 +0x42b | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous write by goroutine 84: | |
github.com/benbjohnson/raft.(*Raft).heartbeat() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:311 +0x55b | |
github.com/benbjohnson/raft.func·006() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x91 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 82 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).startReplication() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x430 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:661 +0x479 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 84 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x188 | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 69: | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:399 +0x370 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 71: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 69 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 71 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_TripleNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:381 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_TripleNode (0.03 seconds) | |
=== RUN TestRaft_LeaderFail | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Leader] entering Leader state | |
2014/04/29 16:03:28 [INFO] Disconnecting Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Leader] | |
2014/04/29 16:03:28 [WARN] Disconnecting 17430b0b-6111-a2ec-a578-34b9fdbefc0d | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9: Failed to connect to peer: 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9: Failed to connect to peer: 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912: Failed to connect to peer: 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912: Failed to connect to peer: 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9: Failed to connect to peer: 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912: Failed to connect to peer: 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9: Failed to connect to peer: 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912: Failed to connect to peer: 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 | |
2014/04/29 16:03:28 [ERR] raft: Failed to make RequestVote RPC to 17430b0b-6111-a2ec-a578-34b9fdbefc0d: Failed to connect to peer: 17430b0b-6111-a2ec-a578-34b9fdbefc0d | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 [Leader] entering Leader state | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to 17430b0b-6111-a2ec-a578-34b9fdbefc0d: Failed to connect to peer: 17430b0b-6111-a2ec-a578-34b9fdbefc0d | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to 17430b0b-6111-a2ec-a578-34b9fdbefc0d: Failed to connect to peer: 17430b0b-6111-a2ec-a578-34b9fdbefc0d | |
2014/04/29 16:03:28 [INFO] Reconnecting Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Leader] | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [ERR] raft: peer 7e4c8936-42e8-a1c2-089e-06cc8e65dbb9 has newer term, stopping replication | |
2014/04/29 16:03:28 [ERR] raft: peer 4c3b38ae-7136-a4bb-60e7-9b44fc0bc912 has newer term, stopping replication | |
2014/04/29 16:03:28 [WARN] raft: Clearing log suffix from 3 to 3 | |
2014/04/29 16:03:28 [INFO] raft: Node at 17430b0b-6111-a2ec-a578-34b9fdbefc0d [Follower] entering Follower state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 4: | |
github.com/benbjohnson/raft.TestRaft_LeaderFail() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:475 +0xc5c | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 6: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 4 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 6 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_LeaderFail() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:407 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 4: | |
github.com/benbjohnson/raft.TestRaft_LeaderFail() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:481 +0x105e | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 6: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 4 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 6 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_LeaderFail() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:407 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_LeaderFail (0.07 seconds) | |
=== RUN TestRaft_BehindFollower | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 22972c68-0250-da53-37f5-1ddc9237fde2 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at a1f43684-bd37-e22c-515c-875f3cc63d07 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 10e58e6d-37aa-4fce-95c4-f58f4212c128 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 22972c68-0250-da53-37f5-1ddc9237fde2 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 22972c68-0250-da53-37f5-1ddc9237fde2 [Leader] entering Leader state | |
2014/04/29 16:03:28 [WARN] Disconnecting a1f43684-bd37-e22c-515c-875f3cc63d07 | |
2014/04/29 16:03:28 [ERR] raft: Failed to AppendEntries to a1f43684-bd37-e22c-515c-875f3cc63d07: Failed to connect to peer: a1f43684-bd37-e22c-515c-875f3cc63d07 | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to a1f43684-bd37-e22c-515c-875f3cc63d07: Failed to connect to peer: a1f43684-bd37-e22c-515c-875f3cc63d07 | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 36: | |
github.com/benbjohnson/raft.(*Raft).replicateTo() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:158 +0x11cb | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:68 +0x328 | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous write by goroutine 41: | |
github.com/benbjohnson/raft.(*Raft).heartbeat() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:311 +0x55b | |
github.com/benbjohnson/raft.func·006() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x91 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 36 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).startReplication() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x430 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:661 +0x479 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 41 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x188 | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
================== | |
2014/04/29 16:03:28 [INFO] Finished apply without behind follower | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 28: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous read by goroutine 22: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x1a1 | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:520 +0x45b | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 28 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:489 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 22 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 22: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3e6 | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:520 +0x45b | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 28: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 22 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 28 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:489 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 22: | |
github.com/benbjohnson/raft.(*InmemAddr).String() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:27 +0x35 | |
github.com/benbjohnson/raft.(*cluster).EnsureLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:174 +0x2eb | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:524 +0x4bd | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 24: | |
github.com/benbjohnson/raft.(*InmemTransport).DecodePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:134 +0x47 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1062 +0x3ba | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 22 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 24 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_BehindFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:489 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:28 [ERR] raft: Failed to heartbeat to a1f43684-bd37-e22c-515c-875f3cc63d07: command timed out | |
--- PASS: TestRaft_BehindFollower (0.10 seconds) | |
=== RUN TestRaft_ApplyNonLeader | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 2527c501-ba53-0262-00c9-e37861b1585c [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at a3b73532-1806-40dd-cc80-f8333f353947 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at acf7f4f7-f6cc-4055-8389-389c2e5cceb6 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at acf7f4f7-f6cc-4055-8389-389c2e5cceb6 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at acf7f4f7-f6cc-4055-8389-389c2e5cceb6 [Leader] entering Leader state | |
--- PASS: TestRaft_ApplyNonLeader (0.03 seconds) | |
=== RUN TestRaft_ApplyConcurrent | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 1068b880-07ad-dcbb-26d5-efb77758bfb1 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 7998bdd3-849a-0f2d-90f5-430396fba624 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 12583754-04b2-f5fd-543e-bd4142527c27 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 12583754-04b2-f5fd-543e-bd4142527c27 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 12583754-04b2-f5fd-543e-bd4142527c27 [Leader] entering Leader state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 62: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x193 | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:597 +0x369 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 64: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 62 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 64 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:561 +0xc3 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 62: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x1a1 | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:597 +0x369 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 66: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 62 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 66 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:561 +0xc3 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 62: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3a7 | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:597 +0x369 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 64: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 62 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 64 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:561 +0xc3 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 62: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3e6 | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:597 +0x369 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 66: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 62 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 66 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:561 +0xc3 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_ApplyConcurrent (0.18 seconds) | |
=== RUN TestRaft_ApplyConcurrent_Timeout | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at e4c9d7ce-8616-948d-6f05-2d9cd2fdce84 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at e4c9d7ce-8616-948d-6f05-2d9cd2fdce84 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Node at e4c9d7ce-8616-948d-6f05-2d9cd2fdce84 [Leader] entering Leader state | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 14: | |
github.com/benbjohnson/raft.func·018() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:617 +0x20b | |
Previous write by goroutine 69: | |
github.com/benbjohnson/raft.func·018() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:617 +0x20b | |
Goroutine 14 (running) created at: | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent_Timeout() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:619 +0x1a2 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 69 (finished) created at: | |
github.com/benbjohnson/raft.TestRaft_ApplyConcurrent_Timeout() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:619 +0x1a2 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_ApplyConcurrent_Timeout (0.22 seconds) | |
=== RUN TestRaft_JoinNode | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 9598edb6-2caf-d436-233a-c8a69e29e2e8 [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 6cf9867a-44d2-b7ae-850a-490b7bee94b4 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 9598edb6-2caf-d436-233a-c8a69e29e2e8 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 9598edb6-2caf-d436-233a-c8a69e29e2e8 [Leader] entering Leader state | |
2014/04/29 16:03:28 [INFO] Applied log | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 2fe60d00-a6e8-0987-ad2e-964168c0eea3 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 2fe60d00-a6e8-0987-ad2e-964168c0eea3 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:28 [INFO] raft: Node at 2fe60d00-a6e8-0987-ad2e-964168c0eea3 [Leader] entering Leader state | |
2014/04/29 16:03:28 [DEBUG] raft: Node 9598edb6-2caf-d436-233a-c8a69e29e2e8 updated peer set (add): [2fe60d00-a6e8-0987-ad2e-964168c0eea3 9598edb6-2caf-d436-233a-c8a69e29e2e8 6cf9867a-44d2-b7ae-850a-490b7bee94b4] | |
2014/04/29 16:03:28 [INFO] raft: Added peer 2fe60d00-a6e8-0987-ad2e-964168c0eea3, starting replication | |
2014/04/29 16:03:28 [WARN] raft: Failed to get previous log: 3 log not found (last: 1) | |
2014/04/29 16:03:28 [INFO] raft: Node at 2fe60d00-a6e8-0987-ad2e-964168c0eea3 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: AppendEntries to 2fe60d00-a6e8-0987-ad2e-964168c0eea3 rejected, sending older logs (next: 2) | |
2014/04/29 16:03:28 [DEBUG] raft: Node 9598edb6-2caf-d436-233a-c8a69e29e2e8 updated peer set (add): [2fe60d00-a6e8-0987-ad2e-964168c0eea3 9598edb6-2caf-d436-233a-c8a69e29e2e8 6cf9867a-44d2-b7ae-850a-490b7bee94b4] | |
2014/04/29 16:03:28 [DEBUG] raft: Node 6cf9867a-44d2-b7ae-850a-490b7bee94b4 updated peer set (add): [2fe60d00-a6e8-0987-ad2e-964168c0eea3 9598edb6-2caf-d436-233a-c8a69e29e2e8 6cf9867a-44d2-b7ae-850a-490b7bee94b4] | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x1a1 | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:682 +0x982 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 140: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 140 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3e6 | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:682 +0x982 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 140: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 140 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:28 [DEBUG] raft: Node 2fe60d00-a6e8-0987-ad2e-964168c0eea3 updated peer set (add): [2fe60d00-a6e8-0987-ad2e-964168c0eea3 9598edb6-2caf-d436-233a-c8a69e29e2e8 6cf9867a-44d2-b7ae-850a-490b7bee94b4] | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.raftToPeerSet() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:229 +0xd2 | |
github.com/benbjohnson/raft.(*cluster).EnsureSamePeers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:245 +0x1b0 | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:685 +0x99d | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 139: | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:952 +0x6a2 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1119 +0xd95 | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 139 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.raftToPeerSet() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:229 +0x11a | |
github.com/benbjohnson/raft.(*cluster).EnsureSamePeers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:245 +0x1b0 | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:685 +0x99d | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 139: | |
github.com/benbjohnson/raft.ExcludePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/util.go:85 +0x27b | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:952 +0x70a | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1119 +0xd95 | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 139 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.(*InmemAddr).String() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:27 +0x35 | |
github.com/benbjohnson/raft.raftToPeerSet() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:230 +0x138 | |
github.com/benbjohnson/raft.(*cluster).EnsureSamePeers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:245 +0x1b0 | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:685 +0x99d | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 139: | |
github.com/benbjohnson/raft.(*InmemTransport).DecodePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:134 +0x47 | |
github.com/benbjohnson/raft.decodePeers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/util.go:139 +0x272 | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:948 +0x4d4 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1119 +0xd95 | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 139 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 135: | |
github.com/benbjohnson/raft.(*InmemAddr).String() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:27 +0x35 | |
github.com/benbjohnson/raft.(*cluster).EnsureLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:174 +0x2eb | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:689 +0x9ff | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 139: | |
github.com/benbjohnson/raft.(*InmemTransport).DecodePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_transport.go:134 +0x47 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1062 +0x3ba | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 135 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 139 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_JoinNode() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:633 +0x57 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_JoinNode (0.08 seconds) | |
=== RUN TestRaft_RemoveFollower | |
2014/04/29 16:03:28 [WARN] Fully Connecting | |
2014/04/29 16:03:28 [INFO] raft: Node at 5cb71f1b-06b9-012e-7f04-72bf7c2e562e [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 21c7b566-cea7-fc67-c605-0ece48684d7b [Follower] entering Follower state | |
2014/04/29 16:03:28 [INFO] raft: Node at 961de145-a6d8-84ef-b209-139c5e6d4773 [Follower] entering Follower state | |
2014/04/29 16:03:28 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:28 [INFO] raft: Node at 961de145-a6d8-84ef-b209-139c5e6d4773 [Candidate] entering Candidate state | |
2014/04/29 16:03:28 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:28 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:28 [INFO] raft: Node at 961de145-a6d8-84ef-b209-139c5e6d4773 [Leader] entering Leader state | |
2014/04/29 16:03:28 [DEBUG] raft: Node 961de145-a6d8-84ef-b209-139c5e6d4773 updated peer set (remove): [961de145-a6d8-84ef-b209-139c5e6d4773 21c7b566-cea7-fc67-c605-0ece48684d7b] | |
2014/04/29 16:03:28 [INFO] raft: Removed peer 5cb71f1b-06b9-012e-7f04-72bf7c2e562e, stopping replication | |
2014/04/29 16:03:28 [DEBUG] raft: Node 961de145-a6d8-84ef-b209-139c5e6d4773 updated peer set (remove): [961de145-a6d8-84ef-b209-139c5e6d4773 21c7b566-cea7-fc67-c605-0ece48684d7b] | |
2014/04/29 16:03:28 [DEBUG] raft: Node 21c7b566-cea7-fc67-c605-0ece48684d7b updated peer set (remove): [961de145-a6d8-84ef-b209-139c5e6d4773 21c7b566-cea7-fc67-c605-0ece48684d7b] | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 5cb71f1b-06b9-012e-7f04-72bf7c2e562e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at 961de145-a6d8-84ef-b209-139c5e6d4773 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Remote peer 21c7b566-cea7-fc67-c605-0ece48684d7b does not have local node 5cb71f1b-06b9-012e-7f04-72bf7c2e562e as a peer | |
2014/04/29 16:03:29 [WARN] raft: Remote peer 961de145-a6d8-84ef-b209-139c5e6d4773 does not have local node 5cb71f1b-06b9-012e-7f04-72bf7c2e562e as a peer | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 5cb71f1b-06b9-012e-7f04-72bf7c2e562e [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node 5cb71f1b-06b9-012e-7f04-72bf7c2e562e updated peer set (remove): [961de145-a6d8-84ef-b209-139c5e6d4773 21c7b566-cea7-fc67-c605-0ece48684d7b] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 21c7b566-cea7-fc67-c605-0ece48684d7b, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 961de145-a6d8-84ef-b209-139c5e6d4773, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed ourself, shutting down | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 150: | |
github.com/benbjohnson/raft.TestRaft_RemoveFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:725 +0x513 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 154: | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:975 +0x1540 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1119 +0xd95 | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 150 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 154 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_RemoveFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:694 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_RemoveFollower (0.05 seconds) | |
=== RUN TestRaft_RemoveLeader | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 16e96470-8b63-7e31-2ddf-904af2af5031 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at d8c045bf-2fe8-fe0a-735a-12310d94d92e [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 1f806495-6977-4715-52d3-870b68855694 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 16e96470-8b63-7e31-2ddf-904af2af5031 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 16e96470-8b63-7e31-2ddf-904af2af5031 [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node 16e96470-8b63-7e31-2ddf-904af2af5031 updated peer set (remove): [d8c045bf-2fe8-fe0a-735a-12310d94d92e 1f806495-6977-4715-52d3-870b68855694] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer d8c045bf-2fe8-fe0a-735a-12310d94d92e, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 1f806495-6977-4715-52d3-870b68855694, stopping replication | |
2014/04/29 16:03:29 [DEBUG] raft: Node 16e96470-8b63-7e31-2ddf-904af2af5031 updated peer set (remove): [d8c045bf-2fe8-fe0a-735a-12310d94d92e 1f806495-6977-4715-52d3-870b68855694] | |
2014/04/29 16:03:29 [INFO] raft: Removed ourself, shutting down | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at d8c045bf-2fe8-fe0a-735a-12310d94d92e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at d8c045bf-2fe8-fe0a-735a-12310d94d92e [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node d8c045bf-2fe8-fe0a-735a-12310d94d92e updated peer set (remove): [d8c045bf-2fe8-fe0a-735a-12310d94d92e 1f806495-6977-4715-52d3-870b68855694] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 16e96470-8b63-7e31-2ddf-904af2af5031, stopping replication | |
2014/04/29 16:03:29 [DEBUG] raft: Node 1f806495-6977-4715-52d3-870b68855694 updated peer set (remove): [d8c045bf-2fe8-fe0a-735a-12310d94d92e 1f806495-6977-4715-52d3-870b68855694] | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 172: | |
github.com/benbjohnson/raft.TestRaft_RemoveLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:762 +0x334 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 176: | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:975 +0x1540 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).leaderLoop() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:707 +0x344 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:669 +0x517 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 172 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 176 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_RemoveLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:732 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 16e96470-8b63-7e31-2ddf-904af2af5031: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 16e96470-8b63-7e31-2ddf-904af2af5031: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 16e96470-8b63-7e31-2ddf-904af2af5031: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 16e96470-8b63-7e31-2ddf-904af2af5031: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 16e96470-8b63-7e31-2ddf-904af2af5031: command timed out | |
--- PASS: TestRaft_RemoveLeader (0.16 seconds) | |
=== RUN TestRaft_RemoveLeader_SplitCluster | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 384f4d97-73d8-6e64-dd8e-2745333698bb [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at aff757ec-6eab-315e-3df7-35656fc2fd81 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node bdfc583f-cf9b-6066-a311-e1f80c609c64 updated peer set (remove): [384f4d97-73d8-6e64-dd8e-2745333698bb aff757ec-6eab-315e-3df7-35656fc2fd81] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 384f4d97-73d8-6e64-dd8e-2745333698bb, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed peer aff757ec-6eab-315e-3df7-35656fc2fd81, stopping replication | |
2014/04/29 16:03:29 [DEBUG] raft: Node bdfc583f-cf9b-6066-a311-e1f80c609c64 updated peer set (remove): [384f4d97-73d8-6e64-dd8e-2745333698bb aff757ec-6eab-315e-3df7-35656fc2fd81] | |
2014/04/29 16:03:29 [INFO] raft: Removed ourself, transitioning to follower | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Leader] entering Leader state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at aff757ec-6eab-315e-3df7-35656fc2fd81 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Duplicate RequestVote for same term: 2 | |
2014/04/29 16:03:29 [WARN] raft: Remote peer bdfc583f-cf9b-6066-a311-e1f80c609c64 does not have local node aff757ec-6eab-315e-3df7-35656fc2fd81 as a peer | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at aff757ec-6eab-315e-3df7-35656fc2fd81 [Leader] entering Leader state | |
2014/04/29 16:03:29 [WARN] raft: Clearing log suffix from 3 to 3 | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Follower] entering Follower state | |
2014/04/29 16:03:29 [DEBUG] raft: Node aff757ec-6eab-315e-3df7-35656fc2fd81 updated peer set (remove): [384f4d97-73d8-6e64-dd8e-2745333698bb aff757ec-6eab-315e-3df7-35656fc2fd81] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer bdfc583f-cf9b-6066-a311-e1f80c609c64, stopping replication | |
2014/04/29 16:03:29 [DEBUG] raft: Node 384f4d97-73d8-6e64-dd8e-2745333698bb updated peer set (remove): [384f4d97-73d8-6e64-dd8e-2745333698bb aff757ec-6eab-315e-3df7-35656fc2fd81] | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at bdfc583f-cf9b-6066-a311-e1f80c609c64 [Leader] entering Leader state | |
--- PASS: TestRaft_RemoveLeader_SplitCluster (0.06 seconds) | |
=== RUN TestRaft_AddKnownPeer | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at b1f0b4cb-c619-7024-ea79-470af08c0d41 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 47b18433-41ed-b65a-eeb8-51cd7e49786c [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at b412e497-d11f-48d7-5ce4-50f602a49c8c [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at b412e497-d11f-48d7-5ce4-50f602a49c8c [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at b412e497-d11f-48d7-5ce4-50f602a49c8c [Leader] entering Leader state | |
--- PASS: TestRaft_AddKnownPeer (0.02 seconds) | |
=== RUN TestRaft_RemoveUnknownPeer | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 42ffa9fd-bb8a-4c84-1b4f-50f44c2d7da6 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 1dba7870-1e87-eead-4f4e-c262fdb2177d [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 8065ce86-a3d4-6d67-6b36-d102436f41b3 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 1dba7870-1e87-eead-4f4e-c262fdb2177d [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 1dba7870-1e87-eead-4f4e-c262fdb2177d [Leader] entering Leader state | |
--- PASS: TestRaft_RemoveUnknownPeer (0.02 seconds) | |
=== RUN TestRaft_SnapshotRestore | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 357e5000-6129-7bd4-0134-beecc59664e4 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 357e5000-6129-7bd4-0134-beecc59664e4 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at 357e5000-6129-7bd4-0134-beecc59664e4 [Leader] entering Leader state | |
2014/04/29 16:03:29 [INFO] raft: Starting snapshot up to 101 | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft767593768/snapshots/1-101-2014-04-29T16:03:29.30552547-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 1 to 91 | |
2014/04/29 16:03:29 [INFO] raft: Snapshot to 101 complete | |
2014/04/29 16:03:29 [INFO] raft: Restored from snapshot 1-101-2014-04-29T16:03:29.30552547-06:00 | |
--- PASS: TestRaft_SnapshotRestore (0.04 seconds) | |
=== RUN TestRaft_AutoSnapshot | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 20886764-90aa-89fa-d687-5da38fe9c5c7 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 20886764-90aa-89fa-d687-5da38fe9c5c7 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at 20886764-90aa-89fa-d687-5da38fe9c5c7 [Leader] entering Leader state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 74: | |
github.com/benbjohnson/raft.(*InmemStore).LastIndex() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_store.go:35 +0x3a | |
github.com/benbjohnson/raft.(*Raft).shouldSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1425 +0x8b | |
github.com/benbjohnson/raft.(*Raft).runSnapshots() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1395 +0xd1 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runSnapshots)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:204 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous write by goroutine 70: | |
github.com/benbjohnson/raft.(*InmemStore).StoreLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_store.go:62 +0x1c3 | |
github.com/benbjohnson/raft.(*InmemStore).StoreLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/inmem_store.go:50 +0xa4 | |
github.com/benbjohnson/raft.(*Raft).dispatchLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:870 +0x2e0 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:666 +0x506 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 74 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:204 +0xe63 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_AutoSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:907 +0xaf | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 70 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_AutoSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:907 +0xaf | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:29 [INFO] raft: Starting snapshot up to 57 | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft054581402/snapshots/1-57-2014-04-29T16:03:29.338303383-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 1 to 49 | |
2014/04/29 16:03:29 [INFO] raft: Snapshot to 57 complete | |
--- PASS: TestRaft_AutoSnapshot (0.08 seconds) | |
=== RUN TestRaft_SendSnapshotFollower | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [WARN] Disconnecting 05bd295a-6927-0ecf-7f71-49625d650f50 | |
2014/04/29 16:03:29 [INFO] raft: Node at 05bd295a-6927-0ecf-7f71-49625d650f50 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at ebc6f769-107a-d29a-9996-500b09acf8e8 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 97bc070c-8088-d7f7-1364-d99a75afab6e [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at ebc6f769-107a-d29a-9996-500b09acf8e8 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 05bd295a-6927-0ecf-7f71-49625d650f50: Failed to connect to peer: 05bd295a-6927-0ecf-7f71-49625d650f50 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at ebc6f769-107a-d29a-9996-500b09acf8e8 [Leader] entering Leader state | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 05bd295a-6927-0ecf-7f71-49625d650f50: Failed to connect to peer: 05bd295a-6927-0ecf-7f71-49625d650f50 | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 05bd295a-6927-0ecf-7f71-49625d650f50: Failed to connect to peer: 05bd295a-6927-0ecf-7f71-49625d650f50 | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 05bd295a-6927-0ecf-7f71-49625d650f50 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to ebc6f769-107a-d29a-9996-500b09acf8e8: Failed to connect to peer: ebc6f769-107a-d29a-9996-500b09acf8e8 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 97bc070c-8088-d7f7-1364-d99a75afab6e: Failed to connect to peer: 97bc070c-8088-d7f7-1364-d99a75afab6e | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 05bd295a-6927-0ecf-7f71-49625d650f50: Failed to connect to peer: 05bd295a-6927-0ecf-7f71-49625d650f50 | |
2014/04/29 16:03:29 [INFO] Finished apply without behind follower | |
2014/04/29 16:03:29 [INFO] raft: Starting snapshot up to 0 | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft177891548/snapshots/0-0-2014-04-29T16:03:29.425225495-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 0 to 0 | |
2014/04/29 16:03:29 [INFO] raft: Snapshot to 0 complete | |
2014/04/29 16:03:29 [INFO] raft: Starting snapshot up to 101 | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft731920494/snapshots/1-101-2014-04-29T16:03:29.427763228-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 1 to 91 | |
2014/04/29 16:03:29 [INFO] raft: Snapshot to 101 complete | |
2014/04/29 16:03:29 [INFO] raft: Starting snapshot up to 98 | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft905684432/snapshots/1-98-2014-04-29T16:03:29.42973687-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 1 to 91 | |
2014/04/29 16:03:29 [INFO] raft: Snapshot to 98 complete | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 05bd295a-6927-0ecf-7f71-49625d650f50 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] snapshot: Creating new snapshot at /var/folders/p3/nqt2bgp17fn7_t9hr6tr_1m00000gn/T/raft177891548/snapshots/1-101-2014-04-29T16:03:29.435607883-06:00.tmp | |
2014/04/29 16:03:29 [INFO] raft: Copied 693 bytes to local snapshot | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 89: | |
github.com/benbjohnson/raft.(*MockFSM).Restore() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:43 +0x163 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:427 +0x405 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous read by goroutine 73: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x193 | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:969 +0x5a9 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 89 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:935 +0x79 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Goroutine 73 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
================== | |
2014/04/29 16:03:29 [INFO] raft: Compacting logs from 1 to 101 | |
2014/04/29 16:03:29 [INFO] raft: Installed remote snapshot | |
================== | |
WARNING: DATA RACE | |
Write by goroutine 101: | |
github.com/benbjohnson/raft.(*Raft).heartbeat() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:311 +0x55b | |
github.com/benbjohnson/raft.func·006() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x91 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Previous write by goroutine 99: | |
github.com/benbjohnson/raft.(*Raft).sendLatestSnapshot() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:260 +0xd7a | |
github.com/benbjohnson/raft.(*Raft).replicateTo() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:191 +0x5a3 | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:68 +0x328 | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 101 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).replicate() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/replication.go:56 +0x188 | |
github.com/benbjohnson/raft.func·003() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x6d | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 99 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.(*Raft).startReplication() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:687 +0x430 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:661 +0x479 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
================== | |
2014/04/29 16:03:29 [WARN] raft: Skipping application of old log: 101 | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 73: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3a7 | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:969 +0x5a9 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 89: | |
reflect.Value.SetBytes() | |
/usr/local/go/src/pkg/reflect/value.go:1409 +0xcd | |
github.com/ugorji/go/codec.(*decFnInfo).kSlice() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:423 +0xb97 | |
github.com/ugorji/go/codec.(*Decoder).decodeValue() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:825 +0x905 | |
github.com/ugorji/go/codec.(*decFnInfo).kSlice() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:472 +0xa34 | |
github.com/ugorji/go/codec.(*Decoder).decodeValue() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:825 +0x905 | |
github.com/ugorji/go/codec.(*Decoder).decode() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:693 +0x3ac | |
github.com/ugorji/go/codec.(*Decoder).Decode() | |
/Users/benbjohnson/go/src/github.com/ugorji/go/codec/decode.go:624 +0x76 | |
github.com/benbjohnson/raft.(*MockFSM).Restore() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:44 +0x199 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:427 +0x405 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 73 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 89 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:935 +0x79 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 73: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3e6 | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:969 +0x5a9 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 95: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 73 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 95 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_SendSnapshotFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:935 +0x79 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 97bc070c-8088-d7f7-1364-d99a75afab6e: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 97bc070c-8088-d7f7-1364-d99a75afab6e: command timed out | |
--- PASS: TestRaft_SendSnapshotFollower (0.12 seconds) | |
=== RUN TestRaft_ReJoinFollower | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at ef69a1c0-f12e-6bed-8dc5-f1528674d220 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at b7abd8b7-b511-6b5f-6f37-289b72cceb0c [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at ef69a1c0-f12e-6bed-8dc5-f1528674d220 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at ef69a1c0-f12e-6bed-8dc5-f1528674d220 [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node ef69a1c0-f12e-6bed-8dc5-f1528674d220 updated peer set (remove): [ef69a1c0-f12e-6bed-8dc5-f1528674d220 30bd734d-5c54-1ec3-0263-d9fc40ef25d4] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer b7abd8b7-b511-6b5f-6f37-289b72cceb0c, stopping replication | |
2014/04/29 16:03:29 [DEBUG] raft: Node ef69a1c0-f12e-6bed-8dc5-f1528674d220 updated peer set (remove): [ef69a1c0-f12e-6bed-8dc5-f1528674d220 30bd734d-5c54-1ec3-0263-d9fc40ef25d4] | |
2014/04/29 16:03:29 [DEBUG] raft: Node 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 updated peer set (remove): [ef69a1c0-f12e-6bed-8dc5-f1528674d220 30bd734d-5c54-1ec3-0263-d9fc40ef25d4] | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at b7abd8b7-b511-6b5f-6f37-289b72cceb0c [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at ef69a1c0-f12e-6bed-8dc5-f1528674d220 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Remote peer ef69a1c0-f12e-6bed-8dc5-f1528674d220 does not have local node b7abd8b7-b511-6b5f-6f37-289b72cceb0c as a peer | |
2014/04/29 16:03:29 [WARN] raft: Remote peer 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 does not have local node b7abd8b7-b511-6b5f-6f37-289b72cceb0c as a peer | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at b7abd8b7-b511-6b5f-6f37-289b72cceb0c [Leader] entering Leader state | |
2014/04/29 16:03:29 [DEBUG] raft: Node b7abd8b7-b511-6b5f-6f37-289b72cceb0c updated peer set (remove): [ef69a1c0-f12e-6bed-8dc5-f1528674d220 30bd734d-5c54-1ec3-0263-d9fc40ef25d4] | |
2014/04/29 16:03:29 [INFO] raft: Removed peer ef69a1c0-f12e-6bed-8dc5-f1528674d220, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed peer 30bd734d-5c54-1ec3-0263-d9fc40ef25d4, stopping replication | |
2014/04/29 16:03:29 [INFO] raft: Removed ourself, transitioning to follower | |
2014/04/29 16:03:29 [INFO] raft: Node at b7abd8b7-b511-6b5f-6f37-289b72cceb0c [Follower] entering Follower state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 105: | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1009 +0x57f | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 112: | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:975 +0x1540 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).appendEntries() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1119 +0xd95 | |
github.com/benbjohnson/raft.(*Raft).processRPC() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:1023 +0x1b3 | |
github.com/benbjohnson/raft.(*Raft).runFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:516 +0x1f8 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:499 +0xd2 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 105 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 112 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:978 +0x81 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 105: | |
github.com/benbjohnson/raft.(*StaticPeers).Peers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/peer.go:37 +0x35 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:159 +0x54f | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1020 +0x723 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 109: | |
github.com/benbjohnson/raft.(*StaticPeers).SetPeers() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/peer.go:41 +0x35 | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:973 +0xe84 | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).leaderLoop() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:707 +0x344 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:669 +0x517 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 105 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 109 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:978 +0x81 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 105: | |
github.com/benbjohnson/raft.ExcludePeer() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/util.go:83 +0xdd | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:163 +0x6bb | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1020 +0x723 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 109: | |
github.com/benbjohnson/raft.(*Raft).processLog() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:973 +0xdec | |
github.com/benbjohnson/raft.(*Raft).processLogs() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:918 +0x428 | |
github.com/benbjohnson/raft.(*Raft).leaderLoop() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:707 +0x344 | |
github.com/benbjohnson/raft.(*Raft).runLeader() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:669 +0x517 | |
github.com/benbjohnson/raft.(*Raft).run() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:503 +0x106 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.run)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 105 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 109 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:202 +0xd8b | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_ReJoinFollower() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:978 +0x81 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
2014/04/29 16:03:29 [INFO] raft: Node at b7abd8b7-b511-6b5f-6f37-289b72cceb0c [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 [Leader] entering Leader state | |
2014/04/29 16:03:29 [WARN] raft: EnableSingleNode disabled, and no known peers. Aborting election. | |
2014/04/29 16:03:29 [WARN] raft: EnableSingleNode disabled, and no known peers. Aborting election. | |
2014/04/29 16:03:29 [DEBUG] raft: Node 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 updated peer set (add): [b7abd8b7-b511-6b5f-6f37-289b72cceb0c 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 ef69a1c0-f12e-6bed-8dc5-f1528674d220] | |
2014/04/29 16:03:29 [INFO] raft: Added peer b7abd8b7-b511-6b5f-6f37-289b72cceb0c, starting replication | |
2014/04/29 16:03:29 [WARN] raft: Failed to get previous log: 5 log not found (last: 3) | |
2014/04/29 16:03:29 [WARN] raft: AppendEntries to b7abd8b7-b511-6b5f-6f37-289b72cceb0c rejected, sending older logs (next: 4) | |
2014/04/29 16:03:29 [DEBUG] raft: Node 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 updated peer set (add): [b7abd8b7-b511-6b5f-6f37-289b72cceb0c 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 ef69a1c0-f12e-6bed-8dc5-f1528674d220] | |
2014/04/29 16:03:29 [DEBUG] raft: Node ef69a1c0-f12e-6bed-8dc5-f1528674d220 updated peer set (add): [b7abd8b7-b511-6b5f-6f37-289b72cceb0c 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 ef69a1c0-f12e-6bed-8dc5-f1528674d220] | |
2014/04/29 16:03:29 [DEBUG] raft: Node b7abd8b7-b511-6b5f-6f37-289b72cceb0c updated peer set (add): [b7abd8b7-b511-6b5f-6f37-289b72cceb0c 30bd734d-5c54-1ec3-0263-d9fc40ef25d4 ef69a1c0-f12e-6bed-8dc5-f1528674d220] | |
--- PASS: TestRaft_ReJoinFollower (0.09 seconds) | |
=== RUN TestRaft_LeaderLeaseExpire | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Leader] entering Leader state | |
2014/04/29 16:03:29 [INFO] Disconnecting Node at 72bbb540-1259-f642-7370-d02a54646151 [Follower] | |
2014/04/29 16:03:29 [WARN] Disconnecting 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 8f998608-3526-543c-e247-278c72135f9e: Failed to connect to peer: 8f998608-3526-543c-e247-278c72135f9e | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 8f998608-3526-543c-e247-278c72135f9e: Failed to connect to peer: 8f998608-3526-543c-e247-278c72135f9e | |
2014/04/29 16:03:29 [WARN] raft: Failed to contact 72bbb540-1259-f642-7370-d02a54646151 in 40.739553ms | |
2014/04/29 16:03:29 [WARN] raft: Failed to contact quorum of nodes, stepping down | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 8f998608-3526-543c-e247-278c72135f9e: Failed to connect to peer: 8f998608-3526-543c-e247-278c72135f9e | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 8f998608-3526-543c-e247-278c72135f9e: Failed to connect to peer: 8f998608-3526-543c-e247-278c72135f9e | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 72bbb540-1259-f642-7370-d02a54646151 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 8f998608-3526-543c-e247-278c72135f9e: Failed to connect to peer: 8f998608-3526-543c-e247-278c72135f9e | |
2014/04/29 16:03:29 [WARN] raft: Election timeout reached, restarting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 8f998608-3526-543c-e247-278c72135f9e [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [ERR] raft: Failed to make RequestVote RPC to 72bbb540-1259-f642-7370-d02a54646151: Failed to connect to peer: 72bbb540-1259-f642-7370-d02a54646151 | |
--- PASS: TestRaft_LeaderLeaseExpire (0.12 seconds) | |
=== RUN TestRaft_Barrier | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 542f445a-594e-6ae4-0073-1f2a3360e698 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at cb9ebbf9-04f2-3b83-2c0d-45b9661f2773 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 43b9b409-26db-b8e0-9d99-fe190ce183af [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 43b9b409-26db-b8e0-9d99-fe190ce183af [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 43b9b409-26db-b8e0-9d99-fe190ce183af [Leader] entering Leader state | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 204: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x193 | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1126 +0x2fa | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 206: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 204 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 206 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1106 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 204: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:200 +0x1a1 | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1126 +0x2fa | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 209: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x175 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 204 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 209 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1106 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 204: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3a7 | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1126 +0x2fa | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 206: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 204 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 206 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1106 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
================== | |
WARNING: DATA RACE | |
Read by goroutine 204: | |
github.com/benbjohnson/raft.(*cluster).EnsureSame() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:210 +0x3e6 | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1126 +0x2fa | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
Previous write by goroutine 209: | |
github.com/benbjohnson/raft.(*MockFSM).Apply() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:30 +0x139 | |
github.com/benbjohnson/raft.(*Raft).runFSM() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:465 +0xe73 | |
github.com/benbjohnson/raft.*Raft.(github.com/benbjohnson/raft.runFSM)·fm() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0x33 | |
github.com/benbjohnson/raft.func·007() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:143 +0x7b | |
Goroutine 204 (running) created at: | |
testing.RunTests() | |
/usr/local/go/src/pkg/testing/testing.go:471 +0xb3c | |
testing.Main() | |
/usr/local/go/src/pkg/testing/testing.go:403 +0xa2 | |
main.main() | |
github.com/benbjohnson/raft/_test/_testmain.go:167 +0xdc | |
Goroutine 209 (running) created at: | |
github.com/benbjohnson/raft.(*raftState).goFunc() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/state.go:144 +0xf1 | |
github.com/benbjohnson/raft.NewRaft() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft.go:203 +0xdf9 | |
github.com/benbjohnson/raft.MakeCluster() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:303 +0x119b | |
github.com/benbjohnson/raft.TestRaft_Barrier() | |
/Users/benbjohnson/go/src/github.com/benbjohnson/raft/raft_test.go:1106 +0x54 | |
testing.tRunner() | |
/usr/local/go/src/pkg/testing/testing.go:391 +0x10f | |
================== | |
--- PASS: TestRaft_Barrier (0.07 seconds) | |
=== RUN TestRaft_VerifyLeader | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at eb56bc1c-13fd-d45e-63e1-901cbb9a258b [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at db517165-6d73-e035-3244-42371136cb04 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 5f17b68d-b56b-42e1-e0a9-f2ee1206b540 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 5f17b68d-b56b-42e1-e0a9-f2ee1206b540 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 5f17b68d-b56b-42e1-e0a9-f2ee1206b540 [Leader] entering Leader state | |
--- PASS: TestRaft_VerifyLeader (0.02 seconds) | |
=== RUN TestRaft_VerifyLeader_Single | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 591ae712-3e1b-2afe-4f4b-987009355644 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 591ae712-3e1b-2afe-4f4b-987009355644 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 1 | |
2014/04/29 16:03:29 [INFO] raft: Node at 591ae712-3e1b-2afe-4f4b-987009355644 [Leader] entering Leader state | |
--- PASS: TestRaft_VerifyLeader_Single (0.02 seconds) | |
=== RUN TestRaft_VerifyLeader_Fail | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 02a0e22b-5fbd-19e1-ee52-0116a0bd62cd [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at b0805341-7ca0-82da-9fe2-754de4f22f72 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 02a0e22b-5fbd-19e1-ee52-0116a0bd62cd [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 02a0e22b-5fbd-19e1-ee52-0116a0bd62cd [Leader] entering Leader state | |
2014/04/29 16:03:29 [WARN] raft: New leader elected, stepping down | |
2014/04/29 16:03:29 [INFO] raft: Node at 02a0e22b-5fbd-19e1-ee52-0116a0bd62cd [Follower] entering Follower state | |
--- PASS: TestRaft_VerifyLeader_Fail (0.03 seconds) | |
=== RUN TestRaft_VerifyLeader_ParitalConnect | |
2014/04/29 16:03:29 [WARN] Fully Connecting | |
2014/04/29 16:03:29 [INFO] raft: Node at 8e164987-95c9-b8d1-2497-a5d56d2d9e8e [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 80496076-661e-370d-1cef-8634e62c4673 [Follower] entering Follower state | |
2014/04/29 16:03:29 [INFO] raft: Node at 17ab3269-0f8a-76ec-2ed1-3675f86434a9 [Follower] entering Follower state | |
2014/04/29 16:03:29 [WARN] raft: Heartbeat timeout reached, starting election | |
2014/04/29 16:03:29 [INFO] raft: Node at 17ab3269-0f8a-76ec-2ed1-3675f86434a9 [Candidate] entering Candidate state | |
2014/04/29 16:03:29 [DEBUG] raft: Votes needed: 2 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 1 | |
2014/04/29 16:03:29 [DEBUG] raft: Vote granted. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Election won. Tally: 2 | |
2014/04/29 16:03:29 [INFO] raft: Node at 17ab3269-0f8a-76ec-2ed1-3675f86434a9 [Leader] entering Leader state | |
2014/04/29 16:03:29 [INFO] Disconnecting Node at 8e164987-95c9-b8d1-2497-a5d56d2d9e8e [Follower] | |
2014/04/29 16:03:29 [WARN] Disconnecting 8e164987-95c9-b8d1-2497-a5d56d2d9e8e | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 8e164987-95c9-b8d1-2497-a5d56d2d9e8e: Failed to connect to peer: 8e164987-95c9-b8d1-2497-a5d56d2d9e8e | |
2014/04/29 16:03:29 [ERR] raft: Failed to AppendEntries to 80496076-661e-370d-1cef-8634e62c4673: command timed out | |
2014/04/29 16:03:29 [ERR] raft: Failed to heartbeat to 80496076-661e-370d-1cef-8634e62c4673: command timed out | |
--- PASS: TestRaft_VerifyLeader_ParitalConnect (0.08 seconds) | |
=== RUN TestTCPTransport_BadAddr | |
--- PASS: TestTCPTransport_BadAddr (0.00 seconds) | |
=== RUN TestTCPTransport_WithAdvertise | |
--- PASS: TestTCPTransport_WithAdvertise (0.00 seconds) | |
=== RUN TestRandomTimeout | |
--- PASS: TestRandomTimeout (0.00 seconds) | |
=== RUN TestRandomTimeout_NoTime | |
--- PASS: TestRandomTimeout_NoTime (0.00 seconds) | |
=== RUN TestMin | |
--- PASS: TestMin (0.00 seconds) | |
=== RUN TestMax | |
--- PASS: TestMax (0.00 seconds) | |
=== RUN TestGenerateUUID | |
--- PASS: TestGenerateUUID (0.04 seconds) | |
=== RUN TestAsyncNotify | |
--- PASS: TestAsyncNotify (0.00 seconds) | |
=== RUN TestExcludePeer | |
--- PASS: TestExcludePeer (0.00 seconds) | |
=== RUN TestPeerContained | |
--- PASS: TestPeerContained (0.00 seconds) | |
=== RUN TestAddUniquePeer | |
--- PASS: TestAddUniquePeer (0.00 seconds) | |
=== RUN TestEncodeDecodePeers | |
--- PASS: TestEncodeDecodePeers (0.00 seconds) | |
=== RUN TestBackoff | |
--- PASS: TestBackoff (0.00 seconds) | |
PASS | |
Found 41 data race(s) | |
exit status 66 | |
FAIL github.com/benbjohnson/raft 2.864s |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment