cregit-Linux how code gets into the kernel

Release 4.11 drivers/md/bcache/io.c

/*
 * Some low level IO code, and hacks for various block layer limitations
 *
 * Copyright 2010, 2011 Kent Overstreet <kent.overstreet@gmail.com>
 * Copyright 2012 Google, Inc.
 */

#include "bcache.h"
#include "bset.h"
#include "debug.h"

#include <linux/blkdev.h>

/* Bios with headers */


void bch_bbio_free(struct bio *bio, struct cache_set *c) { struct bbio *b = container_of(bio, struct bbio, bio); mempool_free(b, c->bio_meta); }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet39100.00%1100.00%
Total39100.00%1100.00%


struct bio *bch_bbio_alloc(struct cache_set *c) { struct bbio *b = mempool_alloc(c->bio_meta, GFP_NOIO); struct bio *bio = &b->bio; bio_init(bio, bio->bi_inline_vecs, bucket_pages(c)); return bio; }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet4992.45%150.00%
Lei Ming47.55%150.00%
Total53100.00%2100.00%


void __bch_submit_bbio(struct bio *bio, struct cache_set *c) { struct bbio *b = container_of(bio, struct bbio, bio); bio->bi_iter.bi_sector = PTR_OFFSET(&b->key, 0); bio->bi_bdev = PTR_CACHE(c, &b->key, 0)->bdev; b->submit_time_us = local_clock_us(); closure_bio_submit(bio, bio->bi_private); }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet80100.00%2100.00%
Total80100.00%2100.00%


void bch_submit_bbio(struct bio *bio, struct cache_set *c, struct bkey *k, unsigned ptr) { struct bbio *b = container_of(bio, struct bbio, bio); bch_bkey_copy_single_ptr(&b->key, k, ptr); __bch_submit_bbio(bio, c); }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet57100.00%1100.00%
Total57100.00%1100.00%

/* IO errors */
void bch_count_io_errors(struct cache *ca, int error, const char *m) { /* * The halflife of an error is: * log2(1/2)/log2(127/128) * refresh ~= 88 * refresh */ if (ca->set->error_decay) { unsigned count = atomic_inc_return(&ca->io_count); while (count > ca->set->error_decay) { unsigned errors; unsigned old = count; unsigned new = count - ca->set->error_decay; /* * First we subtract refresh from count; each time we * succesfully do so, we rescale the errors once: */ count = atomic_cmpxchg(&ca->io_count, old, new); if (count == old) { count = new; errors = atomic_read(&ca->io_errors); do { old = errors; new = ((uint64_t) errors * 127) / 128; errors = atomic_cmpxchg(&ca->io_errors, old, new); } while (old != errors); } } } if (error) { char buf[BDEVNAME_SIZE]; unsigned errors = atomic_add_return(1 << IO_ERROR_SHIFT, &ca->io_errors); errors >>= IO_ERROR_SHIFT; if (errors < ca->set->error_limit) pr_err("%s: IO error on %s, recovering", bdevname(ca->bdev, buf), m); else bch_cache_set_error(ca->set, "%s: too many IO errors %s", bdevname(ca->bdev, buf), m); } }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet227100.00%1100.00%
Total227100.00%1100.00%


void bch_bbio_count_io_errors(struct cache_set *c, struct bio *bio, int error, const char *m) { struct bbio *b = container_of(bio, struct bbio, bio); struct cache *ca = PTR_CACHE(c, &b->key, 0); unsigned threshold = op_is_write(bio_op(bio)) ? c->congested_write_threshold_us : c->congested_read_threshold_us; if (threshold) { unsigned t = local_clock_us(); int us = t - b->submit_time_us; int congested = atomic_read(&c->congested); if (us > (int) threshold) { int ms = us / 1024; c->congested_last_us = t; ms = min(ms, CONGESTED_MAX + congested); atomic_sub(ms, &c->congested); } else if (congested < 0) atomic_inc(&c->congested); } bch_count_io_errors(ca, error, m); }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet16996.57%150.00%
Michael Christie63.43%150.00%
Total175100.00%2100.00%


void bch_bbio_endio(struct cache_set *c, struct bio *bio, int error, const char *m) { struct closure *cl = bio->bi_private; bch_bbio_count_io_errors(c, bio, error, m); bio_put(bio); closure_put(cl); }

Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet53100.00%1100.00%
Total53100.00%1100.00%


Overall Contributors

PersonTokensPropCommitsCommitProp
Kent Overstreet68998.57%360.00%
Michael Christie60.86%120.00%
Lei Ming40.57%120.00%
Total699100.00%5100.00%
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.