Skip to content

Commit 8950a56

Browse files
committed
patch 7.4.1541
Problem: Missing job_info(). Solution: Implement it.
1 parent ac42afd commit 8950a56

6 files changed

Lines changed: 62 additions & 3 deletions

File tree

runtime/doc/eval.txt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4527,6 +4527,8 @@ job_status({job}) *job_status()* *E916*
45274527
If an exit callback was set with the "exit-cb" option and the
45284528
job is now detected to be "dead" the callback will be invoked.
45294529

4530+
For more information see |job_info()|.
4531+
45304532
{only available when compiled with the |+job| feature}
45314533

45324534
job_stop({job} [, {how}]) *job_stop()*

src/channel.c

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3725,6 +3725,40 @@ job_status(job_T *job)
37253725
return result;
37263726
}
37273727

3728+
/*
3729+
* Implementation of job_info().
3730+
*/
3731+
void
3732+
job_info(job_T *job, dict_T *dict)
3733+
{
3734+
dictitem_T *item;
3735+
varnumber_T nr;
3736+
3737+
dict_add_nr_str(dict, "status", 0L, (char_u *)job_status(job));
3738+
3739+
item = dictitem_alloc((char_u *)"channel");
3740+
if (item == NULL)
3741+
return;
3742+
item->di_tv.v_lock = 0;
3743+
item->di_tv.v_type = VAR_CHANNEL;
3744+
item->di_tv.vval.v_channel = job->jv_channel;
3745+
if (job->jv_channel != NULL)
3746+
++job->jv_channel->ch_refcount;
3747+
if (dict_add(dict, item) == FAIL)
3748+
dictitem_free(item);
3749+
3750+
#ifdef UNIX
3751+
nr = job->jv_pid;
3752+
#else
3753+
nr = job->jv_proc_info.dwProcessId;
3754+
#endif
3755+
dict_add_nr_str(dict, "process", nr, NULL);
3756+
3757+
dict_add_nr_str(dict, "exitval", job->jv_exitval, NULL);
3758+
dict_add_nr_str(dict, "exit-cb", 0L, job->jv_exit_cb);
3759+
dict_add_nr_str(dict, "stoponexit", 0L, job->jv_stoponexit);
3760+
}
3761+
37283762
int
37293763
job_stop(job_T *job, typval_T *argvars)
37303764
{

src/eval.c

Lines changed: 15 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -632,6 +632,7 @@ static void f_isnan(typval_T *argvars, typval_T *rettv);
632632
static void f_items(typval_T *argvars, typval_T *rettv);
633633
#ifdef FEAT_JOB_CHANNEL
634634
static void f_job_getchannel(typval_T *argvars, typval_T *rettv);
635+
static void f_job_info(typval_T *argvars, typval_T *rettv);
635636
static void f_job_setoptions(typval_T *argvars, typval_T *rettv);
636637
static void f_job_start(typval_T *argvars, typval_T *rettv);
637638
static void f_job_stop(typval_T *argvars, typval_T *rettv);
@@ -8208,6 +8209,7 @@ static struct fst
82088209
{"items", 1, 1, f_items},
82098210
#ifdef FEAT_JOB_CHANNEL
82108211
{"job_getchannel", 1, 1, f_job_getchannel},
8212+
{"job_info", 1, 1, f_job_info},
82118213
{"job_setoptions", 2, 2, f_job_setoptions},
82128214
{"job_start", 1, 2, f_job_start},
82138215
{"job_status", 1, 1, f_job_status},
@@ -14341,6 +14343,18 @@ f_job_getchannel(typval_T *argvars, typval_T *rettv)
1434114343
}
1434214344
}
1434314345

14346+
/*
14347+
* "job_info()" function
14348+
*/
14349+
static void
14350+
f_job_info(typval_T *argvars, typval_T *rettv)
14351+
{
14352+
job_T *job = get_job_arg(&argvars[0]);
14353+
14354+
if (job != NULL && rettv_dict_alloc(rettv) != FAIL)
14355+
job_info(job, rettv->vval.v_dict);
14356+
}
14357+
1434414358
/*
1434514359
* "job_setoptions()" function
1434614360
*/
@@ -14375,13 +14389,11 @@ f_job_start(typval_T *argvars, typval_T *rettv)
1437514389
f_job_status(typval_T *argvars, typval_T *rettv)
1437614390
{
1437714391
job_T *job = get_job_arg(&argvars[0]);
14378-
char *result;
1437914392

1438014393
if (job != NULL)
1438114394
{
14382-
result = job_status(job);
1438314395
rettv->v_type = VAR_STRING;
14384-
rettv->vval.v_string = vim_strsave((char_u *)result);
14396+
rettv->vval.v_string = vim_strsave((char_u *)job_status(job));
1438514397
}
1438614398
}
1438714399

src/proto/channel.pro

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,5 +54,6 @@ void job_stop_on_exit(void);
5454
void job_check_ended(void);
5555
job_T *job_start(typval_T *argvars);
5656
char *job_status(job_T *job);
57+
void job_info(job_T *job, dict_T *dict);
5758
int job_stop(job_T *job, typval_T *argvars);
5859
/* vim: set ft=c : */

src/testdir/test_channel.vim

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -479,6 +479,12 @@ func Test_raw_pipe()
479479
finally
480480
call job_stop(job)
481481
endtry
482+
483+
let s:job = job
484+
call s:waitFor('"dead" == job_status(s:job)')
485+
let info = job_info(job)
486+
call assert_equal("dead", info.status)
487+
call assert_equal("term", info.stoponexit)
482488
endfunc
483489

484490
func Test_nl_pipe()
@@ -1051,6 +1057,7 @@ endfunc
10511057
function s:test_exit_callback(port)
10521058
call job_setoptions(s:job, {'exit-cb': 'MyExitCb'})
10531059
let s:exit_job = s:job
1060+
call assert_equal('MyExitCb', job_info(s:job)['exit-cb'])
10541061
endfunc
10551062

10561063
func Test_exit_callback()
@@ -1069,6 +1076,7 @@ func Test_exit_callback()
10691076
endfor
10701077

10711078
call assert_equal('done', s:job_exit_ret)
1079+
call assert_equal('dead', job_info(s:exit_job).status)
10721080
unlet s:exit_job
10731081
endif
10741082
endfunc

src/version.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -743,6 +743,8 @@ static char *(features[]) =
743743

744744
static int included_patches[] =
745745
{ /* Add new patch number below this line */
746+
/**/
747+
1541,
746748
/**/
747749
1540,
748750
/**/

0 commit comments

Comments
 (0)