EpollFD.hxx 2.39 KB
Newer Older
1
/*
2
 * Copyright 2013-2018 Max Kellermann <max.kellermann@gmail.com>
3
 *
4 5 6
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
7
 *
8 9
 * - Redistributions of source code must retain the above copyright
 * notice, this list of conditions and the following disclaimer.
10
 *
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
 * - 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
 * FOUNDATION 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.
28 29
 */

30 31
#ifndef EPOLL_FD_HXX
#define EPOLL_FD_HXX
32

33 34
#include "UniqueFileDescriptor.hxx"

35 36 37
#include <assert.h>
#include <sys/epoll.h>
#include <unistd.h>
38
#include <stdint.h>
39 40 41 42 43 44

struct epoll_event;

/**
 * A class that wraps Linux epoll.
 */
45
class EpollFD {
46
	UniqueFileDescriptor fd;
47 48

public:
49 50 51
	/**
	 * Throws on error.
	 */
52
	EpollFD();
53

54 55
	EpollFD(EpollFD &&) = default;
	EpollFD &operator=(EpollFD &&) = default;
56

57
	int Wait(epoll_event *events, int maxevents, int timeout) noexcept {
58
		return ::epoll_wait(fd.Get(), events, maxevents, timeout);
59 60
	}

61
	bool Control(int op, int _fd, epoll_event *event) noexcept {
62
		return ::epoll_ctl(fd.Get(), op, _fd, event) >= 0;
63 64
	}

65
	bool Add(int _fd, uint32_t events, void *ptr) noexcept {
66 67 68 69
		epoll_event e;
		e.events = events;
		e.data.ptr = ptr;

70
		return Control(EPOLL_CTL_ADD, _fd, &e);
71 72
	}

73
	bool Modify(int _fd, uint32_t events, void *ptr) noexcept {
74 75 76 77 78 79 80
		epoll_event e;
		e.events = events;
		e.data.ptr = ptr;

		return Control(EPOLL_CTL_MOD, _fd, &e);
	}

81
	bool Remove(int _fd) noexcept {
82 83 84 85 86
		return Control(EPOLL_CTL_DEL, _fd, nullptr);
	}
};

#endif