diff options
| author | Nobuyoshi Nakada <nobu@ruby-lang.org> | 2022-10-18 00:23:23 +0900 |
|---|---|---|
| committer | Nobuyoshi Nakada <nobu@ruby-lang.org> | 2022-10-18 00:23:23 +0900 |
| commit | 637144b83432781e7e070ca74445b172f8af109e (patch) | |
| tree | ecee8c60cc57ccb32bdef408321d7f601f409702 /thread_sync.c | |
| parent | 60defe0a68a40d1b3225cf6b971ea195e19ae2e2 (diff) | |
| download | ruby-637144b83432781e7e070ca74445b172f8af109e.tar.gz | |
Adjust indents [ci skip]
Diffstat (limited to 'thread_sync.c')
| -rw-r--r-- | thread_sync.c | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/thread_sync.c b/thread_sync.c index b2ee052aa5..3888534468 100644 --- a/thread_sync.c +++ b/thread_sync.c @@ -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); |