Host Code for Controlling Graph and Partition Reloading - Host Code for Controlling Graph and Partition Reloading - 2025.2 English - XD100

auto xclbin_1 = xrt::xclbin(xclbinfile_gr1);
auto uuid1 = device.register_xclbin(xclbin_1);
std::cout<<"xclbin file name:"<<xclbinfile_gr1<<std::endl;
xrt::hw_context *hwctx_1=new xrt::hw_context(device, uuid1);
std::cout<<"Load XCLBIN successfully"<<std::endl;

auto din_buffer = new xrt::aie::bo (*hwctx_1, BLOCK_SIZE_in_Bytes,xrt::bo::flags::normal, /*memory group*/0); //Only non-cacheable buffer is supported
int* dinArray= din_buffer->map<int*>();
auto dout_buffer = new xrt::aie::bo (*hwctx_1, BLOCK_SIZE_in_Bytes,xrt::bo::flags::normal, /*memory group*/0); //Only non-cacheable buffer is supported
int* doutArray= dout_buffer->map<int*>();
int* doutRef=(int*)malloc(BLOCK_SIZE_in_Bytes);
std::cout<<"Allocate buffer completed"<<std::endl;

int coeff[8]={1,2,3,4,5,6,7,8};

for(int i=0;i<ITERATION*1024/4;i++){
	dinArray[i]=i;
}

auto ghdl=new xrt::graph(*hwctx_1,"gr");
std::cout<<"Open partition 0 with graph1 successfully"<<std::endl;
xrt::aie::buffer *bufIn=new xrt::aie::buffer(*hwctx_1, "gr.gmioIn");
//memory group is 0, depending on the platform
bufIn->async(*din_buffer, XCL_BO_SYNC_BO_GMIO_TO_AIE, BLOCK_SIZE_in_Bytes, 0); 
ghdl->run(ITERATION);
xrt::aie::buffer *bufOut=new xrt::aie::buffer(*hwctx_1, "gr.gmioOut");
//memory group is 0, depending on the platform
bufOut->async(*dout_buffer, XCL_BO_SYNC_BO_AIE_TO_GMIO, BLOCK_SIZE_in_Bytes, 0);
//PS can do other tasks here when data is transferring
std::cout<<"Waiting for graph to be completed"<<std::endl;
bufOut->wait();

ref_func(dinArray,coeff,doutRef,ITERATION*1024/4);
for(int i=0;i<ITERATION*1024/4;i++){
	if(doutArray[i]!=doutRef[i]){
		std::cout<<"ERROR:dout["<<i<<"]="<<doutArray[i]<<",gold="<<doutRef[i]<<std::endl;
		error++;
	}
}

std::cout<<"GMIO transactions finished"<<std::endl;

ghdl->end();
if(error==0){
	std::cout<<"TEST PASSED!"<<std::endl;
}else{
	std::cout<<"ERROR!"<<std::endl;
}
//delete the objects that is associated to the hw context, and then delete the hw context.
delete bufIn;
delete bufOut;
delete din_buffer;
delete dout_buffer;
delete ghdl;
delete hwctx_1;

bufIn->wait();
bufIn2->wait();

#include <stdlib.h>
#include <fstream>
#include <iostream>
#include <unistd.h>
#include <math.h>
#include "xrt/xrt_kernel.h"
#include "xrt/xrt_graph.h"

const int ITERATION=4;
const int ELEM_per_iter=256;
int run(char* xclbinFilename_pl, char* xclbinFilename_aie, int rtp_type){

	size_t output_size_in_bytes = ELEM_per_iter*4*ITERATION;
	int ret;
	// Open xclbin
	auto dhdl = xrt::device(0); //device index=0
	auto xclbin_pl = xrt::xclbin(std::string(xclbinFilename_pl));
	auto uuid_pl = dhdl.register_xclbin(xclbin_pl);
	xrt::hw_context hwctx_pl{dhdl, uuid_pl};
	auto xclbin_aie = xrt::xclbin(std::string(xclbinFilename_aie));
	auto uuid_aie = dhdl.register_xclbin(xclbin_aie);
	xrt::hw_context hwctx_aie{dhdl, uuid_aie};

	// s2mm & datagen kernel handle
	auto s2mm = xrt::kernel(hwctx_pl, "s2mm:{s2mm_1}");
	auto datagen = xrt::kernel(hwctx_pl, "datagen");

	// output memory
	auto out_bo = xrt::bo(hwctx_pl, output_size_in_bytes,static_cast<xrt::bo::flags>(0),s2mm.group_id(0));
	auto host_out=out_bo.map<int*>();

	//kernel run
	auto s2mm_run = s2mm(out_bo, nullptr, ELEM_per_iter*ITERATION);//1st run for s2mm has started
	auto datagen_run = datagen(nullptr, ELEM_per_iter*ITERATION,0);

	auto ghdl=xrt::graph(hwctx_aie,"gr");
	ghdl.run(ITERATION);
	int value[16]={1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16};
	if(rtp_type==0){
		ghdl.update("gr.k.in[1]",10);
	}else if(rtp_type==1){
		ghdl.update("gr.k.in[1]",value);
	}
	ghdl.end();

	s2mm_run.wait();
	out_bo.sync(XCL_BO_SYNC_BO_FROM_DEVICE);

	int match = 0;
	int base=10;
	for (int i = 0; i < ITERATION; i++) {
		for(int j=0;j<ELEM_per_iter;j++){
			if(rtp_type==0){
				if(host_out[ELEM_per_iter*i+j]!=base+i*ELEM_per_iter+j){
					match=1;
				}
			}else if(rtp_type==1){
				if(host_out[ELEM_per_iter*i+j]!=value[j%16]+i*ELEM_per_iter+j){
					match=1;
				}
			}
		}
	}

	return match;
}

int main(int argc, char* argv[])
{
	try {
		if(argc != 3 && argc != 4) {
			std::cout << "Usage: " << argv[0] <<" <pl.xclbin> <aie_only.xclbin> <aie_only_second.xclbin>" << std::endl;
			return EXIT_FAILURE;
		}
		char* xclbinFilename_pl = argv[1];
		char* xclbinFilename_aie = argv[2];
		auto match = run(xclbinFilename_pl, xclbinFilename_aie,0);
		std::cout << "TEST PR1 Graph0 " << (match ? "FAILED" : "PASSED") << "\n";
		if(argc==4){//Do second xclbin reload
			xclbinFilename_aie = argv[3];
			match = run(xclbinFilename_pl, xclbinFilename_aie,1);
			std::cout << "TEST PR1 SECOND GRAPH " << (match ? "FAILED" : "PASSED") << "\n";
		}
		return (match ? EXIT_FAILURE :  EXIT_SUCCESS);
	}	
		catch (std::exception const& e) {
		std::cout << "Exception: " << e.what() << "\n";
		std::cout << "FAILED TEST\n";
		return 1;
	}
}