Source of blk-rq-qos.c - linux-imx - PHYTEC BitBucket (Stash)

Raw file
Source viewDiff to previous
 * inc the rqw->inflight if we have the ability to do so, or return false if not
 
#include "blk-rq-qos.h"
​
/*
 * Increment 'v', if 'v' is below 'below'. Returns true if we succeeded,
 * false if 'v' + 1 would be bigger than 'below'.
 */
static bool atomic_inc_below(atomic_t *v, unsigned int below)
{
    unsigned int cur = atomic_read(v);
​
    for (;;) {
        unsigned int old;
​
        if (cur >= below)
            return false;
        old = atomic_cmpxchg(v, cur, cur + 1);
        if (old == cur)
            break;
        cur = old;
    }
​
    return true;
}
​
bool rq_wait_inc_below(struct rq_wait *rq_wait, unsigned int limit)
{
    return atomic_inc_below(&rq_wait->inflight, limit);
}
​
void __rq_qos_cleanup(struct rq_qos *rqos, struct bio *bio)
{
    do {
        if (rqos->ops->cleanup)
            rqos->ops->cleanup(rqos, bio);
        rqos = rqos->next;
    } while (rqos);
}
​
void __rq_qos_done(struct rq_qos *rqos, struct request *rq)
{
    do {
        if (rqos->ops->done)
            rqos->ops->done(rqos, rq);
        rqos = rqos->next;
    } while (rqos);
}
​
void __rq_qos_issue(struct rq_qos *rqos, struct request *rq)
{
    do {
        if (rqos->ops->issue)
            rqos->ops->issue(rqos, rq);
        rqos = rqos->next;
    } while (rqos);
}
​
void __rq_qos_requeue(struct rq_qos *rqos, struct request *rq)
{
    do {
        if (rqos->ops->requeue)
            rqos->ops->requeue(rqos, rq);
        rqos = rqos->next;
    } while (rqos);