Reading an uncommitted block which has been deleted from buffer cache

CHANGELOG.md

@@ -3,7 +3,7 @@
 **Bug Fixes**
 - Flush shall only sync the blocks to storage and not delete them from local cache.
 - Random write has been re-enabled in block cache.
-- Writing to an uncommitted block which has been deleted from the in-memory cache.
+- Reading or writing to an uncommitted block which has been deleted from the in-memory cache.
 - Check download status of a block before updating and return error if it failed to download.
 
 ## 2.3.1 (Unreleased)

azure-pipeline-templates/verbose-tests.yml

@@ -177,7 +177,7 @@ steps:
       distro_name: ${{ parameters.distro_name }}
       quick_test: false
       verbose_log: ${{ parameters.verbose_log }}
-      clone: true
+      clone: false
 
   - ${{ if eq(parameters.test_sas_credential, true) }}:
     - template: e2e-tests.yml
@@ -385,4 +385,4 @@ steps:
           ${{ parameters.working_dir }}/blobfuse2 mount ${{ parameters.mount_dir }} --config-file=${{ parameters.config }}
           --default-working-dir=${{ parameters.working_dir }}
         displayName: 'HugeList: Mount'
-        continueOnError: false
+        continueOnError: false

cmd/health-monitor.go

@@ -132,7 +132,7 @@ func validateHMonOptions() error {
 	}
 
 	if len(errMsg) != 0 {
-		return fmt.Errorf(errMsg)
+		return fmt.Errorf("%s", errMsg)
 	}
 
 	return nil

cmd/mount.go

@@ -754,5 +754,5 @@ func init() {
 
 func Destroy(message string) error {
 	_ = log.Destroy()
-	return fmt.Errorf(message)
+	return fmt.Errorf("%s", message)
 }

component/azstorage/azauthmsi.go

@@ -97,7 +97,7 @@ func (azmsi *azAuthMSI) getTokenCredentialUsingCLI() (azcore.TokenCredential, er
 		if msg == "" {
 			msg = err.Error()
 		}
-		return nil, fmt.Errorf(msg)
+		return nil, fmt.Errorf("%s", msg)
 	}
 
 	log.Info("azAuthMSI::getTokenCredentialUsingCLI : Successfully logged in using Azure CLI")

component/block_cache/block.go

@@ -51,6 +51,14 @@ const (
 	BlockFlagFailed             // Block upload/download has failed
 )
 
+// Flags to denote the status of upload/download of a block
+const (
+	BlockStatusDownloaded     int = iota + 1 // Download of this block is complete
+	BlockStatusUploaded                      // Upload of this block is complete
+	BlockStatusDownloadFailed                // Download of this block has failed
+	BlockStatusUploadFailed                  // Upload of this block has failed
+)
+
 // Block is a memory mapped buffer with its state to hold data
 type Block struct {
 	offset   uint64          // Start offset of the data this block holds
@@ -127,9 +135,9 @@ func (b *Block) Uploading() {
 }
 
 // Ready marks this Block is now ready for reading by its first reader (data download completed)
-func (b *Block) Ready() {
+func (b *Block) Ready(val int) {
 	select {
-	case b.state <- 1:
+	case b.state <- val:
 		break
 	default:
 		break