openrsync mini cleanup

[Claudio Jeker]

Normalize some code.

-- 
:wq Claudio

Index: receiver.c
===================================================================
RCS file: /cvs/src/usr.bin/rsync/receiver.c,v
retrieving revision 1.25
diff -u -p -r1.25 receiver.c
--- receiver.c  24 Nov 2020 16:54:44 -0000      1.25
+++ receiver.c  5 May 2021 15:11:38 -0000
@@ -356,7 +356,7 @@ rsync_receiver(struct sess *sess, int fd
                 */
 
                if (sess->mplex_reads &&
-                   (POLLIN & pfd[PFD_SENDER_IN].revents)) {
+                   (pfd[PFD_SENDER_IN].revents & POLLIN)) {
                        if (!io_read_flush(sess, fdin)) {
                                ERRX1("io_read_flush");
                                goto out;
@@ -371,8 +371,8 @@ rsync_receiver(struct sess *sess, int fd
                 * is read to mmap.
                 */
 
-               if ((POLLIN & pfd[PFD_UPLOADER_IN].revents) ||
-                   (POLLOUT & pfd[PFD_SENDER_OUT].revents)) {
+               if ((pfd[PFD_UPLOADER_IN].revents & POLLIN) ||
+                   (pfd[PFD_SENDER_OUT].revents & POLLOUT)) {
                        c = rsync_uploader(ul,
                                &pfd[PFD_UPLOADER_IN].fd,
                                sess, &pfd[PFD_SENDER_OUT].fd);
@@ -391,8 +391,8 @@ rsync_receiver(struct sess *sess, int fd
                 * messages, which will otherwise clog up the pipes.
                 */
 
-               if ((POLLIN & pfd[PFD_SENDER_IN].revents) ||
-                   (POLLIN & pfd[PFD_DOWNLOADER_IN].revents)) {
+               if ((pfd[PFD_SENDER_IN].revents & POLLIN) ||
+                   (pfd[PFD_DOWNLOADER_IN].revents & POLLIN)) {
                        c = rsync_downloader(dl, sess,
                                &pfd[PFD_DOWNLOADER_IN].fd);
                        if (c < 0) {
@@ -421,10 +421,12 @@ rsync_receiver(struct sess *sess, int fd
                if (!io_write_int(sess, fdout, -1)) {
                        ERRX1("io_write_int");
                        goto out;
-               } else if (!io_read_int(sess, fdin, &ioerror)) {
+               }
+               if (!io_read_int(sess, fdin, &ioerror)) {
                        ERRX1("io_read_int");
                        goto out;
-               } else if (ioerror != -1) {
+               }
+               if (ioerror != -1) {
                        ERRX("expected phase ack");
                        goto out;
                }
@@ -445,7 +447,8 @@ rsync_receiver(struct sess *sess, int fd
        if (!sess_stats_recv(sess, fdin)) {
                ERRX1("sess_stats_recv");
                goto out;
-       } else if (!io_write_int(sess, fdout, -1)) {
+       }
+       if (!io_write_int(sess, fdout, -1)) {
                ERRX1("io_write_int");
                goto out;
        }