[PATCH 4/5, v2] libceph: use a do..while loop in con_work()

[Alex Elder]

This just converts a manually-implemented loop into a do..while loop
in con_work().  It also moves handling of EAGAIN inside the blocks
where it's already been determined an error code was returned.

Also update a few dout() calls near the affected code for
consistency.

NOTE:
    This was done in two steps in order to facilitate review.  The
    This patch will be squashed into the next one before commit.
    next patch simply indents the loop properly.

Signed-off-by: Alex Elder <el...@inktank.com>
---
v2: rebased

 net/ceph/messenger.c |   39 ++++++++++++++++++++-------------------
 1 file changed, 20 insertions(+), 19 deletions(-)

diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 18eb788..223406f 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -2387,51 +2387,53 @@ static void con_work(struct work_struct *work)
 {
        struct ceph_connection *con = container_of(work, struct ceph_connection,
                                                   work.work);
-       bool fault = false;
-       int ret;
+       bool fault;

        mutex_lock(&con->mutex);
-restart:
-       if (con_sock_closed(con)) {
+while (true) {
+       int ret;
+
+       if ((fault = con_sock_closed(con))) {
                dout("%s: con %p SOCK_CLOSED\n", __func__, con);
-               fault = true;
-               goto done;
+               break;
        }
        if (con_backoff(con)) {
                dout("%s: con %p BACKOFF\n", __func__, con);
-               goto done;
+               break;
        }
        if (con->state == CON_STATE_STANDBY) {
-               dout("con_work %p STANDBY\n", con);
-               goto done;
+               dout("%s: con %p STANDBY\n", __func__, con);
+               break;
        }
        if (con->state == CON_STATE_CLOSED) {
-               dout("con_work %p CLOSED\n", con);
+               dout("%s: con %p CLOSED\n", __func__, con);
                BUG_ON(con->sock);
-               goto done;
+               break;
        }
        if (con->state == CON_STATE_PREOPEN) {
-               dout("%s: con %p OPENING\n", __func__, con);
+               dout("%s: con %p PREOPEN\n", __func__, con);
                BUG_ON(con->sock);
        }

        ret = try_read(con);
-       if (ret == -EAGAIN)
-               goto restart;
        if (ret < 0) {
+               if (ret == -EAGAIN)
+                       continue;
                con->error_msg = "socket error on read";
                fault = true;
-               goto done;
+               break;
        }

        ret = try_write(con);
-       if (ret == -EAGAIN)
-               goto restart;
        if (ret < 0) {
+               if (ret == -EAGAIN)
+                       continue;
                con->error_msg = "socket error on write";
                fault = true;
        }
-done:
+
+       break;  /* If we make it to here, we're done */
+}
        if (fault)
                con_fault(con);
        mutex_unlock(&con->mutex);
@@ -2442,7 +2444,6 @@ done:
        con->ops->put(con);
 }

-
 /*
  * Generic error/fault handler.  A retry mechanism is used with
  * exponential backoff
-- 
1.7.9.5

--
To unsubscribe from this list: send the line "unsubscribe ceph-devel" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html