PHP bindings to the linux epoll API.
- PHP >= 7.4
- PHP FFI extension available
- Linux > 2.6
- toknot/ffi-extend>=0.1
use composer install:
composer require toknot/php-epoll
include composer autoload file : ./vendor/autoload.php
-
Epoll::__construct() -
Epoll::create(int $flags)open an epoll file descriptor
-
Epoll::ctl(int $op, int $fd, EpollEvent $events): intcontrol interface for an epoll file descriptor
-
Epoll::wait(EpollEvent $event, int $maxevents, int $timeout, $sigmask = null): intwait for an I/O event on an epoll file descriptor
-
Epoll::getFdno(resource $file, int $type): intget id from file descriptor of php resource
-
Epoll::lastErrno(): intget last error code
-
Epoll::lastError(): stringget last error message
-
Epoll::ffi(): FFI -
Epoll::initEvents($num): EpollEvent -
EpollEvent::__construct(Epoll $epoll,$num) -
EpollEvent::setEvent($event, $idx)set Epoll events
-
EpollEvent::setData($data, $idx)set user data variable
-
EpollEvent::getEvents($idx): FFI\CData
php resource to file descriptor
$epoll = new Epoll();
$fp = fopen(__FILE__, 'rb');
$fdno = $epoll->getFdno($fp, Epoll::RES_TYPE_FILE);
$fdfp = fopen("php://fd/$fdno", 'rb');
echo fread($fdfp, 1024);epoll example from man epoll
const MAX_EVENTS = 10;
const EXIT_FAILURE = 1;
$epoll = new Epoll();
$ev = $epoll->initEvents(MAX_EVENTS);
$events = $epoll->initEvents();
$stream = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);
$listen_sock = $epoll->getFdno($stream, Epoll::RES_TYPE_NET);
function perror($str) {
fprintf(STDERR, $str);
}
$epollfd = $epoll->create(0);
$ev->setEvent(Epoll::EPOLLIN);
$ev->setData(['fd' => $listen_sock]);
if ($epoll->ctl(Epoll::EPOLL_CTL_ADD, $listen_sock, $ev) == -1) {
perror("epoll_ctl: listen_sock");
exit(EXIT_FAILURE);
}
for (;;) {
$nfds = $epoll->wait($events, MAX_EVENTS, -1);
if ($nfds == -1) {
perror("epoll_wait");
exit(EXIT_FAILURE);
}
for ($n = 0; $n < $nfds; ++$n) {
if ($events[$n]->data->fd == $listen_sock) {
$conn_sock = stream_socket_accept($stream);
if (!$conn_sock) {
perror("accept");
exit(EXIT_FAILURE);
}
stream_set_blocking($conn_sock, false);
$ev->setEvent(Epoll::EPOLLIN | Epoll::EPOLLET);
$connFdno = $epoll->getFdno($conn_sock, Epoll::RES_TYPE_NET);
$ev->setData(['fd' => $connFdno]);
if ($epoll->ctl(Epoll::EPOLL_CTL_ADD, $connFdno,
$ev) == -1) {
perror("epoll_ctl: conn_sock");
exit(EXIT_FAILURE);
}
} else {
do_use_fd($events[$n]->data->fd);
}
}
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent