Lines Matching refs:packet
34 #define PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_size, packet_type_as_text, packet_type) \ argument
37 if (FAIL == mysqlnd_read_header((conn), &((packet)->header) TSRMLS_CC)) {\
44 if ((buf_size) < (packet)->header.size) { \
46 (buf_size), (packet)->header.size, (packet)->header.size - (buf_size)); \
49 if (FAIL == conn->net->m.receive((conn), (buf), (packet)->header.size TSRMLS_CC)) { \
57 MYSQLND_HEADER_SIZE + (packet)->header.size, \
64 if ((size_t)(p - begin) > packet->header.size) { \
130 php_mysqlnd_net_field_length(zend_uchar **packet) in php_mysqlnd_net_field_length() argument
132 register zend_uchar *p= (zend_uchar *)*packet; in php_mysqlnd_net_field_length()
135 (*packet)++; in php_mysqlnd_net_field_length()
141 (*packet)++; in php_mysqlnd_net_field_length()
144 (*packet) += 3; in php_mysqlnd_net_field_length()
147 (*packet) += 4; in php_mysqlnd_net_field_length()
150 (*packet) += 9; in php_mysqlnd_net_field_length()
160 php_mysqlnd_net_field_length_ll(zend_uchar **packet) in php_mysqlnd_net_field_length_ll() argument
162 register zend_uchar *p= (zend_uchar *)*packet; in php_mysqlnd_net_field_length_ll()
165 (*packet)++; in php_mysqlnd_net_field_length_ll()
171 (*packet)++; in php_mysqlnd_net_field_length_ll()
174 (*packet) += 3; in php_mysqlnd_net_field_length_ll()
177 (*packet) += 4; in php_mysqlnd_net_field_length_ll()
180 (*packet) += 9; in php_mysqlnd_net_field_length_ll()
189 php_mysqlnd_net_store_length(zend_uchar *packet, uint64_t length) in php_mysqlnd_net_store_length() argument
192 *packet = (zend_uchar) length; in php_mysqlnd_net_store_length()
193 return packet + 1; in php_mysqlnd_net_store_length()
197 *packet++ = 252; in php_mysqlnd_net_store_length()
198 int2store(packet,(unsigned int) length); in php_mysqlnd_net_store_length()
199 return packet + 2; in php_mysqlnd_net_store_length()
203 *packet++ = 253; in php_mysqlnd_net_store_length()
204 int3store(packet,(ulong) length); in php_mysqlnd_net_store_length()
205 return packet + 3; in php_mysqlnd_net_store_length()
207 *packet++ = 254; in php_mysqlnd_net_store_length()
208 int8store(packet, length); in php_mysqlnd_net_store_length()
209 return packet + 8; in php_mysqlnd_net_store_length()
308 MYSQLND_PACKET_GREET *packet= (MYSQLND_PACKET_GREET *) _packet; in php_mysqlnd_greet_read() local
312 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); in php_mysqlnd_greet_read()
315 packet->protocol_version = uint1korr(p); in php_mysqlnd_greet_read()
319 if (ERROR_MARKER == packet->protocol_version) { in php_mysqlnd_greet_read()
320 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_greet_read()
321 packet->error, sizeof(packet->error), in php_mysqlnd_greet_read()
322 &packet->error_no, packet->sqlstate in php_mysqlnd_greet_read()
329 if (packet->error_no == 1040) { in php_mysqlnd_greet_read()
330 memcpy(packet->sqlstate, "08004", MYSQLND_SQLSTATE_LENGTH); in php_mysqlnd_greet_read()
335 packet->server_version = estrdup((char *)p); in php_mysqlnd_greet_read()
336 p+= strlen(packet->server_version) + 1; /* eat the '\0' */ in php_mysqlnd_greet_read()
339 packet->thread_id = uint4korr(p); in php_mysqlnd_greet_read()
343 memcpy(packet->scramble_buf, p, SCRAMBLE_LENGTH_323); in php_mysqlnd_greet_read()
351 packet->server_capabilities = uint2korr(p); in php_mysqlnd_greet_read()
355 packet->charset_no = uint1korr(p); in php_mysqlnd_greet_read()
359 packet->server_status = uint2korr(p); in php_mysqlnd_greet_read()
367 if ((size_t) (p - buf) < packet->header.size) { in php_mysqlnd_greet_read()
369 memcpy(packet->scramble_buf + SCRAMBLE_LENGTH_323, in php_mysqlnd_greet_read()
372 packet->pre41 = TRUE; in php_mysqlnd_greet_read()
376 packet->protocol_version, packet->server_version, packet->thread_id); in php_mysqlnd_greet_read()
379 packet->server_capabilities, packet->charset_no, packet->server_status); in php_mysqlnd_greet_read()
383 DBG_ERR_FMT("GREET packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_greet_read()
385 p - begin - packet->header.size); in php_mysqlnd_greet_read()
458 register MYSQLND_PACKET_AUTH *packet= (MYSQLND_PACKET_AUTH *) _packet; in php_mysqlnd_auth_write() local
462 int4store(p, packet->client_flags); in php_mysqlnd_auth_write()
465 int4store(p, packet->max_packet_size); in php_mysqlnd_auth_write()
468 int1store(p, packet->charset_no); in php_mysqlnd_auth_write()
474 if (!packet->send_half_packet) { in php_mysqlnd_auth_write()
475 len = MIN(strlen(packet->user), MYSQLND_MAX_ALLOWED_USER_LEN); in php_mysqlnd_auth_write()
476 memcpy(p, packet->user, len); in php_mysqlnd_auth_write()
481 if (packet->password && packet->password[0]) { in php_mysqlnd_auth_write()
485 php_mysqlnd_scramble((zend_uchar*)p, packet->server_scramble_buf, (zend_uchar*)packet->password); in php_mysqlnd_auth_write()
493 if (packet->db) { in php_mysqlnd_auth_write()
494 size_t real_db_len = MIN(MYSQLND_MAX_ALLOWED_DB_LEN, packet->db_len); in php_mysqlnd_auth_write()
495 memcpy(p, packet->db, real_db_len); in php_mysqlnd_auth_write()
532 register MYSQLND_PACKET_OK *packet= (MYSQLND_PACKET_OK *) _packet; in php_mysqlnd_ok_read() local
536 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); in php_mysqlnd_ok_read()
540 packet->field_count = uint1korr(p); in php_mysqlnd_ok_read()
544 if (ERROR_MARKER == packet->field_count) { in php_mysqlnd_ok_read()
545 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_ok_read()
546 packet->error, sizeof(packet->error), in php_mysqlnd_ok_read()
547 &packet->error_no, packet->sqlstate in php_mysqlnd_ok_read()
552 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
555 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
558 packet->server_status = uint2korr(p); in php_mysqlnd_ok_read()
562 packet->warning_count = uint2korr(p); in php_mysqlnd_ok_read()
567 if (packet->header.size > (size_t) (p - buf) && (i = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_ok_read()
568 packet->message_len = MIN(i, buf_len - (p - begin)); in php_mysqlnd_ok_read()
569 packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); in php_mysqlnd_ok_read()
571 packet->message = NULL; in php_mysqlnd_ok_read()
572 packet->message_len = 0; in php_mysqlnd_ok_read()
576 packet->affected_rows, packet->last_insert_id, packet->server_status, in php_mysqlnd_ok_read()
577 packet->warning_count); in php_mysqlnd_ok_read()
583 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_ok_read()
585 p - begin - packet->header.size); in php_mysqlnd_ok_read()
617 MYSQLND_PACKET_EOF *packet= (MYSQLND_PACKET_EOF *) _packet; in php_mysqlnd_eof_read() local
625 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); in php_mysqlnd_eof_read()
629 packet->field_count = uint1korr(p); in php_mysqlnd_eof_read()
633 if (ERROR_MARKER == packet->field_count) { in php_mysqlnd_eof_read()
634 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_eof_read()
635 packet->error, sizeof(packet->error), in php_mysqlnd_eof_read()
636 &packet->error_no, packet->sqlstate in php_mysqlnd_eof_read()
646 if (packet->header.size > 1) { in php_mysqlnd_eof_read()
647 packet->warning_count = uint2korr(p); in php_mysqlnd_eof_read()
651 packet->server_status = uint2korr(p); in php_mysqlnd_eof_read()
655 packet->warning_count = 0; in php_mysqlnd_eof_read()
656 packet->server_status = 0; in php_mysqlnd_eof_read()
662 packet->field_count, packet->server_status, packet->warning_count); in php_mysqlnd_eof_read()
666 DBG_ERR_FMT("EOF packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_eof_read()
668 p - begin - packet->header.size); in php_mysqlnd_eof_read()
689 MYSQLND_PACKET_COMMAND *packet= (MYSQLND_PACKET_COMMAND *) _packet; in php_mysqlnd_cmd_write() local
709 net->m.consume_uneaten_data(net, packet->command TSRMLS_CC); in php_mysqlnd_cmd_write()
712 if (!packet->argument || !packet->arg_len) { in php_mysqlnd_cmd_write()
715 int1store(buffer + MYSQLND_HEADER_SIZE, packet->command); in php_mysqlnd_cmd_write()
718 size_t tmp_len = packet->arg_len + 1 + MYSQLND_HEADER_SIZE, ret; in php_mysqlnd_cmd_write()
726 int1store(p, packet->command); in php_mysqlnd_cmd_write()
729 memcpy(p, packet->argument, packet->arg_len); in php_mysqlnd_cmd_write()
770 MYSQLND_PACKET_RSET_HEADER *packet= (MYSQLND_PACKET_RSET_HEADER *) _packet; in php_mysqlnd_rset_header_read() local
774 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKE… in php_mysqlnd_rset_header_read()
785 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_header_read()
786 packet->error_info.error, sizeof(packet->error_info.error), in php_mysqlnd_rset_header_read()
787 &packet->error_info.error_no, packet->error_info.sqlstate in php_mysqlnd_rset_header_read()
792 packet->field_count = php_mysqlnd_net_field_length(&p); in php_mysqlnd_rset_header_read()
795 switch (packet->field_count) { in php_mysqlnd_rset_header_read()
805 len = packet->header.size - 1; in php_mysqlnd_rset_header_read()
806 packet->info_or_local_file = mnd_emalloc(len + 1); in php_mysqlnd_rset_header_read()
807 if (packet->info_or_local_file) { in php_mysqlnd_rset_header_read()
808 memcpy(packet->info_or_local_file, p, len); in php_mysqlnd_rset_header_read()
809 packet->info_or_local_file[len] = '\0'; in php_mysqlnd_rset_header_read()
810 packet->info_or_local_file_len = len; in php_mysqlnd_rset_header_read()
818 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
821 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
824 packet->server_status = uint2korr(p); in php_mysqlnd_rset_header_read()
828 packet->warning_count = uint2korr(p); in php_mysqlnd_rset_header_read()
832 if (packet->header.size > (size_t) (p - buf) && (len = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_rset_header_read()
833 packet->info_or_local_file = mnd_emalloc(len + 1); in php_mysqlnd_rset_header_read()
834 if (packet->info_or_local_file) { in php_mysqlnd_rset_header_read()
835 memcpy(packet->info_or_local_file, p, len); in php_mysqlnd_rset_header_read()
836 packet->info_or_local_file[len] = '\0'; in php_mysqlnd_rset_header_read()
837 packet->info_or_local_file_len = len; in php_mysqlnd_rset_header_read()
844 packet->affected_rows, packet->last_insert_id, in php_mysqlnd_rset_header_read()
845 packet->server_status, packet->warning_count); in php_mysqlnd_rset_header_read()
856 DBG_ERR_FMT("RSET_HEADER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
858 p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
903 MYSQLND_PACKET_RES_FIELD *packet= (MYSQLND_PACKET_RES_FIELD *) _packet; in php_mysqlnd_rset_field_read() local
915 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); in php_mysqlnd_rset_field_read()
917 if (packet->skip_parsing) { in php_mysqlnd_rset_field_read()
926 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_field_read()
927 packet->error_info.error, sizeof(packet->error_info.error), in php_mysqlnd_rset_field_read()
928 &packet->error_info.error_no, packet->error_info.sqlstate in php_mysqlnd_rset_field_read()
930 DBG_ERR_FMT("Server error : (%u) %s", packet->error_info.error_no, packet->error_info.error); in php_mysqlnd_rset_field_read()
932 } else if (EODATA_MARKER == *p && packet->header.size < 8) { in php_mysqlnd_rset_field_read()
935 packet->stupid_list_fields_eof = TRUE; in php_mysqlnd_rset_field_read()
939 meta = packet->metadata; in php_mysqlnd_rset_field_read()
1008 if (packet->header.size > (size_t) (p - buf) && in php_mysqlnd_rset_field_read()
1013 DBG_INF_FMT("Def found, length %lu, persistent=%u", len, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1014 meta->def = mnd_pemalloc(len + 1, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1025 DBG_INF_FMT("allocing root. persistent=%u", packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1026 root_ptr = meta->root = mnd_pemalloc(total_len, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1087 DBG_ERR_FMT("RSET field packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1089 "shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1534 MYSQLND_PACKET_ROW *packet= (MYSQLND_PACKET_ROW *) _packet; in php_mysqlnd_rowp_read() local
1540 if (!packet->binary_protocol && packet->bit_fields_count) { in php_mysqlnd_rowp_read()
1542 post_alloc_for_bit_fields = packet->bit_fields_total_len + packet->bit_fields_count; in php_mysqlnd_rowp_read()
1545 …ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_siz… in php_mysqlnd_rowp_read()
1546 packet->persistent_alloc, post_alloc_for_bit_fields in php_mysqlnd_rowp_read()
1552 MYSQLND_HEADER_SIZE + packet->header.size, in php_mysqlnd_rowp_read()
1557 packet->header.size = data_size; in php_mysqlnd_rowp_read()
1558 packet->row_buffer->app = data_size; in php_mysqlnd_rowp_read()
1560 if (ERROR_MARKER == (*(p = packet->row_buffer->ptr))) { in php_mysqlnd_rowp_read()
1568 packet->error_info.error, in php_mysqlnd_rowp_read()
1569 sizeof(packet->error_info.error), in php_mysqlnd_rowp_read()
1570 &packet->error_info.error_no, in php_mysqlnd_rowp_read()
1571 packet->error_info.sqlstate in php_mysqlnd_rowp_read()
1574 packet->eof = TRUE; in php_mysqlnd_rowp_read()
1577 packet->warning_count = uint2korr(p); in php_mysqlnd_rowp_read()
1579 packet->server_status = uint2korr(p); in php_mysqlnd_rowp_read()
1581 DBG_INF_FMT("server_status=%u warning_count=%u", packet->server_status, packet->warning_count); in php_mysqlnd_rowp_read()
1585 packet->binary_protocol? STAT_ROWS_FETCHED_FROM_SERVER_PS: in php_mysqlnd_rowp_read()
1588 packet->eof = FALSE; in php_mysqlnd_rowp_read()
1591 if (!packet->skip_extraction) { in php_mysqlnd_rowp_read()
1592 if (!packet->fields) { in php_mysqlnd_rowp_read()
1604 packet->fields = (zval **) mnd_pecalloc(packet->field_count, sizeof(zval *), in php_mysqlnd_rowp_read()
1605 packet->persistent_alloc); in php_mysqlnd_rowp_read()
1609 packet->binary_protocol? STAT_ROWS_SKIPPED_PS: in php_mysqlnd_rowp_read()
1653 MYSQLND_PACKET_STATS *packet= (MYSQLND_PACKET_STATS *) _packet; in php_mysqlnd_stats_read() local
1659 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); in php_mysqlnd_stats_read()
1661 packet->message = mnd_emalloc(packet->header.size + 1); in php_mysqlnd_stats_read()
1662 memcpy(packet->message, buf, packet->header.size); in php_mysqlnd_stats_read()
1663 packet->message[packet->header.size] = '\0'; in php_mysqlnd_stats_read()
1664 packet->message_len = packet->header.size; in php_mysqlnd_stats_read()
1701 MYSQLND_PACKET_PREPARE_RESPONSE *packet= (MYSQLND_PACKET_PREPARE_RESPONSE *) _packet; in php_mysqlnd_prepare_read() local
1705 PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); in php_mysqlnd_prepare_read()
1708 data_size = packet->header.size; in php_mysqlnd_prepare_read()
1709 packet->error_code = uint1korr(p); in php_mysqlnd_prepare_read()
1713 if (ERROR_MARKER == packet->error_code) { in php_mysqlnd_prepare_read()
1715 packet->error_info.error, in php_mysqlnd_prepare_read()
1716 sizeof(packet->error_info.error), in php_mysqlnd_prepare_read()
1717 &packet->error_info.error_no, in php_mysqlnd_prepare_read()
1718 packet->error_info.sqlstate in php_mysqlnd_prepare_read()
1731 packet->stmt_id = uint4korr(p); in php_mysqlnd_prepare_read()
1736 packet->field_count = uint2korr(p); in php_mysqlnd_prepare_read()
1740 packet->param_count = uint2korr(p); in php_mysqlnd_prepare_read()
1749 packet->warning_count = uint2korr(p); in php_mysqlnd_prepare_read()
1753 packet->stmt_id, packet->field_count, packet->param_count); in php_mysqlnd_prepare_read()
1759 DBG_ERR_FMT("PREPARE packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_prepare_read()
1761 p - begin - packet->header.size); in php_mysqlnd_prepare_read()
1788 MYSQLND_PACKET_CHG_USER_RESPONSE *packet= (MYSQLND_PACKET_CHG_USER_RESPONSE *) _packet; in php_mysqlnd_chg_user_read() local
1792 …PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP… in php_mysqlnd_chg_user_read()
1801 packet->field_count= uint1korr(p); in php_mysqlnd_chg_user_read()
1804 …if (packet->header.size == 1 && buf[0] == EODATA_MARKER && packet->server_capabilities & CLIENT_SE… in php_mysqlnd_chg_user_read()
1806 packet->server_asked_323_auth = TRUE; in php_mysqlnd_chg_user_read()
1810 if (ERROR_MARKER == packet->field_count) { in php_mysqlnd_chg_user_read()
1811 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_chg_user_read()
1812 packet->error_info.error, in php_mysqlnd_chg_user_read()
1813 sizeof(packet->error_info.error), in php_mysqlnd_chg_user_read()
1814 &packet->error_info.error_no, in php_mysqlnd_chg_user_read()
1815 packet->error_info.sqlstate in php_mysqlnd_chg_user_read()
1822 DBG_ERR_FMT("CHANGE_USER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
1824 p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
1919 …struct st_mysqlnd_packet_greet * packet = mnd_pecalloc(1, packet_methods[PROT_GREET_PACKET].struct… in MYSQLND_METHOD() local
1921 if (packet) { in MYSQLND_METHOD()
1922 packet->header.m = &packet_methods[PROT_GREET_PACKET]; in MYSQLND_METHOD()
1923 packet->header.persistent = persistent; in MYSQLND_METHOD()
1925 DBG_RETURN(packet); in MYSQLND_METHOD()
1934 …struct st_mysqlnd_packet_auth * packet = mnd_pecalloc(1, packet_methods[PROT_AUTH_PACKET].struct_s… in MYSQLND_METHOD() local
1936 if (packet) { in MYSQLND_METHOD()
1937 packet->header.m = &packet_methods[PROT_AUTH_PACKET]; in MYSQLND_METHOD()
1938 packet->header.persistent = persistent; in MYSQLND_METHOD()
1940 DBG_RETURN(packet); in MYSQLND_METHOD()
1949 …struct st_mysqlnd_packet_ok * packet = mnd_pecalloc(1, packet_methods[PROT_OK_PACKET].struct_size,… in MYSQLND_METHOD() local
1951 if (packet) { in MYSQLND_METHOD()
1952 packet->header.m = &packet_methods[PROT_OK_PACKET]; in MYSQLND_METHOD()
1953 packet->header.persistent = persistent; in MYSQLND_METHOD()
1955 DBG_RETURN(packet); in MYSQLND_METHOD()
1964 …struct st_mysqlnd_packet_eof * packet = mnd_pecalloc(1, packet_methods[PROT_EOF_PACKET].struct_siz… in MYSQLND_METHOD() local
1966 if (packet) { in MYSQLND_METHOD()
1967 packet->header.m = &packet_methods[PROT_EOF_PACKET]; in MYSQLND_METHOD()
1968 packet->header.persistent = persistent; in MYSQLND_METHOD()
1970 DBG_RETURN(packet); in MYSQLND_METHOD()
1979 …struct st_mysqlnd_packet_command * packet = mnd_pecalloc(1, packet_methods[PROT_CMD_PACKET].struct… in MYSQLND_METHOD() local
1981 if (packet) { in MYSQLND_METHOD()
1982 packet->header.m = &packet_methods[PROT_CMD_PACKET]; in MYSQLND_METHOD()
1983 packet->header.persistent = persistent; in MYSQLND_METHOD()
1985 DBG_RETURN(packet); in MYSQLND_METHOD()
1994 …struct st_mysqlnd_packet_rset_header * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_HEADER_PA… in MYSQLND_METHOD() local
1996 if (packet) { in MYSQLND_METHOD()
1997 packet->header.m = &packet_methods[PROT_RSET_HEADER_PACKET]; in MYSQLND_METHOD()
1998 packet->header.persistent = persistent; in MYSQLND_METHOD()
2000 DBG_RETURN(packet); in MYSQLND_METHOD()
2009 …struct st_mysqlnd_packet_res_field * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_FLD_PACKET]… in MYSQLND_METHOD() local
2011 if (packet) { in MYSQLND_METHOD()
2012 packet->header.m = &packet_methods[PROT_RSET_FLD_PACKET]; in MYSQLND_METHOD()
2013 packet->header.persistent = persistent; in MYSQLND_METHOD()
2015 DBG_RETURN(packet); in MYSQLND_METHOD()
2024 …struct st_mysqlnd_packet_row * packet = mnd_pecalloc(1, packet_methods[PROT_ROW_PACKET].struct_siz… in MYSQLND_METHOD() local
2026 if (packet) { in MYSQLND_METHOD()
2027 packet->header.m = &packet_methods[PROT_ROW_PACKET]; in MYSQLND_METHOD()
2028 packet->header.persistent = persistent; in MYSQLND_METHOD()
2030 DBG_RETURN(packet); in MYSQLND_METHOD()
2039 …struct st_mysqlnd_packet_stats * packet = mnd_pecalloc(1, packet_methods[PROT_STATS_PACKET].struct… in MYSQLND_METHOD() local
2041 if (packet) { in MYSQLND_METHOD()
2042 packet->header.m = &packet_methods[PROT_STATS_PACKET]; in MYSQLND_METHOD()
2043 packet->header.persistent = persistent; in MYSQLND_METHOD()
2045 DBG_RETURN(packet); in MYSQLND_METHOD()
2054 …struct st_mysqlnd_packet_prepare_response * packet = mnd_pecalloc(1, packet_methods[PROT_PREPARE_R… in MYSQLND_METHOD() local
2056 if (packet) { in MYSQLND_METHOD()
2057 packet->header.m = &packet_methods[PROT_PREPARE_RESP_PACKET]; in MYSQLND_METHOD()
2058 packet->header.persistent = persistent; in MYSQLND_METHOD()
2060 DBG_RETURN(packet); in MYSQLND_METHOD()
2069 …struct st_mysqlnd_packet_chg_user_resp * packet = mnd_pecalloc(1, packet_methods[PROT_CHG_USER_RES… in MYSQLND_METHOD() local
2071 if (packet) { in MYSQLND_METHOD()
2072 packet->header.m = &packet_methods[PROT_CHG_USER_RESP_PACKET]; in MYSQLND_METHOD()
2073 packet->header.persistent = persistent; in MYSQLND_METHOD()
2075 DBG_RETURN(packet); in MYSQLND_METHOD()
