diff options
Diffstat (limited to 'thread_sync.c')
| -rw-r--r-- | thread_sync.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/thread_sync.c b/thread_sync.c index 3689dee789..3b8c5364a9 100644 --- a/thread_sync.c +++ b/thread_sync.c @@ -1156,7 +1156,7 @@ rb_szqueue_push(int argc, VALUE *argv, VALUE self) rb_raise(rb_eThreadError, "queue full"); } else if (queue_closed_p(self)) { - goto closed; + break; } else { struct queue_waiter qw; @@ -1172,7 +1172,6 @@ rb_szqueue_push(int argc, VALUE *argv, VALUE self) } if (queue_closed_p(self)) { - closed: raise_closed_queue_error(self); } |