iiod: thread_pool: Add function thread_pool_restart()

This function can be used to re-activate a thread pool that has been previously stopped with thread_pool_stop(). Signed-off-by: Paul Cercueil <paul@crapouillou.net>
analogdevicesinc · Jun 5, 2023 · f5f8422 · f5f8422
1 parent e26bff1
commit f5f8422
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/iiod/thread-pool.c b/iiod/thread-pool.c
@@ -185,6 +185,14 @@ bool thread_pool_is_stopped(const struct thread_pool *pool)
 	return pool->stop;
 }
 
+void thread_pool_restart(struct thread_pool *pool)
+{
+	if (pool->stop) {
+		thread_pool_purge_events(pool);
+		pool->stop = false;
+	}
+}
+
 void thread_pool_destroy(struct thread_pool *pool)
 {
 	pthread_mutex_destroy(&pool->thread_count_lock);

diff --git a/iiod/thread-pool.h b/iiod/thread-pool.h
@@ -19,6 +19,7 @@ int thread_pool_get_poll_fd(const struct thread_pool *pool);
 void thread_pool_stop(struct thread_pool *pool);
 void thread_pool_stop_and_wait(struct thread_pool *pool);
 bool thread_pool_is_stopped(const struct thread_pool *pool);
+void thread_pool_restart(struct thread_pool *pool);
 
 void thread_pool_destroy(struct thread_pool *pool);