Initial commit for epoll

Author: userz

qiling/os/posix/const.py

@@ -1090,3 +1090,21 @@ class qnx_mmap_prot_flags(QlPrettyFlag):
 # https://docs.huihoo.com/doxygen/linux/kernel/3.7/include_2uapi_2linux_2fcntl_8h.html
 AT_SYMLINK_NOFOLLOW = 0x100
 AT_FDCWD = 0xffffff9c # -0n100 in 2's complement
+# epoll syscall
+EPOLL_OPS = {0x001: "EPOLL_CTL_ADD", 0x002: "EPOLL_CTL_DEL", 0x003: "EPOLL_CTL_MOD"}
+
+EPOLLIN = 0x001
+EPOLLPRI = 0x002
+EPOLLOUT = 0x004
+EPOLLRDNORM = 0x040
+EPOLLRDBAND = 0x080
+EPOLLWRNORM = 0x100
+EPOLLWRBAND = 0x200
+EPOLLMSG = 0x400
+EPOLLERR = 0x008
+EPOLLHUP = 0x010
+EPOLLRDHUP = 0x2000
+EPOLLEXCLUSIVE = 1 << 28
+EPOLLWAKEUP = 1 << 29
+EPOLLONESHOT = 1 << 30
+EPOLLET = 1 << 31

qiling/os/posix/syscall/epoll.py

@@ -59,6 +59,7 @@ def is_present(self, fd):
         return 1
 
 
+<<<<<<< HEAD
 """
 Recursively checks each epoll instance's 'watched'
 fds for an instance of epoll being watched.
@@ -69,6 +70,10 @@ def is_present(self, fd):
 
 def check_epoll_depth(ql_fd_list, epolls_list, depth):
     if depth == 7:
+=======
+def check_epoll_depth(ql_fd_list, epolls_list, depth):
+    if depth == 6:
+>>>>>>> 0aef533c (Initial commit for epoll)
         return 1
     new_epolls_list = []
     flag = 0
@@ -83,6 +88,7 @@ def check_epoll_depth(ql_fd_list, epolls_list, depth):
     return 0
 
 
+<<<<<<< HEAD
 """
 Modify an existing epoll
 man 7 epoll for more details
@@ -92,6 +98,9 @@ def check_epoll_depth(ql_fd_list, epolls_list, depth):
 def ql_syscall_epoll_ctl(
     ql: qiling.Qiling, epfd: int, op: int, fd: int, event: POINTER
 ):
+=======
+def ql_epoll_ctl(ql: qiling.Qiling, epfd: int, op: int, fd: int, event: POINTER):
+>>>>>>> 0aef533c (Initial commit for epoll)
     # Basic sanity checks first
     if event != 0:
         ql_event = ql.unpack32(ql.mem.read(event, 4))  # events list is uint32_t
@@ -148,6 +157,7 @@ def ql_syscall_epoll_ctl(
     if epoll_obj is None or fd_obj is None:
         # epfd or fd is not a valid file descriptor.
         return EBADF
+<<<<<<< HEAD
     if epfd == fd:  # epoll can't monitor itself
         return EINVAL
     if epoll_obj.fileno() == fd:
@@ -181,17 +191,54 @@ def ql_syscall_epoll_ctl(
         if op & EPOLLEXCLUSIVE and fd in epoll_obj.get_fds:
             return EINVAL  # EINVAL op was EPOLL_CTL_MOD and the EPOLLEXCLUSIVE flag has previously been applied to this epfd, fd pair.
         epoll_parent_obj.set_eventmask(ql_event)
+=======
+    if epfd == fd:
+        return EINVAL
+    if epoll_obj.fileno() == fd:
+        return ELOOP  # ELOOP  ...or a nesting depth of epoll instances greater than 5.
+    match ql_op:
+        case "EPOLL_CTL_ADD":
+            if epoll_parent_obj.is_present(
+                fd
+            ):  # can't add an fd that's already being waited on
+                return EEXIST  # op was EPOLL_CTL_ADD, and the supplied file descriptor fd is already registered with this epoll instance.
+            epoll_parent_obj.monitor_fd(
+                fd, ql_event
+            )  # add to list of fds to be monitored with per-fd eventmask
+            # register will actual epoll instance
+            # and add eventmask accordingly
+        case "EPOLL_CTL_DEL":
+            if not epoll_parent_obj.is_present(
+                fd
+            ):  #  op was EPOLL_CTL_MOD or EPOLL_CTL_DEL, and fd is not registered with this epoll instance.
+                return ENOENT
+            epoll_parent_obj.delist_fd(fd)  # remove from fds list and do so in the
+            # underlying epoll instance
+        case "EPOLL_CTL_MOD":
+            if not epoll_parent_obj.is_present(
+                fd
+            ):  # ENOENT op was EPOLL_CTL_MOD or EPOLL_CTL_DEL, and fd is not registered with this epoll instance
+                return ENOENT
+            # EINVAL op was EPOLL_CTL_MOD and events included EPOLLEXCLUSIVE.
+            if op & EPOLLEXCLUSIVE and fd in epoll_obj.get_fds:
+                return EINVAL  # EINVAL op was EPOLL_CTL_MOD and the EPOLLEXCLUSIVE flag has previously been applied to this epfd, fd pair.
+            epoll_parent_obj.set_eventmask(ql_event)
+>>>>>>> 0aef533c (Initial commit for epoll)
 
     return 0
 
 
+<<<<<<< HEAD
 """
 Wait on an existing epoll for events specified
 earlier. man 7 epoll_wait for more info
 """
 
 
 def ql_syscall_epoll_wait(
+=======
+def ql_epoll_wait(
+>>>>>>> 0aef533c (Initial commit for epoll)
     ql: qiling.Qiling, epfd: int, epoll_events: POINTER, maxevents: int, timeout: int
 ):
     if maxevents <= 0:
@@ -244,7 +291,11 @@ def ql_syscall_epoll_wait(
 """
 
 
+<<<<<<< HEAD
 def ql_syscall_epoll_create1(ql: qiling.Qiling, flags: int):
+=======
+def ql_epoll_create1(ql: qiling.Qiling, flags: int):
+>>>>>>> 0aef533c (Initial commit for epoll)
     if flags != select.EPOLL_CLOEXEC and flags != 0:
         return EINVAL
     ret = select.epoll(sizehint=-1, flags=flags)
@@ -256,15 +307,28 @@ def ql_syscall_epoll_create1(ql: qiling.Qiling, flags: int):
 
 """
 Almost identical to above, but can't simply wrap
+<<<<<<< HEAD
 because of the slightly different prototype
 """
 
 
 def ql_syscall_epoll_create(ql: qiling.Qiling, size: int):
+=======
+because of the slightly different args and the different
+syscall number
+"""
+
+
+def ql_epoll_create(ql: qiling.Qiling, size: int):
+>>>>>>> 0aef533c (Initial commit for epoll)
     if size < 0:
         return EINVAL
     ret = select.epoll(sizehint=size, flags=0)
     fd = ret.fileno()
     ql_obj = QlEpollObj(ret)
     ql.os.fd[fd] = ql_obj
+<<<<<<< HEAD
+    return fd
+=======
     return fd
+>>>>>>> 0aef533c (Initial commit for epoll)