From: zooko Date: Sun, 11 Nov 2007 17:04:44 +0000 (+0530) Subject: zfec: do encoding within a fixed window of memory in order to be cache friendly X-Git-Url: https://git.rkrishnan.org/(%5B%5E?a=commitdiff_plain;h=0fd765dbe3be40cb920391bc10d08c02c7d5b039;p=tahoe-lafs%2Fzfec.git zfec: do encoding within a fixed window of memory in order to be cache friendly darcs-hash:ecd8bb2a485674ce3178b9d9bdb9df107fa3411f --- diff --git a/zfec/zfec/fec.c b/zfec/zfec/fec.c index 796425e..2054697 100644 --- a/zfec/zfec/fec.c +++ b/zfec/zfec/fec.c @@ -75,6 +75,7 @@ static gf gf_mul_table[256][256]; #define gf_mul(x,y) gf_mul_table[x][y] #define USE_GF_MULC register gf * __gf_mulc_ + #define GF_MULC0(c) __gf_mulc_ = gf_mul_table[c] #define GF_ADDMULC(dst, x) dst ^= __gf_mulc_[x] @@ -470,19 +471,26 @@ fec_new(unsigned k, unsigned n) { return retval; } +/* To make sure that we stay within cache in the inner loops of fec_encode() + and fec_decode(). */ +#define STRIDE 1024 + void fec_encode(const fec_t* code, const gf*restrict const*restrict const src, gf*restrict const*restrict const fecs, const unsigned*restrict const block_nums, size_t num_block_nums, size_t sz) { unsigned char i, j; + size_t k; unsigned fecnum; - gf* p; + const gf* p; for (i=0; i= code->k); memset(fecs[i], 0, sz); p = &(code->enc_matrix[fecnum * code->k]); - for (j = 0; j < code->k; j++) - addmul(fecs[i], src[j], p[j], sz); +// DUFF ME + for (k = 0; k < sz; k += STRIDE) + for (j = 0; j < code->k; j++) + addmul(fecs[i]+k, src[j]+k, p[j], ((sz-k) < STRIDE)?(sz-k):STRIDE); } }