Skip to content
Snippets Groups Projects
Commit 13021fe9 authored by Jake Taylor's avatar Jake Taylor
Browse files

fix pipeline

parent 7533a868
No related branches found
No related tags found
2 merge requests!510Release,!485early attempt at making the network follower period adjustable via the bindings
...@@ -151,6 +151,11 @@ type mockCmix struct { ...@@ -151,6 +151,11 @@ type mockCmix struct {
instance *network.Instance instance *network.Instance
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix() *mockCmix { func newMockCmix() *mockCmix {
return &mockCmix{} return &mockCmix{}
} }
......
...@@ -30,6 +30,11 @@ type mockCmix struct { ...@@ -30,6 +30,11 @@ type mockCmix struct {
payloadSize int payloadSize int
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix(payloadSize int) cmix.Client { func newMockCmix(payloadSize int) cmix.Client {
return &mockCmix{ return &mockCmix{
......
...@@ -110,6 +110,11 @@ type mockFpgCmix struct { ...@@ -110,6 +110,11 @@ type mockFpgCmix struct {
sync.Mutex sync.Mutex
} }
func (m *mockFpgCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockFpgCmix() *mockFpgCmix { func newMockFpgCmix() *mockFpgCmix {
return &mockFpgCmix{ return &mockFpgCmix{
processors: make(map[id.ID]map[format.Fingerprint]message.Processor), processors: make(map[id.ID]map[format.Fingerprint]message.Processor),
......
...@@ -221,6 +221,11 @@ func (m mockServiceHandler) DeleteService(clientID *id.ID, toDelete message.Serv ...@@ -221,6 +221,11 @@ func (m mockServiceHandler) DeleteService(clientID *id.ID, toDelete message.Serv
type mockNetManager struct{} type mockNetManager struct{}
func (m *mockNetManager) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func (m *mockNetManager) GetIdentity(get *id.ID) (identity.TrackedID, error) { func (m *mockNetManager) GetIdentity(get *id.ID) (identity.TrackedID, error) {
// TODO implement me // TODO implement me
panic("implement me") panic("implement me")
......
...@@ -154,6 +154,11 @@ type mockCmix struct { ...@@ -154,6 +154,11 @@ type mockCmix struct {
instance *network.Instance instance *network.Instance
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix(myID *id.ID, handler *mockCmixHandler, t testing.TB) *mockCmix { func newMockCmix(myID *id.ID, handler *mockCmixHandler, t testing.TB) *mockCmix {
comms := &connect.ProtoComms{Manager: connect.NewManagerTesting(t)} comms := &connect.ProtoComms{Manager: connect.NewManagerTesting(t)}
def := getNDF() def := getNDF()
......
...@@ -95,6 +95,11 @@ type mockCmix struct { ...@@ -95,6 +95,11 @@ type mockCmix struct {
sync.Mutex sync.Mutex
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix( func newMockCmix(
myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix { myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix {
return &mockCmix{ return &mockCmix{
......
...@@ -98,6 +98,11 @@ type mockCmix struct { ...@@ -98,6 +98,11 @@ type mockCmix struct {
sync.Mutex sync.Mutex
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix(myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix { func newMockCmix(myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix {
return &mockCmix{ return &mockCmix{
myID: myID, myID: myID,
......
...@@ -92,6 +92,11 @@ type mockCmix struct { ...@@ -92,6 +92,11 @@ type mockCmix struct {
sync.Mutex sync.Mutex
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix( func newMockCmix(
myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix { myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix {
return &mockCmix{ return &mockCmix{
......
...@@ -145,6 +145,11 @@ type mockCmix struct { ...@@ -145,6 +145,11 @@ type mockCmix struct {
sync.Mutex sync.Mutex
} }
func (m *mockCmix) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newMockCmix( func newMockCmix(
myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix { myID *id.ID, handler *mockCmixHandler, storage *mockStorage) *mockCmix {
return &mockCmix{ return &mockCmix{
......
...@@ -35,6 +35,11 @@ type testNetworkManager struct { ...@@ -35,6 +35,11 @@ type testNetworkManager struct {
sync.RWMutex sync.RWMutex
} }
func (tnm *testNetworkManager) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func newTestNetworkManager(sendErr int) cmix.Client { func newTestNetworkManager(sendErr int) cmix.Client {
return &testNetworkManager{ return &testNetworkManager{
receptionMessages: [][]format.Message{}, receptionMessages: [][]format.Message{},
......
...@@ -34,6 +34,11 @@ type testNetworkManager struct { ...@@ -34,6 +34,11 @@ type testNetworkManager struct {
responseProcessor message.Processor responseProcessor message.Processor
} }
func (tnm *testNetworkManager) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
func (tnm *testNetworkManager) SendWithAssembler(recipient *id.ID, assembler cmix.MessageAssembler, func (tnm *testNetworkManager) SendWithAssembler(recipient *id.ID, assembler cmix.MessageAssembler,
cmixParams cmix.CMIXParams) (rounds.Round, ephemeral.Id, error) { cmixParams cmix.CMIXParams) (rounds.Round, ephemeral.Id, error) {
......
...@@ -85,6 +85,12 @@ type testNetworkManagerGeneric struct { ...@@ -85,6 +85,12 @@ type testNetworkManagerGeneric struct {
instance *network.Instance instance *network.Instance
sender gateway.Sender sender gateway.Sender
} }
func (t *testNetworkManagerGeneric) SetTrackNetworkPeriod(d time.Duration) {
//TODO implement me
panic("implement me")
}
type dummyEventMgr struct{} type dummyEventMgr struct{}
func (d *dummyEventMgr) Report(p int, a, b, c string) {} func (d *dummyEventMgr) Report(p int, a, b, c string) {}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment