Add seeding time functions

Signed-off-by: Arnaud Rebillout <[email protected]>

Author: elboulangero

src/caseed.c

@@ -48,6 +48,9 @@ struct CaSeed {
 
         uint64_t n_requests;
         uint64_t n_request_bytes;
+
+        uint64_t first_step_nsec;
+        uint64_t last_step_nsec;
 };
 
 CaSeed *ca_seed_new(void) {
@@ -471,10 +474,16 @@ int ca_seed_step(CaSeed *s) {
                 return -EALREADY;
 
         if (!s->cache_chunks && !s->cache_hardlink) {
+                if (s->last_step_nsec == 0)
+                        s->last_step_nsec = now(CLOCK_MONOTONIC);
+
                 s->ready = true;
                 return CA_SEED_READY;
         }
 
+        if (s->first_step_nsec == 0)
+                s->first_step_nsec = now(CLOCK_MONOTONIC);
+
         r = ca_seed_open(s);
         if (r < 0)
                 return r;
@@ -494,6 +503,9 @@ int ca_seed_step(CaSeed *s) {
                         if (r < 0)
                                 return r;
 
+                        if (s->last_step_nsec == 0)
+                                s->last_step_nsec = now(CLOCK_MONOTONIC);
+
                         s->ready = true;
                         return CA_SEED_READY;
 
@@ -925,3 +937,21 @@ int ca_seed_get_request_bytes(CaSeed *s, uint64_t *ret) {
         *ret = s->n_request_bytes;
         return 0;
 }
+
+int ca_seed_get_seeding_time_nsec(CaSeed *s, uint64_t *ret) {
+        if (!s)
+                return -EINVAL;
+        if (!ret)
+                return -EINVAL;
+
+        if (!s->cache_chunks)
+                return -ENOTTY;
+
+        if (s->first_step_nsec == 0 || s->last_step_nsec == 0)
+                return -ENODATA;
+        if (s->first_step_nsec > s->last_step_nsec)
+                return -ENODATA;
+
+        *ret = s->last_step_nsec - s->first_step_nsec;
+        return 0;
+}

src/caseed.h

@@ -47,5 +47,6 @@ int ca_seed_get_file_root(CaSeed *s, CaFileRoot **ret);
 
 int ca_seed_get_requests(CaSeed *s, uint64_t *ret);
 int ca_seed_get_request_bytes(CaSeed *s, uint64_t *ret);
+int ca_seed_get_seeding_time_nsec(CaSeed *s, uint64_t *ret);
 
 #endif

src/casync.c

@@ -4250,6 +4250,31 @@ int ca_sync_get_seed_request_bytes(CaSync *s, uint64_t *ret) {
         return 0;
 }
 
+int ca_sync_get_seed_seeding_time_nsec(CaSync *s, uint64_t *ret) {
+        uint64_t sum = 0;
+        size_t i;
+        int r;
+
+        if (!s)
+                return -EINVAL;
+        if (!ret)
+                return -EINVAL;
+
+        /* We can sum seeding times since seeds are processed one after another */
+        for (i = 0; i < s->n_seeds; i++) {
+                uint64_t x;
+
+                r = ca_seed_get_seeding_time_nsec(s->seeds[i], &x);
+                if (r < 0)
+                        return r;
+
+                sum += x;
+        }
+
+        *ret = sum;
+        return 0;
+}
+
 int ca_sync_get_local_requests(CaSync *s, uint64_t *ret) {
         uint64_t sum;
         size_t i;

src/casync.h

@@ -152,6 +152,7 @@ int ca_sync_get_hardlink_digest(CaSync *s, CaChunkID *ret);
 
 int ca_sync_get_seed_requests(CaSync *s, uint64_t *ret);
 int ca_sync_get_seed_request_bytes(CaSync *s, uint64_t *ret);
+int ca_sync_get_seed_seeding_time_nsec(CaSync *s, uint64_t *ret);
 int ca_sync_get_local_requests(CaSync *s, uint64_t *ret);
 int ca_sync_get_local_request_bytes(CaSync *s, uint64_t *ret);
 int ca_sync_get_remote_requests(CaSync *s, uint64_t *ret);