util.go 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. // Copyright 2015 The etcd Authors
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package etcdserver
  15. import (
  16. "time"
  17. "github.com/coreos/etcd/etcdserver/membership"
  18. "github.com/coreos/etcd/pkg/types"
  19. "github.com/coreos/etcd/rafthttp"
  20. )
  21. // isConnectedToQuorumSince checks whether the local member is connected to the
  22. // quorum of the cluster since the given time.
  23. func isConnectedToQuorumSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*membership.Member) bool {
  24. return numConnectedSince(transport, since, self, members) >= (len(members)/2)+1
  25. }
  26. // isConnectedSince checks whether the local member is connected to the
  27. // remote member since the given time.
  28. func isConnectedSince(transport rafthttp.Transporter, since time.Time, remote types.ID) bool {
  29. t := transport.ActiveSince(remote)
  30. return !t.IsZero() && t.Before(since)
  31. }
  32. // isConnectedFullySince checks whether the local member is connected to all
  33. // members in the cluster since the given time.
  34. func isConnectedFullySince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*membership.Member) bool {
  35. return numConnectedSince(transport, since, self, members) == len(members)
  36. }
  37. // numConnectedSince counts how many members are connected to the local member
  38. // since the given time.
  39. func numConnectedSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*membership.Member) int {
  40. connectedNum := 0
  41. for _, m := range members {
  42. if m.ID == self || isConnectedSince(transport, since, m.ID) {
  43. connectedNum++
  44. }
  45. }
  46. return connectedNum
  47. }
  48. // longestConnected chooses the member with longest active-since-time.
  49. // It returns false, if nothing is active.
  50. func longestConnected(tp rafthttp.Transporter, membs []types.ID) (types.ID, bool) {
  51. var longest types.ID
  52. var oldest time.Time
  53. for _, id := range membs {
  54. tm := tp.ActiveSince(id)
  55. if tm.IsZero() { // inactive
  56. continue
  57. }
  58. if oldest.IsZero() { // first longest candidate
  59. oldest = tm
  60. longest = id
  61. }
  62. if tm.Before(oldest) {
  63. oldest = tm
  64. longest = id
  65. }
  66. }
  67. if uint64(longest) == 0 {
  68. return longest, false
  69. }
  70. return longest, true
  71. }
  72. type notifier struct {
  73. c chan struct{}
  74. err error
  75. }
  76. func newNotifier() *notifier {
  77. return &notifier{
  78. c: make(chan struct{}, 0),
  79. }
  80. }
  81. func (nc *notifier) notify(err error) {
  82. nc.err = err
  83. close(nc.c)
  84. }