Merge pull request #926 from harshavardhana/available-disk-space

Add 5% cumulative reduction in total size of the disk
master
Harshavardhana 9 years ago
commit e9d5ec3d64
  1. 2
      api-errors.go
  2. 4
      pkg/fs/fs-bucket.go
  3. 8
      pkg/fs/fs-multipart.go
  4. 4
      pkg/fs/fs-object.go
  5. 2
      server-main.go

@ -228,7 +228,7 @@ var errorCodeResponse = map[int]APIError{
}, },
RootPathFull: { RootPathFull: {
Code: "RootPathFull", Code: "RootPathFull",
Description: "Root path has reached its minimum free disk threshold. Please clear few objects to proceed.", Description: "Root path has reached its minimum free disk threshold. Please delete few objects to proceed.",
HTTPStatusCode: http.StatusInternalServerError, HTTPStatusCode: http.StatusInternalServerError,
}, },
} }

@ -98,7 +98,9 @@ func (fs Filesystem) MakeBucket(bucket, acl string) *probe.Error {
return probe.NewError(err) return probe.NewError(err)
} }
if int64((float64(stfs.Free)/float64(stfs.Total))*100) <= fs.minFreeDisk { // Remove 5% from total space for cumulative disk space used for journalling, inodes etc.
availableDiskSpace := (float64(stfs.Free) / (float64(stfs.Total) - (0.05 * float64(stfs.Total)))) * 100
if int64(availableDiskSpace) <= fs.minFreeDisk {
return probe.NewError(RootPathFull{Path: fs.path}) return probe.NewError(RootPathFull{Path: fs.path})
} }

@ -153,7 +153,9 @@ func (fs Filesystem) NewMultipartUpload(bucket, object string) (string, *probe.E
return "", probe.NewError(err) return "", probe.NewError(err)
} }
if int64((float64(stfs.Free)/float64(stfs.Total))*100) <= fs.minFreeDisk { // Remove 5% from total space for cumulative disk space used for journalling, inodes etc.
availableDiskSpace := (float64(stfs.Free) / (float64(stfs.Total) - (0.05 * float64(stfs.Total)))) * 100
if int64(availableDiskSpace) <= fs.minFreeDisk {
return "", probe.NewError(RootPathFull{Path: fs.path}) return "", probe.NewError(RootPathFull{Path: fs.path})
} }
@ -228,7 +230,9 @@ func (fs Filesystem) CreateObjectPart(bucket, object, uploadID, expectedMD5Sum s
return "", probe.NewError(err) return "", probe.NewError(err)
} }
if int64((float64(stfs.Free)/float64(stfs.Total))*100) <= fs.minFreeDisk { // Remove 5% from total space for cumulative disk space used for journalling, inodes etc.
availableDiskSpace := (float64(stfs.Free) / (float64(stfs.Total) - (0.05 * float64(stfs.Total)))) * 100
if int64(availableDiskSpace) <= fs.minFreeDisk {
return "", probe.NewError(RootPathFull{Path: fs.path}) return "", probe.NewError(RootPathFull{Path: fs.path})
} }

@ -171,7 +171,9 @@ func (fs Filesystem) CreateObject(bucket, object, expectedMD5Sum string, size in
return ObjectMetadata{}, probe.NewError(err) return ObjectMetadata{}, probe.NewError(err)
} }
if int64((float64(stfs.Free)/float64(stfs.Total))*100) <= fs.minFreeDisk { // Remove 5% from total space for cumulative disk space used for journalling, inodes etc.
availableDiskSpace := (float64(stfs.Free) / (float64(stfs.Total) - (0.05 * float64(stfs.Total)))) * 100
if int64(availableDiskSpace) <= fs.minFreeDisk {
return ObjectMetadata{}, probe.NewError(RootPathFull{Path: fs.path}) return ObjectMetadata{}, probe.NewError(RootPathFull{Path: fs.path})
} }

@ -247,6 +247,8 @@ func serverMain(c *cli.Context) {
var minFreeDisk int64 var minFreeDisk int64
minFreeDiskSet := false minFreeDiskSet := false
// Default
minFreeDisk = 10
var expiration time.Duration var expiration time.Duration
expirationSet := false expirationSet := false

Loading…
Cancel
Save