Commit 927036f9 authored by Andreas Gruenbacher's avatar Andreas Gruenbacher Committed by Philipp Reisner

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

Signed-off-by: default avatarPhilipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: default avatarLars Ellenberg <lars.ellenberg@linbit.com>
parent 103ea275
...@@ -974,7 +974,7 @@ int drbd_send_state(struct drbd_conf *mdev) ...@@ -974,7 +974,7 @@ int drbd_send_state(struct drbd_conf *mdev)
{ {
struct socket *sock; struct socket *sock;
struct p_state p; struct p_state p;
int ok = 0; int err = -EIO;
mutex_lock(&mdev->tconn->data.mutex); mutex_lock(&mdev->tconn->data.mutex);
...@@ -982,11 +982,11 @@ int drbd_send_state(struct drbd_conf *mdev) ...@@ -982,11 +982,11 @@ int drbd_send_state(struct drbd_conf *mdev)
sock = mdev->tconn->data.socket; sock = mdev->tconn->data.socket;
if (likely(sock != NULL)) if (likely(sock != NULL))
ok = !_drbd_send_cmd(mdev, sock, P_STATE, &p.head, sizeof(p), 0); err = _drbd_send_cmd(mdev, sock, P_STATE, &p.head, sizeof(p), 0);
mutex_unlock(&mdev->tconn->data.mutex); mutex_unlock(&mdev->tconn->data.mutex);
return ok; return err;
} }
int _conn_send_state_req(struct drbd_tconn *tconn, int vnr, enum drbd_packet cmd, int _conn_send_state_req(struct drbd_tconn *tconn, int vnr, enum drbd_packet cmd,
......
...@@ -766,7 +766,7 @@ int drbd_connected(int vnr, void *p, void *data) ...@@ -766,7 +766,7 @@ int drbd_connected(int vnr, void *p, void *data)
ok &= !drbd_send_sync_param(mdev); ok &= !drbd_send_sync_param(mdev);
ok &= drbd_send_sizes(mdev, 0, 0); ok &= drbd_send_sizes(mdev, 0, 0);
ok &= drbd_send_uuids(mdev); ok &= drbd_send_uuids(mdev);
ok &= drbd_send_state(mdev); ok &= !drbd_send_state(mdev);
clear_bit(USE_DEGR_WFC_T, &mdev->flags); clear_bit(USE_DEGR_WFC_T, &mdev->flags);
clear_bit(RESIZE_PENDING, &mdev->flags); clear_bit(RESIZE_PENDING, &mdev->flags);
......
...@@ -1188,7 +1188,7 @@ static void after_state_ch(struct drbd_conf *mdev, union drbd_state os, ...@@ -1188,7 +1188,7 @@ static void after_state_ch(struct drbd_conf *mdev, union drbd_state os,
"ASSERT FAILED: disk is %s during detach\n", "ASSERT FAILED: disk is %s during detach\n",
drbd_disk_str(mdev->state.disk)); drbd_disk_str(mdev->state.disk));
if (drbd_send_state(mdev)) if (!drbd_send_state(mdev))
dev_warn(DEV, "Notified peer that I am detaching my disk\n"); dev_warn(DEV, "Notified peer that I am detaching my disk\n");
else else
dev_err(DEV, "Sending state for detaching disk failed\n"); dev_err(DEV, "Sending state for detaching disk failed\n");
...@@ -1220,7 +1220,7 @@ static void after_state_ch(struct drbd_conf *mdev, union drbd_state os, ...@@ -1220,7 +1220,7 @@ static void after_state_ch(struct drbd_conf *mdev, union drbd_state os,
mdev->rs_failed = 0; mdev->rs_failed = 0;
atomic_set(&mdev->rs_pending_cnt, 0); atomic_set(&mdev->rs_pending_cnt, 0);
if (drbd_send_state(mdev)) if (!drbd_send_state(mdev))
dev_warn(DEV, "Notified peer that I'm now diskless.\n"); dev_warn(DEV, "Notified peer that I'm now diskless.\n");
/* corresponding get_ldev in __drbd_set_state /* corresponding get_ldev in __drbd_set_state
* this may finally trigger drbd_ldev_destroy. */ * this may finally trigger drbd_ldev_destroy. */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment