diff --git a/test/unit/lib/blob/bs_dev_common.c b/test/unit/lib/blob/bs_dev_common.c
index fe3105269..4e94fef8b 100644
--- a/test/unit/lib/blob/bs_dev_common.c
+++ b/test/unit/lib/blob/bs_dev_common.c
@@ -42,6 +42,63 @@ uint8_t *g_dev_buffer;
 uint64_t g_dev_write_bytes;
 uint64_t g_dev_read_bytes;
 
+struct spdk_power_failure_counters {
+	uint64_t general_counter;
+	uint64_t read_counter;
+	uint64_t write_counter;
+	uint64_t unmap_counter;
+	uint64_t write_zero_counter;
+	uint64_t flush_counter;
+};
+
+static struct spdk_power_failure_counters g_power_failure_counters = {};
+
+struct spdk_power_failure_thresholds {
+	uint64_t general_threshold;
+	uint64_t read_threshold;
+	uint64_t write_threshold;
+	uint64_t unmap_threshold;
+	uint64_t write_zero_threshold;
+	uint64_t flush_threshold;
+};
+
+static struct spdk_power_failure_thresholds g_power_failure_thresholds = {};
+
+static uint64_t g_power_failure_rc;
+
+void dev_reset_power_failure_event(void);
+void dev_reset_power_failure_counters(void);
+void dev_set_power_failure_thresholds(struct spdk_power_failure_thresholds thresholds);
+
+void
+dev_reset_power_failure_event(void)
+{
+	memset(&g_power_failure_counters, 0, sizeof(g_power_failure_counters));
+	memset(&g_power_failure_thresholds, 0, sizeof(g_power_failure_thresholds));
+	g_power_failure_rc = 0;
+}
+
+void
+dev_reset_power_failure_counters(void)
+{
+	memset(&g_power_failure_counters, 0, sizeof(g_power_failure_counters));
+	g_power_failure_rc = 0;
+}
+
+/**
+ * Set power failure event. Power failure will occur after given number
+ * of IO operations. It may occure after number of particular operations
+ * (read, write, unmap, write zero or flush) or after given number of
+ * any IO operations (general_treshold). Value 0 means that the treshold
+ * is disabled. Any other value is the number of operation starting from
+ * which power failure event will happen.
+ */
+void
+dev_set_power_failure_thresholds(struct spdk_power_failure_thresholds thresholds)
+{
+	g_power_failure_thresholds = thresholds;
+}
+
 /* Define here for UT only. */
 struct spdk_io_channel g_io_channel;
 
@@ -68,7 +125,7 @@ dev_complete_cb(void *arg)
 {
 	struct spdk_bs_dev_cb_args *cb_args = arg;
 
-	cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, 0);
+	cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, g_power_failure_rc);
 }
 
 static void
