blob: 19216091723a1c921469f280b8093cf2f46c34f7 (
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
|
/* Read from stdin and have an active fiber in the background.
* Stdin needs to be redirected to FIFO or similar; mixing
* console and non-blocking I/O is not a good idea.
*/
#include <libtf/tf.h>
#include <stdio.h>
#include <unistd.h>
static void time_fiber(void *ptr)
{
while (1) {
printf("Tick\n");
tf_msleep(1000);
printf("Tack\n");
tf_msleep(1000);
}
}
static void io_fiber(void *ptr)
{
char data[8];
struct tf_fd fin;
tf_open_fd(&fin, STDIN_FILENO);
while (1) {
if (tf_read(&fin, data, sizeof(data), TF_INFINITE) < 0)
break;
printf("Read: %8.8s\n", data);
}
printf("Exiting io fiber\n");
tf_close(&fin);
}
static void init_fiber(void *ptr)
{
tf_fiber_put(tf_fiber_create(time_fiber, 0));
tf_fiber_put(tf_fiber_create(io_fiber, 0));
}
int main(int argc, char **argv)
{
return tf_main(init_fiber);
}
|
