diff options
author | Andreas Gruenbacher <agruen@linbit.com> | 2014-09-11 08:29:05 -0400 |
---|---|---|
committer | Jens Axboe <axboe@fb.com> | 2014-09-11 10:41:29 -0400 |
commit | 11f8b2b69d32d43a6d9b45c60c1fee48ab91f440 (patch) | |
tree | 8a1e1f1a1e09f452eb7dd54d896e9fd7a4b1e885 | |
parent | 018a17bdc8658ad448497c84d4ba21b6985820ec (diff) |
drbd: Use better variable names
Rename local variable 'ds' to 'disk_state' or 'data_size'.
'dgs' to 'digest_size'
Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>
Signed-off-by: Jens Axboe <axboe@fb.com>
-rw-r--r-- | drivers/block/drbd/drbd_int.h | 6 | ||||
-rw-r--r-- | drivers/block/drbd/drbd_main.c | 28 | ||||
-rw-r--r-- | drivers/block/drbd/drbd_receiver.c | 46 | ||||
-rw-r--r-- | drivers/block/drbd/drbd_state.c | 18 |
4 files changed, 49 insertions, 49 deletions
diff --git a/drivers/block/drbd/drbd_int.h b/drivers/block/drbd/drbd_int.h index 1a000016ccdf..9e1288e4148c 100644 --- a/drivers/block/drbd/drbd_int.h +++ b/drivers/block/drbd/drbd_int.h | |||
@@ -2109,7 +2109,7 @@ static inline bool is_sync_state(enum drbd_conns connection_state) | |||
2109 | 2109 | ||
2110 | static inline void put_ldev(struct drbd_device *device) | 2110 | static inline void put_ldev(struct drbd_device *device) |
2111 | { | 2111 | { |
2112 | enum drbd_disk_state ds = device->state.disk; | 2112 | enum drbd_disk_state disk_state = device->state.disk; |
2113 | /* We must check the state *before* the atomic_dec becomes visible, | 2113 | /* We must check the state *before* the atomic_dec becomes visible, |
2114 | * or we have a theoretical race where someone hitting zero, | 2114 | * or we have a theoretical race where someone hitting zero, |
2115 | * while state still D_FAILED, will then see D_DISKLESS in the | 2115 | * while state still D_FAILED, will then see D_DISKLESS in the |
@@ -2122,10 +2122,10 @@ static inline void put_ldev(struct drbd_device *device) | |||
2122 | __release(local); | 2122 | __release(local); |
2123 | D_ASSERT(device, i >= 0); | 2123 | D_ASSERT(device, i >= 0); |
2124 | if (i == 0) { | 2124 | if (i == 0) { |
2125 | if (ds == D_DISKLESS) | 2125 | if (disk_state == D_DISKLESS) |
2126 | /* even internal references gone, safe to destroy */ | 2126 | /* even internal references gone, safe to destroy */ |
2127 | drbd_device_post_work(device, DESTROY_DISK); | 2127 | drbd_device_post_work(device, DESTROY_DISK); |
2128 | if (ds == D_FAILED) | 2128 | if (disk_state == D_FAILED) |
2129 | /* all application IO references gone. */ | 2129 | /* all application IO references gone. */ |
2130 | if (!test_and_set_bit(GOING_DISKLESS, &device->flags)) | 2130 | if (!test_and_set_bit(GOING_DISKLESS, &device->flags)) |
2131 | drbd_device_post_work(device, GO_DISKLESS); | 2131 | drbd_device_post_work(device, GO_DISKLESS); |
diff --git a/drivers/block/drbd/drbd_main.c b/drivers/block/drbd/drbd_main.c index 9b465bb68487..973c185c9cfe 100644 --- a/drivers/block/drbd/drbd_main.c +++ b/drivers/block/drbd/drbd_main.c | |||
@@ -1622,13 +1622,13 @@ int drbd_send_dblock(struct drbd_peer_device *peer_device, struct drbd_request * | |||
1622 | struct drbd_socket *sock; | 1622 | struct drbd_socket *sock; |
1623 | struct p_data *p; | 1623 | struct p_data *p; |
1624 | unsigned int dp_flags = 0; | 1624 | unsigned int dp_flags = 0; |
1625 | int dgs; | 1625 | int digest_size; |
1626 | int err; | 1626 | int err; |
1627 | 1627 | ||
1628 | sock = &peer_device->connection->data; | 1628 | sock = &peer_device->connection->data; |
1629 | p = drbd_prepare_command(peer_device, sock); | 1629 | p = drbd_prepare_command(peer_device, sock); |
1630 | dgs = peer_device->connection->integrity_tfm ? | 1630 | digest_size = peer_device->connection->integrity_tfm ? |
1631 | crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0; | 1631 | crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0; |
1632 | 1632 | ||
1633 | if (!p) | 1633 | if (!p) |
1634 | return -EIO; | 1634 | return -EIO; |
@@ -1659,9 +1659,9 @@ int drbd_send_dblock(struct drbd_peer_device *peer_device, struct drbd_request * | |||
1659 | 1659 | ||
1660 | /* our digest is still only over the payload. | 1660 | /* our digest is still only over the payload. |
1661 | * TRIM does not carry any payload. */ | 1661 | * TRIM does not carry any payload. */ |
1662 | if (dgs) | 1662 | if (digest_size) |
1663 | drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, p + 1); | 1663 | drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, p + 1); |
1664 | err = __send_command(peer_device->connection, device->vnr, sock, P_DATA, sizeof(*p) + dgs, NULL, req->i.size); | 1664 | err = __send_command(peer_device->connection, device->vnr, sock, P_DATA, sizeof(*p) + digest_size, NULL, req->i.size); |
1665 | if (!err) { | 1665 | if (!err) { |
1666 | /* For protocol A, we have to memcpy the payload into | 1666 | /* For protocol A, we have to memcpy the payload into |
1667 | * socket buffers, as we may complete right away | 1667 | * socket buffers, as we may complete right away |
@@ -1674,23 +1674,23 @@ int drbd_send_dblock(struct drbd_peer_device *peer_device, struct drbd_request * | |||
1674 | * out ok after sending on this side, but does not fit on the | 1674 | * out ok after sending on this side, but does not fit on the |
1675 | * receiving side, we sure have detected corruption elsewhere. | 1675 | * receiving side, we sure have detected corruption elsewhere. |
1676 | */ | 1676 | */ |
1677 | if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || dgs) | 1677 | if (!(req->rq_state & (RQ_EXP_RECEIVE_ACK | RQ_EXP_WRITE_ACK)) || digest_size) |
1678 | err = _drbd_send_bio(peer_device, req->master_bio); | 1678 | err = _drbd_send_bio(peer_device, req->master_bio); |
1679 | else | 1679 | else |
1680 | err = _drbd_send_zc_bio(peer_device, req->master_bio); | 1680 | err = _drbd_send_zc_bio(peer_device, req->master_bio); |
1681 | 1681 | ||
1682 | /* double check digest, sometimes buffers have been modified in flight. */ | 1682 | /* double check digest, sometimes buffers have been modified in flight. */ |
1683 | if (dgs > 0 && dgs <= 64) { | 1683 | if (digest_size > 0 && digest_size <= 64) { |
1684 | /* 64 byte, 512 bit, is the largest digest size | 1684 | /* 64 byte, 512 bit, is the largest digest size |
1685 | * currently supported in kernel crypto. */ | 1685 | * currently supported in kernel crypto. */ |
1686 | unsigned char digest[64]; | 1686 | unsigned char digest[64]; |
1687 | drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest); | 1687 | drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest); |
1688 | if (memcmp(p + 1, digest, dgs)) { | 1688 | if (memcmp(p + 1, digest, digest_size)) { |
1689 | drbd_warn(device, | 1689 | drbd_warn(device, |
1690 | "Digest mismatch, buffer modified by upper layers during write: %llus +%u\n", | 1690 | "Digest mismatch, buffer modified by upper layers during write: %llus +%u\n", |
1691 | (unsigned long long)req->i.sector, req->i.size); | 1691 | (unsigned long long)req->i.sector, req->i.size); |
1692 | } | 1692 | } |
1693 | } /* else if (dgs > 64) { | 1693 | } /* else if (digest_size > 64) { |
1694 | ... Be noisy about digest too large ... | 1694 | ... Be noisy about digest too large ... |
1695 | } */ | 1695 | } */ |
1696 | } | 1696 | } |
@@ -1711,13 +1711,13 @@ int drbd_send_block(struct drbd_peer_device *peer_device, enum drbd_packet cmd, | |||
1711 | struct drbd_socket *sock; | 1711 | struct drbd_socket *sock; |
1712 | struct p_data *p; | 1712 | struct p_data *p; |
1713 | int err; | 1713 | int err; |
1714 | int dgs; | 1714 | int digest_size; |
1715 | 1715 | ||
1716 | sock = &peer_device->connection->data; | 1716 | sock = &peer_device->connection->data; |
1717 | p = drbd_prepare_command(peer_device, sock); | 1717 | p = drbd_prepare_command(peer_device, sock); |
1718 | 1718 | ||
1719 | dgs = peer_device->connection->integrity_tfm ? | 1719 | digest_size = peer_device->connection->integrity_tfm ? |
1720 | crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0; | 1720 | crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0; |
1721 | 1721 | ||
1722 | if (!p) | 1722 | if (!p) |
1723 | return -EIO; | 1723 | return -EIO; |
@@ -1725,9 +1725,9 @@ int drbd_send_block(struct drbd_peer_device *peer_device, enum drbd_packet cmd, | |||
1725 | p->block_id = peer_req->block_id; | 1725 | p->block_id = peer_req->block_id; |
1726 | p->seq_num = 0; /* unused */ | 1726 | p->seq_num = 0; /* unused */ |
1727 | p->dp_flags = 0; | 1727 | p->dp_flags = 0; |
1728 | if (dgs) | 1728 | if (digest_size) |
1729 | drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1); | 1729 | drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1); |
1730 | err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + dgs, NULL, peer_req->i.size); | 1730 | err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NULL, peer_req->i.size); |
1731 | if (!err) | 1731 | if (!err) |
1732 | err = _drbd_send_zc_ee(peer_device, peer_req); | 1732 | err = _drbd_send_zc_ee(peer_device, peer_req); |
1733 | mutex_unlock(&sock->mutex); /* locked by drbd_prepare_command() */ | 1733 | mutex_unlock(&sock->mutex); /* locked by drbd_prepare_command() */ |
diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c index 9342b8da73ab..3ae769e671e8 100644 --- a/drivers/block/drbd/drbd_receiver.c +++ b/drivers/block/drbd/drbd_receiver.c | |||
@@ -1371,9 +1371,9 @@ int drbd_submit_peer_request(struct drbd_device *device, | |||
1371 | struct bio *bio; | 1371 | struct bio *bio; |
1372 | struct page *page = peer_req->pages; | 1372 | struct page *page = peer_req->pages; |
1373 | sector_t sector = peer_req->i.sector; | 1373 | sector_t sector = peer_req->i.sector; |
1374 | unsigned ds = peer_req->i.size; | 1374 | unsigned data_size = peer_req->i.size; |
1375 | unsigned n_bios = 0; | 1375 | unsigned n_bios = 0; |
1376 | unsigned nr_pages = (ds + PAGE_SIZE -1) >> PAGE_SHIFT; | 1376 | unsigned nr_pages = (data_size + PAGE_SIZE -1) >> PAGE_SHIFT; |
1377 | int err = -ENOMEM; | 1377 | int err = -ENOMEM; |
1378 | 1378 | ||
1379 | if (peer_req->flags & EE_IS_TRIM_USE_ZEROOUT) { | 1379 | if (peer_req->flags & EE_IS_TRIM_USE_ZEROOUT) { |
@@ -1388,7 +1388,7 @@ int drbd_submit_peer_request(struct drbd_device *device, | |||
1388 | list_add_tail(&peer_req->w.list, &device->active_ee); | 1388 | list_add_tail(&peer_req->w.list, &device->active_ee); |
1389 | spin_unlock_irq(&device->resource->req_lock); | 1389 | spin_unlock_irq(&device->resource->req_lock); |
1390 | if (blkdev_issue_zeroout(device->ldev->backing_bdev, | 1390 | if (blkdev_issue_zeroout(device->ldev->backing_bdev, |
1391 | sector, ds >> 9, GFP_NOIO)) | 1391 | sector, data_size >> 9, GFP_NOIO)) |
1392 | peer_req->flags |= EE_WAS_ERROR; | 1392 | peer_req->flags |= EE_WAS_ERROR; |
1393 | drbd_endio_write_sec_final(peer_req); | 1393 | drbd_endio_write_sec_final(peer_req); |
1394 | return 0; | 1394 | return 0; |
@@ -1426,12 +1426,12 @@ next_bio: | |||
1426 | ++n_bios; | 1426 | ++n_bios; |
1427 | 1427 | ||
1428 | if (rw & REQ_DISCARD) { | 1428 | if (rw & REQ_DISCARD) { |
1429 | bio->bi_iter.bi_size = ds; | 1429 | bio->bi_iter.bi_size = data_size; |
1430 | goto submit; | 1430 | goto submit; |
1431 | } | 1431 | } |
1432 | 1432 | ||
1433 | page_chain_for_each(page) { | 1433 | page_chain_for_each(page) { |
1434 | unsigned len = min_t(unsigned, ds, PAGE_SIZE); | 1434 | unsigned len = min_t(unsigned, data_size, PAGE_SIZE); |
1435 | if (!bio_add_page(bio, page, len, 0)) { | 1435 | if (!bio_add_page(bio, page, len, 0)) { |
1436 | /* A single page must always be possible! | 1436 | /* A single page must always be possible! |
1437 | * But in case it fails anyways, | 1437 | * But in case it fails anyways, |
@@ -1446,11 +1446,11 @@ next_bio: | |||
1446 | } | 1446 | } |
1447 | goto next_bio; | 1447 | goto next_bio; |
1448 | } | 1448 | } |
1449 | ds -= len; | 1449 | data_size -= len; |
1450 | sector += len >> 9; | 1450 | sector += len >> 9; |
1451 | --nr_pages; | 1451 | --nr_pages; |
1452 | } | 1452 | } |
1453 | D_ASSERT(device, ds == 0); | 1453 | D_ASSERT(device, data_size == 0); |
1454 | submit: | 1454 | submit: |
1455 | D_ASSERT(device, page == NULL); | 1455 | D_ASSERT(device, page == NULL); |
1456 | 1456 | ||
@@ -1591,24 +1591,24 @@ read_in_block(struct drbd_peer_device *peer_device, u64 id, sector_t sector, | |||
1591 | const sector_t capacity = drbd_get_capacity(device->this_bdev); | 1591 | const sector_t capacity = drbd_get_capacity(device->this_bdev); |
1592 | struct drbd_peer_request *peer_req; | 1592 | struct drbd_peer_request *peer_req; |
1593 | struct page *page; | 1593 | struct page *page; |
1594 | int dgs, ds, err; | 1594 | int digest_size, err; |
1595 | unsigned int data_size = pi->size; | 1595 | unsigned int data_size = pi->size, ds; |
1596 | void *dig_in = peer_device->connection->int_dig_in; | 1596 | void *dig_in = peer_device->connection->int_dig_in; |
1597 | void *dig_vv = peer_device->connection->int_dig_vv; | 1597 | void *dig_vv = peer_device->connection->int_dig_vv; |
1598 | unsigned long *data; | 1598 | unsigned long *data; |
1599 | struct p_trim *trim = (pi->cmd == P_TRIM) ? pi->data : NULL; | 1599 | struct p_trim *trim = (pi->cmd == P_TRIM) ? pi->data : NULL; |
1600 | 1600 | ||
1601 | dgs = 0; | 1601 | digest_size = 0; |
1602 | if (!trim && peer_device->connection->peer_integrity_tfm) { | 1602 | if (!trim && peer_device->connection->peer_integrity_tfm) { |
1603 | dgs = crypto_hash_digestsize(peer_device->connection->peer_integrity_tfm); | 1603 | digest_size = crypto_hash_digestsize(peer_device->connection->peer_integrity_tfm); |
1604 | /* | 1604 | /* |
1605 | * FIXME: Receive the incoming digest into the receive buffer | 1605 | * FIXME: Receive the incoming digest into the receive buffer |
1606 | * here, together with its struct p_data? | 1606 | * here, together with its struct p_data? |
1607 | */ | 1607 | */ |
1608 | err = drbd_recv_all_warn(peer_device->connection, dig_in, dgs); | 1608 | err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size); |
1609 | if (err) | 1609 | if (err) |
1610 | return NULL; | 1610 | return NULL; |
1611 | data_size -= dgs; | 1611 | data_size -= digest_size; |
1612 | } | 1612 | } |
1613 | 1613 | ||
1614 | if (trim) { | 1614 | if (trim) { |
@@ -1661,16 +1661,16 @@ read_in_block(struct drbd_peer_device *peer_device, u64 id, sector_t sector, | |||
1661 | ds -= len; | 1661 | ds -= len; |
1662 | } | 1662 | } |
1663 | 1663 | ||
1664 | if (dgs) { | 1664 | if (digest_size) { |
1665 | drbd_csum_ee(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv); | 1665 | drbd_csum_ee(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv); |
1666 | if (memcmp(dig_in, dig_vv, dgs)) { | 1666 | if (memcmp(dig_in, dig_vv, digest_size)) { |
1667 | drbd_err(device, "Digest integrity check FAILED: %llus +%u\n", | 1667 | drbd_err(device, "Digest integrity check FAILED: %llus +%u\n", |
1668 | (unsigned long long)sector, data_size); | 1668 | (unsigned long long)sector, data_size); |
1669 | drbd_free_peer_req(device, peer_req); | 1669 | drbd_free_peer_req(device, peer_req); |
1670 | return NULL; | 1670 | return NULL; |
1671 | } | 1671 | } |
1672 | } | 1672 | } |
1673 | device->recv_cnt += data_size>>9; | 1673 | device->recv_cnt += data_size >> 9; |
1674 | return peer_req; | 1674 | return peer_req; |
1675 | } | 1675 | } |
1676 | 1676 | ||
@@ -1708,17 +1708,17 @@ static int recv_dless_read(struct drbd_peer_device *peer_device, struct drbd_req | |||
1708 | struct bio_vec bvec; | 1708 | struct bio_vec bvec; |
1709 | struct bvec_iter iter; | 1709 | struct bvec_iter iter; |
1710 | struct bio *bio; | 1710 | struct bio *bio; |
1711 | int dgs, err, expect; | 1711 | int digest_size, err, expect; |
1712 | void *dig_in = peer_device->connection->int_dig_in; | 1712 | void *dig_in = peer_device->connection->int_dig_in; |
1713 | void *dig_vv = peer_device->connection->int_dig_vv; | 1713 | void *dig_vv = peer_device->connection->int_dig_vv; |
1714 | 1714 | ||
1715 | dgs = 0; | 1715 | digest_size = 0; |
1716 | if (peer_device->connection->peer_integrity_tfm) { | 1716 | if (peer_device->connection->peer_integrity_tfm) { |
1717 | dgs = crypto_hash_digestsize(peer_device->connection->peer_integrity_tfm); | 1717 | digest_size = crypto_hash_digestsize(peer_device->connection->peer_integrity_tfm); |
1718 | err = drbd_recv_all_warn(peer_device->connection, dig_in, dgs); | 1718 | err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size); |
1719 | if (err) | 1719 | if (err) |
1720 | return err; | 1720 | return err; |
1721 | data_size -= dgs; | 1721 | data_size -= digest_size; |
1722 | } | 1722 | } |
1723 | 1723 | ||
1724 | /* optimistically update recv_cnt. if receiving fails below, | 1724 | /* optimistically update recv_cnt. if receiving fails below, |
@@ -1738,9 +1738,9 @@ static int recv_dless_read(struct drbd_peer_device *peer_device, struct drbd_req | |||
1738 | data_size -= expect; | 1738 | data_size -= expect; |
1739 | } | 1739 | } |
1740 | 1740 | ||
1741 | if (dgs) { | 1741 | if (digest_size) { |
1742 | drbd_csum_bio(peer_device->connection->peer_integrity_tfm, bio, dig_vv); | 1742 | drbd_csum_bio(peer_device->connection->peer_integrity_tfm, bio, dig_vv); |
1743 | if (memcmp(dig_in, dig_vv, dgs)) { | 1743 | if (memcmp(dig_in, dig_vv, digest_size)) { |
1744 | drbd_err(peer_device, "Digest integrity check FAILED. Broken NICs?\n"); | 1744 | drbd_err(peer_device, "Digest integrity check FAILED. Broken NICs?\n"); |
1745 | return -EINVAL; | 1745 | return -EINVAL; |
1746 | } | 1746 | } |
diff --git a/drivers/block/drbd/drbd_state.c b/drivers/block/drbd/drbd_state.c index c35c0f001bb7..84b11f887d73 100644 --- a/drivers/block/drbd/drbd_state.c +++ b/drivers/block/drbd/drbd_state.c | |||
@@ -136,50 +136,50 @@ enum drbd_role conn_highest_peer(struct drbd_connection *connection) | |||
136 | 136 | ||
137 | enum drbd_disk_state conn_highest_disk(struct drbd_connection *connection) | 137 | enum drbd_disk_state conn_highest_disk(struct drbd_connection *connection) |
138 | { | 138 | { |
139 | enum drbd_disk_state ds = D_DISKLESS; | 139 | enum drbd_disk_state disk_state = D_DISKLESS; |
140 | struct drbd_peer_device *peer_device; | 140 | struct drbd_peer_device *peer_device; |
141 | int vnr; | 141 | int vnr; |
142 | 142 | ||
143 | rcu_read_lock(); | 143 | rcu_read_lock(); |
144 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { | 144 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { |
145 | struct drbd_device *device = peer_device->device; | 145 | struct drbd_device *device = peer_device->device; |
146 | ds = max_t(enum drbd_disk_state, ds, device->state.disk); | 146 | disk_state = max_t(enum drbd_disk_state, disk_state, device->state.disk); |
147 | } | 147 | } |
148 | rcu_read_unlock(); | 148 | rcu_read_unlock(); |
149 | 149 | ||
150 | return ds; | 150 | return disk_state; |
151 | } | 151 | } |
152 | 152 | ||
153 | enum drbd_disk_state conn_lowest_disk(struct drbd_connection *connection) | 153 | enum drbd_disk_state conn_lowest_disk(struct drbd_connection *connection) |
154 | { | 154 | { |
155 | enum drbd_disk_state ds = D_MASK; | 155 | enum drbd_disk_state disk_state = D_MASK; |
156 | struct drbd_peer_device *peer_device; | 156 | struct drbd_peer_device *peer_device; |
157 | int vnr; | 157 | int vnr; |
158 | 158 | ||
159 | rcu_read_lock(); | 159 | rcu_read_lock(); |
160 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { | 160 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { |
161 | struct drbd_device *device = peer_device->device; | 161 | struct drbd_device *device = peer_device->device; |
162 | ds = min_t(enum drbd_disk_state, ds, device->state.disk); | 162 | disk_state = min_t(enum drbd_disk_state, disk_state, device->state.disk); |
163 | } | 163 | } |
164 | rcu_read_unlock(); | 164 | rcu_read_unlock(); |
165 | 165 | ||
166 | return ds; | 166 | return disk_state; |
167 | } | 167 | } |
168 | 168 | ||
169 | enum drbd_disk_state conn_highest_pdsk(struct drbd_connection *connection) | 169 | enum drbd_disk_state conn_highest_pdsk(struct drbd_connection *connection) |
170 | { | 170 | { |
171 | enum drbd_disk_state ds = D_DISKLESS; | 171 | enum drbd_disk_state disk_state = D_DISKLESS; |
172 | struct drbd_peer_device *peer_device; | 172 | struct drbd_peer_device *peer_device; |
173 | int vnr; | 173 | int vnr; |
174 | 174 | ||
175 | rcu_read_lock(); | 175 | rcu_read_lock(); |
176 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { | 176 | idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { |
177 | struct drbd_device *device = peer_device->device; | 177 | struct drbd_device *device = peer_device->device; |
178 | ds = max_t(enum drbd_disk_state, ds, device->state.pdsk); | 178 | disk_state = max_t(enum drbd_disk_state, disk_state, device->state.pdsk); |
179 | } | 179 | } |
180 | rcu_read_unlock(); | 180 | rcu_read_unlock(); |
181 | 181 | ||
182 | return ds; | 182 | return disk_state; |
183 | } | 183 | } |
184 | 184 | ||
185 | enum drbd_conns conn_lowest_conn(struct drbd_connection *connection) | 185 | enum drbd_conns conn_lowest_conn(struct drbd_connection *connection) |