Lines Matching refs:row_packet
254 if (result->row_packet) { in MYSQLND_METHOD()
255 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
256 result->row_packet = NULL; in MYSQLND_METHOD()
618 MYSQLND_PACKET_ROW *row_packet = result->row_packet; in mysqlnd_fetch_row_unbuffered_c() local
632 if (!row_packet) { in mysqlnd_fetch_row_unbuffered_c()
637 row_packet->skip_extraction = FALSE; in mysqlnd_fetch_row_unbuffered_c()
643 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered_c()
648 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_row_unbuffered_c()
649 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_row_unbuffered_c()
650 row_packet->fields = NULL; in mysqlnd_fetch_row_unbuffered_c()
651 row_packet->row_buffer = NULL; in mysqlnd_fetch_row_unbuffered_c()
655 if (!row_packet->skip_extraction) { in mysqlnd_fetch_row_unbuffered_c()
661 row_packet->field_count, in mysqlnd_fetch_row_unbuffered_c()
662 row_packet->fields_metadata, in mysqlnd_fetch_row_unbuffered_c()
697 if (row_packet->error_info.error_no) { in mysqlnd_fetch_row_unbuffered_c()
698 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered_c()
699 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in mysqlnd_fetch_row_unbuffered_c()
703 } else if (row_packet->eof) { in mysqlnd_fetch_row_unbuffered_c()
705 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in mysqlnd_fetch_row_unbuffered_c()
708 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered_c()
709 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered_c()
733 MYSQLND_PACKET_ROW *row_packet = result->row_packet; in mysqlnd_fetch_row_unbuffered() local
746 if (!row_packet) { in mysqlnd_fetch_row_unbuffered()
751 row_packet->skip_extraction = row? FALSE:TRUE; in mysqlnd_fetch_row_unbuffered()
757 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered()
760 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_row_unbuffered()
761 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_row_unbuffered()
762 row_packet->fields = NULL; in mysqlnd_fetch_row_unbuffered()
763 row_packet->row_buffer = NULL; in mysqlnd_fetch_row_unbuffered()
767 if (!row_packet->skip_extraction) { in mysqlnd_fetch_row_unbuffered()
777 row_packet->fields_metadata, in mysqlnd_fetch_row_unbuffered()
824 if (row_packet->error_info.error_no) { in mysqlnd_fetch_row_unbuffered()
825 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered()
826 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in mysqlnd_fetch_row_unbuffered()
830 } else if (row_packet->eof) { in mysqlnd_fetch_row_unbuffered()
832 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in mysqlnd_fetch_row_unbuffered()
835 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered()
836 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered()
893 …result->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE TSRMLS… in MYSQLND_METHOD()
894 if (!result->row_packet) { in MYSQLND_METHOD()
897 result->row_packet->result_set_memory_pool = result->result_set_memory_pool; in MYSQLND_METHOD()
898 result->row_packet->field_count = result->field_count; in MYSQLND_METHOD()
899 result->row_packet->binary_protocol = ps; in MYSQLND_METHOD()
900 result->row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
901 result->row_packet->bit_fields_count = result->meta->bit_fields_count; in MYSQLND_METHOD()
902 result->row_packet->bit_fields_total_len = result->meta->bit_fields_total_len; in MYSQLND_METHOD()
1083 MYSQLND_PACKET_ROW *row_packet = NULL; in MYSQLND_METHOD() local
1106 row_packet = conn->protocol->m.get_row_packet(conn->protocol, FALSE TSRMLS_CC); in MYSQLND_METHOD()
1107 if (!row_packet) { in MYSQLND_METHOD()
1112 row_packet->result_set_memory_pool = result->result_set_memory_pool; in MYSQLND_METHOD()
1113 row_packet->field_count = meta->field_count; in MYSQLND_METHOD()
1114 row_packet->binary_protocol = binary_protocol; in MYSQLND_METHOD()
1115 row_packet->fields_metadata = meta->fields; in MYSQLND_METHOD()
1116 row_packet->bit_fields_count = meta->bit_fields_count; in MYSQLND_METHOD()
1117 row_packet->bit_fields_total_len = meta->bit_fields_total_len; in MYSQLND_METHOD()
1119 …row_packet->skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet->fields… in MYSQLND_METHOD()
1121 while (FAIL != (ret = PACKET_READ(row_packet, conn)) && !row_packet->eof) { in MYSQLND_METHOD()
1142 set->row_buffers[set->row_count] = row_packet->row_buffer; in MYSQLND_METHOD()
1147 row_packet->fields = NULL; in MYSQLND_METHOD()
1148 row_packet->row_buffer = NULL; in MYSQLND_METHOD()
1181 if (row_packet->eof) { in MYSQLND_METHOD()
1183 conn->upsert_status->warning_count = row_packet->warning_count; in MYSQLND_METHOD()
1184 conn->upsert_status->server_status = row_packet->server_status; in MYSQLND_METHOD()
1204 COPY_CLIENT_ERROR(set->error_info, row_packet->error_info); in MYSQLND_METHOD()
1215 PACKET_FREE(row_packet); in MYSQLND_METHOD()
