Less sleep

CHANGELOG.md

@@ -1,6 +1,7 @@
 # v1.9.3-alpha0
 
 * Fixed sanatize runtime checking, pr #455.
+* Replaced `ti_sleep(..)` with `sched_yield()` with a few exceptions, pr #456.
 
 # v1.9.2
 

inc/ti/version.h

@@ -25,7 +25,7 @@
  *  "-rc0"
  *  ""
  */
-#define TI_VERSION_PRE_RELEASE "-alpha0"
+#define TI_VERSION_PRE_RELEASE "-alpha1"
 
 #define TI_MAINTAINER \
     "Jeroen van der Heijden <jeroen@cesbit.com>"

src/ti/archive.c

@@ -186,7 +186,7 @@ static int archive__to_disk(void)
 
         ti_cpkg_drop(cpkg);
 
-        (void) ti_sleep(10);
+        (void) sched_yield();
     }
     while ((cpkg = queue_shift(archive->queue)));
 
@@ -425,7 +425,7 @@ int ti_archive_to_disk(void)
         (void) ti_store_store();
 
     /* sleep a little before archiving */
-    (void) ti_sleep(200);
+    (void) ti_sleep(100);
 
     /* archive changes, even after full store for synchronizing `other` nodes */
     if (archive__to_disk())

src/ti/collection.c

@@ -539,7 +539,7 @@ int ti_collection_gc(ti_collection_t * collection, _Bool do_mark_things)
         /* Release the lock */
         uv_mutex_unlock(collection->lock);
 
-        (void) ti_sleep(5);
+        (void) sched_yield();
     }
 
     uv_mutex_lock(collection->lock);
@@ -601,7 +601,7 @@ int ti_collection_gc(ti_collection_t * collection, _Bool do_mark_things)
     /* Release the lock and let the thread sleep some time */
     uv_mutex_unlock(collection->lock);
 
-    (void) ti_sleep(5);
+    (void) sched_yield();
 
     /* Take a new lock */
     uv_mutex_lock(collection->lock);
@@ -626,7 +626,7 @@ int ti_collection_gc(ti_collection_t * collection, _Bool do_mark_things)
     /* Finished, release the collection lock */
     uv_mutex_unlock(collection->lock);
 
-    (void) ti_sleep(2);
+    (void) sched_yield();
 
     ti_counters_add_garbage_collected(n);
 

src/ti/collections.c

@@ -79,7 +79,7 @@ int ti_collections_gc(void)
             rc = -1;
         }
 
-        (void) ti_sleep(100);
+        (void) sched_yield();
     }
 
     return rc;

src/ti/qcache.c

@@ -187,8 +187,7 @@ void ti_qcache_cleanup(void)
         return;
 
     (void) smap_values(qcache, (smap_val_cb) qcache__cleanup_cb, &w);
-
-    (void) ti_sleep(100);
+    (void) sched_yield();
 
     log_info("removed %u item(s) from query cache", w.qcached->n);
 

src/ti/store.c

@@ -202,7 +202,7 @@ int ti_store_store(void)
         log_errno_file("cannot create directory", errno, store->tmp_path);
     }
 
-    (void) ti_sleep(5);
+    (void) sched_yield();
 
     store__set_filename(/* use_tmp: */ true);
 
@@ -231,7 +231,7 @@ int ti_store_store(void)
         if (!store_collection)
             goto failed;
 
-        (void) ti_sleep(2);
+        (void) sched_yield();
 
         rc = mkdir(store_collection->collection_path, FX_DEFAULT_DIR_ACCESS);
         if (rc)
@@ -286,7 +286,7 @@ int ti_store_store(void)
     }
 
     (void) rename(store->store_path, store->prev_path);
-    (void) ti_sleep(2);
+    (void) sched_yield();
 
     if (rename(store->tmp_path, store->store_path))
     {
@@ -297,9 +297,9 @@ int ti_store_store(void)
         goto failed;
     }
 
-    (void) ti_sleep(2);
+    (void) sched_yield();
     (void) fx_rmdir(store->prev_path);
-    (void) ti_sleep(2);
+    (void) sched_yield();
 
     store->last_stored_change_id = ti.node->ccid;
 

src/ti/store/storeaccess.c

@@ -44,7 +44,7 @@ int ti_store_access_store(const vec_t * access, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storecollection.c

@@ -120,7 +120,7 @@ int ti_store_collection_store(ti_collection_t * collection, const char * fn)
     if (rc == 0)
         log_debug("stored collection info to file: `%s`", fn);
 
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return rc;
 }
 

src/ti/store/storecollections.c

@@ -55,7 +55,7 @@ int ti_store_collections_store(const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storecommits.c

@@ -52,7 +52,7 @@ int ti_store_commits_store(vec_t * commits, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storeenums.c

@@ -78,7 +78,7 @@ int ti_store_enums_store(ti_enums_t * enums, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storegcollect.c

@@ -55,7 +55,7 @@ int ti_store_gcollect_store(queue_t * queue, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 
@@ -138,7 +138,7 @@ int ti_store_gcollect_store_data(queue_t * queue, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storemodules.c

@@ -62,7 +62,7 @@ int ti_store_modules_store(const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storenamedrooms.c

@@ -53,7 +53,7 @@ int ti_store_named_rooms_store(smap_t * named_rooms, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storenames.c

@@ -38,7 +38,7 @@ int ti_store_names_store(const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storeprocedures.c

@@ -53,7 +53,7 @@ int ti_store_procedures_store(smap_t * procedures, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storestatus.c

@@ -36,7 +36,7 @@ int ti_store_status_store(const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storetasks.c

@@ -62,7 +62,7 @@ int ti_store_tasks_store(vec_t * vtasks, const char * fn)
         return -1;
     }
 
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storethings.c

@@ -76,7 +76,7 @@ int ti_store_things_store(imap_t * things, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 
@@ -155,7 +155,7 @@ int ti_store_things_store_data(imap_t * things, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storetypes.c

@@ -160,7 +160,7 @@ int ti_store_types_store(ti_types_t * types, const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }
 

src/ti/store/storeusers.c

@@ -90,7 +90,7 @@ int ti_store_users_store(const char * fn)
         log_errno_file("cannot close file", errno, fn);
         return -1;
     }
-    (void) ti_sleep(5);
+    (void) sched_yield();
     return 0;
 }