summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--ChangeLog5
-rw-r--r--thread.c17
2 files changed, 17 insertions, 5 deletions
diff --git a/ChangeLog b/ChangeLog
index 50b31c1582..1398ae564a 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+Tue Nov 27 08:04:26 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
+
+ * thread.c (rb_thread_terminate_all): broadcast eTerminateSignal
+ again when Ctrl-C was pressed. [Feature #1952] [ruby-dev:39107]
+
Tue Nov 27 07:58:03 2012 Koichi Sasada <ko1@atdot.net>
* vm_core.h: add members to rb_trace_arg_t:
diff --git a/thread.c b/thread.c
index ed8d429ef8..e74cf6d14a 100644
--- a/thread.c
+++ b/thread.c
@@ -378,20 +378,27 @@ rb_thread_terminate_all(void)
/* unlock all locking mutexes */
rb_threadptr_unlock_all_locking_mutexes(th);
+
+ vm->inhibit_thread_creation = 1;
+
+ retry:
thread_debug("rb_thread_terminate_all (main thread: %p)\n", (void *)th);
st_foreach(vm->living_threads, terminate_i, (st_data_t)th);
- vm->inhibit_thread_creation = 1;
while (!rb_thread_alone()) {
+ int state;
+
PUSH_TAG();
- if (EXEC_TAG() == 0) {
+ if ((state = EXEC_TAG()) == 0) {
native_sleep(th, 0);
RUBY_VM_CHECK_INTS_BLOCKING(th);
}
- else {
- /* ignore exception */
- }
POP_TAG();
+
+ /* broadcast eTerminateSignal again if Ctrl-C was pressed. */
+ if (state && rb_obj_is_kind_of(GET_THREAD()->errinfo, rb_eInterrupt)) {
+ goto retry;
+ }
}
}