Compare commits
185 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0598a791bf | ||
|
|
e215682be2 | ||
|
|
8ddde74704 | ||
|
|
990ab03d70 | ||
|
|
98decd24e2 | ||
|
|
1c549c3ab7 | ||
|
|
dcaa6606e0 | ||
|
|
4a7e05917f | ||
|
|
f8325fba92 | ||
|
|
71e9ea6664 | ||
|
|
e9fa25980b | ||
|
|
2ce1a56c40 | ||
|
|
f8a135487d | ||
|
|
07af653b17 | ||
|
|
78bb46e678 | ||
|
|
fa78be3f47 | ||
|
|
469cb335c1 | ||
|
|
8dc6115127 | ||
|
|
8223744d7b | ||
|
|
81411367b5 | ||
|
|
126c00944c | ||
|
|
532d57ed31 | ||
|
|
8128da416c | ||
|
|
4fe5f50f22 | ||
|
|
efa35adbc5 | ||
|
|
3ad20d71ff | ||
|
|
4536518f8a | ||
|
|
bb6c522d8f | ||
|
|
d272c5188d | ||
|
|
dd7dd6fcd9 | ||
|
|
c57eb84863 | ||
|
|
8cd6e896cd | ||
|
|
d87deefada | ||
|
|
a11398b1c5 | ||
|
|
8c98df30da | ||
|
|
d5f8f5f1b1 | ||
|
|
a627f365fd | ||
|
|
027fb4a419 | ||
|
|
7080d540e2 | ||
|
|
017fa62aac | ||
|
|
06dd355e33 | ||
|
|
20af8d02c7 | ||
|
|
cf4530307f | ||
|
|
0088a1f263 | ||
|
|
4727adafb7 | ||
|
|
65b4e44abd | ||
|
|
e9bf27c395 | ||
|
|
adf44ab203 | ||
|
|
f196d9fc31 | ||
|
|
870273c60d | ||
|
|
ec78f05d70 | ||
|
|
2cd1a594d4 | ||
|
|
b7289278e1 | ||
|
|
b55b10a934 | ||
|
|
210f4f8fba | ||
|
|
fca062c60d | ||
|
|
11633bf403 | ||
|
|
1bc78625f0 | ||
|
|
97276ce4dd | ||
|
|
a82802933a | ||
|
|
653545fd35 | ||
|
|
7274ddd9fb | ||
|
|
6cf7a01f4a | ||
|
|
bf5e17e5c5 | ||
|
|
5c32cea921 | ||
|
|
8b7b340610 | ||
|
|
a9e78ad9b5 | ||
|
|
d6144b2e83 | ||
|
|
43f8095c14 | ||
|
|
f5ad7a4657 | ||
|
|
040ba6e466 | ||
|
|
0857889a0f | ||
|
|
61a794d0fb | ||
|
|
9a2efd9db7 | ||
|
|
21deebe236 | ||
|
|
006dc04624 | ||
|
|
dc895c6dec | ||
|
|
4a741f3271 | ||
|
|
ec63f7f473 | ||
|
|
d78d67632d | ||
|
|
f704614aa2 | ||
|
|
02bddcd1a9 | ||
|
|
5dacd46a94 | ||
|
|
e61acfab97 | ||
|
|
f813598587 | ||
|
|
9fa0461e33 | ||
|
|
95c6d8b7a1 | ||
|
|
6e50accebe | ||
|
|
44f357ab2e | ||
|
|
dd65a0c06b | ||
|
|
74e6f02ee4 | ||
|
|
49146ab381 | ||
|
|
513410278d | ||
|
|
e7e2cd478a | ||
|
|
4e685dcf29 | ||
|
|
6146716d4a | ||
|
|
64b714ab36 | ||
|
|
613a821a30 | ||
|
|
8f4d4e9602 | ||
|
|
042bfd32f3 | ||
|
|
bcc72f8ec5 | ||
|
|
4e21e8411e | ||
|
|
cb50462b77 | ||
|
|
52e3f7d596 | ||
|
|
3e2cc6379f | ||
|
|
73af86d1f5 | ||
|
|
a919a57ad2 | ||
|
|
2e882a5dfe | ||
|
|
0a817e84ec | ||
|
|
3098a3cda5 | ||
|
|
a60d90a26a | ||
|
|
fa16c36d95 | ||
|
|
354e56be7e | ||
|
|
3e3251e0d9 | ||
|
|
e3c63df748 | ||
|
|
24dda1ef62 | ||
|
|
8e4f574d37 | ||
|
|
f00c18e323 | ||
|
|
1e5def7413 | ||
|
|
52c9a3722a | ||
|
|
3512e8324a | ||
|
|
33a6ee6889 | ||
|
|
2e4627ba4a | ||
|
|
6f6c32628a | ||
|
|
b9b4cc7686 | ||
|
|
7c57e19298 | ||
|
|
74d7624afd | ||
|
|
fb9820b06c | ||
|
|
55d08bee97 | ||
|
|
5b7b5b0ed4 | ||
|
|
0fbf0e2b0e | ||
|
|
7c52fee8be | ||
|
|
279315afcd | ||
|
|
c3506ab046 | ||
|
|
3315e2fb1b | ||
|
|
5323fa751b | ||
|
|
b895c1866e | ||
|
|
065fee7b29 | ||
|
|
6353061ecf | ||
|
|
578f056670 | ||
|
|
1714c32f13 | ||
|
|
ed63069469 | ||
|
|
45159cb572 | ||
|
|
7d5eff6737 | ||
|
|
1bcd5d35e3 | ||
|
|
564db33b82 | ||
|
|
d6845acd26 | ||
|
|
56f2d70ce3 | ||
|
|
8ac9b204da | ||
|
|
f4cfe68f5b | ||
|
|
5313db4399 | ||
|
|
df7abafe96 | ||
|
|
cab89ae16a | ||
|
|
1a8573c4c1 | ||
|
|
5bcde85f8b | ||
|
|
c07cc8f7cc | ||
|
|
dfeefa8780 | ||
|
|
6a932e0daf | ||
|
|
607ed77216 | ||
|
|
a54e813d2f | ||
|
|
2789bad793 | ||
|
|
c69f361564 | ||
|
|
ba343a0898 | ||
|
|
de68d70f9c | ||
|
|
9d61ddfddb | ||
|
|
06342920d6 | ||
|
|
e7e8385354 | ||
|
|
075e1cef0b | ||
|
|
7fc24cef64 | ||
|
|
47497ee19d | ||
|
|
002c7f0899 | ||
|
|
cb43cb5c06 | ||
|
|
2b59b3295c | ||
|
|
01714be0d2 | ||
|
|
727786c6ee | ||
|
|
7dc6890500 | ||
|
|
9799eec661 | ||
|
|
3db46f068f | ||
|
|
3fd1466c56 | ||
|
|
b5356bac0f | ||
|
|
18931462bd | ||
|
|
437fb2f24c | ||
|
|
cdd70c9e3d | ||
|
|
fabbb839c1 | ||
|
|
bde80b0938 |
28
LICENSE
Normal file
28
LICENSE
Normal file
@ -0,0 +1,28 @@
|
||||
wepoll - epoll for Windows
|
||||
https://github.com/piscisaureus/wepoll
|
||||
|
||||
Copyright 2012-2020, Bert Belder <bertbelder@gmail.com>
|
||||
All rights reserved.
|
||||
|
||||
Redistribution and use in source and binary forms, with or without
|
||||
modification, are permitted provided that the following conditions are
|
||||
met:
|
||||
|
||||
* Redistributions of source code must retain the above copyright
|
||||
notice, this list of conditions and the following disclaimer.
|
||||
|
||||
* Redistributions in binary form must reproduce the above copyright
|
||||
notice, this list of conditions and the following disclaimer in the
|
||||
documentation and/or other materials provided with the distribution.
|
||||
|
||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
||||
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
||||
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
||||
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
||||
OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||
LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
112
README.md
112
README.md
@ -38,21 +38,23 @@ to run on Linux.
|
||||
## How to use
|
||||
|
||||
The library is [distributed][dist] as a single source file
|
||||
([wepoll.c][wepoll.c]) and a single header file ([wepoll.h][wepoll.h]).
|
||||
Compile the .c file as part of your project, and include the header
|
||||
wherever needed.
|
||||
([wepoll.c][wepoll.c]) and a single header file ([wepoll.h][wepoll.h]).<br>
|
||||
Compile the .c file as part of your project, and include the header wherever
|
||||
needed.
|
||||
|
||||
## Compatibility
|
||||
|
||||
* Requires Windows Vista or higher.
|
||||
* Can be compiled with recent versions of MSVC, Clang, and GCC.
|
||||
|
||||
## API notes
|
||||
## API
|
||||
|
||||
### General
|
||||
### General remarks
|
||||
|
||||
* The epoll port is a `HANDLE`, not a file descriptor.
|
||||
* All functions set both `errno` and `GetLastError()` on failure.
|
||||
* For more extensive documentation, see the [epoll(7) man page][man epoll],
|
||||
and the per-function man pages that are linked below.
|
||||
|
||||
### epoll_create/epoll_create1
|
||||
|
||||
@ -65,7 +67,7 @@ HANDLE epoll_create1(int flags);
|
||||
* `size` is ignored but most be greater than zero.
|
||||
* `flags` must be zero as there are no supported flags.
|
||||
* Returns `NULL` on failure.
|
||||
* [man page][man epoll_create]
|
||||
* [Linux man page][man epoll_create]
|
||||
|
||||
### epoll_close
|
||||
|
||||
@ -87,15 +89,22 @@ int epoll_ctl(HANDLE ephnd,
|
||||
```
|
||||
|
||||
* Control which socket events are monitored by an epoll port.
|
||||
* `ephnd` must be a HANDLE created by `epoll_create` or `epoll_create1`.
|
||||
* `ephnd` must be a HANDLE created by
|
||||
[`epoll_create()`](#epoll_createepoll_create1) or
|
||||
[`epoll_create1()`](#epoll_createepoll_create1).
|
||||
* `op` must be one of `EPOLL_CTL_ADD`, `EPOLL_CTL_MOD`, `EPOLL_CTL_DEL`.
|
||||
* `sock` must be a valid socket created by [`socket()`][msdn socket],
|
||||
[`WSASocket()`][msdn wsasocket], or [`accept()`][msdn accept].
|
||||
* `event` should be a pointer to a [`struct epoll_event`](#struct-epoll_event).<br>
|
||||
If `op` is `EPOLL_CTL_DEL` then the `event` parameter is ignored, and it
|
||||
may be `NULL`.
|
||||
* Returns 0 on success, -1 on failure.
|
||||
* It is recommended to always explicitly remove a socket from its epoll
|
||||
set using `EPOLL_CTL_DEL` *before* closing it. As on Linux, sockets
|
||||
are automatically removed from the epoll set when they are closed, but
|
||||
wepoll may not be able to detect this until the next call to
|
||||
`epoll_wait()`.
|
||||
* TODO: expand
|
||||
* [man page][man epoll_ctl]
|
||||
set using `EPOLL_CTL_DEL` *before* closing it.<br>
|
||||
As on Linux, closed sockets are automatically removed from the epoll set, but
|
||||
wepoll may not be able to detect that a socket was closed until the next call
|
||||
to [`epoll_wait()`](#epoll_wait).
|
||||
* [Linux man page][man epoll_ctl]
|
||||
|
||||
### epoll_wait
|
||||
|
||||
@ -107,12 +116,74 @@ int epoll_wait(HANDLE ephnd,
|
||||
```
|
||||
|
||||
* Receive socket events from an epoll port.
|
||||
* Returns
|
||||
- -1 on failure
|
||||
- 0 when a timeout occurs
|
||||
- ≥1 the number of evens received
|
||||
* TODO: expand
|
||||
* [man page][man epoll_wait]
|
||||
* `events` should point to a caller-allocated array of
|
||||
[`epoll_event`](#struct-epoll_event) structs, which will receive the
|
||||
reported events.
|
||||
* `maxevents` is the maximum number of events that will be written to the
|
||||
`events` array, and must be greater than zero.
|
||||
* `timeout` specifies whether to block when no events are immediately available.
|
||||
- `<0` block indefinitely
|
||||
- `0` report any events that are already waiting, but don't block
|
||||
- `≥1` block for at most N milliseconds
|
||||
* Return value:
|
||||
- `-1` an error occurred
|
||||
- `0` timed out without any events to report
|
||||
- `≥1` the number of events stored in the `events` buffer
|
||||
* [Linux man page][man epoll_wait]
|
||||
|
||||
### struct epoll_event
|
||||
|
||||
```c
|
||||
typedef union epoll_data {
|
||||
void* ptr;
|
||||
int fd;
|
||||
uint32_t u32;
|
||||
uint64_t u64;
|
||||
SOCKET sock; /* Windows specific */
|
||||
HANDLE hnd; /* Windows specific */
|
||||
} epoll_data_t;
|
||||
```
|
||||
|
||||
```c
|
||||
struct epoll_event {
|
||||
uint32_t events; /* Epoll events and flags */
|
||||
epoll_data_t data; /* User data variable */
|
||||
};
|
||||
```
|
||||
|
||||
* The `events` field is a bit mask containing the events being
|
||||
monitored/reported, and optional flags.<br>
|
||||
Flags are accepted by [`epoll_ctl()`](#epoll_ctl), but they are not reported
|
||||
back by [`epoll_wait()`](#epoll_wait).
|
||||
* The `data` field can be used to associate application-specific information
|
||||
with a socket; its value will be returned unmodified by
|
||||
[`epoll_wait()`](#epoll_wait).
|
||||
* [Linux man page][man epoll_ctl]
|
||||
|
||||
| Event | Description |
|
||||
|---------------|----------------------------------------------------------------------|
|
||||
| `EPOLLIN` | incoming data available, or incoming connection ready to be accepted |
|
||||
| `EPOLLOUT` | ready to send data, or outgoing connection successfully established |
|
||||
| `EPOLLRDHUP` | remote peer initiated graceful socket shutdown |
|
||||
| `EPOLLPRI` | out-of-band data available for reading |
|
||||
| `EPOLLERR` | socket error<sup>1</sup> |
|
||||
| `EPOLLHUP` | socket hang-up<sup>1</sup> |
|
||||
| `EPOLLRDNORM` | same as `EPOLLIN` |
|
||||
| `EPOLLRDBAND` | same as `EPOLLPRI` |
|
||||
| `EPOLLWRNORM` | same as `EPOLLOUT` |
|
||||
| `EPOLLWRBAND` | same as `EPOLLOUT` |
|
||||
| `EPOLLMSG` | never reported |
|
||||
|
||||
| Flag | Description |
|
||||
|------------------|---------------------------|
|
||||
| `EPOLLONESHOT` | report event(s) only once |
|
||||
| `EPOLLET` | not supported by wepoll |
|
||||
| `EPOLLEXCLUSIVE` | not supported by wepoll |
|
||||
| `EPOLLWAKEUP` | not supported by wepoll |
|
||||
|
||||
<sup>1</sup>: the `EPOLLERR` and `EPOLLHUP` events may always be reported by
|
||||
[`epoll_wait()`](#epoll_wait), regardless of the event mask that was passed to
|
||||
[`epoll_ctl()`](#epoll_ctl).
|
||||
|
||||
|
||||
[ci status badge]: https://ci.appveyor.com/api/projects/status/github/piscisaureus/wepoll?branch=master&svg=true
|
||||
@ -122,6 +193,9 @@ int epoll_wait(HANDLE ephnd,
|
||||
[man epoll_create]: http://man7.org/linux/man-pages/man2/epoll_create.2.html
|
||||
[man epoll_ctl]: http://man7.org/linux/man-pages/man2/epoll_ctl.2.html
|
||||
[man epoll_wait]: http://man7.org/linux/man-pages/man2/epoll_wait.2.html
|
||||
[msdn accept]: https://msdn.microsoft.com/en-us/library/windows/desktop/ms737526(v=vs.85).aspx
|
||||
[msdn socket]: https://msdn.microsoft.com/en-us/library/windows/desktop/ms740506(v=vs.85).aspx
|
||||
[msdn wsasocket]: https://msdn.microsoft.com/en-us/library/windows/desktop/ms742212(v=vs.85).aspx
|
||||
[select scale]: https://daniel.haxx.se/docs/poll-vs-select.html
|
||||
[wsapoll broken]: https://daniel.haxx.se/blog/2012/10/10/wsapoll-is-broken/
|
||||
[wepoll.c]: https://github.com/piscisaureus/wepoll/blob/dist/wepoll.c
|
||||
|
||||
60
wepoll.h
60
wepoll.h
@ -1,9 +1,9 @@
|
||||
/*
|
||||
* wepoll - epoll for Windows
|
||||
* Copyright 2012-2017, Bert Belder. All rights reserved.
|
||||
* https://github.com/piscisaureus/wepoll
|
||||
*
|
||||
* The red-black tree implementation:
|
||||
* Copyright 2002 Niels Provos <provos@citi.umich.edu> All rights reserved.
|
||||
* Copyright 2012-2020, Bert Belder <bertbelder@gmail.com>
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are
|
||||
@ -38,42 +38,38 @@
|
||||
|
||||
#include <stdint.h>
|
||||
|
||||
/* clang-format off */
|
||||
|
||||
enum EPOLL_EVENTS {
|
||||
EPOLLIN = 1 << 0,
|
||||
EPOLLPRI = 1 << 1,
|
||||
EPOLLOUT = 1 << 2,
|
||||
EPOLLERR = 1 << 3,
|
||||
EPOLLHUP = 1 << 4,
|
||||
EPOLLRDNORM = 1 << 6,
|
||||
EPOLLRDBAND = 1 << 7,
|
||||
EPOLLWRNORM = 1 << 8,
|
||||
EPOLLWRBAND = 1 << 9,
|
||||
EPOLLMSG = 1 << 10, /* Never reported. */
|
||||
EPOLLRDHUP = 1 << 13,
|
||||
EPOLLONESHOT = 1 << 31
|
||||
EPOLLIN = (int) (1U << 0),
|
||||
EPOLLPRI = (int) (1U << 1),
|
||||
EPOLLOUT = (int) (1U << 2),
|
||||
EPOLLERR = (int) (1U << 3),
|
||||
EPOLLHUP = (int) (1U << 4),
|
||||
EPOLLRDNORM = (int) (1U << 6),
|
||||
EPOLLRDBAND = (int) (1U << 7),
|
||||
EPOLLWRNORM = (int) (1U << 8),
|
||||
EPOLLWRBAND = (int) (1U << 9),
|
||||
EPOLLMSG = (int) (1U << 10), /* Never reported. */
|
||||
EPOLLRDHUP = (int) (1U << 13),
|
||||
EPOLLONESHOT = (int) (1U << 31)
|
||||
};
|
||||
|
||||
#define EPOLLIN ((uint32_t) EPOLLIN)
|
||||
#define EPOLLPRI ((uint32_t) EPOLLPRI)
|
||||
#define EPOLLOUT ((uint32_t) EPOLLOUT)
|
||||
#define EPOLLERR ((uint32_t) EPOLLERR)
|
||||
#define EPOLLHUP ((uint32_t) EPOLLHUP)
|
||||
#define EPOLLRDNORM ((uint32_t) EPOLLRDNORM)
|
||||
#define EPOLLRDBAND ((uint32_t) EPOLLRDBAND)
|
||||
#define EPOLLWRNORM ((uint32_t) EPOLLWRNORM)
|
||||
#define EPOLLWRBAND ((uint32_t) EPOLLWRBAND)
|
||||
#define EPOLLMSG ((uint32_t) EPOLLMSG)
|
||||
#define EPOLLRDHUP ((uint32_t) EPOLLRDHUP)
|
||||
#define EPOLLONESHOT ((uint32_t) EPOLLONESHOT)
|
||||
#define EPOLLIN (1U << 0)
|
||||
#define EPOLLPRI (1U << 1)
|
||||
#define EPOLLOUT (1U << 2)
|
||||
#define EPOLLERR (1U << 3)
|
||||
#define EPOLLHUP (1U << 4)
|
||||
#define EPOLLRDNORM (1U << 6)
|
||||
#define EPOLLRDBAND (1U << 7)
|
||||
#define EPOLLWRNORM (1U << 8)
|
||||
#define EPOLLWRBAND (1U << 9)
|
||||
#define EPOLLMSG (1U << 10)
|
||||
#define EPOLLRDHUP (1U << 13)
|
||||
#define EPOLLONESHOT (1U << 31)
|
||||
|
||||
#define EPOLL_CTL_ADD 1
|
||||
#define EPOLL_CTL_MOD 2
|
||||
#define EPOLL_CTL_DEL 3
|
||||
|
||||
/* clang-format on */
|
||||
|
||||
typedef void* HANDLE;
|
||||
typedef uintptr_t SOCKET;
|
||||
|
||||
@ -87,7 +83,7 @@ typedef union epoll_data {
|
||||
} epoll_data_t;
|
||||
|
||||
struct epoll_event {
|
||||
uint32_t events; /* Epoll events */
|
||||
uint32_t events; /* Epoll events and flags */
|
||||
epoll_data_t data; /* User data variable */
|
||||
};
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user