kotovalexarian-likes-github/ruby--ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2022-11-09 12:17:21 -05:00
Code Releases Activity

* win32/win32.c (mypopen): fixed that mypclose() didn't really close

Browse source 
pipe.

	* win32/win32.c (CreateChild): set STARTF_USESTDHANDLES flag only
	  when some handles are passed.


git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@1859 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
usa 2001-11-26 07:59:01 +00:00
parent 5444b117f2
commit 43271e97ab
2 changed files with 84 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ChangeLog
View file

@ -1,3 +1,11 @@
Mon Nov 26 16:54:59 2001 Usaku Nakamura <usa@ruby-lang.org>
* win32/win32.c (mypopen): fixed that mypclose() didn't really close
pipe.
* win32/win32.c (CreateChild): set STARTF_USESTDHANDLES flag only
when some handles are passed.
Sun Nov 25 21:02:18 2001 Usaku Nakamura <usa@ruby-lang.org>
* parse.y (str_extend): change types of second and third arguments

104
win32/win32.c
View file

@ -444,7 +444,8 @@ mypopen (char *cmd, char *mode)
int pipemode;
struct ChildRecord* child;
BOOL fRet;
HANDLE hInFile, hOutFile;
HANDLE hInFile, hOutFile, hSavedStdIo, hDupFile;
HANDLE hCurProc;
SECURITY_ATTRIBUTES sa;
int fd;
@ -468,30 +469,75 @@ mypopen (char *cmd, char *mode)
return NULL;
}
/* save parent's STDIO and redirect for child */
hCurProc = GetCurrentProcess();
if (reading) {
child = CreateChild(cmd, &sa, NULL, hOutFile, NULL);
hSavedStdIo = GetStdHandle(STD_OUTPUT_HANDLE);
if (!SetStdHandle(STD_OUTPUT_HANDLE, hOutFile) ||
!DuplicateHandle(hCurProc, hInFile, hCurProc, &hDupFile, 0, FALSE,
DUPLICATE_SAME_ACCESS)) {
errno = GetLastError();
CloseHandle(hInFile);
CloseHandle(hOutFile);
CloseHandle(hCurProc);
return NULL;
}
CloseHandle(hInFile);
}
else {
child = CreateChild(cmd, &sa, hInFile, NULL, NULL);
}
if (!child) {
CloseHandle(hInFile);
hSavedStdIo = GetStdHandle(STD_INPUT_HANDLE);
if (!SetStdHandle(STD_INPUT_HANDLE, hInFile) ||
!DuplicateHandle(hCurProc, hOutFile, hCurProc, &hDupFile, 0, FALSE,
DUPLICATE_SAME_ACCESS)) {
errno = GetLastError();
CloseHandle(hInFile);
CloseHandle(hOutFile);
CloseHandle(hCurProc);
return NULL;
}
CloseHandle(hOutFile);
}
CloseHandle(hCurProc);
/* create child process */
child = CreateChild(cmd, &sa, NULL, NULL, NULL);
if (!child) {
CloseHandle(reading ? hOutFile : hInFile);
CloseHandle(hDupFile);
return NULL;
}
/* restore STDIO */
if (reading) {
fd = _open_osfhandle((long)hInFile, (_O_RDONLY | pipemode));
if (!SetStdHandle(STD_OUTPUT_HANDLE, hSavedStdIo)) {
errno = GetLastError();
CloseChildHandle(child);
CloseHandle(hDupFile);
CloseHandle(hOutFile);
return NULL;
}
}
else {
if (!SetStdHandle(STD_INPUT_HANDLE, hSavedStdIo)) {
errno = GetLastError();
CloseChildHandle(child);
CloseHandle(hInFile);
CloseHandle(hDupFile);
return NULL;
}
}
if (reading) {
fd = _open_osfhandle((long)hDupFile, (_O_RDONLY | pipemode));
CloseHandle(hOutFile);
}
else {
fd = _open_osfhandle((long)hOutFile, (_O_WRONLY | pipemode));
fd = _open_osfhandle((long)hDupFile, (_O_WRONLY | pipemode));
CloseHandle(hInFile);
}
if (fd == -1) {
CloseHandle(reading ? hInFile : hOutFile);
CloseHandle(hDupFile);
CloseChildHandle(child);
return NULL;
}
@ -571,24 +617,26 @@ CreateChild(char *cmd, SECURITY_ATTRIBUTES *psa, HANDLE hInput, HANDLE hOutput,
memset(&aStartupInfo, 0, sizeof (STARTUPINFO));
memset(&aProcessInformation, 0, sizeof (PROCESS_INFORMATION));
aStartupInfo.cb = sizeof (STARTUPINFO);
aStartupInfo.dwFlags = STARTF_USESTDHANDLES;
if (hInput) {
aStartupInfo.hStdInput = hInput;
}
else {
aStartupInfo.hStdInput = GetStdHandle(STD_INPUT_HANDLE);
}
if (hOutput) {
aStartupInfo.hStdOutput = hOutput;
}
else {
aStartupInfo.hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
}
if (hError) {
aStartupInfo.hStdError = hError;
}
else {
aStartupInfo.hStdError = GetStdHandle(STD_ERROR_HANDLE);
if (hInput || hOutput || hError) {
aStartupInfo.dwFlags = STARTF_USESTDHANDLES;
if (hInput) {
aStartupInfo.hStdInput = hInput;
}
else {
aStartupInfo.hStdInput = GetStdHandle(STD_INPUT_HANDLE);
}
if (hOutput) {
aStartupInfo.hStdOutput = hOutput;
}
else {
aStartupInfo.hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
}
if (hError) {
aStartupInfo.hStdError = hError;
}
else {
aStartupInfo.hStdError = GetStdHandle(STD_ERROR_HANDLE);
}
}
dwCreationFlags = (NORMAL_PRIORITY_CLASS);