 |
libfaster API Documentation
Development Version
Super fast distributted computing
|
|
libfaster API Documentation
Development Version
Super fast distributted computing
|
This is the complete list of members for faster::_workerIFdd< K, T >, including all inherited members.
| _workerIFdd(unsigned int ident, fddType kt, fddType t) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inline |
| _workerIFdd(unsigned int ident, fddType kt, fddType t, size_t size) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inline |
| apply(void *func, fddOpType op, workerFddBase *dest, fastCommBuffer &buffer) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | virtual |
| baseSize() override (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
| bulkFlatMap(workerFddBase *dest, IbulkFlatMapIPFunctionP< K, T, L, U > bulkFlatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkFlatMap(workerFddBase *dest, IPbulkFlatMapIPFunctionP< K, T, L, U > bulkFlatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkFlatMap(workerFddBase *dest, bulkFlatMapIPFunctionP< K, T, U > bulkFlatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkFlatMap(workerFddBase *dest, PbulkFlatMapIPFunctionP< K, T, U > bulkFlatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkMap(workerFddBase *dest, IbulkMapIPFunctionP< K, T, L, U > bulkMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkMap(workerFddBase *dest, IPbulkMapIPFunctionP< K, T, L, U > bulkMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkMap(workerFddBase *dest, bulkMapIPFunctionP< K, T, U > bulkMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| bulkMap(workerFddBase *dest, PbulkMapIPFunctionP< K, T, U > bulkMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| collect(fastComm *comm) override (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | 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 |
| flatMap(workerFddBase *dest, IflatMapIPFunctionP< K, T, L, U > flatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| flatMap(workerFddBase *dest, IPflatMapIPFunctionP< K, T, L, U > flatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| flatMap(workerFddBase *dest, flatMapIPFunctionP< K, T, U > flatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| flatMap(workerFddBase *dest, PflatMapIPFunctionP< K, T, U > flatMapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| 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() (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inlinevirtual |
| 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 *in, size_t s) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | virtual |
| insert(K &key, T &in) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| insert(std::deque< std::pair< K, T > > &in) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| insertl(void *in) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | 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 |
| map(workerFddBase *dest, ImapIPFunctionP< K, T, L, U > mapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| map(workerFddBase *dest, IPmapIPFunctionP< K, T, L, U > mapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| map(workerFddBase *dest, mapIPFunctionP< K, T, U > mapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| map(workerFddBase *dest, PmapIPFunctionP< K, T, U > mapFunc) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| 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(K *keys, T *data, size_t size) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | |
| setData(void *keys, void *data, size_t size) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inlinevirtual |
| setData(void *keys, void *data, size_t *lineSizes UNUSED, size_t size) (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inline |
| 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 *, size_t)=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
| setDataRaw(void *keys, void *data, size_t size) override (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | virtual |
| setDataRaw(void *keys UNUSED, void *data UNUSED, size_t *lineSizes UNUSED, size_t size UNUSED) override (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inline |
| 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 *, 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 |
| ~_workerIFdd() (defined in faster::_workerIFdd< K, T >) | faster::_workerIFdd< K, T > | inline |
| ~workerFddBase()=0 (defined in faster::workerFddBase) | faster::workerFddBase | pure virtual |
| ~workerIFddCore() (defined in faster::workerIFddCore< K, T >) | faster::workerIFddCore< K, T > | virtual |
1.8.12