sysfs_notify_dirent_safe(rdev->sysfs_state);
        }
  
 -      if (mddev->bio_set == NULL) {
 -              mddev->bio_set = bioset_create(BIO_POOL_SIZE, 0, BIOSET_NEED_BVECS);
 -              if (!mddev->bio_set)
 -                      return -ENOMEM;
 +      if (!bioset_initialized(&mddev->bio_set)) {
 +              err = bioset_init(&mddev->bio_set, BIO_POOL_SIZE, 0, BIOSET_NEED_BVECS);
 +              if (err)
 +                      return err;
        }
 -      if (mddev->sync_set == NULL) {
 -              mddev->sync_set = bioset_create(BIO_POOL_SIZE, 0, BIOSET_NEED_BVECS);
 -              if (!mddev->sync_set) {
 -                      err = -ENOMEM;
 -                      goto abort;
 -              }
 +      if (!bioset_initialized(&mddev->sync_set)) {
 +              err = bioset_init(&mddev->sync_set, BIO_POOL_SIZE, 0, BIOSET_NEED_BVECS);
 +              if (err)
 +                      return err;
        }
+       if (mddev->flush_pool == NULL) {
+               mddev->flush_pool = mempool_create(NR_FLUSH_INFOS, flush_info_alloc,
+                                               flush_info_free, mddev);
+               if (!mddev->flush_pool) {
+                       err = -ENOMEM;
+                       goto abort;
+               }
+       }
+       if (mddev->flush_bio_pool == NULL) {
+               mddev->flush_bio_pool = mempool_create(NR_FLUSH_BIOS, flush_bio_alloc,
+                                               flush_bio_free, mddev);
+               if (!mddev->flush_bio_pool) {
+                       err = -ENOMEM;
+                       goto abort;
+               }
+       }
  
        spin_lock(&pers_lock);
        pers = find_pers(mddev->level, mddev->clevel);
        sysfs_notify_dirent_safe(mddev->sysfs_action);
        sysfs_notify(&mddev->kobj, NULL, "degraded");
        return 0;
 -      if (mddev->bio_set) {
 -              bioset_free(mddev->bio_set);
 -              mddev->bio_set = NULL;
 -      }
 -      if (mddev->sync_set) {
 -              bioset_free(mddev->sync_set);
 -              mddev->sync_set = NULL;
 -      }
+ 
+ abort:
+       if (mddev->flush_bio_pool) {
+               mempool_destroy(mddev->flush_bio_pool);
+               mddev->flush_bio_pool = NULL;
+       }
+       if (mddev->flush_pool){
+               mempool_destroy(mddev->flush_pool);
+               mddev->flush_pool = NULL;
+       }
+ 
+       return err;
  }
  EXPORT_SYMBOL_GPL(md_run);
  
         * This is called from dm-raid
         */
        __md_stop(mddev);
 -      if (mddev->bio_set) {
 -              bioset_free(mddev->bio_set);
 -              mddev->bio_set = NULL;
 -      }
 -      if (mddev->sync_set) {
 -              bioset_free(mddev->sync_set);
 -              mddev->sync_set = NULL;
 -      }
+       if (mddev->flush_bio_pool) {
+               mempool_destroy(mddev->flush_bio_pool);
+               mddev->flush_bio_pool = NULL;
+       }
+       if (mddev->flush_pool) {
+               mempool_destroy(mddev->flush_pool);
+               mddev->flush_pool = NULL;
+       }
 +      bioset_exit(&mddev->bio_set);
 +      bioset_exit(&mddev->sync_set);
  }
  
  EXPORT_SYMBOL_GPL(md_stop);