зеркало из https://github.com/github/ruby.git
strip trailing spaces and adjusted indents [ci skip]
This commit is contained in:
Родитель
98de98fb70
Коммит
0d52dce3a3
22
cont.c
22
cont.c
|
@ -1825,19 +1825,19 @@ rb_fiber_initialize_kw(int argc, VALUE* argv, VALUE self, int kw_splat)
|
|||
VALUE blocking = Qfalse;
|
||||
|
||||
if (kw_splat != RB_NO_KEYWORDS) {
|
||||
VALUE options = Qnil;
|
||||
VALUE arguments[2] = {Qundef};
|
||||
VALUE options = Qnil;
|
||||
VALUE arguments[2] = {Qundef};
|
||||
|
||||
argc = rb_scan_args_kw(kw_splat, argc, argv, ":", &options);
|
||||
rb_get_kwargs(options, fiber_initialize_keywords, 0, 2, arguments);
|
||||
argc = rb_scan_args_kw(kw_splat, argc, argv, ":", &options);
|
||||
rb_get_kwargs(options, fiber_initialize_keywords, 0, 2, arguments);
|
||||
|
||||
if (arguments[0] != Qundef) {
|
||||
blocking = arguments[0];
|
||||
}
|
||||
|
||||
if (arguments[1] != Qundef) {
|
||||
pool = arguments[1];
|
||||
}
|
||||
if (arguments[0] != Qundef) {
|
||||
blocking = arguments[0];
|
||||
}
|
||||
|
||||
if (arguments[1] != Qundef) {
|
||||
pool = arguments[1];
|
||||
}
|
||||
}
|
||||
|
||||
return fiber_initialize(self, rb_block_proc(), rb_fiber_pool_default(pool), RTEST(blocking));
|
||||
|
|
|
@ -30,7 +30,7 @@ sync_wakeup(struct list_head *head, long max)
|
|||
list_del_init(&cur->node);
|
||||
|
||||
if (cur->th->status != THREAD_KILLED) {
|
||||
|
||||
|
||||
if (cur->th->scheduler != Qnil) {
|
||||
rb_scheduler_unblock(cur->th->scheduler, cur->self, rb_fiberptr_self(cur->fiber));
|
||||
} else {
|
||||
|
|
Загрузка…
Ссылка в новой задаче