@@ -211,7 +211,6 @@ rb_fiber_scheduler_blocking_operation_execute(rb_fiber_scheduler_blocking_operat
211211 }
212212
213213 // Now we're executing - call the function
214- fprintf (stderr , "[blocking_operation] execute: op=%p state=%p\n" , (void * )blocking_operation , (void * )blocking_operation -> state );
215214 blocking_operation -> state -> result = blocking_operation -> function (blocking_operation -> data );
216215 blocking_operation -> state -> saved_errno = errno ;
217216
@@ -1107,18 +1106,11 @@ VALUE rb_fiber_scheduler_blocking_operation_wait(VALUE scheduler, void* (*functi
11071106 VALUE blocking_operation = rb_fiber_scheduler_blocking_operation_new (function , data , unblock_function , data2 , flags , state );
11081107
11091108 rb_fiber_scheduler_blocking_operation_t * operation = get_blocking_operation (blocking_operation );
1110- fprintf (stderr , "[blocking_operation] wait: op=%p state=%p\n" , (void * )operation , (void * )state );
11111109
11121110 int tag = 0 ;
11131111 VALUE call_args [2 ] = {scheduler , blocking_operation };
11141112 VALUE result = rb_protect (scheduler_blocking_operation_wait_call , (VALUE )call_args , & tag );
11151113
1116- if (tag ) {
1117- // Exception from blocking_operation_wait: cleanup still runs below,
1118- // but log this so we can detect when a stale state pointer is later accessed.
1119- fprintf (stderr , "[blocking_operation] wait exception: op=%p state=%p (now dangling!)\n" , (void * )operation , (void * )state );
1120- }
1121-
11221114 // Get fresh operation pointer after rb_protect (GC may have run)
11231115 operation = get_blocking_operation (blocking_operation );
11241116 // Get the operation data to check if it was executed
@@ -1235,7 +1227,6 @@ rb_fiber_scheduler_blocking_operation_cancel(rb_fiber_scheduler_blocking_operati
12351227
12361228 case RB_FIBER_SCHEDULER_BLOCKING_OPERATION_STATUS_EXECUTING :
12371229 // Work is running - mark cancelled AND call unblock function
1238- fprintf (stderr , "[blocking_operation] cancel(executing): op=%p state=%p\n" , (void * )blocking_operation , (void * )blocking_operation -> state );
12391230 if (RUBY_ATOMIC_CAS (blocking_operation -> status , current_state , RB_FIBER_SCHEDULER_BLOCKING_OPERATION_STATUS_CANCELLED ) != current_state ) {
12401231 // State changed between load and CAS - operation may have completed:
12411232 return 0 ;
0 commit comments