mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
7c1f50d920
The types of fields in syscall.Statfs_t varies between platforms. fs.Bavail is uint64 on Linux and int64 on FreeBSD. This is the opposite way around to fs.Bsize. For now, just coerce the Bavail to be uint64. If the VFS layer might return -1 for one or the other of these then these casts will be problematic and we'll need more safeguards.
38 lines
1.1 KiB
Go
38 lines
1.1 KiB
Go
// Copyright 2020 The NATS Authors
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
// +build !windows
|
|
|
|
package server
|
|
|
|
import (
|
|
"os"
|
|
"syscall"
|
|
)
|
|
|
|
func diskAvailable(storeDir string) int64 {
|
|
var ba int64
|
|
if _, err := os.Stat(storeDir); os.IsNotExist(err) {
|
|
os.MkdirAll(storeDir, 0755)
|
|
}
|
|
var fs syscall.Statfs_t
|
|
if err := syscall.Statfs(storeDir, &fs); err == nil {
|
|
// Estimate 75% of available storage.
|
|
ba = int64(uint64(fs.Bavail) * uint64(fs.Bsize) / 4 * 3)
|
|
} else {
|
|
// Used 1TB default as a guess if all else fails.
|
|
ba = JetStreamMaxStoreDefault
|
|
}
|
|
return ba
|
|
}
|