Problem: Job control doesn't work well on MS-Windows.
Solution: Various fixes. (Ken Takata, Ozaki Kiichi , Yukihiro Nakadaira,
Yasuhiro Matsumoto)
# Processor Version: CPUNR=[i386, i486, i586, i686, pentium4] (default is
# i386)
#
-# Version Support: WINVER=[0x0400, 0x0500] (default is 0x0400)
+# Version Support: WINVER=[0x0400, 0x0500] (default is 0x0500)
#
# Debug version: DEBUG=yes
# Mapfile: MAP=[no, yes or lines] (default is yes)
!endif
### Set the default $(WINVER) to make it work with VC++7.0 (VS.NET)
-# When set to 0x0500 ":browse" stops working.
!ifndef WINVER
-WINVER = 0x0400
+WINVER = 0x0500
!endif
# If you have a fixed directory for $VIM or $VIMRUNTIME, other than the normal
static void
job_free(job_T *job)
{
- /* TODO: free any handles */
-
+ mch_clear_job(job);
vim_free(job);
}
s = vim_strsave_shellescape(s, FALSE, TRUE);
if (s == NULL)
goto theend;
+ ga_concat(&ga, s);
+ vim_free(s);
}
- ga_concat(&ga, s);
- vim_free(s);
+ else
+ ga_concat(&ga, s);
if (li->li_next != NULL)
ga_append(&ga, ' ');
#endif
"process %ld %s", (long)job->jv_pid, status);
# elif defined(WIN32)
vim_snprintf((char *)buf, NUMBUFLEN,
- "process %ld %s", (long)job->jv_pi.dwProcessId,
+ "process %ld %s",
+ (long)job->jv_proc_info.dwProcessId,
status);
# else
/* fall-back */
job->jv_status = JOB_ENDED;
return "dead";
}
+ if (WIFSIGNALED(status))
+ {
+ job->jv_exitval = -1;
+ job->jv_status = JOB_ENDED;
+ return "dead";
+ }
return "run";
}
mch_stop_job(job_T *job, char_u *how)
{
int sig = -1;
+ pid_t job_pid;
if (STRCMP(how, "hup") == 0)
sig = SIGHUP;
sig = atoi((char *)how);
else
return FAIL;
+
/* TODO: have an option to only kill the process, not the group? */
- kill(-job->jv_pid, sig);
+ job_pid = job->jv_pid;
+ if (job_pid == getpgid(job_pid))
+ job_pid = -job_pid;
+
+ kill(job_pid, sig);
+
return OK;
}
+
+/*
+ * Clear the data related to "job".
+ */
+ void
+mch_clear_job(job_T *job)
+{
+ /* call waitpid because child process may become zombie */
+# ifdef __NeXT__
+ wait4(job->jv_pid, NULL, WNOHANG, (struct rusage *)0);
+# else
+ waitpid(job->jv_pid, NULL, WNOHANG);
+# endif
+}
#endif
/*
{
STARTUPINFO si;
PROCESS_INFORMATION pi;
+ HANDLE jo;
+ jo = CreateJobObject(NULL, NULL);
+ if (jo == NULL)
+ {
+ job->jv_status = JOB_FAILED;
+ return;
+ }
+
+ ZeroMemory(&pi, sizeof(pi));
ZeroMemory(&si, sizeof(si));
si.cb = sizeof(si);
+ si.dwFlags = STARTF_USESHOWWINDOW;
+ si.wShowWindow = SW_HIDE;
if (!vim_create_process(cmd, FALSE,
+ CREATE_SUSPENDED |
CREATE_DEFAULT_ERROR_MODE |
CREATE_NEW_PROCESS_GROUP |
- CREATE_NO_WINDOW,
+ CREATE_NEW_CONSOLE,
&si, &pi))
+ {
+ CloseHandle(jo);
job->jv_status = JOB_FAILED;
+ }
else
{
- job->jv_pi = pi;
+ if (!AssignProcessToJobObject(jo, pi.hProcess))
+ {
+ /* if failing, switch the way to terminate
+ * process with TerminateProcess. */
+ CloseHandle(jo);
+ jo = NULL;
+ }
+ ResumeThread(pi.hThread);
+ CloseHandle(job->jv_proc_info.hThread);
+ job->jv_proc_info = pi;
+ job->jv_job_object = jo;
job->jv_status = JOB_STARTED;
}
}
{
DWORD dwExitCode = 0;
- if (!GetExitCodeProcess(job->jv_pi.hProcess, &dwExitCode))
- return "dead";
- if (dwExitCode != STILL_ACTIVE)
+ if (!GetExitCodeProcess(job->jv_proc_info.hProcess, &dwExitCode)
+ || dwExitCode != STILL_ACTIVE)
{
- CloseHandle(job->jv_pi.hProcess);
- CloseHandle(job->jv_pi.hThread);
+ job->jv_status = JOB_ENDED;
return "dead";
}
return "run";
int
mch_stop_job(job_T *job, char_u *how)
{
+ int ret = 0;
+ int ctrl_c = STRCMP(how, "int") == 0;
+
if (STRCMP(how, "kill") == 0)
- TerminateProcess(job->jv_pi.hProcess, 0);
- else
- return GenerateConsoleCtrlEvent(
- STRCMP(how, "hup") == 0 ?
- CTRL_BREAK_EVENT : CTRL_C_EVENT,
- job->jv_pi.dwProcessId) ? OK : FAIL;
- return OK;
+ {
+ if (job->jv_job_object != NULL)
+ return TerminateJobObject(job->jv_job_object, 0) ? OK : FAIL;
+ else
+ return TerminateProcess(job->jv_proc_info.hProcess, 0) ? OK : FAIL;
+ }
+
+ if (!AttachConsole(job->jv_proc_info.dwProcessId))
+ return FAIL;
+ ret = GenerateConsoleCtrlEvent(
+ ctrl_c ? CTRL_C_EVENT : CTRL_BREAK_EVENT,
+ job->jv_proc_info.dwProcessId)
+ ? OK : FAIL;
+ FreeConsole();
+ return ret;
+}
+
+/*
+ * Clear the data related to "job".
+ */
+ void
+mch_clear_job(job_T *job)
+{
+ if (job->jv_status != JOB_FAILED)
+ {
+ if (job->jv_job_object != NULL)
+ CloseHandle(job->jv_job_object);
+ CloseHandle(job->jv_proc_info.hProcess);
+ }
}
#endif
void mch_start_job(char **argv, job_T *job);
char *mch_job_status(job_T *job);
int mch_stop_job(job_T *job, char_u *how);
+void mch_clear_job(job_T *job);
void mch_breakcheck(void);
int mch_expandpath(garray_T *gap, char_u *path, int flags);
int mch_expand_wildcards(int num_pat, char_u **pat, int *num_file, char_u ***file, int flags);
void mch_start_job(char *cmd, job_T *job);
char *mch_job_status(job_T *job);
int mch_stop_job(job_T *job, char_u *how);
+void mch_clear_job(job_T *job);
void mch_set_normal_colors(void);
void mch_write(char_u *s, int len);
void mch_delay(long msec, int ignoreinput);
int jv_exitval;
#endif
#ifdef WIN32
- PROCESS_INFORMATION jv_pi;
+ PROCESS_INFORMATION jv_proc_info;
+ HANDLE jv_job_object;
#endif
jobstatus_T jv_status;
static int included_patches[] =
{ /* Add new patch number below this line */
+/**/
+ 1306,
/**/
1305,
/**/