aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--drivers/block/rbd.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/drivers/block/rbd.c b/drivers/block/rbd.c
index 6bbd5af1f029..013c7a549fb6 100644
--- a/drivers/block/rbd.c
+++ b/drivers/block/rbd.c
@@ -82,7 +82,6 @@ struct rbd_image_header {
82 __u8 obj_order; 82 __u8 obj_order;
83 __u8 crypt_type; 83 __u8 crypt_type;
84 __u8 comp_type; 84 __u8 comp_type;
85 struct rw_semaphore snap_rwsem;
86 struct ceph_snap_context *snapc; 85 struct ceph_snap_context *snapc;
87 size_t snap_names_len; 86 size_t snap_names_len;
88 u64 snap_seq; 87 u64 snap_seq;
@@ -173,6 +172,8 @@ struct rbd_device {
173 struct ceph_osd_event *watch_event; 172 struct ceph_osd_event *watch_event;
174 struct ceph_osd_request *watch_request; 173 struct ceph_osd_request *watch_request;
175 174
175 /* protects updating the header */
176 struct rw_semaphore header_rwsem;
176 char snap_name[RBD_MAX_SNAP_NAME_LEN]; 177 char snap_name[RBD_MAX_SNAP_NAME_LEN];
177 u32 cur_snap; /* index+1 of current snapshot within snap context 178 u32 cur_snap; /* index+1 of current snapshot within snap context
178 0 - for the head */ 179 0 - for the head */
@@ -502,7 +503,6 @@ static int rbd_header_from_disk(struct rbd_image_header *header,
502 if (!header->snapc) 503 if (!header->snapc)
503 return -ENOMEM; 504 return -ENOMEM;
504 505
505 init_rwsem(&header->snap_rwsem);
506 header->snap_names_len = le64_to_cpu(ondisk->snap_names_len); 506 header->snap_names_len = le64_to_cpu(ondisk->snap_names_len);
507 if (snap_count) { 507 if (snap_count) {
508 header->snap_names = kmalloc(header->snap_names_len, 508 header->snap_names = kmalloc(header->snap_names_len,
@@ -597,7 +597,7 @@ static int rbd_header_set_snap(struct rbd_device *dev, u64 *size)
597 597
598 BUILD_BUG_ON(sizeof (dev->snap_name) < sizeof (RBD_SNAP_HEAD_NAME)); 598 BUILD_BUG_ON(sizeof (dev->snap_name) < sizeof (RBD_SNAP_HEAD_NAME));
599 599
600 down_write(&header->snap_rwsem); 600 down_write(&dev->header_rwsem);
601 601
602 if (!memcmp(dev->snap_name, RBD_SNAP_HEAD_NAME, 602 if (!memcmp(dev->snap_name, RBD_SNAP_HEAD_NAME,
603 sizeof (RBD_SNAP_HEAD_NAME))) { 603 sizeof (RBD_SNAP_HEAD_NAME))) {
@@ -620,7 +620,7 @@ static int rbd_header_set_snap(struct rbd_device *dev, u64 *size)
620 620
621 ret = 0; 621 ret = 0;
622done: 622done:
623 up_write(&header->snap_rwsem); 623 up_write(&dev->header_rwsem);
624 return ret; 624 return ret;
625} 625}
626 626
@@ -887,7 +887,6 @@ static int rbd_do_request(struct request *rq,
887 struct timespec mtime = CURRENT_TIME; 887 struct timespec mtime = CURRENT_TIME;
888 struct rbd_request *req_data; 888 struct rbd_request *req_data;
889 struct ceph_osd_request_head *reqhead; 889 struct ceph_osd_request_head *reqhead;
890 struct rbd_image_header *header = &dev->header;
891 struct ceph_osd_client *osdc; 890 struct ceph_osd_client *osdc;
892 891
893 req_data = kzalloc(sizeof(*req_data), GFP_NOIO); 892 req_data = kzalloc(sizeof(*req_data), GFP_NOIO);
@@ -905,13 +904,13 @@ static int rbd_do_request(struct request *rq,
905 904
906 dout("rbd_do_request obj=%s ofs=%lld len=%lld\n", obj, len, ofs); 905 dout("rbd_do_request obj=%s ofs=%lld len=%lld\n", obj, len, ofs);
907 906
908 down_read(&header->snap_rwsem); 907 down_read(&dev->header_rwsem);
909 908
910 osdc = &dev->rbd_client->client->osdc; 909 osdc = &dev->rbd_client->client->osdc;
911 req = ceph_osdc_alloc_request(osdc, flags, snapc, ops, 910 req = ceph_osdc_alloc_request(osdc, flags, snapc, ops,
912 false, GFP_NOIO, pages, bio); 911 false, GFP_NOIO, pages, bio);
913 if (!req) { 912 if (!req) {
914 up_read(&header->snap_rwsem); 913 up_read(&dev->header_rwsem);
915 ret = -ENOMEM; 914 ret = -ENOMEM;
916 goto done_pages; 915 goto done_pages;
917 } 916 }
@@ -946,7 +945,7 @@ static int rbd_do_request(struct request *rq,
946 snapc, 945 snapc,
947 &mtime, 946 &mtime,
948 req->r_oid, req->r_oid_len); 947 req->r_oid, req->r_oid_len);
949 up_read(&header->snap_rwsem); 948 up_read(&dev->header_rwsem);
950 949
951 if (linger_req) { 950 if (linger_req) {
952 ceph_osdc_set_request_linger(osdc, req); 951 ceph_osdc_set_request_linger(osdc, req);
@@ -1718,7 +1717,7 @@ static int __rbd_update_snaps(struct rbd_device *rbd_dev)
1718 /* resized? */ 1717 /* resized? */
1719 set_capacity(rbd_dev->disk, h.image_size / SECTOR_SIZE); 1718 set_capacity(rbd_dev->disk, h.image_size / SECTOR_SIZE);
1720 1719
1721 down_write(&rbd_dev->header.snap_rwsem); 1720 down_write(&rbd_dev->header_rwsem);
1722 1721
1723 snap_seq = rbd_dev->header.snapc->seq; 1722 snap_seq = rbd_dev->header.snapc->seq;
1724 if (rbd_dev->header.total_snaps && 1723 if (rbd_dev->header.total_snaps &&
@@ -1743,7 +1742,7 @@ static int __rbd_update_snaps(struct rbd_device *rbd_dev)
1743 1742
1744 ret = __rbd_init_snaps_header(rbd_dev); 1743 ret = __rbd_init_snaps_header(rbd_dev);
1745 1744
1746 up_write(&rbd_dev->header.snap_rwsem); 1745 up_write(&rbd_dev->header_rwsem);
1747 1746
1748 return ret; 1747 return ret;
1749} 1748}
@@ -2380,8 +2379,9 @@ static ssize_t rbd_add(struct bus_type *bus,
2380 spin_lock_init(&rbd_dev->lock); 2379 spin_lock_init(&rbd_dev->lock);
2381 INIT_LIST_HEAD(&rbd_dev->node); 2380 INIT_LIST_HEAD(&rbd_dev->node);
2382 INIT_LIST_HEAD(&rbd_dev->snaps); 2381 INIT_LIST_HEAD(&rbd_dev->snaps);
2382 init_rwsem(&rbd_dev->header_rwsem);
2383 2383
2384 init_rwsem(&rbd_dev->header.snap_rwsem); 2384 init_rwsem(&rbd_dev->header_rwsem);
2385 2385
2386 /* generate unique id: find highest unique id, add one */ 2386 /* generate unique id: find highest unique id, add one */
2387 rbd_id_get(rbd_dev); 2387 rbd_id_get(rbd_dev);