Lines Matching refs:row_packet

37 	if (result->row_packet) {  in MYSQLND_METHOD()
38 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
39 mnd_efree(result->row_packet); in MYSQLND_METHOD()
40 result->row_packet = NULL; in MYSQLND_METHOD()
416 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
433 if (!row_packet) { in MYSQLND_METHOD()
441 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
442 set->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
443 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
455 row_packet->fields_metadata, conn->options->int_and_float_native, conn->stats); in MYSQLND_METHOD()
473 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
474 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
476 COPY_CLIENT_ERROR(set->stmt->error_info, row_packet->error_info); in MYSQLND_METHOD()
478 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
484 } else if (row_packet->eof) { in MYSQLND_METHOD()
486 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
490 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
491 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
536 struct st_mysqlnd_packet_row *row_packet = mnd_emalloc(sizeof(struct st_mysqlnd_packet_row)); in MYSQLND_METHOD() local
538 conn->payload_decoder_factory->m.init_row_packet(row_packet); in MYSQLND_METHOD()
539 row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; in MYSQLND_METHOD()
540 row_packet->field_count = result->field_count; in MYSQLND_METHOD()
541 row_packet->binary_protocol = stmt != NULL; in MYSQLND_METHOD()
542 row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
544 result->unbuf->row_packet = row_packet; in MYSQLND_METHOD()
632 MYSQLND_PACKET_ROW row_packet; in MYSQLND_METHOD() local
642 conn->payload_decoder_factory->m.init_row_packet(&row_packet); in MYSQLND_METHOD()
645 row_packet.result_set_memory_pool = result->stored_data->result_set_memory_pool; in MYSQLND_METHOD()
646 row_packet.field_count = meta->field_count; in MYSQLND_METHOD()
647 row_packet.binary_protocol = binary_protocol; in MYSQLND_METHOD()
648 row_packet.fields_metadata = meta->fields; in MYSQLND_METHOD()
650 while (FAIL != (ret = PACKET_READ(conn, &row_packet)) && !row_packet.eof) { in MYSQLND_METHOD()
681 (*row_buffers)[set->row_count] = row_packet.row_buffer; in MYSQLND_METHOD()
686 row_packet.row_buffer.ptr = NULL; in MYSQLND_METHOD()
695 if (row_packet.eof) { in MYSQLND_METHOD()
697 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet.warning_count); in MYSQLND_METHOD()
698 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet.server_status); in MYSQLND_METHOD()
726 COPY_CLIENT_ERROR(&set->error_info, row_packet.error_info); in MYSQLND_METHOD()
737 PACKET_FREE(&row_packet); in MYSQLND_METHOD()