blob: 41223cb577080910b30b264ef3f0508b8c8c078a (
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
#ifndef FQM_H
#define FQM_H
#include "thread.h"
#define REQHANDLER(func) int func(struct _request_t *req, reqthread_t *self)
enum _status_t { IDLE, BUSY, NOALLOC };
typedef enum _status_t status_t;
struct _reqthread_t {
struct _fqm_t *fqm;
thread_t *tid;
void *arg;
int dieflag;
status_t status;
};
typedef struct _reqthread_t reqthread_t;
struct _request_t {
REQHANDLER((*req_handler));
char *req;
int sock;
short reqid;
struct _request_t *next;
};
typedef struct _request_t request_t;
struct _fqm_t {
cond_t *q_cond;
cond_t *t_cond;
request_t *sreq, *ereq;
reqthread_t **tids;
int maxitems;
int nitems;
};
typedef struct _fqm_t fqm_t;
request_t *req_new(int sock, short reqid, REQHANDLER((*req_handler)),
const char *reqstr, int reqlen);
void req_delete(request_t *req);
fqm_t *fqm_new(int maxitems);
void fqm_delete(fqm_t *fqm);
int fqm_changemaxitems(fqm_t *fqm, int maxitems);
int fqm_push(fqm_t *fqm, request_t *req);
#endif
|
