sink 681 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c void pmix_iof_static_dump_output(pmix_iof_sink_t *sink) sink 685 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_write_event_t *wev = &sink->wev; sink 706 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_sink_t *sink = (pmix_iof_sink_t*)cbdata; sink 707 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_write_event_t *wev = &sink->wev; sink 712 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_ACQUIRE_OBJECT(sink); sink 723 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_RELEASE(sink); sink 235 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h PMIX_EXPORT void pmix_iof_static_dump_output(pmix_iof_sink_t *sink); sink 129 opal/util/bipartite_graph_internal.h #define FOREACH_UV_ON_PATH(pred, source, sink, u, v) \ sink 130 opal/util/bipartite_graph_internal.h for (u = pred[sink], v = sink; u != -1; v = u, u = pred[u]) sink 51 orte/mca/filem/base/filem_base_fns.c req->sink = *ORTE_NAME_INVALID; sink 56 orte/mca/filem/base/filem_base_fns.c req->sink = *ORTE_NAME_INVALID; sink 84 orte/mca/filem/filem.h orte_process_name_t sink; sink 1108 orte/mca/filem/raw/filem_raw_module.c orte_filem_raw_incoming_t *sink = (orte_filem_raw_incoming_t*)cbdata; sink 1116 orte/mca/filem/raw/filem_raw_module.c ORTE_ACQUIRE_OBJECT(sink); sink 1121 orte/mca/filem/raw/filem_raw_module.c sink->fd)); sink 1124 orte/mca/filem/raw/filem_raw_module.c sink->pending = false; sink 1126 orte/mca/filem/raw/filem_raw_module.c while (NULL != (item = opal_list_remove_first(&sink->outputs))) { sink 1133 orte/mca/filem/raw/filem_raw_module.c sink->file)); sink 1135 orte/mca/filem/raw/filem_raw_module.c close(sink->fd); sink 1136 orte/mca/filem/raw/filem_raw_module.c sink->fd = -1; sink 1137 orte/mca/filem/raw/filem_raw_module.c if (ORTE_FILEM_TYPE_FILE == sink->type || sink 1138 orte/mca/filem/raw/filem_raw_module.c ORTE_FILEM_TYPE_EXE == sink->type) { sink 1142 orte/mca/filem/raw/filem_raw_module.c opal_argv_append_nosize(&sink->link_pts, sink->top); sink 1143 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_SUCCESS); sink 1146 orte/mca/filem/raw/filem_raw_module.c if (ORTE_FILEM_TYPE_TAR == sink->type) { sink 1147 orte/mca/filem/raw/filem_raw_module.c opal_asprintf(&cmd, "tar xf %s", sink->file); sink 1148 orte/mca/filem/raw/filem_raw_module.c } else if (ORTE_FILEM_TYPE_BZIP == sink->type) { sink 1149 orte/mca/filem/raw/filem_raw_module.c opal_asprintf(&cmd, "tar xjf %s", sink->file); sink 1150 orte/mca/filem/raw/filem_raw_module.c } else if (ORTE_FILEM_TYPE_GZIP == sink->type) { sink 1151 orte/mca/filem/raw/filem_raw_module.c opal_asprintf(&cmd, "tar xzf %s", sink->file); sink 1154 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1159 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1162 orte/mca/filem/raw/filem_raw_module.c dirname = opal_dirname(sink->fullpath); sink 1165 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1171 orte/mca/filem/raw/filem_raw_module.c sink->file, cmd)); sink 1174 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1179 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1185 orte/mca/filem/raw/filem_raw_module.c if (ORTE_SUCCESS != (rc = link_archive(sink))) { sink 1187 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_ERR_FILE_WRITE_FAILURE); sink 1189 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, ORTE_SUCCESS); sink 1194 orte/mca/filem/raw/filem_raw_module.c num_written = write(sink->fd, output->data, output->numbytes); sink 1198 orte/mca/filem/raw/filem_raw_module.c num_written, sink->file)); sink 1202 orte/mca/filem/raw/filem_raw_module.c opal_list_prepend(&sink->outputs, item); sink 1206 orte/mca/filem/raw/filem_raw_module.c sink->pending = true; sink 1207 orte/mca/filem/raw/filem_raw_module.c ORTE_POST_OBJECT(sink); sink 1208 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&sink->ev, 0); sink 1217 orte/mca/filem/raw/filem_raw_module.c sink->file, strerror(errno))); sink 1219 orte/mca/filem/raw/filem_raw_module.c opal_list_remove_item(&incoming_files, &sink->super); sink 1220 orte/mca/filem/raw/filem_raw_module.c send_complete(sink->file, OPAL_ERR_FILE_WRITE_FAILURE); sink 1221 orte/mca/filem/raw/filem_raw_module.c OBJ_RELEASE(sink); sink 1227 orte/mca/filem/raw/filem_raw_module.c opal_list_prepend(&sink->outputs, item); sink 1231 orte/mca/filem/raw/filem_raw_module.c sink->pending = true; sink 1232 orte/mca/filem/raw/filem_raw_module.c ORTE_POST_OBJECT(sink); sink 1233 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&sink->ev, 0); sink 122 orte/mca/iof/base/base.h orte_iof_sink_t *sink; sink 245 orte/mca/iof/base/iof_base_frame.c rev->sink = NULL; sink 262 orte/mca/iof/base/iof_base_frame.c if (NULL != rev->sink) { sink 263 orte/mca/iof/base/iof_base_frame.c OBJ_RELEASE(rev->sink); sink 280 orte/mca/iof/base/iof_base_output.c if (NULL != rev->sink) { sink 281 orte/mca/iof/base/iof_base_output.c wev = rev->sink->wev; sink 301 orte/mca/iof/base/iof_base_output.c orte_iof_sink_t *sink = (orte_iof_sink_t*)cbdata; sink 302 orte/mca/iof/base/iof_base_output.c orte_iof_write_event_t *wev = sink->wev; sink 307 orte/mca/iof/base/iof_base_output.c ORTE_ACQUIRE_OBJECT(sink); sink 318 orte/mca/iof/base/iof_base_output.c OBJ_RELEASE(sink); sink 335 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstdout && NULL == proct->revstdout->sink) { sink 346 orte/mca/iof/base/iof_base_setup.c ORTE_IOF_SINK_DEFINE(&proct->revstdout->sink, dst_name, sink 351 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstderr && NULL == proct->revstderr->sink) { sink 357 orte/mca/iof/base/iof_base_setup.c OBJ_RETAIN(proct->revstdout->sink); sink 358 orte/mca/iof/base/iof_base_setup.c proct->revstdout->sink->tag = ORTE_IOF_STDMERGE; // show that it is merged sink 359 orte/mca/iof/base/iof_base_setup.c proct->revstderr->sink = proct->revstdout->sink; sink 370 orte/mca/iof/base/iof_base_setup.c ORTE_IOF_SINK_DEFINE(&proct->revstderr->sink, dst_name, sink 376 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstddiag && NULL == proct->revstddiag->sink) { sink 378 orte/mca/iof/base/iof_base_setup.c OBJ_RETAIN(proct->revstderr->sink); sink 379 orte/mca/iof/base/iof_base_setup.c proct->revstddiag->sink = proct->revstderr->sink; sink 531 orte/mca/iof/hnp/iof_hnp.c orte_iof_sink_t *sink = (orte_iof_sink_t*)cbdata; sink 532 orte/mca/iof/hnp/iof_hnp.c orte_iof_write_event_t *wev = sink->wev; sink 537 orte/mca/iof/hnp/iof_hnp.c ORTE_ACQUIRE_OBJECT(sink); sink 632 orte/mca/iof/hnp/iof_hnp.c if (sink->closed && 0 == opal_list_get_size(&wev->outputs)) { sink 634 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(sink); sink 639 orte/mca/iof/hnp/iof_hnp.c sink->wev = NULL; sink 110 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_sink_t *sink; sink 202 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(rev->sink); sink 237 orte/mca/iof/hnp/iof_hnp_read.c OPAL_LIST_FOREACH(sink, proct->subscribers, orte_iof_sink_t) { sink 239 orte/mca/iof/hnp/iof_hnp_read.c if (ORTE_JOBID_INVALID == sink->daemon.jobid) { sink 242 orte/mca/iof/hnp/iof_hnp_read.c if ((sink->tag & rev->tag) && sink 243 orte/mca/iof/hnp/iof_hnp_read.c sink->name.jobid == proct->name.jobid && sink 244 orte/mca/iof/hnp/iof_hnp_read.c (ORTE_VPID_WILDCARD == sink->name.vpid || sink->name.vpid == proct->name.vpid)) { sink 255 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&sink->daemon))); sink 267 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&sink->daemon)); sink 268 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &proct->name, rev->tag, data, numbytes)); sink 270 orte/mca/iof/hnp/iof_hnp_read.c if (sink->exclusive) { sink 334 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != rev->sink && !(ORTE_IOF_STDIN & rev->sink->tag)) { sink 336 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); sink 63 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_sink_t *sink, *next; sink 152 orte/mca/iof/hnp/iof_hnp_receive.c ORTE_IOF_SINK_DEFINE(&sink, &origin, -1, ORTE_IOF_STDOUT, NULL); sink 153 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.jobid = requestor.jobid; sink 154 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.vpid = requestor.vpid; sink 155 orte/mca/iof/hnp/iof_hnp_receive.c sink->exclusive = exclusive; sink 156 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); sink 159 orte/mca/iof/hnp/iof_hnp_receive.c ORTE_IOF_SINK_DEFINE(&sink, &origin, -1, ORTE_IOF_STDERR, NULL); sink 160 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.jobid = requestor.jobid; sink 161 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.vpid = requestor.vpid; sink 162 orte/mca/iof/hnp/iof_hnp_receive.c sink->exclusive = exclusive; sink 163 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); sink 166 orte/mca/iof/hnp/iof_hnp_receive.c ORTE_IOF_SINK_DEFINE(&sink, &origin, -1, ORTE_IOF_STDDIAG, NULL); sink 167 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.jobid = requestor.jobid; sink 168 orte/mca/iof/hnp/iof_hnp_receive.c sink->daemon.vpid = requestor.vpid; sink 169 orte/mca/iof/hnp/iof_hnp_receive.c sink->exclusive = exclusive; sink 170 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); sink 188 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH_SAFE(sink, next, proct->subscribers, orte_iof_sink_t) { sink 190 orte/mca/iof/hnp/iof_hnp_receive.c if (ORTE_JOBID_INVALID == sink->daemon.jobid) { sink 194 orte/mca/iof/hnp/iof_hnp_receive.c if ((stream & sink->tag) && sink 195 orte/mca/iof/hnp/iof_hnp_receive.c sink->name.jobid == origin.jobid && sink 196 orte/mca/iof/hnp/iof_hnp_receive.c (ORTE_VPID_WILDCARD == sink->name.vpid || sink 198 orte/mca/iof/hnp/iof_hnp_receive.c sink->name.vpid == origin.vpid)) { sink 202 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &origin, ORTE_IOF_CLOSE, NULL, 0); sink 203 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_remove_item(proct->subscribers, &sink->super); sink 204 orte/mca/iof/hnp/iof_hnp_receive.c OBJ_RELEASE(sink); sink 241 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(sink, proct->subscribers, orte_iof_sink_t) { sink 243 orte/mca/iof/hnp/iof_hnp_receive.c if (ORTE_JOBID_INVALID == sink->daemon.jobid) { sink 246 orte/mca/iof/hnp/iof_hnp_receive.c if ((stream & sink->tag) && sink 247 orte/mca/iof/hnp/iof_hnp_receive.c sink->name.jobid == origin.jobid && sink 248 orte/mca/iof/hnp/iof_hnp_receive.c (ORTE_VPID_WILDCARD == sink->name.vpid || sink 250 orte/mca/iof/hnp/iof_hnp_receive.c sink->name.vpid == origin.vpid)) { sink 261 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &origin, stream, data, numbytes); sink 263 orte/mca/iof/hnp/iof_hnp_receive.c if (sink->exclusive) { sink 386 orte/mca/iof/orted/iof_orted.c orte_iof_sink_t *sink = (orte_iof_sink_t*)cbdata; sink 387 orte/mca/iof/orted/iof_orted.c orte_iof_write_event_t *wev = sink->wev; sink 392 orte/mca/iof/orted/iof_orted.c ORTE_ACQUIRE_OBJECT(sink); sink 411 orte/mca/iof/orted/iof_orted.c sink->wev = NULL; sink 437 orte/mca/iof/orted/iof_orted.c sink->wev = NULL; sink 105 orte/mca/iof/orted/iof_orted_read.c if (NULL != rev->sink) { sink 107 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); sink 1196 orte/mca/sstore/stage/sstore_stage_global.c p_set->sink.jobid = ORTE_PROC_MY_NAME->jobid; sink 1197 orte/mca/sstore/stage/sstore_stage_global.c p_set->sink.vpid = ORTE_PROC_MY_NAME->vpid; sink 2065 orte/mca/sstore/stage/sstore_stage_local.c p_set->sink.jobid = ORTE_PROC_MY_NAME->jobid; sink 2066 orte/mca/sstore/stage/sstore_stage_local.c p_set->sink.vpid = ORTE_PROC_MY_NAME->vpid; sink 75 test/util/bipartite_graph.c #define check_path_cycle(n, source, sink, pred) \ sink 83 test/util/bipartite_graph.c i_ = (sink); \ sink 84 test/util/bipartite_graph.c j_ = pred[(sink)]; \