This is the complete list of members for cargo::ipc::Processor, including all inherited members.
addPeer(const std::shared_ptr< Socket > &socketPtr) | cargo::ipc::Processor | |
callAsync(const MethodID methodID, const PeerID &peerID, const std::shared_ptr< SentDataType > &data, const typename ResultHandler< ReceivedDataType >::type &process) | cargo::ipc::Processor | |
callAsyncNonBlock(const MethodID methodID, const PeerID &peerID, const std::shared_ptr< SentDataType > &data, const typename ResultHandler< ReceivedDataType >::type &process) | cargo::ipc::Processor | |
callSync(const MethodID methodID, const PeerID &peerID, const std::shared_ptr< SentDataType > &data, unsigned int timeoutMS=5000) | cargo::ipc::Processor | |
ERROR_METHOD_ID | cargo::ipc::Processor | static |
Event enum name | cargo::ipc::Processor | private |
getEventFD() | cargo::ipc::Processor | |
getPeerInfoIterator(const FileDescriptor fd) | cargo::ipc::Processor | private |
getPeerInfoIterator(const PeerID &peerID) | cargo::ipc::Processor | private |
handleEvent() | cargo::ipc::Processor | |
handleInput(const FileDescriptor fd) | cargo::ipc::Processor | |
handleLostConnection(const FileDescriptor fd) | cargo::ipc::Processor | |
isHandled(const MethodID methodID) | cargo::ipc::Processor | |
isStarted() | cargo::ipc::Processor | |
Lock typedef | cargo::ipc::Processor | private |
mEventPoll | cargo::ipc::Processor | private |
mIsRunning | cargo::ipc::Processor | private |
mLogPrefix | cargo::ipc::Processor | private |
mMaxNumberOfPeers | cargo::ipc::Processor | private |
mMethodsCallbacks | cargo::ipc::Processor | private |
mNewPeerCallback | cargo::ipc::Processor | private |
mPeerInfo | cargo::ipc::Processor | private |
mRemovedPeerCallback | cargo::ipc::Processor | private |
mRequestQueue | cargo::ipc::Processor | private |
mReturnCallbacks | cargo::ipc::Processor | private |
mSignalsCallbacks | cargo::ipc::Processor | private |
mSignalsPeers | cargo::ipc::Processor | private |
mStateMutex | cargo::ipc::Processor | private |
onAddPeerRequest(AddPeerRequest &request) | cargo::ipc::Processor | private |
onErrorSignal(const PeerID &peerID, std::shared_ptr< ErrorProtocolMessage > &data) | cargo::ipc::Processor | private |
onFinishRequest(FinishRequest &request) | cargo::ipc::Processor | private |
onMethodRequest(MethodRequest &request) | cargo::ipc::Processor | private |
onNewSignals(const PeerID &peerID, std::shared_ptr< RegisterSignalsProtocolMessage > &data) | cargo::ipc::Processor | private |
onRemoteMethod(Peers::iterator &peerIt, const MethodID methodID, const MessageID &messageID, std::shared_ptr< MethodHandlers > methodCallbacks) | cargo::ipc::Processor | private |
onRemoteSignal(Peers::iterator &peerIt, const MethodID methodID, const MessageID &messageID, std::shared_ptr< SignalHandlers > signalCallbacks) | cargo::ipc::Processor | private |
onRemoveMethodRequest(RemoveMethodRequest &request) | cargo::ipc::Processor | private |
onRemovePeerRequest(RemovePeerRequest &request) | cargo::ipc::Processor | private |
onReturnValue(Peers::iterator &peerIt, const MessageID &messageID) | cargo::ipc::Processor | private |
onSendResultRequest(SendResultRequest &request) | cargo::ipc::Processor | private |
onSignalRequest(SignalRequest &request) | cargo::ipc::Processor | private |
operator<<(std::ostream &os, const Processor::Event &event) | cargo::ipc::Processor | friend |
operator=(const Processor &)=delete | cargo::ipc::Processor | |
Peers typedef | cargo::ipc::Processor | private |
Processor(epoll::EventPoll &eventPoll, const std::string &logName="", const PeerCallback &newPeerCallback=nullptr, const PeerCallback &removedPeerCallback=nullptr, const unsigned int maxNumberOfPeers=DEFAULT_MAX_NUMBER_OF_PEERS) | cargo::ipc::Processor | |
Processor(const Processor &)=delete | cargo::ipc::Processor | |
Processor(Processor &&)=delete | cargo::ipc::Processor | |
REGISTER_SIGNAL_METHOD_ID | cargo::ipc::Processor | static |
removeMethod(const MethodID methodID) | cargo::ipc::Processor | |
removePeerInternal(Peers::iterator peerIt, const std::exception_ptr &exceptionPtr) | cargo::ipc::Processor | private |
removePeerSyncInternal(const PeerID &peerID, Lock &lock) | cargo::ipc::Processor | private |
Request typedef | cargo::ipc::Processor | private |
RETURN_METHOD_ID | cargo::ipc::Processor | static |
sendError(const PeerID &peerID, const MessageID &messageID, const int errorCode, const std::string &message) | cargo::ipc::Processor | |
sendResult(const MethodID methodID, const PeerID &peerID, const MessageID &messageID, const std::shared_ptr< void > &data) | cargo::ipc::Processor | |
sendVoid(const MethodID methodID, const PeerID &peerID, const MessageID &messageID) | cargo::ipc::Processor | |
setMethodHandler(const MethodID methodID, const typename MethodHandler< SentDataType, ReceivedDataType >::type &process) | cargo::ipc::Processor | |
setMethodHandlerInternal(const MethodID methodID, const typename MethodHandler< SentDataType, ReceivedDataType >::type &process) | cargo::ipc::Processor | private |
setNewPeerCallback(const PeerCallback &newPeerCallback) | cargo::ipc::Processor | |
setRemovedPeerCallback(const PeerCallback &removedPeerCallback) | cargo::ipc::Processor | |
setSignalHandler(const MethodID methodID, const typename SignalHandler< ReceivedDataType >::type &process) | cargo::ipc::Processor | |
setSignalHandlerInternal(const MethodID methodID, const typename SignalHandler< ReceivedDataType >::type &handler) | cargo::ipc::Processor | private |
signal(const MethodID methodID, const std::shared_ptr< SentDataType > &data) | cargo::ipc::Processor | |
signalInternal(const MethodID methodID, const PeerID &peerID, const std::shared_ptr< SentDataType > &data) | cargo::ipc::Processor | private |
start() | cargo::ipc::Processor | |
stop(bool wait) | cargo::ipc::Processor | |
~Processor() | cargo::ipc::Processor |