x1 wrote:
=20
Simon, this worked on my machine also --excellent!
---Question / Request:
I tried stripping out the GUI stuff so that I could implement this
'solution' into my current needs (to no avail)
I would like to use this as a replacement to popen(), could you help
me strip this down into popen() form?
After the read_file method, I tried keeping what appeared to do the
actual work but.. no luck.. any suggestions?
=20
ok, here we go:
---------------------------------------
io =3D popen('ver')
puts io.read_all
---------------------------------------
better?
=20
or:
---------------------------------------
io =3D popen('cmd')
io.write("ping localhost\nexit\n")
=20
while !(buffer =3D io.read).empty?
print buffer
end
---------------------------------------
?
=20
note that read blocks if there is no data to read, but this is done in a
ruby-thread friendly way. So you may put that in a new Thread and your
gui is still responsive (i tried that with the fox gui).
(if you let it block on read_file the whole process blocks)
=20
The same is true for read_all and you can have multiple childs at once.
=20
here is the complete code:
=20
-------------------------------------------------------------------------
require 'Win32API'
=20
$stdout.sync =3D true
=20
NORMAL_PRIORITY_CLASS =3D 0x00000020
STARTUP_INFO_SIZE =3D 68
PROCESS_INFO_SIZE =3D 16
SECURITY_ATTRIBUTES_SIZE =3D 12
=20
ERROR_SUCCESS =3D 0x00
FORMAT_MESSAGE_FROM_SYSTEM =3D 0x1000
FORMAT_MESSAGE_ARGUMENT_ARRAY =3D 0x2000
=20
HANDLE_FLAG_INHERIT =3D 1
HANDLE_FLAG_PROTECT_FROM_CLOSE =3D2
=20
STARTF_USESHOWWINDOW =3D 0x00000001
STARTF_USESTDHANDLES =3D 0x00000100
=20
def raise_last_win_32_error
errorCode =3D Win32API.new("kernel32", "GetLastError", [], 'L').call
if errorCode !=3D ERROR_SUCCESS
params =3D [
'L', # IN DWORD dwFlags,
'P', # IN LPCVOID lpSource,
'L', # IN DWORD dwMessageId,
'L', # IN DWORD dwLanguageId,
'P', # OUT LPSTR lpBuffer,
'L', # IN DWORD nSize,
'P', # IN va_list *Arguments
]
=20
formatMessage =3D Win32API.new("kernel32", "FormatMessage", params, = 'L')
msg =3D ' ' * 255
msgLength =3D formatMessage.call(FORMAT_MESSAGE_FROM_SYSTEM +
FORMAT_MESSAGE_ARGUMENT_ARRAY, '', errorCode, 0, msg, 255, '')
=20
msg.gsub!(/\000/, '')
msg.strip!
raise msg
else
raise 'GetLastError returned ERROR_SUCCESS'
end
end
=20
def create_pipe # returns read and write handle
params =3D [
'P', # pointer to read handle
'P', # pointer to write handle
'P', # pointer to security attributes
'L'] # pipe size
=20
createPipe =3D Win32API.new("kernel32", "CreatePipe", params, 'I')
=20
read_handle, write_handle =3D [0].pack('I'), [0].pack('I')
sec_attrs =3D [SECURITY_ATTRIBUTES_SIZE, 0, 1].pack('III')
=20
raise_last_win_32_error if createPipe.Call(read_handle,
write_handle, sec_attrs, 0).zero?
=20
[read_handle.unpack('I')[0], write_handle.unpack('I')[0]]
end
=20
def set_handle_information(handle, flags, value)
params =3D [
'L', # handle to an object
'L', # specifies flags to change
'L'] # specifies new values for flags
=20
setHandleInformation =3D Win32API.new("kernel32",
"SetHandleInformation", params, 'I')
raise_last_win_32_error if setHandleInformation.Call(handle,
flags, value).zero?
nil
end
=20
def close_handle(handle)
closeHandle =3D Win32API.new("kernel32", "CloseHandle", ['L'], 'I')
raise_last_win_32_error if closeHandle.call(handle).zero?
end
=20
def create_process(command, stdin, stdout, stderror)
params =3D [
'L', # IN LPCSTR lpApplicationName
'P', # IN LPSTR lpCommandLine
'L', # IN LPSECURITY_ATTRIBUTES lpProcessAttributes
'L', # IN LPSECURITY_ATTRIBUTES lpThreadAttributes
'L', # IN BOOL bInheritHandles
'L', # IN DWORD dwCreationFlags
'L', # IN LPVOID lpEnvironment
'L', # IN LPCSTR lpCurrentDirectory
'P', # IN LPSTARTUPINFOA lpStartupInfo
'P'] # OUT LPPROCESS_INFORMATION lpProcessInformation
=20
startupInfo =3D [STARTUP_INFO_SIZE, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
STARTF_USESTDHANDLES | STARTF_USESHOWWINDOW, 0,
0, 0, stdin, stdout, stderror].pack('IIIIIIIIIIIISSIIII')
=20
processInfo =3D [0, 0, 0, 0].pack('IIII')
command << 0
=20
createProcess =3D Win32API.new("kernel32", "CreateProcess", params, 'I= ')
raise_last_win_32_error if createProcess.call(0,
command, 0, 0, 1, 0, 0, 0, startupInfo, processInfo).zero?
=20
hProcess, hThread, dwProcessId, dwThreadId =3D processInfo.unpack('LLL= L')
=20
close_handle(hProcess)
close_handle(hThread)
=20
[dwProcessId, dwThreadId]
end
=20
def write_file(hFile, buffer)
params =3D [
'L', # handle to file to write to
'P', # pointer to data to write to file
'L', # number of bytes to write
'P', # pointer to number of bytes written
'L'] # pointer to structure for overlapped I/O
=20
written =3D [0].pack('I')
writeFile =3D Win32API.new("kernel32", "WriteFile", params, 'I')
=20
raise_last_win_32_error if writeFile.call(hFile, buffer, buffer.size,
written, 0).zero?
=20
written.unpack('I')[0]
end
=20
def read_file(hFile)
params =3D [
'L', # handle of file to read
'P', # pointer to buffer that receives data
'L', # number of bytes to read
'P', # pointer to number of bytes read
'L'] #pointer to structure for data
=20
number =3D [0].pack('I')
buffer =3D ' ' * 255
=20
readFile =3D Win32API.new("kernel32", "ReadFile", params, 'I')
return '' if readFile.call(hFile, buffer, 255, number, 0).zero?
=20
buffer[0...number.unpack('I')[0]]
end
=20
def peek_named_pipe(hFile)
params =3D [
'L', # handle to pipe to copy from
'L', # pointer to data buffer
'L', # size, in bytes, of data buffer
'L', # pointer to number of bytes read
'P', # pointer to total number of bytes available
'L'] # pointer to unread bytes in this message
=20
available =3D [0].pack('I')
peekNamedPipe =3D Win32API.new("kernel32", "PeekNamedPipe", params, 'I= ')
=20
return -1 if peekNamedPipe.Call(hFile, 0, 0, 0, available, 0).zero?
=20
available.unpack('I')[0]
end
=20
class Win32popenIO
def initialize (hRead, hWrite)
@hRead =3D hRead
@hWrite =3D hWrite
end
=20
def write data
write_file(@hWrite, data.to_s)
end
=20
def read
sleep(0.01) while peek_named_pipe(@hRead).zero?
read_file(@hRead)
end
=20
def read_all
all =3D ''
while !(buffer =3D read).empty?
all << buffer
end
all
end
end
=20
def popen(command)
# create 3 pipes
child_in_r, child_in_w =3D create_pipe
child_out_r, child_out_w =3D create_pipe
child_error_r, child_error_w =3D create_pipe
=20
# Ensure the write handle to the pipe for STDIN is not inherited.
set_handle_information(child_in_w, HANDLE_FLAG_INHERIT, 0)
set_handle_information(child_out_r, HANDLE_FLAG_INHERIT, 0)
set_handle_information(child_error_r, HANDLE_FLAG_INHERIT, 0)
=20
processId, threadId =3D create_process(ENV['ComSpec'] + ' /C ' +
command, child_in_r, child_out_w, child_error_w)
=20
# we have to close the handles, so the pipes terminate with the proces= s
close_handle(child_in_r)
close_handle(child_out_w)
close_handle(child_error_w)
=20
Win32popenIO.new(child_out_r, child_in_w)
end
=20
if $0 =3D=3D __FILE__
io =3D popen('ver')
puts io.read_all
=20
io =3D popen('cmd')
io.write("ping localhost\nexit\n")
=20
while !(buffer =3D io.read).empty?
print buffer.gsub("\r", '')
end
end
-------------------------------------------------------------------------
=20
btw: i would love to have all the methods from IO but i realy don't like
to implement them all - there must be another way.
=20
cheers
=20
Simon
=20