aboutsummaryrefslogtreecommitdiff
path: root/weed/server
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2019-04-29 20:37:31 -0700
committerGitHub <noreply@github.com>2019-04-29 20:37:31 -0700
commitac52db3bedbba647cb4531444e16914e6d17b06a (patch)
treeeda72514de5aa891a7db569c4f8cc213ccb8f94e /weed/server
parent82e06a780bb12adc47d6036067164c2fd02a25c4 (diff)
parent8b51c16e2c7b73a571c04cc43cba78b54841dd12 (diff)
downloadseaweedfs-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.go6
-rw-r--r--weed/server/volume_grpc_client_to_master.go4
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,
},
}