@@ -242,16 +242,15 @@ MYSQLND_METHOD_PRIVATE(mysqlnd_conn, dtor)(MYSQLND *conn TSRMLS_DC)
242
242
/* }}} */
243
243
244
244
245
- /* {{{ mysqlnd_simple_command_handle_response */
246
- enum_func_status
247
- mysqlnd_simple_command_handle_response (MYSQLND * conn , enum php_mysql_packet_type ok_packet ,
248
- zend_bool silent , enum php_mysqlnd_server_command command ,
249
- zend_bool ignore_upsert_status
250
- TSRMLS_DC )
245
+ /* {{{ mysqlnd_conn::simple_command_handle_response */
246
+ static enum_func_status
247
+ MYSQLND_METHOD (mysqlnd_conn , simple_command_handle_response )(MYSQLND * conn , enum php_mysql_packet_type ok_packet ,
248
+ zend_bool silent , enum php_mysqlnd_server_command command ,
249
+ zend_bool ignore_upsert_status TSRMLS_DC )
251
250
{
252
251
enum_func_status ret ;
253
252
254
- DBG_ENTER ("mysqlnd_simple_command_handle_response " );
253
+ DBG_ENTER ("mysqlnd_conn::simple_command_handle_response " );
255
254
DBG_INF_FMT ("silent=%d packet=%d command=%s" , silent , ok_packet , mysqlnd_command_to_text [command ]);
256
255
257
256
switch (ok_packet ) {
@@ -343,17 +342,16 @@ mysqlnd_simple_command_handle_response(MYSQLND *conn, enum php_mysql_packet_type
343
342
/* }}} */
344
343
345
344
346
- /* {{{ mysqlnd_simple_command */
347
- enum_func_status
348
- mysqlnd_simple_command (MYSQLND * conn , enum php_mysqlnd_server_command command ,
349
- const char * const arg , size_t arg_len ,
350
- enum php_mysql_packet_type ok_packet , zend_bool silent ,
351
- zend_bool ignore_upsert_status TSRMLS_DC )
345
+ /* {{{ mysqlnd_conn::simple_command */
346
+ static enum_func_status
347
+ MYSQLND_METHOD (mysqlnd_conn , simple_command )(MYSQLND * conn , enum php_mysqlnd_server_command command ,
348
+ const char * const arg , size_t arg_len , enum php_mysql_packet_type ok_packet , zend_bool silent ,
349
+ zend_bool ignore_upsert_status TSRMLS_DC )
352
350
{
353
351
enum_func_status ret = PASS ;
354
352
php_mysql_packet_command cmd_packet ;
355
353
356
- DBG_ENTER ("mysqlnd_simple_command " );
354
+ DBG_ENTER ("mysqlnd_conn::simple_command " );
357
355
DBG_INF_FMT ("command=%s ok_packet=%d silent=%d" , mysqlnd_command_to_text [command ], ok_packet , silent );
358
356
359
357
switch (CONN_GET_STATE (conn )) {
@@ -394,7 +392,7 @@ mysqlnd_simple_command(MYSQLND *conn, enum php_mysqlnd_server_command command,
394
392
DBG_ERR ("Server is gone" );
395
393
ret = FAIL ;
396
394
} else if (ok_packet != PROT_LAST ) {
397
- ret = mysqlnd_simple_command_handle_response (conn , ok_packet , silent , command , ignore_upsert_status TSRMLS_CC );
395
+ ret = conn -> m -> simple_command_handle_response (conn , ok_packet , silent , command , ignore_upsert_status TSRMLS_CC );
398
396
}
399
397
400
398
/*
@@ -419,8 +417,7 @@ MYSQLND_METHOD(mysqlnd_conn, set_server_option)(MYSQLND * const conn,
419
417
DBG_ENTER ("mysqlnd_conn::set_server_option" );
420
418
421
419
int2store (buffer , (unsigned int ) option );
422
- ret = mysqlnd_simple_command (conn , COM_SET_OPTION , buffer , sizeof (buffer ),
423
- PROT_EOF_PACKET , FALSE, TRUE TSRMLS_CC );
420
+ ret = conn -> m -> simple_command (conn , COM_SET_OPTION , buffer , sizeof (buffer ), PROT_EOF_PACKET , FALSE, TRUE TSRMLS_CC );
424
421
DBG_RETURN (ret );
425
422
}
426
423
/* }}} */
@@ -892,7 +889,7 @@ MYSQLND_METHOD(mysqlnd_conn, query)(MYSQLND *conn, const char *query, unsigned i
892
889
DBG_ENTER ("mysqlnd_conn::query" );
893
890
DBG_INF_FMT ("conn=%llu query=%s" , conn -> thread_id , query );
894
891
895
- if (PASS != mysqlnd_simple_command (conn , COM_QUERY , query , query_len ,
892
+ if (PASS != conn -> m -> simple_command (conn , COM_QUERY , query , query_len ,
896
893
PROT_LAST /* we will handle the OK packet*/ ,
897
894
FALSE, FALSE TSRMLS_CC )) {
898
895
DBG_RETURN (FAIL );
@@ -920,7 +917,7 @@ MYSQLND_METHOD(mysqlnd_conn, send_query)(MYSQLND *conn, const char *query, unsig
920
917
DBG_ENTER ("mysqlnd_conn::send_query" );
921
918
DBG_INF_FMT ("conn=%llu query=%s" , conn -> thread_id , query );
922
919
923
- ret = mysqlnd_simple_command (conn , COM_QUERY , query , query_len ,
920
+ ret = conn -> m -> simple_command (conn , COM_QUERY , query , query_len ,
924
921
PROT_LAST /* we will handle the OK packet*/ ,
925
922
FALSE, FALSE TSRMLS_CC );
926
923
CONN_SET_STATE (conn , CONN_QUERY_SENT );
@@ -1155,7 +1152,7 @@ MYSQLND_METHOD(mysqlnd_conn, list_fields)(MYSQLND *conn, const char *table, cons
1155
1152
* p ++ = '\0' ;
1156
1153
}
1157
1154
1158
- if (PASS != mysqlnd_simple_command (conn , COM_FIELD_LIST , buff , p - buff ,
1155
+ if (PASS != conn -> m -> simple_command (conn , COM_FIELD_LIST , buff , p - buff ,
1159
1156
PROT_LAST /* we will handle the OK packet*/ ,
1160
1157
FALSE, TRUE TSRMLS_CC )) {
1161
1158
DBG_RETURN (NULL );
@@ -1278,7 +1275,7 @@ MYSQLND_METHOD(mysqlnd_conn, dump_debug_info)(MYSQLND * const conn TSRMLS_DC)
1278
1275
{
1279
1276
DBG_ENTER ("mysqlnd_conn::dump_debug_info" );
1280
1277
DBG_INF_FMT ("conn=%llu" , conn -> thread_id );
1281
- DBG_RETURN (mysqlnd_simple_command (conn , COM_DEBUG , NULL , 0 , PROT_EOF_PACKET , FALSE, TRUE TSRMLS_CC ));
1278
+ DBG_RETURN (conn -> m -> simple_command (conn , COM_DEBUG , NULL , 0 , PROT_EOF_PACKET , FALSE, TRUE TSRMLS_CC ));
1282
1279
}
1283
1280
/* }}} */
1284
1281
@@ -1294,7 +1291,7 @@ MYSQLND_METHOD(mysqlnd_conn, select_db)(MYSQLND * const conn,
1294
1291
DBG_ENTER ("mysqlnd_conn::select_db" );
1295
1292
DBG_INF_FMT ("conn=%llu db=%s" , conn -> thread_id , db );
1296
1293
1297
- ret = mysqlnd_simple_command (conn , COM_INIT_DB , db , db_len , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC );
1294
+ ret = conn -> m -> simple_command (conn , COM_INIT_DB , db , db_len , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC );
1298
1295
/*
1299
1296
The server sends 0 but libmysql doesn't read it and has established
1300
1297
a protocol of giving back -1. Thus we have to follow it :(
@@ -1321,7 +1318,7 @@ MYSQLND_METHOD(mysqlnd_conn, ping)(MYSQLND * const conn TSRMLS_DC)
1321
1318
DBG_ENTER ("mysqlnd_conn::ping" );
1322
1319
DBG_INF_FMT ("conn=%llu" , conn -> thread_id );
1323
1320
1324
- ret = mysqlnd_simple_command (conn , COM_PING , NULL , 0 , PROT_OK_PACKET , TRUE, TRUE TSRMLS_CC );
1321
+ ret = conn -> m -> simple_command (conn , COM_PING , NULL , 0 , PROT_OK_PACKET , TRUE, TRUE TSRMLS_CC );
1325
1322
/*
1326
1323
The server sends 0 but libmysql doesn't read it and has established
1327
1324
a protocol of giving back -1. Thus we have to follow it :(
@@ -1344,7 +1341,7 @@ MYSQLND_METHOD(mysqlnd_conn, stat)(MYSQLND *conn, char **message, unsigned int *
1344
1341
DBG_ENTER ("mysqlnd_conn::stat" );
1345
1342
DBG_INF_FMT ("conn=%llu" , conn -> thread_id );
1346
1343
1347
- ret = mysqlnd_simple_command (conn , COM_STATISTICS , NULL , 0 , PROT_LAST , FALSE, TRUE TSRMLS_CC );
1344
+ ret = conn -> m -> simple_command (conn , COM_STATISTICS , NULL , 0 , PROT_LAST , FALSE, TRUE TSRMLS_CC );
1348
1345
if (FAIL == ret ) {
1349
1346
DBG_RETURN (FAIL );
1350
1347
}
@@ -1378,13 +1375,13 @@ MYSQLND_METHOD(mysqlnd_conn, kill)(MYSQLND *conn, unsigned int pid TSRMLS_DC)
1378
1375
1379
1376
/* If we kill ourselves don't expect OK packet, PROT_LAST will skip it */
1380
1377
if (pid != conn -> thread_id ) {
1381
- ret = mysqlnd_simple_command (conn , COM_PROCESS_KILL , buff , 4 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC );
1378
+ ret = conn -> m -> simple_command (conn , COM_PROCESS_KILL , buff , 4 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC );
1382
1379
/*
1383
1380
The server sends 0 but libmysql doesn't read it and has established
1384
1381
a protocol of giving back -1. Thus we have to follow it :(
1385
1382
*/
1386
1383
SET_ERROR_AFF_ROWS (conn );
1387
- } else if (PASS == (ret = mysqlnd_simple_command (conn , COM_PROCESS_KILL , buff ,
1384
+ } else if (PASS == (ret = conn -> m -> simple_command (conn , COM_PROCESS_KILL , buff ,
1388
1385
4 , PROT_LAST , FALSE, TRUE TSRMLS_CC ))) {
1389
1386
CONN_SET_STATE (conn , CONN_QUIT_SENT );
1390
1387
}
@@ -1438,7 +1435,7 @@ MYSQLND_METHOD(mysqlnd_conn, refresh)(MYSQLND * const conn, uint8_t options TSRM
1438
1435
1439
1436
int1store (bits , options );
1440
1437
1441
- DBG_RETURN (mysqlnd_simple_command (conn , COM_REFRESH , (char * )bits , 1 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC ));
1438
+ DBG_RETURN (conn -> m -> simple_command (conn , COM_REFRESH , (char * )bits , 1 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC ));
1442
1439
}
1443
1440
/* }}} */
1444
1441
@@ -1453,7 +1450,7 @@ MYSQLND_METHOD(mysqlnd_conn, shutdown)(MYSQLND * const conn, uint8_t level TSRML
1453
1450
1454
1451
int1store (bits , level );
1455
1452
1456
- DBG_RETURN (mysqlnd_simple_command (conn , COM_SHUTDOWN , (char * )bits , 1 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC ));
1453
+ DBG_RETURN (conn -> m -> simple_command (conn , COM_SHUTDOWN , (char * )bits , 1 , PROT_OK_PACKET , FALSE, TRUE TSRMLS_CC ));
1457
1454
}
1458
1455
/* }}} */
1459
1456
@@ -1472,7 +1469,7 @@ mysqlnd_send_close(MYSQLND * conn TSRMLS_DC)
1472
1469
case CONN_READY :
1473
1470
DBG_INF ("Connection clean, sending COM_QUIT" );
1474
1471
if (conn -> net .stream ) {
1475
- ret = mysqlnd_simple_command (conn , COM_QUIT , NULL , 0 , PROT_LAST , TRUE, TRUE TSRMLS_CC );
1472
+ ret = conn -> m -> simple_command (conn , COM_QUIT , NULL , 0 , PROT_LAST , TRUE, TRUE TSRMLS_CC );
1476
1473
}
1477
1474
/* Do nothing */
1478
1475
break ;
@@ -1888,7 +1885,7 @@ MYSQLND_METHOD(mysqlnd_conn, change_user)(MYSQLND * const conn,
1888
1885
}
1889
1886
* p ++ = '\0' ;
1890
1887
1891
- if (PASS != mysqlnd_simple_command (conn , COM_CHANGE_USER , buffer , p - buffer ,
1888
+ if (PASS != conn -> m -> simple_command (conn , COM_CHANGE_USER , buffer , p - buffer ,
1892
1889
PROT_LAST /* we will handle the OK packet*/ ,
1893
1890
silent , TRUE TSRMLS_CC )) {
1894
1891
DBG_RETURN (FAIL );
@@ -2200,6 +2197,9 @@ MYSQLND_CLASS_METHODS_START(mysqlnd_conn)
2200
2197
MYSQLND_METHOD_PRIVATE (mysqlnd_conn , free_reference ),
2201
2198
MYSQLND_METHOD_PRIVATE (mysqlnd_conn , get_state ),
2202
2199
MYSQLND_METHOD_PRIVATE (mysqlnd_conn , set_state ),
2200
+
2201
+ MYSQLND_METHOD (mysqlnd_conn , simple_command ),
2202
+ MYSQLND_METHOD (mysqlnd_conn , simple_command_handle_response )
2203
2203
MYSQLND_CLASS_METHODS_END ;
2204
2204
2205
2205
0 commit comments