MIRA
ConcreteRemoteOutgoingConnection< BinaryFormatVersion > Member List

This is the complete list of members for ConcreteRemoteOutgoingConnection< BinaryFormatVersion >, including all inherited members.

mira::addBinaryFormatVersion(Buffer< uint8 > &data)=0RemoteConnectionprotectedpure virtual
mira::ConcreteRemoteConnection::addBinaryFormatVersion(Buffer< uint8 > &data)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
addressRemoteConnectionprotected
authorityRemoteConnectionprotected
AuthorityDescriptions typedefRemoteConnection
AuthState enum nameRemoteConnectionprotected
AUTHSTATE_ACCEPTED enum valueRemoteConnectionprotected
AUTHSTATE_AUTHENTICATING enum valueRemoteConnectionprotected
AUTHSTATE_CONNECTING enum valueRemoteConnectionprotected
AUTHSTATE_DENIED enum valueRemoteConnectionprotected
AUTHSTATE_NONE enum valueRemoteConnectionprotected
ChannelSendMap typedefRemoteConnection
ChannelTypeMap typedefRemoteConnection
checkMessageHeader() constRemoteConnectionprotected
checkPingTimeoutThread()RemoteConnectionprotected
CLASS()Objectinlinestatic
ClassFactoryDefaultConstClassBuilder classConcreteRemoteOutgoingConnection< BinaryFormatVersion >friend
clockOffsetRemoteConnectionprotected
ConcreteRemoteConnection()ConcreteRemoteConnection< BinaryFormatVersion >inlineprotected
ConcreteRemoteConnection(boost::asio::io_service &service)ConcreteRemoteConnection< BinaryFormatVersion >inlineprotected
ConcreteRemoteOutgoingConnection(const KnownFramework &address)ConcreteRemoteOutgoingConnection< BinaryFormatVersion >inlineprotected
frameworkIDRemoteConnectionprotected
getAddress() constRemoteConnectioninline
getClass() constObjectinline
getFrameworkID() constRemoteConnectioninline
getGlobalID() constRemoteConnectioninline
getRemoteID() constRemoteConnectioninline
getSocket()RemoteConnectioninline
handleConnect(const boost::system::error_code &error, boost::asio::ip::tcp::resolver::iterator iterator)RemoteOutgoingConnectionBaseprotected
handleReadHeader(const boost::system::error_code &error)RemoteOutgoingConnectionBaseprotected
handleReadMessage(const boost::system::error_code &error)RemoteOutgoingConnectionBaseprotected
hasAuthority(const std::string &id) constRemoteConnection
hasPingTimeout() constRemoteConnectionprotected
internalGetClass() const =0Objectprotectedpure virtual
isPingTimeoutEnabled()RemoteConnectioninline
isPTPSyncEnabled()RemoteConnectioninline
isSynchronized() constRemoteConnectioninline
mAuthSignMsgRemoteConnectionprotected
mAuthStateRemoteConnectionprotected
mChannelUpdatesMutexRemoteConnectionprotected
mCheckPingTimeoutThreadRemoteConnectionprotected
mEnablePingTimeoutRemoteConnectionprotected
mEnablePTPSyncRemoteConnectionprotected
MetaSet typedefRemoteConnection
mHeaderRemoteConnectionprotected
mHeaderReceivedRemoteConnectionprotected
mHostNameRemoteOutgoingConnectionBaseprotected
migrateUnit(const std::string &id)RemoteConnection
mLastPTPRemoteConnectionprotected
mMessageRemoteConnectionprotected
mMigrationIDRemoteConnectionprotected
mMigrationNSRemoteConnectionprotected
mMigrationUnitRemoteConnectionprotected
mOutgoingRPCMessagesRemoteConnectionprotected
mPendingChannelUpdatesRemoteConnectionprotected
mPingLastReceivedRemoteConnectionprotected
mPingLastSendRemoteConnectionprotected
mPortRemoteOutgoingConnectionBaseprotected
mProcessPingThreadRemoteConnectionprotected
mPTPDelayLocalRemoteConnectionprotected
mPTPDelayRemoteRemoteConnectionprotected
mPTPOutgoingRemoteConnectionprotected
mPTPSyncLocalRemoteConnectionprotected
mPTPSyncRemoteRemoteConnectionprotected
mRemoteAuthoritiesRemoteConnectionprotected
mRPCFinishHandlerRemoteConnectionprotected
mRPCMessagesConditionRemoteConnectionprotected
mRPCMessagesMutexRemoteConnectionprotected
mRPCRequestHandlerRemoteConnectionprotected
mSendChannelUpdatesThreadRemoteConnectionprotected
mSendRPCMessagesThreadRemoteConnectionprotected
mServiceRemoteConnectionprotected
mSocketRemoteConnectionprotected
mStopMutexRemoteConnectionprotected
mStoppedRemoteConnectionprotected
mStopScheduledRemoteOutgoingConnectionBaseprotected
mSyncTimeTimerRemoteConnectionprotected
mWriteMutexRemoteConnectionprotected
onConnect(bool enablePTPTimeSync, bool enablePingTimeout)RemoteConnection
onDisconnect()RemoteOutgoingConnectionBaseprotectedvirtual
onWriteError(boost::system::system_error &e)RemoteOutgoingConnectionBaseprotectedvirtual
parseMessage()RemoteConnectionprotected
ping()RemoteConnectionprotected
processPingThread()RemoteConnectionprotected
mira::publishAuthorities(const AuthorityDescriptions &authorities)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::publishAuthorities(const AuthorityDescriptions &authorities)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
mira::publishChannels(const ChannelTypeMap &channels)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::publishChannels(const ChannelTypeMap &channels)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
publishedServicesRemoteConnectionprotected
mira::publishServices(const StringSet &services)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::publishServices(const StringSet &services)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
publishServicesFiltered(const StringSet &services)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
queueRPCMessage(FrameworkMessageType msg, Buffer< uint8 > &&answer)RemoteConnectionprotected
receivedChannelMetaMsg()RemoteConnectionprotected
receivedMigrationFinishedMsg()RemoteConnectionprotected
receivedMigrationMsg()RemoteConnectionprotected
receivedMigrationSinkFailureMsg()RemoteConnectionprotected
receivedMigrationSinkSuccessMsg()RemoteConnectionprotected
receivedPingMsg()RemoteConnectionprotected
receivedPTPDelayRequest(uint64 timestamp)RemoteConnectionprotected
receivedPTPDelayResponse(uint64 timestamp)RemoteConnectionprotected
receivedPTPFinish()RemoteConnectionprotected
receivedPTPFollowUp(uint64 timestamp)RemoteConnectionprotected
receivedPublishAuthorityMsg()RemoteConnectionprotected
receivedPublishChannelMsg()RemoteConnectionprotected
mira::receivedPublishServiceMsg()=0RemoteConnectionprotectedpure virtual
mira::ConcreteRemoteConnection::receivedPublishServiceMsg()ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
receivedRequestMigrationMsg()RemoteConnectionprotected
mira::receivedRPCRequestMsg()=0RemoteConnectionprotectedpure virtual
mira::ConcreteRemoteConnection::receivedRPCRequestMsg()ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
mira::receivedRPCResponseMsg()=0RemoteConnectionprotectedpure virtual
mira::ConcreteRemoteConnection::receivedRPCResponseMsg()ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
receivedSubscribeChannelRequest()RemoteConnectionprotected
receivedTypeMetaMsg()RemoteConnectionprotected
receivedUnpublishAuthorityMsg()RemoteConnectionprotected
receivedUnpublishChannelMsg()RemoteConnectionprotected
receivedUnpublishServiceMsg()RemoteConnectionprotected
receivedUnsubscribeChannelRequest(const std::string &channelID)RemoteConnectionprotected
receivedWriteChannelMsg()RemoteConnectionprotected
reflect(Reflector &r)RemoteOutgoingConnectionBaseinline
RemoteConnection()RemoteConnectionprotected
RemoteConnection(boost::asio::io_service &service)RemoteConnectionprotected
RemoteConnectionPool classConcreteRemoteOutgoingConnection< BinaryFormatVersion >friend
remoteIDRemoteConnectionprotected
RemoteOutgoingConnectionBase(const KnownFramework &address)RemoteOutgoingConnectionBaseprotected
remoteVersionRemoteConnectionprotected
RPCMessage typedefRemoteConnectionprotected
sendChannelUpdatesThread()RemoteConnectionprotected
sendConnectDenied(const std::string &msg)RemoteConnectionprotected
mira::sendData(ChannelRead< void > value, ServiceLevel &serviceLevel)RemoteConnectioninlineprotectedvirtual
mira::ConcreteRemoteConnection::sendData(ChannelRead< void > value, ServiceLevel &serviceLevel)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
sendPTP()RemoteConnectionprotected
sendRPCMessagesThread()RemoteConnectionprotected
sentMetaInformationRemoteConnectionprotected
setAddress(const KnownFramework &addr)RemoteConnectioninline
setAuthority(std::unique_ptr< Authority > auth)RemoteConnectioninline
setAutoReconnect(bool autoReconnect)RemoteConnectioninline
start()RemoteOutgoingConnectionBasevirtual
startTimeSync()RemoteConnection
stop()RemoteConnection
StringSet typedefRemoteConnection
mira::subscribeChannel(const std::string &channelID, const ServiceLevel &serviceLevel)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::subscribeChannel(const std::string &channelID, const ServiceLevel &serviceLevel)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
subscriptionsRemoteConnectionprotected
synchronizedTimeRemoteConnectionprotected
synchronizeFrameworks()RemoteConnectionprotected
syncTime()RemoteConnectionprotected
mira::unpublishAuthorities(const AuthorityDescriptions &authorities)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::unpublishAuthorities(const AuthorityDescriptions &authorities)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
unpublishChannel(const std::string &channel)RemoteConnection
mira::unpublishServices(const StringSet &services)=0RemoteConnectionpure virtual
mira::ConcreteRemoteConnection::unpublishServices(const StringSet &services)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
unpublishServicesFiltered(const StringSet &services)ConcreteRemoteConnection< BinaryFormatVersion >protectedvirtual
updateOutgoingStats(std::size_t size)RemoteConnectionprotected
valueChanged(ChannelRead< void > value, ServiceLevel &serviceLevel)RemoteConnectionprotected
write(const BufferSequence &buffers)RemoteConnectioninline
writeMessage(FrameworkMessageType msg)RemoteConnectioninlineprotected
writeMessage(FrameworkMessageType msg, Arg &&arg, Args &&... args)RemoteConnectioninlineprotected
writeMessageFromBuffer(FrameworkMessageType msg, const BufferType &buffer)RemoteConnectioninlineprotected
writeMessageFromData(FrameworkMessageType msg, const DataType &data)RemoteConnectioninlineprotected
~ConcreteRemoteConnection()ConcreteRemoteConnection< BinaryFormatVersion >inlinevirtual
~Object()Objectinlinevirtual
~RemoteConnection()RemoteConnectionvirtual