1*4882a593Smuzhiyun /*
2*4882a593Smuzhiyun * Copyright 2015 Rockchip Electronics Co. LTD
3*4882a593Smuzhiyun *
4*4882a593Smuzhiyun * Licensed under the Apache License, Version 2.0 (the "License");
5*4882a593Smuzhiyun * you may not use this file except in compliance with the License.
6*4882a593Smuzhiyun * You may obtain a copy of the License at
7*4882a593Smuzhiyun *
8*4882a593Smuzhiyun * http://www.apache.org/licenses/LICENSE-2.0
9*4882a593Smuzhiyun *
10*4882a593Smuzhiyun * Unless required by applicable law or agreed to in writing, software
11*4882a593Smuzhiyun * distributed under the License is distributed on an "AS IS" BASIS,
12*4882a593Smuzhiyun * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13*4882a593Smuzhiyun * See the License for the specific language governing permissions and
14*4882a593Smuzhiyun * limitations under the License.
15*4882a593Smuzhiyun */
16*4882a593Smuzhiyun
17*4882a593Smuzhiyun #include <unistd.h>
18*4882a593Smuzhiyun #include <errno.h>
19*4882a593Smuzhiyun #include <poll.h>
20*4882a593Smuzhiyun #include <sys/eventfd.h>
21*4882a593Smuzhiyun
22*4882a593Smuzhiyun #include "mpp_eventfd.h"
23*4882a593Smuzhiyun
mpp_eventfd_get(RK_U32 init)24*4882a593Smuzhiyun RK_S32 mpp_eventfd_get(RK_U32 init)
25*4882a593Smuzhiyun {
26*4882a593Smuzhiyun RK_S32 fd = eventfd(init, 0);
27*4882a593Smuzhiyun
28*4882a593Smuzhiyun if (fd < 0)
29*4882a593Smuzhiyun fd = errno;
30*4882a593Smuzhiyun
31*4882a593Smuzhiyun return fd;
32*4882a593Smuzhiyun }
33*4882a593Smuzhiyun
mpp_eventfd_put(RK_S32 fd)34*4882a593Smuzhiyun RK_S32 mpp_eventfd_put(RK_S32 fd)
35*4882a593Smuzhiyun {
36*4882a593Smuzhiyun if (fd >= 0)
37*4882a593Smuzhiyun close(fd);
38*4882a593Smuzhiyun
39*4882a593Smuzhiyun return 0;
40*4882a593Smuzhiyun }
41*4882a593Smuzhiyun
mpp_eventfd_read(RK_S32 fd,RK_U64 * val,RK_S64 timeout)42*4882a593Smuzhiyun RK_S32 mpp_eventfd_read(RK_S32 fd, RK_U64 *val, RK_S64 timeout)
43*4882a593Smuzhiyun {
44*4882a593Smuzhiyun RK_S32 ret = 0;
45*4882a593Smuzhiyun struct pollfd nfds;
46*4882a593Smuzhiyun RK_U64 tmp = 0;
47*4882a593Smuzhiyun
48*4882a593Smuzhiyun if (NULL == val)
49*4882a593Smuzhiyun val = &tmp;
50*4882a593Smuzhiyun
51*4882a593Smuzhiyun nfds.fd = fd;
52*4882a593Smuzhiyun nfds.events = POLLIN;
53*4882a593Smuzhiyun
54*4882a593Smuzhiyun ret = poll(&nfds, 1, timeout);
55*4882a593Smuzhiyun if (ret == 1 && (nfds.revents & POLLIN) &&
56*4882a593Smuzhiyun sizeof(RK_U64) == read(fd, val, sizeof(RK_U64))) {
57*4882a593Smuzhiyun ret = 0;
58*4882a593Smuzhiyun } else
59*4882a593Smuzhiyun ret = errno;
60*4882a593Smuzhiyun
61*4882a593Smuzhiyun return ret;
62*4882a593Smuzhiyun }
63*4882a593Smuzhiyun
mpp_eventfd_write(RK_S32 fd,RK_U64 val)64*4882a593Smuzhiyun RK_S32 mpp_eventfd_write(RK_S32 fd, RK_U64 val)
65*4882a593Smuzhiyun {
66*4882a593Smuzhiyun RK_S32 ret = 0;
67*4882a593Smuzhiyun
68*4882a593Smuzhiyun if (sizeof(RK_U64) != write(fd, &val, sizeof(val)))
69*4882a593Smuzhiyun ret = errno;
70*4882a593Smuzhiyun
71*4882a593Smuzhiyun return ret;
72*4882a593Smuzhiyun }
73