blob: 172e6cf084f659e06177dac909e92accf1143d11 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
#pragma once
#include <stdbool.h>
#include <pthsem.h>
struct prne_worker {
void *ctx;
void *(*entry)(void*);
void (*fin)(void*);
void (*free_ctx)(void*);
pth_t pth;
};
typedef struct prne_worker prne_worker_t;
struct prne_pth_cv {
pth_mutex_t *lock;
pth_cond_t *cond;
bool broadcast;
};
typedef struct prne_pth_cv prne_pth_cv_t;
void prne_init_worker (prne_worker_t *w);
void prne_free_worker (prne_worker_t *w);
void prne_fin_worker (prne_worker_t *w);
bool prne_pth_cv_notify (prne_pth_cv_t *cv);
bool prne_pth_cond_timedwait (prne_pth_cv_t *cv, const struct timespec *timeout, bool *to_reached);
int prne_unint_pth_poll (struct pollfd *fds, nfds_t nfds, const struct timespec *timeout);
void prne_unint_pth_nanosleep (struct timespec dur);
|
