mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
5007c34619
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@17069 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
126 lines
2.6 KiB
C
126 lines
2.6 KiB
C
/**********************************************************************
|
|
|
|
io/wait.c -
|
|
|
|
$Author$
|
|
$Date$
|
|
created at: Tue Aug 28 09:08:06 JST 2001
|
|
|
|
All the files in this distribution are covered under the Ruby's
|
|
license (see the file COPYING).
|
|
|
|
**********************************************************************/
|
|
|
|
#include "ruby.h"
|
|
#include "rubyio.h"
|
|
|
|
#include <sys/types.h>
|
|
#if defined(FIONREAD_HEADER)
|
|
#include FIONREAD_HEADER
|
|
#endif
|
|
|
|
#ifdef HAVE_RB_W32_IOCTLSOCKET
|
|
#define ioctl ioctlsocket
|
|
#define ioctl_arg u_long
|
|
#define ioctl_arg2num(i) ULONG2NUM(i)
|
|
#else
|
|
#define ioctl_arg int
|
|
#define ioctl_arg2num(i) INT2NUM(i)
|
|
#endif
|
|
|
|
#ifdef HAVE_RB_W32_IS_SOCKET
|
|
#define FIONREAD_POSSIBLE_P(fd) rb_w32_is_socket(fd)
|
|
#else
|
|
#define FIONREAD_POSSIBLE_P(fd) ((void)(fd),Qtrue)
|
|
#endif
|
|
|
|
static VALUE io_ready_p _((VALUE io));
|
|
static VALUE io_wait _((int argc, VALUE *argv, VALUE io));
|
|
void Init_wait _((void));
|
|
|
|
EXTERN struct timeval rb_time_interval _((VALUE time));
|
|
|
|
/*
|
|
=begin
|
|
= IO wait methods.
|
|
=end
|
|
*/
|
|
|
|
/*
|
|
=begin
|
|
--- IO#ready?
|
|
returns non-nil if input available without blocking, or nil.
|
|
=end
|
|
*/
|
|
static VALUE
|
|
io_ready_p(io)
|
|
VALUE io;
|
|
{
|
|
rb_io_t *fptr;
|
|
FILE *fp;
|
|
ioctl_arg n;
|
|
|
|
GetOpenFile(io, fptr);
|
|
rb_io_check_readable(fptr);
|
|
if (!FIONREAD_POSSIBLE_P(fileno(fptr->f))) return Qfalse;
|
|
fp = fptr->f;
|
|
if (feof(fp)) return Qfalse;
|
|
if (rb_read_pending(fp)) return Qtrue;
|
|
if (ioctl(fileno(fp), FIONREAD, &n)) rb_sys_fail(0);
|
|
if (n > 0) return ioctl_arg2num(n);
|
|
return Qnil;
|
|
}
|
|
|
|
/*
|
|
=begin
|
|
--- IO#wait([timeout])
|
|
waits until input available or timed out and returns self, or nil
|
|
when EOF reached.
|
|
=end
|
|
*/
|
|
static VALUE
|
|
io_wait(argc, argv, io)
|
|
int argc;
|
|
VALUE *argv;
|
|
VALUE io;
|
|
{
|
|
rb_io_t *fptr;
|
|
fd_set rd;
|
|
FILE *fp;
|
|
int fd;
|
|
ioctl_arg n;
|
|
VALUE timeout;
|
|
struct timeval *tp, timerec;
|
|
|
|
GetOpenFile(io, fptr);
|
|
rb_io_check_readable(fptr);
|
|
rb_scan_args(argc, argv, "01", &timeout);
|
|
if (NIL_P(timeout)) {
|
|
tp = 0;
|
|
}
|
|
else {
|
|
timerec = rb_time_interval(timeout);
|
|
tp = &timerec;
|
|
}
|
|
|
|
fp = fptr->f;
|
|
if (feof(fp)) return Qfalse;
|
|
if (rb_read_pending(fp)) return Qtrue;
|
|
fd = fileno(fp);
|
|
FD_ZERO(&rd);
|
|
FD_SET(fd, &rd);
|
|
if (rb_thread_select(fd + 1, &rd, NULL, NULL, tp) < 0)
|
|
rb_sys_fail(0);
|
|
rb_io_check_closed(fptr);
|
|
if (!FIONREAD_POSSIBLE_P(fileno(fptr->f))) return Qfalse;
|
|
if (ioctl(fileno(fp), FIONREAD, &n)) rb_sys_fail(0);
|
|
if (n > 0) return io;
|
|
return Qnil;
|
|
}
|
|
|
|
void
|
|
Init_wait()
|
|
{
|
|
rb_define_method(rb_cIO, "ready?", io_ready_p, 0);
|
|
rb_define_method(rb_cIO, "wait", io_wait, -1);
|
|
}
|