From b97df8d5f6b7cdeebfcf42cc3f9d3f7c0a135c8a Mon Sep 17 00:00:00 2001 From: mcrakhman Date: Fri, 3 Feb 2023 20:15:55 +0100 Subject: [PATCH] Remove SendResponsible --- commonspace/objectsync/msgpool.go | 5 ----- .../mock_peermanager/mock_peermanager.go | 14 -------------- commonspace/peermanager/peermanager.go | 2 -- 3 files changed, 21 deletions(-) diff --git a/commonspace/objectsync/msgpool.go b/commonspace/objectsync/msgpool.go index 4d4f11e1..c47fc30d 100644 --- a/commonspace/objectsync/msgpool.go +++ b/commonspace/objectsync/msgpool.go @@ -86,11 +86,6 @@ func (s *messagePool) SendPeer(ctx context.Context, peerId string, msg *spacesyn return s.PeerManager.SendPeer(ctx, peerId, msg) } -func (s *messagePool) SendResponsible(ctx context.Context, msg *spacesyncproto.ObjectSyncMessage) (err error) { - s.updateLastUsage() - return s.PeerManager.SendResponsible(ctx, msg) -} - func (s *messagePool) Broadcast(ctx context.Context, msg *spacesyncproto.ObjectSyncMessage) (err error) { s.updateLastUsage() return s.PeerManager.Broadcast(ctx, msg) diff --git a/commonspace/peermanager/mock_peermanager/mock_peermanager.go b/commonspace/peermanager/mock_peermanager/mock_peermanager.go index ae97fe7b..f7d0ce74 100644 --- a/commonspace/peermanager/mock_peermanager/mock_peermanager.go +++ b/commonspace/peermanager/mock_peermanager/mock_peermanager.go @@ -78,17 +78,3 @@ func (mr *MockPeerManagerMockRecorder) SendPeer(arg0, arg1, arg2 interface{}) *g mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendPeer", reflect.TypeOf((*MockPeerManager)(nil).SendPeer), arg0, arg1, arg2) } - -// SendResponsible mocks base method. -func (m *MockPeerManager) SendResponsible(arg0 context.Context, arg1 *spacesyncproto.ObjectSyncMessage) error { - m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "SendResponsible", arg0, arg1) - ret0, _ := ret[0].(error) - return ret0 -} - -// SendResponsible indicates an expected call of SendResponsible. -func (mr *MockPeerManagerMockRecorder) SendResponsible(arg0, arg1 interface{}) *gomock.Call { - mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendResponsible", reflect.TypeOf((*MockPeerManager)(nil).SendResponsible), arg0, arg1) -} diff --git a/commonspace/peermanager/peermanager.go b/commonspace/peermanager/peermanager.go index 373c3a51..676d000c 100644 --- a/commonspace/peermanager/peermanager.go +++ b/commonspace/peermanager/peermanager.go @@ -13,8 +13,6 @@ const CName = "common.commonspace.peermanager" type PeerManager interface { // SendPeer sends a message to a stream by peerId SendPeer(ctx context.Context, peerId string, msg *spacesyncproto.ObjectSyncMessage) (err error) - // SendResponsible sends a message to responsible peers streams - SendResponsible(ctx context.Context, msg *spacesyncproto.ObjectSyncMessage) (err error) // Broadcast sends a message to all subscribed peers Broadcast(ctx context.Context, msg *spacesyncproto.ObjectSyncMessage) (err error) // GetResponsiblePeers dials or gets from cache responsible peers to unary operations