libfaster API Documentation  Development Version
Super fast distributted computing
faster::fastComm Member List

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::fastComminline
decodeCollect(std::pair< T *, size_t > &item) (defined in faster::fastComm)faster::fastComminline
decodeCollect(std::pair< K, T > &item) (defined in faster::fastComm)faster::fastComminline
decodeCollect(std::tuple< K, T *, size_t > &item) (defined in faster::fastComm)faster::fastComminline
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::fastCommfriend
getNumProcs() (defined in faster::fastComm)faster::fastComminline
getProcId() (defined in faster::fastComm)faster::fastComminline
getResultBuffer() (defined in faster::fastComm)faster::fastComminline
getSendBuffers() (defined in faster::fastComm)faster::fastComminline
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