drbd: conn_send_cmd2(): Return 0 upon success and an error code otherwise

Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>

diff --git a/drivers/block/drbd/drbd_main.c b/drivers/block/drbd/drbd_main.c
index 7f2afb8115cea1cf321e2c78ec0ebe3c0490d11a..018c336aea09dd52495cb7f20e5d074e169e3130 100644 (file)
--- a/drivers/block/drbd/drbd_main.c
+++ b/drivers/block/drbd/drbd_main.c
@@ -769,21 +769,17 @@ int conn_send_cmd2(struct drbd_tconn *tconn, enum drbd_packet cmd, char *data,
                   size_t size)
 {
        struct p_header80 h;
-       int ok;
+       int err;
 
        prepare_header80(&h, cmd, size);
-
-       if (drbd_get_data_sock(tconn))
-               return 0;
-
-       ok = (sizeof(h) ==
-               drbd_send(tconn, tconn->data.socket, &h, sizeof(h), 0));
-       ok = ok && (size ==
-               drbd_send(tconn, tconn->data.socket, data, size, 0));
-
-       drbd_put_data_sock(tconn);
-
-       return ok;
+       err = drbd_get_data_sock(tconn);
+       if (!err) {
+               err = drbd_send_all(tconn, tconn->data.socket, &h, sizeof(h), 0);
+               if (!err)
+                       err = drbd_send_all(tconn, tconn->data.socket, data, size, 0);
+               drbd_put_data_sock(tconn);
+       }
+       return err;
 }
 
 int drbd_send_sync_param(struct drbd_conf *mdev)
@@ -882,7 +878,7 @@ int drbd_send_protocol(struct drbd_tconn *tconn)
        if (tconn->agreed_pro_version >= 87)
                strcpy(p->integrity_alg, tconn->net_conf->integrity_alg);
 
-       rv = conn_send_cmd2(tconn, P_PROTOCOL, p->head.payload, size - sizeof(struct p_header));
+       rv = !conn_send_cmd2(tconn, P_PROTOCOL, p->head.payload, size - sizeof(struct p_header));
        kfree(p);
        return rv;
 }

diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c
index c8c826b2444f826c38456105bac050a32c4cae21..9c781ff1aa8b425eb50fb03c90cd7a6176b711b9 100644 (file)
--- a/drivers/block/drbd/drbd_receiver.c
+++ b/drivers/block/drbd/drbd_receiver.c
@@ -4265,7 +4265,7 @@ static int drbd_do_auth(struct drbd_tconn *tconn)
 
        get_random_bytes(my_challenge, CHALLENGE_LEN);
 
-       rv = conn_send_cmd2(tconn, P_AUTH_CHALLENGE, my_challenge, CHALLENGE_LEN);
+       rv = !conn_send_cmd2(tconn, P_AUTH_CHALLENGE, my_challenge, CHALLENGE_LEN);
        if (!rv)
                goto fail;
 
@@ -4320,7 +4320,7 @@ static int drbd_do_auth(struct drbd_tconn *tconn)
                goto fail;
        }
 
-       rv = conn_send_cmd2(tconn, P_AUTH_RESPONSE, response, resp_size);
+       rv = !conn_send_cmd2(tconn, P_AUTH_RESPONSE, response, resp_size);
        if (!rv)
                goto fail;