=begin
Hi,
2009/2/20 Yusuke ENDOH mame@tsg.ne.jp:
HI,
2009/2/20 Chris Schlaeger redmine@ruby-lang.org:
I've tried to run taskjuggler with ruby 1.9 CVS from today and got internal error messages. The applications runs fine with ruby 1.8.7. I tried to cut it down to a smaller test case, but it seems like you need the full app to trigger the problem. When run in uniprocessor mode, it works fine even with 1.9. But when running in SMP mode (-c 2 or larger number) it multithreads and forks to run on muliple CPUs. The problem seems to be thread related as the error message indicates. The locations in the ruby code seem to be random and change with every run. Here are the steps to reproduce the problem:
- Download the taskjuggler gem: http://www.taskjuggler.org/tj3/taskjuggler-0.0.1.gem and install it
- change to the 'examples' that comes with the gem or download acso.tjp from http://www.taskjuggler.org/tj3/examples/acso.tjp
- tj3 -c 2 acso.tjp
Thank you for your detailed report!
I confirmed the issue. I'll try to tackle it tonight.
The following patch should fix the issue. Could you try?
Index: bootstraptest/test_thread.rb¶
--- bootstraptest/test_thread.rb (revision 22466)
+++ bootstraptest/test_thread.rb (working copy)
@@ -216,6 +216,18 @@
end
}
+assert_equal 'ok', %{
- open("zzz.rb", "w") do |f|
- f.puts <<-END
-
Thread.new { fork { GC.start } }.join
-
pid, status = Process.wait2
-
$result = status.success? ? :ok : :ng
- END
- end
- require "zzz.rb"
- $result
+}
-
assert_finish 3, %{
th = Thread.new {sleep 2}
th.join(1)
Index: thread.c
--- thread.c (revision 22466)
+++ thread.c (working copy)
@@ -291,7 +291,7 @@
struct rb_mutex_struct *next_mutex;
} mutex_t;
-static void rb_mutex_unlock_all(mutex_t *mutex);
+static void rb_mutex_unlock_all(mutex_t *mutex, rb_thread_t *th);
void
rb_thread_terminate_all(void)
@@ -305,7 +305,7 @@
/* unlock all locking mutexes */
if (th->keeping_mutexes) {
- rb_mutex_unlock_all(th->keeping_mutexes);
-
rb_mutex_unlock_all(th->keeping_mutexes, GET_THREAD());
}
thread_debug("rb_thread_terminate_all (main thread: %p)\n", (void *)th);
@@ -339,6 +339,12 @@
thread_cleanup_func(void *th_ptr)
{
rb_thread_t *th = th_ptr;
-
-
/* unlock all locking mutexes */
-
if (th->keeping_mutexes) {
-
rb_mutex_unlock_all(th->keeping_mutexes, th);
-
th->keeping_mutexes = NULL;
-
}
thread_cleanup_func_before_exec(th_ptr);
native_thread_destroy(th);
}
@@ -434,12 +440,6 @@
(void *)th, th->locking_mutex);
}
-
/* unlock all locking mutexes */
-
if (th->keeping_mutexes) {
-
rb_mutex_unlock_all(th->keeping_mutexes);
-
th->keeping_mutexes = NULL;
-
}
-
/* delete self other than main thread from living_threads */
if (th != main_th) {
st_delete_wrap(th->vm->living_threads, th->self);
@@ -457,7 +457,6 @@
}
join_th = join_th->join_list_next;
}
-
if (th != main_th) rb_check_deadlock(th->vm);
if (!th->root_fiber) {
rb_thread_recycle_stack_release(th->stack);
@@ -465,6 +464,7 @@
}
}
thread_cleanup_func(th);
- if (th != main_th) rb_check_deadlock(th->vm);
if (th->vm->main_thread == th) {
ruby_cleanup(state);
}
@@ -3146,7 +3146,7 @@
}
static void
-rb_mutex_unlock_all(mutex_t *mutexes)
+rb_mutex_unlock_all(mutex_t *mutexes, rb_thread_t *th)
{
const char *err;
mutex_t mutex;
@@ -3156,7 +3156,7 @@
/ rb_warn("mutex #<%p> remains to be locked by terminated thread",
mutexes); */
mutexes = mutex->next_mutex;
- err = mutex_unlock(mutex, GET_THREAD());
- err = mutex_unlock(mutex, th);
if (err) rb_bug("invalid keeping_mutexes: %s", err);
}
}
--
Yusuke ENDOH mame@tsg.ne.jp
=end
Updated by 
Updated by 
Updated by 
Updated by