node_test.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. package raft
  2. import (
  3. "testing"
  4. )
  5. const (
  6. defaultHeartbeat = 1
  7. defaultElection = 5
  8. )
  9. func TestTickMsgHup(t *testing.T) {
  10. n := New(0, defaultHeartbeat, defaultElection)
  11. n.sm = newStateMachine(0, []int{0, 1, 2})
  12. // simulate to patch the join log
  13. n.Step(Message{Type: msgApp, Commit: 1, Entries: []Entry{Entry{}}})
  14. for i := 0; i < defaultElection+1; i++ {
  15. n.Tick()
  16. }
  17. called := false
  18. for _, m := range n.Msgs() {
  19. if m.Type == msgVote {
  20. called = true
  21. }
  22. }
  23. if !called {
  24. t.Errorf("called = %v, want true", called)
  25. }
  26. }
  27. func TestTickMsgBeat(t *testing.T) {
  28. k := 3
  29. n := dictate(New(0, defaultHeartbeat, defaultElection))
  30. n.Next()
  31. for i := 1; i < k; i++ {
  32. n.Add(i, "")
  33. for _, m := range n.Msgs() {
  34. if m.Type == msgApp {
  35. n.Step(Message{From: m.To, Type: msgAppResp, Index: m.Index + len(m.Entries)})
  36. }
  37. }
  38. // ignore commit index update messages
  39. n.Msgs()
  40. n.Next()
  41. }
  42. for i := 0; i < defaultHeartbeat+1; i++ {
  43. n.Tick()
  44. }
  45. called := 0
  46. for _, m := range n.Msgs() {
  47. if m.Type == msgApp {
  48. called++
  49. }
  50. }
  51. // msgBeat -> k-1 append
  52. w := k - 1
  53. if called != w {
  54. t.Errorf("called = %v, want %v", called, w)
  55. }
  56. }
  57. func TestResetElapse(t *testing.T) {
  58. tests := []struct {
  59. msg Message
  60. welapsed tick
  61. }{
  62. {Message{From: 0, To: 1, Type: msgApp, Term: 2, Entries: []Entry{{Term: 1}}}, 0},
  63. {Message{From: 0, To: 1, Type: msgApp, Term: 1, Entries: []Entry{{Term: 1}}}, 1},
  64. {Message{From: 0, To: 1, Type: msgVote, Term: 2}, 0},
  65. {Message{From: 0, To: 1, Type: msgVote, Term: 1}, 1},
  66. }
  67. for i, tt := range tests {
  68. n := New(0, defaultHeartbeat, defaultElection)
  69. n.sm = newStateMachine(0, []int{0, 1, 2})
  70. n.sm.term = 2
  71. n.sm.log.committed = 1
  72. n.Tick()
  73. if n.elapsed != 1 {
  74. t.Errorf("%d: elpased = %d, want %d", i, n.elapsed, 1)
  75. }
  76. n.Step(tt.msg)
  77. if n.elapsed != tt.welapsed {
  78. t.Errorf("%d: elpased = %d, want %d", i, n.elapsed, tt.welapsed)
  79. }
  80. }
  81. }
  82. func TestStartCluster(t *testing.T) {
  83. n := dictate(New(0, defaultHeartbeat, defaultElection))
  84. n.Next()
  85. if len(n.sm.ins) != 1 {
  86. t.Errorf("k = %d, want 1", len(n.sm.ins))
  87. }
  88. if n.sm.id != 0 {
  89. t.Errorf("id = %d, want 0", n.sm.id)
  90. }
  91. if n.sm.state != stateLeader {
  92. t.Errorf("state = %s, want %s", n.sm.state, stateLeader)
  93. }
  94. }
  95. func TestAdd(t *testing.T) {
  96. n := dictate(New(0, defaultHeartbeat, defaultElection))
  97. n.Next()
  98. n.Add(1, "")
  99. n.Next()
  100. if len(n.sm.ins) != 2 {
  101. t.Errorf("k = %d, want 2", len(n.sm.ins))
  102. }
  103. if n.sm.id != 0 {
  104. t.Errorf("id = %d, want 0", n.sm.id)
  105. }
  106. }
  107. func TestRemove(t *testing.T) {
  108. n := dictate(New(0, defaultHeartbeat, defaultElection))
  109. n.Next()
  110. n.Add(1, "")
  111. n.Next()
  112. n.Remove(0)
  113. n.Step(Message{Type: msgAppResp, From: 1, Term: 1, Index: 4})
  114. n.Next()
  115. if len(n.sm.ins) != 1 {
  116. t.Errorf("k = %d, want 1", len(n.sm.ins))
  117. }
  118. if n.sm.id != 0 {
  119. t.Errorf("id = %d, want 0", n.sm.id)
  120. }
  121. }
  122. func dictate(n *Node) *Node {
  123. n.Step(Message{Type: msgHup})
  124. n.Add(n.Id(), "")
  125. return n
  126. }