diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2019-04-29 20:37:31 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-04-29 20:37:31 -0700 |
| commit | ac52db3bedbba647cb4531444e16914e6d17b06a (patch) | |
| tree | eda72514de5aa891a7db569c4f8cc213ccb8f94e /weed/server | |
| parent | 82e06a780bb12adc47d6036067164c2fd02a25c4 (diff) | |
| parent | 8b51c16e2c7b73a571c04cc43cba78b54841dd12 (diff) | |
| download | seaweedfs-ac52db3bedbba647cb4531444e16914e6d17b06a.tar.xz seaweedfs-ac52db3bedbba647cb4531444e16914e6d17b06a.zip | |
Merge pull request #948 from Wine93/style
Style
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/master_grpc_server.go | 6 | ||||
| -rw-r--r-- | weed/server/volume_grpc_client_to_master.go | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 730412b47..1cc3fef7a 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -79,10 +79,10 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ } if len(heartbeat.NewVolumes) > 0 || len(heartbeat.DeletedVolumes) > 0 { // process delta volume ids if exists for fast volume id updates - for _, volInfo := range heartbeat.NewVolumes{ + for _, volInfo := range heartbeat.NewVolumes { message.NewVids = append(message.NewVids, volInfo.Id) } - for _, volInfo := range heartbeat.DeletedVolumes{ + for _, volInfo := range heartbeat.DeletedVolumes { message.DeletedVids = append(message.DeletedVids, volInfo.Id) } // update master internal volume layouts @@ -92,7 +92,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ newVolumes, deletedVolumes := t.SyncDataNodeRegistration(heartbeat.Volumes, dn) for _, v := range newVolumes { - glog.V(0).Infof("master see new volume %d from %s", uint32(v.Id), dn.Url()) + glog.V(0).Infof("master see new volume %d from %s", uint32(v.Id), dn.Url()) message.NewVids = append(message.NewVids, uint32(v.Id)) } for _, v := range deletedVolumes { diff --git a/weed/server/volume_grpc_client_to_master.go b/weed/server/volume_grpc_client_to_master.go index 1c292db6a..b30b2d124 100644 --- a/weed/server/volume_grpc_client_to_master.go +++ b/weed/server/volume_grpc_client_to_master.go @@ -99,7 +99,7 @@ func (vs *VolumeServer) doHeartbeat(ctx context.Context, masterNode, masterGrpcA select { case volumeMessage := <-vs.store.NewVolumesChan: deltaBeat := &master_pb.Heartbeat{ - NewVolumes:[]*master_pb.VolumeShortInformationMessage{ + NewVolumes: []*master_pb.VolumeShortInformationMessage{ &volumeMessage, }, } @@ -110,7 +110,7 @@ func (vs *VolumeServer) doHeartbeat(ctx context.Context, masterNode, masterGrpcA } case volumeMessage := <-vs.store.DeletedVolumesChan: deltaBeat := &master_pb.Heartbeat{ - DeletedVolumes:[]*master_pb.VolumeShortInformationMessage{ + DeletedVolumes: []*master_pb.VolumeShortInformationMessage{ &volumeMessage, }, } |
