addBinaryFormatVersion(Buffer< uint8 > &data)=0 | RemoteConnection | protectedpure virtual |
address | RemoteConnection | protected |
authority | RemoteConnection | protected |
AuthorityDescriptions typedef | RemoteConnection | |
AuthState enum name | RemoteConnection | protected |
AUTHSTATE_ACCEPTED enum value | RemoteConnection | protected |
AUTHSTATE_AUTHENTICATING enum value | RemoteConnection | protected |
AUTHSTATE_CONNECTING enum value | RemoteConnection | protected |
AUTHSTATE_DENIED enum value | RemoteConnection | protected |
AUTHSTATE_NONE enum value | RemoteConnection | protected |
ChannelSendMap typedef | RemoteConnection | |
ChannelTypeMap typedef | RemoteConnection | |
checkMessageHeader() const | RemoteConnection | protected |
checkPingTimeoutThread() | RemoteConnection | protected |
CLASS() | Object | inlinestatic |
clockOffset | RemoteConnection | protected |
frameworkID | RemoteConnection | protected |
getAddress() const | RemoteConnection | inline |
getClass() const | Object | inline |
getFrameworkID() const | RemoteConnection | inline |
getGlobalID() const | RemoteConnection | inline |
getRemoteID() const | RemoteConnection | inline |
getSocket() | RemoteConnection | inline |
handleConnect(const boost::system::error_code &error, boost::asio::ip::tcp::resolver::iterator iterator) | RemoteOutgoingConnectionBase | protected |
handleReadHeader(const boost::system::error_code &error) | RemoteOutgoingConnectionBase | protected |
handleReadMessage(const boost::system::error_code &error) | RemoteOutgoingConnectionBase | protected |
hasAuthority(const std::string &id) const | RemoteConnection | |
hasPingTimeout() const | RemoteConnection | protected |
internalGetClass() const =0 | Object | protectedpure virtual |
isPingTimeoutEnabled() | RemoteConnection | inline |
isPTPSyncEnabled() | RemoteConnection | inline |
isSynchronized() const | RemoteConnection | inline |
mAuthSignMsg | RemoteConnection | protected |
mAuthState | RemoteConnection | protected |
mChannelUpdatesMutex | RemoteConnection | protected |
mCheckPingTimeoutThread | RemoteConnection | protected |
mEnablePingTimeout | RemoteConnection | protected |
mEnablePTPSync | RemoteConnection | protected |
MetaSet typedef | RemoteConnection | |
mHeader | RemoteConnection | protected |
mHeaderReceived | RemoteConnection | protected |
mHostName | RemoteOutgoingConnectionBase | protected |
migrateUnit(const std::string &id) | RemoteConnection | |
mLastPTP | RemoteConnection | protected |
mMessage | RemoteConnection | protected |
mMigrationID | RemoteConnection | protected |
mMigrationNS | RemoteConnection | protected |
mMigrationUnit | RemoteConnection | protected |
mOutgoingRPCMessages | RemoteConnection | protected |
mPendingChannelUpdates | RemoteConnection | protected |
mPingLastReceived | RemoteConnection | protected |
mPingLastSend | RemoteConnection | protected |
mPort | RemoteOutgoingConnectionBase | protected |
mProcessPingThread | RemoteConnection | protected |
mPTPDelayLocal | RemoteConnection | protected |
mPTPDelayRemote | RemoteConnection | protected |
mPTPOutgoing | RemoteConnection | protected |
mPTPSyncLocal | RemoteConnection | protected |
mPTPSyncRemote | RemoteConnection | protected |
mRemoteAuthorities | RemoteConnection | protected |
mRPCFinishHandler | RemoteConnection | protected |
mRPCMessagesCondition | RemoteConnection | protected |
mRPCMessagesMutex | RemoteConnection | protected |
mRPCRequestHandler | RemoteConnection | protected |
mSendChannelUpdatesThread | RemoteConnection | protected |
mSendRPCMessagesThread | RemoteConnection | protected |
mService | RemoteConnection | protected |
mSocket | RemoteConnection | protected |
mStopMutex | RemoteConnection | protected |
mStopped | RemoteConnection | protected |
mStopScheduled | RemoteOutgoingConnectionBase | protected |
mSyncTimeTimer | RemoteConnection | protected |
mWriteMutex | RemoteConnection | protected |
onConnect(bool enablePTPTimeSync, bool enablePingTimeout) | RemoteConnection | |
onDisconnect() | RemoteOutgoingConnectionBase | protectedvirtual |
onWriteError(boost::system::system_error &e) | RemoteOutgoingConnectionBase | protectedvirtual |
parseMessage() | RemoteConnection | protected |
ping() | RemoteConnection | protected |
processPingThread() | RemoteConnection | protected |
publishAuthorities(const AuthorityDescriptions &authorities)=0 | RemoteConnection | pure virtual |
publishChannels(const ChannelTypeMap &channels)=0 | RemoteConnection | pure virtual |
publishedServices | RemoteConnection | protected |
publishServices(const StringSet &services)=0 | RemoteConnection | pure virtual |
queueRPCMessage(FrameworkMessageType msg, Buffer< uint8 > &&answer) | RemoteConnection | protected |
receivedChannelMetaMsg() | RemoteConnection | protected |
receivedMigrationFinishedMsg() | RemoteConnection | protected |
receivedMigrationMsg() | RemoteConnection | protected |
receivedMigrationSinkFailureMsg() | RemoteConnection | protected |
receivedMigrationSinkSuccessMsg() | RemoteConnection | protected |
receivedPingMsg() | RemoteConnection | protected |
receivedPTPDelayRequest(uint64 timestamp) | RemoteConnection | protected |
receivedPTPDelayResponse(uint64 timestamp) | RemoteConnection | protected |
receivedPTPFinish() | RemoteConnection | protected |
receivedPTPFollowUp(uint64 timestamp) | RemoteConnection | protected |
receivedPublishAuthorityMsg() | RemoteConnection | protected |
receivedPublishChannelMsg() | RemoteConnection | protected |
receivedPublishServiceMsg()=0 | RemoteConnection | protectedpure virtual |
receivedRequestMigrationMsg() | RemoteConnection | protected |
receivedRPCRequestMsg()=0 | RemoteConnection | protectedpure virtual |
receivedRPCResponseMsg()=0 | RemoteConnection | protectedpure virtual |
receivedSubscribeChannelRequest() | RemoteConnection | protected |
receivedTypeMetaMsg() | RemoteConnection | protected |
receivedUnpublishAuthorityMsg() | RemoteConnection | protected |
receivedUnpublishChannelMsg() | RemoteConnection | protected |
receivedUnpublishServiceMsg() | RemoteConnection | protected |
receivedUnsubscribeChannelRequest(const std::string &channelID) | RemoteConnection | protected |
receivedWriteChannelMsg() | RemoteConnection | protected |
reflect(Reflector &r) | RemoteOutgoingConnectionBase | inline |
RemoteConnection() | RemoteConnection | protected |
RemoteConnection(boost::asio::io_service &service) | RemoteConnection | protected |
remoteID | RemoteConnection | protected |
RemoteOutgoingConnectionBase(const KnownFramework &address) | RemoteOutgoingConnectionBase | protected |
remoteVersion | RemoteConnection | protected |
RPCMessage typedef | RemoteConnection | protected |
sendChannelUpdatesThread() | RemoteConnection | protected |
sendConnectDenied(const std::string &msg) | RemoteConnection | protected |
sendData(ChannelRead< void > value, ServiceLevel &serviceLevel) | RemoteConnection | inlineprotectedvirtual |
sendPTP() | RemoteConnection | protected |
sendRPCMessagesThread() | RemoteConnection | protected |
sentMetaInformation | RemoteConnection | protected |
setAddress(const KnownFramework &addr) | RemoteConnection | inline |
setAuthority(std::unique_ptr< Authority > auth) | RemoteConnection | inline |
setAutoReconnect(bool autoReconnect) | RemoteConnection | inline |
start() | RemoteOutgoingConnectionBase | virtual |
startTimeSync() | RemoteConnection | |
stop() | RemoteConnection | |
StringSet typedef | RemoteConnection | |
subscribeChannel(const std::string &channelID, const ServiceLevel &serviceLevel)=0 | RemoteConnection | pure virtual |
subscriptions | RemoteConnection | protected |
synchronizedTime | RemoteConnection | protected |
synchronizeFrameworks() | RemoteConnection | protected |
syncTime() | RemoteConnection | protected |
unpublishAuthorities(const AuthorityDescriptions &authorities)=0 | RemoteConnection | pure virtual |
unpublishChannel(const std::string &channel) | RemoteConnection | |
unpublishServices(const StringSet &services)=0 | RemoteConnection | pure virtual |
updateOutgoingStats(std::size_t size) | RemoteConnection | protected |
valueChanged(ChannelRead< void > value, ServiceLevel &serviceLevel) | RemoteConnection | protected |
write(const BufferSequence &buffers) | RemoteConnection | inline |
writeMessage(FrameworkMessageType msg) | RemoteConnection | inlineprotected |
writeMessage(FrameworkMessageType msg, Arg &&arg, Args &&... args) | RemoteConnection | inlineprotected |
writeMessageFromBuffer(FrameworkMessageType msg, const BufferType &buffer) | RemoteConnection | inlineprotected |
writeMessageFromData(FrameworkMessageType msg, const DataType &data) | RemoteConnection | inlineprotected |
~Object() | Object | inlinevirtual |
~RemoteConnection() | RemoteConnection | virtual |