![]() |
libfaster API Documentation
Development Version
Super fast distributted computing
|
This is the complete list of members for faster::fastComm, including all inherited members.
| bcastBuffer(int src, int i) (defined in faster::fastComm) | faster::fastComm | |
| decodeCollect(T &item) (defined in faster::fastComm) | faster::fastComm | inline |
| decodeCollect(std::pair< T *, size_t > &item) (defined in faster::fastComm) | faster::fastComm | inline |
| decodeCollect(std::pair< K, T > &item) (defined in faster::fastComm) | faster::fastComm | inline |
| decodeCollect(std::tuple< K, T *, size_t > &item) (defined in faster::fastComm) | faster::fastComm | inline |
| distributeKeyMap(std::unordered_map< K, int > &localKeyMap, std::unordered_map< K, int > &keyMap) (defined in faster::fastComm) | faster::fastComm | |
| fastComm(int &argc, char **argv) (defined in faster::fastComm) | faster::fastComm | |
| fastContext (defined in faster::fastComm) | faster::fastComm | friend |
| getNumProcs() (defined in faster::fastComm) | faster::fastComm | inline |
| getProcId() (defined in faster::fastComm) | faster::fastComm | inline |
| getResultBuffer() (defined in faster::fastComm) | faster::fastComm | inline |
| getSendBuffers() (defined in faster::fastComm) | faster::fastComm | inline |
| getSize(T *data UNUSED, size_t *ds UNUSED, size_t s) (defined in faster::fastComm) | faster::fastComm | |
| getSize(std::vector< T > *data, size_t *ds UNUSED, size_t s) (defined in faster::fastComm) | faster::fastComm | |
| getSize(T **data UNUSED, size_t *ds, size_t s) (defined in faster::fastComm) | faster::fastComm | |
| getSize(std::string *data, size_t *ds UNUSED, size_t s) (defined in faster::fastComm) | faster::fastComm | |
| isDriver() (defined in faster::fastComm) | faster::fastComm | |
| isSendBufferFree(int i) (defined in faster::fastComm) | faster::fastComm | |
| joinAll() (defined in faster::fastComm) | faster::fastComm | |
| joinSlaves() (defined in faster::fastComm) | faster::fastComm | |
| maxMsgSize (defined in faster::fastComm) | faster::fastComm | |
| probeMsgs(int &tag, int &src) (defined in faster::fastComm) | faster::fastComm | |
| recvCogroupData(unsigned long tid, std::unordered_map< K, int > &keyMap, std::vector< bool > &flags) (defined in faster::fastComm) | faster::fastComm | |
| recvCollect(unsigned long int &id) (defined in faster::fastComm) | faster::fastComm | |
| recvCreateFDD(unsigned long int &id, fddType &type, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvCreateFDDGroup(unsigned long int &id, fddType &keyType, std::vector< unsigned long int > &members) (defined in faster::fastComm) | faster::fastComm | |
| recvCreateIFDD(unsigned long int &id, fddType &kType, fddType &tType, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvDiscardFDD(unsigned long int &id) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDData(unsigned long int &id, void *data, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDDataCollect(std::vector< T > &ret) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDInfo(size_t &size, int &src) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDSetData(unsigned long int &id, void *&data, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDSetData(unsigned long int &id, void *&data, size_t *&lineSizes, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDSetIData(unsigned long int &id, K *&keys, T *&data, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvFDDSetIData(unsigned long int &id, K *&keys, T *&data, size_t *&lineSizes, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvFileName(std::string &filename) (defined in faster::fastComm) | faster::fastComm | |
| recvFinish() (defined in faster::fastComm) | faster::fastComm | |
| recvGroupByKeyData(int &size) (defined in faster::fastComm) | faster::fastComm | |
| recvIFDDData(unsigned long int &id, void *keys, void *data, size_t &size) (defined in faster::fastComm) | faster::fastComm | |
| recvKeyMap(unsigned long tid, std::unordered_map< K, int > &keyMap) (defined in faster::fastComm) | faster::fastComm | |
| recvReadFDDFile(unsigned long int &id, std::string &filename, size_t &size, size_t &offset) (defined in faster::fastComm) | faster::fastComm | |
| recvTask(fastTask &task) (defined in faster::fastComm) | faster::fastComm | |
| recvTaskResult(unsigned long int &tid, unsigned long int &sid, size_t &size, size_t &time, procstat &stat) (defined in faster::fastComm) | faster::fastComm | |
| recvWriteFDDFile(unsigned long int &id, std::string &path, std::string &sufix) (defined in faster::fastComm) | faster::fastComm | |
| sendCogroupData(unsigned long tid, std::unordered_map< K, int > &keyMap, std::vector< bool > &flags) (defined in faster::fastComm) | faster::fastComm | |
| sendCollect(unsigned long int id) (defined in faster::fastComm) | faster::fastComm | |
| sendCreateFDD(unsigned long int id, fddType type, size_t size, int dest) (defined in faster::fastComm) | faster::fastComm | |
| sendCreateFDDGroup(unsigned long int id, fddType keyType, std::vector< unsigned long int > &members) (defined in faster::fastComm) | faster::fastComm | |
| sendCreateIFDD(unsigned long int id, fddType kType, fddType tType, size_t size, int dest) (defined in faster::fastComm) | faster::fastComm | |
| sendDataUltraPlus(int dest, T *data, size_t *lineSizes UNUSED, size_t size, int tag, fastCommBuffer &b UNUSED, MPI_Request *request) (defined in faster::fastComm) | faster::fastComm | |
| sendDataUltraPlus(int dest, std::vector< T > *data, size_t *lineSizes UNUSED, size_t size, int tag, fastCommBuffer &b UNUSED, MPI_Request *request) (defined in faster::fastComm) | faster::fastComm | |
| sendDiscardFDD(unsigned long int id) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDData(unsigned long int id, int dest, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDDataCollect(unsigned long int id, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDDataCollect(unsigned long int id, T **data, size_t *dataSizes, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDDataCollect(unsigned long int id, K *keys, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDDataCollect(unsigned long int id, K *keys, T **data, size_t *dataSizes, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDInfo(size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDSetData(unsigned long int id, int dest, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDSetData(unsigned long int id, int dest, T **data, size_t *lineSizes, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDSetIData(unsigned long int id, int dest, K *keys, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFDDSetIData(unsigned long int id, int dest, K *keys, T **data, size_t *lineSizes, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendFileName(std::string path) (defined in faster::fastComm) | faster::fastComm | |
| sendFinish() (defined in faster::fastComm) | faster::fastComm | |
| sendGroupByKeyData(int i) (defined in faster::fastComm) | faster::fastComm | |
| sendIFDDData(unsigned long int id, int dest, K *keys, T *data, size_t size) (defined in faster::fastComm) | faster::fastComm | |
| sendKeyMap(unsigned long tid, std::unordered_map< K, int > &keyMap) (defined in faster::fastComm) | faster::fastComm | |
| sendReadFDDFile(unsigned long int id, std::string filename, size_t size, size_t offset, int dest) (defined in faster::fastComm) | faster::fastComm | |
| sendTask(fastTask &task) (defined in faster::fastComm) | faster::fastComm | |
| sendTaskResult() (defined in faster::fastComm) | faster::fastComm | |
| sendWriteFDDFile(unsigned long int id, std::string &path, std::string &sufix) (defined in faster::fastComm) | faster::fastComm | |
| waitForReq(int numReqs) (defined in faster::fastComm) | faster::fastComm | |
| ~fastComm() (defined in faster::fastComm) | faster::fastComm |