Merge branch 'for-3.14/core' of git://git.kernel.dk/linux-block

Pull core block IO changes from Jens Axboe:
 "The major piece in here is the immutable bio_ve series from Kent, the
  rest is fairly minor.  It was supposed to go in last round, but
  various issues pushed it to this release instead.  The pull request
  contains:

   - Various smaller blk-mq fixes from different folks.  Nothing major
     here, just minor fixes and cleanups.

   - Fix for a memory leak in the error path in the block ioctl code
     from Christian Engelmayer.

   - Header export fix from CaiZhiyong.

   - Finally the immutable biovec changes from Kent Overstreet.  This
     enables some nice future work on making arbitrarily sized bios
     possible, and splitting more efficient.  Related fixes to immutable
     bio_vecs:

        - dm-cache immutable fixup from Mike Snitzer.
        - btrfs immutable fixup from Muthu Kumar.

  - bio-integrity fix from Nic Bellinger, which is also going to stable"

* 'for-3.14/core' of git://git.kernel.dk/linux-block: (44 commits)
  xtensa: fixup simdisk driver to work with immutable bio_vecs
  block/blk-mq-cpu.c: use hotcpu_notifier()
  blk-mq: for_each_* macro correctness
  block: Fix memory leak in rw_copy_check_uvector() handling
  bio-integrity: Fix bio_integrity_verify segment start bug
  block: remove unrelated header files and export symbol
  blk-mq: uses page->list incorrectly
  blk-mq: use __smp_call_function_single directly
  btrfs: fix missing increment of bi_remaining
  Revert "block: Warn and free bio if bi_end_io is not set"
  block: Warn and free bio if bi_end_io is not set
  blk-mq: fix initializing request's start time
  block: blk-mq: don't export blk_mq_free_queue()
  block: blk-mq: make blk_sync_queue support mq
  block: blk-mq: support draining mq queue
  dm cache: increment bi_remaining when bi_end_io is restored
  block: fixup for generic bio chaining
  block: Really silence spurious compiler warnings
  block: Silence spurious compiler warnings
  block: Kill bio_pair_split()
  ...

1 files changed, 17 insertions, 26 deletions

diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 2ed1304d22a7..0e478a0f4204 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -778,13 +778,12 @@ static void ceph_msg_data_bio_cursor_init(struct ceph_msg_data_cursor *cursor,
 
         bio = data->bio;
         BUG_ON(!bio);
-        BUG_ON(!bio->bi_vcnt);
 
         cursor->resid = min(length, data->bio_length);
         cursor->bio = bio;
-        cursor->vector_index = 0;
-        cursor->vector_offset = 0;
-        cursor->last_piece = length <= bio->bi_io_vec[0].bv_len;
+        cursor->bvec_iter = bio->bi_iter;
+        cursor->last_piece =
+                cursor->resid <= bio_iter_len(bio, cursor->bvec_iter);
 }
 
 static struct page *ceph_msg_data_bio_next(struct ceph_msg_data_cursor *cursor,
@@ -793,71 +792,63 @@ static struct page *ceph_msg_data_bio_next(struct ceph_msg_data_cursor *cursor,
 {
         struct ceph_msg_data *data = cursor->data;
         struct bio *bio;
-        struct bio_vec *bio_vec;
-        unsigned int index;
+        struct bio_vec bio_vec;
 
         BUG_ON(data->type != CEPH_MSG_DATA_BIO);
 
         bio = cursor->bio;
         BUG_ON(!bio);
 
-        index = cursor->vector_index;
-        BUG_ON(index >= (unsigned int) bio->bi_vcnt);
+        bio_vec = bio_iter_iovec(bio, cursor->bvec_iter);
 
-        bio_vec = &bio->bi_io_vec[index];
-        BUG_ON(cursor->vector_offset >= bio_vec->bv_len);
-        *page_offset = (size_t) (bio_vec->bv_offset + cursor->vector_offset);
+        *page_offset = (size_t) bio_vec.bv_offset;
         BUG_ON(*page_offset >= PAGE_SIZE);
         if (cursor->last_piece) /* pagelist offset is always 0 */
                 *length = cursor->resid;
         else
-                *length = (size_t) (bio_vec->bv_len - cursor->vector_offset);
+                *length = (size_t) bio_vec.bv_len;
         BUG_ON(*length > cursor->resid);
         BUG_ON(*page_offset + *length > PAGE_SIZE);
 
-        return bio_vec->bv_page;
+        return bio_vec.bv_page;
 }
 
 static bool ceph_msg_data_bio_advance(struct ceph_msg_data_cursor *cursor,
                                         size_t bytes)
 {
         struct bio *bio;
-        struct bio_vec *bio_vec;
-        unsigned int index;
+        struct bio_vec bio_vec;
 
         BUG_ON(cursor->data->type != CEPH_MSG_DATA_BIO);
 
         bio = cursor->bio;
         BUG_ON(!bio);
 
-        index = cursor->vector_index;
-        BUG_ON(index >= (unsigned int) bio->bi_vcnt);
-        bio_vec = &bio->bi_io_vec[index];
+        bio_vec = bio_iter_iovec(bio, cursor->bvec_iter);
 
         /* Advance the cursor offset */
 
         BUG_ON(cursor->resid < bytes);
         cursor->resid -= bytes;
-        cursor->vector_offset += bytes;
-        if (cursor->vector_offset < bio_vec->bv_len)
+
+        bio_advance_iter(bio, &cursor->bvec_iter, bytes);
+
+        if (bytes < bio_vec.bv_len)
                 return false;   /* more bytes to process in this segment */
-        BUG_ON(cursor->vector_offset != bio_vec->bv_len);
 
         /* Move on to the next segment, and possibly the next bio */
 
-        if (++index == (unsigned int) bio->bi_vcnt) {
+        if (!cursor->bvec_iter.bi_size) {
                 bio = bio->bi_next;
-                index = 0;
+                cursor->bvec_iter = bio->bi_iter;
         }
         cursor->bio = bio;
-        cursor->vector_index = index;
-        cursor->vector_offset = 0;
 
         if (!cursor->last_piece) {
                 BUG_ON(!cursor->resid);
                 BUG_ON(!bio);
                 /* A short read is OK, so use <= rather than == */
-                if (cursor->resid <= bio->bi_io_vec[index].bv_len)
+                if (cursor->resid <= bio_iter_len(bio, cursor->bvec_iter))
                         cursor->last_piece = true;
         }