peerstreamer-src / src / task_manager.h @ 9eb656e7
History | View | Annotate | Download (1.97 KB)
1 | 9eb656e7 | Luca Baldesi | /*******************************************************************
|
---|---|---|---|
2 | * PeerStreamer-ng is a P2P video streaming application exposing a ReST
|
||
3 | * interface.
|
||
4 | * Copyright (C) 2017 Luca Baldesi <luca.baldesi@unitn.it>
|
||
5 | *
|
||
6 | * This program is free software: you can redistribute it and/or modify
|
||
7 | * it under the terms of the GNU Affero General Public License as published by
|
||
8 | * the Free Software Foundation, either version 3 of the License, or
|
||
9 | * (at your option) any later version.
|
||
10 | *
|
||
11 | * This program is distributed in the hope that it will be useful,
|
||
12 | * but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
13 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
14 | * GNU Affero General Public License for more details.
|
||
15 | *
|
||
16 | * You should have received a copy of the GNU Affero General Public License
|
||
17 | * along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
18 | *******************************************************************/
|
||
19 | |||
20 | #ifndef __TASK_MANAGER__
|
||
21 | #define __TASK_MANAGER__ 1 |
||
22 | |||
23 | #include<stdint.h> |
||
24 | #include <sys/select.h> |
||
25 | |||
26 | typedef uint16_t timeout;
|
||
27 | |||
28 | struct periodic_task;
|
||
29 | |||
30 | struct task_manager;
|
||
31 | |||
32 | typedef uint8_t (*periodic_task_callback)(int ret, fd_set * readfds, fd_set * writefds, fd_set * errfds); |
||
33 | |||
34 | typedef uint8_t (*periodic_task_reinit)(struct periodic_task * pt); |
||
35 | |||
36 | struct task_manager * task_manager_new();
|
||
37 | |||
38 | void task_manager_destroy(struct task_manager **tm); |
||
39 | |||
40 | struct periodic_task * task_manager_new_task(struct task_manager *tm, periodic_task_reinit reinit, periodic_task_callback callback, timeout to); |
||
41 | |||
42 | void task_manager_destroy_task(struct task_manager * tm, struct periodic_task ** pt); |
||
43 | |||
44 | int task_manager_poll(struct task_manager * tm, timeout to); |
||
45 | |||
46 | /**** WARNING: the following do not have test cases ********/
|
||
47 | |||
48 | int periodic_task_writefd_add(struct periodic_task * pt, int fd); |
||
49 | |||
50 | int periodic_task_readfd_add(struct periodic_task * pt, int fd); |
||
51 | |||
52 | int periodic_task_errfd_add(struct periodic_task * pt, int fd); |
||
53 | |||
54 | int periodic_task_reset_timeout(struct periodic_task * pt, timeout to); |
||
55 | |||
56 | #endif |