MIRA
RemoteOutgoingConnectionBase Member List

This is the complete list of members for RemoteOutgoingConnectionBase, including all inherited members.

addBinaryFormatVersion(Buffer< uint8 > &data)=0RemoteConnectionprotectedpure virtual
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
clockOffsetRemoteConnectionprotected
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
publishAuthorities(const AuthorityDescriptions &authorities)=0RemoteConnectionpure virtual
publishChannels(const ChannelTypeMap &channels)=0RemoteConnectionpure virtual
publishedServicesRemoteConnectionprotected
publishServices(const StringSet &services)=0RemoteConnectionpure virtual
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
receivedPublishServiceMsg()=0RemoteConnectionprotectedpure virtual
receivedRequestMigrationMsg()RemoteConnectionprotected
receivedRPCRequestMsg()=0RemoteConnectionprotectedpure virtual
receivedRPCResponseMsg()=0RemoteConnectionprotectedpure virtual
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
remoteIDRemoteConnectionprotected
RemoteOutgoingConnectionBase(const KnownFramework &address)RemoteOutgoingConnectionBaseprotected
remoteVersionRemoteConnectionprotected
RPCMessage typedefRemoteConnectionprotected
sendChannelUpdatesThread()RemoteConnectionprotected
sendConnectDenied(const std::string &msg)RemoteConnectionprotected
sendData(ChannelRead< void > value, ServiceLevel &serviceLevel)RemoteConnectioninlineprotectedvirtual
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
subscribeChannel(const std::string &channelID, const ServiceLevel &serviceLevel)=0RemoteConnectionpure virtual
subscriptionsRemoteConnectionprotected
synchronizedTimeRemoteConnectionprotected
synchronizeFrameworks()RemoteConnectionprotected
syncTime()RemoteConnectionprotected
unpublishAuthorities(const AuthorityDescriptions &authorities)=0RemoteConnectionpure virtual
unpublishChannel(const std::string &channel)RemoteConnection
unpublishServices(const StringSet &services)=0RemoteConnectionpure virtual
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
~Object()Objectinlinevirtual
~RemoteConnection()RemoteConnectionvirtual