Conditional schedule cleanup

oldmoe · Oct 31, 2008 · 57712a6 · 57712a6
1 parent 4640893
commit 57712a6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ext/mysql.c b/ext/mysql.c
@@ -1035,7 +1035,7 @@ static void schedule_query(VALUE obj, VALUE timeout)
 }
 
 static int should_schedule_query(){
-  return ( ( rb_thread_main() == rb_thread_current() ) && rb_thread_alone() );
+  return ( ( rb_thread_main() == rb_thread_current() ) && rb_thread_alone() ) != 1;
 }
 
 /* async_query(sql,timeout=nil) */
@@ -1052,7 +1052,7 @@ static VALUE async_query(int argc, VALUE* argv, VALUE obj)
 
     send_query( obj, sql );
 
-    if ( should_schedule_query() != 1 ){
+    if ( should_schedule_query() ){
       schedule_query(obj, timeout);
     }