libfaster API Documentation  Development Version
Super fast distributted computing
faster::workerIFddCore< K, T > Member List

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::workerFddBasepure virtual
baseSize() override (defined in faster::workerIFddCore< K, T >)faster::workerIFddCore< K, T >virtual
collect(fastComm *comm)=0 (defined in faster::workerFddBase)faster::workerFddBasepure 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::workerFddBasepure 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::workerFddBaseprotected
insert(void *k, void *v, size_t s)=0 (defined in faster::workerFddBase)faster::workerFddBasepure virtual
insertl(void *v)=0 (defined in faster::workerFddBase)faster::workerFddBasepure 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::workerFddBaseprotected
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::workerFddBasepure virtual
setData(void *, size_t *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure virtual
setData(void *, void *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure virtual
setData(void *, void *, size_t *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure 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::workerFddBasepure virtual
setDataRaw(void *, size_t *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure virtual
setDataRaw(void *, void *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure virtual
setDataRaw(void *, void *, size_t *, size_t)=0 (defined in faster::workerFddBase)faster::workerFddBasepure 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::workerFddBaseprotected
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::workerFddBasepure virtual
~workerIFddCore() (defined in faster::workerIFddCore< K, T >)faster::workerIFddCore< K, T >virtual