forked from jiuyuan/InfiniTensor
75 lines
2.3 KiB
C++
75 lines
2.3 KiB
C++
#pragma once
|
|
#include "bang/bang_common.h"
|
|
#include "core/runtime.h"
|
|
|
|
namespace infini {
|
|
|
|
class BangRuntimeObj : public RuntimeObj {
|
|
private:
|
|
cnnlHandle_t cnnl;
|
|
BangPtr workspace;
|
|
size_t workspaceSize;
|
|
|
|
public:
|
|
BangRuntimeObj() : RuntimeObj(Device::BANG) {
|
|
cnInit(0);
|
|
CNdev dev;
|
|
cnDeviceGet(&dev, 0);
|
|
checkBangError(cnrtSetDevice(dev));
|
|
cnrtQueue_t queue;
|
|
checkBangError(cnrtQueueCreate(&queue));
|
|
|
|
checkCnnlError(cnnlCreate(&cnnl));
|
|
checkCnnlError(cnnlSetQueue(cnnl, queue));
|
|
// 10GB for Longformer
|
|
// size_t longformerNum = 3lu * (1 << 30);
|
|
workspaceSize = 7ll << 30; // 7 GB
|
|
workspace = alloc(workspaceSize);
|
|
}
|
|
virtual ~BangRuntimeObj() {
|
|
dealloc(workspace);
|
|
checkCnnlError(cnnlDestroy(cnnl));
|
|
}
|
|
string toString() const override;
|
|
|
|
void run(const Graph &graph, bool tune = false,
|
|
bool profiling = false) const;
|
|
// double runEvaluation(const Graph &graph, int nWarmups,
|
|
// int nEvaluations) const;
|
|
void sync() const;
|
|
BangPtr alloc(size_t size) override {
|
|
void *ptr;
|
|
checkBangError(cnrtMalloc(&ptr, size));
|
|
return ptr;
|
|
}
|
|
void dealloc(void *ptr) override { checkBangError(cnrtFree(ptr)); }
|
|
cnnlHandle_t cnnlHandle() const { return cnnl; }
|
|
BangPtr getWorkspace(size_t size) const {
|
|
IT_ASSERT(size <= workspaceSize);
|
|
return workspace;
|
|
}
|
|
|
|
void copyBlobFromCPU(void *dst, const void *src,
|
|
size_t bytes) const override {
|
|
checkBangError(cnrtMemcpy(dst, const_cast<void *>(src), bytes,
|
|
CNRT_MEM_TRANS_DIR_HOST2DEV));
|
|
}
|
|
|
|
void copyBlobToCPU(void *dst, const void *src,
|
|
size_t bytes) const override {
|
|
checkBangError(cnrtMemcpy(dst, const_cast<void *>(src), bytes,
|
|
CNRT_MEM_TRANS_DIR_DEV2HOST));
|
|
}
|
|
|
|
void copyBlobInsideRuntime(void *dst, const void *src,
|
|
size_t bytes) const override {
|
|
checkBangError(cnrtMemcpy(dst, const_cast<void *>(src), bytes,
|
|
CNRT_MEM_TRANS_DIR_PEER2PEER));
|
|
}
|
|
|
|
private:
|
|
void runWithoutSync(const Graph &graph, bool tune, bool profiling) const;
|
|
};
|
|
|
|
} // namespace infini
|