diff options
| author | chrislusf <chrislu@Chriss-MacBook-Air.local> | 2014-12-08 20:29:25 -0800 |
|---|---|---|
| committer | chrislusf <chrislu@Chriss-MacBook-Air.local> | 2014-12-08 20:29:25 -0800 |
| commit | 52180f386b044af7a6daba3e33ff04b5e9da25ba (patch) | |
| tree | 1490ad6c11f986da12a421e717767402dc993d3c /go/topology/topology_map.go | |
| parent | ba972694c730429889c696bd9853a38843f64f65 (diff) | |
| download | seaweedfs-52180f386b044af7a6daba3e33ff04b5e9da25ba.tar.xz seaweedfs-52180f386b044af7a6daba3e33ff04b5e9da25ba.zip | |
Add read-write lock to guard topology changes on new collections and ttls.
Diffstat (limited to 'go/topology/topology_map.go')
| -rw-r--r-- | go/topology/topology_map.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/go/topology/topology_map.go b/go/topology/topology_map.go index af95c6536..6a1423ca8 100644 --- a/go/topology/topology_map.go +++ b/go/topology/topology_map.go @@ -11,10 +11,11 @@ func (t *Topology) ToMap() interface{} { } m["DataCenters"] = dcs var layouts []interface{} - for _, c := range t.collectionMap { - for _, layout := range c.storageType2VolumeLayout { + for _, col := range t.collectionMap.Items { + c := col.(*Collection) + for _, layout := range c.storageType2VolumeLayout.Items { if layout != nil { - tmp := layout.ToMap() + tmp := layout.(*VolumeLayout).ToMap() tmp["collection"] = c.Name layouts = append(layouts, tmp) } |