m-vim_plugins/vim-fugitive
1
0
Fork 0
mirror of https://github.com/tpope/vim-fugitive.git synced 2025-11-10 04:23:46 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use jobs for calls to git update-index

Browse Source 
This is our only use of Git that requires writing to stdin, so
shoehorning that behavior onto s:StdoutToFile() frees us from worrying
about that when designing a more general purpose API.
This commit is contained in:
Tim Pope
2021-07-26 06:21:59 -04:00
parent 56561e47a6
commit f11b80022f
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
autoload/fugitive.vim
View File

@@ -629,7 +629,7 @@ function! s:TreeChomp(...) abort
throw 'fugitive: error running `' . cmd . '`: ' . out throw 'fugitive: error running `' . cmd . '`: ' . out
endfunction endfunction
function! s:StdoutToFile(out, cmd) abort function! s:StdoutToFile(out, cmd, ...) abort
let [argv, jopts, _] = s:PrepareJob(a:cmd) let [argv, jopts, _] = s:PrepareJob(a:cmd)
let exit = [] let exit = []
if exists('*jobstart') if exists('*jobstart')
@@ -638,6 +638,9 @@ function! s:StdoutToFile(out, cmd) abort
\ 'stderr_buffered': v:true, \ 'stderr_buffered': v:true,
\ 'on_exit': { j, code, _ -> add(exit, code) }}) \ 'on_exit': { j, code, _ -> add(exit, code) }})
let job = jobstart(argv, jopts) let job = jobstart(argv, jopts)
if a:0
call chansend(job, a:1)
endif
call chanclose(job, 'stdin') call chanclose(job, 'stdin')
call jobwait([job]) call jobwait([job])
if len(a:out) if len(a:out)
@@ -654,6 +657,9 @@ function! s:StdoutToFile(out, cmd) abort
\ 'err_name': err, \ 'err_name': err,
\ 'exit_cb': { j, code -> add(exit, code) }}) \ 'exit_cb': { j, code -> add(exit, code) }})
let job = job_start(argv, jopts) let job = job_start(argv, jopts)
if a:0
call ch_sendraw(job, a:1)
endif
call ch_close_in(job) call ch_close_in(job)
while ch_status(job) !=# 'closed' || job_status(job) ==# 'run' while ch_status(job) !=# 'closed' || job_status(job) ==# 'run'
exe has('patch-8.2.2366') ? 'sleep! 1m' : 'sleep 1m' exe has('patch-8.2.2366') ? 'sleep! 1m' : 'sleep 1m'
@@ -1733,7 +1739,7 @@ endfunction
function! s:UpdateIndex(dir, info) abort function! s:UpdateIndex(dir, info) abort
let info = join(a:info[0:-2]) . "\t" . a:info[-1] . "\n" let info = join(a:info[0:-2]) . "\t" . a:info[-1] . "\n"
let [error, exec_error] = s:SystemError(fugitive#Prepare([a:dir, 'update-index', '--index-info']), info) let [error, exec_error] = s:StdoutToFile('', [a:dir, 'update-index', '--index-info'], info)
return !exec_error ? '' : len(error) ? error : 'unknown update-index error' return !exec_error ? '' : len(error) ? error : 'unknown update-index error'
endfunction endfunction