blob: 2cc4edb4dd65561a54b4ecaf728ddc404f0db757 (
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
#ifndef TRITON_H
#define TRITON_H
#include <sys/time.h>
#include <pthread.h>
#include <sys/epoll.h>
#include "list.h"
#include "spinlock.h"
struct triton_thread_t
{
struct list_head entry;
struct list_head entry2;
pthread_t thread;
int terminate:1;
struct triton_ctx_t *ctx;
};
struct triton_ctx_t
{
struct list_head entry;
struct list_head entry2;
spinlock_t lock;
struct list_head handlers;
struct list_head timers;
struct triton_thread_t *thread;
struct list_head pending_handlers;
struct list_head pending_timers;
int queued:1;
int need_close:1;
int need_free:1;
void (*close)(struct triton_ctx_t*);
void (*free)(struct triton_ctx_t*);
};
struct triton_md_handler_t
{
//triton part
//==========
struct list_head entry;
struct list_head entry2;
struct triton_ctx_t *ctx;
struct epoll_event epoll_event;
uint32_t trig_epoll_events;
int pending:1;
//=========
//user part
//=========
int fd;
int (*read)(struct triton_md_handler_t *);
int (*write)(struct triton_md_handler_t *);
//=========
};
struct triton_timer_t
{
struct list_head entry;
struct list_head entry2;
struct epoll_event epoll_event;
struct triton_ctx_t *ctx;
int fd;
int pending:1;
struct timeval expire_tv;
int period;
int (*expire)(struct triton_timer_t *);
};
struct conf_option_t
{
struct list_head entry;
char *name;
char *val;
};
struct conf_sect_t
{
const char *name;
struct list_head items;
};
void triton_register_ctx(struct triton_ctx_t *);
void triton_unregister_ctx(struct triton_ctx_t *);
#define MD_MODE_READ 1
#define MD_MODE_WRITE 2
void triton_md_register_handler(struct triton_md_handler_t *h);
void triton_md_unregister_handler(struct triton_md_handler_t *h);
int triton_md_enable_handler(struct triton_md_handler_t *h, int mode);
int triton_md_disable_handler(struct triton_md_handler_t *h,int mode);
int triton_timer_add(struct triton_timer_t*,int abs_time);
int triton_timer_mod(struct triton_timer_t*,int abs_time);
void triton_timer_del(struct triton_timer_t*);
struct conf_sect_t *conf_get_section(const char *name);
char *conf_get_opt(const char *sect, const char *name);
#define TRITON_OK 0
#define TRITON_ERR_NOCOMP -1
#define TRITON_ERR_NOSUPP -2
#define TRITON_ERR_NOINTF -3
#define TRITON_ERR_EXISTS -4
#define TRITON_ERR_NOCHAN -5
#define TRITON_ERR_NOMSG -6
#define TRITON_ERR_BUSY -5
int triton_init(const char *conf_file);
void triton_run(void);
void triton_terminate(void);
#define __init __attribute__((constructor))
#undef offsetof
#ifdef __compiler_offsetof
#define offsetof(TYPE,MEMBER) __compiler_offsetof(TYPE,MEMBER)
#else
#define offsetof(TYPE, MEMBER) ((size_t) &((TYPE *)0)->MEMBER)
#endif
#define container_of(ptr, type, member) ({ \
const typeof( ((type *)0)->member ) *__mptr = (ptr); \
(type *)( (char *)__mptr - offsetof(type,member) );})
#define __export __attribute__((visibility("default")))
#endif
|
