mirror of
https://github.com/vim/vim.git
synced 2025-07-26 11:04:33 -04:00
patch 8.0.1742: cannot get a list of all the jobs
Problem: Cannot get a list of all the jobs. Cannot get the command of the job. Solution: When job_info() is called without an argument return a list of jobs. Otherwise, include the command that the job is running. (Yegappan Lakshmanan)
This commit is contained in:
parent
259a90f7ce
commit
e1fc51558d
@ -2234,7 +2234,7 @@ islocked({expr}) Number |TRUE| if {expr} is locked
|
|||||||
isnan({expr}) Number |TRUE| if {expr} is NaN
|
isnan({expr}) Number |TRUE| if {expr} is NaN
|
||||||
items({dict}) List key-value pairs in {dict}
|
items({dict}) List key-value pairs in {dict}
|
||||||
job_getchannel({job}) Channel get the channel handle for {job}
|
job_getchannel({job}) Channel get the channel handle for {job}
|
||||||
job_info({job}) Dict get information about {job}
|
job_info([{job}]) Dict get information about {job}
|
||||||
job_setoptions({job}, {options}) none set options for {job}
|
job_setoptions({job}, {options}) none set options for {job}
|
||||||
job_start({command} [, {options}])
|
job_start({command} [, {options}])
|
||||||
Job start a job
|
Job start a job
|
||||||
|
@ -5002,6 +5002,8 @@ static job_T *first_job = NULL;
|
|||||||
static void
|
static void
|
||||||
job_free_contents(job_T *job)
|
job_free_contents(job_T *job)
|
||||||
{
|
{
|
||||||
|
int i;
|
||||||
|
|
||||||
ch_log(job->jv_channel, "Freeing job");
|
ch_log(job->jv_channel, "Freeing job");
|
||||||
if (job->jv_channel != NULL)
|
if (job->jv_channel != NULL)
|
||||||
{
|
{
|
||||||
@ -5019,6 +5021,12 @@ job_free_contents(job_T *job)
|
|||||||
vim_free(job->jv_tty_out);
|
vim_free(job->jv_tty_out);
|
||||||
vim_free(job->jv_stoponexit);
|
vim_free(job->jv_stoponexit);
|
||||||
free_callback(job->jv_exit_cb, job->jv_exit_partial);
|
free_callback(job->jv_exit_cb, job->jv_exit_partial);
|
||||||
|
if (job->argv != NULL)
|
||||||
|
{
|
||||||
|
for (i = 0; job->argv[i] != NULL; i++)
|
||||||
|
vim_free(job->argv[i]);
|
||||||
|
vim_free(job->argv);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
@ -5463,6 +5471,8 @@ job_start(typval_T *argvars, char **argv_arg, jobopt_T *opt_arg)
|
|||||||
#endif
|
#endif
|
||||||
jobopt_T opt;
|
jobopt_T opt;
|
||||||
ch_part_T part;
|
ch_part_T part;
|
||||||
|
int len;
|
||||||
|
int i;
|
||||||
|
|
||||||
job = job_alloc();
|
job = job_alloc();
|
||||||
if (job == NULL)
|
if (job == NULL)
|
||||||
@ -5593,11 +5603,21 @@ job_start(typval_T *argvars, char **argv_arg, jobopt_T *opt_arg)
|
|||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* Save the command used to start the job */
|
||||||
|
len = 0;
|
||||||
|
for (i = 0; argv[i] != NULL; i++)
|
||||||
|
len++;
|
||||||
|
job->argv = (char_u **)alloc(sizeof(char_u *) * (len + 1));
|
||||||
|
if (job->argv == NULL)
|
||||||
|
goto theend;
|
||||||
|
for (i = 0; argv[i] != NULL; i++)
|
||||||
|
job->argv[i] = vim_strsave((char_u *)argv[i]);
|
||||||
|
job->argv[i] = NULL;
|
||||||
|
|
||||||
#ifdef USE_ARGV
|
#ifdef USE_ARGV
|
||||||
if (ch_log_active())
|
if (ch_log_active())
|
||||||
{
|
{
|
||||||
garray_T ga;
|
garray_T ga;
|
||||||
int i;
|
|
||||||
|
|
||||||
ga_init2(&ga, (int)sizeof(char), 200);
|
ga_init2(&ga, (int)sizeof(char), 200);
|
||||||
for (i = 0; i < argc; ++i)
|
for (i = 0; i < argc; ++i)
|
||||||
@ -5661,6 +5681,8 @@ job_info(job_T *job, dict_T *dict)
|
|||||||
{
|
{
|
||||||
dictitem_T *item;
|
dictitem_T *item;
|
||||||
varnumber_T nr;
|
varnumber_T nr;
|
||||||
|
list_T *l;
|
||||||
|
int i;
|
||||||
|
|
||||||
dict_add_nr_str(dict, "status", 0L, (char_u *)job_status(job));
|
dict_add_nr_str(dict, "status", 0L, (char_u *)job_status(job));
|
||||||
|
|
||||||
@ -5689,6 +5711,33 @@ job_info(job_T *job, dict_T *dict)
|
|||||||
dict_add_nr_str(dict, "exitval", job->jv_exitval, NULL);
|
dict_add_nr_str(dict, "exitval", job->jv_exitval, NULL);
|
||||||
dict_add_nr_str(dict, "exit_cb", 0L, job->jv_exit_cb);
|
dict_add_nr_str(dict, "exit_cb", 0L, job->jv_exit_cb);
|
||||||
dict_add_nr_str(dict, "stoponexit", 0L, job->jv_stoponexit);
|
dict_add_nr_str(dict, "stoponexit", 0L, job->jv_stoponexit);
|
||||||
|
|
||||||
|
l = list_alloc();
|
||||||
|
if (l != NULL)
|
||||||
|
{
|
||||||
|
dict_add_list(dict, "cmd", l);
|
||||||
|
for (i = 0; job->argv[i] != NULL; i++)
|
||||||
|
list_append_string(l, job->argv[i], -1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Implementation of job_info() to return info for all jobs.
|
||||||
|
*/
|
||||||
|
void
|
||||||
|
job_info_all(list_T *l)
|
||||||
|
{
|
||||||
|
job_T *job;
|
||||||
|
typval_T tv;
|
||||||
|
|
||||||
|
for (job = first_job; job != NULL; job = job->jv_next)
|
||||||
|
{
|
||||||
|
tv.v_type = VAR_JOB;
|
||||||
|
tv.vval.v_job = job;
|
||||||
|
|
||||||
|
if (list_append_tv(l, &tv) != OK)
|
||||||
|
return;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -682,7 +682,7 @@ static struct fst
|
|||||||
{"items", 1, 1, f_items},
|
{"items", 1, 1, f_items},
|
||||||
#ifdef FEAT_JOB_CHANNEL
|
#ifdef FEAT_JOB_CHANNEL
|
||||||
{"job_getchannel", 1, 1, f_job_getchannel},
|
{"job_getchannel", 1, 1, f_job_getchannel},
|
||||||
{"job_info", 1, 1, f_job_info},
|
{"job_info", 0, 1, f_job_info},
|
||||||
{"job_setoptions", 2, 2, f_job_setoptions},
|
{"job_setoptions", 2, 2, f_job_setoptions},
|
||||||
{"job_start", 1, 2, f_job_start},
|
{"job_start", 1, 2, f_job_start},
|
||||||
{"job_status", 1, 1, f_job_status},
|
{"job_status", 1, 1, f_job_status},
|
||||||
@ -7007,10 +7007,15 @@ f_job_getchannel(typval_T *argvars, typval_T *rettv)
|
|||||||
static void
|
static void
|
||||||
f_job_info(typval_T *argvars, typval_T *rettv)
|
f_job_info(typval_T *argvars, typval_T *rettv)
|
||||||
{
|
{
|
||||||
job_T *job = get_job_arg(&argvars[0]);
|
if (argvars[0].v_type != VAR_UNKNOWN)
|
||||||
|
{
|
||||||
|
job_T *job = get_job_arg(&argvars[0]);
|
||||||
|
|
||||||
if (job != NULL && rettv_dict_alloc(rettv) != FAIL)
|
if (job != NULL && rettv_dict_alloc(rettv) != FAIL)
|
||||||
job_info(job, rettv->vval.v_dict);
|
job_info(job, rettv->vval.v_dict);
|
||||||
|
}
|
||||||
|
else if (rettv_list_alloc(rettv) == OK)
|
||||||
|
job_info_all(rettv->vval.v_list);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -68,5 +68,6 @@ void job_check_ended(void);
|
|||||||
job_T *job_start(typval_T *argvars, char **argv_arg, jobopt_T *opt_arg);
|
job_T *job_start(typval_T *argvars, char **argv_arg, jobopt_T *opt_arg);
|
||||||
char *job_status(job_T *job);
|
char *job_status(job_T *job);
|
||||||
void job_info(job_T *job, dict_T *dict);
|
void job_info(job_T *job, dict_T *dict);
|
||||||
|
void job_info_all(list_T *l);
|
||||||
int job_stop(job_T *job, typval_T *argvars, char *type);
|
int job_stop(job_T *job, typval_T *argvars, char *type);
|
||||||
/* vim: set ft=c : */
|
/* vim: set ft=c : */
|
||||||
|
@ -271,10 +271,10 @@ typedef struct
|
|||||||
# define w_p_scl w_onebuf_opt.wo_scl /* 'signcolumn' */
|
# define w_p_scl w_onebuf_opt.wo_scl /* 'signcolumn' */
|
||||||
#endif
|
#endif
|
||||||
#ifdef FEAT_TERMINAL
|
#ifdef FEAT_TERMINAL
|
||||||
char_u *wo_tk;
|
char_u *wo_twk;
|
||||||
#define w_p_tk w_onebuf_opt.wo_tk /* 'termkey' */
|
# define w_p_twk w_onebuf_opt.wo_twk /* 'termwinkey' */
|
||||||
char_u *wo_tms;
|
char_u *wo_tws;
|
||||||
#define w_p_tms w_onebuf_opt.wo_tms /* 'termsize' */
|
# define w_p_tws w_onebuf_opt.wo_tws /* 'termwinsize' */
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#ifdef FEAT_EVAL
|
#ifdef FEAT_EVAL
|
||||||
@ -1488,6 +1488,7 @@ struct jobvar_S
|
|||||||
int jv_copyID;
|
int jv_copyID;
|
||||||
|
|
||||||
channel_T *jv_channel; /* channel for I/O, reference counted */
|
channel_T *jv_channel; /* channel for I/O, reference counted */
|
||||||
|
char_u **argv; /* command line used to start the job */
|
||||||
};
|
};
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -2262,6 +2263,9 @@ struct file_buffer
|
|||||||
#ifdef FEAT_LISP
|
#ifdef FEAT_LISP
|
||||||
char_u *b_p_lw; /* 'lispwords' local value */
|
char_u *b_p_lw; /* 'lispwords' local value */
|
||||||
#endif
|
#endif
|
||||||
|
#ifdef FEAT_TERMINAL
|
||||||
|
long b_p_twsl; /* 'termwinscroll' */
|
||||||
|
#endif
|
||||||
|
|
||||||
/* end of buffer options */
|
/* end of buffer options */
|
||||||
|
|
||||||
|
@ -508,6 +508,16 @@ func Test_raw_pipe()
|
|||||||
let info = job_info(job)
|
let info = job_info(job)
|
||||||
call assert_equal("dead", info.status)
|
call assert_equal("dead", info.status)
|
||||||
call assert_equal("term", info.stoponexit)
|
call assert_equal("term", info.stoponexit)
|
||||||
|
call assert_equal(2, len(info.cmd))
|
||||||
|
call assert_equal("test_channel_pipe.py", info.cmd[1])
|
||||||
|
|
||||||
|
let found = 0
|
||||||
|
for j in job_info()
|
||||||
|
if j == job
|
||||||
|
let found += 1
|
||||||
|
endif
|
||||||
|
endfor
|
||||||
|
call assert_equal(1, found)
|
||||||
endfunc
|
endfunc
|
||||||
|
|
||||||
func Test_nl_pipe()
|
func Test_nl_pipe()
|
||||||
|
@ -761,6 +761,8 @@ static char *(features[]) =
|
|||||||
|
|
||||||
static int included_patches[] =
|
static int included_patches[] =
|
||||||
{ /* Add new patch number below this line */
|
{ /* Add new patch number below this line */
|
||||||
|
/**/
|
||||||
|
1742,
|
||||||
/**/
|
/**/
|
||||||
1741,
|
1741,
|
||||||
/**/
|
/**/
|
||||||
|
Loading…
x
Reference in New Issue
Block a user