Function worker

tests/unit/bcache_test.cc:122–181

};

void * worker(void *voidargs)
{
    uint8_t *buf = (uint8_t *)malloc(4096);
    struct worker_args *args = (struct worker_args*)voidargs;
    struct timeval ts_begin, ts_cur, ts_gap;

    ssize_t ret;
    bid_t bid;
    uint32_t crc, crc_file;
    uint64_t i, c, run_count=0;
    TEST_INIT();

    memset(buf, 0, 4096);
    gettimeofday(&ts_begin, NULL);

    while(1) {
        bid = rand() % args->nblocks;
        ret = bcache_read(args->file, bid, buf);
        if (ret <= 0) {
            ret = args->file->ops->pread(args->file->fd, buf,
                                         args->file->blocksize, bid * args->file->blocksize);
            TEST_CHK(ret == args->file->blocksize);
            ret = bcache_write(args->file, bid, buf, BCACHE_REQ_CLEAN, false);
            TEST_CHK(ret == args->file->blocksize);
        }
        crc_file = crc32_8(buf, sizeof(uint64_t)*2, 0);
        (void)crc_file;
        memcpy(&i, buf, sizeof(i));
        memcpy(&crc, buf + sizeof(uint64_t)*2, sizeof(crc));
        // Disable checking the CRC value at this time as pread and pwrite are
        // not thread-safe.
        // TEST_CHK(crc == crc_file && i==bid);
        //DBG("%d %d %d %x %x\n", (int)args->n, (int)i, (int)bid, (int)crc, (int)crc_file);

        if (args->writer) {
            memcpy(&c, buf+sizeof(i), sizeof(c));
            c++;
            memcpy(buf+sizeof(i), &c, sizeof(c));
            crc = crc32_8(buf, sizeof(uint64_t)*2, 0);
            memcpy(buf + sizeof(uint64_t)*2, &crc, sizeof(crc));

            ret = bcache_write(args->file, bid, buf, BCACHE_REQ_DIRTY, true);
            TEST_CHK(ret == args->file->blocksize);
        } else { // have some of the reader threads flush dirty immutable blocks
            if (bid <= args->nblocks / 4) { // 25% probability
                filemgr_flush_immutable(args->file, NULL);
            }
        }

        gettimeofday(&ts_cur, NULL);
        ts_gap = _utime_gap(ts_begin, ts_cur);
        if ((size_t)ts_gap.tv_sec >= args->time_sec) break;

        run_count++;
    }

    free(buf);
    thread_exit(0);