|
|
@@ -454,43 +454,3 @@ func (t *Transport) ActivePeers() (cnt int) {
|
|
|
}
|
|
|
return cnt
|
|
|
}
|
|
|
-
|
|
|
-type nopTransporter struct{}
|
|
|
-
|
|
|
-func NewNopTransporter() Transporter {
|
|
|
- return &nopTransporter{}
|
|
|
-}
|
|
|
-
|
|
|
-func (s *nopTransporter) Start() error { return nil }
|
|
|
-func (s *nopTransporter) Handler() http.Handler { return nil }
|
|
|
-func (s *nopTransporter) Send(m []raftpb.Message) {}
|
|
|
-func (s *nopTransporter) SendSnapshot(m raftsnap.Message) {}
|
|
|
-func (s *nopTransporter) AddRemote(id types.ID, us []string) {}
|
|
|
-func (s *nopTransporter) AddPeer(id types.ID, us []string) {}
|
|
|
-func (s *nopTransporter) RemovePeer(id types.ID) {}
|
|
|
-func (s *nopTransporter) RemoveAllPeers() {}
|
|
|
-func (s *nopTransporter) UpdatePeer(id types.ID, us []string) {}
|
|
|
-func (s *nopTransporter) ActiveSince(id types.ID) time.Time { return time.Time{} }
|
|
|
-func (s *nopTransporter) ActivePeers() int { return 0 }
|
|
|
-func (s *nopTransporter) Stop() {}
|
|
|
-func (s *nopTransporter) Pause() {}
|
|
|
-func (s *nopTransporter) Resume() {}
|
|
|
-
|
|
|
-type snapTransporter struct {
|
|
|
- nopTransporter
|
|
|
- snapDoneC chan raftsnap.Message
|
|
|
- snapDir string
|
|
|
-}
|
|
|
-
|
|
|
-func NewSnapTransporter(snapDir string) (Transporter, <-chan raftsnap.Message) {
|
|
|
- ch := make(chan raftsnap.Message, 1)
|
|
|
- tr := &snapTransporter{snapDoneC: ch, snapDir: snapDir}
|
|
|
- return tr, ch
|
|
|
-}
|
|
|
-
|
|
|
-func (s *snapTransporter) SendSnapshot(m raftsnap.Message) {
|
|
|
- ss := raftsnap.New(zap.NewExample(), s.snapDir)
|
|
|
- ss.SaveDBFrom(m.ReadCloser, m.Snapshot.Metadata.Index+1)
|
|
|
- m.CloseWithError(nil)
|
|
|
- s.snapDoneC <- m
|
|
|
-}
|