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)];                       \