diff options
Diffstat (limited to 'go/topology/topology.go')
| -rw-r--r-- | go/topology/topology.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/go/topology/topology.go b/go/topology/topology.go index d0e9fb42b..b21601210 100644 --- a/go/topology/topology.go +++ b/go/topology/topology.go @@ -28,7 +28,7 @@ type Topology struct { configuration *Configuration } -func NewTopology(id string, confFile string, dirname string, sequenceFilename string, volumeSizeLimit uint64, pulse int) (*Topology, error) { +func NewTopology(id string, confFile string, seq sequence.Sequencer, volumeSizeLimit uint64, pulse int) (*Topology, error) { t := &Topology{} t.id = NodeId(id) t.nodeType = "Topology" @@ -38,7 +38,7 @@ func NewTopology(id string, confFile string, dirname string, sequenceFilename st t.pulse = int64(pulse) t.volumeSizeLimit = volumeSizeLimit - t.sequence = sequence.NewSequencer(dirname, sequenceFilename) + t.sequence = seq t.chanDeadDataNodes = make(chan *DataNode) t.chanRecoveredDataNodes = make(chan *DataNode) |