status-im/simulation
2
0
Fork 0
mirror of https://github.com/status-im/simulation.git synced 2025-02-23 20:38:07 +00:00
Code Issues Projects Releases Wiki Activity

Rename interface again

Browse Source
This commit is contained in:
Ivan Danyliuk 2018-04-30 22:07:17 +02:00
parent 842ad42fc2
commit e2ebc9fe91
No known key found for this signature in database
GPG Key ID: 97ED33CE024E1DBF
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/propagation_simulator/main.go
View File

@ -38,7 +38,7 @@ func main() {
} }
defer fd.Close() defer fd.Close()
var sim propagation.PropagationSimulator var sim propagation.Simulator
switch *simType { switch *simType {
case "naivep2p": case "naivep2p":
sim = naivep2p.NewSimulator(data, *naiveP2PN, *naiveP2PDelay) sim = naivep2p.NewSimulator(data, *naiveP2PN, *naiveP2PDelay)

4
propagation/naivep2p/simulator.go
View File

@ -46,12 +46,12 @@ func NewSimulator(data *graph.Graph, N int, delay time.Duration) *Simulator {
return sim return sim
} }
// Stop stops simulator and frees all resources if any. Implements propagation.PropagationSimulator. // Stop stops simulator and frees all resources if any. Implements propagation.Simulator.
func (s *Simulator) Stop() error { func (s *Simulator) Stop() error {
return nil return nil
} }
// SendMessage sends single message and tracks propagation. Implements propagation.PropagationSimulator. // SendMessage sends single message and tracks propagation. Implements propagation.Simulator.
func (s *Simulator) SendMessage(startNodeIdx, ttl int) *propagation.Log { func (s *Simulator) SendMessage(startNodeIdx, ttl int) *propagation.Log {
message := Message{ message := Message{
Content: "dummy", Content: "dummy",

4
propagation/propagation.go
View File

@ -1,7 +1,7 @@
package propagation package propagation
// PropagationSimulator defines the simulators for message propagation within the graph. // Simulator defines the simulators for message propagation within the graph.
type PropagationSimulator interface { type Simulator interface {
SendMessage(idx, ttl int) *Log SendMessage(idx, ttl int) *Log
Stop() error Stop() error
} }

4
propagation/whisperv6/simulator.go
View File

@ -18,7 +18,7 @@ import (
) )
// Simulator simulates WhisperV6 message propagation through the // Simulator simulates WhisperV6 message propagation through the
// given p2p network. Implements PropagationSimulator interface. // given p2p network. Implements Simulator interface.
type Simulator struct { type Simulator struct {
data *graph.Graph data *graph.Graph
network *simulations.Network network *simulations.Network
@ -120,7 +120,7 @@ func (s *Simulator) Stop() error {
return nil return nil
} }
// SendMessage sends single message and tracks propagation. Implements propagation.PropagationSimulator. // SendMessage sends single message and tracks propagation. Implements propagation.Simulator.
func (s *Simulator) SendMessage(startNodeIdx, ttl int) *propagation.Log { func (s *Simulator) SendMessage(startNodeIdx, ttl int) *propagation.Log {
node := s.network.Nodes[startNodeIdx] node := s.network.Nodes[startNodeIdx]