Home
last modified time | relevance | path

Searched refs:task_map (Results 1 – 17 of 17) sorted by relevance

/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/mpi/pmix/
H A Dpmixp_nspaces.c47 xfree(nsptr->task_map); in _xfree_nspace()
54 char *mynspace, *task_map; in pmixp_nspaces_init() local
68 task_map = pmixp_info_task_map(); in pmixp_nspaces_init()
72 task_map, hostlist_copy(hl)); in pmixp_nspaces_init()
106 nsptr->task_map = unpack_process_mapping_flat(task_map_packed, nnodes, in pmixp_nspaces_add()
108 if (nsptr->task_map == NULL) { in pmixp_nspaces_add()
149 int node = nsptr->task_map[rank]; in pmixp_nspace_rankhosts()
177 return nsptr->task_map[rank]; in pmixp_nspace_resolve()
H A Dpmixp_nspaces.h62 uint32_t *task_map; /* i'th task is located on task_map[i] node */ member
H A Dpmixp_client.c250 nodeid = nsptr->task_map[i]; in _set_procdatas()
403 int node = nsptr->task_map[i], offset;
/dports/games/frogatto/frogatto-1.3.1/src/
H A Dbackground_task_pool.cpp26 std::map<int, task> task_map; variable
44 while(task_map.empty() == false) { in ~manager()
52 task_map[next_task_id] = t; in submit()
65 task_map[t].on_complete(); in pump()
66 task_map.erase(t); in pump()
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/
H A Dmapping.c165 uint32_t *task_map = xmalloc(sizeof(int) * task_cnt); in unpack_process_mapping_flat() local
196 task_map[taskid++] = node; in unpack_process_mapping_flat()
207 return task_map; in unpack_process_mapping_flat()
209 xfree(task_map); in unpack_process_mapping_flat()
224 uint32_t *task_map = NULL; in unpack_process_mapping() local
229 task_map = unpack_process_mapping_flat(map, node_cnt, task_cnt, tasks); in unpack_process_mapping()
230 if (task_map == NULL) { in unpack_process_mapping()
242 uint32_t node = task_map[i]; in unpack_process_mapping()
251 if (task_map != NULL){ in unpack_process_mapping()
252 xfree(task_map); in unpack_process_mapping()
/dports/sysutils/snapraid/snapraid-12.1/cmdline/
H A Dio.c65 struct snapraid_task* task = &worker->task_map[task_index]; in io_reader_sched()
97 struct snapraid_task* task = &worker->task_map[task_index]; in io_writer_sched()
122 struct snapraid_task* task = &worker->task_map[task_index]; in io_writer_sched_empty()
208 task = &worker->task_map[0]; in io_task_read_mono()
244 task = &worker->task_map[0]; in io_parity_write_mono()
318 task = &worker->task_map[worker->index]; in io_reader_step()
373 task = &worker->task_map[worker->index]; in io_writer_step()
430 blockcur_caller = io->reader_map[0].task_map[io->reader_index].position; in io_read_next_thread()
579 task = &worker->task_map[io->reader_index]; in io_task_read_thread()
711 io_reader_worker(worker, &worker->task_map[0]); in io_reader_thread()
H A Dio.h111 struct snapraid_task task_map[IO_MAX]; member
/dports/net/openmpi/openmpi-4.1.1/opal/mca/pmix/pmix3x/pmix/test/
H A Dtest_server.c70 if (ns->task_map) { in nsdes()
71 free(ns->task_map); in nsdes()
79 ns->task_map = NULL; in nscon()
131 return tmp->task_map[rank]; in server_find_id()
284 memset(ns_item->task_map, -1, sizeof(int) * ntasks); in server_unpack_procs()
293 if (ns_item->task_map[rank] >= 0) { in server_unpack_procs()
296 ns_item->task_map[rank] = server_id; in server_unpack_procs()
344 if (tmp->task_map[i] == server_id) { in server_pack_procs()
1032 nspace_item->task_map = (int*)malloc(sizeof(int) * univ_size); in server_launch_clients()
1033 memset(nspace_item->task_map, -1, sizeof(int)*univ_size); in server_launch_clients()
[all …]
H A Dtest_server.h59 int *task_map; member
/dports/databases/mongodb36/mongodb-src-r3.6.23/buildscripts/ciconfig/
H A Devergreen.py106 def __init__(self, conf_dict, task_map): argument
109 self.tasks = [VariantTask(task_map.get(t["name"]), t.get("distros", run_on), self)
/dports/audio/csound/csound-6.15.0/Engine/
H A Dcs_new_dispatch.c189 INSDS **task_map; in dag_build() local
215 task_map = csound->dag_task_map; in dag_build()
269 task_map[i] = chain; in dag_build()
/dports/deskutils/calibre/calibre-src-5.34.0/src/calibre/utils/
H A Dmatcher.py126 task_map = self.task_maps[task_num]
128 item = task_map[i]
/dports/japanese/p5-Number-Phone-JP/Number-Phone-JP-0.20190521/
H A Dregexp-table-maker.pl36 my %task_map = (
85 if (my $param = $task_map{$class}) {
/dports/games/keeperrl/keeperrl-alpha23/mac/keeper.xcodeproj/
H A Dproject.pbxproj94 …FCC49A1D1B0DB84700E91EF7 /* task_map.cpp in Sources */ = {isa = PBXBuildFile; fileRef = FCC499A91B…
289 …F7 /* task_map.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.…
290 …E91EF7 /* task_map.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecod…
529 FCC499A91B0DB84600E91EF7 /* task_map.cpp */,
530 FCC499AA1B0DB84600E91EF7 /* task_map.h */,
692 FCC49A1D1B0DB84700E91EF7 /* task_map.cpp in Sources */,
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/cc/tiles/
H A Dsoftware_image_decode_cache.cc44 SoftwareImageDecodeCache::CacheKeyHash>* task_map, in AutoRemoveKeyFromTaskMap() argument
46 : task_map_(task_map), key_(key) {} in AutoRemoveKeyFromTaskMap()
/dports/www/chromium-legacy/chromium-88.0.4324.182/cc/tiles/
H A Dsoftware_image_decode_cache.cc44 SoftwareImageDecodeCache::CacheKeyHash>* task_map, in AutoRemoveKeyFromTaskMap() argument
46 : task_map_(task_map), key_(key) {} in AutoRemoveKeyFromTaskMap()
/dports/audio/csound/csound-6.15.0/Top/
H A Dcsound.c1528 INSDS **task_map = (INSDS**)csound->dag_task_map; in nodePerf() local
1543 insds = task_map[which_task]; in nodePerf()
1556 opstart = (OPDS*)task_map[which_task]; in nodePerf()