Skip to content
Snippets Groups Projects
Commit 56d1629e authored by Morris Jette's avatar Morris Jette
Browse files

Add back function

Commit 5e18d666 was incomplete, missing
  a function and not buildable.
parent 09afe7a3
No related branches found
No related tags found
No related merge requests found
...@@ -213,6 +213,7 @@ static bb_pools_t *_bb_get_pools(int *num_ent, bb_state_t *state_ptr, ...@@ -213,6 +213,7 @@ static bb_pools_t *_bb_get_pools(int *num_ent, bb_state_t *state_ptr,
uint32_t timeout); uint32_t timeout);
static bb_sessions_t *_bb_get_sessions(int *num_ent, bb_state_t *state_ptr, static bb_sessions_t *_bb_get_sessions(int *num_ent, bb_state_t *state_ptr,
uint32_t timeout); uint32_t timeout);
static int _build_bb_script(struct job_record *job_ptr, char *script_file);
static int _create_bufs(struct job_record *job_ptr, bb_job_t *bb_job, static int _create_bufs(struct job_record *job_ptr, bb_job_t *bb_job,
bool job_ready); bool job_ready);
static void * _create_persistent(void *x); static void * _create_persistent(void *x);
...@@ -2730,6 +2731,21 @@ fini: xfree(access); ...@@ -2730,6 +2731,21 @@ fini: xfree(access);
return rc; return rc;
} }
/* For interactive jobs, build a script containing the relevant DataWarp
* commands, as needed by the Cray API */
static int _build_bb_script(struct job_record *job_ptr, char *script_file)
{
char *out_buf = NULL;
int rc;
xstrcat(out_buf, "#!/bin/bash\n");
xstrcat(out_buf, job_ptr->burst_buffer);
rc = _write_file(script_file, out_buf);
xfree(out_buf);
return rc;
}
/* /*
* init() is called when the plugin is loaded, before any other functions * init() is called when the plugin is loaded, before any other functions
* are called. Read and validate configuration file here. Spawn thread to * are called. Read and validate configuration file here. Spawn thread to
......
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