blob: 0a345c16e17811ee93448508bdca07063be23479 (
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
|
#include <__aio.h>
#include <aio.h>
#include <errno.h>
#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <sys/eventfd.h>
#include <unistd.h>
#include <stdint.h>
int lio_listio(int mode, struct aiocb *restrict const list[restrict], int nent,
struct sigevent *restrict sig)
{
struct lio_group *grp = NULL;
if ((void *)list == NULL || nent <= 0) {
errno = EINVAL;
return -1;
}
if (mode != LIO_WAIT && mode != LIO_NOWAIT) {
errno = EINVAL;
return -1;
}
grp = malloc(sizeof(*grp));
memset(grp, 0, sizeof(*grp));
grp->eventfd = eventfd(0, EFD_CLOEXEC);
grp->sig = sig;
for (int i = 0; i < nent; i++) {
int ret;
struct aio_request *req;
struct aiocb *aiocbp = list[i];
if (aiocbp == NULL) {
continue;
}
switch (aiocbp->aio_lio_opcode) {
case LIO_READ:
ret = aio_read(aiocbp);
break;
case LIO_WRITE:
ret = aio_write(aiocbp);
break;
case LIO_NOP:
ret = 0;
continue;
default:
errno = EINVAL;
return -1;
}
if (ret < 0) {
return -1;
}
req = __aio_lookup(aiocbp);
req->grp = grp;
grp->pending++;
}
if (mode == LIO_NOWAIT) {
return 0;
}
while (grp->pending > 0) {
uint64_t val;
if (read(grp->eventfd, &val, sizeof(val)) < 0) {
return -1;
}
}
if (grp->error) {
errno = EIO;
return -1;
}
return 0;
}
|
