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->data->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats…
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],…
323 php_mysqlnd_greet_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_greet_read()
333 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); in php_mysqlnd_greet_read()
485 size_t php_mysqlnd_auth_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_auth_write()
521 SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, msg); in php_mysqlnd_auth_write()
580 zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); in php_mysqlnd_auth_write()
602 zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); in php_mysqlnd_auth_write()
610 …if (PASS != conn->m->simple_command(conn, COM_CHANGE_USER, buffer + MYSQLND_HEADER_SIZE, p - buffe… in php_mysqlnd_auth_write()
617 …size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn… in php_mysqlnd_auth_write()
619 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_auth_write()
643 php_mysqlnd_auth_response_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_auth_response_read()
646 size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length: AUTH_RESP_BUFFER_SIZE; in php_mysqlnd_auth_response_read()
647 …zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : loca… in php_mysqlnd_auth_response_read()
657 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); in php_mysqlnd_auth_response_read()
763 php_mysqlnd_change_auth_response_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_change_auth_response_write()
766 …zend_uchar * buffer = conn->net->cmd_buffer.length >= packet->auth_data_len? conn->net->cmd_buffer… in php_mysqlnd_change_auth_response_write()
777 …size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn… in php_mysqlnd_change_auth_response_write()
778 if (buffer != conn->net->cmd_buffer.buffer) { in php_mysqlnd_change_auth_response_write()
782 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_change_auth_response_write()
806 php_mysqlnd_ok_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_ok_read()
809 size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length : OK_BUFFER_SIZE; in php_mysqlnd_ok_read()
810 …zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : loca… in php_mysqlnd_ok_read()
818 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); in php_mysqlnd_ok_read()
831 DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); in php_mysqlnd_ok_read()
892 php_mysqlnd_eof_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_eof_read()
901 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_eof_read()
902 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_eof_read()
908 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); in php_mysqlnd_eof_read()
969 size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_cmd_write()
973 MYSQLND_NET * net = conn->net; in php_mysqlnd_cmd_write()
989 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PACKETS_SENT_CMD); in php_mysqlnd_cmd_write()
999 sent = net->data->m.send_ex(net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC); in php_mysqlnd_cmd_write()
1014 …sent = net->data->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info… in php_mysqlnd_cmd_write()
1016 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CMD_BUFFER_TOO_SMALL); in php_mysqlnd_cmd_write()
1026 CONN_SET_STATE(conn, CONN_QUIT_SENT); in php_mysqlnd_cmd_write()
1047 php_mysqlnd_rset_header_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rset_header_read()
1050 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_rset_header_read()
1051 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_rset_header_read()
1059 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKE… in php_mysqlnd_rset_header_read()
1074 DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); in php_mysqlnd_rset_header_read()
1098 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_header_read()
1125 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_header_read()
1186 php_mysqlnd_rset_field_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rset_field_read()
1190 size_t buf_len = conn->net->cmd_buffer.length, total_len = 0; in php_mysqlnd_rset_field_read()
1191 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_rset_field_read()
1201 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); in php_mysqlnd_rset_field_read()
1302 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_field_read()
1314 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_rset_field_read()
1396 php_mysqlnd_read_row_ex(MYSQLND_CONN_DATA * conn, MYSQLND_MEMORY_POOL * result_set_memory_pool, in php_mysqlnd_read_row_ex() argument
1418 if (FAIL == mysqlnd_read_header(conn->net, &header, conn->stats, conn->error_info TSRMLS_CC)) { in php_mysqlnd_read_row_ex()
1450 SET_OOM_ERROR(*conn->error_info); in php_mysqlnd_read_row_ex()
1458 …if (PASS != (ret = conn->net->data->m.receive_ex(conn->net, p, header.size, conn->stats, conn->err… in php_mysqlnd_read_row_ex()
1767 php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_rowp_read()
1782 …ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_siz… in php_mysqlnd_rowp_read()
1788 …MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[PROT_ROW_PACK… in php_mysqlnd_rowp_read()
1821 MYSQLND_INC_CONN_STATISTIC(conn->stats, in php_mysqlnd_rowp_read()
1845 MYSQLND_INC_CONN_STATISTIC(conn->stats, in php_mysqlnd_rowp_read()
1887 php_mysqlnd_stats_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_stats_read()
1890 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_stats_read()
1891 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_stats_read()
1895 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); in php_mysqlnd_stats_read()
1929 php_mysqlnd_prepare_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_prepare_read()
1932 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_prepare_read()
1933 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_prepare_read()
1941 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); in php_mysqlnd_prepare_read()
2017 php_mysqlnd_chg_user_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_chg_user_read()
2020 size_t buf_len = conn->net->cmd_buffer.length; in php_mysqlnd_chg_user_read()
2021 zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; in php_mysqlnd_chg_user_read()
2028 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP… in php_mysqlnd_chg_user_read()
2105 size_t php_mysqlnd_sha256_pk_request_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_sha256_pk_request_write()
2113 sent = conn->net->data->m.send_ex(conn->net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC); in php_mysqlnd_sha256_pk_request_write()
2136 php_mysqlnd_sha256_pk_request_response_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) in php_mysqlnd_sha256_pk_request_response_read()
2146 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "SHA256_PK_REQUEST_RESPONSE", PROT_SHA… in php_mysqlnd_sha256_pk_request_response_read()
