Changes in uspace/lib/block/block.c [2463df9:c1f26834] in mainline

File:

• uspace/lib/block/block.c (modified) (12 diffs)

uspace/lib/block/block.c

@@ -55 +55 @@
 #include "block.h"
 
+#define MAX_WRITE_RETRIES 10
+
 /** Lock protecting the device connection list */
 static FIBRIL_MUTEX_INITIALIZE(dcl_lock);
@@ -79 +81 @@
         void *bb_buf;
         aoff64_t bb_addr;
+        aoff64_t pblocks;    /**< Number of physical blocks */
         size_t pblock_size;  /**< Physical block size. */
         cache_t *cache;
@@ -103 +106 @@
 
 static int devcon_add(service_id_t service_id, async_sess_t *sess,
-    size_t bsize, bd_t *bd)
+    size_t bsize, aoff64_t dev_size, bd_t *bd)
 {
         devcon_t *devcon;
@@ -118 +121 @@
         devcon->bb_addr = 0;
         devcon->pblock_size = bsize;
+        devcon->pblocks = dev_size;
         devcon->cache = NULL;
         
@@ -164 +168 @@
                 return rc;
         }
-        
-        rc = devcon_add(service_id, sess, bsize, bd);
+
+        aoff64_t dev_size;
+        rc = bd_get_num_blocks(bd, &dev_size);
+        if (rc != EOK) {
+                bd_close(bd);
+                async_hangup(sess);
+                return rc;
+        }
+        
+        rc = devcon_add(service_id, sess, bsize, dev_size, bd);
         if (rc != EOK) {
                 bd_close(bd);
@@ -349 +361 @@
         fibril_mutex_initialize(&b->lock);
         b->refcnt = 1;
+        b->write_failures = 0;
         b->dirty = false;
         b->toxic = false;
@@ -373 +386 @@
         block_t *b;
         link_t *link;
-
+        aoff64_t p_ba;
         int rc;
         
@@ -382 +395 @@
         
         cache = devcon->cache;
+
+        /* Check whether the logical block (or part of it) is beyond
+         * the end of the device or not.
+         */
+        p_ba = ba_ltop(devcon, ba);
+        p_ba += cache->blocks_cluster;
+        if (p_ba >= devcon->pblocks) {
+                /* This request cannot be satisfied */
+                return EIO;
+        }
+
 
 retry:
@@ -458 +482 @@
                                          * another block next time.
                                          */
-                                        fibril_mutex_unlock(&b->lock);
-                                        goto retry;
-                                }
+                                        if (b->write_failures < MAX_WRITE_RETRIES) {
+                                                b->write_failures++;
+                                                fibril_mutex_unlock(&b->lock);
+                                                goto retry;
+                                        } else {
+                                                printf("Too many errors writing block %"
+                                                    PRIuOFF64 "from device handle %" PRIun "\n"
+                                                    "SEVERE DATA LOSS POSSIBLE\n",
+                                                    b->lba, devcon->service_id);
+                                        }
+                                } else
+                                        b->write_failures = 0;
+
                                 b->dirty = false;
                                 if (!fibril_mutex_trylock(&cache->lock)) {
@@ -577 +611 @@
                 rc = write_blocks(devcon, block->pba, cache->blocks_cluster,
                     block->data, block->size);
+                if (rc == EOK)
+                        block->write_failures = 0;
                 block->dirty = false;
         }
@@ -602 +638 @@
                                  */
                                 block->refcnt++;
-                                fibril_mutex_unlock(&block->lock);
-                                fibril_mutex_unlock(&cache->lock);
-                                goto retry;
+
+                                if (block->write_failures < MAX_WRITE_RETRIES) {
+                                        block->write_failures++;
+                                        fibril_mutex_unlock(&block->lock);
+                                        fibril_mutex_unlock(&cache->lock);
+                                        goto retry;
+                                } else {
+                                        printf("Too many errors writing block %"
+                                            PRIuOFF64 "from device handle %" PRIun "\n"
+                                            "SEVERE DATA LOSS POSSIBLE\n",
+                                            block->lba, devcon->service_id);
+                                }
                         }
                         /*
@@ -770 +815 @@
         devcon_t *devcon = devcon_search(service_id);
         assert(devcon);
-        
+
         return bd_get_num_blocks(devcon->bd, nblocks);
 }