Lines Matching refs:conn
35 #define PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_size, packet_type_as_text, packet_type) \ argument
38 …if (FAIL == mysqlnd_read_header((conn)->net, &((packet)->header), (conn)->stats, ((conn)->error_in…
39 CONN_SET_STATE(conn, CONN_QUIT_SENT); \
40 … SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone);\
50 …if (FAIL == conn->net->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats, ((co…
51 CONN_SET_STATE(conn, CONN_QUIT_SENT); \
52 … SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone);\
57 …MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[packet_type],…
305 php_mysqlnd_greet_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_greet_read()
315 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); in php_mysqlnd_greet_read()
467 size_t php_mysqlnd_auth_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_auth_write()
503 SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, msg); in php_mysqlnd_auth_write()
546 …if (PASS != conn->m->simple_command(conn, COM_CHANGE_USER, buffer + MYSQLND_HEADER_SIZE, p - buffe… in php_mysqlnd_auth_write()
553 …size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stat… in php_mysqlnd_auth_write()
555 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_auth_write()
579 php_mysqlnd_auth_response_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_auth_response_read()
582 size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length: AUTH_RESP_BUFFER_SIZE; in php_mysqlnd_auth_response_read()
583 …zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : loca… in php_mysqlnd_auth_response_read()
593 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); in php_mysqlnd_auth_response_read()
699 php_mysqlnd_change_auth_response_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_change_auth_response_write()
702 …zend_uchar * buffer = conn->net->cmd_buffer.length >= packet->auth_data_len? conn->net->cmd_buffer… in php_mysqlnd_change_auth_response_write()
713 …size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stat… in php_mysqlnd_change_auth_response_write()
714 if (buffer != conn->net->cmd_buffer.buffer) { in php_mysqlnd_change_auth_response_write()
718 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_change_auth_response_write()
742 php_mysqlnd_ok_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_ok_read()
745 size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length : OK_BUFFER_SIZE; in php_mysqlnd_ok_read()
746 …zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : loca… in php_mysqlnd_ok_read()
754 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); in php_mysqlnd_ok_read()
767 DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); in php_mysqlnd_ok_read()
828 php_mysqlnd_eof_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_eof_read()
837 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_eof_read()
838 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_eof_read()
844 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); in php_mysqlnd_eof_read()
905 size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_cmd_write()
909 MYSQLND_NET * net = conn->net; in php_mysqlnd_cmd_write()
925 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PACKETS_SENT_CMD); in php_mysqlnd_cmd_write()
935 sent = net->m.send_ex(net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC); in php_mysqlnd_cmd_write()
950 …sent = net->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRML… in php_mysqlnd_cmd_write()
952 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CMD_BUFFER_TOO_SMALL); in php_mysqlnd_cmd_write()
962 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_cmd_write()
983 php_mysqlnd_rset_header_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rset_header_read()
986 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_rset_header_read()
987 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_rset_header_read()
995 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKE… in php_mysqlnd_rset_header_read()
1010 DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); in php_mysqlnd_rset_header_read()
1034 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_header_read()
1061 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_header_read()
1122 php_mysqlnd_rset_field_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rset_field_read()
1126 size_t buf_len = conn->net->cmd_buffer.length, total_len = 0; in php_mysqlnd_rset_field_read()
1127 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_rset_field_read()
1137 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); in php_mysqlnd_rset_field_read()
1238 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_field_read()
1250 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_field_read()
1332 php_mysqlnd_read_row_ex(MYSQLND_CONN_DATA * conn, MYSQLND_MEMORY_POOL * result_set_memory_pool, in php_mysqlnd_read_row_ex() argument
1354 if (FAIL == mysqlnd_read_header(conn->net, &header, conn->stats, conn->error_info TSRMLS_CC)) { in php_mysqlnd_read_row_ex()
1386 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_read_row_ex()
1394 …if (PASS != (ret = conn->net->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_inf… in php_mysqlnd_read_row_ex()
1748 php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rowp_read()
1750 MYSQLND_NET * net = conn->net; in php_mysqlnd_rowp_read()
1765 …ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_siz… in php_mysqlnd_rowp_read()
1771 …MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[PROT_ROW_PACK… in php_mysqlnd_rowp_read()
1804 MYSQLND_INC_CONN_STATISTIC(conn->stats, in php_mysqlnd_rowp_read()
1828 MYSQLND_INC_CONN_STATISTIC(conn->stats, in php_mysqlnd_rowp_read()
1871 php_mysqlnd_stats_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_stats_read()
1874 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_stats_read()
1875 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_stats_read()
1879 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); in php_mysqlnd_stats_read()
1913 php_mysqlnd_prepare_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_prepare_read()
1916 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_prepare_read()
1917 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_prepare_read()
1925 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); in php_mysqlnd_prepare_read()
2001 php_mysqlnd_chg_user_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_chg_user_read()
2004 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_chg_user_read()
2005 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_chg_user_read()
2012 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP… in php_mysqlnd_chg_user_read()
