From 5bc28488b23152fb5650c78ce4ecefdc9113541c Mon Sep 17 00:00:00 2001 From: Gyuho Lee Date: Thu, 17 May 2018 14:17:08 -0700 Subject: [PATCH] rafthttp: remove unused test Transporter Signed-off-by: Gyuho Lee --- rafthttp/transport.go | 40 ---------------------------------------- 1 file changed, 40 deletions(-) diff --git a/rafthttp/transport.go b/rafthttp/transport.go index 27d37a12e..9127625a8 100644 --- a/rafthttp/transport.go +++ b/rafthttp/transport.go @@ -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 -}