99)
1010
1111const (
12- TargetV1Version = pebble .FormatFlushableIngest
13- TargetUpgradedV1Version = pebblev2 .FormatMajorVersion (TargetV1Version )
14- TargetNewV2Version = pebblev2 .FormatFlushableIngest
12+ TargetV1Version = pebble .FormatFlushableIngest
13+ TargetV2Version = pebblev2 .FormatValueSeparation
1514)
1615
1716// There are currently two possible cases: an old database created with version 1
@@ -22,7 +21,7 @@ const (
2221func upgradeFormatIfNeeded (path string ) (pebblev2.FormatMajorVersion , error ) {
2322 desc , err := pebble .Peek (path , vfs .Default )
2423 if isNotV1 := err != nil || ! desc .Exists ; isNotV1 {
25- return TargetNewV2Version , nil
24+ return TargetV2Version , nil
2625 }
2726
2827 if isV2Supported := desc .FormatMajorVersion >= TargetV1Version ; isV2Supported {
@@ -33,7 +32,7 @@ func upgradeFormatIfNeeded(path string) (pebblev2.FormatMajorVersion, error) {
3332 if v2Format > pebblev2 .FormatNewest {
3433 return 0 , fmt .Errorf ("unknown pebble db newer format %v" , v2Format )
3534 }
36- return v2Format , nil
35+ return max ( TargetV2Version , v2Format ) , nil
3736 }
3837
3938 database , err := pebble .Open (path , & pebble.Options {
@@ -44,5 +43,5 @@ func upgradeFormatIfNeeded(path string) (pebblev2.FormatMajorVersion, error) {
4443 }
4544 defer database .Close ()
4645
47- return TargetUpgradedV1Version , nil
46+ return TargetV2Version , nil
4847}
0 commit comments