Skip to content
Snippets Groups Projects
Commit 9761a773 authored by Christopher J. Morrone's avatar Christopher J. Morrone
Browse files

Finish renaming standard IO variables, and more man page updates.

parent 0f69361a
No related branches found
No related tags found
No related merge requests found
...@@ -130,15 +130,21 @@ data to standard output or error, this can be performance limiting.) ...@@ -130,15 +130,21 @@ data to standard output or error, this can be performance limiting.)
.PD .PD
Instruct SLURM to connect each task's standard input, standard output, Instruct SLURM to connect each task's standard input, standard output,
or standard error directly to the file name specified or standard error directly to the file name specified
in the "\fIfilename pattern\fR". Unlike the \-\-slaunch\-[input|output|error] in the "\fIfilename pattern\fR".
options, standard IO traffic is NOT transferred between the tasks and slaunch
for the specified input, output, or error stream. By default, the standard IO streams of all tasks are received and transmitted
over the network to commands like slaunch and sattach. These options disable
the networked standard IO streams and instead connect the standard IO streams
of the tasks directly to files on the local node of each task (although the file
may, of course, be located on a networked filesystem).
Whether or not the tasks share a file depends on whether or not the file lives
on a local filesystem or a shared network filesytem, and on whether or not
the filename pattern expands to the same file name for each task.
The filename pattern may The filename pattern may
contain one or more replacement symbols, which are a percent sign "%" followed contain one or more replacement symbols, which are a percent sign "%" followed
by a letter (e.g. %t). If a replacement symbol is expanded to a by a letter (e.g. %t).
different string for each task, then each task will be connected to a
different file.
Supported replacement symbols are: Supported replacement symbols are:
.PD 0 .PD 0
......
...@@ -88,15 +88,15 @@ typedef struct slaunch_options { ...@@ -88,15 +88,15 @@ typedef struct slaunch_options {
char *local_ofname; /* --local-output, -o filename */ char *local_ofname; /* --local-output, -o filename */
char *local_ifname; /* --local-input, -i filename */ char *local_ifname; /* --local-input, -i filename */
char *local_efname; /* --local-error, -e filename */ char *local_efname; /* --local-error, -e filename */
uint32_t local_input_taskid; uint32_t local_input_filter;
uint32_t local_output_taskid; uint32_t local_output_filter;
uint32_t local_error_taskid; uint32_t local_error_filter;
char *remote_ofname; /* --remote-output filename */ char *remote_ofname; /* --remote-output filename */
char *remote_ifname; /* --remote-input filename */ char *remote_ifname; /* --remote-input filename */
char *remote_efname; /* --remote-error filename */ char *remote_efname; /* --remote-error filename */
uint32_t remote_input_taskid; uint32_t remote_input_filter;
uint32_t remote_output_taskid; uint32_t remote_output_filter;
uint32_t remote_error_taskid; uint32_t remote_error_filter;
int slurmd_debug; /* --slurmd-debug, -D */ int slurmd_debug; /* --slurmd-debug, -D */
core_format_t core_type;/* --core= */ core_format_t core_type;/* --core= */
......
...@@ -528,12 +528,12 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx) ...@@ -528,12 +528,12 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx)
if (cio_fds->in.fd == -1) if (cio_fds->in.fd == -1)
fatal("Could not open stdin file: %m"); fatal("Could not open stdin file: %m");
} }
if (opt.local_input_taskid != (uint32_t)-1) { if (opt.local_input_filter != (uint32_t)-1) {
cio_fds->in.taskid = opt.local_input_taskid; cio_fds->in.taskid = opt.local_input_filter;
/* FIXME - don't peek into the step context, that's cheating! */ /* FIXME - don't peek into the step context, that's cheating! */
cio_fds->in.nodeid = cio_fds->in.nodeid =
_taskid_to_nodeid(step_ctx->step_resp->step_layout, _taskid_to_nodeid(step_ctx->step_resp->step_layout,
opt.local_input_taskid); opt.local_input_filter);
} }
/* /*
...@@ -547,8 +547,8 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx) ...@@ -547,8 +547,8 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx)
if (cio_fds->out.fd == -1) if (cio_fds->out.fd == -1)
fatal("Could not open stdout file: %m"); fatal("Could not open stdout file: %m");
} }
if (opt.local_output_taskid != (uint32_t)-1) { if (opt.local_output_filter != (uint32_t)-1) {
cio_fds->out.taskid = opt.local_output_taskid; cio_fds->out.taskid = opt.local_output_filter;
} }
/* FIXME - need to change condition for shared output and error */ /* FIXME - need to change condition for shared output and error */
...@@ -575,8 +575,8 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx) ...@@ -575,8 +575,8 @@ _setup_local_fds(slurm_step_io_fds_t *cio_fds, slurm_step_ctx ctx)
if (cio_fds->err.fd == -1) if (cio_fds->err.fd == -1)
fatal("Could not open stderr file: %m"); fatal("Could not open stderr file: %m");
} }
if (opt.local_error_taskid != (uint32_t)-1) { if (opt.local_error_filter != (uint32_t)-1) {
cio_fds->err.taskid = opt.local_error_taskid; cio_fds->err.taskid = opt.local_error_filter;
} }
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment