X-Git-Url: https://git.sesse.net/?p=jam;a=blobdiff_plain;f=jam.c;h=d447debb1c723849714fd3b65356a3ca024ed0d5;hp=0353dc53e7c5257d583daee14fa1ef606f674065;hb=4122bc3e390fa1cc93fbd2854757067a6c34e763;hpb=703a230f6d1292ed0e8207b748eef1c28710dacb

diff --git a/jam.c b/jam.c
index 0353dc5..d447deb 100644
--- a/jam.c
+++ b/jam.c
@@ -220,8 +220,13 @@ void *sender_worker(void *arg)
 		generate_new_sender(ep_fd);
 
 	for ( ;; ) {
-		int ret = epoll_wait(ep_fd, events, num_sockets_per_sender, -1);
-		for (i = 0; i < ret; ++i) {
+		int num_active = epoll_wait(ep_fd, events, num_sockets_per_sender, -1);
+		if (num_active == -1) {
+			perror("epoll_wait");
+			exit(1);
+		}
+
+		for (i = 0; i < num_active; ++i) {
 			unsigned bytes_to_send = events[i].data.u64;
 			unsigned ret;