Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 345964
b: refs/heads/master
c: 6038178
h: refs/heads/master
v: v3
  • Loading branch information
Andreas Gruenbacher authored and Philipp Reisner committed Nov 8, 2012
1 parent 8385025 commit 42dd2cc
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 20 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: e5d6f33abe9da025d3d891367f93d084e8c74bf5
refs/heads/master: 6038178ebe29e6b5e4d519a5ac56653d156c90f9
6 changes: 3 additions & 3 deletions trunk/drivers/block/drbd/drbd_int.h
Original file line number Diff line number Diff line change
Expand Up @@ -235,7 +235,7 @@ enum drbd_packet {
P_INITIAL_META = 0xfff1, /* First Packet on the MetaSock */
P_INITIAL_DATA = 0xfff2, /* First Packet on the Socket */

P_HAND_SHAKE = 0xfffe /* FIXED for the next century! */
P_CONNECTION_FEATURES = 0xfffe /* FIXED for the next century! */
};

extern const char *cmdname(enum drbd_packet cmd);
Expand Down Expand Up @@ -374,14 +374,14 @@ struct p_block_req {

/*
* commands with their own struct for additional fields:
* P_HAND_SHAKE
* P_CONNECTION_FEATURES
* P_BARRIER
* P_BARRIER_ACK
* P_SYNC_PARAM
* ReportParams
*/

struct p_handshake {
struct p_connection_features {
struct p_header head; /* Note: vnr will be ignored */
u32 protocol_min;
u32 feature_flags;
Expand Down
6 changes: 3 additions & 3 deletions trunk/drivers/block/drbd/drbd_main.c
Original file line number Diff line number Diff line change
Expand Up @@ -2497,7 +2497,7 @@ int __init drbd_init(void)
int err;

BUILD_BUG_ON(sizeof(struct p_header80) != sizeof(struct p_header95));
BUILD_BUG_ON(sizeof(struct p_handshake) != 80);
BUILD_BUG_ON(sizeof(struct p_connection_features) != 80);

if (minor_count < DRBD_MINOR_COUNT_MIN || minor_count > DRBD_MINOR_COUNT_MAX) {
printk(KERN_ERR
Expand Down Expand Up @@ -3149,8 +3149,8 @@ const char *cmdname(enum drbd_packet cmd)
return "InitialMeta";
if (cmd == P_INITIAL_DATA)
return "InitialData";
if (cmd == P_HAND_SHAKE)
return "HandShake";
if (cmd == P_CONNECTION_FEATURES)
return "ConnectionFeatures";
if (cmd >= ARRAY_SIZE(cmdnames))
return "Unknown";
return cmdnames[cmd];
Expand Down
26 changes: 13 additions & 13 deletions trunk/drivers/block/drbd/drbd_receiver.c
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ enum finish_epoch {
FE_RECYCLED,
};

static int drbd_do_handshake(struct drbd_tconn *tconn);
static int drbd_do_features(struct drbd_tconn *tconn);
static int drbd_do_auth(struct drbd_tconn *tconn);
static int drbd_disconnected(int vnr, void *p, void *data);

Expand Down Expand Up @@ -913,7 +913,7 @@ static int drbd_connect(struct drbd_tconn *tconn)
/* NOT YET ...
* sock->sk->sk_sndtimeo = tconn->net_conf->timeout*HZ/10;
* sock->sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT;
* first set it to the P_HAND_SHAKE timeout,
* first set it to the P_CONNECTION_FEATURES timeout,
* which we set to 4x the configured ping_timeout. */
sock->sk->sk_sndtimeo =
sock->sk->sk_rcvtimeo = tconn->net_conf->ping_timeo*4*HZ/10;
Expand All @@ -928,7 +928,7 @@ static int drbd_connect(struct drbd_tconn *tconn)

tconn->last_received = jiffies;

h = drbd_do_handshake(tconn);
h = drbd_do_features(tconn);
if (h <= 0)
return h;

Expand Down Expand Up @@ -4176,10 +4176,10 @@ static int drbd_disconnected(int vnr, void *p, void *data)
*
* for now, they are expected to be zero, but ignored.
*/
static int drbd_send_handshake(struct drbd_tconn *tconn)
static int drbd_send_features(struct drbd_tconn *tconn)
{
/* ASSERT current == mdev->tconn->receiver ... */
struct p_handshake *p = tconn->data.sbuf;
struct p_connection_features *p = tconn->data.sbuf;
int err;

if (mutex_lock_interruptible(&tconn->data.mutex)) {
Expand All @@ -4195,7 +4195,7 @@ static int drbd_send_handshake(struct drbd_tconn *tconn)
memset(p, 0, sizeof(*p));
p->protocol_min = cpu_to_be32(PRO_VERSION_MIN);
p->protocol_max = cpu_to_be32(PRO_VERSION_MAX);
err = _conn_send_cmd(tconn, 0, &tconn->data, P_HAND_SHAKE,
err = _conn_send_cmd(tconn, 0, &tconn->data, P_CONNECTION_FEATURES,
&p->head, sizeof(*p), 0);
mutex_unlock(&tconn->data.mutex);
return err;
Expand All @@ -4208,30 +4208,30 @@ static int drbd_send_handshake(struct drbd_tconn *tconn)
* -1 peer talks different language,
* no point in trying again, please go standalone.
*/
static int drbd_do_handshake(struct drbd_tconn *tconn)
static int drbd_do_features(struct drbd_tconn *tconn)
{
/* ASSERT current == tconn->receiver ... */
struct p_handshake *p = tconn->data.rbuf;
const int expect = sizeof(struct p_handshake) - sizeof(struct p_header80);
struct p_connection_features *p = tconn->data.rbuf;
const int expect = sizeof(struct p_connection_features) - sizeof(struct p_header80);
struct packet_info pi;
int err;

err = drbd_send_handshake(tconn);
err = drbd_send_features(tconn);
if (err)
return 0;

err = drbd_recv_header(tconn, &pi);
if (err)
return 0;

if (pi.cmd != P_HAND_SHAKE) {
conn_err(tconn, "expected HandShake packet, received: %s (0x%04x)\n",
if (pi.cmd != P_CONNECTION_FEATURES) {
conn_err(tconn, "expected ConnectionFeatures packet, received: %s (0x%04x)\n",
cmdname(pi.cmd), pi.cmd);
return -1;
}

if (pi.size != expect) {
conn_err(tconn, "expected HandShake length: %u, received: %u\n",
conn_err(tconn, "expected ConnectionFeatures length: %u, received: %u\n",
expect, pi.size);
return -1;
}
Expand Down

0 comments on commit 42dd2cc

Please sign in to comment.