[ruby-dev:21906] Re: pthread trouble on tcltklib

On Wed, 12 Nov 2003 11:20:18 +0900
In article <[e-mail]>
[[ruby-dev:21903] Re: pthread trouble on tcltklib]
Tietew <[e-mail]> wrote:

> > > この部分ですが、rb_thread_schedule()への再入だけではなく、別の
> > > pthread内でのrubyスレッドの切替え自体が危険じゃないでしょうか。
> > > そう考えると、ロックじゃなくて最初にスレッドIDを保存しておいて、
> > > 単純に現在のスレッドと一致しなかったら戻る、だけでもよさそうな
> > > 気がして来ました。

チェック版パッチ作ってみました。

Index: eval.c
===================================================================
RCS file: /src/ruby/eval.c,v
retrieving revision 1.579
diff -p -u -2 -r1.579 eval.c
--- eval.c	29 Oct 2003 17:47:17 -0000	1.579
+++ eval.c	12 Nov 2003 02:49:32 -0000
@@ -8624,4 +8624,5 @@ rb_thread_schedule()
     int select_timeout = 0;

+    THREAD_CHECK;
     rb_thread_pending = 0;
     if (curr_thread == curr_thread->next
Index: gc.c
===================================================================
RCS file: /src/ruby/gc.c,v
retrieving revision 1.160
diff -p -u -2 -r1.160 gc.c
--- gc.c        20 Oct 2003 02:06:39 -0000      1.160
+++ gc.c        12 Nov 2003 02:49:33 -0000
@@ -1217,4 +1217,5 @@ rb_gc()
     SET_STACK_END;

+    THREAD_CHECK;
     if (dont_gc || during_gc) {
 	if (!freelist) {
@@ -1317,4 +1318,14 @@ rb_gc_start()
 }

+#ifdef HAVE_NATIVETHREAD
+static rb_nativethread_t ruby_thid;
+void
+rb_thread_check()
+{
+    if (!ruby_thid || ruby_thid != NATIVETHREAD_CURRENT())
+	rb_bug("cross-thread violation.");
+}
+#endif
+
 void
 Init_stack(addr)
@@ -1354,4 +1365,8 @@ Init_stack(addr)
 	STACK_LEVEL_MAX = IA64_MAGIC_STACK_LIMIT;
 #endif
+#endif
+#ifdef HAVE_NATIVETHREAD
+    if (ruby_thid) rb_thread_check();
+    else ruby_thid = NATIVETHREAD_CURRENT();
 #endif
 }
Index: ruby.h
===================================================================
RCS file: /src/ruby/ruby.h,v
retrieving revision 1.90
diff -p -u -2 -r1.90 ruby.h
--- ruby.h      14 Oct 2003 02:53:53 -0000      1.90
+++ ruby.h      12 Nov 2003 02:49:33 -0000
@@ -672,4 +672,20 @@ static char *dln_libs_to_be_linked[] = {
 #endif

+#if defined(HAVE_LIBPTHREAD)
+typedef pthread_t rb_nativethread_t;
+# define NATIVETHREAD_CURRENT() pthread_self()
+# define HAVE_NATIVETHREAD
+#elif defined(_WIN32) || defined(__CYGWIN__)
+typedef DWORD rb_nativethread_t;
+# define NATIVETHREAD_CURRENT() GetCurrentThreadId()
+# define HAVE_NATIVETHREAD
+#endif
+#ifdef HAVE_NATIVETHREAD
+extern void rb_thread_check _(());
+# define THREAD_CHECK rb_thread_check()
+#else
+# define THREAD_CHECK
+#endif
+
 #if defined(__cplusplus)
 }  /* extern "C" { */


—[ Tietew ]——————————————————————————
 メ : [e-mail] / [e-mail] / [e-mail]
ホペ: http://www.tietew.net/     Tietew Windows Lab.
      http://www.masuclub.net/   鱒倶楽部
指紋: 26CB 71BB B595 09C4 0153  81C4 773C 963A D51B 8CAA