Commit 0625ac19 authored by Philipp Reisner's avatar Philipp Reisner

drbd: Converted wake_asender() and request_ping() from mdev to tconn

Signed-off-by: default avatarPhilipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: default avatarLars Ellenberg <lars.ellenberg@linbit.com>
parent 808e37b8
...@@ -1858,16 +1858,16 @@ drbd_queue_work(struct drbd_work_queue *q, struct drbd_work *w) ...@@ -1858,16 +1858,16 @@ drbd_queue_work(struct drbd_work_queue *q, struct drbd_work *w)
spin_unlock_irqrestore(&q->q_lock, flags); spin_unlock_irqrestore(&q->q_lock, flags);
} }
static inline void wake_asender(struct drbd_conf *mdev) static inline void wake_asender(struct drbd_tconn *tconn)
{ {
if (test_bit(SIGNAL_ASENDER, &mdev->tconn->flags)) if (test_bit(SIGNAL_ASENDER, &tconn->flags))
force_sig(DRBD_SIG, mdev->tconn->asender.task); force_sig(DRBD_SIG, tconn->asender.task);
} }
static inline void request_ping(struct drbd_conf *mdev) static inline void request_ping(struct drbd_tconn *tconn)
{ {
set_bit(SEND_PING, &mdev->tconn->flags); set_bit(SEND_PING, &tconn->flags);
wake_asender(mdev); wake_asender(tconn);
} }
static inline int drbd_send_short_cmd(struct drbd_conf *mdev, static inline int drbd_send_short_cmd(struct drbd_conf *mdev,
......
...@@ -1348,7 +1348,7 @@ static int we_should_drop_the_connection(struct drbd_conf *mdev, struct socket * ...@@ -1348,7 +1348,7 @@ static int we_should_drop_the_connection(struct drbd_conf *mdev, struct socket *
if (!drop_it) { if (!drop_it) {
dev_err(DEV, "[%s/%d] sock_sendmsg time expired, ko = %u\n", dev_err(DEV, "[%s/%d] sock_sendmsg time expired, ko = %u\n",
current->comm, current->pid, mdev->tconn->ko_count); current->comm, current->pid, mdev->tconn->ko_count);
request_ping(mdev); request_ping(mdev->tconn);
} }
return drop_it; /* && (mdev->state == R_PRIMARY) */; return drop_it; /* && (mdev->state == R_PRIMARY) */;
......
...@@ -318,7 +318,7 @@ drbd_set_role(struct drbd_conf *mdev, enum drbd_role new_role, int force) ...@@ -318,7 +318,7 @@ drbd_set_role(struct drbd_conf *mdev, enum drbd_role new_role, int force)
enum drbd_disk_state nps; enum drbd_disk_state nps;
if (new_role == R_PRIMARY) if (new_role == R_PRIMARY)
request_ping(mdev); /* Detect a dead peer ASAP */ request_ping(mdev->tconn); /* Detect a dead peer ASAP */
mutex_lock(&mdev->state_mutex); mutex_lock(&mdev->state_mutex);
......
...@@ -1864,7 +1864,7 @@ static int receive_Data(struct drbd_conf *mdev, enum drbd_packet cmd, ...@@ -1864,7 +1864,7 @@ static int receive_Data(struct drbd_conf *mdev, enum drbd_packet cmd,
* but I don't like the receiver using the msock */ * but I don't like the receiver using the msock */
put_ldev(mdev); put_ldev(mdev);
wake_asender(mdev); wake_asender(mdev->tconn);
finish_wait(&mdev->misc_wait, &wait); finish_wait(&mdev->misc_wait, &wait);
return true; return true;
} }
......
...@@ -145,7 +145,7 @@ static void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req) __rel ...@@ -145,7 +145,7 @@ static void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req) __rel
if (do_al_complete_io) if (do_al_complete_io)
drbd_al_complete_io(mdev, e_sector); drbd_al_complete_io(mdev, e_sector);
wake_asender(mdev); wake_asender(mdev->tconn);
put_ldev(mdev); put_ldev(mdev);
} }
...@@ -728,7 +728,7 @@ static int w_resync_finished(struct drbd_conf *mdev, struct drbd_work *w, int ca ...@@ -728,7 +728,7 @@ static int w_resync_finished(struct drbd_conf *mdev, struct drbd_work *w, int ca
static void ping_peer(struct drbd_conf *mdev) static void ping_peer(struct drbd_conf *mdev)
{ {
clear_bit(GOT_PING_ACK, &mdev->flags); clear_bit(GOT_PING_ACK, &mdev->flags);
request_ping(mdev); request_ping(mdev->tconn);
wait_event(mdev->misc_wait, wait_event(mdev->misc_wait,
test_bit(GOT_PING_ACK, &mdev->flags) || mdev->state.conn < C_CONNECTED); test_bit(GOT_PING_ACK, &mdev->flags) || mdev->state.conn < C_CONNECTED);
} }
......
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