@@ -373,7 +373,7 @@ static VALUE rb_connect(VALUE self, VALUE user, VALUE pass, VALUE host, VALUE po
373
373
if (wrapper -> connect_timeout )
374
374
mysql_options (wrapper -> client , MYSQL_OPT_CONNECT_TIMEOUT , & wrapper -> connect_timeout );
375
375
if (rv == Qfalse )
376
- return rb_raise_mysql2_error (wrapper );
376
+ rb_raise_mysql2_error (wrapper );
377
377
}
378
378
379
379
wrapper -> server_version = mysql_get_server_version (wrapper -> client );
@@ -419,7 +419,7 @@ static VALUE do_send_query(void *args) {
419
419
if ((VALUE )rb_thread_call_without_gvl (nogvl_send_query , args , RUBY_UBF_IO , 0 ) == Qfalse ) {
420
420
/* an error occurred, we're not active anymore */
421
421
wrapper -> active_thread = Qnil ;
422
- return rb_raise_mysql2_error (wrapper );
422
+ rb_raise_mysql2_error (wrapper );
423
423
}
424
424
return Qnil ;
425
425
}
@@ -481,7 +481,7 @@ static VALUE rb_mysql_client_async_result(VALUE self) {
481
481
if ((VALUE )rb_thread_call_without_gvl (nogvl_read_query_result , wrapper -> client , RUBY_UBF_IO , 0 ) == Qfalse ) {
482
482
/* an error occurred, mark this connection inactive */
483
483
wrapper -> active_thread = Qnil ;
484
- return rb_raise_mysql2_error (wrapper );
484
+ rb_raise_mysql2_error (wrapper );
485
485
}
486
486
487
487
is_streaming = rb_hash_aref (rb_iv_get (self , "@current_query_options" ), sym_stream );
@@ -1228,7 +1228,7 @@ static VALUE initialize_ext(VALUE self) {
1228
1228
1229
1229
if ((VALUE )rb_thread_call_without_gvl (nogvl_init , wrapper , RUBY_UBF_IO , 0 ) == Qfalse ) {
1230
1230
/* TODO: warning - not enough memory? */
1231
- return rb_raise_mysql2_error (wrapper );
1231
+ rb_raise_mysql2_error (wrapper );
1232
1232
}
1233
1233
1234
1234
wrapper -> initialized = 1 ;
0 commit comments