atomics.h
No OneTemporary
Actions

Size

646 B

Referenced Files

None

Subscribers

None

atomics.h
View Options

	#ifndef ATOMICS_H
	#define ATOMICS_H

	#include <stdint.h>
	#include <pthread.h>

	void init_atomics_module(void);

	typedef struct WaitQueueEntry {
	pthread_cond_t cond;
	pthread_mutex_t mutex;
	int32_t *address;
	int notified;
	struct WaitQueueEntry *next;
	} WaitQueueEntry;

	typedef struct {
	WaitQueueEntry *head;
	pthread_mutex_t lock;
	} WaitQueue;

	void wait_queue_init(WaitQueue *queue);
	void wait_queue_cleanup(WaitQueue *queue);

	void wait_queue_add(WaitQueue queue, WaitQueueEntry entry);
	void wait_queue_remove(WaitQueue queue, WaitQueueEntry entry);
	int wait_queue_notify(WaitQueue queue, int32_t address, int count);

	#endif