summaryrefslogtreecommitdiff
path: root/thread_sync.c
diff options
context:
space:
mode:
authorNobuyoshi Nakada <nobu@ruby-lang.org>2022-10-18 00:23:23 +0900
committerNobuyoshi Nakada <nobu@ruby-lang.org>2022-10-18 00:23:23 +0900
commit637144b83432781e7e070ca74445b172f8af109e (patch)
treeecee8c60cc57ccb32bdef408321d7f601f409702 /thread_sync.c
parent60defe0a68a40d1b3225cf6b971ea195e19ae2e2 (diff)
downloadruby-637144b83432781e7e070ca74445b172f8af109e.tar.gz
Adjust indents [ci skip]
Diffstat (limited to 'thread_sync.c')
-rw-r--r--thread_sync.c24
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);