Lines Matching refs:p
65 if ((size_t)(p - begin) > packet->header.size) { \
134 register zend_uchar *p= (zend_uchar *)*packet; in php_mysqlnd_net_field_length() local
136 if (*p < 251) { in php_mysqlnd_net_field_length()
138 return (unsigned long) *p; in php_mysqlnd_net_field_length()
141 switch (*p) { in php_mysqlnd_net_field_length()
147 return (unsigned long) uint2korr(p+1); in php_mysqlnd_net_field_length()
150 return (unsigned long) uint3korr(p+1); in php_mysqlnd_net_field_length()
153 return (unsigned long) uint4korr(p+1); in php_mysqlnd_net_field_length()
164 register zend_uchar *p= (zend_uchar *)*packet; in php_mysqlnd_net_field_length_ll() local
166 if (*p < 251) { in php_mysqlnd_net_field_length_ll()
168 return (uint64_t) *p; in php_mysqlnd_net_field_length_ll()
171 switch (*p) { in php_mysqlnd_net_field_length_ll()
177 return (uint64_t) uint2korr(p + 1); in php_mysqlnd_net_field_length_ll()
180 return (uint64_t) uint3korr(p + 1); in php_mysqlnd_net_field_length_ll()
183 return (uint64_t) uint8korr(p + 1); in php_mysqlnd_net_field_length_ll()
222 zend_uchar *p = buf; in php_mysqlnd_read_error_from_line() local
231 *error_no = uint2korr(p); in php_mysqlnd_read_error_from_line()
232 p+= 2; in php_mysqlnd_read_error_from_line()
237 if (*p == '#') { in php_mysqlnd_read_error_from_line()
238 ++p; in php_mysqlnd_read_error_from_line()
239 if ((buf_len - (p - buf)) >= MYSQLND_SQLSTATE_LENGTH) { in php_mysqlnd_read_error_from_line()
240 memcpy(sqlstate, p, MYSQLND_SQLSTATE_LENGTH); in php_mysqlnd_read_error_from_line()
241 p+= MYSQLND_SQLSTATE_LENGTH; in php_mysqlnd_read_error_from_line()
246 if ((buf_len - (p - buf)) > 0) { in php_mysqlnd_read_error_from_line()
247 error_msg_len = MIN((int)((buf_len - (p - buf))), (int) (error_buf_len - 1)); in php_mysqlnd_read_error_from_line()
248 memcpy(error, p, error_msg_len); in php_mysqlnd_read_error_from_line()
308 zend_uchar *p = buf; in php_mysqlnd_greet_read() local
329 packet->protocol_version = uint1korr(p); in php_mysqlnd_greet_read()
330 p++; in php_mysqlnd_greet_read()
334 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_greet_read()
349 packet->server_version = estrdup((char *)p); in php_mysqlnd_greet_read()
350 p+= strlen(packet->server_version) + 1; /* eat the '\0' */ in php_mysqlnd_greet_read()
353 packet->thread_id = uint4korr(p); in php_mysqlnd_greet_read()
354 p+=4; in php_mysqlnd_greet_read()
357 memcpy(packet->auth_plugin_data, p, SCRAMBLE_LENGTH_323); in php_mysqlnd_greet_read()
358 p+= SCRAMBLE_LENGTH_323; in php_mysqlnd_greet_read()
362 p++; in php_mysqlnd_greet_read()
365 packet->server_capabilities = uint2korr(p); in php_mysqlnd_greet_read()
366 p+= 2; in php_mysqlnd_greet_read()
369 packet->charset_no = uint1korr(p); in php_mysqlnd_greet_read()
370 p++; in php_mysqlnd_greet_read()
373 packet->server_status = uint2korr(p); in php_mysqlnd_greet_read()
374 p+= 2; in php_mysqlnd_greet_read()
378 pad_start = p; in php_mysqlnd_greet_read()
379 p+= 13; in php_mysqlnd_greet_read()
382 if ((size_t) (p - buf) < packet->header.size) { in php_mysqlnd_greet_read()
384 memcpy(packet->auth_plugin_data + SCRAMBLE_LENGTH_323, p, SCRAMBLE_LENGTH - SCRAMBLE_LENGTH_323); in php_mysqlnd_greet_read()
385 p+= SCRAMBLE_LENGTH - SCRAMBLE_LENGTH_323; in php_mysqlnd_greet_read()
386 p++; /* 0x0 at the end of the scramble and thus last byte in the packet in 5.1 and previous */ in php_mysqlnd_greet_read()
392 if ((size_t) (p - buf) < packet->header.size) { in php_mysqlnd_greet_read()
394 p--; in php_mysqlnd_greet_read()
409 … memcpy(new_auth_plugin_data + SCRAMBLE_LENGTH, p, packet->auth_plugin_data_len - SCRAMBLE_LENGTH); in php_mysqlnd_greet_read()
410 p+= (packet->auth_plugin_data_len - SCRAMBLE_LENGTH); in php_mysqlnd_greet_read()
418 packet->auth_protocol = estrdup((char *)p); in php_mysqlnd_greet_read()
419 p+= strlen(packet->auth_protocol) + 1; /* eat the '\0' */ in php_mysqlnd_greet_read()
431 DBG_ERR_FMT("GREET packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_greet_read()
433 p - begin - packet->header.size); in php_mysqlnd_greet_read()
443 MYSQLND_PACKET_GREET *p= (MYSQLND_PACKET_GREET *) _packet; in php_mysqlnd_greet_free_mem() local
444 if (p->server_version) { in php_mysqlnd_greet_free_mem()
445 efree(p->server_version); in php_mysqlnd_greet_free_mem()
446 p->server_version = NULL; in php_mysqlnd_greet_free_mem()
448 if (p->auth_plugin_data && p->auth_plugin_data != p->intern_auth_plugin_data) { in php_mysqlnd_greet_free_mem()
449 efree(p->auth_plugin_data); in php_mysqlnd_greet_free_mem()
450 p->auth_plugin_data = NULL; in php_mysqlnd_greet_free_mem()
452 if (p->auth_protocol) { in php_mysqlnd_greet_free_mem()
453 efree(p->auth_protocol); in php_mysqlnd_greet_free_mem()
454 p->auth_protocol = NULL; in php_mysqlnd_greet_free_mem()
457 mnd_pefree(p, p->header.persistent); in php_mysqlnd_greet_free_mem()
470 zend_uchar *p = buffer + MYSQLND_HEADER_SIZE; /* start after the header */ in php_mysqlnd_auth_write() local
477 int4store(p, packet->client_flags); in php_mysqlnd_auth_write()
478 p+= 4; in php_mysqlnd_auth_write()
480 int4store(p, packet->max_packet_size); in php_mysqlnd_auth_write()
481 p+= 4; in php_mysqlnd_auth_write()
483 int1store(p, packet->charset_no); in php_mysqlnd_auth_write()
484 p++; in php_mysqlnd_auth_write()
486 memset(p, 0, 23); /* filler */ in php_mysqlnd_auth_write()
487 p+= 23; in php_mysqlnd_auth_write()
492 memcpy(p, packet->user, len); in php_mysqlnd_auth_write()
493 p+= len; in php_mysqlnd_auth_write()
494 *p++ = '\0'; in php_mysqlnd_auth_write()
508 int1store(p, packet->auth_data_len); in php_mysqlnd_auth_write()
509 ++p; in php_mysqlnd_auth_write()
511 if ((sizeof(buffer) - (p - buffer)) < packet->auth_data_len) { in php_mysqlnd_auth_write()
516 memcpy(p, packet->auth_data, packet->auth_data_len); in php_mysqlnd_auth_write()
517 p+= packet->auth_data_len; in php_mysqlnd_auth_write()
523 memcpy(p, packet->db, real_db_len); in php_mysqlnd_auth_write()
524 p+= real_db_len; in php_mysqlnd_auth_write()
525 *p++= '\0'; in php_mysqlnd_auth_write()
527 *p++= '\0'; in php_mysqlnd_auth_write()
533 int2store(p, packet->charset_no); in php_mysqlnd_auth_write()
534 p+= 2; in php_mysqlnd_auth_write()
539 size_t len = MIN(strlen(packet->auth_plugin_name), sizeof(buffer) - (p - buffer) - 1); in php_mysqlnd_auth_write()
540 memcpy(p, packet->auth_plugin_name, len); in php_mysqlnd_auth_write()
541 p+= len; in php_mysqlnd_auth_write()
542 *p++= '\0'; in php_mysqlnd_auth_write()
546 …if (PASS != conn->m->simple_command(conn, COM_CHANGE_USER, buffer + MYSQLND_HEADER_SIZE, p - buffe… in php_mysqlnd_auth_write()
551 DBG_RETURN(p - buffer - MYSQLND_HEADER_SIZE); in php_mysqlnd_auth_write()
553 …size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stat… in php_mysqlnd_auth_write()
568 MYSQLND_PACKET_AUTH * p = (MYSQLND_PACKET_AUTH *) _packet; in php_mysqlnd_auth_free_mem() local
569 mnd_pefree(p, p->header.persistent); in php_mysqlnd_auth_free_mem()
584 zend_uchar *p = buf; in php_mysqlnd_auth_response_read() local
603 packet->response_code = uint1korr(p); in php_mysqlnd_auth_response_read()
604 p++; in php_mysqlnd_auth_response_read()
608 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_auth_response_read()
616 if (packet->header.size > (size_t) (p - buf)) { in php_mysqlnd_auth_response_read()
617 packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); in php_mysqlnd_auth_response_read()
619 p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ in php_mysqlnd_auth_response_read()
621 packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); in php_mysqlnd_auth_response_read()
624 memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); in php_mysqlnd_auth_response_read()
631 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_auth_response_read()
634 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_auth_response_read()
637 packet->server_status = uint2korr(p); in php_mysqlnd_auth_response_read()
638 p+= 2; in php_mysqlnd_auth_response_read()
641 packet->warning_count = uint2korr(p); in php_mysqlnd_auth_response_read()
642 p+= 2; in php_mysqlnd_auth_response_read()
646 if (packet->header.size > (size_t) (p - buf) && (i = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_auth_response_read()
647 packet->message_len = MIN(i, buf_len - (p - begin)); in php_mysqlnd_auth_response_read()
648 packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); in php_mysqlnd_auth_response_read()
661 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_auth_response_read()
663 p - begin - packet->header.size); in php_mysqlnd_auth_response_read()
673 MYSQLND_PACKET_AUTH_RESPONSE * p = (MYSQLND_PACKET_AUTH_RESPONSE *) _packet; in php_mysqlnd_auth_response_free_mem() local
674 if (p->message) { in php_mysqlnd_auth_response_free_mem()
675 mnd_efree(p->message); in php_mysqlnd_auth_response_free_mem()
676 p->message = NULL; in php_mysqlnd_auth_response_free_mem()
678 if (p->new_auth_protocol) { in php_mysqlnd_auth_response_free_mem()
679 mnd_efree(p->new_auth_protocol); in php_mysqlnd_auth_response_free_mem()
680 p->new_auth_protocol = NULL; in php_mysqlnd_auth_response_free_mem()
682 p->new_auth_protocol_len = 0; in php_mysqlnd_auth_response_free_mem()
684 if (p->new_auth_protocol_data) { in php_mysqlnd_auth_response_free_mem()
685 mnd_efree(p->new_auth_protocol_data); in php_mysqlnd_auth_response_free_mem()
686 p->new_auth_protocol_data = NULL; in php_mysqlnd_auth_response_free_mem()
688 p->new_auth_protocol_data_len = 0; in php_mysqlnd_auth_response_free_mem()
691 mnd_pefree(p, p->header.persistent); in php_mysqlnd_auth_response_free_mem()
703 zend_uchar *p = buffer + MYSQLND_HEADER_SIZE; /* start after the header */ in php_mysqlnd_change_auth_response_write() local
708 memcpy(p, packet->auth_data, packet->auth_data_len); in php_mysqlnd_change_auth_response_write()
709 p+= packet->auth_data_len; in php_mysqlnd_change_auth_response_write()
713 …size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stat… in php_mysqlnd_change_auth_response_write()
731 MYSQLND_PACKET_CHANGE_AUTH_RESPONSE * p = (MYSQLND_PACKET_CHANGE_AUTH_RESPONSE *) _packet; in php_mysqlnd_change_auth_response_free_mem() local
732 mnd_pefree(p, p->header.persistent); in php_mysqlnd_change_auth_response_free_mem()
747 zend_uchar *p = buf; in php_mysqlnd_ok_read() local
758 packet->field_count = uint1korr(p); in php_mysqlnd_ok_read()
759 p++; in php_mysqlnd_ok_read()
763 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_ok_read()
771 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
774 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_ok_read()
777 packet->server_status = uint2korr(p); in php_mysqlnd_ok_read()
778 p+= 2; in php_mysqlnd_ok_read()
781 packet->warning_count = uint2korr(p); in php_mysqlnd_ok_read()
782 p+= 2; in php_mysqlnd_ok_read()
786 if (packet->header.size > (size_t) (p - buf) && (i = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_ok_read()
787 packet->message_len = MIN(i, buf_len - (p - begin)); in php_mysqlnd_ok_read()
788 packet->message = mnd_pestrndup((char *)p, packet->message_len, FALSE); in php_mysqlnd_ok_read()
802 DBG_ERR_FMT("OK packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_ok_read()
804 p - begin - packet->header.size); in php_mysqlnd_ok_read()
814 MYSQLND_PACKET_OK *p= (MYSQLND_PACKET_OK *) _packet; in php_mysqlnd_ok_free_mem() local
815 if (p->message) { in php_mysqlnd_ok_free_mem()
816 mnd_efree(p->message); in php_mysqlnd_ok_free_mem()
817 p->message = NULL; in php_mysqlnd_ok_free_mem()
820 mnd_pefree(p, p->header.persistent); in php_mysqlnd_ok_free_mem()
839 zend_uchar *p = buf; in php_mysqlnd_eof_read() local
848 packet->field_count = uint1korr(p); in php_mysqlnd_eof_read()
849 p++; in php_mysqlnd_eof_read()
853 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_eof_read()
866 packet->warning_count = uint2korr(p); in php_mysqlnd_eof_read()
867 p+= 2; in php_mysqlnd_eof_read()
870 packet->server_status = uint2korr(p); in php_mysqlnd_eof_read()
871 p+= 2; in php_mysqlnd_eof_read()
885 DBG_ERR_FMT("EOF packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_eof_read()
887 p - begin - packet->header.size); in php_mysqlnd_eof_read()
938 zend_uchar *tmp, *p; in php_mysqlnd_cmd_write() local
943 p = tmp + MYSQLND_HEADER_SIZE; /* skip the header */ in php_mysqlnd_cmd_write()
945 int1store(p, packet->command); in php_mysqlnd_cmd_write()
946 p++; in php_mysqlnd_cmd_write()
948 memcpy(p, packet->argument, packet->arg_len); in php_mysqlnd_cmd_write()
974 MYSQLND_PACKET_COMMAND * p = (MYSQLND_PACKET_COMMAND *) _packet; in php_mysqlnd_cmd_free_mem() local
975 mnd_pefree(p, p->header.persistent); in php_mysqlnd_cmd_free_mem()
988 zend_uchar *p = buf; in php_mysqlnd_rset_header_read() local
1002 if (ERROR_MARKER == *p) { in php_mysqlnd_rset_header_read()
1004 p++; in php_mysqlnd_rset_header_read()
1006 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_header_read()
1014 packet->field_count = php_mysqlnd_net_field_length(&p); in php_mysqlnd_rset_header_read()
1030 memcpy(packet->info_or_local_file, p, len); in php_mysqlnd_rset_header_read()
1040 packet->affected_rows = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
1043 packet->last_insert_id = php_mysqlnd_net_field_length_ll(&p); in php_mysqlnd_rset_header_read()
1046 packet->server_status = uint2korr(p); in php_mysqlnd_rset_header_read()
1047 p+=2; in php_mysqlnd_rset_header_read()
1050 packet->warning_count = uint2korr(p); in php_mysqlnd_rset_header_read()
1051 p+=2; in php_mysqlnd_rset_header_read()
1054 if (packet->header.size > (size_t) (p - buf) && (len = php_mysqlnd_net_field_length(&p))) { in php_mysqlnd_rset_header_read()
1057 memcpy(packet->info_or_local_file, p, len); in php_mysqlnd_rset_header_read()
1078 DBG_ERR_FMT("RSET_HEADER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
1080 p - begin - packet->header.size); in php_mysqlnd_rset_header_read()
1090 MYSQLND_PACKET_RSET_HEADER *p= (MYSQLND_PACKET_RSET_HEADER *) _packet; in php_mysqlnd_rset_header_free_mem() local
1092 if (p->info_or_local_file) { in php_mysqlnd_rset_header_free_mem()
1093 mnd_efree(p->info_or_local_file); in php_mysqlnd_rset_header_free_mem()
1094 p->info_or_local_file = NULL; in php_mysqlnd_rset_header_free_mem()
1097 mnd_pefree(p, p->header.persistent); in php_mysqlnd_rset_header_free_mem()
1128 zend_uchar *p = buf; in php_mysqlnd_rset_field_read() local
1144 if (ERROR_MARKER == *p) { in php_mysqlnd_rset_field_read()
1146 p++; in php_mysqlnd_rset_field_read()
1148 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_rset_field_read()
1154 } else if (EODATA_MARKER == *p && packet->header.size < 8) { in php_mysqlnd_rset_field_read()
1164 len = php_mysqlnd_net_field_length(&p); in php_mysqlnd_rset_field_read()
1174 *(const char **)(((char *)meta) + rset_field_offsets[i]) = (const char *)p; in php_mysqlnd_rset_field_read()
1176 p += len; in php_mysqlnd_rset_field_read()
1184 if (12 != *p) { in php_mysqlnd_rset_field_read()
1185 DBG_ERR_FMT("Protocol error. Server sent false length. Expected 12 got %d", (int) *p); in php_mysqlnd_rset_field_read()
1188 p++; in php_mysqlnd_rset_field_read()
1191 meta->charsetnr = uint2korr(p); in php_mysqlnd_rset_field_read()
1192 p += 2; in php_mysqlnd_rset_field_read()
1195 meta->length = uint4korr(p); in php_mysqlnd_rset_field_read()
1196 p += 4; in php_mysqlnd_rset_field_read()
1199 meta->type = uint1korr(p); in php_mysqlnd_rset_field_read()
1200 p += 1; in php_mysqlnd_rset_field_read()
1203 meta->flags = uint2korr(p); in php_mysqlnd_rset_field_read()
1204 p += 2; in php_mysqlnd_rset_field_read()
1207 meta->decimals = uint1korr(p); in php_mysqlnd_rset_field_read()
1208 p += 1; in php_mysqlnd_rset_field_read()
1212 p +=2; in php_mysqlnd_rset_field_read()
1230 if (packet->header.size > (size_t) (p - buf) && in php_mysqlnd_rset_field_read()
1231 (len = php_mysqlnd_net_field_length(&p)) && in php_mysqlnd_rset_field_read()
1241 memcpy(meta->def, p, len); in php_mysqlnd_rset_field_read()
1244 p += len; in php_mysqlnd_rset_field_read()
1309 DBG_ERR_FMT("RSET field packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1311 "shorter than expected", p - begin - packet->header.size); in php_mysqlnd_rset_field_read()
1321 MYSQLND_PACKET_RES_FIELD *p= (MYSQLND_PACKET_RES_FIELD *) _packet; in php_mysqlnd_rset_field_free_mem() local
1324 mnd_pefree(p, p->header.persistent); in php_mysqlnd_rset_field_free_mem()
1339 zend_uchar * p = NULL; in php_mysqlnd_read_row_ex() local
1372 p = (*buffer)->ptr; in php_mysqlnd_read_row_ex()
1391 p = (*buffer)->ptr + (*data_size - header.size); in php_mysqlnd_read_row_ex()
1394 …if (PASS != (ret = conn->net->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_inf… in php_mysqlnd_read_row_ex()
1422 zend_uchar * p = row_buffer->ptr; in php_mysqlnd_rowp_read_binary_protocol() local
1435 p++; in php_mysqlnd_rowp_read_binary_protocol()
1436 null_ptr= p; in php_mysqlnd_rowp_read_binary_protocol()
1437 p += (field_count + 9)/8; /* skip null bits */ in php_mysqlnd_rowp_read_binary_protocol()
1450 zend_uchar * orig_p = p; in php_mysqlnd_rowp_read_binary_protocol()
1462 …mysqlnd_ps_fetch_functions[type].func(*current_field, &fields_metadata[i], 0, &p, as_unicode TSRML… in php_mysqlnd_rowp_read_binary_protocol()
1500 Z_STRLEN_PP(current_field) : (p - orig_p)); in php_mysqlnd_rowp_read_binary_protocol()
1523 zend_uchar * p = row_buffer->ptr; in php_mysqlnd_rowp_read_text_protocol() local
1545 zend_uchar *this_field_len_pos = p; in php_mysqlnd_rowp_read_text_protocol()
1547 unsigned long len = php_mysqlnd_net_field_length(&p); in php_mysqlnd_rowp_read_text_protocol()
1610 zend_uchar save = *(p + len); in php_mysqlnd_rowp_read_text_protocol()
1612 *(p + len) = '\0'; in php_mysqlnd_rowp_read_text_protocol()
1617 atoll((char *) p); in php_mysqlnd_rowp_read_text_protocol()
1619 _atoi64((char *) p); in php_mysqlnd_rowp_read_text_protocol()
1625 (uint64_t) atoll((char *) p); in php_mysqlnd_rowp_read_text_protocol()
1627 (uint64_t) _atoi64((char *) p); in php_mysqlnd_rowp_read_text_protocol()
1641 ZVAL_STRINGL(*current_field, (char *)p, len, 0); in php_mysqlnd_rowp_read_text_protocol()
1646 *(p + len) = save; in php_mysqlnd_rowp_read_text_protocol()
1648 zend_uchar save = *(p + len); in php_mysqlnd_rowp_read_text_protocol()
1650 *(p + len) = '\0'; in php_mysqlnd_rowp_read_text_protocol()
1651 ZVAL_DOUBLE(*current_field, atof((char *) p)); in php_mysqlnd_rowp_read_text_protocol()
1652 *(p + len) = save; in php_mysqlnd_rowp_read_text_protocol()
1666 …ps_fetch_from_1_to_8_bytes(*current_field, &(fields_metadata[i]), 0, &p, as_unicode, len TSRMLS_CC… in php_mysqlnd_rowp_read_text_protocol()
1671 p -= len; in php_mysqlnd_rowp_read_text_protocol()
1703 ZVAL_STRINGL(*current_field, (char *)p, len, 0); in php_mysqlnd_rowp_read_text_protocol()
1723 ZVAL_STRINGL(*current_field, (char *)p, len, 0); in php_mysqlnd_rowp_read_text_protocol()
1725 ZVAL_UTF8_STRINGL(*current_field, (char *)p, len, 0); in php_mysqlnd_rowp_read_text_protocol()
1728 p += len; in php_mysqlnd_rowp_read_text_protocol()
1751 zend_uchar *p; in php_mysqlnd_rowp_read() local
1780 if (ERROR_MARKER == (*(p = packet->row_buffer->ptr))) { in php_mysqlnd_rowp_read()
1787 php_mysqlnd_read_error_from_line(p + 1, data_size - 1, in php_mysqlnd_rowp_read()
1793 } else if (EODATA_MARKER == *p && data_size < 8) { /* EOF */ in php_mysqlnd_rowp_read()
1795 p++; in php_mysqlnd_rowp_read()
1797 packet->warning_count = uint2korr(p); in php_mysqlnd_rowp_read()
1798 p += 2; in php_mysqlnd_rowp_read()
1799 packet->server_status = uint2korr(p); in php_mysqlnd_rowp_read()
1845 MYSQLND_PACKET_ROW *p; in php_mysqlnd_rowp_free_mem() local
1848 p = (MYSQLND_PACKET_ROW *) _packet; in php_mysqlnd_rowp_free_mem()
1849 if (p->row_buffer) { in php_mysqlnd_rowp_free_mem()
1850 p->row_buffer->free_chunk(p->row_buffer TSRMLS_CC); in php_mysqlnd_rowp_free_mem()
1851 p->row_buffer = NULL; in php_mysqlnd_rowp_free_mem()
1853 DBG_INF_FMT("stack_allocation=%u persistent=%u", (int)stack_allocation, (int)p->header.persistent); in php_mysqlnd_rowp_free_mem()
1862 mnd_pefree(p, p->header.persistent); in php_mysqlnd_rowp_free_mem()
1895 MYSQLND_PACKET_STATS *p= (MYSQLND_PACKET_STATS *) _packet; in php_mysqlnd_stats_free_mem() local
1896 if (p->message) { in php_mysqlnd_stats_free_mem()
1897 mnd_efree(p->message); in php_mysqlnd_stats_free_mem()
1898 p->message = NULL; in php_mysqlnd_stats_free_mem()
1901 mnd_pefree(p, p->header.persistent); in php_mysqlnd_stats_free_mem()
1918 zend_uchar *p = buf; in php_mysqlnd_prepare_read() local
1929 packet->error_code = uint1korr(p); in php_mysqlnd_prepare_read()
1930 p++; in php_mysqlnd_prepare_read()
1934 php_mysqlnd_read_error_from_line(p, data_size - 1, in php_mysqlnd_prepare_read()
1951 packet->stmt_id = uint4korr(p); in php_mysqlnd_prepare_read()
1952 p += 4; in php_mysqlnd_prepare_read()
1956 packet->field_count = uint2korr(p); in php_mysqlnd_prepare_read()
1957 p += 2; in php_mysqlnd_prepare_read()
1960 packet->param_count = uint2korr(p); in php_mysqlnd_prepare_read()
1961 p += 2; in php_mysqlnd_prepare_read()
1966 p++; in php_mysqlnd_prepare_read()
1969 packet->warning_count = uint2korr(p); in php_mysqlnd_prepare_read()
1979 DBG_ERR_FMT("PREPARE packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_prepare_read()
1981 p - begin - packet->header.size); in php_mysqlnd_prepare_read()
1991 MYSQLND_PACKET_PREPARE_RESPONSE *p= (MYSQLND_PACKET_PREPARE_RESPONSE *) _packet; in php_mysqlnd_prepare_free_mem() local
1993 mnd_pefree(p, p->header.persistent); in php_mysqlnd_prepare_free_mem()
2006 zend_uchar *p = buf; in php_mysqlnd_chg_user_read() local
2021 packet->response_code = uint1korr(p); in php_mysqlnd_chg_user_read()
2022 p++; in php_mysqlnd_chg_user_read()
2031 php_mysqlnd_read_error_from_line(p, packet->header.size - 1, in php_mysqlnd_chg_user_read()
2039 if (packet->response_code == 0xFE && packet->header.size > (size_t) (p - buf)) { in php_mysqlnd_chg_user_read()
2040 packet->new_auth_protocol = mnd_pestrdup((char *)p, FALSE); in php_mysqlnd_chg_user_read()
2042 p+= packet->new_auth_protocol_len + 1; /* +1 for the \0 */ in php_mysqlnd_chg_user_read()
2043 packet->new_auth_protocol_data_len = packet->header.size - (size_t) (p - buf); in php_mysqlnd_chg_user_read()
2046 memcpy(packet->new_auth_protocol_data, p, packet->new_auth_protocol_data_len); in php_mysqlnd_chg_user_read()
2054 DBG_ERR_FMT("CHANGE_USER packet %d bytes shorter than expected", p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
2056 p - begin - packet->header.size); in php_mysqlnd_chg_user_read()
2066 MYSQLND_PACKET_CHG_USER_RESPONSE * p = (MYSQLND_PACKET_CHG_USER_RESPONSE *) _packet; in php_mysqlnd_chg_user_free_mem() local
2068 if (p->new_auth_protocol) { in php_mysqlnd_chg_user_free_mem()
2069 mnd_efree(p->new_auth_protocol); in php_mysqlnd_chg_user_free_mem()
2070 p->new_auth_protocol = NULL; in php_mysqlnd_chg_user_free_mem()
2072 p->new_auth_protocol_len = 0; in php_mysqlnd_chg_user_free_mem()
2074 if (p->new_auth_protocol_data) { in php_mysqlnd_chg_user_free_mem()
2075 mnd_efree(p->new_auth_protocol_data); in php_mysqlnd_chg_user_free_mem()
2076 p->new_auth_protocol_data = NULL; in php_mysqlnd_chg_user_free_mem()
2078 p->new_auth_protocol_data_len = 0; in php_mysqlnd_chg_user_free_mem()
2081 mnd_pefree(p, p->header.persistent); in php_mysqlnd_chg_user_free_mem()
