Lines Matching refs:row_packet
192 if (result->row_packet) { in MYSQLND_METHOD()
193 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
194 result->row_packet = NULL; in MYSQLND_METHOD()
693 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
708 if (!row_packet) { in MYSQLND_METHOD()
713 row_packet->skip_extraction = FALSE; in MYSQLND_METHOD()
719 if (PASS == (ret = PACKET_READ(row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
722 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
723 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
724 row_packet->fields = NULL; in MYSQLND_METHOD()
725 row_packet->row_buffer = NULL; in MYSQLND_METHOD()
729 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
735 row_packet->fields_metadata, in MYSQLND_METHOD()
776 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
777 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
778 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
782 } else if (row_packet->eof) { in MYSQLND_METHOD()
784 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
788 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
789 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
814 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
829 if (!row_packet) { in MYSQLND_METHOD()
834 row_packet->skip_extraction = row? FALSE:TRUE; in MYSQLND_METHOD()
840 if (PASS == (ret = PACKET_READ(row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
843 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
844 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
845 row_packet->fields = NULL; in MYSQLND_METHOD()
846 row_packet->row_buffer = NULL; in MYSQLND_METHOD()
850 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
856 row_packet->fields_metadata, in MYSQLND_METHOD()
904 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
905 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
906 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
910 } else if (row_packet->eof) { in MYSQLND_METHOD()
912 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
916 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
917 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
963 …struct st_mysqlnd_packet_row * row_packet = conn->payload_decoder_factory->m.get_row_packet(conn->… in MYSQLND_METHOD() local
964 if (!row_packet) { in MYSQLND_METHOD()
967 row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; in MYSQLND_METHOD()
968 row_packet->field_count = result->field_count; in MYSQLND_METHOD()
969 row_packet->binary_protocol = ps; in MYSQLND_METHOD()
970 row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
972 result->unbuf->row_packet = row_packet; in MYSQLND_METHOD()
1295 MYSQLND_PACKET_ROW * row_packet = NULL; in MYSQLND_METHOD() local
1311 row_packet = conn->payload_decoder_factory->m.get_row_packet(conn->payload_decoder_factory, FALSE); in MYSQLND_METHOD()
1312 if (!row_packet) { in MYSQLND_METHOD()
1319 row_packet->result_set_memory_pool = result->stored_data->result_set_memory_pool; in MYSQLND_METHOD()
1320 row_packet->field_count = meta->field_count; in MYSQLND_METHOD()
1321 row_packet->binary_protocol = binary_protocol; in MYSQLND_METHOD()
1322 row_packet->fields_metadata = meta->fields; in MYSQLND_METHOD()
1324 …row_packet->skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet->fields… in MYSQLND_METHOD()
1326 while (FAIL != (ret = PACKET_READ(row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
1347 (*row_buffers)[set->row_count] = row_packet->row_buffer; in MYSQLND_METHOD()
1352 row_packet->fields = NULL; in MYSQLND_METHOD()
1353 row_packet->row_buffer = NULL; in MYSQLND_METHOD()
1369 if (row_packet->eof) { in MYSQLND_METHOD()
1371 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
1372 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
1392 COPY_CLIENT_ERROR(&set->error_info, row_packet->error_info); in MYSQLND_METHOD()
1403 PACKET_FREE(row_packet); in MYSQLND_METHOD()
