This is just the second part of a two-part patch.  It simply
indents a block of code.  This patch is going to be merged into
its predecessor following review.

Signed-off-by: Alex Elder <[email protected]>
---
v2: rebased

 net/ceph/messenger.c |   80
+++++++++++++++++++++++++-------------------------
 1 file changed, 40 insertions(+), 40 deletions(-)

diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 223406f..2c0669f 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -2390,50 +2390,50 @@ static void con_work(struct work_struct *work)
        bool fault;

        mutex_lock(&con->mutex);
-while (true) {
-       int ret;
+       while (true) {
+               int ret;

-       if ((fault = con_sock_closed(con))) {
-               dout("%s: con %p SOCK_CLOSED\n", __func__, con);
-               break;
-       }
-       if (con_backoff(con)) {
-               dout("%s: con %p BACKOFF\n", __func__, con);
-               break;
-       }
-       if (con->state == CON_STATE_STANDBY) {
-               dout("%s: con %p STANDBY\n", __func__, con);
-               break;
-       }
-       if (con->state == CON_STATE_CLOSED) {
-               dout("%s: con %p CLOSED\n", __func__, con);
-               BUG_ON(con->sock);
-               break;
-       }
-       if (con->state == CON_STATE_PREOPEN) {
-               dout("%s: con %p PREOPEN\n", __func__, con);
-               BUG_ON(con->sock);
-       }
+               if ((fault = con_sock_closed(con))) {
+                       dout("%s: con %p SOCK_CLOSED\n", __func__, con);
+                       break;
+               }
+               if (con_backoff(con)) {
+                       dout("%s: con %p BACKOFF\n", __func__, con);
+                       break;
+               }
+               if (con->state == CON_STATE_STANDBY) {
+                       dout("%s: con %p STANDBY\n", __func__, con);
+                       break;
+               }
+               if (con->state == CON_STATE_CLOSED) {
+                       dout("%s: con %p CLOSED\n", __func__, con);
+                       BUG_ON(con->sock);
+                       break;
+               }
+               if (con->state == CON_STATE_PREOPEN) {
+                       dout("%s: con %p PREOPEN\n", __func__, con);
+                       BUG_ON(con->sock);
+               }

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

-       ret = try_write(con);
-       if (ret < 0) {
-               if (ret == -EAGAIN)
-                       continue;
-               con->error_msg = "socket error on write";
-               fault = true;
-       }
+               ret = try_write(con);
+               if (ret < 0) {
+                       if (ret == -EAGAIN)
+                               continue;
+                       con->error_msg = "socket error on write";
+                       fault = true;
+               }

-       break;  /* If we make it to here, we're done */
-}
+               break;  /* If we make it to here, we're done */
+       }
        if (fault)
                con_fault(con);
        mutex_unlock(&con->mutex);
-- 
1.7.9.5

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

Reply via email to