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()
651 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
667 if (!row_packet) { in MYSQLND_METHOD()
672 row_packet->skip_extraction = FALSE; in MYSQLND_METHOD()
681 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
684 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
685 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
686 row_packet->fields = NULL; in MYSQLND_METHOD()
687 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
691 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
697 row_packet->fields_metadata, in MYSQLND_METHOD()
740 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
741 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
742 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
746 } else if (row_packet->eof) { in MYSQLND_METHOD()
748 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
752 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
753 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
781 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
797 if (!row_packet) { in MYSQLND_METHOD()
802 row_packet->skip_extraction = row? FALSE:TRUE; in MYSQLND_METHOD()
811 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
814 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
815 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
816 row_packet->fields = NULL; in MYSQLND_METHOD()
817 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
821 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
827 row_packet->fields_metadata, in MYSQLND_METHOD()
878 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
879 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
880 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
884 } else if (row_packet->eof) { in MYSQLND_METHOD()
886 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
890 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
891 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
940 struct st_mysqlnd_packet_row *row_packet = mnd_emalloc(sizeof(struct st_mysqlnd_packet_row)); in MYSQLND_METHOD() local
942 conn->payload_decoder_factory->m.init_row_packet(row_packet); in MYSQLND_METHOD()
943 row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; in MYSQLND_METHOD()
944 row_packet->field_count = result->field_count; in MYSQLND_METHOD()
945 row_packet->binary_protocol = ps; in MYSQLND_METHOD()
946 row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
948 result->unbuf->row_packet = row_packet; in MYSQLND_METHOD()
1272 MYSQLND_PACKET_ROW row_packet; in MYSQLND_METHOD() local
1282 conn->payload_decoder_factory->m.init_row_packet(&row_packet); in MYSQLND_METHOD()
1285 row_packet.result_set_memory_pool = result->stored_data->result_set_memory_pool; in MYSQLND_METHOD()
1286 row_packet.field_count = meta->field_count; in MYSQLND_METHOD()
1287 row_packet.binary_protocol = binary_protocol; in MYSQLND_METHOD()
1288 row_packet.fields_metadata = meta->fields; in MYSQLND_METHOD()
1290 …row_packet.skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet.fields, … in MYSQLND_METHOD()
1292 while (FAIL != (ret = PACKET_READ(conn, &row_packet)) && !row_packet.eof) { in MYSQLND_METHOD()
1328 (*row_buffers)[set->row_count] = row_packet.row_buffer; in MYSQLND_METHOD()
1333 row_packet.fields = NULL; in MYSQLND_METHOD()
1334 row_packet.row_buffer.ptr = NULL; in MYSQLND_METHOD()
1350 if (row_packet.eof) { in MYSQLND_METHOD()
1352 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet.warning_count); in MYSQLND_METHOD()
1353 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet.server_status); in MYSQLND_METHOD()
1374 COPY_CLIENT_ERROR(&set->error_info, row_packet.error_info); in MYSQLND_METHOD()
1385 PACKET_FREE(&row_packet); in MYSQLND_METHOD()
