Lines Matching refs:trk

145     orte_dfs_tracker_t *trk;  in recv_dfs()  local
210 trk = OBJ_NEW(orte_dfs_tracker_t); in recv_dfs()
211 trk->requestor.jobid = ORTE_PROC_MY_NAME->jobid; in recv_dfs()
212 trk->requestor.vpid = ORTE_PROC_MY_NAME->vpid; in recv_dfs()
213 trk->host_daemon.jobid = sender->jobid; in recv_dfs()
214 trk->host_daemon.vpid = sender->vpid; in recv_dfs()
215 trk->filename = strdup(dfs->uri); in recv_dfs()
217 trk->local_fd = local_fd++; in recv_dfs()
219 trk->remote_fd = remote_fd; in recv_dfs()
221 opal_list_append(&active_files, &trk->super); in recv_dfs()
228 dfs->uri, trk->local_fd, remote_fd); in recv_dfs()
230 dfs->open_cbfunc(trk->local_fd, dfs->cbdata); in recv_dfs()
595 orte_dfs_tracker_t *tptr, *trk; in process_close() local
608 trk = NULL; in process_close()
614 trk = tptr; in process_close()
618 if (NULL == trk) { in process_close()
635 if (OPAL_SUCCESS != (rc = opal_dss.pack(buffer, &trk->remote_fd, 1, OPAL_INT))) { in process_close()
643 ORTE_NAME_PRINT(&trk->host_daemon), in process_close()
644 trk->local_fd); in process_close()
647 &trk->host_daemon, buffer, in process_close()
656 opal_list_remove_item(&active_files, &trk->super); in process_close()
657 OBJ_RELEASE(trk); in process_close()
687 orte_dfs_tracker_t *tptr, *trk; in process_sizes() local
700 trk = NULL; in process_sizes()
706 trk = tptr; in process_sizes()
710 if (NULL == trk) { in process_sizes()
737 if (OPAL_SUCCESS != (rc = opal_dss.pack(buffer, &trk->remote_fd, 1, OPAL_INT))) { in process_sizes()
746 ORTE_NAME_PRINT(&trk->host_daemon), in process_sizes()
747 trk->local_fd); in process_sizes()
750 &trk->host_daemon, buffer, in process_sizes()
792 orte_dfs_tracker_t *tptr, *trk; in process_seeks() local
806 trk = NULL; in process_seeks()
812 trk = tptr; in process_seeks()
816 if (NULL == trk) { in process_seeks()
842 if (OPAL_SUCCESS != (rc = opal_dss.pack(buffer, &trk->remote_fd, 1, OPAL_INT))) { in process_seeks()
859 ORTE_NAME_PRINT(&trk->host_daemon), in process_seeks()
860 trk->local_fd); in process_seeks()
863 &trk->host_daemon, buffer, in process_seeks()
903 orte_dfs_tracker_t *tptr, *trk; in process_reads() local
912 trk = NULL; in process_reads()
918 trk = tptr; in process_reads()
922 if (NULL == trk) { in process_reads()
945 if (OPAL_SUCCESS != (rc = opal_dss.pack(buffer, &trk->remote_fd, 1, OPAL_INT))) { in process_reads()
958 ORTE_NAME_PRINT(&trk->host_daemon), in process_reads()
959 trk->local_fd); in process_reads()
962 &trk->host_daemon, buffer, in process_reads()