Lines Matching defs:this_thr
773 kmp_info_t *this_thr = parent_team->t.t_threads[master_tid];
863 int cg_nthreads = this_thr->th.th_cg_roots->cg_nthreads;
864 int max_cg_threads = this_thr->th.th_cg_roots->cg_thread_limit;
949 if (this_thr->th.th_nt_strict && new_nthreads < set_nthreads) {
950 __kmpc_error(this_thr->th.th_nt_loc, this_thr->th.th_nt_sev,
951 this_thr->th.th_nt_msg);
1182 kmp_info_t *this_thr;
1196 this_thr = __kmp_threads[global_tid];
1197 serial_team = this_thr->th.th_serial_team;
1203 kmp_proc_bind_t proc_bind = this_thr->th.th_set_proc_bind;
1204 if (this_thr->th.th_current_task->td_icvs.proc_bind == proc_bind_false) {
1209 proc_bind = this_thr->th.th_current_task->td_icvs.proc_bind;
1212 this_thr->th.th_set_proc_bind = proc_bind_default;
1215 this_thr->th.th_set_nproc = 0;
1221 this_thr->th.ompt_thread_info.state != ompt_state_overhead) {
1224 parent_task_info = OMPT_CUR_TASK_INFO(this_thr);
1238 if (this_thr->th.th_team != serial_team) {
1240 int level = this_thr->th.th_team->t.t_level;
1250 __kmp_allocate_team(this_thr->th.th_root, 1, 1,
1254 proc_bind, &this_thr->th.th_current_task->td_icvs,
1260 new_team->t.t_threads[0] = this_thr;
1261 new_team->t.t_parent = this_thr->th.th_team;
1263 this_thr->th.th_serial_team = serial_team;
1282 KMP_DEBUG_ASSERT(serial_team->t.t_threads[0] == this_thr);
1283 KMP_DEBUG_ASSERT(this_thr->th.th_team != serial_team);
1287 serial_team->t.t_parent = this_thr->th.th_team;
1288 if (this_thr->th.th_team->t.t_nested_nth)
1289 serial_team->t.t_nested_nth = this_thr->th.th_team->t.t_nested_nth;
1293 serial_team->t.t_primary_task_state = this_thr->th.th_task_state;
1294 serial_team->t.t_sched.sched = this_thr->th.th_team->t.t_sched.sched;
1295 this_thr->th.th_team = serial_team;
1296 serial_team->t.t_master_tid = this_thr->th.th_info.ds.ds_tid;
1299 this_thr->th.th_current_task));
1300 KMP_ASSERT(this_thr->th.th_current_task->td_flags.executing == 1);
1301 this_thr->th.th_current_task->td_flags.executing = 0;
1303 __kmp_push_current_task_to_thread(this_thr, serial_team, 0);
1308 copy_icvs(&this_thr->th.th_current_task->td_icvs,
1309 &this_thr->th.th_current_task->td_parent->td_icvs);
1314 if (this_thr->th.th_team->t.t_nested_nth)
1315 nested_nth = this_thr->th.th_team->t.t_nested_nth;
1317 this_thr->th.th_current_task->td_icvs.nproc = nested_nth->nth[level + 1];
1322 this_thr->th.th_current_task->td_icvs.proc_bind =
1329 this_thr->th.th_info.ds.ds_tid = 0;
1332 this_thr->th.th_team_nproc = 1;
1333 this_thr->th.th_team_master = this_thr;
1334 this_thr->th.th_team_serialized = 1;
1335 this_thr->th.th_task_team = NULL;
1336 this_thr->th.th_task_state = 0;
1340 serial_team->t.t_def_allocator = this_thr->th.th_def_allocator; // save
1351 this_thr->th.th_dispatch = serial_team->t.t_dispatch;
1358 KMP_DEBUG_ASSERT(this_thr->th.th_team == serial_team);
1360 KMP_DEBUG_ASSERT(serial_team->t.t_threads[0] == this_thr);
1362 this_thr->th.th_team_serialized = serial_team->t.t_serialized;
1365 int level = this_thr->th.th_team->t.t_level;
1373 this_thr->th.th_current_task->td_icvs.nproc = nested_nth->nth[level + 1];
1390 this_thr->th.th_dispatch = serial_team->t.t_dispatch;
1393 __kmp_push_task_team_node(this_thr, serial_team);
1402 if (this_thr->th.th_prev_level != serial_team->t.t_level ||
1403 this_thr->th.th_prev_num_threads != 1) {
1406 this_thr->th.th_prev_level = serial_team->t.t_level;
1407 this_thr->th.th_prev_num_threads = 1;
1416 this_thr->th.ompt_thread_info.state != ompt_state_overhead) {
1417 OMPT_CUR_TASK_INFO(this_thr)->frame.exit_frame.ptr =
1421 __ompt_lw_taskteam_init(&lw_taskteam, this_thr, global_tid,
1424 __ompt_lw_taskteam_link(&lw_taskteam, this_thr, 1);
1430 ompt_scope_begin, OMPT_CUR_TEAM_DATA(this_thr),
1431 OMPT_CUR_TASK_DATA(this_thr), 1, __kmp_tid_from_gtid(global_tid),
1433 OMPT_CUR_TASK_INFO(this_thr)->thread_num =
1438 this_thr->th.ompt_thread_info.state = ompt_state_work_parallel;
1439 OMPT_CUR_TASK_INFO(this_thr)->frame.exit_frame.ptr =
4260 kmp_info_t *this_thr = __kmp_threads[gtid];
4261 kmp_team_t *steam = this_thr->th.th_serial_team;
4262 kmp_team_t *team = this_thr->th.th_team;
4267 gtid, tid, this_thr, team, steam, this_thr->th.th_current_task,
4275 static void __kmp_initialize_info(kmp_info_t *this_thr, kmp_team_t *team,
4277 /* this_thr->th.th_info.ds.ds_gtid is setup in
4279 this_thr->th.th_serial_team is setup in __kmp_allocate_thread */
4280 KMP_DEBUG_ASSERT(this_thr != NULL);
4281 KMP_DEBUG_ASSERT(this_thr->th.th_serial_team);
4291 TCW_SYNC_PTR(this_thr->th.th_team, team);
4293 this_thr->th.th_info.ds.ds_tid = tid;
4294 this_thr->th.th_set_nproc = 0;
4298 this_thr->th.th_reap_state = KMP_NOT_SAFE_TO_REAP;
4300 this_thr->th.th_reap_state = KMP_SAFE_TO_REAP;
4301 this_thr->th.th_set_proc_bind = proc_bind_default;
4304 this_thr->th.th_new_place = this_thr->th.th_current_place;
4306 this_thr->th.th_root = master->th.th_root;
4309 this_thr->th.th_team_nproc = team->t.t_nproc;
4310 this_thr->th.th_team_master = master;
4311 this_thr->th.th_team_serialized = team->t.t_serialized;
4316 tid, gtid, this_thr, this_thr->th.th_current_task));
4318 __kmp_init_implicit_task(this_thr->th.th_team_master->th.th_ident, this_thr,
4322 tid, gtid, this_thr, this_thr->th.th_current_task));
4327 this_thr->th.th_dispatch = &team->t.t_dispatch[tid];
4329 this_thr->th.th_local.this_construct = 0;
4331 if (!this_thr->th.th_pri_common) {
4332 this_thr->th.th_pri_common =
4336 gtid, this_thr->th.th_pri_common, this_thr->th.th_pri_common + 1,
4339 this_thr->th.th_pri_head = NULL;
4342 if (this_thr != master && // Primary thread's CG root is initialized elsewhere
4343 this_thr->th.th_cg_roots != master->th.th_cg_roots) { // CG root not set
4346 kmp_cg_root_t *tmp = this_thr->th.th_cg_roots;
4352 this_thr, tmp, tmp->cg_root, tmp->cg_nthreads));
4357 this_thr->th.th_cg_roots = master->th.th_cg_roots;
4359 this_thr->th.th_cg_roots->cg_nthreads++;
4362 this_thr, this_thr->th.th_cg_roots,
4363 this_thr->th.th_cg_roots->cg_root,
4364 this_thr->th.th_cg_roots->cg_nthreads));
4365 this_thr->th.th_current_task->td_icvs.thread_limit =
4366 this_thr->th.th_cg_roots->cg_thread_limit;
4371 volatile kmp_disp_t *dispatch = this_thr->th.th_dispatch;
4410 this_thr->th.th_next_pool = NULL;
4412 KMP_DEBUG_ASSERT(!this_thr->th.th_spin_here);
4413 KMP_DEBUG_ASSERT(this_thr->th.th_next_waiting == 0);
6007 void *__kmp_launch_thread(kmp_info_t *this_thr) {
6015 int gtid = this_thr->th.th_info.ds.ds_gtid;
6023 this_thr->th.th_cons = __kmp_allocate_cons_stack(gtid); // ATT: Memory leak?
6034 thread_data = &(this_thr->th.ompt_thread_info.thread_data);
6037 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
6038 this_thr->th.ompt_thread_info.wait_id = 0;
6039 this_thr->th.ompt_thread_info.idle_frame = OMPT_GET_FRAME_ADDRESS(0);
6040 this_thr->th.ompt_thread_info.parallel_flags = 0;
6045 this_thr->th.ompt_thread_info.state = ompt_state_idle;
6051 KMP_DEBUG_ASSERT(this_thr == __kmp_threads[gtid]);
6062 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
6066 pteam = &this_thr->th.th_team;
6082 this_thr->th.ompt_thread_info.state = ompt_state_work_parallel;
6099 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
6118 this_thr->th.th_task_team = NULL;
6128 return this_thr;
7647 void __kmp_run_before_invoked_task(int gtid, int tid, kmp_info_t *this_thr,
7654 this_thr->th.th_local.this_construct = 0;
7656 KMP_CACHE_PREFETCH(&this_thr->th.th_bar[bs_forkjoin_barrier].bb.b_arrived);
7658 dispatch = (kmp_disp_t *)TCR_PTR(this_thr->th.th_dispatch);
7661 // KMP_DEBUG_ASSERT( this_thr->th.th_dispatch == &team->t.t_dispatch[
7662 // this_thr->th.th_info.ds.ds_tid ] );
7672 void __kmp_run_after_invoked_task(int gtid, int tid, kmp_info_t *this_thr,
7677 __kmp_finish_implicit_task(this_thr);
7683 kmp_info_t *this_thr = __kmp_threads[gtid];
7684 kmp_team_t *team = this_thr->th.th_team;
7686 __kmp_run_before_invoked_task(gtid, tid, this_thr, team);
7725 OMPT_CUR_TASK_INFO(this_thr)->thread_num = __kmp_tid_from_gtid(gtid);
7748 this_thr->th.ompt_thread_info.parallel_flags = ompt_parallel_team;
7770 __kmp_run_after_invoked_task(gtid, tid, this_thr, team);
7824 kmp_info_t *this_thr = __kmp_threads[gtid];
7825 kmp_team_t *team = this_thr->th.th_team;
7831 __kmp_run_before_invoked_task(gtid, 0, this_thr, team);
7841 OMPT_CUR_TASK_INFO(this_thr)->thread_num = tid;
7846 this_thr->th.ompt_thread_info.parallel_flags = ompt_parallel_league;
7848 __kmp_run_after_invoked_task(gtid, 0, this_thr, team);
8060 kmp_info_t *this_thr = __kmp_threads[gtid];
8067 KMP_DEBUG_ASSERT(this_thr->th.th_team == team);
8089 KMP_ASSERT(this_thr->th.th_team == team);
8103 kmp_info_t *this_thr = __kmp_threads[gtid];
8106 KMP_DEBUG_ASSERT(this_thr->th.th_team == team);
8129 ompt_state_t ompt_state = this_thr->th.ompt_thread_info.state;
8133 int ds_tid = this_thr->th.th_info.ds.ds_tid;
8134 ompt_data_t *task_data = OMPT_CUR_TASK_DATA(this_thr);
8135 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
8141 codeptr = OMPT_CUR_TEAM_INFO(this_thr)->master_return_address;
8144 if (this_thr->th.ompt_thread_info.parallel_flags & ompt_parallel_league)
8164 KMP_ASSERT(this_thr->th.th_team == team);