mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
* io.c, signal.c, thread.c, thread_win32.c, include/ruby/intern.h:
suppress warnings. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@16204 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
c7451eb725
commit
87e4ad0a23
6 changed files with 26 additions and 13 deletions
|
@ -1,3 +1,8 @@
|
||||||
|
Sat Apr 26 18:36:31 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||||
|
|
||||||
|
* io.c, signal.c, thread.c, thread_win32.c, include/ruby/intern.h:
|
||||||
|
suppress warnings.
|
||||||
|
|
||||||
Sat Apr 26 17:42:30 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
Sat Apr 26 17:42:30 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||||
|
|
||||||
* error.c (builtin_types), gc.c (count_objects): added Complex and
|
* error.c (builtin_types), gc.c (count_objects): added Complex and
|
||||||
|
|
|
@ -226,7 +226,7 @@ typedef fd_set rb_fdset_t;
|
||||||
#define rb_fd_copy(d, s, n) (*(d) = *(s))
|
#define rb_fd_copy(d, s, n) (*(d) = *(s))
|
||||||
#define rb_fd_ptr(f) (f)
|
#define rb_fd_ptr(f) (f)
|
||||||
#define rb_fd_init(f) FD_ZERO(f)
|
#define rb_fd_init(f) FD_ZERO(f)
|
||||||
#define rb_fd_term(f) (f)
|
#define rb_fd_term(f) (void)(f)
|
||||||
#define rb_fd_max(f) FD_SETSIZE
|
#define rb_fd_max(f) FD_SETSIZE
|
||||||
#define rb_fd_select(n, rfds, wfds, efds, timeout) select(n, rfds, wfds, efds, timeout)
|
#define rb_fd_select(n, rfds, wfds, efds, timeout) select(n, rfds, wfds, efds, timeout)
|
||||||
|
|
||||||
|
|
3
io.c
3
io.c
|
@ -488,7 +488,10 @@ io_alloc(VALUE klass)
|
||||||
static int
|
static int
|
||||||
wsplit_p(rb_io_t *fptr)
|
wsplit_p(rb_io_t *fptr)
|
||||||
{
|
{
|
||||||
|
#if defined(HAVE_FCNTL) && defined(F_GETFL) && defined(O_NONBLOCK)
|
||||||
int r;
|
int r;
|
||||||
|
#endif
|
||||||
|
|
||||||
if (!(fptr->mode & FMODE_WSPLIT_INITIALIZED)) {
|
if (!(fptr->mode & FMODE_WSPLIT_INITIALIZED)) {
|
||||||
struct stat buf;
|
struct stat buf;
|
||||||
if (fstat(fptr->fd, &buf) == 0 &&
|
if (fstat(fptr->fd, &buf) == 0 &&
|
||||||
|
|
5
signal.c
5
signal.c
|
@ -473,12 +473,13 @@ sighandler(int sig)
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#if USE_TRAP_MASK
|
||||||
# ifdef HAVE_SIGPROCMASK
|
# ifdef HAVE_SIGPROCMASK
|
||||||
static sigset_t trap_last_mask;
|
static sigset_t trap_last_mask;
|
||||||
# else
|
# else
|
||||||
static int trap_last_mask;
|
static int trap_last_mask;
|
||||||
# endif
|
# endif
|
||||||
|
#endif
|
||||||
|
|
||||||
#if HAVE_PTHREAD_H
|
#if HAVE_PTHREAD_H
|
||||||
#include <pthread.h>
|
#include <pthread.h>
|
||||||
|
@ -961,6 +962,7 @@ install_sighandler(int signum, sighandler_t handler)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#if defined(SIGCLD) || defined(SIGCHLD)
|
||||||
static void
|
static void
|
||||||
init_sigchld(int sig)
|
init_sigchld(int sig)
|
||||||
{
|
{
|
||||||
|
@ -1001,6 +1003,7 @@ init_sigchld(int sig)
|
||||||
trap_last_mask = mask;
|
trap_last_mask = mask;
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
void
|
void
|
||||||
ruby_sig_finalize()
|
ruby_sig_finalize()
|
||||||
|
|
14
thread.c
14
thread.c
|
@ -1811,7 +1811,7 @@ do_select(int n, fd_set *read, fd_set *write, fd_set *except,
|
||||||
fd_set orig_read, orig_write, orig_except;
|
fd_set orig_read, orig_write, orig_except;
|
||||||
|
|
||||||
#ifndef linux
|
#ifndef linux
|
||||||
double limit;
|
double limit = 0;
|
||||||
struct timeval wait_rest;
|
struct timeval wait_rest;
|
||||||
|
|
||||||
if (timeout) {
|
if (timeout) {
|
||||||
|
@ -1862,11 +1862,11 @@ do_select(int n, fd_set *read, fd_set *write, fd_set *except,
|
||||||
errno = lerrno;
|
errno = lerrno;
|
||||||
|
|
||||||
if (result < 0) {
|
if (result < 0) {
|
||||||
if (errno == EINTR
|
switch (errno) {
|
||||||
|
case EINTR:
|
||||||
#ifdef ERESTART
|
#ifdef ERESTART
|
||||||
|| errno == ERESTART
|
case ERESTART:
|
||||||
#endif
|
#endif
|
||||||
) {
|
|
||||||
if (read) *read = orig_read;
|
if (read) *read = orig_read;
|
||||||
if (write) *write = orig_write;
|
if (write) *write = orig_write;
|
||||||
if (except) *except = orig_except;
|
if (except) *except = orig_except;
|
||||||
|
@ -1881,6 +1881,8 @@ do_select(int n, fd_set *read, fd_set *write, fd_set *except,
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
goto retry;
|
goto retry;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return result;
|
return result;
|
||||||
|
@ -1985,8 +1987,8 @@ timer_thread_function(void)
|
||||||
/* check signal */
|
/* check signal */
|
||||||
if (vm->buffered_signal_size && vm->main_thread->exec_signal == 0) {
|
if (vm->buffered_signal_size && vm->main_thread->exec_signal == 0) {
|
||||||
vm->main_thread->exec_signal = rb_get_next_signal(vm);
|
vm->main_thread->exec_signal = rb_get_next_signal(vm);
|
||||||
thread_debug("buffered_signal_size: %d, sig: %d\n",
|
thread_debug("buffered_signal_size: %ld, sig: %d\n",
|
||||||
vm->buffered_signal_size, vm->main_thread->exec_signal);
|
(long)vm->buffered_signal_size, vm->main_thread->exec_signal);
|
||||||
rb_thread_interrupt(vm->main_thread);
|
rb_thread_interrupt(vm->main_thread);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -73,7 +73,7 @@ w32_error(void)
|
||||||
GetLastError(),
|
GetLastError(),
|
||||||
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
|
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
|
||||||
(LPTSTR) & lpMsgBuf, 0, NULL);
|
(LPTSTR) & lpMsgBuf, 0, NULL);
|
||||||
rb_bug("%s", lpMsgBuf);
|
rb_bug("%s", (char*)lpMsgBuf);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
@ -116,7 +116,7 @@ w32_wait_events(HANDLE *events, int count, DWORD timeout, rb_thread_t *th)
|
||||||
|
|
||||||
thread_debug(" WaitForMultipleObjects start (count: %d)\n", count);
|
thread_debug(" WaitForMultipleObjects start (count: %d)\n", count);
|
||||||
ret = WaitForMultipleObjects(count, targets, FALSE, timeout);
|
ret = WaitForMultipleObjects(count, targets, FALSE, timeout);
|
||||||
thread_debug(" WaitForMultipleObjects end (ret: %d)\n", ret);
|
thread_debug(" WaitForMultipleObjects end (ret: %lu)\n", ret);
|
||||||
|
|
||||||
if (ret == WAIT_OBJECT_0 + count - 1 && th) {
|
if (ret == WAIT_OBJECT_0 + count - 1 && th) {
|
||||||
errno = EINTR;
|
errno = EINTR;
|
||||||
|
@ -227,9 +227,9 @@ native_sleep(rb_thread_t *th, struct timeval *tv)
|
||||||
/* interrupted. return immediate */
|
/* interrupted. return immediate */
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
thread_debug("native_sleep start (%d)\n", (int)msec);
|
thread_debug("native_sleep start (%lu)\n", msec);
|
||||||
ret = w32_wait_events(0, 0, msec, th);
|
ret = w32_wait_events(0, 0, msec, th);
|
||||||
thread_debug("native_sleep done (%d)\n", ret);
|
thread_debug("native_sleep done (%lu)\n", ret);
|
||||||
}
|
}
|
||||||
|
|
||||||
th->unblock_function = 0;
|
th->unblock_function = 0;
|
||||||
|
@ -393,7 +393,7 @@ native_cond_wait(rb_thread_cond_t *cond, rb_thread_lock_t *mutex)
|
||||||
{
|
{
|
||||||
r = WaitForSingleObject(entry.event, INFINITE);
|
r = WaitForSingleObject(entry.event, INFINITE);
|
||||||
if (r != WAIT_OBJECT_0) {
|
if (r != WAIT_OBJECT_0) {
|
||||||
rb_bug("native_cond_wait: WaitForSingleObject returns %d", r);
|
rb_bug("native_cond_wait: WaitForSingleObject returns %lu", r);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
native_mutex_lock(mutex);
|
native_mutex_lock(mutex);
|
||||||
|
|
Loading…
Add table
Reference in a new issue