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
|
/*
* Copyright (c) 2002, Intel Corporation.
* Created by: julie.n.fleischer REMOVE-THIS AT intel DOT com
* This file is licensed under the GPL license. For the full content
* of this license, see the COPYING file at the top level of this
* source tree.
*/
#include <sys/select.h>
int sync_pipe_create(int fd[])
{
return pipe (fd);
}
int sync_pipe_close(int fd[])
{
int r = 0;
if (fd[0] != -1)
r = close (fd[0]);
if (fd[1] != -1)
r |= close (fd[1]);
return r;
}
int sync_pipe_wait(int fd[])
{
char buf;
int r;
if (fd[1] != -1) {
close (fd[1]);
fd[1] = -1;
}
r = read (fd[0], &buf, 1);
if ((r != 1) || (buf != 'A'))
return -1;
return 0;
}
int sync_pipe_wait_select(int fd[], long tv_sec)
{
int r;
fd_set rfds;
struct timeval tv;
int err;
tv.tv_sec = tv_sec;
tv.tv_usec = 0;
if (fd[1] != -1) {
close (fd[1]);
fd[1] = -1;
}
FD_ZERO(&rfds);
FD_SET(fd[0], &rfds);
r = select(fd[0] + 1, &rfds, NULL, NULL, &tv);
err = errno;
if (FD_ISSET(fd[0], &rfds)) {
return sync_pipe_wait(fd);
}
return r ? err : -ETIMEDOUT;
}
int sync_pipe_notify(int fd[])
{
char buf = 'A';
int r;
if (fd[0] != -1) {
close (fd[0]);
fd[0] = -1;
}
r = write (fd[1], &buf, 1);
if (r != 1)
return -1;
return 0;
}
|
