2003-09-16 21:37:34 +04:00
|
|
|
# open3.rb: Spawn a program like popen, but with stderr, too. You might also
|
|
|
|
# want to use this if you want to bypass the shell. (By passing multiple args,
|
2003-09-18 17:43:42 +04:00
|
|
|
# which IO#popen does not allow)
|
2003-09-16 21:37:34 +04:00
|
|
|
#
|
1999-08-13 09:45:20 +04:00
|
|
|
# Usage:
|
|
|
|
# require "open3"
|
|
|
|
#
|
2003-09-16 21:37:34 +04:00
|
|
|
# stdin, stdout, stderr = Open3.popen3('nroff -man')
|
1999-08-13 09:45:20 +04:00
|
|
|
# or
|
|
|
|
# include Open3
|
2003-09-16 21:37:34 +04:00
|
|
|
# stdin, stdout, stderr = popen3('nroff -man')
|
2004-12-15 19:01:11 +03:00
|
|
|
#
|
|
|
|
# popen3 can also take a block which will receive stdin, stdout and stderr
|
|
|
|
# as parameters. This ensures stdin, stdout and stderr are closed once
|
|
|
|
# the block exits.
|
|
|
|
#
|
|
|
|
# Such as
|
|
|
|
# Open3.popen3('nroff -man') { |stdin, stdout, stderr| ... }
|
1999-08-13 09:45:20 +04:00
|
|
|
|
|
|
|
module Open3
|
|
|
|
#[stdin, stdout, stderr] = popen3(command);
|
2000-10-25 08:48:41 +04:00
|
|
|
def popen3(*cmd)
|
1999-08-13 09:45:20 +04:00
|
|
|
pw = IO::pipe # pipe[0] for read, pipe[1] for write
|
|
|
|
pr = IO::pipe
|
|
|
|
pe = IO::pipe
|
|
|
|
|
2000-10-20 20:37:01 +04:00
|
|
|
pid = fork{
|
|
|
|
# child
|
2000-10-25 08:48:41 +04:00
|
|
|
fork{
|
|
|
|
# grandchild
|
|
|
|
pw[1].close
|
|
|
|
STDIN.reopen(pw[0])
|
|
|
|
pw[0].close
|
1999-08-13 09:45:20 +04:00
|
|
|
|
2000-10-25 08:48:41 +04:00
|
|
|
pr[0].close
|
|
|
|
STDOUT.reopen(pr[1])
|
|
|
|
pr[1].close
|
1999-08-13 09:45:20 +04:00
|
|
|
|
2000-10-25 08:48:41 +04:00
|
|
|
pe[0].close
|
|
|
|
STDERR.reopen(pe[1])
|
|
|
|
pe[1].close
|
1999-08-13 09:45:20 +04:00
|
|
|
|
2000-10-25 08:48:41 +04:00
|
|
|
exec(*cmd)
|
|
|
|
}
|
* array.c: replace rb_protect_inspect() and rb_inspecting_p() by
rb_exec_recursive() in eval.c.
* eval.c (rb_exec_recursive): new function.
* array.c (rb_ary_join): use rb_exec_recursive().
* array.c (rb_ary_inspect, rb_ary_hash): ditto.
* file.c (rb_file_join): ditto.
* hash.c (rb_hash_inspect, rb_hash_to_s, rb_hash_hash): ditto.
* io.c (rb_io_puts): ditto.
* object.c (rb_obj_inspect): ditto
* struct.c (rb_struct_inspect): ditto.
* lib/set.rb (SortedSet::setup): a hack to shut up warning.
[ruby-talk:132866]
* lib/time.rb (Time::strptime): add new function. inspired by
[ruby-talk:132815].
* lib/parsedate.rb (ParseDate::strptime): ditto.
* regparse.c: move st_*_strend() functions from st.c. fixed some
potential memory leaks.
* exception error messages updated. [ruby-core:04497]
* ext/socket/socket.c (Init_socket): add bunch of Socket
constants. Patch from Sam Roberts <sroberts@uniserve.com>.
[ruby-core:04409]
* array.c (rb_ary_s_create): no need for negative argc check.
[ruby-core:04463]
* array.c (rb_ary_unshift_m): ditto.
* lib/xmlrpc/parser.rb (XMLRPC::FaultException): make it subclass
of StandardError class, not Exception class. [ruby-core:04429]
* parse.y (fcall_gen): lvar(arg) will be evaluated as
lvar.call(arg) when lvar is a defined local variable. [new]
* object.c (rb_class_initialize): call inherited method before
calling initializing block.
* eval.c (rb_thread_start_1): initialize newly pushed frame.
* lib/open3.rb (Open3::popen3): $? should not be EXIT_FAILURE.
fixed: [ruby-core:04444]
* eval.c (is_defined): NODE_IASGN is an assignment.
* ext/readline/readline.c (Readline.readline): use rl_outstream
and rl_instream. [ruby-dev:25699]
* ext/etc/etc.c (Init_etc): sGroup needs HAVE_ST_GR_PASSWD check
[ruby-dev:25675]
* misc/ruby-mode.el: [ruby-core:04415]
* lib/rdoc/generators/html_generator.rb: [ruby-core:04412]
* lib/rdoc/generators/ri_generator.rb: ditto.
* struct.c (make_struct): fixed: [ruby-core:04402]
* ext/curses/curses.c (window_color_set): [ruby-core:04393]
* ext/socket/socket.c (Init_socket): SO_REUSEPORT added.
[ruby-talk:130092]
* object.c: [ruby-doc:818]
* parse.y (open_args): fix too verbose warnings for the space
before argument parentheses. [ruby-dev:25492]
* parse.y (parser_yylex): ditto.
* parse.y (parser_yylex): the first expression in the parentheses
should not be a command. [ruby-dev:25492]
* lib/irb/context.rb (IRB::Context::initialize): [ruby-core:04330]
* object.c (Init_Object): remove Object#type. [ruby-core:04335]
* st.c (st_foreach): report success/failure by return value.
[ruby-Bugs-1396]
* parse.y: forgot to initialize parser struct. [ruby-dev:25492]
* parse.y (parser_yylex): no tLABEL on EXPR_BEG.
[ruby-talk:127711]
* document updates - [ruby-core:04296], [ruby-core:04301],
[ruby-core:04302], [ruby-core:04307]
* dir.c (rb_push_glob): should work for NUL delimited patterns.
* dir.c (rb_glob2): should aware of offset in the pattern.
* string.c (rb_str_new4): should propagate taintedness.
* env.h: rename member names in struct FRAME; last_func -> callee,
orig_func -> this_func, last_class -> this_class.
* struct.c (rb_struct_set): use original method name, not callee
name, to retrieve member slot. [ruby-core:04268]
* time.c (time_strftime): protect from format modification from GC
finalizers.
* object.c (Init_Object): remove rb_obj_id_obsolete()
* eval.c (rb_mod_define_method): incomplete subclass check.
[ruby-dev:25464]
* gc.c (rb_data_object_alloc): klass may be NULL.
[ruby-list:40498]
* bignum.c (rb_big_rand): should return positive random number.
[ruby-dev:25401]
* bignum.c (rb_big_rand): do not use rb_big_modulo to generate
random bignums. [ruby-dev:25396]
* variable.c (rb_autoload): [ruby-dev:25373]
* eval.c (svalue_to_avalue): [ruby-dev:25366]
* string.c (rb_str_justify): [ruby-dev:25367]
* io.c (rb_f_select): [ruby-dev:25312]
* ext/socket/socket.c (sock_s_getservbyport): [ruby-talk:124072]
* struct.c (make_struct): [ruby-dev:25249]
* dir.c (dir_open_dir): new function. [ruby-dev:25242]
* io.c (rb_f_open): add type check for return value from to_open.
* lib/pstore.rb (PStore#transaction): Use the empty content when a
file is not found. [ruby-dev:24561]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@8068 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2005-03-04 09:47:45 +03:00
|
|
|
exit!(0)
|
2000-10-20 20:37:01 +04:00
|
|
|
}
|
|
|
|
|
|
|
|
pw[0].close
|
|
|
|
pr[1].close
|
|
|
|
pe[1].close
|
2000-10-25 08:48:41 +04:00
|
|
|
Process.waitpid(pid)
|
|
|
|
pi = [pw[1], pr[0], pe[0]]
|
2002-01-29 10:16:09 +03:00
|
|
|
pw[1].sync = true
|
2000-10-20 20:37:01 +04:00
|
|
|
if defined? yield
|
2000-10-25 08:48:41 +04:00
|
|
|
begin
|
2000-11-08 08:29:37 +03:00
|
|
|
return yield(*pi)
|
2000-10-25 08:48:41 +04:00
|
|
|
ensure
|
|
|
|
pi.each{|p| p.close unless p.closed?}
|
|
|
|
end
|
1999-08-13 09:45:20 +04:00
|
|
|
end
|
2000-10-20 20:37:01 +04:00
|
|
|
pi
|
1999-08-13 09:45:20 +04:00
|
|
|
end
|
|
|
|
module_function :popen3
|
|
|
|
end
|
|
|
|
|
|
|
|
if $0 == __FILE__
|
|
|
|
a = Open3.popen3("nroff -man")
|
|
|
|
Thread.start do
|
2000-02-25 06:51:23 +03:00
|
|
|
while line = gets
|
|
|
|
a[0].print line
|
1999-08-13 09:45:20 +04:00
|
|
|
end
|
|
|
|
a[0].close
|
|
|
|
end
|
2000-02-25 06:51:23 +03:00
|
|
|
while line = a[1].gets
|
|
|
|
print ":", line
|
1999-08-13 09:45:20 +04:00
|
|
|
end
|
|
|
|
end
|