bomp/backends/xomp_master.c

55     XOMP_WORKER_TYPE_REMOTE  = 2   ///< worker runs remote to master
99         uint32_t num;                   ///< number of remote workers
100         struct xomp_worker *workers;    ///< array of remote workers
101         uint32_t next;                  ///< next remote worker to "allocate"
102     } remote;
139 /// only use remote workers, no locals
148 /// arguments to supply to the remote spawned workers
305     debug_printf("remote worker %016lx: add memory took %lu cycles, %lu ms\n",
550         spawn_args_remote.path = args->args.distinct.remote.path;
571     /* remote initialization */
574         argv = args->args.distinct.remote.argv;
575         spawn_args_remote.argc = args->args.distinct.remote.argc;
626     xmaster.remote.next = 0;
628     xmaster.remote.num = remote_threads;
640         xmaster.remote.workers = workers + local_threads;
643     XMI_DEBUG("spawning %u workers: local:%u, remote: %ux%u\n", nworkers - 1,
864     debug_printf("Avg spawn time remote: %lu cycles, %lu ms\n",
868     debug_printf("Avg connect time remote: %lu cycles, %lu ms\n",
875     xmaster.remote.next = 0;
917     for (uint32_t i = 0; i < xmaster.remote.num; ++i) {
918         worker = &xmaster.remote.workers[i];
944             debug_printf("remote worker %lx: chan open took  %lu cycles, %lu ms\n",
1006     for (uint32_t i = 0; i < xmaster.remote.num; ++i) {
1007         worker = &xmaster.remote.workers[i];
1042     remote_timer /= (xmaster.remote.num ? xmaster.remote.num : 1);
1045     debug_printf("Avg mem add time remote: %lu cycles, %lu ms\n",
1059  * \param remote pointer where to store the remote path
1064                                 char **remote)
1088     if (remote) {
1089         *remote = path;
1129     assert(remote_threads <= xmaster.remote.num);
1137          * do the address translation for the remote workers
1167             worker = &xmaster.remote.workers[xmaster.remote.next++];
1171             if (xmaster.remote.next == xmaster.remote.num) {
1172                 xmaster.remote.next = 0;
1177             XMP_DEBUG("remote worker id: %016lx, function %s @ index %u\n",
1336     uint32_t nthreads = xmaster.local.num + xmaster.remote.num;