diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-02-16 03:03:00 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-02-16 03:03:00 -0800 |
| commit | 3fe628f04e2aa3ac550c670c27d00fcc3fc2e12b (patch) | |
| tree | 98c2c6e2355c237dcc1e383673f83a555f13ab27 /weed/topology/data_node.go | |
| parent | f8446b42abd7f3c6c0a298dbbb8641e466891561 (diff) | |
| download | seaweedfs-3fe628f04e2aa3ac550c670c27d00fcc3fc2e12b.tar.xz seaweedfs-3fe628f04e2aa3ac550c670c27d00fcc3fc2e12b.zip | |
use hdd instead of empty string
Diffstat (limited to 'weed/topology/data_node.go')
| -rw-r--r-- | weed/topology/data_node.go | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/weed/topology/data_node.go b/weed/topology/data_node.go index 5b625de80..038d87043 100644 --- a/weed/topology/data_node.go +++ b/weed/topology/data_node.go @@ -14,10 +14,10 @@ import ( type DataNode struct { NodeImpl - Ip string - Port int - PublicUrl string - LastSeen int64 // unix time in seconds + Ip string + Port int + PublicUrl string + LastSeen int64 // unix time in seconds } func NewDataNode(id string) *DataNode { @@ -80,7 +80,7 @@ func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (newVolume deletedVolumes = append(deletedVolumes, v) deltaDiskUsages := newDiskUsages() - deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.DiskType(v.DiskType)) + deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.ToDiskType(v.DiskType)) deltaDiskUsage.volumeCount = -1 if v.IsRemote() { deltaDiskUsage.remoteVolumeCount = -1 @@ -112,7 +112,7 @@ func (dn *DataNode) DeltaUpdateVolumes(newVolumes, deletedVolumes []storage.Volu delete(disk.volumes, v.Id) deltaDiskUsages := newDiskUsages() - deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.DiskType(v.DiskType)) + deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.ToDiskType(v.DiskType)) deltaDiskUsage.volumeCount = -1 if v.IsRemote() { deltaDiskUsage.remoteVolumeCount = -1 @@ -194,7 +194,8 @@ func (dn *DataNode) ToMap() interface{} { func (dn *DataNode) ToDataNodeInfo() *master_pb.DataNodeInfo { m := &master_pb.DataNodeInfo{ - Id: string(dn.Id()), + Id: string(dn.Id()), + DiskInfos: make(map[string]*master_pb.DiskInfo), } for _, c := range dn.Children() { disk := c.(*Disk) @@ -224,4 +225,4 @@ func (dn *DataNode) getVolumes() []storage.VolumeInfo { existingVolumes = append(existingVolumes, disk.GetVolumes()...) } return existingVolumes -}
\ No newline at end of file +} |