radare2/libr/include/r_th.h
pancake 54bdfb22bd * Uppsercase classnames (rCore -> RCore)
- Fixes ruby warnings
  - Follow java syntax conventions
  - Helped to identify and fix bugs in many vapis
  - Sync swig examples
  - Add test-r_core.rb (ruby test for RCore)
* Some work in r_cons, some refactoring and cleanup
  - scr.html is now working again
  - w32 cons support should work now
  - Rename r_cons_get_columns -> r_cons_get_size()
  - But it needs more work
* Typedef all r_range, r_parse and r_anal structs
  - Add missing r_lib.pc in configure.acr
* 'make' clean now removes the libr* in swig/${LANG}/
2010-01-26 01:28:33 +01:00

68 lines
1.7 KiB
C

#ifndef _INCLUDE_R_TH_H_
#define _INCLUDE_R_TH_H_
#include "r_types.h"
#define HAVE_PTHREAD 1
#if __WINDOWS__
#include <windows.h>
#define R_TH_TID HANDLE
#define R_TH_LOCK_T CRITICAL_SECTION
#elif HAVE_PTHREAD
#define __GNU
#include <pthread.h>
#define R_TH_TID pthread_t
#define R_TH_LOCK_T pthread_mutex_t
#else
#error Threading library only supported for ptrace and w32
#endif
#define R_TH_FUNCTION(x) int (*x)(struct r_th_t *)
typedef struct r_th_lock_t {
int refs;
R_TH_LOCK_T lock;
} RThreadLock;
typedef struct r_th_t {
R_TH_TID tid;
struct r_th_lock_t lock;
R_TH_FUNCTION(fun);
void *user; // user pointer
int running;
int breaked; // thread aims to be interruped
int delay; // delay the startup of the thread N seconds
int ready; // thread is properly setup
} RThread;
typedef struct r_th_pool_t {
int size;
struct r_th_t **threads;
} RThreadPool;
#ifdef R_API
R_API struct r_th_t *r_th_new(R_TH_FUNCTION(fun), void *user, int delay);
R_API int r_th_init(struct r_th_t *th, R_TH_FUNCTION(fun), void *user, int delay);
R_API int r_th_start(struct r_th_t *th, int enable);
R_API int r_th_wait(struct r_th_t *th);
R_API int r_th_wait_async(struct r_th_t *th);
R_API void r_th_break(struct r_th_t *th);
R_API int r_th_wait(struct r_th_t *th);
R_API void *r_th_free(struct r_th_t *th);
R_API int r_th_lock_init(struct r_th_lock_t *thl);
R_API struct r_th_lock_t *r_th_lock_new();
R_API int r_th_lock_wait(struct r_th_lock_t *th);
R_API int r_th_lock_check(struct r_th_lock_t *thl);
R_API int r_th_lock_enter(struct r_th_lock_t *thl);
R_API int r_th_lock_leave(struct r_th_lock_t *thl);
R_API void *r_th_lock_free(struct r_th_lock_t *thl);
#endif
#endif