Searched refs:ltasks (Results 1 – 14 of 14) sorted by relevance
312 for (i = 0; i < job_info.ltasks; i ++) { in _agent()317 initialized = xmalloc(job_info.ltasks * sizeof(int)); in _agent()318 finalized = xmalloc(job_info.ltasks * sizeof(int)); in _agent()
115 job_info.ltasks = job->node_tasks; in _setup_stepd_job_info()116 job_info.gtids = xmalloc(job_info.ltasks * sizeof(uint32_t)); in _setup_stepd_job_info()117 for (i = 0; i < job_info.ltasks; i ++) { in _setup_stepd_job_info()127 job_info.ltasks = job->node_tasks; in _setup_stepd_job_info()128 job_info.gtids = xmalloc(job_info.ltasks * sizeof(uint32_t)); in _setup_stepd_job_info()129 for (i = 0; i < job_info.ltasks; i ++) { in _setup_stepd_job_info()595 job_info.ltasks = 0; /* not used */ in _setup_srun_job_info()
65 uint32_t ltasks; /* number of tasks on *this* (local) node */ member
125 for (i = 0; i < job->ltasks; i ++) { in p_mpi_hook_slurmstepd_task()
280 pmix_app_children = job->ltasks; in pmix_ring_init()
131 tasks_to_wait = job_info.ltasks; in _handle_kvs_fence()
614 for (i = 0; i < job_info.ltasks; i ++) { in send_kvs_fence_resp_to_clients()
178 tasks_to_wait = job_info.ltasks; in _handle_barrier_in()
293 tasks_to_wait = job_info.ltasks; in _handle_kvs_fence()
256 size_t ltasks, ntasks; in server_unpack_procs() local268 memcpy (<asks, ptr, sizeof(size_t)); in server_unpack_procs()281 ns_item->ltasks = ltasks; in server_unpack_procs()289 for (i = 0; i < ltasks; i++) { in server_unpack_procs()317 sizeof(int) * tmp->ltasks; in server_pack_procs()340 memcpy(ptr, &tmp->ltasks, sizeof(size_t)); in server_pack_procs()1031 nspace_item->ltasks = local_size; in server_launch_clients()
58 size_t ltasks; /* local */ member
154 info("ntasks:%u local_tasks:%u", job->ntasks, job->ltasks); in _log_task_rec()
324 info->ltasks = job->node_tasks; in _setup_mpi()336 info->ltasks = job->node_tasks; in _setup_mpi()