@@ -84,11 +141,28 @@ dev_read(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload
 {
 	uint64_t offset, length;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	memcpy(payload, &g_dev_buffer[offset], length);
-	g_dev_read_bytes += length;
+	if (g_power_failure_thresholds.read_threshold != 0) {
+		g_power_failure_counters.read_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.read_threshold == 0 ||
+	     g_power_failure_counters.read_counter < g_power_failure_thresholds.read_threshold) &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+
+		memcpy(payload, &g_dev_buffer[offset], length);
+		g_dev_read_bytes += length;
+	} else {
+		g_power_failure_rc = -EIO;
+	}
+
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -99,11 +173,28 @@ dev_write(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payloa
 {
 	uint64_t offset, length;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	memcpy(&g_dev_buffer[offset], payload, length);
-	g_dev_write_bytes += length;
+	if (g_power_failure_thresholds.write_threshold != 0) {
+		g_power_failure_counters.write_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.write_threshold == 0 ||
+	     g_power_failure_counters.write_counter < g_power_failure_thresholds.write_threshold) &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+
+		memcpy(&g_dev_buffer[offset], payload, length);
+		g_dev_write_bytes += length;
+	} else {
+		g_power_failure_rc = -EIO;
+	}
+
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -128,17 +219,33 @@ dev_readv(struct spdk_bs_dev *dev, struct spdk_io_channel *channel,
 	uint64_t offset, length;
 	int i;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	__check_iov(iov, iovcnt, length);
-
-	for (i = 0; i < iovcnt; i++) {
-		memcpy(iov[i].iov_base, &g_dev_buffer[offset], iov[i].iov_len);
-		offset += iov[i].iov_len;
+	if (g_power_failure_thresholds.read_threshold != 0) {
+		g_power_failure_counters.read_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.read_threshold == 0 ||
+	     g_power_failure_counters.read_counter < g_power_failure_thresholds.read_threshold) &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+		__check_iov(iov, iovcnt, length);
+
+		for (i = 0; i < iovcnt; i++) {
+			memcpy(iov[i].iov_base, &g_dev_buffer[offset], iov[i].iov_len);
+			offset += iov[i].iov_len;
+		}
+
+		g_dev_read_bytes += length;
+	} else {
+		g_power_failure_rc = -EIO;
 	}
 
-	g_dev_read_bytes += length;
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -151,17 +258,33 @@ dev_writev(struct spdk_bs_dev *dev, struct spdk_io_channel *channel,
 	uint64_t offset, length;
 	int i;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	__check_iov(iov, iovcnt, length);
-
-	for (i = 0; i < iovcnt; i++) {
-		memcpy(&g_dev_buffer[offset], iov[i].iov_base, iov[i].iov_len);
-		offset += iov[i].iov_len;
+	if (g_power_failure_thresholds.write_threshold != 0) {
+		g_power_failure_counters.write_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.write_threshold == 0 ||
+	     g_power_failure_counters.write_counter < g_power_failure_thresholds.write_threshold)  &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+		__check_iov(iov, iovcnt, length);
+
+		for (i = 0; i < iovcnt; i++) {
+			memcpy(&g_dev_buffer[offset], iov[i].iov_base, iov[i].iov_len);
+			offset += iov[i].iov_len;
+		}
+
+		g_dev_write_bytes += length;
+	} else {
+		g_power_failure_rc = -EIO;
 	}
 
-	g_dev_write_bytes += length;
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -169,6 +292,21 @@ static void
 dev_flush(struct spdk_bs_dev *dev, struct spdk_io_channel *channel,
 	  struct spdk_bs_dev_cb_args *cb_args)
 {
+	if (g_power_failure_thresholds.flush_threshold != 0) {
+		g_power_failure_counters.flush_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.flush_threshold != 0 &&
+	     g_power_failure_counters.flush_counter >= g_power_failure_thresholds.flush_threshold)  ||
+	    (g_power_failure_thresholds.general_threshold != 0 &&
+	     g_power_failure_counters.general_counter >= g_power_failure_thresholds.general_threshold)) {
+		g_power_failure_rc = -EIO;
+	}
+
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -179,10 +317,26 @@ dev_unmap(struct spdk_bs_dev *dev, struct spdk_io_channel *channel,
 {
 	uint64_t offset, length;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	memset(&g_dev_buffer[offset], 0, length);
+	if (g_power_failure_thresholds.unmap_threshold != 0) {
+		g_power_failure_counters.unmap_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.unmap_threshold == 0 ||
+	     g_power_failure_counters.unmap_counter < g_power_failure_thresholds.unmap_threshold)  &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+		memset(&g_dev_buffer[offset], 0, length);
+	} else {
+		g_power_failure_rc = -EIO;
+	}
+
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }
 
@@ -193,11 +347,27 @@ dev_write_zeroes(struct spdk_bs_dev *dev, struct spdk_io_channel *channel,
 {
 	uint64_t offset, length;
 
-	offset = lba * dev->blocklen;
-	length = lba_count * dev->blocklen;
-	SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
-	memset(&g_dev_buffer[offset], 0, length);
-	g_dev_write_bytes += length;
+	if (g_power_failure_thresholds.write_zero_threshold != 0) {
+		g_power_failure_counters.write_zero_counter++;
+	}
+
+	if (g_power_failure_thresholds.general_threshold != 0) {
+		g_power_failure_counters.general_counter++;
+	}
+
+	if ((g_power_failure_thresholds.write_zero_threshold == 0 ||
+	     g_power_failure_counters.write_zero_counter < g_power_failure_thresholds.write_zero_threshold)  &&
+	    (g_power_failure_thresholds.general_threshold == 0 ||
+	     g_power_failure_counters.general_counter < g_power_failure_thresholds.general_threshold)) {
+		offset = lba * dev->blocklen;
+		length = lba_count * dev->blocklen;
+		SPDK_CU_ASSERT_FATAL(offset + length <= DEV_BUFFER_SIZE);
+		memset(&g_dev_buffer[offset], 0, length);
+		g_dev_write_bytes += length;
+	} else {
+		g_power_failure_rc = -EIO;
+	}
+
 	spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args);
 }