kotovalexarian-likes-github/ruby--ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2022-11-09 12:17:21 -05:00
Code Releases Activity

Adjust indents [ci skip]

Browse source
This commit is contained in:
Nobuyoshi Nakada 2022-10-18 00:23:23 +09:00
parent 60defe0a68
commit 637144b834
No known key found for this signature in database
GPG key ID: 7CD2805BFA3770C6
1 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
thread_sync.c
View file

@ -1030,13 +1030,13 @@ queue_do_pop(VALUE self, struct rb_queue *q, int should_block, VALUE timeout)
{
check_array(self, q->que);
if (RARRAY_LEN(q->que) == 0) {
if (!should_block) {
rb_raise(rb_eThreadError, "queue empty");
}
if (!should_block) {
rb_raise(rb_eThreadError, "queue empty");
}
if (RTEST(rb_equal(INT2FIX(0), timeout))) {
return Qnil;
}
if (RTEST(rb_equal(INT2FIX(0), timeout))) {
return Qnil;
}
}
rb_hrtime_t end = queue_timeout2hrtime(timeout);
@ -1241,13 +1241,13 @@ rb_szqueue_push(rb_execution_context_t *ec, VALUE self, VALUE object, VALUE non_
struct rb_szqueue *sq = szqueue_ptr(self);
if (queue_length(self, &sq->q) >= sq->max) {
if (RTEST(non_block)) {
rb_raise(rb_eThreadError, "queue full");
}
if (RTEST(non_block)) {
rb_raise(rb_eThreadError, "queue full");
}
if (RTEST(rb_equal(INT2FIX(0), timeout))) {
return Qnil;
}
if (RTEST(rb_equal(INT2FIX(0), timeout))) {
return Qnil;
}
}
rb_hrtime_t end = queue_timeout2hrtime(timeout);