Skip to content

Commit

Permalink
Remember cache input data (#133)
Browse files Browse the repository at this point in the history
Make init_cache and set_cache no-ops if fed the same data as before
  • Loading branch information
hyc authored and tevador committed Oct 4, 2019
1 parent f1199a9 commit 01648b3
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 5 deletions.
1 change: 1 addition & 0 deletions src/dataset.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@ struct randomx_cache {
randomx::DatasetInitFunc* datasetInit;
randomx::SuperscalarProgram programs[RANDOMX_CACHE_ACCESSES];
std::vector<uint64_t> reciprocalCache;
std::string cacheKey;

bool isInitialized() {
return programs[0].getSize() != 0;
Expand Down
16 changes: 13 additions & 3 deletions src/randomx.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,12 @@ extern "C" {
void randomx_init_cache(randomx_cache *cache, const void *key, size_t keySize) {
assert(cache != nullptr);
assert(keySize == 0 || key != nullptr);
cache->initialize(cache, key, keySize);
std::string cacheKey;
cacheKey.assign((const char *)key, keySize);
if (cache->cacheKey != cacheKey || !cache->isInitialized()) {
cache->initialize(cache, key, keySize);
cache->cacheKey = cacheKey;
}
}

void randomx_release_cache(randomx_cache* cache) {
Expand Down Expand Up @@ -274,8 +279,10 @@ extern "C" {
UNREACHABLE;
}

if(cache != nullptr)
if(cache != nullptr) {
vm->setCache(cache);
vm->cacheKey = cache->cacheKey;
}

if(dataset != nullptr)
vm->setDataset(dataset);
Expand All @@ -293,7 +300,10 @@ extern "C" {
void randomx_vm_set_cache(randomx_vm *machine, randomx_cache* cache) {
assert(machine != nullptr);
assert(cache != nullptr && cache->isInitialized());
machine->setCache(cache);
if (machine->cacheKey != cache->cacheKey) {
machine->setCache(cache);
machine->cacheKey = cache->cacheKey;
}
}

void randomx_vm_set_dataset(randomx_vm *machine, randomx_dataset *dataset) {
Expand Down
4 changes: 3 additions & 1 deletion src/randomx.h
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ RANDOMX_EXPORT randomx_cache *randomx_alloc_cache(randomx_flags flags);

/**
* Initializes the cache memory and SuperscalarHash using the provided key value.
* Does nothing if called again with the same key value.
*
* @param cache is a pointer to a previously allocated randomx_cache structure. Must not be NULL.
* @param key is a pointer to memory which contains the key value. Must not be NULL.
Expand Down Expand Up @@ -162,7 +163,8 @@ RANDOMX_EXPORT randomx_vm *randomx_create_vm(randomx_flags flags, randomx_cache

/**
* Reinitializes a virtual machine with a new Cache. This function should be called anytime
* the Cache is reinitialized with a new key.
* the Cache is reinitialized with a new key. Does nothing if called with a Cache containing
* the same key value as already set.
*
* @param machine is a pointer to a randomx_vm structure that was initialized
* without RANDOMX_FLAG_FULL_MEM. Must not be NULL.
Expand Down
4 changes: 3 additions & 1 deletion src/virtual_machine.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,8 @@ class randomx_vm {
randomx_dataset* datasetPtr;
};
uint64_t datasetOffset;
public:
std::string cacheKey;
};

namespace randomx {
Expand All @@ -80,4 +82,4 @@ namespace randomx {
void generateProgram(void* seed);
};

}
}

0 comments on commit 01648b3

Please sign in to comment.