over-provision 10GB

zhuhyc · awzhgw · commit f5627e012da8 · 2019-06-11T12:53:17.000+08:00
Signed-off-by: zhuhyc &lt;zzhniy.163.niy@163.com&gt;
diff --git a/master/data_partition_check.go b/master/data_partition_check.go
@@ -19,6 +19,7 @@ import (
 	"github.com/chubaofs/chubaofs/proto"
 	"github.com/chubaofs/chubaofs/util/log"
 	"time"
+	"github.com/chubaofs/chubaofs/util"
 )
 
 func (partition *DataPartition) checkStatus(clusterName string, needLog bool, dpTimeOutSec int64) {
@@ -36,7 +37,7 @@ func (partition *DataPartition) checkStatus(clusterName string, needLog bool, dp
 	switch len(liveReplicas) {
 	case (int)(partition.ReplicaNum):
 		partition.Status = proto.ReadOnly
-		if partition.checkReplicaStatusOnLiveNode(liveReplicas) == true && partition.isReplicaSizeAligned() {
+		if partition.checkReplicaStatusOnLiveNode(liveReplicas) == true && partition.isReplicaSizeAligned() && partition.canWrite() {
 			partition.Status = proto.ReadWrite
 		}
 	default:
@@ -49,6 +50,14 @@ func (partition *DataPartition) checkStatus(clusterName string, needLog bool, dp
 	}
 }
 
+func (partition *DataPartition) canWrite() bool {
+	avail := partition.total - partition.used
+	if int64(avail) > 10*util.GB {
+		return true
+	}
+	return false
+}
+
 func (partition *DataPartition) checkReplicaStatusOnLiveNode(liveReplicas []*DataReplica) (equal bool) {
 	for _, replica := range liveReplicas {
 		if replica.Status != proto.ReadWrite {
