Lines Matching refs:packet
30 if ((size_t)(p - begin) > packet->header.size) { \
95 php_mysqlnd_net_field_length(const zend_uchar **packet) in php_mysqlnd_net_field_length() argument
97 register const zend_uchar *p= (const zend_uchar *)*packet; in php_mysqlnd_net_field_length()
100 (*packet)++; in php_mysqlnd_net_field_length()
106 (*packet)++; in php_mysqlnd_net_field_length()
109 (*packet) += 3; in php_mysqlnd_net_field_length()
112 (*packet) += 4; in php_mysqlnd_net_field_length()
115 (*packet) += 9; in php_mysqlnd_net_field_length()
125 php_mysqlnd_net_field_length_ll(const zend_uchar **packet) in php_mysqlnd_net_field_length_ll() argument
127 register const zend_uchar *p = (zend_uchar *)*packet; in php_mysqlnd_net_field_length_ll()
130 (*packet)++; in php_mysqlnd_net_field_length_ll()
136 (*packet)++; in php_mysqlnd_net_field_length_ll()
139 (*packet) += 3; in php_mysqlnd_net_field_length_ll()
142 (*packet) += 4; in php_mysqlnd_net_field_length_ll()
145 (*packet) += 9; in php_mysqlnd_net_field_length_ll()
154 php_mysqlnd_net_store_length(zend_uchar *packet, const uint64_t length) in php_mysqlnd_net_store_length() argument
157 *packet = (zend_uchar) length; in php_mysqlnd_net_store_length()
158 return packet + 1; in php_mysqlnd_net_store_length()
162 *packet++ = 252; in php_mysqlnd_net_store_length()
163 int2store(packet,(unsigned int) length); in php_mysqlnd_net_store_length()
164 return packet + 2; in php_mysqlnd_net_store_length()
168 *packet++ = 253; in php_mysqlnd_net_store_length()
169 int3store(packet,(zend_ulong) length); in php_mysqlnd_net_store_length()
170 return packet + 3; in php_mysqlnd_net_store_length()
172 *packet++ = 254; in php_mysqlnd_net_store_length()
173 int8store(packet, length); in php_mysqlnd_net_store_length()
174 return packet + 8; in php_mysqlnd_net_store_length()
331 MYSQLND_PACKET_GREET *packet= (MYSQLND_PACKET_GREET *) _packet; in php_mysqlnd_greet_read() local
332 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_greet_read()
333 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_greet_read()
334 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_greet_read()
335 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_greet_read()
336 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_greet_read()
340 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_greet_read()
345 packet->authentication_plugin_data.s = packet->intern_auth_plugin_data; in php_mysqlnd_greet_read()
346 packet->authentication_plugin_data.l = sizeof(packet->intern_auth_plugin_data); in php_mysqlnd_greet_read()
348 if (packet->header.size < sizeof(buf)) { in php_mysqlnd_greet_read()
353 buf[packet->header.size] = '\0'; in php_mysqlnd_greet_read()
356 packet->protocol_version = uint1korr(p); in php_mysqlnd_greet_read()
360 if (ERROR_MARKER == packet->protocol_version) { in php_mysqlnd_greet_read()
361 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_greet_read()
362 packet->error, sizeof(packet->error), in php_mysqlnd_greet_read()
363 &packet->error_no, packet->sqlstate in php_mysqlnd_greet_read()
370 if (packet->error_no == 1040) { in php_mysqlnd_greet_read()
371 memcpy(packet->sqlstate, "08004", MYSQLND_SQLSTATE_LENGTH); in php_mysqlnd_greet_read()
376 packet->server_version = estrdup((char *)p); in php_mysqlnd_greet_read()
377 p+= strlen(packet->server_version) + 1; /* eat the '\0' */ in php_mysqlnd_greet_read()
380 packet->thread_id = uint4korr(p); in php_mysqlnd_greet_read()
384 memcpy(packet->authentication_plugin_data.s, p, SCRAMBLE_LENGTH_323); in php_mysqlnd_greet_read()
392 packet->server_capabilities = uint2korr(p); in php_mysqlnd_greet_read()
396 packet->charset_no = uint1korr(p); in php_mysqlnd_greet_read()
400 packet->server_status = uint2korr(p); in php_mysqlnd_greet_read()
409 if ((size_t) (p - buf) < packet->header.size) { in php_mysqlnd_greet_read()
411 …memcpy(packet->authentication_plugin_data.s + SCRAMBLE_LENGTH_323, p, SCRAMBLE_LENGTH - SCRAMBLE_L… in php_mysqlnd_greet_read()
415 packet->pre41 = TRUE; in php_mysqlnd_greet_read()
419 if ((size_t) (p - buf) < packet->header.size) { in php_mysqlnd_greet_read()
424 packet->server_capabilities |= uint2korr(pad_start) << 16; in php_mysqlnd_greet_read()
426 packet->authentication_plugin_data.l = uint1korr(pad_start + 2); in php_mysqlnd_greet_read()
427 if (packet->authentication_plugin_data.l > SCRAMBLE_LENGTH) { in php_mysqlnd_greet_read()
429 char * new_auth_plugin_data = emalloc(packet->authentication_plugin_data.l); in php_mysqlnd_greet_read()
434 memcpy(new_auth_plugin_data, packet->authentication_plugin_data.s, SCRAMBLE_LENGTH); in php_mysqlnd_greet_read()
436 …memcpy(new_auth_plugin_data + SCRAMBLE_LENGTH, p, packet->authentication_plugin_data.l - SCRAMBLE_… in php_mysqlnd_greet_read()
437 p+= (packet->authentication_plugin_data.l - SCRAMBLE_LENGTH); in php_mysqlnd_greet_read()
438 packet->authentication_plugin_data.s = new_auth_plugin_data; in php_mysqlnd_greet_read()
442 if (packet->server_capabilities & CLIENT_PLUGIN_AUTH) { in php_mysqlnd_greet_read()
445 packet->auth_protocol = estrdup((char *)p); in php_mysqlnd_greet_read()
446 p+= strlen(packet->auth_protocol) + 1; /* eat the '\0' */ in php_mysqlnd_greet_read()
450 packet->protocol_version, packet->server_version, packet->thread_id); in php_mysqlnd_greet_read()
453 packet->server_capabilities, packet->charset_no, packet->server_status, in php_mysqlnd_greet_read()
454 packet->auth_protocol? packet->auth_protocol:"n/a", packet->authentication_plugin_data.l); in php_mysqlnd_greet_read()
458 DBG_ERR_FMT("GREET packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_greet_read()
460 p - begin - packet->header.size); in php_mysqlnd_greet_read()
499 MYSQLND_PACKET_AUTH * packet= (MYSQLND_PACKET_AUTH *) _packet; in php_mysqlnd_auth_write() local
500 MYSQLND_CONN_DATA * conn = packet->header.conn; in php_mysqlnd_auth_write()
501 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_auth_write()
502 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_auth_write()
503 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_auth_write()
504 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_auth_write()
505 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_auth_write()
509 if (!packet->is_change_user_packet) { in php_mysqlnd_auth_write()
510 int4store(p, packet->client_flags); in php_mysqlnd_auth_write()
513 int4store(p, packet->max_packet_size); in php_mysqlnd_auth_write()
516 int1store(p, packet->charset_no); in php_mysqlnd_auth_write()
523 if (packet->send_auth_data || packet->is_change_user_packet) { in php_mysqlnd_auth_write()
524 len = MIN(strlen(packet->user), MYSQLND_MAX_ALLOWED_USER_LEN); in php_mysqlnd_auth_write()
525 memcpy(p, packet->user, len); in php_mysqlnd_auth_write()
530 if (packet->auth_data == NULL) { in php_mysqlnd_auth_write()
531 packet->auth_data_len = 0; in php_mysqlnd_auth_write()
533 if (packet->auth_data_len > 0xFF) { in php_mysqlnd_auth_write()
541 int1store(p, packet->auth_data_len); in php_mysqlnd_auth_write()
544 if (sizeof(buffer) < (packet->auth_data_len + (p - buffer))) { in php_mysqlnd_auth_write()
548 if (packet->auth_data_len) { in php_mysqlnd_auth_write()
549 memcpy(p, packet->auth_data, packet->auth_data_len); in php_mysqlnd_auth_write()
550 p+= packet->auth_data_len; in php_mysqlnd_auth_write()
553 if (packet->db) { in php_mysqlnd_auth_write()
555 size_t real_db_len = MIN(MYSQLND_MAX_ALLOWED_DB_LEN, packet->db_len); in php_mysqlnd_auth_write()
556 memcpy(p, packet->db, real_db_len); in php_mysqlnd_auth_write()
559 } else if (packet->is_change_user_packet) { in php_mysqlnd_auth_write()
564 if (packet->is_change_user_packet) { in php_mysqlnd_auth_write()
565 if (packet->charset_no) { in php_mysqlnd_auth_write()
566 int2store(p, packet->charset_no); in php_mysqlnd_auth_write()
571 if (packet->auth_plugin_name) { in php_mysqlnd_auth_write()
572 len = MIN(strlen(packet->auth_plugin_name), sizeof(buffer) - (p - buffer) - 1); in php_mysqlnd_auth_write()
573 memcpy(p, packet->auth_plugin_name, len); in php_mysqlnd_auth_write()
578 if (packet->connect_attr && zend_hash_num_elements(packet->connect_attr)) { in php_mysqlnd_auth_write()
584 ZEND_HASH_FOREACH_STR_KEY_VAL(packet->connect_attr, key, entry_value) { in php_mysqlnd_auth_write()
602 ZEND_HASH_FOREACH_STR_KEY_VAL(packet->connect_attr, key, entry_value) { in php_mysqlnd_auth_write()
622 if (packet->is_change_user_packet) { in php_mysqlnd_auth_write()
625 const unsigned int silent = packet->silent; in php_mysqlnd_auth_write()
662 register MYSQLND_PACKET_AUTH_RESPONSE * packet= (MYSQLND_PACKET_AUTH_RESPONSE *) _packet; in php_mysqlnd_auth_response_read() local
663 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_auth_response_read()
664 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_auth_response_read()
665 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_auth_response_read()
666 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_auth_response_read()
667 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_auth_response_read()
678 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_auth_response_read()
687 buf[packet->header.size] = '\0'; in php_mysqlnd_auth_response_read()
690 packet->response_code = uint1korr(p); in php_mysqlnd_auth_response_read()
694 if (ERROR_MARKER == packet->response_code) { in php_mysqlnd_auth_response_read()
695 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_auth_response_read()
696 packet->error, sizeof(packet->error), in php_mysqlnd_auth_response_read()
697 &packet->error_no, packet->sqlstate in php_mysqlnd_auth_response_read()
701 if (0xFE == packet->response_code) { in php_mysqlnd_auth_response_read()
703 if (packet->header.size > (size_t) (p - buf)) { in php_mysqlnd_auth_response_read()
704 packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); in php_mysqlnd_auth_response_read()
705 packet->new_auth_protocol_len = strlen(packet->new_auth_protocol); in php_mysqlnd_auth_response_read()
706 p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ in php_mysqlnd_auth_response_read()
708 packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); in php_mysqlnd_auth_response_read()
709 if (packet->new_auth_protocol_data_len) { in php_mysqlnd_auth_response_read()
710 packet->new_auth_protocol_data = mnd_emalloc(packet->new_auth_protocol_data_len); in php_mysqlnd_auth_response_read()
711 memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); in php_mysqlnd_auth_response_read()
713 DBG_INF_FMT("The server requested switching auth plugin to : %s", packet->new_auth_protocol); in php_mysqlnd_auth_response_read()
714 …_INF_FMT("Server salt : [%d][%.*s]", packet->new_auth_protocol_data_len, packet->new_auth_protocol… in php_mysqlnd_auth_response_read()
719 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_auth_response_read()
722 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_auth_response_read()
725 packet->server_status = uint2korr(p); in php_mysqlnd_auth_response_read()
729 packet->warning_count = uint2korr(p); in php_mysqlnd_auth_response_read()
734 if (packet->header.size > (size_t) (p - buf) && (net_len = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_auth_response_read()
735 packet->message_len = MIN(net_len, buf_len - (p - begin)); in php_mysqlnd_auth_response_read()
736 packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); in php_mysqlnd_auth_response_read()
738 packet->message = NULL; in php_mysqlnd_auth_response_read()
739 packet->message_len = 0; in php_mysqlnd_auth_response_read()
743 packet->affected_rows, packet->last_insert_id, packet->server_status, in php_mysqlnd_auth_response_read()
744 packet->warning_count); in php_mysqlnd_auth_response_read()
749 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_auth_response_read()
751 p - begin - packet->header.size); in php_mysqlnd_auth_response_read()
789 MYSQLND_PACKET_CHANGE_AUTH_RESPONSE *packet= (MYSQLND_PACKET_CHANGE_AUTH_RESPONSE *) _packet; in php_mysqlnd_change_auth_response_write() local
790 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_change_auth_response_write()
791 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_change_auth_response_write()
792 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_change_auth_response_write()
793 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_change_auth_response_write()
794 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_change_auth_response_write()
795 …uchar * buffer = pfc->cmd_buffer.length >= packet->auth_data_len? pfc->cmd_buffer.buffer : mnd_ema… in php_mysqlnd_change_auth_response_write()
800 if (packet->auth_data_len) { in php_mysqlnd_change_auth_response_write()
801 memcpy(p, packet->auth_data, packet->auth_data_len); in php_mysqlnd_change_auth_response_write()
802 p+= packet->auth_data_len; in php_mysqlnd_change_auth_response_write()
837 register MYSQLND_PACKET_OK *packet= (MYSQLND_PACKET_OK *) _packet; in php_mysqlnd_ok_read() local
838 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_ok_read()
839 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_ok_read()
840 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_ok_read()
841 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_ok_read()
842 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_ok_read()
852 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_ok_read()
858 packet->field_count = uint1korr(p); in php_mysqlnd_ok_read()
862 if (ERROR_MARKER == packet->field_count) { in php_mysqlnd_ok_read()
863 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_ok_read()
864 packet->error, sizeof(packet->error), in php_mysqlnd_ok_read()
865 &packet->error_no, packet->sqlstate in php_mysqlnd_ok_read()
870 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
873 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
876 packet->server_status = uint2korr(p); in php_mysqlnd_ok_read()
880 packet->warning_count = uint2korr(p); in php_mysqlnd_ok_read()
885 if (packet->header.size > (size_t) (p - buf) && (net_len = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_ok_read()
886 packet->message_len = MIN(net_len, buf_len - (p - begin)); in php_mysqlnd_ok_read()
887 packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); in php_mysqlnd_ok_read()
889 packet->message = NULL; in php_mysqlnd_ok_read()
890 packet->message_len = 0; in php_mysqlnd_ok_read()
894 packet->affected_rows, packet->last_insert_id, packet->server_status, in php_mysqlnd_ok_read()
895 packet->warning_count); in php_mysqlnd_ok_read()
901 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_ok_read()
903 p - begin - packet->header.size); in php_mysqlnd_ok_read()
935 MYSQLND_PACKET_EOF *packet= (MYSQLND_PACKET_EOF *) _packet; in php_mysqlnd_eof_read() local
936 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_eof_read()
937 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_eof_read()
938 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_eof_read()
939 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_eof_read()
940 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_eof_read()
948 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_eof_read()
954 packet->field_count = uint1korr(p); in php_mysqlnd_eof_read()
958 if (ERROR_MARKER == packet->field_count) { in php_mysqlnd_eof_read()
959 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_eof_read()
960 packet->error, sizeof(packet->error), in php_mysqlnd_eof_read()
961 &packet->error_no, packet->sqlstate in php_mysqlnd_eof_read()
971 if (packet->header.size > 1) { in php_mysqlnd_eof_read()
972 packet->warning_count = uint2korr(p); in php_mysqlnd_eof_read()
976 packet->server_status = uint2korr(p); in php_mysqlnd_eof_read()
980 packet->warning_count = 0; in php_mysqlnd_eof_read()
981 packet->server_status = 0; in php_mysqlnd_eof_read()
987 packet->field_count, packet->server_status, packet->warning_count); in php_mysqlnd_eof_read()
991 DBG_ERR_FMT("EOF packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_eof_read()
993 p - begin - packet->header.size); in php_mysqlnd_eof_read()
1014 MYSQLND_PACKET_COMMAND * packet= (MYSQLND_PACKET_COMMAND *) _packet; in php_mysqlnd_cmd_write() local
1015 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_cmd_write()
1016 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_cmd_write()
1017 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_cmd_write()
1018 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_cmd_write()
1019 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_cmd_write()
1037 vio->data->m.consume_uneaten_data(vio, packet->command); in php_mysqlnd_cmd_write()
1040 if (!packet->argument.s || !packet->argument.l) { in php_mysqlnd_cmd_write()
1043 int1store(buffer + MYSQLND_HEADER_SIZE, packet->command); in php_mysqlnd_cmd_write()
1046 size_t tmp_len = packet->argument.l + 1 + MYSQLND_HEADER_SIZE; in php_mysqlnd_cmd_write()
1054 int1store(p, packet->command); in php_mysqlnd_cmd_write()
1057 memcpy(p, packet->argument.s, packet->argument.l); in php_mysqlnd_cmd_write()
1094 MYSQLND_PACKET_RSET_HEADER * packet= (MYSQLND_PACKET_RSET_HEADER *) _packet; in php_mysqlnd_rset_header_read() local
1095 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_rset_header_read()
1096 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_rset_header_read()
1097 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_rset_header_read()
1098 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_rset_header_read()
1099 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_rset_header_read()
1109 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_rset_header_read()
1122 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_header_read()
1123 packet->error_info.error, sizeof(packet->error_info.error), in php_mysqlnd_rset_header_read()
1124 &packet->error_info.error_no, packet->error_info.sqlstate in php_mysqlnd_rset_header_read()
1129 packet->field_count = php_mysqlnd_net_field_length(&p); in php_mysqlnd_rset_header_read()
1132 switch (packet->field_count) { in php_mysqlnd_rset_header_read()
1142 len = packet->header.size - 1; in php_mysqlnd_rset_header_read()
1143 packet->info_or_local_file.s = mnd_emalloc(len + 1); in php_mysqlnd_rset_header_read()
1144 if (packet->info_or_local_file.s) { in php_mysqlnd_rset_header_read()
1145 memcpy(packet->info_or_local_file.s, p, len); in php_mysqlnd_rset_header_read()
1146 packet->info_or_local_file.s[len] = '\0'; in php_mysqlnd_rset_header_read()
1147 packet->info_or_local_file.l = len; in php_mysqlnd_rset_header_read()
1155 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
1158 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
1161 packet->server_status = uint2korr(p); in php_mysqlnd_rset_header_read()
1165 packet->warning_count = uint2korr(p); in php_mysqlnd_rset_header_read()
1169 if (packet->header.size > (size_t) (p - buf) && (len = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_rset_header_read()
1170 packet->info_or_local_file.s = mnd_emalloc(len + 1); in php_mysqlnd_rset_header_read()
1171 if (packet->info_or_local_file.s) { in php_mysqlnd_rset_header_read()
1172 memcpy(packet->info_or_local_file.s, p, len); in php_mysqlnd_rset_header_read()
1173 packet->info_or_local_file.s[len] = '\0'; in php_mysqlnd_rset_header_read()
1174 packet->info_or_local_file.l = len; in php_mysqlnd_rset_header_read()
1181 packet->affected_rows, packet->last_insert_id, in php_mysqlnd_rset_header_read()
1182 packet->server_status, packet->warning_count); in php_mysqlnd_rset_header_read()
1193 DBG_ERR_FMT("RSET_HEADER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
1195 p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
1240 MYSQLND_PACKET_RES_FIELD *packet = (MYSQLND_PACKET_RES_FIELD *) _packet; in php_mysqlnd_rset_field_read() local
1241 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_rset_field_read()
1242 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_rset_field_read()
1243 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_rset_field_read()
1244 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_rset_field_read()
1245 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_rset_field_read()
1257 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_rset_field_read()
1261 if (packet->skip_parsing) { in php_mysqlnd_rset_field_read()
1270 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_field_read()
1271 packet->error_info.error, sizeof(packet->error_info.error), in php_mysqlnd_rset_field_read()
1272 &packet->error_info.error_no, packet->error_info.sqlstate in php_mysqlnd_rset_field_read()
1274 DBG_ERR_FMT("Server error : (%u) %s", packet->error_info.error_no, packet->error_info.error); in php_mysqlnd_rset_field_read()
1276 } else if (EODATA_MARKER == *p && packet->header.size < 8) { in php_mysqlnd_rset_field_read()
1282 meta = packet->metadata; in php_mysqlnd_rset_field_read()
1352 if (packet->header.size > (size_t) (p - buf) && in php_mysqlnd_rset_field_read()
1357 DBG_INF_FMT("Def found, length %lu, persistent=%u", len, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1358 meta->def = mnd_pemalloc(len + 1, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1369 root_ptr = meta->root = mnd_pemalloc(total_len, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1378 meta->sname = zend_string_init(meta->name, meta->name_length, packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1421 DBG_INF_FMT("allocing root. persistent=%u", packet->persistent_alloc); in php_mysqlnd_rset_field_read()
1434 DBG_ERR_FMT("RSET field packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1436 "shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1817 MYSQLND_PACKET_ROW *packet= (MYSQLND_PACKET_ROW *) _packet; in php_mysqlnd_rowp_read() local
1818 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_rowp_read()
1819 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_rowp_read()
1820 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_rowp_read()
1821 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_rowp_read()
1829 packet->result_set_memory_pool, &packet->row_buffer, &data_size, in php_mysqlnd_rowp_read()
1830 packet->persistent_alloc); in php_mysqlnd_rowp_read()
1835 MYSQLND_HEADER_SIZE + packet->header.size, in php_mysqlnd_rowp_read()
1848 packet->header.size = data_size; in php_mysqlnd_rowp_read()
1849 packet->row_buffer->app = data_size; in php_mysqlnd_rowp_read()
1851 if (ERROR_MARKER == (*(p = packet->row_buffer->ptr))) { in php_mysqlnd_rowp_read()
1859 packet->error_info.error, in php_mysqlnd_rowp_read()
1860 sizeof(packet->error_info.error), in php_mysqlnd_rowp_read()
1861 &packet->error_info.error_no, in php_mysqlnd_rowp_read()
1862 packet->error_info.sqlstate in php_mysqlnd_rowp_read()
1865 packet->eof = TRUE; in php_mysqlnd_rowp_read()
1868 packet->warning_count = uint2korr(p); in php_mysqlnd_rowp_read()
1870 packet->server_status = uint2korr(p); in php_mysqlnd_rowp_read()
1872 DBG_INF_FMT("server_status=%u warning_count=%u", packet->server_status, packet->warning_count); in php_mysqlnd_rowp_read()
1876 packet->binary_protocol? STAT_ROWS_FETCHED_FROM_SERVER_PS: in php_mysqlnd_rowp_read()
1879 packet->eof = FALSE; in php_mysqlnd_rowp_read()
1882 if (!packet->skip_extraction) { in php_mysqlnd_rowp_read()
1883 if (!packet->fields) { in php_mysqlnd_rowp_read()
1895 packet->fields = mnd_pecalloc(packet->field_count, sizeof(zval), in php_mysqlnd_rowp_read()
1896 packet->persistent_alloc); in php_mysqlnd_rowp_read()
1900 packet->binary_protocol? STAT_ROWS_SKIPPED_PS: in php_mysqlnd_rowp_read()
1943 MYSQLND_PACKET_STATS *packet= (MYSQLND_PACKET_STATS *) _packet; in php_mysqlnd_stats_read() local
1944 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_stats_read()
1945 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_stats_read()
1946 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_stats_read()
1947 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_stats_read()
1948 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_stats_read()
1954 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_stats_read()
1958 packet->message.s = mnd_emalloc(packet->header.size + 1); in php_mysqlnd_stats_read()
1959 memcpy(packet->message.s, buf, packet->header.size); in php_mysqlnd_stats_read()
1960 packet->message.s[packet->header.size] = '\0'; in php_mysqlnd_stats_read()
1961 packet->message.l = packet->header.size; in php_mysqlnd_stats_read()
1992 MYSQLND_PACKET_PREPARE_RESPONSE *packet= (MYSQLND_PACKET_PREPARE_RESPONSE *) _packet; in php_mysqlnd_prepare_read() local
1993 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_prepare_read()
1994 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_prepare_read()
1995 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_prepare_read()
1996 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_prepare_read()
1997 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_prepare_read()
2007 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_prepare_read()
2012 data_size = packet->header.size; in php_mysqlnd_prepare_read()
2013 packet->error_code = uint1korr(p); in php_mysqlnd_prepare_read()
2017 if (ERROR_MARKER == packet->error_code) { in php_mysqlnd_prepare_read()
2019 packet->error_info.error, in php_mysqlnd_prepare_read()
2020 sizeof(packet->error_info.error), in php_mysqlnd_prepare_read()
2021 &packet->error_info.error_no, in php_mysqlnd_prepare_read()
2022 packet->error_info.sqlstate in php_mysqlnd_prepare_read()
2035 packet->stmt_id = uint4korr(p); in php_mysqlnd_prepare_read()
2040 packet->field_count = uint2korr(p); in php_mysqlnd_prepare_read()
2044 packet->param_count = uint2korr(p); in php_mysqlnd_prepare_read()
2053 packet->warning_count = uint2korr(p); in php_mysqlnd_prepare_read()
2057 packet->stmt_id, packet->field_count, packet->param_count); in php_mysqlnd_prepare_read()
2063 DBG_ERR_FMT("PREPARE packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_prepare_read()
2065 p - begin - packet->header.size); in php_mysqlnd_prepare_read()
2087 MYSQLND_PACKET_CHG_USER_RESPONSE *packet= (MYSQLND_PACKET_CHG_USER_RESPONSE *) _packet; in php_mysqlnd_chg_user_read() local
2088 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_chg_user_read()
2089 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_chg_user_read()
2090 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_chg_user_read()
2091 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_chg_user_read()
2092 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_chg_user_read()
2101 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_chg_user_read()
2112 packet->response_code = uint1korr(p); in php_mysqlnd_chg_user_read()
2115 …if (packet->header.size == 1 && buf[0] == EODATA_MARKER && packet->server_capabilities & CLIENT_SE… in php_mysqlnd_chg_user_read()
2117 packet->server_asked_323_auth = TRUE; in php_mysqlnd_chg_user_read()
2121 if (ERROR_MARKER == packet->response_code) { in php_mysqlnd_chg_user_read()
2122 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_chg_user_read()
2123 packet->error_info.error, in php_mysqlnd_chg_user_read()
2124 sizeof(packet->error_info.error), in php_mysqlnd_chg_user_read()
2125 &packet->error_info.error_no, in php_mysqlnd_chg_user_read()
2126 packet->error_info.sqlstate in php_mysqlnd_chg_user_read()
2130 if (packet->response_code == 0xFE && packet->header.size > (size_t) (p - buf)) { in php_mysqlnd_chg_user_read()
2131 packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); in php_mysqlnd_chg_user_read()
2132 packet->new_auth_protocol_len = strlen(packet->new_auth_protocol); in php_mysqlnd_chg_user_read()
2133 p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ in php_mysqlnd_chg_user_read()
2134 packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); in php_mysqlnd_chg_user_read()
2135 if (packet->new_auth_protocol_data_len) { in php_mysqlnd_chg_user_read()
2136 packet->new_auth_protocol_data = mnd_emalloc(packet->new_auth_protocol_data_len); in php_mysqlnd_chg_user_read()
2137 memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); in php_mysqlnd_chg_user_read()
2139 DBG_INF_FMT("The server requested switching auth plugin to : %s", packet->new_auth_protocol); in php_mysqlnd_chg_user_read()
2140 …DBG_INF_FMT("Server salt : [%*s]", packet->new_auth_protocol_data_len, packet->new_auth_protocol_d… in php_mysqlnd_chg_user_read()
2145 DBG_ERR_FMT("CHANGE_USER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
2147 p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
2182 MYSQLND_PACKET_SHA256_PK_REQUEST * packet = (MYSQLND_PACKET_SHA256_PK_REQUEST *) _packet; in php_mysqlnd_sha256_pk_request_write() local
2183 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_sha256_pk_request_write()
2184 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_sha256_pk_request_write()
2185 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_sha256_pk_request_write()
2186 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_sha256_pk_request_write()
2218 …MYSQLND_PACKET_SHA256_PK_REQUEST_RESPONSE * packet= (MYSQLND_PACKET_SHA256_PK_REQUEST_RESPONSE *) … in php_mysqlnd_sha256_pk_request_response_read() local
2219 MYSQLND_ERROR_INFO * error_info = packet->header.error_info; in php_mysqlnd_sha256_pk_request_response_read()
2220 MYSQLND_PFC * pfc = packet->header.protocol_frame_codec; in php_mysqlnd_sha256_pk_request_response_read()
2221 MYSQLND_VIO * vio = packet->header.vio; in php_mysqlnd_sha256_pk_request_response_read()
2222 MYSQLND_STATS * stats = packet->header.stats; in php_mysqlnd_sha256_pk_request_response_read()
2223 MYSQLND_CONNECTION_STATE * connection_state = packet->header.connection_state; in php_mysqlnd_sha256_pk_request_response_read()
2231 …if (FAIL == mysqlnd_read_packet_header_and_body(&(packet->header), pfc, vio, stats, error_info, co… in php_mysqlnd_sha256_pk_request_response_read()
2239 packet->public_key_len = packet->header.size - (p - buf); in php_mysqlnd_sha256_pk_request_response_read()
2240 packet->public_key = mnd_emalloc(packet->public_key_len + 1); in php_mysqlnd_sha256_pk_request_response_read()
2241 memcpy(packet->public_key, p, packet->public_key_len); in php_mysqlnd_sha256_pk_request_response_read()
2242 packet->public_key[packet->public_key_len] = '\0'; in php_mysqlnd_sha256_pk_request_response_read()
2247 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_sha256_pk_request_response_read()
2249 p - begin - packet->header.size); in php_mysqlnd_sha256_pk_request_response_read()
2375 …struct st_mysqlnd_packet_greet * packet = mnd_pecalloc(1, packet_methods[PROT_GREET_PACKET].struct… in MYSQLND_METHOD() local
2377 if (packet) { in MYSQLND_METHOD()
2378 packet->header.m = &packet_methods[PROT_GREET_PACKET]; in MYSQLND_METHOD()
2379 packet->header.factory = factory; in MYSQLND_METHOD()
2381 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2382 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2383 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2384 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2385 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2387 packet->header.persistent = persistent; in MYSQLND_METHOD()
2389 DBG_RETURN(packet); in MYSQLND_METHOD()
2398 …struct st_mysqlnd_packet_auth * packet = mnd_pecalloc(1, packet_methods[PROT_AUTH_PACKET].struct_s… in MYSQLND_METHOD() local
2400 if (packet) { in MYSQLND_METHOD()
2401 packet->header.m = &packet_methods[PROT_AUTH_PACKET]; in MYSQLND_METHOD()
2402 packet->header.factory = factory; in MYSQLND_METHOD()
2404 packet->header.conn = factory->conn; in MYSQLND_METHOD()
2405 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2406 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2407 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2408 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2409 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2411 packet->header.persistent = persistent; in MYSQLND_METHOD()
2413 DBG_RETURN(packet); in MYSQLND_METHOD()
2422 …struct st_mysqlnd_packet_auth_response * packet = mnd_pecalloc(1, packet_methods[PROT_AUTH_RESP_PA… in MYSQLND_METHOD() local
2424 if (packet) { in MYSQLND_METHOD()
2425 packet->header.m = &packet_methods[PROT_AUTH_RESP_PACKET]; in MYSQLND_METHOD()
2426 packet->header.factory = factory; in MYSQLND_METHOD()
2428 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2429 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2430 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2431 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2432 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2434 packet->header.persistent = persistent; in MYSQLND_METHOD()
2436 DBG_RETURN(packet); in MYSQLND_METHOD()
2445 …struct st_mysqlnd_packet_change_auth_response * packet = mnd_pecalloc(1, packet_methods[PROT_CHANG… in MYSQLND_METHOD() local
2447 if (packet) { in MYSQLND_METHOD()
2448 packet->header.m = &packet_methods[PROT_CHANGE_AUTH_RESP_PACKET]; in MYSQLND_METHOD()
2449 packet->header.factory = factory; in MYSQLND_METHOD()
2451 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2452 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2453 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2454 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2455 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2457 packet->header.persistent = persistent; in MYSQLND_METHOD()
2459 DBG_RETURN(packet); in MYSQLND_METHOD()
2468 …struct st_mysqlnd_packet_ok * packet = mnd_pecalloc(1, packet_methods[PROT_OK_PACKET].struct_size,… in MYSQLND_METHOD() local
2470 if (packet) { in MYSQLND_METHOD()
2471 packet->header.m = &packet_methods[PROT_OK_PACKET]; in MYSQLND_METHOD()
2472 packet->header.factory = factory; in MYSQLND_METHOD()
2474 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2475 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2476 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2477 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2478 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2480 packet->header.persistent = persistent; in MYSQLND_METHOD()
2482 DBG_RETURN(packet); in MYSQLND_METHOD()
2491 …struct st_mysqlnd_packet_eof * packet = mnd_pecalloc(1, packet_methods[PROT_EOF_PACKET].struct_siz… in MYSQLND_METHOD() local
2493 if (packet) { in MYSQLND_METHOD()
2494 packet->header.m = &packet_methods[PROT_EOF_PACKET]; in MYSQLND_METHOD()
2495 packet->header.factory = factory; in MYSQLND_METHOD()
2497 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2498 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2499 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2500 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2501 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2503 packet->header.persistent = persistent; in MYSQLND_METHOD()
2505 DBG_RETURN(packet); in MYSQLND_METHOD()
2514 …struct st_mysqlnd_packet_command * packet = mnd_pecalloc(1, packet_methods[PROT_CMD_PACKET].struct… in MYSQLND_METHOD() local
2516 if (packet) { in MYSQLND_METHOD()
2517 packet->header.m = &packet_methods[PROT_CMD_PACKET]; in MYSQLND_METHOD()
2518 packet->header.factory = factory; in MYSQLND_METHOD()
2520 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2521 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2522 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2523 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2524 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2526 packet->header.persistent = persistent; in MYSQLND_METHOD()
2528 DBG_RETURN(packet); in MYSQLND_METHOD()
2537 …struct st_mysqlnd_packet_rset_header * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_HEADER_PA… in MYSQLND_METHOD() local
2539 if (packet) { in MYSQLND_METHOD()
2540 packet->header.m = &packet_methods[PROT_RSET_HEADER_PACKET]; in MYSQLND_METHOD()
2541 packet->header.factory = factory; in MYSQLND_METHOD()
2543 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2544 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2545 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2546 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2547 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2549 packet->header.persistent = persistent; in MYSQLND_METHOD()
2551 DBG_RETURN(packet); in MYSQLND_METHOD()
2560 …struct st_mysqlnd_packet_res_field * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_FLD_PACKET]… in MYSQLND_METHOD() local
2562 if (packet) { in MYSQLND_METHOD()
2563 packet->header.m = &packet_methods[PROT_RSET_FLD_PACKET]; in MYSQLND_METHOD()
2564 packet->header.factory = factory; in MYSQLND_METHOD()
2566 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2567 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2568 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2569 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2570 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2572 packet->header.persistent = persistent; in MYSQLND_METHOD()
2574 DBG_RETURN(packet); in MYSQLND_METHOD()
2583 …struct st_mysqlnd_packet_row * packet = mnd_pecalloc(1, packet_methods[PROT_ROW_PACKET].struct_siz… in MYSQLND_METHOD() local
2585 if (packet) { in MYSQLND_METHOD()
2586 packet->header.m = &packet_methods[PROT_ROW_PACKET]; in MYSQLND_METHOD()
2587 packet->header.factory = factory; in MYSQLND_METHOD()
2589 packet->header.conn = factory->conn; in MYSQLND_METHOD()
2590 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2591 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2592 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2593 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2594 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2596 packet->header.persistent = persistent; in MYSQLND_METHOD()
2598 DBG_RETURN(packet); in MYSQLND_METHOD()
2607 …struct st_mysqlnd_packet_stats * packet = mnd_pecalloc(1, packet_methods[PROT_STATS_PACKET].struct… in MYSQLND_METHOD() local
2609 if (packet) { in MYSQLND_METHOD()
2610 packet->header.m = &packet_methods[PROT_STATS_PACKET]; in MYSQLND_METHOD()
2611 packet->header.factory = factory; in MYSQLND_METHOD()
2613 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2614 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2615 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2616 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2617 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2619 packet->header.persistent = persistent; in MYSQLND_METHOD()
2621 DBG_RETURN(packet); in MYSQLND_METHOD()
2630 …struct st_mysqlnd_packet_prepare_response * packet = mnd_pecalloc(1, packet_methods[PROT_PREPARE_R… in MYSQLND_METHOD() local
2632 if (packet) { in MYSQLND_METHOD()
2633 packet->header.m = &packet_methods[PROT_PREPARE_RESP_PACKET]; in MYSQLND_METHOD()
2634 packet->header.factory = factory; in MYSQLND_METHOD()
2636 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2637 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2638 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2639 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2640 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2642 packet->header.persistent = persistent; in MYSQLND_METHOD()
2644 DBG_RETURN(packet); in MYSQLND_METHOD()
2653 …struct st_mysqlnd_packet_chg_user_resp * packet = mnd_pecalloc(1, packet_methods[PROT_CHG_USER_RES… in MYSQLND_METHOD() local
2655 if (packet) { in MYSQLND_METHOD()
2656 packet->header.m = &packet_methods[PROT_CHG_USER_RESP_PACKET]; in MYSQLND_METHOD()
2657 packet->header.factory = factory; in MYSQLND_METHOD()
2659 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2660 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2661 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2662 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2663 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2665 packet->header.persistent = persistent; in MYSQLND_METHOD()
2667 DBG_RETURN(packet); in MYSQLND_METHOD()
2676 …struct st_mysqlnd_packet_sha256_pk_request * packet = mnd_pecalloc(1, packet_methods[PROT_SHA256_P… in MYSQLND_METHOD() local
2678 if (packet) { in MYSQLND_METHOD()
2679 packet->header.m = &packet_methods[PROT_SHA256_PK_REQUEST_PACKET]; in MYSQLND_METHOD()
2680 packet->header.factory = factory; in MYSQLND_METHOD()
2682 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2683 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2684 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2685 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2686 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2688 packet->header.persistent = persistent; in MYSQLND_METHOD()
2690 DBG_RETURN(packet); in MYSQLND_METHOD()
2699 …struct st_mysqlnd_packet_sha256_pk_request_response * packet = mnd_pecalloc(1, packet_methods[PROT… in MYSQLND_METHOD() local
2701 if (packet) { in MYSQLND_METHOD()
2702 packet->header.m = &packet_methods[PROT_SHA256_PK_REQUEST_RESPONSE_PACKET]; in MYSQLND_METHOD()
2703 packet->header.factory = factory; in MYSQLND_METHOD()
2705 packet->header.protocol_frame_codec = factory->conn->protocol_frame_codec; in MYSQLND_METHOD()
2706 packet->header.vio = factory->conn->vio; in MYSQLND_METHOD()
2707 packet->header.stats = factory->conn->stats; in MYSQLND_METHOD()
2708 packet->header.error_info = factory->conn->error_info; in MYSQLND_METHOD()
2709 packet->header.connection_state = &factory->conn->state; in MYSQLND_METHOD()
2711 packet->header.persistent = persistent; in MYSQLND_METHOD()
2713 DBG_RETURN(packet); in MYSQLND_METHOD()
