Commits

Genki Sugawara committed 074e086

fix

  • Participants
  • Parent commits ef38fef
  • Branches ruby-1.9.3

Comments (0)

Files changed (1)

File ext/ruby_binlog.cpp

     Data_Get_Struct(self, Client, p);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-    result = rb_thread_blocking_region(_connect, p, RUBY_UBF_IO, NULL);
+    result = rb_thread_blocking_region(_connect, p, RUBY_UBF_IO, 0);
 #else
     TRAP_BEG;
     result = _connect(p);
       bool socket_is_open;
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      socket_is_open = rb_thread_blocking_region(_is_open, driver, RUBY_UBF_IO, NULL);
+      socket_is_open = rb_thread_blocking_region(_is_open, driver, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       socket_is_open = _is_open(driver);
       args[3] = reinterpret_cast<void *>(&closed);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      result = rb_thread_blocking_region(_disconnect, driver, RUBY_UBF_IO, NULL);
+      result = rb_thread_blocking_region(_wait_for_next_event_loop, args, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       result = _wait_for_next_event_loop(args);
 
       if (closed) {
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-        rb_thread_blocking_region(_disconnect, driver, RUBY_UBF_IO, NULL);
+        rb_thread_blocking_region(_disconnect, driver, RUBY_UBF_IO, 0);
 #else
         TRAP_BEG;
         _disconnect(driver);
       args[1] = reinterpret_cast<void *>(&event);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      result = rb_thread_blocking_region(_wait_for_next_event, args, RUBY_UBF_IO, NULL);
+      result = rb_thread_blocking_region(_wait_for_next_event, args, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       result = _wait_for_next_event(args);
       args[1] = reinterpret_cast<void *>(i_position);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      result = rb_thread_blocking_region(_set_position_pos, args, RUBY_UBF_IO, NULL);
+      result = rb_thread_blocking_region(_set_position_pos, args, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       _set_position_pos(args);
       args[1] = reinterpret_cast<void *>(&s_filename);
       args[2] = reinterpret_cast<void *>(i_position);
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      result = rb_thread_blocking_region(_set_position_filename_pos, args, RUBY_UBF_IO, NULL);
+      result = rb_thread_blocking_region(_set_position_filename_pos, args, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       _set_position_name_pos(args);
     args[1] = reinterpret_cast<void *>(i_position);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-    result = rb_thread_blocking_region(_set_position_pos, args, RUBY_UBF_IO, NULL);
+    result = rb_thread_blocking_region(_set_position_pos, args, RUBY_UBF_IO, 0);
 #else
     TRAP_BEG;
     result = _set_position_pos(args);
 
     if (NIL_P(filename)) {
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      position = rb_thread_blocking_region(_get_position, p, RUBY_UBF_IO, NULL);
+      position = rb_thread_blocking_region(_get_position, p, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       position = _get_position(p);
       args[1] = reinterpret_cast<void *>(&s_filename);
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-      position = rb_thread_blocking_region(_get_position_filename, args, RUBY_UBF_IO, NULL);
+      position = rb_thread_blocking_region(_get_position_filename, args, RUBY_UBF_IO, 0);
 #else
       TRAP_BEG;
       position = _get_position_filename(args);
     unsigned long position;
 
 #ifdef HAVE_RB_THREAD_BLOCKING_REGION
-    position = rb_thread_blocking_region(_get_position, p, RUBY_UBF_IO, NULL);
+    position = rb_thread_blocking_region(_get_position, p, RUBY_UBF_IO, 0);
 #else
     TRAP_BEG;
     position = _get_position(p);