[thirdparty/xfsprogs-dev.git] / libfrog / workqueue.h

// SPDX-License-Identifier: GPL-2.0+
/*
 * Copyright (C) 2017 Oracle.  All Rights Reserved.
 * Author: Darrick J. Wong <darrick.wong@oracle.com>
 */
#ifndef	__LIBFROG_WORKQUEUE_H__
#define	__LIBFROG_WORKQUEUE_H__

#include <pthread.h>

struct workqueue;

typedef void workqueue_func_t(struct workqueue *wq, uint32_t index, void *arg);

struct workqueue_item {
	struct workqueue	*queue;
	struct workqueue_item	*next;
	workqueue_func_t	*function;
	void			*arg;
	uint32_t		index;
};

struct workqueue {
	void			*wq_ctx;
	pthread_t		*threads;
	struct workqueue_item	*next_item;
	struct workqueue_item	*last_item;
	pthread_mutex_t		lock;
	pthread_cond_t		wakeup;
	unsigned int		item_count;
	unsigned int		thread_count;
	bool			terminate;
	bool			terminated;
};

int workqueue_create(struct workqueue *wq, void *wq_ctx,
		unsigned int nr_workers);
int workqueue_add(struct workqueue *wq, workqueue_func_t fn,
		uint32_t index, void *arg);
int workqueue_terminate(struct workqueue *wq);
void workqueue_destroy(struct workqueue *wq);

#endif	/* __LIBFROG_WORKQUEUE_H__ */
Commit	Line	Data
959ef981	1	// SPDX-License-Identifier: GPL-2.0+
f434fd95 DW	2	/*
f434fd95 DW	3	* Copyright (C) 2017 Oracle. All Rights Reserved.
f434fd95	4	* Author: Darrick J. Wong <darrick.wong@oracle.com>
f434fd95	5	*/
56598728 DW	6	#ifndef __LIBFROG_WORKQUEUE_H__
56598728 DW	7	#define __LIBFROG_WORKQUEUE_H__
f434fd95	8
40b2e298 BS	9	#include <pthread.h>
40b2e298 BS	10
f434fd95 DW	11	struct workqueue;
	12
	13	typedef void workqueue_func_t(struct workqueue wq, uint32_t index, void arg);
	14
	15	struct workqueue_item {
	16	struct workqueue *queue;
	17	struct workqueue_item *next;
	18	workqueue_func_t *function;
	19	void *arg;
	20	uint32_t index;
	21	};
	22
	23	struct workqueue {
	24	void *wq_ctx;
	25	pthread_t *threads;
	26	struct workqueue_item *next_item;
	27	struct workqueue_item *last_item;
	28	pthread_mutex_t lock;
	29	pthread_cond_t wakeup;
	30	unsigned int item_count;
	31	unsigned int thread_count;
	32	bool terminate;
71296cf8	33	bool terminated;
f434fd95 DW	34	};
	35
	36	int workqueue_create(struct workqueue wq, void wq_ctx,
	37	unsigned int nr_workers);
	38	int workqueue_add(struct workqueue *wq, workqueue_func_t fn,
	39	uint32_t index, void *arg);
71296cf8	40	int workqueue_terminate(struct workqueue *wq);
f434fd95 DW	41	void workqueue_destroy(struct workqueue *wq);
f434fd95 DW	42
56598728	43	#endif /* __LIBFROG_WORKQUEUE_H__ */