Skip to content

Commit 2ac6f71

Browse files
Fix typos.
1 parent a99b682 commit 2ac6f71

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

scheduler.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1106,9 +1106,9 @@ rb_fiber_scheduler_address_resolve(VALUE scheduler, VALUE hostname)
11061106
* Thread.new{blocking_operation.call}.join
11071107
* end
11081108
*/
1109-
VALUE rb_fiber_scheduler_blocking_operation_wait(VALUE scheduler, void* (*function)(void *), void *data, rb_unblock_function_t *unblock_function, void *data2, int flags, struct rb_fiber_scheduler_blocking_operation_state *state)
1109+
VALUE rb_fiber_scheduler_blocking_operation_wait(VALUE scheduler, void* (*function)(void *), void *data, rb_unblock_function_t *unblock_function, void *data2, int flags, struct rb_fiber_scheduler_blocking_operation_state *blocking_operation_state)
11101110
{
1111-
fprintf(stderr, "rb_fiber_scheduler_blocking_operation_wait: scheduler=%p, function=%p, data=%p, unblock_function=%p, data2=%p, flags=%d, state=%p\n", scheduler, function, data, unblock_function, data2, flags, state);
1111+
fprintf(stderr, "rb_fiber_scheduler_blocking_operation_wait: scheduler=%p, function=%p, data=%p, unblock_function=%p, data2=%p, flags=%d, state=%p\n", (void*)scheduler, function, data, unblock_function, data2, flags, blocking_operation_state);
11121112

11131113
// Check if scheduler supports blocking_operation_wait before creating the object
11141114
if (!rb_respond_to(scheduler, id_blocking_operation_wait)) {
@@ -1145,7 +1145,7 @@ VALUE rb_fiber_scheduler_blocking_operation_wait(VALUE scheduler, void* (*functi
11451145
// to blocking_operation->state is not writing into freed memory. We do not
11461146
// copy the state in the non-COMPLETED paths, so the caller never reads a
11471147
// partial result.
1148-
fprintf(stderr, "rb_fiber_scheduler_blocking_operation_wait: blocking_operation=%p\n operation->status=%d\n state=%d\n", operation, current_status, state);
1148+
fprintf(stderr, "rb_fiber_scheduler_blocking_operation_wait: blocking_operation=%p\n state=%d\n", (void*)blocking_operation, state);
11491149
rb_fiber_scheduler_blocking_operation_t *operation = get_blocking_operation(blocking_operation);
11501150
rb_atomic_t current_status = RUBY_ATOMIC_LOAD(operation->status);
11511151

@@ -1157,7 +1157,7 @@ VALUE rb_fiber_scheduler_blocking_operation_wait(VALUE scheduler, void* (*functi
11571157
// Copy the result out before invalidating the operation, so the caller
11581158
// gets a stable snapshot regardless of what the scheduler does afterwards.
11591159
if (current_status == RB_FIBER_SCHEDULER_BLOCKING_OPERATION_STATUS_COMPLETED && state) {
1160-
*state = operation->state;
1160+
*blocking_operation_state = operation->state;
11611161
}
11621162

11631163
// Invalidate the function pointer so the now-useless BlockingOperation VALUE

0 commit comments

Comments
 (0)