summaryrefslogtreecommitdiff
path: root/drivers/block/drbd
diff options
context:
space:
mode:
authorPhilipp Reisner <philipp.reisner@linbit.com>2011-02-07 16:47:12 +0100
committerPhilipp Reisner <philipp.reisner@linbit.com>2011-09-28 10:29:50 +0200
commit8a22cccc2068b35124f340fcc3f38b730007deff (patch)
tree9e6adc7937af79b4c9ddf6d8f259b7ead595eb18 /drivers/block/drbd
parenta25b63f1e75df7dbc27666b627e6277d7fea92b7 (diff)
drbd: Converted drbd_send_handshake() from mdev to tconn
Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com> Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>
Diffstat (limited to 'drivers/block/drbd')
-rw-r--r--drivers/block/drbd/drbd_int.h2
-rw-r--r--drivers/block/drbd/drbd_receiver.c20
2 files changed, 11 insertions, 11 deletions
diff --git a/drivers/block/drbd/drbd_int.h b/drivers/block/drbd/drbd_int.h
index e640ffdad9cd..845ff34d2060 100644
--- a/drivers/block/drbd/drbd_int.h
+++ b/drivers/block/drbd/drbd_int.h
@@ -378,7 +378,7 @@ struct p_block_req {
*/
struct p_handshake {
- struct p_header head; /* Note: You must always use a h80 here */
+ struct p_header head; /* Note: vnr will be ignored */
u32 protocol_min;
u32 feature_flags;
u32 protocol_max;
diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c
index 60a4f651a084..565f2ea47ab8 100644
--- a/drivers/block/drbd/drbd_receiver.c
+++ b/drivers/block/drbd/drbd_receiver.c
@@ -3952,28 +3952,28 @@ static void drbd_disconnect(struct drbd_conf *mdev)
*
* for now, they are expected to be zero, but ignored.
*/
-static int drbd_send_handshake(struct drbd_conf *mdev)
+static int drbd_send_handshake(struct drbd_tconn *tconn)
{
/* ASSERT current == mdev->tconn->receiver ... */
- struct p_handshake *p = &mdev->tconn->data.sbuf.handshake;
+ struct p_handshake *p = &tconn->data.sbuf.handshake;
int ok;
- if (mutex_lock_interruptible(&mdev->tconn->data.mutex)) {
- dev_err(DEV, "interrupted during initial handshake\n");
+ if (mutex_lock_interruptible(&tconn->data.mutex)) {
+ conn_err(tconn, "interrupted during initial handshake\n");
return 0; /* interrupted. not ok. */
}
- if (mdev->tconn->data.socket == NULL) {
- mutex_unlock(&mdev->tconn->data.mutex);
+ if (tconn->data.socket == NULL) {
+ mutex_unlock(&tconn->data.mutex);
return 0;
}
memset(p, 0, sizeof(*p));
p->protocol_min = cpu_to_be32(PRO_VERSION_MIN);
p->protocol_max = cpu_to_be32(PRO_VERSION_MAX);
- ok = _drbd_send_cmd(mdev, mdev->tconn->data.socket, P_HAND_SHAKE,
- &p->head, sizeof(*p), 0 );
- mutex_unlock(&mdev->tconn->data.mutex);
+ ok = _conn_send_cmd(tconn, 0, tconn->data.socket, P_HAND_SHAKE,
+ &p->head, sizeof(*p), 0);
+ mutex_unlock(&tconn->data.mutex);
return ok;
}
@@ -3993,7 +3993,7 @@ static int drbd_do_handshake(struct drbd_conf *mdev)
enum drbd_packet cmd;
int rv;
- rv = drbd_send_handshake(mdev);
+ rv = drbd_send_handshake(mdev->tconn);
if (!rv)
return 0;