Lines Matching refs:row_packet
265 if (result->row_packet) { in MYSQLND_METHOD()
266 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
267 result->row_packet = NULL; in MYSQLND_METHOD()
629 MYSQLND_PACKET_ROW *row_packet = result->row_packet; in mysqlnd_fetch_row_unbuffered_c() local
643 if (!row_packet) { in mysqlnd_fetch_row_unbuffered_c()
648 row_packet->skip_extraction = FALSE; in mysqlnd_fetch_row_unbuffered_c()
654 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered_c()
659 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_row_unbuffered_c()
660 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_row_unbuffered_c()
661 row_packet->fields = NULL; in mysqlnd_fetch_row_unbuffered_c()
662 row_packet->row_buffer = NULL; in mysqlnd_fetch_row_unbuffered_c()
666 if (!row_packet->skip_extraction) { in mysqlnd_fetch_row_unbuffered_c()
672 row_packet->field_count, in mysqlnd_fetch_row_unbuffered_c()
673 row_packet->fields_metadata, in mysqlnd_fetch_row_unbuffered_c()
709 if (row_packet->error_info.error_no) { in mysqlnd_fetch_row_unbuffered_c()
710 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered_c()
711 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in mysqlnd_fetch_row_unbuffered_c()
715 } else if (row_packet->eof) { in mysqlnd_fetch_row_unbuffered_c()
717 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in mysqlnd_fetch_row_unbuffered_c()
720 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered_c()
721 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered_c()
745 MYSQLND_PACKET_ROW *row_packet = result->row_packet; in mysqlnd_fetch_row_unbuffered() local
758 if (!row_packet) { in mysqlnd_fetch_row_unbuffered()
763 row_packet->skip_extraction = row? FALSE:TRUE; in mysqlnd_fetch_row_unbuffered()
769 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered()
772 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_row_unbuffered()
773 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_row_unbuffered()
774 row_packet->fields = NULL; in mysqlnd_fetch_row_unbuffered()
775 row_packet->row_buffer = NULL; in mysqlnd_fetch_row_unbuffered()
779 if (!row_packet->skip_extraction) { in mysqlnd_fetch_row_unbuffered()
789 row_packet->fields_metadata, in mysqlnd_fetch_row_unbuffered()
845 if (row_packet->error_info.error_no) { in mysqlnd_fetch_row_unbuffered()
846 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered()
847 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in mysqlnd_fetch_row_unbuffered()
851 } else if (row_packet->eof) { in mysqlnd_fetch_row_unbuffered()
853 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in mysqlnd_fetch_row_unbuffered()
856 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered()
857 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered()
914 …result->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE TSRMLS… in MYSQLND_METHOD()
915 if (!result->row_packet) { in MYSQLND_METHOD()
918 result->row_packet->result_set_memory_pool = result->result_set_memory_pool; in MYSQLND_METHOD()
919 result->row_packet->field_count = result->field_count; in MYSQLND_METHOD()
920 result->row_packet->binary_protocol = ps; in MYSQLND_METHOD()
921 result->row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
922 result->row_packet->bit_fields_count = result->meta->bit_fields_count; in MYSQLND_METHOD()
923 result->row_packet->bit_fields_total_len = result->meta->bit_fields_total_len; in MYSQLND_METHOD()
1114 MYSQLND_PACKET_ROW *row_packet = NULL; in MYSQLND_METHOD() local
1137 row_packet = conn->protocol->m.get_row_packet(conn->protocol, FALSE TSRMLS_CC); in MYSQLND_METHOD()
1138 if (!row_packet) { in MYSQLND_METHOD()
1143 row_packet->result_set_memory_pool = result->result_set_memory_pool; in MYSQLND_METHOD()
1144 row_packet->field_count = meta->field_count; in MYSQLND_METHOD()
1145 row_packet->binary_protocol = binary_protocol; in MYSQLND_METHOD()
1146 row_packet->fields_metadata = meta->fields; in MYSQLND_METHOD()
1147 row_packet->bit_fields_count = meta->bit_fields_count; in MYSQLND_METHOD()
1148 row_packet->bit_fields_total_len = meta->bit_fields_total_len; in MYSQLND_METHOD()
1150 …row_packet->skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet->fields… in MYSQLND_METHOD()
1152 while (FAIL != (ret = PACKET_READ(row_packet, conn)) && !row_packet->eof) { in MYSQLND_METHOD()
1173 set->row_buffers[set->row_count] = row_packet->row_buffer; in MYSQLND_METHOD()
1178 row_packet->fields = NULL; in MYSQLND_METHOD()
1179 row_packet->row_buffer = NULL; in MYSQLND_METHOD()
1212 if (row_packet->eof) { in MYSQLND_METHOD()
1214 conn->upsert_status->warning_count = row_packet->warning_count; in MYSQLND_METHOD()
1215 conn->upsert_status->server_status = row_packet->server_status; in MYSQLND_METHOD()
1235 COPY_CLIENT_ERROR(set->error_info, row_packet->error_info); in MYSQLND_METHOD()
1246 PACKET_FREE(row_packet); in MYSQLND_METHOD()
