aboutsummaryrefslogtreecommitdiffstats
path: root/thread.c
diff options
context:
space:
mode:
authornobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2016-04-15 12:12:25 +0000
committernobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2016-04-15 12:12:25 +0000
commitf7d0059e3643ad1713b8abe4969147e2bc185d75 (patch)
treeb65f21bbab7fbc8f4a291beb7950ab1a412cce53 /thread.c
parent589169cb78ca8dfaaa3d9cacf71dc34bd81265f2 (diff)
downloadruby-f7d0059e3643ad1713b8abe4969147e2bc185d75.tar.gz
thread.c: must be initialized to set name
* thread.c (get_initialized_threadptr): extract ensuring that the thread is initialized. * thread.c (rb_thread_setname): thread must be initialized to set the name. [ruby-core:74963] [Bug #12290] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@54598 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'thread.c')
-rw-r--r--thread.c24
1 files changed, 15 insertions, 9 deletions
diff --git a/thread.c b/thread.c
index e3efcd3946..e8c7e606d8 100644
--- a/thread.c
+++ b/thread.c
@@ -711,6 +711,18 @@ thread_create_core(VALUE thval, VALUE args, VALUE (*fn)(ANYARGS))
return thval;
}
+static rb_thread_t *
+get_initialized_threadptr(VALUE thread, VALUE klass)
+{
+ rb_thread_t *th;
+ GetThreadPtr(thread, th);
+ if (!th->first_args) {
+ rb_raise(rb_eThreadError, "uninitialized thread - check `%"PRIsVALUE"#initialize'",
+ klass);
+ }
+ return th;
+}
+
/*
* call-seq:
* Thread.new { ... } -> thread
@@ -734,18 +746,13 @@ thread_create_core(VALUE thval, VALUE args, VALUE (*fn)(ANYARGS))
static VALUE
thread_s_new(int argc, VALUE *argv, VALUE klass)
{
- rb_thread_t *th;
VALUE thread = rb_thread_alloc(klass);
if (GET_VM()->main_thread->status == THREAD_KILLED)
rb_raise(rb_eThreadError, "can't alloc thread");
rb_obj_call_init(thread, argc, argv);
- GetThreadPtr(thread, th);
- if (!th->first_args) {
- rb_raise(rb_eThreadError, "uninitialized thread - check `%"PRIsVALUE"#initialize'",
- klass);
- }
+ get_initialized_threadptr(thread, klass);
return thread;
}
@@ -2790,8 +2797,7 @@ rb_thread_setname(VALUE thread, VALUE name)
#ifdef SET_ANOTHER_THREAD_NAME
const char *s = "";
#endif
- rb_thread_t *th;
- GetThreadPtr(thread, th);
+ rb_thread_t *th = get_initialized_threadptr(thread, RBASIC_CLASS(thread));
if (!NIL_P(name)) {
rb_encoding *enc;
StringValueCStr(name);
@@ -2830,7 +2836,7 @@ rb_thread_inspect(VALUE thread)
GetThreadPtr(thread, th);
status = thread_status_name(th);
str = rb_sprintf("#<%"PRIsVALUE":%p", cname, (void *)thread);
- if (!NIL_P(th->name)) {
+ if (RTEST(th->name)) {
rb_str_catf(str, "@%"PRIsVALUE, th->name);
}
if (!th->first_func && th->first_proc) {