@@ -487,7 +487,6 @@ _mysql_ConnectionObject_Initialize(
487
487
PyErr_SetNone (PyExc_MemoryError );
488
488
return -1 ;
489
489
}
490
- Py_BEGIN_ALLOW_THREADS ;
491
490
self -> open = 1 ;
492
491
493
492
if (connect_timeout ) {
@@ -548,10 +547,10 @@ _mysql_ConnectionObject_Initialize(
548
547
mysql_options (& (self -> connection ), MYSQL_DEFAULT_AUTH , auth_plugin );
549
548
}
550
549
550
+ Py_BEGIN_ALLOW_THREADS
551
551
conn = mysql_real_connect (& (self -> connection ), host , user , passwd , db ,
552
552
port , unix_socket , client_flag );
553
-
554
- Py_END_ALLOW_THREADS ;
553
+ Py_END_ALLOW_THREADS
555
554
556
555
if (ssl ) {
557
556
int i ;
@@ -1403,9 +1402,9 @@ _mysql__fetch_row(
1403
1402
if (!self -> use )
1404
1403
row = mysql_fetch_row (self -> result );
1405
1404
else {
1406
- Py_BEGIN_ALLOW_THREADS ;
1405
+ Py_BEGIN_ALLOW_THREADS
1407
1406
row = mysql_fetch_row (self -> result );
1408
- Py_END_ALLOW_THREADS ;
1407
+ Py_END_ALLOW_THREADS
1409
1408
}
1410
1409
if (!row && mysql_errno (& (((_mysql_ConnectionObject * )(self -> conn ))-> connection ))) {
1411
1410
_mysql_Exception ((_mysql_ConnectionObject * )self -> conn );
@@ -1495,9 +1494,11 @@ _mysql_ResultObject_discard(
1495
1494
check_result_connection (self );
1496
1495
1497
1496
MYSQL_ROW row ;
1497
+ Py_BEGIN_ALLOW_THREADS
1498
1498
while (NULL != (row = mysql_fetch_row (self -> result ))) {
1499
1499
// do nothing
1500
1500
}
1501
+ Py_END_ALLOW_THREADS
1501
1502
if (mysql_errno (self -> conn )) {
1502
1503
return _mysql_Exception (self -> conn );
1503
1504
}
@@ -1747,9 +1748,7 @@ _mysql_ConnectionObject_insert_id(
1747
1748
{
1748
1749
my_ulonglong r ;
1749
1750
check_connection (self );
1750
- Py_BEGIN_ALLOW_THREADS
1751
1751
r = mysql_insert_id (& (self -> connection ));
1752
- Py_END_ALLOW_THREADS
1753
1752
return PyLong_FromUnsignedLongLong (r );
1754
1753
}
1755
1754
@@ -2058,9 +2057,7 @@ _mysql_ConnectionObject_thread_id(
2058
2057
{
2059
2058
unsigned long pid ;
2060
2059
check_connection (self );
2061
- Py_BEGIN_ALLOW_THREADS
2062
2060
pid = mysql_thread_id (& (self -> connection ));
2063
- Py_END_ALLOW_THREADS
2064
2061
return PyLong_FromLong ((long )pid );
2065
2062
}
2066
2063
0 commit comments