libfaster API Documentation
Development Version
Super fast distributted computing
|
This is the complete list of members for faster::workerIFddCore< K, T >, including all inherited members.
apply(void *func, fddOpType op, workerFddBase *dest, fastCommBuffer &buffer)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
baseSize() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
collect(fastComm *comm)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
countByKey(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
deleteItem(void *item) override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
distributedMaxKeyCount(fastComm *comm, std::unordered_map< K, std::pair< size_t, std::deque< int >> > &keyPPMaxCount) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
distributeOwnership(fastComm *comm, K *uKeys, size_t cSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKFinishDataInsert(std::vector< bool > &deleted, std::deque< std::pair< K, T > > &recvData, size_t &pos) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKRecvData(fastComm *comm, size_t &pos, size_t &posLimit, std::vector< bool > &deleted, std::deque< std::pair< K, T > > &recvData, int &peersFinised, bool &dirty) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKSendData(fastComm *comm, std::vector< size_t > &dataSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKsendDataAsync(fastComm *comm, int owner, K &key, T &data, std::vector< size_t > &dataSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKSendDataHashed(fastComm *comm, size_t &pos, std::vector< bool > &deleted, std::vector< size_t > &dataSize, std::deque< std::pair< K, T > > &recvData, std::vector< std::deque< std::pair< K, T > > > &pendingSend, bool &dirty) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
EDBKShrinkData(std::vector< bool > &deleted, size_t &pos) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
exchangeDataByKey(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
exchangeDataByKeyHashed(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
exchangeDataByKeyMapped(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
findKeyInterval(K *keys, T *data, size_t fddSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
findMyKeys(int numProcs, int Id) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
findMyKeysByHash(int numProcs) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
flushDataSend(fastComm *comm, std::vector< size_t > &dataSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
getData() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
getItem(size_t address) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
getKeyLocations() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
getKeyMap() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
getKeys() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
getKeyType() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
getLineSizes()=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
getSize() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
getType() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
getUKeys() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
groupByKey(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
groupByKeyHashed(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
groupedByHash (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
groupedByKey (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
id (defined in faster::workerFddBase) | faster::workerFddBase | protected |
insert(void *k, void *v, size_t s)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
insertl(void *v)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
itemSize() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
keyLocations (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
keyMap (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
keyType (defined in faster::workerFddBase) | faster::workerFddBase | protected |
localData (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
onlineFullPartRead(fastComm *comm, void *funcP) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
onlinePartRead(fastComm *comm, void *funcP) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
onlinePartReadStage3(std::unordered_map< K, int > &localKeyMap, fastComm *comm, void *funcP, std::deque< std::vector< std::pair< K, T >>> &q2, omp_lock_t &q2lock) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
onlineRead(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
onlineReadStage3(std::deque< std::vector< std::pair< K, T >>> &q2, omp_lock_t &q2lock) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
operator[](size_t address) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
preapply(unsigned long int id, void *func, fddOpType op, workerFddBase *dest, fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
recvPartKeyCount(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
recvPartKeyMaxCount(fastComm *comm, std::unordered_map< K, std::pair< size_t, std::deque< int >> > &keyPPMaxCount) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
sendPartKeyCount(fastComm *comm) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
sendPending(fastComm *comm, std::vector< std::deque< std::pair< K, T > > > &pendingSend, std::vector< size_t > &dataSize) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
setData(void *data UNUSED, size_t size UNUSED) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inline |
setData(void *data UNUSED, size_t *ls UNUSED, size_t size UNUSED) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inline |
setData(void *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setData(void *, size_t *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setData(void *, void *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setData(void *, void *, size_t *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setDataRaw(void *data UNUSED, size_t size UNUSED) override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inline |
setDataRaw(void *data UNUSED, size_t *lineSizes UNUSED, size_t size UNUSED) override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inline |
setDataRaw(void *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setDataRaw(void *, size_t *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setDataRaw(void *, void *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setDataRaw(void *, void *, size_t *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
setKeyMap(void *km) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
setSize(size_t s) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
setUKeys(void *uk) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | inlinevirtual |
shrink() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
type (defined in faster::workerFddBase) | faster::workerFddBase | protected |
uKeys (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | protected |
workerFddBase() (defined in faster::workerFddBase) | faster::workerFddBase | |
workerFddBase(unsigned int ident, fddType t) (defined in faster::workerFddBase) | faster::workerFddBase | |
workerIFddCore(unsigned int ident, fddType kt, fddType t) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
workerIFddCore(unsigned int ident, fddType kt, fddType t, size_t size) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | |
writeToFile(void *path, size_t procId, void *sufix) (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
~workerFddBase()=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
~workerIFddCore() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |