packet 35 ext/mysqlnd/mysqlnd_wireprotocol.c #define PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_size, packet_type_as_text, packet_type) \ packet 38 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == mysqlnd_read_header((conn)->net, &((packet)->header), (conn)->stats, ((conn)->error_info) TSRMLS_CC)) {\ packet 45 ext/mysqlnd/mysqlnd_wireprotocol.c if ((buf_size) < (packet)->header.size) { \ packet 47 ext/mysqlnd/mysqlnd_wireprotocol.c (buf_size), (packet)->header.size, (packet)->header.size - (buf_size)); \ packet 50 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == conn->net->data->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats, ((conn)->error_info) TSRMLS_CC)) { \ packet 58 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_HEADER_SIZE + (packet)->header.size, \ packet 65 ext/mysqlnd/mysqlnd_wireprotocol.c if ((size_t)(p - begin) > packet->header.size) { \ packet 132 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_net_field_length(zend_uchar **packet) packet 134 ext/mysqlnd/mysqlnd_wireprotocol.c register zend_uchar *p= (zend_uchar *)*packet; packet 137 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet)++; packet 143 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet)++; packet 146 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 3; packet 149 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 4; packet 152 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 9; packet 162 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_net_field_length_ll(zend_uchar **packet) packet 164 ext/mysqlnd/mysqlnd_wireprotocol.c register zend_uchar *p= (zend_uchar *)*packet; packet 167 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet)++; packet 173 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet)++; packet 176 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 3; packet 179 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 4; packet 182 ext/mysqlnd/mysqlnd_wireprotocol.c (*packet) += 9; packet 191 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_net_store_length(zend_uchar *packet, uint64_t length) packet 194 ext/mysqlnd/mysqlnd_wireprotocol.c *packet = (zend_uchar) length; packet 195 ext/mysqlnd/mysqlnd_wireprotocol.c return packet + 1; packet 199 ext/mysqlnd/mysqlnd_wireprotocol.c *packet++ = 252; packet 200 ext/mysqlnd/mysqlnd_wireprotocol.c int2store(packet,(unsigned int) length); packet 201 ext/mysqlnd/mysqlnd_wireprotocol.c return packet + 2; packet 205 ext/mysqlnd/mysqlnd_wireprotocol.c *packet++ = 253; packet 206 ext/mysqlnd/mysqlnd_wireprotocol.c int3store(packet,(ulong) length); packet 207 ext/mysqlnd/mysqlnd_wireprotocol.c return packet + 3; packet 209 ext/mysqlnd/mysqlnd_wireprotocol.c *packet++ = 254; packet 210 ext/mysqlnd/mysqlnd_wireprotocol.c int8store(packet, length); packet 211 ext/mysqlnd/mysqlnd_wireprotocol.c return packet + 8; packet 329 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_GREET *packet= (MYSQLND_PACKET_GREET *) _packet; packet 333 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); packet 336 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_plugin_data = packet->intern_auth_plugin_data; packet 337 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_plugin_data_len = sizeof(packet->intern_auth_plugin_data); packet 339 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size < sizeof(buf)) { packet 344 ext/mysqlnd/mysqlnd_wireprotocol.c buf[packet->header.size] = '\0'; packet 347 ext/mysqlnd/mysqlnd_wireprotocol.c packet->protocol_version = uint1korr(p); packet 351 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->protocol_version) { packet 352 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 353 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error, sizeof(packet->error), packet 354 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_no, packet->sqlstate packet 361 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->error_no == 1040) { packet 362 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->sqlstate, "08004", MYSQLND_SQLSTATE_LENGTH); packet 367 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_version = estrdup((char *)p); packet 368 ext/mysqlnd/mysqlnd_wireprotocol.c p+= strlen(packet->server_version) + 1; /* eat the '\0' */ packet 371 ext/mysqlnd/mysqlnd_wireprotocol.c packet->thread_id = uint4korr(p); packet 375 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->auth_plugin_data, p, SCRAMBLE_LENGTH_323); packet 383 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_capabilities = uint2korr(p); packet 387 ext/mysqlnd/mysqlnd_wireprotocol.c packet->charset_no = uint1korr(p); packet 391 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 400 ext/mysqlnd/mysqlnd_wireprotocol.c if ((size_t) (p - buf) < packet->header.size) { packet 402 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->auth_plugin_data + SCRAMBLE_LENGTH_323, p, SCRAMBLE_LENGTH - SCRAMBLE_LENGTH_323); packet 406 ext/mysqlnd/mysqlnd_wireprotocol.c packet->pre41 = TRUE; packet 410 ext/mysqlnd/mysqlnd_wireprotocol.c if ((size_t) (p - buf) < packet->header.size) { packet 415 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_capabilities |= uint2korr(pad_start) << 16; packet 417 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_plugin_data_len = uint1korr(pad_start + 2); packet 418 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_plugin_data_len > SCRAMBLE_LENGTH) { packet 420 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar * new_auth_plugin_data = emalloc(packet->auth_plugin_data_len); packet 425 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(new_auth_plugin_data, packet->auth_plugin_data, SCRAMBLE_LENGTH); packet 427 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(new_auth_plugin_data + SCRAMBLE_LENGTH, p, packet->auth_plugin_data_len - SCRAMBLE_LENGTH); packet 428 ext/mysqlnd/mysqlnd_wireprotocol.c p+= (packet->auth_plugin_data_len - SCRAMBLE_LENGTH); packet 429 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_plugin_data = new_auth_plugin_data; packet 433 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->server_capabilities & CLIENT_PLUGIN_AUTH) { packet 436 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_protocol = estrdup((char *)p); packet 437 ext/mysqlnd/mysqlnd_wireprotocol.c p+= strlen(packet->auth_protocol) + 1; /* eat the '\0' */ packet 441 ext/mysqlnd/mysqlnd_wireprotocol.c packet->protocol_version, packet->server_version, packet->thread_id); packet 444 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_capabilities, packet->charset_no, packet->server_status, packet 445 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_protocol? packet->auth_protocol:"n/a", packet->auth_plugin_data_len); packet 449 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("GREET packet %d bytes shorter than expected", p - begin - packet->header.size); packet 451 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 490 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_AUTH * packet= (MYSQLND_PACKET_AUTH *) _packet; packet 494 ext/mysqlnd/mysqlnd_wireprotocol.c if (!packet->is_change_user_packet) { packet 495 ext/mysqlnd/mysqlnd_wireprotocol.c int4store(p, packet->client_flags); packet 498 ext/mysqlnd/mysqlnd_wireprotocol.c int4store(p, packet->max_packet_size); packet 501 ext/mysqlnd/mysqlnd_wireprotocol.c int1store(p, packet->charset_no); packet 508 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->send_auth_data || packet->is_change_user_packet) { packet 509 ext/mysqlnd/mysqlnd_wireprotocol.c len = MIN(strlen(packet->user), MYSQLND_MAX_ALLOWED_USER_LEN); packet 510 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->user, len); packet 515 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_data == NULL) { packet 516 ext/mysqlnd/mysqlnd_wireprotocol.c packet->auth_data_len = 0; packet 518 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_data_len > 0xFF) { packet 526 ext/mysqlnd/mysqlnd_wireprotocol.c int1store(p, packet->auth_data_len); packet 529 ext/mysqlnd/mysqlnd_wireprotocol.c if ((sizeof(buffer) - (p - buffer)) < packet->auth_data_len) { packet 533 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_data_len) { packet 534 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->auth_data, packet->auth_data_len); packet 535 ext/mysqlnd/mysqlnd_wireprotocol.c p+= packet->auth_data_len; packet 538 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->db) { packet 540 ext/mysqlnd/mysqlnd_wireprotocol.c size_t real_db_len = MIN(MYSQLND_MAX_ALLOWED_DB_LEN, packet->db_len); packet 541 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->db, real_db_len); packet 544 ext/mysqlnd/mysqlnd_wireprotocol.c } else if (packet->is_change_user_packet) { packet 549 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->is_change_user_packet) { packet 550 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->charset_no) { packet 551 ext/mysqlnd/mysqlnd_wireprotocol.c int2store(p, packet->charset_no); packet 556 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_plugin_name) { packet 557 ext/mysqlnd/mysqlnd_wireprotocol.c size_t len = MIN(strlen(packet->auth_plugin_name), sizeof(buffer) - (p - buffer) - 1); packet 558 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->auth_plugin_name, len); packet 563 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->connect_attr && zend_hash_num_elements(packet->connect_attr)) { packet 567 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_internal_pointer_reset_ex(packet->connect_attr, &pos_value); packet 568 ext/mysqlnd/mysqlnd_wireprotocol.c while (SUCCESS == zend_hash_get_current_data_ex(packet->connect_attr, (void **)&entry_value, &pos_value)) { packet 574 ext/mysqlnd/mysqlnd_wireprotocol.c if (HASH_KEY_IS_STRING == zend_hash_get_current_key_ex(packet->connect_attr, &s_key, &s_len, &num_key, 0, &pos_value)) { packet 586 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_internal_pointer_reset_ex(packet->connect_attr, &pos_value); packet 587 ext/mysqlnd/mysqlnd_wireprotocol.c while (SUCCESS == zend_hash_get_current_data_ex(packet->connect_attr, (void **)&entry_value, &pos_value)) { packet 592 ext/mysqlnd/mysqlnd_wireprotocol.c if (HASH_KEY_IS_STRING == zend_hash_get_current_key_ex(packet->connect_attr, &s_key, &s_len, &num_key, 0, &pos_value)) { packet 609 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->is_change_user_packet) { packet 612 ext/mysqlnd/mysqlnd_wireprotocol.c packet->silent, TRUE TSRMLS_CC)) { packet 651 ext/mysqlnd/mysqlnd_wireprotocol.c register MYSQLND_PACKET_AUTH_RESPONSE * packet= (MYSQLND_PACKET_AUTH_RESPONSE *) _packet; packet 657 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); packet 664 ext/mysqlnd/mysqlnd_wireprotocol.c buf[packet->header.size] = '\0'; packet 667 ext/mysqlnd/mysqlnd_wireprotocol.c packet->response_code = uint1korr(p); packet 671 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->response_code) { packet 672 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 673 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error, sizeof(packet->error), packet 674 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_no, packet->sqlstate packet 678 ext/mysqlnd/mysqlnd_wireprotocol.c if (0xFE == packet->response_code) { packet 680 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > (size_t) (p - buf)) { packet 681 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); packet 682 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_len = strlen(packet->new_auth_protocol); packet 683 ext/mysqlnd/mysqlnd_wireprotocol.c p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ packet 685 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); packet 686 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->new_auth_protocol_data_len) { packet 687 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_data = mnd_emalloc(packet->new_auth_protocol_data_len); packet 688 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); packet 690 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("The server requested switching auth plugin to : %s", packet->new_auth_protocol); packet 691 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("Server salt : [%d][%.*s]", packet->new_auth_protocol_data_len, packet->new_auth_protocol_data_len, packet->new_auth_protocol_data); packet 695 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); packet 698 ext/mysqlnd/mysqlnd_wireprotocol.c packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); packet 701 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 705 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 710 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > (size_t) (p - buf) && (i = php_mysqlnd_net_field_length(&p))) { packet 711 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message_len = MIN(i, buf_len - (p - begin)); packet 712 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); packet 714 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message = NULL; packet 715 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message_len = 0; packet 719 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows, packet->last_insert_id, packet->server_status, packet 720 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count); packet 725 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); packet 727 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 765 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_CHANGE_AUTH_RESPONSE *packet= (MYSQLND_PACKET_CHANGE_AUTH_RESPONSE *) _packet; packet 766 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar * buffer = conn->net->cmd_buffer.length >= packet->auth_data_len? conn->net->cmd_buffer.buffer : mnd_emalloc(packet->auth_data_len); packet 771 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->auth_data_len) { packet 772 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->auth_data, packet->auth_data_len); packet 773 ext/mysqlnd/mysqlnd_wireprotocol.c p+= packet->auth_data_len; packet 814 ext/mysqlnd/mysqlnd_wireprotocol.c register MYSQLND_PACKET_OK *packet= (MYSQLND_PACKET_OK *) _packet; packet 818 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); packet 822 ext/mysqlnd/mysqlnd_wireprotocol.c packet->field_count = uint1korr(p); packet 826 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->field_count) { packet 827 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 828 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error, sizeof(packet->error), packet 829 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_no, packet->sqlstate packet 835 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); packet 838 ext/mysqlnd/mysqlnd_wireprotocol.c packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); packet 841 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 845 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 850 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > (size_t) (p - buf) && (i = php_mysqlnd_net_field_length(&p))) { packet 851 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message_len = MIN(i, buf_len - (p - begin)); packet 852 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); packet 854 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message = NULL; packet 855 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message_len = 0; packet 859 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows, packet->last_insert_id, packet->server_status, packet 860 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count); packet 866 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); packet 868 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 900 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_EOF *packet= (MYSQLND_PACKET_EOF *) _packet; packet 908 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); packet 912 ext/mysqlnd/mysqlnd_wireprotocol.c packet->field_count = uint1korr(p); packet 916 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->field_count) { packet 917 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 918 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error, sizeof(packet->error), packet 919 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_no, packet->sqlstate packet 929 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > 1) { packet 930 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 934 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 938 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = 0; packet 939 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = 0; packet 945 ext/mysqlnd/mysqlnd_wireprotocol.c packet->field_count, packet->server_status, packet->warning_count); packet 949 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("EOF packet %d bytes shorter than expected", p - begin - packet->header.size); packet 951 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 972 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_COMMAND * packet= (MYSQLND_PACKET_COMMAND *) _packet; packet 992 ext/mysqlnd/mysqlnd_wireprotocol.c net->data->m.consume_uneaten_data(net, packet->command TSRMLS_CC); packet 995 ext/mysqlnd/mysqlnd_wireprotocol.c if (!packet->argument || !packet->arg_len) { packet 998 ext/mysqlnd/mysqlnd_wireprotocol.c int1store(buffer + MYSQLND_HEADER_SIZE, packet->command); packet 1001 ext/mysqlnd/mysqlnd_wireprotocol.c size_t tmp_len = packet->arg_len + 1 + MYSQLND_HEADER_SIZE; packet 1009 ext/mysqlnd/mysqlnd_wireprotocol.c int1store(p, packet->command); packet 1012 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(p, packet->argument, packet->arg_len); packet 1055 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_RSET_HEADER *packet= (MYSQLND_PACKET_RSET_HEADER *) _packet; packet 1059 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKET); packet 1070 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 1071 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.error, sizeof(packet->error_info.error), packet 1072 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_info.error_no, packet->error_info.sqlstate packet 1078 ext/mysqlnd/mysqlnd_wireprotocol.c packet->field_count = php_mysqlnd_net_field_length(&p); packet 1081 ext/mysqlnd/mysqlnd_wireprotocol.c switch (packet->field_count) { packet 1091 ext/mysqlnd/mysqlnd_wireprotocol.c len = packet->header.size - 1; packet 1092 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file = mnd_emalloc(len + 1); packet 1093 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->info_or_local_file) { packet 1094 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->info_or_local_file, p, len); packet 1095 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file[len] = '\0'; packet 1096 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file_len = len; packet 1104 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); packet 1107 ext/mysqlnd/mysqlnd_wireprotocol.c packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); packet 1110 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 1114 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 1118 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > (size_t) (p - buf) && (len = php_mysqlnd_net_field_length(&p))) { packet 1119 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file = mnd_emalloc(len + 1); packet 1120 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->info_or_local_file) { packet 1121 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->info_or_local_file, p, len); packet 1122 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file[len] = '\0'; packet 1123 ext/mysqlnd/mysqlnd_wireprotocol.c packet->info_or_local_file_len = len; packet 1130 ext/mysqlnd/mysqlnd_wireprotocol.c packet->affected_rows, packet->last_insert_id, packet 1131 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status, packet->warning_count); packet 1142 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("RSET_HEADER packet %d bytes shorter than expected", p - begin - packet->header.size); packet 1144 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 1189 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_RES_FIELD *packet= (MYSQLND_PACKET_RES_FIELD *) _packet; packet 1201 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); packet 1203 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->skip_parsing) { packet 1212 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 1213 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.error, sizeof(packet->error_info.error), packet 1214 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_info.error_no, packet->error_info.sqlstate packet 1216 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("Server error : (%u) %s", packet->error_info.error_no, packet->error_info.error); packet 1218 ext/mysqlnd/mysqlnd_wireprotocol.c } else if (EODATA_MARKER == *p && packet->header.size < 8) { packet 1221 ext/mysqlnd/mysqlnd_wireprotocol.c packet->stupid_list_fields_eof = TRUE; packet 1225 ext/mysqlnd/mysqlnd_wireprotocol.c meta = packet->metadata; packet 1294 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size > (size_t) (p - buf) && packet 1299 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("Def found, length %lu, persistent=%u", len, packet->persistent_alloc); packet 1300 ext/mysqlnd/mysqlnd_wireprotocol.c meta->def = mnd_pemalloc(len + 1, packet->persistent_alloc); packet 1311 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("allocing root. persistent=%u", packet->persistent_alloc); packet 1312 ext/mysqlnd/mysqlnd_wireprotocol.c root_ptr = meta->root = mnd_pemalloc(total_len, packet->persistent_alloc); packet 1373 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("RSET field packet %d bytes shorter than expected", p - begin - packet->header.size); packet 1375 ext/mysqlnd/mysqlnd_wireprotocol.c "shorter than expected", p - begin - packet->header.size); packet 1802 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_ROW *packet= (MYSQLND_PACKET_ROW *) _packet; packet 1808 ext/mysqlnd/mysqlnd_wireprotocol.c if (!packet->binary_protocol && packet->bit_fields_count) { packet 1810 ext/mysqlnd/mysqlnd_wireprotocol.c post_alloc_for_bit_fields = packet->bit_fields_total_len + packet->bit_fields_count; packet 1813 ext/mysqlnd/mysqlnd_wireprotocol.c ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_size, packet 1814 ext/mysqlnd/mysqlnd_wireprotocol.c packet->persistent_alloc, post_alloc_for_bit_fields packet 1820 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_HEADER_SIZE + packet->header.size, packet 1825 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.size = data_size; packet 1826 ext/mysqlnd/mysqlnd_wireprotocol.c packet->row_buffer->app = data_size; packet 1828 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == (*(p = packet->row_buffer->ptr))) { packet 1836 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.error, packet 1837 ext/mysqlnd/mysqlnd_wireprotocol.c sizeof(packet->error_info.error), packet 1838 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_info.error_no, packet 1839 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.sqlstate packet 1842 ext/mysqlnd/mysqlnd_wireprotocol.c packet->eof = TRUE; packet 1845 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 1847 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_status = uint2korr(p); packet 1849 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("server_status=%u warning_count=%u", packet->server_status, packet->warning_count); packet 1853 ext/mysqlnd/mysqlnd_wireprotocol.c packet->binary_protocol? STAT_ROWS_FETCHED_FROM_SERVER_PS: packet 1856 ext/mysqlnd/mysqlnd_wireprotocol.c packet->eof = FALSE; packet 1859 ext/mysqlnd/mysqlnd_wireprotocol.c if (!packet->skip_extraction) { packet 1860 ext/mysqlnd/mysqlnd_wireprotocol.c if (!packet->fields) { packet 1872 ext/mysqlnd/mysqlnd_wireprotocol.c packet->fields = (zval **) mnd_pecalloc(packet->field_count, sizeof(zval *), packet 1873 ext/mysqlnd/mysqlnd_wireprotocol.c packet->persistent_alloc); packet 1877 ext/mysqlnd/mysqlnd_wireprotocol.c packet->binary_protocol? STAT_ROWS_SKIPPED_PS: packet 1920 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_STATS *packet= (MYSQLND_PACKET_STATS *) _packet; packet 1926 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); packet 1928 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message = mnd_emalloc(packet->header.size + 1); packet 1929 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->message, buf, packet->header.size); packet 1930 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message[packet->header.size] = '\0'; packet 1931 ext/mysqlnd/mysqlnd_wireprotocol.c packet->message_len = packet->header.size; packet 1968 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_PREPARE_RESPONSE *packet= (MYSQLND_PACKET_PREPARE_RESPONSE *) _packet; packet 1972 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); packet 1975 ext/mysqlnd/mysqlnd_wireprotocol.c data_size = packet->header.size; packet 1976 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_code = uint1korr(p); packet 1980 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->error_code) { packet 1982 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.error, packet 1983 ext/mysqlnd/mysqlnd_wireprotocol.c sizeof(packet->error_info.error), packet 1984 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_info.error_no, packet 1985 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.sqlstate packet 1998 ext/mysqlnd/mysqlnd_wireprotocol.c packet->stmt_id = uint4korr(p); packet 2003 ext/mysqlnd/mysqlnd_wireprotocol.c packet->field_count = uint2korr(p); packet 2007 ext/mysqlnd/mysqlnd_wireprotocol.c packet->param_count = uint2korr(p); packet 2016 ext/mysqlnd/mysqlnd_wireprotocol.c packet->warning_count = uint2korr(p); packet 2020 ext/mysqlnd/mysqlnd_wireprotocol.c packet->stmt_id, packet->field_count, packet->param_count); packet 2026 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("PREPARE packet %d bytes shorter than expected", p - begin - packet->header.size); packet 2028 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 2055 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_CHG_USER_RESPONSE *packet= (MYSQLND_PACKET_CHG_USER_RESPONSE *) _packet; packet 2059 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP_PACKET); packet 2068 ext/mysqlnd/mysqlnd_wireprotocol.c packet->response_code = uint1korr(p); packet 2071 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->header.size == 1 && buf[0] == EODATA_MARKER && packet->server_capabilities & CLIENT_SECURE_CONNECTION) { packet 2073 ext/mysqlnd/mysqlnd_wireprotocol.c packet->server_asked_323_auth = TRUE; packet 2077 ext/mysqlnd/mysqlnd_wireprotocol.c if (ERROR_MARKER == packet->response_code) { packet 2078 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_error_from_line(p, packet->header.size - 1, packet 2079 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.error, packet 2080 ext/mysqlnd/mysqlnd_wireprotocol.c sizeof(packet->error_info.error), packet 2081 ext/mysqlnd/mysqlnd_wireprotocol.c &packet->error_info.error_no, packet 2082 ext/mysqlnd/mysqlnd_wireprotocol.c packet->error_info.sqlstate packet 2086 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->response_code == 0xFE && packet->header.size > (size_t) (p - buf)) { packet 2087 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); packet 2088 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_len = strlen(packet->new_auth_protocol); packet 2089 ext/mysqlnd/mysqlnd_wireprotocol.c p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ packet 2090 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); packet 2091 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet->new_auth_protocol_data_len) { packet 2092 ext/mysqlnd/mysqlnd_wireprotocol.c packet->new_auth_protocol_data = mnd_emalloc(packet->new_auth_protocol_data_len); packet 2093 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); packet 2095 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("The server requested switching auth plugin to : %s", packet->new_auth_protocol); packet 2096 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("Server salt : [%*s]", packet->new_auth_protocol_data_len, packet->new_auth_protocol_data); packet 2101 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("CHANGE_USER packet %d bytes shorter than expected", p - begin - packet->header.size); packet 2103 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 2172 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_PACKET_SHA256_PK_REQUEST_RESPONSE * packet= (MYSQLND_PACKET_SHA256_PK_REQUEST_RESPONSE *) _packet; packet 2177 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "SHA256_PK_REQUEST_RESPONSE", PROT_SHA256_PK_REQUEST_RESPONSE_PACKET); packet 2183 ext/mysqlnd/mysqlnd_wireprotocol.c packet->public_key_len = packet->header.size - (p - buf); packet 2184 ext/mysqlnd/mysqlnd_wireprotocol.c packet->public_key = mnd_emalloc(packet->public_key_len + 1); packet 2185 ext/mysqlnd/mysqlnd_wireprotocol.c memcpy(packet->public_key, p, packet->public_key_len); packet 2186 ext/mysqlnd/mysqlnd_wireprotocol.c packet->public_key[packet->public_key_len] = '\0'; packet 2191 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); packet 2193 ext/mysqlnd/mysqlnd_wireprotocol.c p - begin - packet->header.size); packet 2319 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_greet * packet = mnd_pecalloc(1, packet_methods[PROT_GREET_PACKET].struct_size, persistent); packet 2321 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2322 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_GREET_PACKET]; packet 2323 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2325 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2334 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_auth * packet = mnd_pecalloc(1, packet_methods[PROT_AUTH_PACKET].struct_size, persistent); packet 2336 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2337 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_AUTH_PACKET]; packet 2338 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2340 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2349 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_auth_response * packet = mnd_pecalloc(1, packet_methods[PROT_AUTH_RESP_PACKET].struct_size, persistent); packet 2351 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2352 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_AUTH_RESP_PACKET]; packet 2353 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2355 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2364 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_change_auth_response * packet = mnd_pecalloc(1, packet_methods[PROT_CHANGE_AUTH_RESP_PACKET].struct_size, persistent); packet 2366 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2367 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_CHANGE_AUTH_RESP_PACKET]; packet 2368 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2370 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2379 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_ok * packet = mnd_pecalloc(1, packet_methods[PROT_OK_PACKET].struct_size, persistent); packet 2381 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2382 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_OK_PACKET]; packet 2383 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2385 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2394 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_eof * packet = mnd_pecalloc(1, packet_methods[PROT_EOF_PACKET].struct_size, persistent); packet 2396 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2397 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_EOF_PACKET]; packet 2398 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2400 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2409 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_command * packet = mnd_pecalloc(1, packet_methods[PROT_CMD_PACKET].struct_size, persistent); packet 2411 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2412 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_CMD_PACKET]; packet 2413 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2415 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2424 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_rset_header * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_HEADER_PACKET].struct_size, persistent); packet 2426 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2427 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_RSET_HEADER_PACKET]; packet 2428 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2430 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2439 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_res_field * packet = mnd_pecalloc(1, packet_methods[PROT_RSET_FLD_PACKET].struct_size, persistent); packet 2441 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2442 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_RSET_FLD_PACKET]; packet 2443 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2445 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2454 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_row * packet = mnd_pecalloc(1, packet_methods[PROT_ROW_PACKET].struct_size, persistent); packet 2456 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2457 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_ROW_PACKET]; packet 2458 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2460 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2469 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_stats * packet = mnd_pecalloc(1, packet_methods[PROT_STATS_PACKET].struct_size, persistent); packet 2471 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2472 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_STATS_PACKET]; packet 2473 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2475 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2484 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_prepare_response * packet = mnd_pecalloc(1, packet_methods[PROT_PREPARE_RESP_PACKET].struct_size, persistent); packet 2486 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2487 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_PREPARE_RESP_PACKET]; packet 2488 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2490 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2499 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_chg_user_resp * packet = mnd_pecalloc(1, packet_methods[PROT_CHG_USER_RESP_PACKET].struct_size, persistent); packet 2501 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2502 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_CHG_USER_RESP_PACKET]; packet 2503 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2505 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2514 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_sha256_pk_request * packet = mnd_pecalloc(1, packet_methods[PROT_SHA256_PK_REQUEST_PACKET].struct_size, persistent); packet 2516 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2517 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_SHA256_PK_REQUEST_PACKET]; packet 2518 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2520 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 2529 ext/mysqlnd/mysqlnd_wireprotocol.c struct st_mysqlnd_packet_sha256_pk_request_response * packet = mnd_pecalloc(1, packet_methods[PROT_SHA256_PK_REQUEST_RESPONSE_PACKET].struct_size, persistent); packet 2531 ext/mysqlnd/mysqlnd_wireprotocol.c if (packet) { packet 2532 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.m = &packet_methods[PROT_SHA256_PK_REQUEST_RESPONSE_PACKET]; packet 2533 ext/mysqlnd/mysqlnd_wireprotocol.c packet->header.persistent = persistent; packet 2535 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_RETURN(packet); packet 39 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_WRITE(packet, conn) ((packet)->header.m->write_to_net((packet), (conn) TSRMLS_CC)) packet 40 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_READ(packet, conn) ((packet)->header.m->read_from_net((packet), (conn) TSRMLS_CC)) packet 41 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_FREE(packet) \ packet 43 ext/mysqlnd/mysqlnd_wireprotocol.h DBG_INF_FMT("PACKET_FREE(%p)", packet); \ packet 44 ext/mysqlnd/mysqlnd_wireprotocol.h if ((packet)) { \ packet 45 ext/mysqlnd/mysqlnd_wireprotocol.h ((packet)->header.m->free_mem((packet), FALSE TSRMLS_CC)); \ packet 54 ext/mysqlnd/mysqlnd_wireprotocol.h enum_func_status (*read_from_net)(void * packet, MYSQLND_CONN_DATA * conn TSRMLS_DC); packet 55 ext/mysqlnd/mysqlnd_wireprotocol.h size_t (*write_to_net)(void * packet, MYSQLND_CONN_DATA * conn TSRMLS_DC); packet 56 ext/mysqlnd/mysqlnd_wireprotocol.h void (*free_mem)(void *packet, zend_bool stack_allocation TSRMLS_DC); packet 303 ext/mysqlnd/mysqlnd_wireprotocol.h unsigned long php_mysqlnd_net_field_length(zend_uchar **packet); packet 304 ext/mysqlnd/mysqlnd_wireprotocol.h zend_uchar * php_mysqlnd_net_store_length(zend_uchar *packet, uint64_t length); packet 51 ext/wddx/php_wddx_api.h #define php_wddx_add_chunk(packet, str) smart_str_appends(packet, str) packet 52 ext/wddx/php_wddx_api.h #define php_wddx_add_chunk_ex(packet, str, len) smart_str_appendl(packet, str, len) packet 53 ext/wddx/php_wddx_api.h #define php_wddx_add_chunk_static(packet, str) smart_str_appendl(packet, str, sizeof(str)-1) packet 58 ext/wddx/php_wddx_api.h void php_wddx_destructor(wddx_packet *packet); packet 60 ext/wddx/php_wddx_api.h void php_wddx_packet_start(wddx_packet *packet, char *comment, int comment_len); packet 61 ext/wddx/php_wddx_api.h void php_wddx_packet_end(wddx_packet *packet); packet 63 ext/wddx/php_wddx_api.h void php_wddx_serialize_var(wddx_packet *packet, zval *var, char *name, int name_len TSRMLS_DC); packet 65 ext/wddx/php_wddx_api.h #define php_wddx_gather(packet) estrndup(packet->c, packet->len) packet 129 ext/wddx/wddx.c ZEND_ARG_INFO(0, packet) packet 264 ext/wddx/wddx.c wddx_packet *packet; packet 267 ext/wddx/wddx.c packet = php_wddx_constructor(); packet 269 ext/wddx/wddx.c php_wddx_packet_start(packet, NULL, 0); packet 270 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 273 ext/wddx/wddx.c php_wddx_serialize_var(packet, *struc, key, key_length TSRMLS_CC); packet 276 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 277 ext/wddx/wddx.c php_wddx_packet_end(packet); packet 278 ext/wddx/wddx.c *newstr = php_wddx_gather(packet); packet 279 ext/wddx/wddx.c php_wddx_destructor(packet); packet 370 ext/wddx/wddx.c void php_wddx_packet_start(wddx_packet *packet, char *comment, int comment_len) packet 372 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_PACKET_S); packet 374 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_HEADER_S); packet 375 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_COMMENT_S); packet 376 ext/wddx/wddx.c php_wddx_add_chunk_ex(packet, comment, comment_len); packet 377 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_COMMENT_E); packet 378 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_HEADER_E); packet 380 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_HEADER); packet 382 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_DATA_S); packet 388 ext/wddx/wddx.c void php_wddx_packet_end(wddx_packet *packet) packet 390 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_DATA_E); packet 391 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_PACKET_E); packet 397 ext/wddx/wddx.c php_wddx_add_chunk_ex(packet, buf, l); \ packet 403 ext/wddx/wddx.c static void php_wddx_serialize_string(wddx_packet *packet, zval *var TSRMLS_DC) packet 405 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_S); packet 413 ext/wddx/wddx.c php_wddx_add_chunk_ex(packet, buf, buf_len); packet 417 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_E); packet 423 ext/wddx/wddx.c static void php_wddx_serialize_number(wddx_packet *packet, zval *var) packet 434 ext/wddx/wddx.c php_wddx_add_chunk(packet, tmp_buf); packet 440 ext/wddx/wddx.c static void php_wddx_serialize_boolean(wddx_packet *packet, zval *var) packet 442 ext/wddx/wddx.c php_wddx_add_chunk(packet, Z_LVAL_P(var) ? WDDX_BOOLEAN_TRUE : WDDX_BOOLEAN_FALSE); packet 448 ext/wddx/wddx.c static void php_wddx_serialize_unset(wddx_packet *packet) packet 450 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_NULL); packet 456 ext/wddx/wddx.c static void php_wddx_serialize_object(wddx_packet *packet, zval *obj) packet 480 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 482 ext/wddx/wddx.c php_wddx_add_chunk(packet, tmp_buf); packet 483 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_S); packet 484 ext/wddx/wddx.c php_wddx_add_chunk_ex(packet, class_name, name_len); packet 485 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_E); packet 486 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_VAR_E); packet 501 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, Z_STRVAL_PP(varname), Z_STRLEN_PP(varname) TSRMLS_CC); packet 505 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 514 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 516 ext/wddx/wddx.c php_wddx_add_chunk(packet, tmp_buf); packet 517 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_S); packet 518 ext/wddx/wddx.c php_wddx_add_chunk_ex(packet, class_name, name_len); packet 519 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRING_E); packet 520 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_VAR_E); packet 536 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, prop_name, strlen(prop_name)+1 TSRMLS_CC); packet 539 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, tmp_buf, key_len TSRMLS_CC); packet 542 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 556 ext/wddx/wddx.c static void php_wddx_serialize_array(wddx_packet *packet, zval *arr) packet 591 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 594 ext/wddx/wddx.c php_wddx_add_chunk(packet, tmp_buf); packet 608 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, key, key_len TSRMLS_CC); packet 611 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, tmp_buf, key_len TSRMLS_CC); packet 614 ext/wddx/wddx.c php_wddx_serialize_var(packet, *ent, NULL, 0 TSRMLS_CC); packet 619 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 621 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_ARRAY_E); packet 628 ext/wddx/wddx.c void php_wddx_serialize_var(wddx_packet *packet, zval *var, char *name, int name_len TSRMLS_DC) packet 639 ext/wddx/wddx.c php_wddx_add_chunk(packet, tmp_buf); packet 646 ext/wddx/wddx.c php_wddx_serialize_string(packet, var TSRMLS_CC); packet 651 ext/wddx/wddx.c php_wddx_serialize_number(packet, var); packet 655 ext/wddx/wddx.c php_wddx_serialize_boolean(packet, var); packet 659 ext/wddx/wddx.c php_wddx_serialize_unset(packet); packet 669 ext/wddx/wddx.c php_wddx_serialize_array(packet, var); packet 680 ext/wddx/wddx.c php_wddx_serialize_object(packet, var); packet 686 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_VAR_E); packet 693 ext/wddx/wddx.c static void php_wddx_add_var(wddx_packet *packet, zval *name_var) packet 705 ext/wddx/wddx.c php_wddx_serialize_var(packet, *val, Z_STRVAL_P(name_var), Z_STRLEN_P(name_var) TSRMLS_CC); packet 724 ext/wddx/wddx.c php_wddx_add_var(packet, *val); packet 1177 ext/wddx/wddx.c wddx_packet *packet; packet 1183 ext/wddx/wddx.c packet = php_wddx_constructor(); packet 1185 ext/wddx/wddx.c php_wddx_packet_start(packet, comment, comment_len); packet 1186 ext/wddx/wddx.c php_wddx_serialize_var(packet, var, NULL, 0 TSRMLS_CC); packet 1187 ext/wddx/wddx.c php_wddx_packet_end(packet); packet 1189 ext/wddx/wddx.c ZVAL_STRINGL(return_value, packet->c, packet->len, 1); packet 1190 ext/wddx/wddx.c smart_str_free(packet); packet 1191 ext/wddx/wddx.c efree(packet); packet 1200 ext/wddx/wddx.c wddx_packet *packet; packet 1207 ext/wddx/wddx.c packet = php_wddx_constructor(); packet 1209 ext/wddx/wddx.c php_wddx_packet_start(packet, NULL, 0); packet 1210 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 1216 ext/wddx/wddx.c php_wddx_add_var(packet, *args[i]); packet 1219 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 1220 ext/wddx/wddx.c php_wddx_packet_end(packet); packet 1224 ext/wddx/wddx.c ZVAL_STRINGL(return_value, packet->c, packet->len, 1); packet 1225 ext/wddx/wddx.c smart_str_free(packet); packet 1226 ext/wddx/wddx.c efree(packet); packet 1234 ext/wddx/wddx.c smart_str *packet; packet 1236 ext/wddx/wddx.c packet = (smart_str *)emalloc(sizeof(smart_str)); packet 1237 ext/wddx/wddx.c packet->c = NULL; packet 1239 ext/wddx/wddx.c return packet; packet 1245 ext/wddx/wddx.c void php_wddx_destructor(wddx_packet *packet) packet 1247 ext/wddx/wddx.c smart_str_free(packet); packet 1248 ext/wddx/wddx.c efree(packet); packet 1258 ext/wddx/wddx.c wddx_packet *packet; packet 1266 ext/wddx/wddx.c packet = php_wddx_constructor(); packet 1268 ext/wddx/wddx.c php_wddx_packet_start(packet, comment, comment_len); packet 1269 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_S); packet 1271 ext/wddx/wddx.c ZEND_REGISTER_RESOURCE(return_value, packet, le_wddx); packet 1280 ext/wddx/wddx.c wddx_packet *packet = NULL; packet 1286 ext/wddx/wddx.c ZEND_FETCH_RESOURCE(packet, wddx_packet *, &packet_id, -1, "WDDX packet ID", le_wddx); packet 1288 ext/wddx/wddx.c php_wddx_add_chunk_static(packet, WDDX_STRUCT_E); packet 1290 ext/wddx/wddx.c php_wddx_packet_end(packet); packet 1292 ext/wddx/wddx.c ZVAL_STRINGL(return_value, packet->c, packet->len, 1); packet 1305 ext/wddx/wddx.c wddx_packet *packet = NULL; packet 1311 ext/wddx/wddx.c if (!ZEND_FETCH_RESOURCE_NO_RETURN(packet, wddx_packet *, &packet_id, -1, "WDDX packet ID", le_wddx)) { packet 1316 ext/wddx/wddx.c if (!packet) { packet 1325 ext/wddx/wddx.c php_wddx_add_var(packet, (*args[i])); packet 1337 ext/wddx/wddx.c zval *packet; packet 1342 ext/wddx/wddx.c if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &packet) == FAILURE) { packet 1346 ext/wddx/wddx.c if (Z_TYPE_P(packet) == IS_STRING) { packet 1347 ext/wddx/wddx.c payload = Z_STRVAL_P(packet); packet 1348 ext/wddx/wddx.c payload_len = Z_STRLEN_P(packet); packet 1349 ext/wddx/wddx.c } else if (Z_TYPE_P(packet) == IS_RESOURCE) { packet 1350 ext/wddx/wddx.c php_stream_from_zval(stream, &packet);