Class: Event::Selector::KQueue
- Inherits:
-
Object
- Object
- Event::Selector::KQueue
- Defined in:
- ext/event/selector/kqueue.c
Instance Method Summary collapse
- #close ⇒ Object
- #initialize(loop) ⇒ Object constructor
- #io_read(fiber, io, buffer, _length) ⇒ Object
- #io_wait(fiber, io, events) ⇒ Object
- #io_write(fiber, io, buffer, _length) ⇒ Object
- #process_wait(fiber, pid, flags) ⇒ Object
- #push(fiber) ⇒ Object
- #raise(*args) ⇒ Object
- #ready? ⇒ Boolean
- #resume(*args) ⇒ Object
- #select(duration) ⇒ Object
- #transfer ⇒ Object
- #yield ⇒ Object
Constructor Details
#initialize(loop) ⇒ Object
87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 |
# File 'ext/event/selector/kqueue.c', line 87
VALUE Event_Selector_KQueue_initialize(VALUE self, VALUE loop) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
Event_Selector_initialize(&data->backend, loop);
int result = kqueue();
if (result == -1) {
rb_sys_fail("kqueue");
} else {
ioctl(result, FIOCLEX);
data->descriptor = result;
rb_update_max_fd(data->descriptor);
}
return self;
}
|
Instance Method Details
#close ⇒ Object
106 107 108 109 110 111 112 113 |
# File 'ext/event/selector/kqueue.c', line 106
VALUE Event_Selector_KQueue_close(VALUE self) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
close_internal(data);
return Qnil;
}
|
#io_read(fiber, io, buffer, _length) ⇒ Object
406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 |
# File 'ext/event/selector/kqueue.c', line 406
VALUE Event_Selector_KQueue_io_read(VALUE self, VALUE fiber, VALUE io, VALUE buffer, VALUE _length) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
int descriptor = Event_Selector_io_descriptor(io);
size_t length = NUM2SIZET(_length);
struct io_read_arguments io_read_arguments = {
.self = self,
.fiber = fiber,
.io = io,
.flags = Event_Selector_nonblock_set(descriptor),
.descriptor = descriptor,
.buffer = buffer,
.length = length,
};
return rb_ensure(io_read_loop, (VALUE)&io_read_arguments, io_read_ensure, (VALUE)&io_read_arguments);
}
|
#io_wait(fiber, io, events) ⇒ Object
337 338 339 340 341 342 343 344 345 346 347 348 349 350 |
# File 'ext/event/selector/kqueue.c', line 337
VALUE Event_Selector_KQueue_io_wait(VALUE self, VALUE fiber, VALUE io, VALUE events) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
int descriptor = Event_Selector_io_descriptor(io);
struct io_wait_arguments io_wait_arguments = {
.events = io_add_filters(data->descriptor, descriptor, RB_NUM2INT(events), fiber),
.data = data,
.descriptor = descriptor,
};
return rb_rescue(io_wait_transfer, (VALUE)&io_wait_arguments, io_wait_rescue, (VALUE)&io_wait_arguments);
}
|
#io_write(fiber, io, buffer, _length) ⇒ Object
481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 |
# File 'ext/event/selector/kqueue.c', line 481
VALUE Event_Selector_KQueue_io_write(VALUE self, VALUE fiber, VALUE io, VALUE buffer, VALUE _length) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
int descriptor = Event_Selector_io_descriptor(io);
size_t length = NUM2SIZET(_length);
struct io_write_arguments io_write_arguments = {
.self = self,
.fiber = fiber,
.io = io,
.flags = Event_Selector_nonblock_set(descriptor),
.descriptor = descriptor,
.buffer = buffer,
.length = length,
};
return rb_ensure(io_write_loop, (VALUE)&io_write_arguments, io_write_ensure, (VALUE)&io_write_arguments);
}
|
#process_wait(fiber, pid, flags) ⇒ Object
225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 |
# File 'ext/event/selector/kqueue.c', line 225
VALUE Event_Selector_KQueue_process_wait(VALUE self, VALUE fiber, VALUE pid, VALUE flags) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
struct process_wait_arguments process_wait_arguments = {
.data = data,
.pid = NUM2PIDT(pid),
.flags = RB_NUM2INT(flags),
};
int waiting = process_add_filters(data->descriptor, process_wait_arguments.pid, fiber);
if (waiting) {
return rb_rescue(process_wait_transfer, (VALUE)&process_wait_arguments, process_wait_rescue, (VALUE)&process_wait_arguments);
} else {
return Event_Selector_process_status_wait(process_wait_arguments.pid);
}
}
|
#push(fiber) ⇒ Object
139 140 141 142 143 144 145 146 147 |
# File 'ext/event/selector/kqueue.c', line 139
VALUE Event_Selector_KQueue_push(VALUE self, VALUE fiber)
{
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
Event_Selector_queue_push(&data->backend, fiber);
return Qnil;
}
|
#raise(*args) ⇒ Object
149 150 151 152 153 154 155 |
# File 'ext/event/selector/kqueue.c', line 149
VALUE Event_Selector_KQueue_raise(int argc, VALUE *argv, VALUE self)
{
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
return Event_Selector_raise(&data->backend, argc, argv);
}
|
#ready? ⇒ Boolean
157 158 159 160 161 162 |
# File 'ext/event/selector/kqueue.c', line 157
VALUE Event_Selector_KQueue_ready_p(VALUE self) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
return data->backend.ready ? Qtrue : Qfalse;
}
|
#resume(*args) ⇒ Object
123 124 125 126 127 128 129 |
# File 'ext/event/selector/kqueue.c', line 123
VALUE Event_Selector_KQueue_resume(int argc, VALUE *argv, VALUE self)
{
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
return Event_Selector_resume(&data->backend, argc, argv);
}
|
#select(duration) ⇒ Object
573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 |
# File 'ext/event/selector/kqueue.c', line 573
VALUE Event_Selector_KQueue_select(VALUE self, VALUE duration) {
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
int ready = Event_Selector_queue_flush(&data->backend);
struct select_arguments arguments = {
.data = data,
.count = KQUEUE_MAX_EVENTS,
.storage = {
.tv_sec = 0,
.tv_nsec = 0
}
};
// We break this implementation into two parts.
// (1) count = kevent(..., timeout = 0)
// (2) without gvl: kevent(..., timeout = 0) if count == 0 and timeout != 0
// This allows us to avoid releasing and reacquiring the GVL.
// Non-comprehensive testing shows this gives a 1.5x speedup.
arguments.timeout = &arguments.storage;
// First do the syscall with no timeout to get any immediately available events:
select_internal_with_gvl(&arguments);
// If there were no pending events, if we have a timeout, wait for more events:
if (!ready && arguments.count == 0) {
arguments.timeout = make_timeout(duration, &arguments.storage);
if (!timeout_nonblocking(arguments.timeout)) {
arguments.count = KQUEUE_MAX_EVENTS;
select_internal_without_gvl(&arguments);
}
}
for (int i = 0; i < arguments.count; i += 1) {
VALUE fiber = (VALUE)arguments.events[i].udata;
VALUE result = INT2NUM(arguments.events[i].filter);
Event_Selector_fiber_transfer(fiber, 1, &result);
}
return INT2NUM(arguments.count);
}
|
#transfer ⇒ Object
115 116 117 118 119 120 121 |
# File 'ext/event/selector/kqueue.c', line 115
VALUE Event_Selector_KQueue_transfer(VALUE self)
{
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
return Event_Selector_fiber_transfer(data->backend.loop, 0, NULL);
}
|
#yield ⇒ Object
131 132 133 134 135 136 137 |
# File 'ext/event/selector/kqueue.c', line 131
VALUE Event_Selector_KQueue_yield(VALUE self)
{
struct Event_Selector_KQueue *data = NULL;
TypedData_Get_Struct(self, struct Event_Selector_KQueue, &Event_Selector_KQueue_Type, data);
return Event_Selector_yield(&data->backend);
}
|