diff --git a/src/modules/module-protocol-native.c b/src/modules/module-protocol-native.c
index 01eaff2f6..965d20585 100644
--- a/src/modules/module-protocol-native.c
+++ b/src/modules/module-protocol-native.c
@@ -290,7 +290,7 @@ connection_data(void *data, int fd, uint32_t mask)
 			SPA_FLAG_CLEAR(mask, SPA_IO_OUT);
 			pw_loop_update_io(client->context->main_loop,
 					this->source, mask);
-		} else if (res != EAGAIN)
+		} else if (res != -EAGAIN)
 			goto error;
 	}
 	if (mask & SPA_IO_IN) {
@@ -748,7 +748,7 @@ on_remote_data(void *data, int fd, uint32_t mask)
 			pw_loop_update_io(loop,
 					impl->source, mask);
 			impl->flushing = false;
-		} else if (res != EAGAIN)
+		} else if (res != -EAGAIN)
 			goto error;
 	}
 
diff --git a/src/modules/module-protocol-pulse/pulse-server.c b/src/modules/module-protocol-pulse/pulse-server.c
index 6d08bb9bf..c9869e63b 100644
--- a/src/modules/module-protocol-pulse/pulse-server.c
+++ b/src/modules/module-protocol-pulse/pulse-server.c
@@ -4055,7 +4055,7 @@ on_client_data(void *data, int fd, uint32_t mask)
 			int mask = client->source->mask;
 			SPA_FLAG_CLEAR(mask, SPA_IO_OUT);
 			pw_loop_update_io(impl->loop, client->source, mask);
-		} else if (res != EAGAIN)
+		} else if (res != -EAGAIN)
 			goto error;
 	}
 	if (mask & SPA_IO_IN) {