nobu	2008-07-05 22:22:29 +0900 (Sat, 05 Jul 2008)

  New Revision: 17892

  Modified files:
    trunk/ChangeLog
    trunk/thread.c
    trunk/thread_pthread.c
    trunk/thread_win32.c

  Log:
    * thread.c (thread_initialize): NUM2INT() returns int.
    
    * thread.c (timer_thread_function), thread_pthread.c (thread_timer),
      thread_win32.c (timer_thread_func), thread_{pthread,win32}.c
      (rb_thread_create_timer_thread): passing VM.


  http://svn.ruby-lang.org/cgi-bin/viewvc.cgi?view=rev&revision=17892

Index: thread_win32.c
===================================================================
--- thread_win32.c	(revision 17891)
+++ thread_win32.c	(revision 17892)
@@ -537,8 +537,6 @@
     w32_set_event(th->native_thread_data.interrupt_event);
 }
 
-static void timer_thread_function(void);
-
 static HANDLE timer_thread_id = 0;
 
 static unsigned long _stdcall
@@ -547,7 +545,7 @@
     thread_debug("timer_thread\n");
     while (system_working) {
 	Sleep(WIN32_WAIT_TIMEOUT);
-	timer_thread_function();
+	timer_thread_function(dummy);
     }
     thread_debug("timer killed\n");
     return 0;
@@ -557,7 +555,7 @@
 rb_thread_create_timer_thread(void)
 {
     if (timer_thread_id == 0) {
-	timer_thread_id = w32_create_thread(1024, timer_thread_func, 0);
+	timer_thread_id = w32_create_thread(1024, timer_thread_func, GET_VM());
 	w32_resume_thread(timer_thread_id);
     }
 }
Index: ChangeLog
===================================================================
--- ChangeLog	(revision 17891)
+++ ChangeLog	(revision 17892)
@@ -1,3 +1,11 @@
+Sat Jul  5 22:22:27 2008  Nobuyoshi Nakada  <nobu@r...>
+
+	* thread.c (thread_initialize): NUM2INT() returns int.
+
+	* thread.c (timer_thread_function), thread_pthread.c (thread_timer),
+	  thread_win32.c (timer_thread_func), thread_{pthread,win32}.c
+	  (rb_thread_create_timer_thread): passing VM.
+
 Sat Jul  5 20:53:18 2008  Masaki Suketa  <masaki.suketa@n...>
 
 	* test/win32ole/test_word.rb: check word installed.
Index: thread_pthread.c
===================================================================
--- thread_pthread.c	(revision 17891)
+++ thread_pthread.c	(revision 17892)
@@ -641,7 +641,6 @@
 }
 
 static pthread_t timer_thread_id;
-static void timer_thread_function(void);
 
 static void *
 thread_timer(void *dummy)
@@ -670,7 +669,7 @@
 	    });
 	}
 #endif
-	timer_thread_function();
+	timer_thread_function(dummy);
     }
     return NULL;
 }
@@ -688,7 +687,7 @@
 #ifdef PTHREAD_STACK_MIN
 	pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN);
 #endif
-	err = pthread_create(&timer_thread_id, &attr, thread_timer, 0);
+	err = pthread_create(&timer_thread_id, &attr, thread_timer, GET_VM());
 	if (err != 0) {
 	    rb_bug("rb_thread_create_timer_thread: return non-zero (%d)", err);
 	}
Index: thread.c
===================================================================
--- thread.c	(revision 17891)
+++ thread.c	(revision 17892)
@@ -151,6 +151,7 @@
 #endif
 NOINLINE(static int thread_start_func_2(rb_thread_t *th, VALUE *stack_start,
 					VALUE *register_stack_start));
+static void timer_thread_function(void *);
 
 #if   defined(_WIN32)
 #include "thread_win32.c"
@@ -490,7 +491,7 @@
 	    rb_raise(rb_eThreadError, "already initialized thread - %s",
 		     file);
 	}
-        rb_raise(rb_eThreadError, "already initialized thread - %s:%ld",
+        rb_raise(rb_eThreadError, "already initialized thread - %s:%d",
                  file, NUM2INT(line));
     }
     return thread_create_core(thread, args, 0);
@@ -2050,9 +2051,9 @@
 int rb_get_next_signal(rb_vm_t *vm);
 
 static void
-timer_thread_function(void)
+timer_thread_function(void *arg)
 {
-    rb_vm_t *vm = GET_VM(); /* TODO: fix me for Multi-VM */
+    rb_vm_t *vm = arg; /* TODO: fix me for Multi-VM */
 
     /* for time slice */
     RUBY_VM_SET_TIMER_INTERRUPT(vm->running_thread);

--
ML: ruby-changes@q...
Info: http://www.atdot.net/~ko1/quickml/