diff options
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_grpc_server_rename.go | 2 | ||||
| -rw-r--r-- | weed/server/master_server_cluster.go | 2 | ||||
| -rw-r--r-- | weed/server/volume_grpc_copy.go | 2 | ||||
| -rw-r--r-- | weed/server/volume_grpc_vacuum.go | 2 |
4 files changed, 4 insertions, 4 deletions
diff --git a/weed/server/filer_grpc_server_rename.go b/weed/server/filer_grpc_server_rename.go index 278ecadbd..a7f428848 100644 --- a/weed/server/filer_grpc_server_rename.go +++ b/weed/server/filer_grpc_server_rename.go @@ -161,7 +161,7 @@ func (fs *FilerServer) moveSelfEntry(ctx context.Context, stream filer_pb.Seawee if err := stream.Send(&filer_pb.StreamRenameEntryResponse{ Directory: string(newParent), EventNotification: &filer_pb.EventNotification{ - OldEntry: &filer_pb.Entry{ + OldEntry: &filer_pb.Entry{ Name: entry.Name(), }, NewEntry: newEntry.ToProtoEntry(), diff --git a/weed/server/master_server_cluster.go b/weed/server/master_server_cluster.go index 52e1526f9..19ecaff0a 100644 --- a/weed/server/master_server_cluster.go +++ b/weed/server/master_server_cluster.go @@ -56,7 +56,7 @@ func (cluster *Cluster) RemoveClusterNode(nodeType string, address pb.ServerAddr } } -func (cluster *Cluster) ListClusterNode(nodeType string) (nodes []*ClusterNode){ +func (cluster *Cluster) ListClusterNode(nodeType string) (nodes []*ClusterNode) { switch nodeType { case "filer": cluster.filersLock.RLock() diff --git a/weed/server/volume_grpc_copy.go b/weed/server/volume_grpc_copy.go index 28018f344..9630b322e 100644 --- a/weed/server/volume_grpc_copy.go +++ b/weed/server/volume_grpc_copy.go @@ -80,7 +80,7 @@ func (vs *VolumeServer) VolumeCopy(req *volume_server_pb.VolumeCopyRequest, stre // println("source:", volFileInfoResp.String()) copyResponse := &volume_server_pb.VolumeCopyResponse{} - reportInterval := int64(1024*1024*128) + reportInterval := int64(1024 * 1024 * 128) nextReportTarget := reportInterval var modifiedTsNs int64 var sendErr error diff --git a/weed/server/volume_grpc_vacuum.go b/weed/server/volume_grpc_vacuum.go index 57bf8d867..0ab782b02 100644 --- a/weed/server/volume_grpc_vacuum.go +++ b/weed/server/volume_grpc_vacuum.go @@ -27,7 +27,7 @@ func (vs *VolumeServer) VacuumVolumeCheck(ctx context.Context, req *volume_serve func (vs *VolumeServer) VacuumVolumeCompact(req *volume_server_pb.VacuumVolumeCompactRequest, stream volume_server_pb.VolumeServer_VacuumVolumeCompactServer) error { resp := &volume_server_pb.VacuumVolumeCompactResponse{} - reportInterval := int64(1024*1024*128) + reportInterval := int64(1024 * 1024 * 128) nextReportTarget := reportInterval var sendErr error |