dmeventd: code mode _get_device_status

Move _get_device_status() in code.
Use dm_task_no_flush() function when reading status.
(e.g. none blocking for thins pool)

diff --git a/WHATS_NEW_DM b/WHATS_NEW_DM
index 000bddd675cab840bc0e25f97e5c1bd45e70fd8b..5f92657da584c0401363e6d5128abb770b53056a 100644 (file)
--- a/WHATS_NEW_DM
+++ b/WHATS_NEW_DM
@@ -1,5 +1,6 @@
 Version 1.02.110 - 
 ======================================
+  Dmeventd read device status with 'noflush'.
   Dmeventd closes control device when no device is monitored.
   Thin plugin for dmeventd improved percentage usage.
   Snapshot plugin for dmeventd improved percentage usage.

diff --git a/daemons/dmeventd/dmeventd.c b/daemons/dmeventd/dmeventd.c
index 26e611d19e362085ec90867275b224b7db35fda8..cde4f934191c17ae1d863b1c4f71c56ab80aaab8 100644 (file)
--- a/daemons/dmeventd/dmeventd.c
+++ b/daemons/dmeventd/dmeventd.c
@@ -570,6 +570,30 @@ fail:
        return ret;
 }
 
+static struct dm_task *_get_device_status(struct thread_status *ts)
+{
+       struct dm_task *dmt = dm_task_create(DM_DEVICE_STATUS);
+
+       if (!dmt)
+               return_NULL;
+
+       if (!dm_task_set_uuid(dmt, ts->device.uuid)) {
+               dm_task_destroy(dmt);
+               return_NULL;
+       }
+
+       /* Non-blocking status read */
+       if (!dm_task_no_flush(dmt))
+               log_warn("WARNING: Can't set no_flush for dm status.");
+
+       if (!dm_task_run(dmt)) {
+               dm_task_destroy(dmt);
+               return_NULL;
+       }
+
+       return dmt;
+}
+
 /*
  * Find an existing thread for a device.
  *
@@ -886,26 +910,6 @@ static void _monitor_unregister(void *arg)
        _unlock_mutex();
 }
 
-static struct dm_task *_get_device_status(struct thread_status *ts)
-{
-       struct dm_task *dmt = dm_task_create(DM_DEVICE_STATUS);
-
-       if (!dmt)
-               return NULL;
-
-       if (!dm_task_set_uuid(dmt, ts->device.uuid)) {
-               dm_task_destroy(dmt);
-               return NULL;
-       }
-
-       if (!dm_task_run(dmt)) {
-               dm_task_destroy(dmt);
-               return NULL;
-       }
-
-       return dmt;
-}
-
 /* Device monitoring thread. */
 static void *_monitor_thread(void *arg)
 {