diff --git a/include/proto/fd.h b/include/proto/fd.h
index f74fbcbb5..605dc215f 100644
--- a/include/proto/fd.h
+++ b/include/proto/fd.h
@@ -135,6 +135,28 @@ static inline void fd_release_cache_entry(int fd)
 	}
 }
 
+/* Computes the new polled status based on the active and ready statuses, for
+ * each direction. This is meant to be used by pollers while processing updates.
+ */
+static inline int fd_compute_new_polled_status(int state)
+{
+	if (state & FD_EV_ACTIVE_R) {
+		if (!(state & FD_EV_READY_R))
+			state |= FD_EV_POLLED_R;
+	}
+	else
+		state &= ~FD_EV_POLLED_R;
+
+	if (state & FD_EV_ACTIVE_W) {
+		if (!(state & FD_EV_READY_W))
+			state |= FD_EV_POLLED_W;
+	}
+	else
+		state &= ~FD_EV_POLLED_W;
+
+	return state;
+}
+
 /* Automatically allocates or releases a cache entry for fd <fd> depending on
  * its new state. This is meant to be used by pollers while processing updates.
  */
diff --git a/src/ev_epoll.c b/src/ev_epoll.c
index b90d9c153..2849ec6c1 100644
--- a/src/ev_epoll.c
+++ b/src/ev_epoll.c
@@ -59,27 +59,14 @@ REGPRM2 static void _do_poll(struct poller *p, int exp)
 	/* first, scan the update list to find changes */
 	for (updt_idx = 0; updt_idx < fd_nbupdt; updt_idx++) {
 		fd = fd_updt[updt_idx];
-		en = eo = fdtab[fd].state;
-
 		fdtab[fd].updated = 0;
 		fdtab[fd].new = 0;
 
 		if (!fdtab[fd].owner)
 			continue;
 
-		if (en & FD_EV_ACTIVE_R) {
-			if (!(en & FD_EV_READY_R))
-				en |= FD_EV_POLLED_R;
-		}
-		else
-			en &= ~FD_EV_POLLED_R;
-
-		if (en & FD_EV_ACTIVE_W) {
-			if (!(en & FD_EV_READY_W))
-				en |= FD_EV_POLLED_W;
-		}
-		else
-			en &= ~FD_EV_POLLED_W;
+		eo = fdtab[fd].state;
+		en = fd_compute_new_polled_status(eo);
 
 		if ((eo ^ en) & FD_EV_POLLED_RW) {
 			/* poll status changed */
diff --git a/src/ev_kqueue.c b/src/ev_kqueue.c
index 0473adc34..06ccaee29 100644
--- a/src/ev_kqueue.c
+++ b/src/ev_kqueue.c
@@ -47,28 +47,14 @@ REGPRM2 static void _do_poll(struct poller *p, int exp)
 	/* first, scan the update list to find changes */
 	for (updt_idx = 0; updt_idx < fd_nbupdt; updt_idx++) {
 		fd = fd_updt[updt_idx];
-		en = eo = fdtab[fd].state;
-
 		fdtab[fd].updated = 0;
 		fdtab[fd].new = 0;
 
 		if (!fdtab[fd].owner)
 			continue;
 
-		if (en & FD_EV_ACTIVE_R) {
-			if (!(en & FD_EV_READY_R))
-				en |= FD_EV_POLLED_R;
-		}
-		else
-			en &= ~FD_EV_POLLED_R;
-
-		if (en & FD_EV_ACTIVE_W) {
-			if (!(en & FD_EV_READY_W))
-				en |= FD_EV_POLLED_W;
-		}
-		else
-			en &= ~FD_EV_POLLED_W;
-
+		eo = fdtab[fd].state;
+		en = fd_compute_new_polled_status(eo);
 
 		if ((eo ^ en) & FD_EV_POLLED_RW) {
 			/* poll status changed */
diff --git a/src/ev_poll.c b/src/ev_poll.c
index 84ba486b8..2f6e56d3c 100644
--- a/src/ev_poll.c
+++ b/src/ev_poll.c
@@ -70,27 +70,14 @@ REGPRM2 static void _do_poll(struct poller *p, int exp)
 	/* first, scan the update list to find changes */
 	for (updt_idx = 0; updt_idx < fd_nbupdt; updt_idx++) {
 		fd = fd_updt[updt_idx];
-		en = eo = fdtab[fd].state;
-
 		fdtab[fd].updated = 0;
 		fdtab[fd].new = 0;
 
 		if (!fdtab[fd].owner)
 			continue;
 
-		if (en & FD_EV_ACTIVE_R) {
-			if (!(en & FD_EV_READY_R))
-				en |= FD_EV_POLLED_R;
-		}
-		else
-			en &= ~FD_EV_POLLED_R;
-
-		if (en & FD_EV_ACTIVE_W) {
-			if (!(en & FD_EV_READY_W))
-				en |= FD_EV_POLLED_W;
-		}
-		else
-			en &= ~FD_EV_POLLED_W;
+		eo = fdtab[fd].state;
+		en = fd_compute_new_polled_status(eo);
 
 		if ((eo ^ en) & FD_EV_POLLED_RW) {
 			/* poll status changed, update the lists */
diff --git a/src/ev_select.c b/src/ev_select.c
index 87ca348a6..5a76d44c0 100644
--- a/src/ev_select.c
+++ b/src/ev_select.c
@@ -53,27 +53,14 @@ REGPRM2 static void _do_poll(struct poller *p, int exp)
 	/* first, scan the update list to find changes */
 	for (updt_idx = 0; updt_idx < fd_nbupdt; updt_idx++) {
 		fd = fd_updt[updt_idx];
-		en = eo = fdtab[fd].state;
-
 		fdtab[fd].updated = 0;
 		fdtab[fd].new = 0;
 
 		if (!fdtab[fd].owner)
 			continue;
 
-		if (en & FD_EV_ACTIVE_R) {
-			if (!(en & FD_EV_READY_R))
-				en |= FD_EV_POLLED_R;
-		}
-		else
-			en &= ~FD_EV_POLLED_R;
-
-		if (en & FD_EV_ACTIVE_W) {
-			if (!(en & FD_EV_READY_W))
-				en |= FD_EV_POLLED_W;
-		}
-		else
-			en &= ~FD_EV_POLLED_W;
+		eo = fdtab[fd].state;
+		en = fd_compute_new_polled_status(eo);
 
 		if ((eo ^ en) & FD_EV_POLLED_RW) {
 			/* poll status changed, update the lists */