Lines Matching refs:tg
617 void set_weight(ffsb_tg_t * tg, config_options_t * config) in set_weight() argument
629 tg_set_op_weight(tg, op, in set_weight()
638 int get_weight_total(ffsb_tg_t * tg) in get_weight_total() argument
651 total += tg_get_op_weight(tg, op); in get_weight_total()
666 static int verify_tg(ffsb_tg_t * tg) in verify_tg() argument
668 uint32_t read_weight = tg_get_op_weight(tg, "read"); in verify_tg()
669 uint32_t readall_weight = tg_get_op_weight(tg, "readall"); in verify_tg()
670 uint32_t write_weight = tg_get_op_weight(tg, "write"); in verify_tg()
671 uint32_t create_weight = tg_get_op_weight(tg, "create"); in verify_tg()
672 uint32_t append_weight = tg_get_op_weight(tg, "append"); in verify_tg()
673 uint32_t createdir_weight = tg_get_op_weight(tg, "createdir"); in verify_tg()
674 uint32_t delete_weight = tg_get_op_weight(tg, "delete"); in verify_tg()
675 uint32_t writeall_weight = tg_get_op_weight(tg, "writeall"); in verify_tg()
676 uint32_t writeall_fsync_weight = tg_get_op_weight(tg, "writeall_fsync"); in verify_tg()
678 uint32_t sum_weight = get_weight_total(tg); in verify_tg()
680 uint32_t read_blocksize = tg_get_read_blocksize(tg); in verify_tg()
681 uint32_t write_blocksize = tg_get_write_blocksize(tg); in verify_tg()
683 int read_random = tg_get_read_random(tg); in verify_tg()
684 int read_skip = tg_get_read_skip(tg); in verify_tg()
685 uint32_t read_skipsize = tg_get_read_skipsize(tg); in verify_tg()
744 container_t *tg = profile_conf->tg_container; in get_num_totalthreads() local
747 while (tg) { in get_num_totalthreads()
748 tg_config = tg->config; in get_num_totalthreads()
754 if (tg->next) in get_num_totalthreads()
755 tg = tg->next; in get_num_totalthreads()
810 ffsb_tg_t * tg, int tg_num) in init_threadgroup() argument
813 memset(tg, 0, sizeof(ffsb_tg_t)); in init_threadgroup()
817 init_ffsb_tg(tg, num_threads, tg_num); in init_threadgroup()
835 tg->bindfs = i; in init_threadgroup()
838 tg->read_random = get_config_bool(config, "read_random"); in init_threadgroup()
839 tg->read_size = get_config_u64(config, "read_size"); in init_threadgroup()
840 tg->read_skip = get_config_bool(config, "read_skip"); in init_threadgroup()
841 tg->read_skipsize = get_config_u32(config, "read_skipsize"); in init_threadgroup()
843 tg->write_random = get_config_bool(config, "write_random"); in init_threadgroup()
844 tg->write_size = get_config_u64(config, "write_size"); in init_threadgroup()
845 tg->fsync_file = get_config_bool(config, "fsync_file"); in init_threadgroup()
847 tg->wait_time = get_config_u32(config, "op_delay"); in init_threadgroup()
849 tg_set_read_blocksize(tg, get_config_u32(config, "read_blocksize")); in init_threadgroup()
850 tg_set_write_blocksize(tg, get_config_u32(config, "write_blocksize")); in init_threadgroup()
852 set_weight(tg, config); in init_threadgroup()
854 if (verify_tg(tg)) { in init_threadgroup()