aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAndreas Gruenbacher <agruen@linbit.com>2014-09-11 08:29:05 -0400
committerJens Axboe <axboe@fb.com>2014-09-11 10:41:29 -0400
commit11f8b2b69d32d43a6d9b45c60c1fee48ab91f440 (patch)
tree8a1e1f1a1e09f452eb7dd54d896e9fd7a4b1e885
parent018a17bdc8658ad448497c84d4ba21b6985820ec (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.h6
-rw-r--r--drivers/block/drbd/drbd_main.c28
-rw-r--r--drivers/block/drbd/drbd_receiver.c46
-rw-r--r--drivers/block/drbd/drbd_state.c18
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
2110static inline void put_ldev(struct drbd_device *device) 2110static 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);
1454submit: 1454submit:
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
137enum drbd_disk_state conn_highest_disk(struct drbd_connection *connection) 137enum 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
153enum drbd_disk_state conn_lowest_disk(struct drbd_connection *connection) 153enum 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
169enum drbd_disk_state conn_highest_pdsk(struct drbd_connection *connection) 169enum 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
185enum drbd_conns conn_lowest_conn(struct drbd_connection *connection) 185enum drbd_conns conn_lowest_conn(struct drbd_connection *connection)