summaryrefslogtreecommitdiffstats
path: root/cont.c
diff options
context:
space:
mode:
authorwanabe <wanabe@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2009-11-01 23:27:12 +0000
committerwanabe <wanabe@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2009-11-01 23:27:12 +0000
commite4a13cce4035ee2745217c53efd0f720ada22646 (patch)
treee42c10ff390371b55f0c48ffd5d8c97ca0419360 /cont.c
parentcf0a9dbf401078b329ecbf6607f49a6a1788cbc2 (diff)
downloadruby-e4a13cce4035ee2745217c53efd0f720ada22646.tar.gz
ruby-e4a13cce4035ee2745217c53efd0f720ada22646.tar.xz
ruby-e4a13cce4035ee2745217c53efd0f720ada22646.zip
* cont.c (fiber_free): don't free unallocated local_storage. see #1325.
* cont.c (cont_init): clear local_storage not to use current thread's. * cont.c (fiber_t_alloc, root_fiber_alloc): link itself always for a case that fiber_link_remove() is called before fiber_link_join(). * cont.c (fiber_init): don't join half-baked fiber. git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@25623 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'cont.c')
-rw-r--r--cont.c10
1 files changed, 6 insertions, 4 deletions
diff --git a/cont.c b/cont.c
index 9021333ba..9e80fb506 100644
--- a/cont.c
+++ b/cont.c
@@ -198,7 +198,8 @@ fiber_free(void *ptr)
if (ptr) {
rb_fiber_t *fib = ptr;
- if (fib->cont.type != ROOT_FIBER_CONTEXT) {
+ if (fib->cont.type != ROOT_FIBER_CONTEXT &&
+ fib->cont.saved_thread.local_storage) {
st_free_table(fib->cont.saved_thread.local_storage);
}
fiber_link_remove(fib);
@@ -283,6 +284,7 @@ cont_init(rb_context_t *cont, rb_thread_t *th)
{
/* save thread context */
cont->saved_thread = *th;
+ cont->saved_thread.local_storage = 0;
}
static rb_context_t *
@@ -731,6 +733,7 @@ fiber_t_alloc(VALUE fibval)
cont_init(&fib->cont, th);
fib->prev = Qnil;
fib->status = CREATED;
+ fib->prev_fiber = fib->next_fiber = fib;
DATA_PTR(fibval) = fib;
@@ -744,8 +747,6 @@ fiber_init(VALUE fibval, VALUE proc)
rb_context_t *cont = &fib->cont;
rb_thread_t *th = &cont->saved_thread;
- fiber_link_join(fib);
-
/* initialize cont */
cont->vm_stack = 0;
@@ -753,6 +754,8 @@ fiber_init(VALUE fibval, VALUE proc)
th->stack_size = FIBER_VM_STACK_SIZE;
th->stack = ALLOC_N(VALUE, th->stack_size);
+ fiber_link_join(fib);
+
th->cfp = (void *)(th->stack + th->stack_size);
th->cfp--;
th->cfp->pc = 0;
@@ -875,7 +878,6 @@ root_fiber_alloc(rb_thread_t *th)
/* no need to allocate vm stack */
fib = fiber_t_alloc(fiber_alloc(rb_cFiber));
fib->cont.type = ROOT_FIBER_CONTEXT;
- fib->prev_fiber = fib->next_fiber = fib;
return fib;
}