summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--ChangeLog7
-rw-r--r--thread_win32.c11
-rw-r--r--win32/win32.c1
3 files changed, 19 insertions, 0 deletions
diff --git a/ChangeLog b/ChangeLog
index e4b0c06b4..f32417811 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,10 @@
+Tue Jul 15 18:12:02 2008 NAKAMURA Usaku <usa@ruby-lang.org>
+
+ * thread_win32.c (ubf_handle): cancel blocking IO if it can (only
+ Vista). see [ruby-dev:35446]
+
+ * win32/win32.c (errmap): add ERROR_OPERATION_ABORTED as EINTR.
+
Mon Jul 14 20:35:21 2008 Masaki Suketa <masaki.suketa@nifty.ne.jp>
* test/win32ole/test_win32ole_event.rb (teardown): fix typo.
diff --git a/thread_win32.c b/thread_win32.c
index a810fb362..7c31a3f70 100644
--- a/thread_win32.c
+++ b/thread_win32.c
@@ -532,8 +532,19 @@ native_thread_apply_priority(rb_thread_t *th)
static void
ubf_handle(void *ptr)
{
+ static int checked = 0;
+ typedef BOOL (WINAPI *cancel_io_func_t)(HANDLE);
+ static cancel_io_func_t cancel_func = NULL;
rb_thread_t *th = (rb_thread_t *)ptr;
thread_debug("ubf_handle: %p\n", th);
+
+ if (!checked) {
+ cancel_func = (cancel_io_func_t)GetProcAddress(GetModuleHandle("kernel32"), "CancelSynchronousIo");
+ checked = 1;
+ }
+ if (cancel_func)
+ cancel_func((HANDLE)th->thread_id);
+
w32_set_event(th->native_thread_data.interrupt_event);
}
diff --git a/win32/win32.c b/win32/win32.c
index 11774cda1..b1e461649 100644
--- a/win32/win32.c
+++ b/win32/win32.c
@@ -164,6 +164,7 @@ static struct {
{ ERROR_PIPE_BUSY, EAGAIN },
{ ERROR_NO_DATA, EPIPE },
{ ERROR_PIPE_NOT_CONNECTED, EPIPE },
+ { ERROR_OPERATION_ABORTED, EINTR },
{ ERROR_NOT_ENOUGH_QUOTA, ENOMEM },
{ WSAENAMETOOLONG, ENAMETOOLONG },
{ WSAENOTEMPTY, ENOTEMPTY },