本文整理汇总了C++中scoped_array类的典型用法代码示例。如果您正苦于以下问题:C++ scoped_array类的具体用法?C++ scoped_array怎么用?C++ scoped_array使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了scoped_array类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: buf
void XEReader::readPortAliases(PortAliases &aliases)
{
const XESector *XNSector = xe.getXNSector();
if (!XNSector)
return;
uint64_t length = XNSector->getLength();
const scoped_array<char> buf(new char[length + 1]);
if (!XNSector->getData(buf.get())) {
std::cerr << "Error reading XN from \"" << xe.getFileName() << "\"";
std::cerr << std::endl;
std::exit(1);
}
if (length < 8) {
std::cerr << "Error unexpected XN sector length" << std::endl;
std::exit(1);
}
length -= 8;
buf[length] = '\0';
xmlDoc *doc = xmlReadDoc(BAD_CAST buf.get(), "platform_def.xn", NULL, 0);
xmlDoc *newDoc = applyXSLTTransform(doc, XNTransform);
xmlFreeDoc(doc);
if (!checkDocAgainstSchema(newDoc, XNSchema, sizeof(XNSchema)))
std::exit(1);
::readPortAliases(aliases, xmlDocGetRootElement(newDoc));
xmlFreeDoc(newDoc);
}
开发者ID:ajwlucas,项目名称:tool_axe,代码行数:28,代码来源:XEReader.cpp
示例2: LCSLength
void LCSLength( scoped_array<scoped_array<size_t> >& C ,vector_start_at_zero<SgNode*>& A, vector_start_at_zero<SgNode*>& B )
{
int m = A.size()+1;
int n = B.size()+1;
C.reset(new scoped_array<size_t>[m]);
for (int i = 0 ; i < m; i++)
C[i].reset(new size_t[n]);
for (size_t i = 0 ; i <= A.size() ; i++)
C[i][0]=0;
for (size_t i = 0 ; i <= B.size() ; i++)
C[0][i]=0;
for (size_t i = 1 ; i <= A.size() ; i++)
for (size_t j = 1 ; j <= B.size() ; j++)
{
if(isEqual(A[i],B[j]))
C[i][j] = C[i-1][j-1]+1;
else
C[i][j] = C[i][j-1] > C[i-1][j] ? C[i][j-1] : C[i-1][j];
}
}
开发者ID:8l,项目名称:rose,代码行数:27,代码来源:evaluateAllBinaries.C
示例3: loadFileData
bool loadFileData(const boost::filesystem::path& path,
scoped_array<char>& fileData,
int& fileSize) {
fs::ifstream ifs(path, ifstream::in | ifstream::binary);
if (!ifs) {
ostringstream oss;
oss << "Could not open file \"" << path << "\".";
throw rlvm::Exception(oss.str());
}
ifs.seekg(0, ios::end);
fileSize = ifs.tellg();
ifs.seekg(0, ios::beg);
fileData.reset(new char[fileSize]);
ifs.read(fileData.get(), fileSize);
return !ifs.good();
}
开发者ID:Morlok8k,项目名称:rlvm,代码行数:19,代码来源:File.cpp
示例4: WriteConsoleInput
void ConsoleHandler::WriteConsoleInput(HANDLE hStdIn, scoped_array<INPUT_RECORD>& consoleInputs, size_t& consoleInputCount, size_t maxConsoleInputCount)
{
if (consoleInputCount > 0)
{
DWORD dwTextWritten = 0;
::WriteConsoleInput(hStdIn, consoleInputs.get(), static_cast<DWORD>(consoleInputCount), &dwTextWritten);
}
if (maxConsoleInputCount > 0)
{
consoleInputs.reset(new INPUT_RECORD[maxConsoleInputCount]);
::ZeroMemory(consoleInputs.get(), sizeof(INPUT_RECORD)*maxConsoleInputCount);
}
else
{
consoleInputs.reset();
}
consoleInputCount = 0;
}
开发者ID:i-e-b,项目名称:windows-ssh-server,代码行数:20,代码来源:ConsoleHandler.cpp
示例5: swap
template<class T> inline void swap(scoped_array<T> & a, scoped_array<T> & b) // never throws
{
a.swap(b);
}
开发者ID:xhy20070406,项目名称:PDAL,代码行数:4,代码来源:scoped_array.hpp
示例6: swap
inline void swap(scoped_array<T> & a, scoped_array<T> & b)
{
a.swap(b);
}
开发者ID:paoletto,项目名称:space-blok-qt,代码行数:4,代码来源:scoped_array.hpp
示例7: createSystemFromConfig
static inline std::auto_ptr<SystemState>
createSystemFromConfig(const char *filename, const XESector *configSector)
{
uint64_t length = configSector->getLength();
const scoped_array<char> buf(new char[length + 1]);
if (!configSector->getData(buf.get())) {
std::cerr << "Error reading config from \"" << filename << "\"" << std::endl;
std::exit(1);
}
if (length < 8) {
std::cerr << "Error unexpected config config sector length" << std::endl;
std::exit(1);
}
length -= 8;
buf[length] = '\0';
/*
* this initialize the library and check potential ABI mismatches
* between the version it was compiled for and the actual shared
* library used.
*/
LIBXML_TEST_VERSION
xmlDoc *doc = xmlReadDoc((xmlChar*)buf.get(), "config.xml", NULL, 0);
xmlRelaxNGParserCtxtPtr schemaContext =
xmlRelaxNGNewMemParserCtxt(configSchema, sizeof(configSchema));
xmlRelaxNGPtr schema = xmlRelaxNGParse(schemaContext);
xmlRelaxNGValidCtxtPtr validationContext =
xmlRelaxNGNewValidCtxt(schema);
if (xmlRelaxNGValidateDoc(validationContext, doc) != 0) {
std::exit(1);
}
xmlNode *root = xmlDocGetRootElement(doc);
xmlNode *system = findChild(root, "System");
xmlNode *nodes = findChild(system, "Nodes");
std::auto_ptr<SystemState> systemState(new SystemState);
std::map<long,Node*> nodeNumberMap;
for (xmlNode *child = nodes->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("Node", (char*)child->name) != 0)
continue;
systemState->addNode(createNodeFromConfig(child, nodeNumberMap));
}
xmlNode *connections = findChild(system, "Connections");
for (xmlNode *child = connections->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("SLink", (char*)child->name) != 0)
continue;
long nodeID1, link1, nodeID2, link2;
if (!parseXLinkEnd(findAttribute(child, "end1"), nodeID1, link1)) {
std::cerr << "Failed to parse \"end1\" attribute" << std::endl;
std::exit(1);
}
if (!parseXLinkEnd(findAttribute(child, "end2"), nodeID2, link2)) {
std::cerr << "Failed to parse \"end2\" attribute" << std::endl;
std::exit(1);
}
Node *node1 = lookupNodeChecked(nodeNumberMap, nodeID1);
if (link1 >= node1->getNumXLinks()) {
std::cerr << "Invalid sLink number " << link1 << std::endl;
std::exit(1);
}
Node *node2 = lookupNodeChecked(nodeNumberMap, nodeID2);
if (link2 >= node2->getNumXLinks()) {
std::cerr << "Invalid sLink number " << link2 << std::endl;
std::exit(1);
}
node1->connectXLink(link1, node2, link2);
node2->connectXLink(link2, node1, link1);
}
xmlNode *jtag = findChild(system, "JtagChain");
unsigned jtagIndex = 0;
for (xmlNode *child = jtag->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("Node", (char*)child->name) != 0)
continue;
long nodeID = readNumberAttribute(child, "id");
lookupNodeChecked(nodeNumberMap, nodeID)->setJtagIndex(jtagIndex++);
}
systemState->finalize();
xmlFreeDoc(doc);
xmlCleanupParser();
return systemState;
}
开发者ID:hoangt,项目名称:tool_axe,代码行数:86,代码来源:main.cpp
示例8: readElf
static void readElf(const char *filename, const XEElfSector *elfSector,
Core &core, std::auto_ptr<CoreSymbolInfo> &SI,
std::map<Core*,uint32_t> &entryPoints)
{
uint64_t ElfSize = elfSector->getElfSize();
const scoped_array<char> buf(new char[ElfSize]);
if (!elfSector->getElfData(buf.get())) {
std::cerr << "Error reading elf data from \"" << filename << "\"" << std::endl;
std::exit(1);
}
if (elf_version(EV_CURRENT) == EV_NONE) {
std::cerr << "ELF library intialisation failed: "
<< elf_errmsg(-1) << std::endl;
std::exit(1);
}
Elf *e;
if ((e = elf_memory(buf.get(), ElfSize)) == NULL) {
std::cerr << "Error reading ELF: " << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (elf_kind(e) != ELF_K_ELF) {
std::cerr << filename << " is not an ELF object" << std::endl;
std::exit(1);
}
GElf_Ehdr ehdr;
if (gelf_getehdr(e, &ehdr) == NULL) {
std::cerr << "Reading ELF header failed: " << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (ehdr.e_machine != XCORE_ELF_MACHINE) {
std::cerr << "Not a XCore ELF" << std::endl;
std::exit(1);
}
if (ehdr.e_entry != 0) {
entryPoints.insert(std::make_pair(&core, (uint32_t)ehdr.e_entry));
}
unsigned num_phdrs = ehdr.e_phnum;
if (num_phdrs == 0) {
std::cerr << "No ELF program headers" << std::endl;
std::exit(1);
}
core.resetCaches();
uint32_t ram_base = core.ram_base;
uint32_t ram_size = core.getRamSize();
for (unsigned i = 0; i < num_phdrs; i++) {
GElf_Phdr phdr;
if (gelf_getphdr(e, i, &phdr) == NULL) {
std::cerr << "Reading ELF program header " << i << " failed: " << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (phdr.p_filesz == 0) {
continue;
}
if (phdr.p_offset > ElfSize) {
std::cerr << "Invalid offet in ELF program header" << i << std::endl;
std::exit(1);
}
if (!core.isValidAddress(phdr.p_paddr) ||
!core.isValidAddress(phdr.p_paddr + phdr.p_memsz)) {
std::cerr << "Error data from ELF program header " << i;
std::cerr << " does not fit in memory" << std::endl;
std::exit(1);
}
core.writeMemory(phdr.p_paddr, &buf[phdr.p_offset], phdr.p_filesz);
}
readSymbols(e, ram_base, ram_base + ram_size, SI);
elf_end(e);
}
开发者ID:hoangt,项目名称:tool_axe,代码行数:71,代码来源:main.cpp
示例9: swap
void swap(scoped_array<T, P, R, D> & a, scoped_array<T, P, R, D> & b)
{
a.swap(b);
}
开发者ID:BackupTheBerlios,项目名称:breeze-svn,代码行数:4,代码来源:scoped_array.hpp
示例10: buf
int BootSequenceStepElf::execute(ExecutionState &state)
{
SystemState &sys = state.sys;
BreakpointManager &BM = state.breakpointManager;
uint64_t ElfSize = elfSector->getElfSize();
const scoped_array<char> buf(new char[ElfSize]);
if (!elfSector->getElfData(buf.get())) {
std::cerr << "Error reading ELF data from ELF sector" << std::endl;
std::exit(1);
}
Elf *e;
if ((e = elf_memory(buf.get(), ElfSize)) == NULL) {
std::cerr << "Error reading ELF: " << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (elf_kind(e) != ELF_K_ELF) {
std::cerr << "ELF section is not an ELF object" << std::endl;
std::exit(1);
}
GElf_Ehdr ehdr;
if (gelf_getehdr(e, &ehdr) == NULL) {
std::cerr << "Reading ELF header failed: " << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (ehdr.e_machine != XCORE_ELF_MACHINE &&
ehdr.e_machine != XCORE_ELF_MACHINE_OLD) {
std::cerr << "Not a XCore ELF" << std::endl;
std::exit(1);
}
uint32_t entryPoint = core->getRamBase();
if (ehdr.e_entry != 0) {
if (core->isValidRamAddress(ehdr.e_entry)) {
entryPoint = ehdr.e_entry;
} else {
std::cout << "Warning: invalid ELF entry point 0x";
std::cout << std::hex << ehdr.e_entry << std::dec << "\n";
}
}
uint32_t ram_base = core->getRamBase();
uint32_t ram_size = core->getRamSize();
if (loadImage) {
unsigned num_phdrs = ehdr.e_phnum;
if (num_phdrs == 0) {
std::cerr << "No ELF program headers" << std::endl;
std::exit(1);
}
for (unsigned i = 0; i < num_phdrs; i++) {
GElf_Phdr phdr;
if (gelf_getphdr(e, i, &phdr) == NULL) {
std::cerr << "Reading ELF program header " << i << " failed: ";
std::cerr << elf_errmsg(-1) << std::endl;
std::exit(1);
}
if (phdr.p_filesz == 0) {
continue;
}
if (phdr.p_offset > ElfSize) {
std::cerr << "Invalid offet in ELF program header" << i << std::endl;
std::exit(1);
}
if (!core->isValidRamAddress(phdr.p_paddr) ||
!core->isValidRamAddress(phdr.p_paddr + phdr.p_memsz)) {
std::cerr << "Error data from ELF program header " << i;
std::cerr << " does not fit in memory" << std::endl;
std::exit(1);
}
core->writeMemory(phdr.p_paddr, &buf[phdr.p_offset], phdr.p_filesz);
}
}
std::auto_ptr<CoreSymbolInfo> CSI;
readSymbols(e, ram_base, ram_base + ram_size, CSI);
SymbolInfo &SI = sys.getSymbolInfo();
SI.add(core, CSI);
// Patch in syscall instruction at the syscall address.
if (const ElfSymbol *syscallSym = SI.getGlobalSymbol(core, "_DoSyscall")) {
if (!BM.setBreakpoint(*core, syscallSym->value, BreakpointType::Syscall)) {
std::cout << "Warning: invalid _DoSyscall address "
<< std::hex << syscallSym->value << std::dec << "\n";
}
}
// Patch in exception instruction at the exception address
if (const ElfSymbol *doExceptionSym = SI.getGlobalSymbol(core, "_DoException")) {
if (!BM.setBreakpoint(*core, doExceptionSym->value,
BreakpointType::Exception)) {
std::cout << "Warning: invalid _DoException address "
<< std::hex << doExceptionSym->value << std::dec << "\n";
}
}
if (useElfEntryPoint) {
sys.schedule(core->getThread(0));
core->getThread(0).setPcFromAddress(entryPoint);
}
elf_end(e);
return 0;
}
开发者ID:Srinivas-E,项目名称:tool_axe,代码行数:98,代码来源:BootSequencer.cpp
示例11:
inline bool operator != (T* __lhs, const scoped_array<T>& __rhs)
{
return __lhs != __rhs.get();
}
开发者ID:alex8374,项目名称:ufc,代码行数:4,代码来源:scoped_array.hpp
示例12: createSystemFromConfig
static std::auto_ptr<SystemState>
createSystemFromConfig(const std::string &filename,
const XESector *configSector,
bool tracing)
{
uint64_t length = configSector->getLength();
const scoped_array<char> buf(new char[length + 1]);
if (!configSector->getData(buf.get())) {
std::cerr << "Error reading config from \"" << filename << "\"" << std::endl;
std::exit(1);
}
if (length < 8) {
std::cerr << "Error unexpected config config sector length" << std::endl;
std::exit(1);
}
length -= 8;
buf[length] = '\0';
xmlDoc *doc = xmlReadDoc(BAD_CAST buf.get(), "config.xml", NULL, 0);
if (!checkDocAgainstSchema(doc, configSchema, sizeof(configSchema)))
std::exit(1);
xmlNode *root = xmlDocGetRootElement(doc);
xmlNode *system = findChild(root, "System");
xmlNode *nodes = findChild(system, "Nodes");
std::auto_ptr<SystemState> systemState(new SystemState(tracing));
std::map<long,Node*> nodeNumberMap;
for (xmlNode *child = nodes->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("Node", (char*)child->name) != 0)
continue;
systemState->addNode(createNodeFromConfig(child, nodeNumberMap, tracing));
}
xmlNode *connections = findChild(system, "Connections");
for (xmlNode *child = connections->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("SLink", (char*)child->name) != 0)
continue;
long nodeID1, link1, nodeID2, link2;
if (!parseXLinkEnd(findAttribute(child, "end1"), nodeID1, link1)) {
std::cerr << "Failed to parse \"end1\" attribute" << std::endl;
std::exit(1);
}
if (!parseXLinkEnd(findAttribute(child, "end2"), nodeID2, link2)) {
std::cerr << "Failed to parse \"end2\" attribute" << std::endl;
std::exit(1);
}
Node *node1 = lookupNodeChecked(nodeNumberMap, nodeID1);
if (link1 >= node1->getNumXLinks()) {
std::cerr << "Invalid sLink number " << link1 << std::endl;
std::exit(1);
}
Node *node2 = lookupNodeChecked(nodeNumberMap, nodeID2);
if (link2 >= node2->getNumXLinks()) {
std::cerr << "Invalid sLink number " << link2 << std::endl;
std::exit(1);
}
node1->connectXLink(link1, node2, link2);
node2->connectXLink(link2, node1, link1);
}
xmlNode *jtag = findChild(system, "JtagChain");
unsigned jtagIndex = 0;
for (xmlNode *child = jtag->children; child; child = child->next) {
if (child->type != XML_ELEMENT_NODE ||
strcmp("Node", (char*)child->name) != 0)
continue;
long nodeID = readNumberAttribute(child, "id");
lookupNodeChecked(nodeNumberMap, nodeID)->setJtagIndex(jtagIndex++);
}
systemState->finalize();
xmlFreeDoc(doc);
return systemState;
}
开发者ID:ajwlucas,项目名称:tool_axe,代码行数:74,代码来源:XEReader.cpp
示例13: init_problem
// Initialize the data for the problem. Requires num_devices to be known.
void init_problem() {
if(num_devices == 0) {
checkError(-1, "No devices");
}
input_a.reset(num_devices);
input_b.reset(num_devices);
output.reset(num_devices);
ref_output.reset(num_devices);
// Generate input vectors A and B and the reference output consisting
// of a total of N elements.
// We create separate arrays for each device so that each device has an
// aligned buffer.
for(unsigned i = 0; i < num_devices; ++i) {
input_a[i].reset(n_per_device[i]);
input_b[i].reset(n_per_device[i]);
output[i].reset(n_per_device[i]);
ref_output[i].reset(n_per_device[i]);
for(unsigned j = 0; j < n_per_device[i]; ++j) {
input_a[i][j] = rand_float();
input_b[i][j] = rand_float();
ref_output[i][j] = input_a[i][j] + input_b[i][j];
}
}
}
开发者ID:arnabd88,项目名称:CIVL-CS6110,代码行数:28,代码来源:main.cpp
示例14: init_problem
// Initialize the data for the problem. Requires num_devices to be known.
void init_problem() {
if(num_devices == 0) {
checkError(-1, "No devices");
}
printf("Generating input matrices\n");
input_a.reset(num_devices);
output.reset(num_devices);
for(unsigned i = 0; i < num_devices; ++i) {
input_a[i].reset(A_height * A_width);
output[i].reset(C_height * C_width);
// printf("array A elements\n");
for(unsigned j = 0; j < A_height * A_width; ++j) {
if(((j%1028)==0) || ((j%1028)>=1025) || ((j/1028)==0) || (j/1028)==1025) {
input_a[i][j] = 0.0f;
}
else {
input_a[i][j] = rand_float();
}
}
}
}
开发者ID:chrisjia6412,项目名称:stencil-codes-tuning,代码行数:25,代码来源:main_SRP_TC4.cpp
示例15: compute_reference
void compute_reference() {
// Compute the reference output.
printf("Computing reference output\n");
ref_output.reset(C_height * C_width);
for(unsigned y = 0; y < C_height; ++y) {
for(unsigned x = 0; x < C_width; ++x) {
float sum = 0.0f;
if(y>=1 && x>=1 && x<=1024)
sum = 0.2*(input_a[0][(y)*A_width+x] + input_a[0][(y-1)*A_width+x] + input_a[0][(y+1)*A_width+x] + input_a[0][(y)*A_width+x-1] + input_a[0][(y)*A_width+x+1]);
ref_output[y*1028+x] = sum;
}
}
}
开发者ID:chrisjia6412,项目名称:stencil-codes-tuning,代码行数:16,代码来源:main_SRP_TC4.cpp
示例16: compute_reference
void compute_reference() {
// Compute the reference output.
printf("Computing reference output\n");
ref_output.reset(C_height * C_width);
for(unsigned y = 0, dev_index = 0; y < C_height; ++dev_index) {
for(unsigned yy = 0; yy < rows_per_device[dev_index]; ++yy, ++y) {
for(unsigned x = 0; x < C_width; ++x) {
// Compute result for C(y, x)
float sum = 0.0f;
for(unsigned k = 0; k < A_width; ++k) {
sum += input_a[dev_index][yy * A_width + k] * input_b[k * B_width + x];
}
ref_output[y * C_width + x] = sum;
}
}
}
}
开发者ID:DiamonDinoia,项目名称:test-regression,代码行数:18,代码来源:main_old.cpp
示例17: add
void add( T* t )
{
BOOST_ASSERT( ptrs_.get() != 0 );
ptrs_[stored_] = t;
++stored_;
}
开发者ID:Niko-r,项目名称:geofeatures,代码行数:6,代码来源:scoped_deleter.hpp
示例18: init_problem
// Initialize the data for the problem. Requires num_devices to be known.
void init_problem() {
if(num_devices == 0) {
checkError(-1, "No devices");
}
// Generate input matrices A and B. For matrix A, we divide up the host
// buffers so that the buffers are aligned for each device. The whole of
// matrix B is used by each device, so it does not need to be divided.
printf("Generating input matrices\n");
input_a.reset(num_devices);
output.reset(num_devices);
#if USE_SVM_API == 0
for(unsigned i = 0; i < num_devices; ++i) {
input_a[i].reset(rows_per_device[i] * A_width);
output[i].reset(rows_per_device[i] * C_width);
for(unsigned j = 0; j < rows_per_device[i] * A_width; ++j) {
input_a[i][j] = rand_float();
}
}
input_b.reset(B_height * B_width);
for(unsigned i = 0; i < B_height * B_width; ++i) {
input_b[i] = rand_float();
}
#else
for(unsigned i = 0; i < num_devices; ++i) {
input_a[i].reset(context, rows_per_device[i] * A_width);
output[i].reset(context, rows_per_device[i] * C_width);
cl_int status;
status = clEnqueueSVMMap(queue[i], CL_TRUE, CL_MAP_WRITE,
(void *)input_a[i], rows_per_device[i] * A_width * sizeof(float), 0, NULL, NULL);
checkError(status, "Failed to map input A");
for(unsigned j = 0; j < rows_per_device[i] * A_width; ++j) {
input_a[i][j] = rand_float();
}
status = clEnqueueSVMUnmap(queue[i], (void *)input_a[i], 0, NULL, NULL);
checkError(status, "Failed to unmap input A");
}
input_b.reset(context, B_height * B_width);
cl_int status;
for (unsigned i = 0; i < num_devices; ++i) {
status = clEnqueueSVMMap(queue[i], CL_TRUE, CL_MAP_WRITE,
(void *)input_b, B_height * B_width * sizeof(float), 0, NULL, NULL);
checkError(status, "Failed to map input B");
}
for(unsigned i = 0; i < B_height * B_width; ++i) {
input_b[i] = rand_float();
}
for (unsigned i = 0; i < num_devices; ++i) {
status = clEnqueueSVMUnmap(queue[i], (void *)input_b, 0, NULL, NULL);
checkError(status, "Failed to unmap input B");
}
#endif /* USE_SVM_API == 0 */
}
开发者ID:DiamonDinoia,项目名称:test-regression,代码行数:65,代码来源:main_old.cpp
示例19: init_opencl
// Initializes the OpenCL objects.
bool init_opencl() {
cl_int status;
printf("Initializing OpenCL\n");
if(!setCwdToExeDir()) {
return false;
}
// Get the OpenCL platform.
platform = findPlatform("Intel(R) FPGA SDK for OpenCL(TM)");
if(platform == NULL) {
printf("ERROR: Unable to find Intel(R) FPGA OpenCL platform.\n");
return false;
}
// Query the available OpenCL device.
device.reset(getDevices(platform, CL_DEVICE_TYPE_ALL, &num_devices));
printf("Platform: %s\n", getPlatformName(platform).c_str());
printf("Using %d device(s)\n", num_devices);
for(unsigned i = 0; i < num_devices; ++i) {
printf(" %s\n", getDeviceName(device[i]).c_str());
}
// Create the context.
context = clCreateContext(NULL, num_devices, device, &oclContextCallback, NULL, &status);
checkError(status, "Failed to create context");
// Create the program for all device. Use the first device as the
// representative device (assuming all device are of the same type).
std::string binary_file = getBoardBinaryFile("matrix_mult", device[0]);
printf("Using AOCX: %s\n", binary_file.c_str());
program = createProgramFromBinary(context, binary_file.c_str(), device, num_devices);
// Build the program that was just created.
status = clBuildProgram(program, 0, NULL, "", NULL, NULL);
checkError(status, "Failed to build program");
// Create per-device objects.
queue.reset(num_devices);
kernel.reset(num_devices);
rows_per_device.reset(num_devices);
#if USE_SVM_API == 0
input_a_buf.reset(num_devices);
input_b_buf.reset(num_devices);
output_buf.reset(num_devices);
#endif /* USE_SVM_API == 0 */
const unsigned num_block_rows = C_height / BLOCK_SIZE;
for(unsigned i = 0; i < num_devices; ++i) {
// Command queue.
queue[i] = clCreateCommandQueue(context, device[i], CL_QUEUE_PROFILING_ENABLE, &status);
checkError(status, "Failed to create command queue");
// Kernel.
const char *kernel_name = "matrixMult";
kernel[i] = clCreateKernel(program, kernel_name, &status);
checkError(status, "Failed to create kernel");
// Determine the number of rows processed by this device.
// First do this computation in block-rows.
rows_per_device[i] = num_block_rows / num_devices; // this is the number of block-rows
// Spread out the remainder of the block-rows over the first
// N % num_devices.
if(i < (num_block_rows % num_devices)) {
rows_per_device[i]++;
}
// Multiply by BLOCK_SIZE to get the actual number of rows.
rows_per_device[i] *= BLOCK_SIZE;
#if USE_SVM_API == 0
// Input buffers.
// For matrix A, each device only needs the rows corresponding
// to the rows of the output matrix. We specifically
// assign this buffer to the first bank of global memory.
input_a_buf[i] = clCreateBuffer(context, CL_MEM_READ_ONLY | CL_CHANNEL_1_INTELFPGA,
rows_per_device[i] * A_width * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for input A");
// For matrix B, each device needs the whole matrix. We specifically
// assign this buffer to the second bank of global memory.
input_b_buf[i] = clCreateBuffer(context, CL_MEM_READ_ONLY | CL_CHANNEL_2_INTELFPGA,
B_height * B_width * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for input B");
// Output buffer. This is matrix C, for the rows that are computed by this
// device. We assign this buffer to the first bank of global memory,
// although it is not material to performance to do so because
// the reads from the input matrices are far more frequent than the
// write to the output matrix.
output_buf[i] = clCreateBuffer(context, CL_MEM_WRITE_ONLY | CL_CHANNEL_1_INTELFPGA,
rows_per_device[i] * C_width * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for output");
#else
cl_device_svm_capabilities caps = 0;
//.........这里部分代码省略.........
开发者ID:DiamonDinoia,项目名称:test-regression,代码行数:101,代码来源:main_old.cpp
示例20: init_opencl
// Initializes the OpenCL objects.
bool init_opencl() {
cl_int status;
printf("Initializing OpenCL\n");
if(!setCwdToExeDir()) {
return false;
}
// Get the OpenCL platform.
platform = findPlatform("Altera");
if(platform == NULL) {
printf("ERROR: Unable to find Altera OpenCL platform.\n");
return false;
}
// Query the available OpenCL device.
device.reset(getDevices(platform, CL_DEVICE_TYPE_ALL, &num_devices));
printf("Platform: %s\n", getPlatformName(platform).c_str());
printf("Using %d device(s)\n", num_devices);
for(unsigned i = 0; i < num_devices; ++i) {
printf(" %s\n", getDeviceName(device[i]).c_str());
}
// Create the context.
context = clCreateContext(NULL, num_devices, device, NULL, NULL, &status);
checkError(status, "Failed to create context");
// Create the program for all device. Use the first device as the
// representative device (assuming all device are of the same type).
std::string binary_file = getBoardBinaryFile("vectorAdd", device[0]);
printf("Using AOCX: %s\n", binary_file.c_str());
program = createProgramFromBinary(context, binary_file.c_str(), device, num_devices);
// Build the program that was just created.
status = clBuildProgram(program, 0, NULL, "", NULL, NULL);
checkError(status, "Failed to build program");
// Create per-device objects.
queue.reset(num_devices);
kernel.reset(num_devices);
n_per_device.reset(num_devices);
input_a_buf.reset(num_devices);
input_b_buf.reset(num_devices);
output_buf.reset(num_devices);
for(unsigned i = 0; i < num_devices; ++i) {
// Command queue.
queue[i] = clCreateCommandQueue(context, device[i], CL_QUEUE_PROFILING_ENABLE, &status);
checkError(status, "Failed to create command queue");
// Kernel.
const char *kernel_name = "vectorAdd";
kernel[i] = clCreateKernel(program, kernel_name, &status);
checkError(status, "Failed to create kernel");
// Determine the number of elements processed by this device.
n_per_device[i] = N / num_devices; // number of elements handled by this device
// Spread out the remainder of the elements over the first
// N % num_devices.
if(i < (N % num_devices)) {
n_per_device[i]++;
}
// Input buffers.
input_a_buf[i] = clCreateBuffer(context, CL_MEM_READ_ONLY,
n_per_device[i] * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for input A");
input_b_buf[i] = clCreateBuffer(context, CL_MEM_READ_ONLY,
n_per_device[i] * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for input B");
// Output buffer.
output_buf[i] = clCreateBuffer(context, CL_MEM_WRITE_ONLY,
n_per_device[i] * sizeof(float), NULL, &status);
checkError(status, "Failed to create buffer for output");
}
return true;
}
开发者ID:arnabd88,项目名称:CIVL-CS6110,代码行数:83,代码来源:main.cpp
注:本文中的scoped_array类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论