mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-22 04:36:42 +00:00
Cache key is contract code. Does not work
This commit is contained in:
parent
7c9cf6e5e7
commit
da02a1869d
5 changed files with 19 additions and 13 deletions
|
|
@ -196,7 +196,7 @@ int main(int argc, char** argv)
|
||||||
data.code = bytecode.data();
|
data.code = bytecode.data();
|
||||||
|
|
||||||
// BROKEN: env_* functions must be implemented & RuntimeData struct created
|
// BROKEN: env_* functions must be implemented & RuntimeData struct created
|
||||||
auto result = engine.run(std::move(module), &data, nullptr);
|
auto result = engine.run(std::move(module), &data, nullptr, bytecode);
|
||||||
return static_cast<int>(result);
|
return static_cast<int>(result);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -27,7 +27,7 @@ ExecBundle& Cache::registerExec(Cache::Key _key, ExecBundle&& _exec)
|
||||||
auto& map = getCacheMap();
|
auto& map = getCacheMap();
|
||||||
auto r = map.insert(std::make_pair(_key, std::move(_exec)));
|
auto r = map.insert(std::make_pair(_key, std::move(_exec)));
|
||||||
assert(r.second && "Updating cached objects not supported");
|
assert(r.second && "Updating cached objects not supported");
|
||||||
LOG() << "add " << _key << "\n";
|
LOG() << "add\n";
|
||||||
return r.first->second; // return exec, now owned by cache
|
return r.first->second; // return exec, now owned by cache
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -37,10 +37,10 @@ ExecBundle* Cache::findExec(Cache::Key _key)
|
||||||
auto it = map.find(_key);
|
auto it = map.find(_key);
|
||||||
if (it != map.end())
|
if (it != map.end())
|
||||||
{
|
{
|
||||||
LOG() << "hit " << _key << "\n";
|
LOG() << "hit\n";
|
||||||
return &it->second;
|
return &it->second;
|
||||||
}
|
}
|
||||||
LOG() << "miss " << _key << "\n";
|
LOG() << "miss\n";
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -12,16 +12,22 @@ namespace jit
|
||||||
{
|
{
|
||||||
|
|
||||||
/// A bundle of objects and information needed for a contract execution
|
/// A bundle of objects and information needed for a contract execution
|
||||||
struct ExecBundle
|
class ExecBundle
|
||||||
{
|
{
|
||||||
|
public:
|
||||||
std::unique_ptr<llvm::ExecutionEngine> engine;
|
std::unique_ptr<llvm::ExecutionEngine> engine;
|
||||||
llvm::Function* entryFunc = nullptr;
|
llvm::Function* entryFunc = nullptr;
|
||||||
|
|
||||||
|
ExecBundle() = default;
|
||||||
|
ExecBundle(ExecBundle&&) = default;
|
||||||
|
ExecBundle(ExecBundle const&) = delete;
|
||||||
|
void operator=(ExecBundle) = delete;
|
||||||
};
|
};
|
||||||
|
|
||||||
class Cache
|
class Cache
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
using Key = void const*;
|
using Key = std::string;
|
||||||
|
|
||||||
static ExecBundle& registerExec(Key _key, ExecBundle&& _exec);
|
static ExecBundle& registerExec(Key _key, ExecBundle&& _exec);
|
||||||
static ExecBundle* findExec(Key _key);
|
static ExecBundle* findExec(Key _key);
|
||||||
|
|
|
||||||
|
|
@ -36,13 +36,13 @@ namespace jit
|
||||||
ReturnCode ExecutionEngine::run(bytes const& _code, RuntimeData* _data, Env* _env)
|
ReturnCode ExecutionEngine::run(bytes const& _code, RuntimeData* _data, Env* _env)
|
||||||
{
|
{
|
||||||
auto module = Compiler({}).compile(_code);
|
auto module = Compiler({}).compile(_code);
|
||||||
return run(std::move(module), _data, _env);
|
return run(std::move(module), _data, _env, _code);
|
||||||
}
|
}
|
||||||
|
|
||||||
ReturnCode ExecutionEngine::run(std::unique_ptr<llvm::Module> _module, RuntimeData* _data, Env* _env)
|
ReturnCode ExecutionEngine::run(std::unique_ptr<llvm::Module> _module, RuntimeData* _data, Env* _env, bytes const& _code)
|
||||||
{
|
{
|
||||||
auto key = _data->code; // TODO: Change cache key
|
std::string key{reinterpret_cast<char const*>(_code.data()), _code.size()};
|
||||||
if (auto cachedExec = Cache::findExec(key))
|
if (auto cachedExec = Cache::findExec(std::move(key)))
|
||||||
{
|
{
|
||||||
return run(*cachedExec, _data, _env);
|
return run(*cachedExec, _data, _env);
|
||||||
}
|
}
|
||||||
|
|
@ -94,7 +94,7 @@ ReturnCode ExecutionEngine::run(std::unique_ptr<llvm::Module> _module, RuntimeDa
|
||||||
if (!exec.entryFunc)
|
if (!exec.entryFunc)
|
||||||
return ReturnCode::LLVMLinkError;
|
return ReturnCode::LLVMLinkError;
|
||||||
|
|
||||||
auto& cachedExec = Cache::registerExec(_data->code, std::move(exec));
|
auto& cachedExec = Cache::registerExec(key, std::move(exec));
|
||||||
auto returnCode = run(cachedExec, _data, _env);
|
auto returnCode = run(cachedExec, _data, _env);
|
||||||
|
|
||||||
auto executionEndTime = std::chrono::high_resolution_clock::now();
|
auto executionEndTime = std::chrono::high_resolution_clock::now();
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,7 @@ namespace eth
|
||||||
{
|
{
|
||||||
namespace jit
|
namespace jit
|
||||||
{
|
{
|
||||||
struct ExecBundle;
|
class ExecBundle;
|
||||||
|
|
||||||
class ExecutionEngine
|
class ExecutionEngine
|
||||||
{
|
{
|
||||||
|
|
@ -23,7 +23,7 @@ public:
|
||||||
void operator=(ExecutionEngine) = delete;
|
void operator=(ExecutionEngine) = delete;
|
||||||
|
|
||||||
ReturnCode run(bytes const& _code, RuntimeData* _data, Env* _env);
|
ReturnCode run(bytes const& _code, RuntimeData* _data, Env* _env);
|
||||||
ReturnCode run(std::unique_ptr<llvm::Module> module, RuntimeData* _data, Env* _env);
|
ReturnCode run(std::unique_ptr<llvm::Module> module, RuntimeData* _data, Env* _env, bytes const& _code);
|
||||||
|
|
||||||
bytes returnData;
|
bytes returnData;
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue