Lines Matching refs:row_packet
187 if (result->row_packet) { in MYSQLND_METHOD()
188 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
189 mnd_efree(result->row_packet); in MYSQLND_METHOD()
190 result->row_packet = NULL; in MYSQLND_METHOD()
653 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
669 if (!row_packet) { in MYSQLND_METHOD()
674 row_packet->skip_extraction = FALSE; in MYSQLND_METHOD()
683 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
686 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
687 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
688 row_packet->fields = NULL; in MYSQLND_METHOD()
689 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
693 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
699 row_packet->fields_metadata, in MYSQLND_METHOD()
742 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
743 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
744 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
750 } else if (row_packet->eof) { in MYSQLND_METHOD()
752 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
756 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
757 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
785 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
801 if (!row_packet) { in MYSQLND_METHOD()
806 row_packet->skip_extraction = row? FALSE:TRUE; in MYSQLND_METHOD()
815 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
818 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
819 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
820 row_packet->fields = NULL; in MYSQLND_METHOD()
821 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
825 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
831 row_packet->fields_metadata, in MYSQLND_METHOD()
882 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
883 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
884 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
890 } else if (row_packet->eof) { in MYSQLND_METHOD()
892 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
896 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
897 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
946 struct st_mysqlnd_packet_row *row_packet = mnd_emalloc(sizeof(struct st_mysqlnd_packet_row)); in MYSQLND_METHOD() local
948 conn->payload_decoder_factory->m.init_row_packet(row_packet); in MYSQLND_METHOD()
949 row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; in MYSQLND_METHOD()
950 row_packet->field_count = result->field_count; in MYSQLND_METHOD()
951 row_packet->binary_protocol = ps; in MYSQLND_METHOD()
952 row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
954 result->unbuf->row_packet = row_packet; in MYSQLND_METHOD()
1278 MYSQLND_PACKET_ROW row_packet; in MYSQLND_METHOD() local
1288 conn->payload_decoder_factory->m.init_row_packet(&row_packet); in MYSQLND_METHOD()
1291 row_packet.result_set_memory_pool = result->stored_data->result_set_memory_pool; in MYSQLND_METHOD()
1292 row_packet.field_count = meta->field_count; in MYSQLND_METHOD()
1293 row_packet.binary_protocol = binary_protocol; in MYSQLND_METHOD()
1294 row_packet.fields_metadata = meta->fields; in MYSQLND_METHOD()
1296 …row_packet.skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet.fields, … in MYSQLND_METHOD()
1298 while (FAIL != (ret = PACKET_READ(conn, &row_packet)) && !row_packet.eof) { in MYSQLND_METHOD()
1334 (*row_buffers)[set->row_count] = row_packet.row_buffer; in MYSQLND_METHOD()
1339 row_packet.fields = NULL; in MYSQLND_METHOD()
1340 row_packet.row_buffer.ptr = NULL; in MYSQLND_METHOD()
1356 if (row_packet.eof) { in MYSQLND_METHOD()
1358 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet.warning_count); in MYSQLND_METHOD()
1359 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet.server_status); in MYSQLND_METHOD()
1387 COPY_CLIENT_ERROR(&set->error_info, row_packet.error_info); in MYSQLND_METHOD()
1398 PACKET_FREE(&row_packet); in MYSQLND_METHOD()
