linux-imx

// SPDX-License-Identifier: GPL-2.0

/*

 * Copyright (C) 2016 CNEX Labs

 * Initial release: Javier Gonzalez <javier@cnexlabs.com>

 *                  Matias Bjorling <matias@cnexlabs.com>

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License version

 * 2 as published by the Free Software Foundation.

 *

 * This program is distributed in the hope that it will be useful, but

 * WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

 * General Public License for more details.

 *

 * pblk-cache.c - pblk's write cache

 */

​

#include "pblk.h"

​

int pblk_write_to_cache(struct pblk *pblk, struct bio *bio, unsigned long flags)

{

    struct request_queue *q = pblk->dev->q;

    struct pblk_w_ctx w_ctx;

    sector_t lba = pblk_get_lba(bio);

    unsigned long start_time = jiffies;

    unsigned int bpos, pos;

    int nr_entries = pblk_get_secs(bio);

    int i, ret;

​

    generic_start_io_acct(q, REQ_OP_WRITE, bio_sectors(bio),

                  &pblk->disk->part0);

​

    /* Update the write buffer head (mem) with the entries that we can

     * write. The write in itself cannot fail, so there is no need to

     * rollback from here on.

     */

retry:

    ret = pblk_rb_may_write_user(&pblk->rwb, bio, nr_entries, &bpos);

    switch (ret) {

    case NVM_IO_REQUEUE:

        io_schedule();

        goto retry;

    case NVM_IO_ERR:

        pblk_pipeline_stop(pblk);

        goto out;

    }

​

    pblk_ppa_set_empty(&w_ctx.ppa);

    w_ctx.flags = flags;

    if (bio->bi_opf & REQ_PREFLUSH) {

        w_ctx.flags |= PBLK_FLUSH_ENTRY;

        pblk_write_kick(pblk);

    }

​

    if (unlikely(!bio_has_data(bio)))

        goto out;

​

    for (i = 0; i < nr_entries; i++) {

        void *data = bio_data(bio);

​

        w_ctx.lba = lba + i;

​