Lines Matching refs:row_packet
185 if (result->row_packet) { in MYSQLND_METHOD()
186 PACKET_FREE(result->row_packet); in MYSQLND_METHOD()
187 mnd_efree(result->row_packet); in MYSQLND_METHOD()
188 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()
748 } else if (row_packet->eof) { in MYSQLND_METHOD()
750 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
754 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
755 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
783 MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; in MYSQLND_METHOD() local
799 if (!row_packet) { in MYSQLND_METHOD()
804 row_packet->skip_extraction = row? FALSE:TRUE; in MYSQLND_METHOD()
813 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in MYSQLND_METHOD()
816 result->unbuf->last_row_data = row_packet->fields; in MYSQLND_METHOD()
817 result->unbuf->last_row_buffer = row_packet->row_buffer; in MYSQLND_METHOD()
818 row_packet->fields = NULL; in MYSQLND_METHOD()
819 row_packet->row_buffer.ptr = NULL; in MYSQLND_METHOD()
823 if (!row_packet->skip_extraction) { in MYSQLND_METHOD()
829 row_packet->fields_metadata, in MYSQLND_METHOD()
880 if (row_packet->error_info.error_no) { in MYSQLND_METHOD()
881 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in MYSQLND_METHOD()
882 … DBG_ERR_FMT("errorno=%u error=%s", row_packet->error_info.error_no, row_packet->error_info.error); in MYSQLND_METHOD()
888 } else if (row_packet->eof) { in MYSQLND_METHOD()
890 DBG_INF_FMT("warnings=%u server_status=%u", row_packet->warning_count, row_packet->server_status); in MYSQLND_METHOD()
894 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in MYSQLND_METHOD()
895 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in MYSQLND_METHOD()
944 struct st_mysqlnd_packet_row *row_packet = mnd_emalloc(sizeof(struct st_mysqlnd_packet_row)); in MYSQLND_METHOD() local
946 conn->payload_decoder_factory->m.init_row_packet(row_packet); in MYSQLND_METHOD()
947 row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; in MYSQLND_METHOD()
948 row_packet->field_count = result->field_count; in MYSQLND_METHOD()
949 row_packet->binary_protocol = ps; in MYSQLND_METHOD()
950 row_packet->fields_metadata = result->meta->fields; in MYSQLND_METHOD()
952 result->unbuf->row_packet = row_packet; in MYSQLND_METHOD()
1276 MYSQLND_PACKET_ROW row_packet; in MYSQLND_METHOD() local
1286 conn->payload_decoder_factory->m.init_row_packet(&row_packet); in MYSQLND_METHOD()
1289 row_packet.result_set_memory_pool = result->stored_data->result_set_memory_pool; in MYSQLND_METHOD()
1290 row_packet.field_count = meta->field_count; in MYSQLND_METHOD()
1291 row_packet.binary_protocol = binary_protocol; in MYSQLND_METHOD()
1292 row_packet.fields_metadata = meta->fields; in MYSQLND_METHOD()
1294 …row_packet.skip_extraction = TRUE; /* let php_mysqlnd_rowp_read() not allocate row_packet.fields, … in MYSQLND_METHOD()
1296 while (FAIL != (ret = PACKET_READ(conn, &row_packet)) && !row_packet.eof) { in MYSQLND_METHOD()
1332 (*row_buffers)[set->row_count] = row_packet.row_buffer; in MYSQLND_METHOD()
1337 row_packet.fields = NULL; in MYSQLND_METHOD()
1338 row_packet.row_buffer.ptr = NULL; in MYSQLND_METHOD()
1354 if (row_packet.eof) { in MYSQLND_METHOD()
1356 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet.warning_count); in MYSQLND_METHOD()
1357 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet.server_status); in MYSQLND_METHOD()
1385 COPY_CLIENT_ERROR(&set->error_info, row_packet.error_info); in MYSQLND_METHOD()
1396 PACKET_FREE(&row_packet); in MYSQLND_METHOD()
