diff --git a/.github/PULL_REQUEST_TEMPLATE/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md similarity index 100% rename from .github/PULL_REQUEST_TEMPLATE/PULL_REQUEST_TEMPLATE.md rename to .github/PULL_REQUEST_TEMPLATE.md diff --git a/docs/api/MASES.DataDistributionManager.Bindings.CommonConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.CommonConfiguration.html index ce6a7c3a..0baa2753 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.CommonConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.CommonConfiguration.html @@ -83,6 +83,7 @@
Inheritance
GlobalConfiguration
CommonConfiguration
KafkaConfiguration
+
MastershipConfiguration
OpenDDSConfiguration
@@ -98,6 +99,9 @@
Inherited Members
GlobalConfiguration.ProtocolLibraryKey
+
+ GlobalConfiguration.MastershipLibraryKey +
GlobalConfiguration.MaxMessageSizeKey
@@ -113,6 +117,9 @@
Inherited Members
GlobalConfiguration.ProtocolLibrary
+
+ GlobalConfiguration.MastershipLibrary +
GlobalConfiguration.MaxMessageSize
@@ -521,7 +528,7 @@

Properties

ChannelSeekTimeout

-

The timeout on seek channel

+

The timeout on seek channel in ms

Declaration
@@ -583,7 +590,7 @@
Property Value

CommitTimeout

-

The timeout on channel message commit

+

The timeout on channel message commit in ms

Declaration
@@ -614,7 +621,7 @@
Property Value

ConsumerTimeout

-

The timeout on channel message consume

+

The timeout on channel message consume in ms

Declaration
@@ -645,7 +652,7 @@
Property Value

CreateChannelTimeout

-

The timeout on create channel

+

The timeout on create channel in ms

Declaration
@@ -707,7 +714,7 @@
Property Value

KeepAliveTimeout

-

The timeout on channel keep alive

+

The timeout on channel keep alive in ms

Declaration
@@ -738,7 +745,7 @@
Property Value

ProducerTimeout

-

The timeout on channel message produce

+

The timeout on channel message produce in ms

Declaration
@@ -769,7 +776,7 @@
Property Value

ReceiveTimeout

-

The timeout on channel receive

+

The timeout on channel receive in ms

Declaration
diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaChannelConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaChannelConfiguration.html index 18ade89e..f3166ca1 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaChannelConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaChannelConfiguration.html @@ -152,6 +152,9 @@
Inherited Members
+ @@ -167,6 +170,9 @@
Inherited Members
+ diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaConfiguration.html index a45f8ad3..dad20e74 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.KafkaConfiguration.html @@ -152,6 +152,9 @@
Inherited Members
+ @@ -167,6 +170,9 @@
Inherited Members
+ diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.MastershipConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.MastershipConfiguration.html new file mode 100644 index 00000000..3be5e966 --- /dev/null +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.MastershipConfiguration.html @@ -0,0 +1,433 @@ + + + + + + + + Class MastershipConfiguration + | Data Distribution Manager website + + + + + + + + + + + + + + + +
+
+ + + +
+ +
+
+
+ +
+ +
+
+
+
+
+
+
+ + +

Class MastershipConfiguration +

+

The configuration class for mastership based on DataDistributionMastershipManager

+
+
+
+
Inheritance
+
Object
+
BaseConfiguration
+
GlobalConfiguration
+
CommonConfiguration
+
MastershipConfiguration
+
+ +
+
Inherited Members
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
+
Namespace: MASES.DataDistributionManager.Bindings.Configuration
+
Assembly: DataDistributionManagerNet.dll
+
Syntax
+
+ 
public class MastershipConfiguration : CommonConfiguration, IConfiguration, INotifyPropertyChanged
+
+

Constructors +

+ + | + Improve this Doc + + + View Source + + +

MastershipConfiguration(IConfiguration)

+

Duplicates a configuration

+
+
+
Declaration
+
+ 
public MastershipConfiguration(IConfiguration originalConf)
+
+
Parameters
+ + + + + + + + + + + + + + + +
TypeNameDescription
IConfigurationoriginalConf

IConfiguration to duplicate

+
+ + | + Improve this Doc + + + View Source + + +

MastershipConfiguration(String, IConfiguration)

+

Duplicates a configuration

+
+
+
Declaration
+
+ 
public MastershipConfiguration(string libraryName, IConfiguration originalConf)
+
+
Parameters
+ + + + + + + + + + + + + + + + + + + + +
TypeNameDescription
StringlibraryName

The mastership library name (or full path) to use

+
IConfigurationoriginalConf

IConfiguration to duplicate

+
+

Fields +

+ + | + Improve this Doc + + + View Source + +

MastershipGlobalConfigurationBasePropertyKey

+

Base property name of all specific configuration key of MastershipConfiguration

+
+
+
Declaration
+
+ 
public const string MastershipGlobalConfigurationBasePropertyKey = "datadistributionmanager.mastership."
+
+
Field Value
+ + + + + + + + + + + + + +
TypeDescription
String
+

Properties +

+ + | + Improve this Doc + + + View Source + + +

Item[String]

+

Generic setter/getter for all configuration properties

+
+
+
Declaration
+
+ 
public string this[string property] { get; set; }
+
+
Parameters
+ + + + + + + + + + + + + + + +
TypeNameDescription
Stringproperty

The property name

+
+
Property Value
+ + + + + + + + + + + + + +
TypeDescription
String

The property value

+
+

Implements

+ + +
+
+ + +
+
+ +
+
+
+
+ + Back to top + + Copyright © 2021 MASES s.r.l..
Generated by DocFX + +
+
+
+
+ + + + + + diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSChannelConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSChannelConfiguration.html index 3279d862..0ad5556c 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSChannelConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSChannelConfiguration.html @@ -179,6 +179,9 @@
Inherited Members
+ @@ -194,6 +197,9 @@
Inherited Members
+ diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSConfiguration.html index d82a4a45..f4e66f2d 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.OpenDDSConfiguration.html @@ -152,6 +152,9 @@
Inherited Members
+ @@ -167,6 +170,9 @@
Inherited Members
+ diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.html b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.html index 8b8b477d..b168db08 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Configuration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Configuration.html @@ -121,6 +121,9 @@

LivelinessQosPolicyConfiguration

Class managing LivelinessQosPolicy

+
+

MastershipConfiguration

+

The configuration class for mastership based on DataDistributionMastershipManager

OpenDDSChannelConfiguration

The configuration class for OpenDDS

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.GlobalConfiguration.html b/docs/api/MASES.DataDistributionManager.Bindings.GlobalConfiguration.html index 10240e0b..218d1b70 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.GlobalConfiguration.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.GlobalConfiguration.html @@ -131,10 +131,10 @@

Fields

| - Improve this Doc + Improve this Doc - View Source + View Source

GlobalLogLevelKey

Configuration key of GlobalLogLevel

@@ -161,10 +161,40 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source + +

MastershipLibraryKey

+

Configuration key of MastershipLibrary

+
+
+
Declaration
+
+ 
public const string MastershipLibraryKey = "datadistributionmanager.common.mastershiplib"
+
+
Field Value
+ + + + + + + + + + + + + +
TypeDescription
String
+ + | + Improve this Doc + + + View Source

MaxMessageSizeKey

Configuration key of MaxMessageSize

@@ -191,10 +221,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ProtocolKey

Configuration key of Protocol

@@ -221,10 +251,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ProtocolLibraryKey

Configuration key of ProtocolLibrary

@@ -251,10 +281,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ServerLostTimeoutKey

Configuration key of ServerLostTimeout

@@ -283,10 +313,10 @@

Properties

| - Improve this Doc + Improve this Doc - View Source + View Source

GlobalLogLevel

@@ -314,10 +344,41 @@
Property Value
| - Improve this Doc + Improve this Doc + + + View Source + + +

MastershipLibrary

+

The mastership library to use

+
+
+
Declaration
+
+ 
public string MastershipLibrary { get; set; }
+
+
Property Value
+ + + + + + + + + + + + + +
TypeDescription
String
+ + | + Improve this Doc - View Source + View Source

MaxMessageSize

@@ -345,10 +406,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

Protocol

@@ -376,10 +437,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ProtocolLibrary

@@ -407,14 +468,14 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ServerLostTimeout

-

The timeout on server lost

+

The timeout on server lost in ms

Declaration
@@ -440,10 +501,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

CheckConfiguration()

@@ -471,10 +532,10 @@

Implements

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistribution.html b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistribution.html index c3382b68..1ce30f79 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistribution.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistribution.html @@ -86,10 +86,10 @@

Properties

| - Improve this Doc + Improve this Doc - View Source + View Source

MastershipLib

@@ -117,10 +117,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

MastershipManager

@@ -148,10 +148,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

Protocol

@@ -179,10 +179,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ProtocolLib

@@ -212,10 +212,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

CreateSmartChannel<T>(String, IConfiguration, DDM_CHANNEL_DIRECTION)

@@ -291,10 +291,10 @@
Type Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

CreateSmartChannel<T>(String, String[], DDM_CHANNEL_DIRECTION)

@@ -370,10 +370,10 @@
Type Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(DDM_GENERAL_PARAMETER)

@@ -397,7 +397,7 @@
Parameters
DDM_GENERAL_PARAMETER paramId -

DDM_GENERAL_PARAMETER parameter to set

+

DDM_GENERAL_PARAMETER parameter to get

@@ -420,10 +420,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(String)

@@ -447,7 +447,7 @@
Parameters
String paramName -

Parameter to set

+

Parameter to get

@@ -470,10 +470,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(IConfiguration, String, String)

@@ -532,10 +532,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(String, String, String)

@@ -594,10 +594,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(String[], String, String)

@@ -656,10 +656,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnChangedState(DDM_INSTANCE_STATE)

@@ -690,10 +690,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnChangingState(DDM_INSTANCE_STATE, DDM_INSTANCE_STATE)

@@ -730,10 +730,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnClusterStateChange(DDM_CLUSTEREVENT, Int64)

@@ -770,10 +770,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnCompletelyDisconnected(String, String)

@@ -810,10 +810,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnConfiguration(String, String, String)

@@ -872,10 +872,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnFirstStateChange(DDM_INSTANCE_STATE)

@@ -906,10 +906,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnLogging(DDM_LOG_LEVEL, String, String, String)

@@ -958,10 +958,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnMultiplePrimary(Int64, Int64)

@@ -998,10 +998,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnRequestedState(IntPtr, IntPtr)

@@ -1038,10 +1038,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnStateChange(DDM_INSTANCE_STATE, DDM_INSTANCE_STATE)

@@ -1078,10 +1078,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnStateReady(IntPtr, Int64)

@@ -1118,19 +1118,19 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source -

RequestMastershipManager(String, String[])

+

RequestMastershipManager(IConfiguration, String)

Request to allocate mastership manager

Declaration
- 
OPERATION_RESULT RequestMastershipManager(string serverName, string[] parameters)
+ 
OPERATION_RESULT RequestMastershipManager(IConfiguration parameters = null, string serverName = null)
Parameters
@@ -1142,16 +1142,72 @@
Parameters
+ + + + + + +
IConfigurationparameters

The configuration coming from an instance of IConfiguration

+
String serverName

The server name
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
OPERATION_RESULT

OPERATION_RESULT

+
+ + | + Improve this Doc + + + View Source + + +

RequestMastershipManager(String[], String)

+

Request to allocate mastership manager

+
+
+
Declaration
+
+ 
OPERATION_RESULT RequestMastershipManager(string[] parameters, string serverName = null)
+
+
Parameters
+ + + + + + + + + + + + + + @@ -1174,10 +1230,10 @@
Returns
TypeNameDescription
String[] parameters

Paramaters to send to underlying layer

+
StringserverName

The server name
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(DDM_GENERAL_PARAMETER, String)

@@ -1214,10 +1270,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(String, String)

@@ -1254,10 +1310,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

Start(UInt32)

@@ -1304,10 +1360,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Stop(UInt32)

@@ -1356,10 +1412,10 @@

Events

| - Improve this Doc + Improve this Doc - View Source + View Source

ChangedStateEvent

The state has changed

@@ -1386,10 +1442,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ChangingStateEvent

The state is starting to change

@@ -1416,10 +1472,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ClusterStateChangeEvent

The cluster has changed its state

@@ -1446,10 +1502,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

CompletelyDisconnectedEvent

Event received when subsystem detects a complete disconnection from central server or other peers

@@ -1476,10 +1532,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ConfigurationEvent

Event received during configuration parameter load on subsystem

@@ -1506,10 +1562,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

FirstStateChangeEvent

Called the first time there is state change

@@ -1536,10 +1592,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

LoggingEvent

Event received when a log is received from subsystem

@@ -1566,10 +1622,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

MultiplePrimaryEvent

There are multiple primary server in the cluster

@@ -1596,10 +1652,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

RequestedStateEvent

Called when a state transfer was requested

@@ -1626,10 +1682,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

StateChangeEvent

My state has changed

@@ -1656,10 +1712,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

StateReadyEvent

The state is ready to be used

@@ -1692,10 +1748,10 @@
Event Type
diff --git a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionChannel.html b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionChannel.html index 704c488a..4f9b2b92 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionChannel.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionChannel.html @@ -86,10 +86,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

ChangeChannelDirection(DDM_CHANNEL_DIRECTION)

@@ -136,10 +136,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(DDM_GENERAL_PARAMETER)

@@ -186,10 +186,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(String)

@@ -236,10 +236,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Lock(UInt32)

@@ -263,7 +263,7 @@
Parameters
UInt32 timeout -

Timeout to acuire lock

+

Timeout to acuire lock in ms

@@ -286,10 +286,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnConditionOrError(String, OPERATION_RESULT, Int32, String)

@@ -338,10 +338,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnDataAvailable(String, String, Byte[])

@@ -384,10 +384,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

ReadFromChannel(Int64, Int64, out Byte[])

@@ -446,10 +446,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

SeekChannel(Int64)

@@ -496,10 +496,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(DDM_GENERAL_PARAMETER, String)

@@ -536,10 +536,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(String, String)

@@ -576,10 +576,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

StartChannel(UInt32)

@@ -626,10 +626,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

StopChannel(UInt32)

@@ -676,10 +676,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Unlock()

@@ -708,10 +708,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(Byte[], Boolean, Int64)

@@ -769,10 +769,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, Boolean, Int64)

@@ -830,10 +830,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, Byte[], Boolean, Int64)

@@ -897,10 +897,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, String, Boolean, Int64)

@@ -966,10 +966,10 @@

Events

| - Improve this Doc + Improve this Doc - View Source + View Source

ConditionOrError

Event to receive condition or errors

@@ -996,10 +996,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

DataAvailable

Event to receive messages when data are available

@@ -1032,10 +1032,10 @@
Event Type
diff --git a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionMastership.html b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionMastership.html index d7e7539a..c532a50a 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionMastership.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.ISmartDataDistributionMastership.html @@ -86,10 +86,10 @@

Properties

| - Improve this Doc + Improve this Doc - View Source + View Source

ClusterHealth

@@ -117,10 +117,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ClusterState

@@ -148,10 +148,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

IamNextPrimary

@@ -180,10 +180,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

LocalServerId

@@ -211,10 +211,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

MessageDelay

@@ -242,10 +242,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

MyState

@@ -273,10 +273,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

PrimaryServerId

@@ -304,10 +304,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

UpTime

@@ -337,10 +337,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

ChangeMyState(DDM_INSTANCE_STATE)

@@ -371,10 +371,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

ChangeState(Int64, DDM_INSTANCE_STATE)

@@ -411,10 +411,60 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source + + +

GetParameter(String)

+

Get mastership parameter

+
+
+
Declaration
+
+ 
string GetParameter(string paramName)
+
+
Parameters
+ + + + + + + + + + + + + + + +
TypeNameDescription
StringparamName

Parameter to get

+
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
String

Parameter value

+
+ + | + Improve this Doc + + + View Source

RequestIAmNextPrimary()

@@ -443,10 +493,50 @@
Returns
| - Improve this Doc + Improve this Doc + + + View Source + + +

SetParameter(String, String)

+

Set mastership parameter

+
+
+
Declaration
+
+ 
void SetParameter(string paramName, string paramValue)
+
+
Parameters
+ + + + + + + + + + + + + + + + + + + + +
TypeNameDescription
StringparamName

Parameter to set

+
StringparamValue

Value to set

+
+ + | + Improve this Doc - View Source + View Source

Start(UInt32)

@@ -493,10 +583,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Stop(UInt32)

@@ -549,10 +639,10 @@
Returns
diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_CLUSTEREVENT.html b/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_CLUSTEREVENT.html index 7faf10a6..1dc2b420 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_CLUSTEREVENT.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_CLUSTEREVENT.html @@ -126,10 +126,10 @@

Extension Methods

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_INSTANCE_STATE.html b/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_INSTANCE_STATE.html index 9666e014..25b20262 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_INSTANCE_STATE.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Interop.DDM_INSTANCE_STATE.html @@ -146,10 +146,10 @@

Extension Methods

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Interop.OPERATION_RESULT.html b/docs/api/MASES.DataDistributionManager.Bindings.Interop.OPERATION_RESULT.html index f3aef8bb..fa3888ac 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Interop.OPERATION_RESULT.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Interop.OPERATION_RESULT.html @@ -101,10 +101,10 @@

Constructors

| - Improve this Doc + Improve this Doc - View Source + View Source

OPERATION_RESULT(Int32)

@@ -135,10 +135,10 @@

Fields

| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_COMMIT_FAILED

Commit failed

@@ -165,10 +165,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_DATA_AVAILABLE

Data are available

@@ -195,10 +195,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_ELAPSED_MESSAGE_ACKNOWLEDGMENT_TIMEOUT

Timeout on acknowledgment

@@ -225,10 +225,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_ELAPSED_MESSAGE_RECEIVE_TIMEOUT_BEGIN

Timeout elapsed waiting for messages from the channel

@@ -255,10 +255,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_ELAPSED_MESSAGE_RECEIVE_TIMEOUT_END

End timeout condition waiting for messages from the channel

@@ -285,10 +285,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_END_OF_STREAM

Reached end of stream

@@ -315,10 +315,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_FATAL_ERROR

Fatal

@@ -345,10 +345,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_INVALID_DATA

Invalid data

@@ -375,10 +375,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_NO_DATA_RETURNED

No data returned

@@ -405,10 +405,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_NO_ERROR_CONDITION

Success code

@@ -435,10 +435,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_NOT_IMPLEMENTED

Function not implemented

@@ -465,10 +465,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_PARAMETER_ERROR

Errors in parameters

@@ -495,10 +495,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_POINTER_NOT_SET

Pointer not set within subsystem

@@ -525,10 +525,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_SUBSYSTEM_NOT_STARTED

Subsystem not started

@@ -555,10 +555,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_TIMEOUT

Timeout occurred

@@ -585,10 +585,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_UNMAPPED_ERROR_CONDITION

Unmapped error

@@ -615,10 +615,10 @@
Field Value
| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_WRITE_FAILED

Failed on write

@@ -647,10 +647,10 @@

Properties

| - Improve this Doc + Improve this Doc - View Source + View Source

Failed

@@ -677,10 +677,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

Succeeded

@@ -709,10 +709,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

CompareTo(OPERATION_RESULT)

@@ -756,10 +756,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

CompareTo(Int32)

@@ -803,10 +803,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

CompareTo(Object)

@@ -850,10 +850,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Equals(OPERATION_RESULT)

@@ -897,10 +897,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Equals(Int32)

@@ -944,10 +944,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Equals(Object)

@@ -993,10 +993,10 @@
Overrides
| - Improve this Doc + Improve this Doc - View Source + View Source

FAILED(Int32)

@@ -1040,10 +1040,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetHashCode()

@@ -1072,10 +1072,10 @@
Overrides
| - Improve this Doc + Improve this Doc - View Source + View Source

SUCCEEDED(Int32)

@@ -1119,10 +1119,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ToString()

@@ -1153,10 +1153,10 @@

Operators

| - Improve this Doc + Improve this Doc - View Source + View Source

False(OPERATION_RESULT)

@@ -1200,10 +1200,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Implicit(OPERATION_RESULT to Boolean)

@@ -1247,10 +1247,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Implicit(OPERATION_RESULT to Int32)

@@ -1294,10 +1294,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Implicit(Int32 to OPERATION_RESULT)

@@ -1341,10 +1341,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

True(OPERATION_RESULT)

@@ -1398,10 +1398,10 @@

Implements

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.Interop.OperationResultException.html b/docs/api/MASES.DataDistributionManager.Bindings.Interop.OperationResultException.html index efe09863..04af5d55 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.Interop.OperationResultException.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.Interop.OperationResultException.html @@ -161,10 +161,10 @@

Implements

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistribution.html b/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistribution.html index cf1132ab..bcf76fac 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistribution.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistribution.html @@ -120,10 +120,10 @@

Constructors

| - Improve this Doc + Improve this Doc - View Source + View Source

SmartDataDistribution()

@@ -138,10 +138,10 @@

Properties

| - Improve this Doc + Improve this Doc - View Source + View Source

MastershipLib

@@ -169,10 +169,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

MastershipManager

@@ -200,10 +200,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

Protocol

@@ -231,10 +231,10 @@
Property Value
| - Improve this Doc + Improve this Doc - View Source + View Source

ProtocolLib

@@ -264,10 +264,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

CreateSmartChannel<T>(String, IConfiguration, DDM_CHANNEL_DIRECTION)

@@ -343,10 +343,10 @@
Type Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

CreateSmartChannel<T>(String, String[], DDM_CHANNEL_DIRECTION)

@@ -422,10 +422,10 @@
Type Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

Finalize()

@@ -438,10 +438,10 @@
Declaration
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(DDM_GENERAL_PARAMETER)

@@ -465,7 +465,7 @@
Parameters
DDM_GENERAL_PARAMETER paramId -

DDM_GENERAL_PARAMETER parameter to set

+

DDM_GENERAL_PARAMETER parameter to get

@@ -488,10 +488,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(String)

@@ -515,7 +515,7 @@
Parameters
String paramName -

Parameter to set

+

Parameter to get

@@ -538,10 +538,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(IConfiguration, String, String)

@@ -600,10 +600,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(String, String, String)

@@ -662,10 +662,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Initialize(String[], String, String)

@@ -724,10 +724,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnChangedState(DDM_INSTANCE_STATE)

@@ -758,10 +758,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnChangingState(DDM_INSTANCE_STATE, DDM_INSTANCE_STATE)

@@ -798,10 +798,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnClusterStateChange(DDM_CLUSTEREVENT, Int64)

@@ -838,10 +838,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnCompletelyDisconnected(String, String)

@@ -878,10 +878,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnConfiguration(String, String, String)

@@ -940,10 +940,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnFirstStateChange(DDM_INSTANCE_STATE)

@@ -974,10 +974,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnLogging(DDM_LOG_LEVEL, String, String, String)

@@ -1026,10 +1026,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnMultiplePrimary(Int64, Int64)

@@ -1066,10 +1066,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnRequestedState(IntPtr, IntPtr)

@@ -1106,10 +1106,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnStateChange(DDM_INSTANCE_STATE, DDM_INSTANCE_STATE)

@@ -1146,10 +1146,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnStateReady(IntPtr, Int64)

@@ -1186,19 +1186,19 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source -

RequestMastershipManager(String, String[])

+

RequestMastershipManager(IConfiguration, String)

Request to allocate mastership manager

Declaration
- 
public OPERATION_RESULT RequestMastershipManager(string serverName, string[] parameters)
+ 
public OPERATION_RESULT RequestMastershipManager(IConfiguration parameters = null, string serverName = null)
Parameters
@@ -1210,16 +1210,72 @@
Parameters
+ + + + + + +
IConfigurationparameters

The configuration coming from an instance of IConfiguration

+
String serverName

The server name
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
OPERATION_RESULT

OPERATION_RESULT

+
+ + | + Improve this Doc + + + View Source + + +

RequestMastershipManager(String[], String)

+

Request to allocate mastership manager

+
+
+
Declaration
+
+ 
public OPERATION_RESULT RequestMastershipManager(string[] parameters, string serverName = null)
+
+
Parameters
+ + + + + + + + + + + + + + @@ -1242,10 +1298,10 @@
Returns
TypeNameDescription
String[] parameters

Paramaters to send to underlying layer

+
StringserverName

The server name
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(DDM_GENERAL_PARAMETER, String)

@@ -1282,10 +1338,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(String, String)

@@ -1322,10 +1378,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

Start(UInt32)

@@ -1372,10 +1428,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Stop(UInt32)

@@ -1424,10 +1480,10 @@

Events

| - Improve this Doc + Improve this Doc - View Source + View Source

ChangedStateEvent

The state has changed

@@ -1454,10 +1510,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ChangingStateEvent

The state is starting to change

@@ -1484,10 +1540,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ClusterStateChangeEvent

The cluster has changed its state

@@ -1514,10 +1570,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

CompletelyDisconnectedEvent

Event received when subsystem detects a complete disconnection from central server or other peers

@@ -1544,10 +1600,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

ConfigurationEvent

Event received during configuration parameter load on subsystem

@@ -1574,10 +1630,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

FirstStateChangeEvent

Called the first time there is state change

@@ -1604,10 +1660,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

LoggingEvent

Event received when a log is received from subsystem

@@ -1634,10 +1690,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

MultiplePrimaryEvent

There are multiple primary server in the cluster

@@ -1664,10 +1720,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

RequestedStateEvent

Called when a state transfer was requested

@@ -1694,10 +1750,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

StateChangeEvent

My state has changed

@@ -1724,10 +1780,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

StateReadyEvent

The state is ready to be used

@@ -1756,10 +1812,10 @@

Explicit Interface Implementations

| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.ChangeMyState(DDM_INSTANCE_STATE)

@@ -1788,10 +1844,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.ChangeState(Int64, DDM_INSTANCE_STATE)

@@ -1825,10 +1881,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.ClusterHealth

@@ -1855,10 +1911,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.ClusterState

@@ -1885,10 +1941,57 @@
Returns
| - Improve this Doc + Improve this Doc + + + View Source + + +

ISmartDataDistributionMastership.GetParameter(String)

+
+
+
Declaration
+
+ 
string ISmartDataDistributionMastership.GetParameter(string paramName)
+
+
Parameters
+ + + + + + + + + + + + + + + +
TypeNameDescription
StringparamName
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
String
+ + | + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.IamNextPrimary

@@ -1915,10 +2018,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.LocalServerId

@@ -1945,10 +2048,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.MessageDelay

@@ -1975,10 +2078,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.MyState

@@ -2005,10 +2108,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.PrimaryServerId

@@ -2035,10 +2138,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.RequestIAmNextPrimary()

@@ -2065,10 +2168,47 @@
Returns
| - Improve this Doc + Improve this Doc + + + View Source + + +

ISmartDataDistributionMastership.SetParameter(String, String)

+
+
+
Declaration
+
+ 
void ISmartDataDistributionMastership.SetParameter(string paramName, string paramValue)
+
+
Parameters
+ + + + + + + + + + + + + + + + + + + + +
TypeNameDescription
StringparamName
StringparamValue
+ + | + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.Start(UInt32)

@@ -2112,10 +2252,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.Stop(UInt32)

@@ -2159,10 +2299,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

ISmartDataDistributionMastership.UpTime

@@ -2202,10 +2342,10 @@

Implements

diff --git a/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistributionChannel.html b/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistributionChannel.html index e0b9ecbb..17fa3d7e 100644 --- a/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistributionChannel.html +++ b/docs/api/MASES.DataDistributionManager.Bindings.SmartDataDistributionChannel.html @@ -119,10 +119,10 @@

Constructors

| - Improve this Doc + Improve this Doc - View Source + View Source

SmartDataDistributionChannel()

@@ -137,10 +137,10 @@

Fields

| - Improve this Doc + Improve this Doc - View Source + View Source

DDM_NO_TIMESTAMP

No timestamp value

@@ -169,10 +169,10 @@

Methods

| - Improve this Doc + Improve this Doc - View Source + View Source

ChangeChannelDirection(DDM_CHANNEL_DIRECTION)

@@ -219,10 +219,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Finalize()

@@ -235,10 +235,10 @@
Declaration
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(DDM_GENERAL_PARAMETER)

@@ -285,10 +285,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

GetParameter(String)

@@ -335,10 +335,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Lock(UInt32)

@@ -362,7 +362,7 @@
Parameters
UInt32 timeout -

Timeout to acuire lock

+

Timeout to acuire lock in ms

@@ -385,10 +385,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

OnConditionOrError(String, OPERATION_RESULT, Int32, String)

@@ -437,10 +437,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

OnDataAvailable(String, String, Byte[])

@@ -483,10 +483,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

ReadFromChannel(Int64, Int64, out Byte[])

@@ -545,10 +545,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

SeekChannel(Int64)

@@ -595,10 +595,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(DDM_GENERAL_PARAMETER, String)

@@ -635,10 +635,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

SetParameter(String, String)

@@ -675,10 +675,10 @@
Parameters
| - Improve this Doc + Improve this Doc - View Source + View Source

StartChannel(UInt32)

@@ -725,10 +725,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

StopChannel(UInt32)

@@ -775,10 +775,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

Unlock()

@@ -807,10 +807,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(Byte[], Boolean, Int64)

@@ -868,10 +868,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, Boolean, Int64)

@@ -929,10 +929,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, Byte[], Boolean, Int64)

@@ -996,10 +996,10 @@
Returns
| - Improve this Doc + Improve this Doc - View Source + View Source

WriteOnChannel(String, String, Boolean, Int64)

@@ -1065,10 +1065,10 @@

Events

| - Improve this Doc + Improve this Doc - View Source + View Source

ConditionOrError

Event to receive condition or errors

@@ -1095,10 +1095,10 @@
Event Type
| - Improve this Doc + Improve this Doc - View Source + View Source

DataAvailable

Event to receive messages when data are available

@@ -1135,10 +1135,10 @@

Implements

diff --git a/docs/api/toc.html b/docs/api/toc.html index 7791b2b5..6adf70cf 100644 --- a/docs/api/toc.html +++ b/docs/api/toc.html @@ -177,6 +177,9 @@
  • LivelinessQosPolicyConfiguration.LivelinessQosPolicyKind
    • +
  • + MastershipConfiguration +
  • OpenDDSChannelConfiguration
    • diff --git a/docs/cppdoc/html/DataDistributionManager_8h_source.html b/docs/cppdoc/html/DataDistributionManager_8h_source.html index 5d9da3af..41cac22a 100644 --- a/docs/cppdoc/html/DataDistributionManager_8h_source.html +++ b/docs/cppdoc/html/DataDistributionManager_8h_source.html @@ -295,44 +295,46 @@
    885 {
    886 public:
    898  virtual OPERATION_RESULT Initialize(IDataDistributionSubsystem *transportManager, IDataDistributionMastershipCallback *cbs, const char *hostAddress = NULL, const char *arrayParams[] = NULL, int len = 0) = 0;
    -
    906  virtual OPERATION_RESULT Start(unsigned long timeout) = 0;
    -
    914  virtual OPERATION_RESULT Stop(unsigned long timeout) = 0;
    -
    920  virtual BOOL GetIamNextPrimary() = 0;
    -
    926  virtual BOOL RequestIAmNextPrimary() = 0;
    -
    935  virtual int64_t *GetClusterIndexes(size_t *length) = 0;
    -
    943  virtual DDM_INSTANCE_STATE GetStateOf(int64_t serverId) = 0;
    -
    949  virtual ClusterHealth GetClusterHealth() = 0;
    -
    955  virtual DDM_INSTANCE_STATE GetMyState() = 0;
    -
    961  virtual void ChangeMyState(DDM_INSTANCE_STATE state) = 0;
    -
    968  virtual void ChangeState(int64_t instanceId, DDM_INSTANCE_STATE state) = 0;
    -
    974  virtual int64_t GetLocalServerId() = 0;
    -
    980  virtual int64_t GetPrimaryServerId() = 0;
    -
    986  virtual int64_t GetMessageDelay() = 0;
    -
    992  virtual int64_t GetUpTime() = 0;
    -
    993 };
    -
    994 
    -
    1000 class DDM_EXPORT IDataDistribution
    -
    1001 {
    -
    1002 public:
    -
    1013  virtual OPERATION_RESULT Initialize(IDataDistributionCallback *iddcb, const char *conf_file = NULL, const char *hostAddress = NULL, const char *channelTrailer = NULL) = 0;
    -
    1025  virtual OPERATION_RESULT Initialize(IDataDistributionCallback *iddcb, const char *arrayParams[], int len, const char *hostAddress = NULL, const char *channelTrailer = NULL) = 0;
    -
    1036  virtual OPERATION_RESULT RequestMastershipManager(IDataDistributionMastershipCallback *cbs, const char *szMyAddress = NULL, const char *arrayParams[] = NULL, int len = 0) = 0;
    -
    1044  virtual BOOL Start(unsigned long timeout) = 0;
    -
    1052  virtual BOOL Stop(unsigned long timeout) = 0;
    -
    1058  virtual IDataDistributionSubsystem *GetSubsystemManager() = 0;
    -
    1064  virtual IDataDistributionMastershipCommon *GetMastershipManager() = 0;
    -
    1070  virtual std::string GetProtocol() = 0;
    -
    1076  virtual std::string GetProtocolLib() = 0;
    -
    1082  virtual std::string GetMastershipLib() = 0;
    -
    1083 };
    -
    1084 
    -
    1090 class DDM_EXPORT DataDistribution : public IDataDistribution
    -
    1091 {
    -
    1092 public:
    -
    1098  static IDataDistribution *create();
    +
    906  virtual void SetParameter(const char *paramName, const char *paramValue) = 0;
    +
    914  virtual const char *GetParameter(const char *paramName) = 0;
    +
    922  virtual OPERATION_RESULT Start(unsigned long timeout) = 0;
    +
    930  virtual OPERATION_RESULT Stop(unsigned long timeout) = 0;
    +
    936  virtual BOOL GetIamNextPrimary() = 0;
    +
    942  virtual BOOL RequestIAmNextPrimary() = 0;
    +
    951  virtual int64_t *GetClusterIndexes(size_t *length) = 0;
    +
    959  virtual DDM_INSTANCE_STATE GetStateOf(int64_t serverId) = 0;
    +
    965  virtual ClusterHealth GetClusterHealth() = 0;
    +
    971  virtual DDM_INSTANCE_STATE GetMyState() = 0;
    +
    977  virtual void ChangeMyState(DDM_INSTANCE_STATE state) = 0;
    +
    984  virtual void ChangeState(int64_t instanceId, DDM_INSTANCE_STATE state) = 0;
    +
    990  virtual int64_t GetLocalServerId() = 0;
    +
    996  virtual int64_t GetPrimaryServerId() = 0;
    +
    1002  virtual int64_t GetMessageDelay() = 0;
    +
    1008  virtual int64_t GetUpTime() = 0;
    +
    1009 };
    +
    1010 
    +
    1016 class DDM_EXPORT IDataDistribution
    +
    1017 {
    +
    1018 public:
    +
    1029  virtual OPERATION_RESULT Initialize(IDataDistributionCallback *iddcb, const char *conf_file = NULL, const char *hostAddress = NULL, const char *channelTrailer = NULL) = 0;
    +
    1041  virtual OPERATION_RESULT Initialize(IDataDistributionCallback *iddcb, const char *arrayParams[], int len, const char *hostAddress = NULL, const char *channelTrailer = NULL) = 0;
    +
    1052  virtual OPERATION_RESULT RequestMastershipManager(IDataDistributionMastershipCallback *cbs, const char *szMyAddress = NULL, const char *arrayParams[] = NULL, int len = 0) = 0;
    +
    1060  virtual BOOL Start(unsigned long timeout) = 0;
    +
    1068  virtual BOOL Stop(unsigned long timeout) = 0;
    +
    1074  virtual IDataDistributionSubsystem *GetSubsystemManager() = 0;
    +
    1080  virtual IDataDistributionMastershipCommon *GetMastershipManager() = 0;
    +
    1086  virtual std::string GetProtocol() = 0;
    +
    1092  virtual std::string GetProtocolLib() = 0;
    +
    1098  virtual std::string GetMastershipLib() = 0;
    1099 };
    1100 
    -
    1101 #endif // !defined(DATADISTRIBUTIONMANAGER_H__INCLUDED_)
    +
    1106 class DDM_EXPORT DataDistribution : public IDataDistribution
    +
    1107 {
    +
    1108 public:
    +
    1114  static IDataDistribution *create();
    +
    1115 };
    +
    1116 
    +
    1117 #endif // !defined(DATADISTRIBUTIONMANAGER_H__INCLUDED_)
    DDM_CHANNEL_DIRECTION
    DDM_CHANNEL_DIRECTION
    DDM_CHANNEL_DIRECTION type.
    Definition: DataDistributionManagerEnums.h:70
    DDM_GENERAL_PARAMETER
    DDM_GENERAL_PARAMETER
    DDM_GENERAL_PARAMETER type.
    Definition: DataDistributionManagerEnums.h:50
    @@ -368,7 +370,7 @@
    DataDistributionChannelCallback::create
    static IDataDistributionChannelCallback * create(void *opaque, dataDistributionUnderlyingEvent uEventCb)
    Creates a new IDataDistributionChannelCallback instance.
    DataDistributionMastershipCallback
    Class to convert C style callbacks into IDataDistributionMastershipCallback C++ callback.
    Definition: DataDistributionManager.h:629
    DataDistributionMastershipCallback::create
    static IDataDistributionMastershipCallback * create(void *opaque, dataDistributionOnClusterStateChange c1, dataDistributionOnStateChange c2, dataDistributionOnStateReady c3, dataDistributionOnRequestedState c4, dataDistributionOnMultiplePrimary c5, dataDistributionFirstStateChange c6, dataDistributionChangingState c7, dataDistributionChangedState c8)
    Creates a new IDataDistributionMastershipCallback instance.
    -
    DataDistribution
    Main entry point to activate an instance of IDataDistribution.
    Definition: DataDistributionManager.h:1091
    +
    DataDistribution
    Main entry point to activate an instance of IDataDistribution.
    Definition: DataDistributionManager.h:1107
    DataDistribution::create
    static IDataDistribution * create()
    Creates a new IDataDistribution instance.
    IDataDistributionCallback
    The C++ callback interface to be externally implemented.
    Definition: DataDistributionManager.h:212
    IDataDistributionCallback::OnLogging
    virtual void OnLogging(DDM_LOG_LEVEL level, const char *source, const char *function, const char *logStr)=0
    Callback invoked when a log is emitted from subsystem.
    @@ -407,6 +409,7 @@
    IDataDistributionMastershipCallback::ChangingState
    virtual void ChangingState(DDM_INSTANCE_STATE actualState, DDM_INSTANCE_STATE futureState)=0
    Callback invoked to report a starting instance state change.
    IDataDistributionMastershipCallback::OnRequestedState
    virtual void OnRequestedState(void **pState, size_t *len)=0
    Callback invoked when a state transfer is requested.
    IDataDistributionMastershipCommon
    Interface to be implemented from mastership subsystem.
    Definition: DataDistributionManager.h:885
    +
    IDataDistributionMastershipCommon::GetParameter
    virtual const char * GetParameter(const char *paramName)=0
    Reads a parameter at run-time.
    IDataDistributionMastershipCommon::GetClusterIndexes
    virtual int64_t * GetClusterIndexes(size_t *length)=0
    Returns an array of all known indexes of the servers within the cluster.
    IDataDistributionMastershipCommon::GetMessageDelay
    virtual int64_t GetMessageDelay()=0
    Returns the message delay within the cluster.
    IDataDistributionMastershipCommon::RequestIAmNextPrimary
    virtual BOOL RequestIAmNextPrimary()=0
    Request to be the next primary server.
    @@ -421,6 +424,7 @@
    IDataDistributionMastershipCommon::GetStateOf
    virtual DDM_INSTANCE_STATE GetStateOf(int64_t serverId)=0
    Returns the DDM_INSTANCE_STATE of a specific server.
    IDataDistributionMastershipCommon::GetUpTime
    virtual int64_t GetUpTime()=0
    Returns the current uptime.
    IDataDistributionMastershipCommon::Initialize
    virtual OPERATION_RESULT Initialize(IDataDistributionSubsystem *transportManager, IDataDistributionMastershipCallback *cbs, const char *hostAddress=NULL, const char *arrayParams[]=NULL, int len=0)=0
    Initialize the subsystem.
    +
    IDataDistributionMastershipCommon::SetParameter
    virtual void SetParameter(const char *paramName, const char *paramValue)=0
    Sets a parameter at run-time.
    IDataDistributionMastershipCommon::GetMyState
    virtual DDM_INSTANCE_STATE GetMyState()=0
    Returns DDM_INSTANCE_STATE of this instance.
    IDataDistributionSubsystem
    Interface to be implemented from subsystem.
    Definition: DataDistributionManager.h:836
    IDataDistributionSubsystem::GetCallbacks
    virtual IDataDistributionCallback * GetCallbacks()=0
    Returns IDataDistributionCallback passed during IDataDistributionSubsystem::Initialize.
    @@ -431,7 +435,7 @@
    IDataDistributionTransport::Start
    virtual OPERATION_RESULT Start(unsigned long timeout)=0
    Start the transport subsystem.
    IDataDistributionTransport::Stop
    virtual OPERATION_RESULT Stop(unsigned long timeout)=0
    Start the transport subsystem.
    IDataDistributionTransport::GetMaxMessageSize
    virtual size_t GetMaxMessageSize()=0
    Returns the max message size managed from the subsystem.
    -
    IDataDistribution
    Interface to be implemented from common manager.
    Definition: DataDistributionManager.h:1001
    +
    IDataDistribution
    Interface to be implemented from common manager.
    Definition: DataDistributionManager.h:1017
    IDataDistribution::GetProtocol
    virtual std::string GetProtocol()=0
    Returns the protocol in use from IDataDistribution instance.
    IDataDistribution::GetSubsystemManager
    virtual IDataDistributionSubsystem * GetSubsystemManager()=0
    Returns the allocated communication subsystem.
    IDataDistribution::GetProtocolLib
    virtual std::string GetProtocolLib()=0
    Returns the protocol library in use from IDataDistribution instance.
    diff --git a/docs/cppdoc/html/SmartDataDistributionManager_8h_source.html b/docs/cppdoc/html/SmartDataDistributionManager_8h_source.html index 7d81fa46..9c8127c6 100644 --- a/docs/cppdoc/html/SmartDataDistributionManager_8h_source.html +++ b/docs/cppdoc/html/SmartDataDistributionManager_8h_source.html @@ -230,7 +230,7 @@
    IDataDistributionChannelCallback
    The C++ callback interface to be externally implemented.
    Definition: DataDistributionManager.h:397
    IDataDistributionMastershipCallback
    The C++ callback interface to be externally implemented.
    Definition: DataDistributionManager.h:542
    IDataDistributionMastershipCommon
    Interface to be implemented from mastership subsystem.
    Definition: DataDistributionManager.h:885
    -
    IDataDistribution
    Interface to be implemented from common manager.
    Definition: DataDistributionManager.h:1001
    +
    IDataDistribution
    Interface to be implemented from common manager.
    Definition: DataDistributionManager.h:1017
    IDataDistribution::GetSubsystemManager
    virtual IDataDistributionSubsystem * GetSubsystemManager()=0
    Returns the allocated communication subsystem.
    ITimeMeasureWrapper
    Interface to manage time information.
    Definition: DataDistributionManager.h:111
    SmartDataDistributionBase
    Smart class to manage IDataDistributionCallback and IDataDistributionMastershipCallback.
    Definition: SmartDataDistributionManager.h:272
    diff --git a/docs/cppdoc/html/classIDataDistributionMastershipCommon-members.html b/docs/cppdoc/html/classIDataDistributionMastershipCommon-members.html index f00bad6d..7335023f 100644 --- a/docs/cppdoc/html/classIDataDistributionMastershipCommon-members.html +++ b/docs/cppdoc/html/classIDataDistributionMastershipCommon-members.html @@ -95,11 +95,13 @@ GetLocalServerId()=0IDataDistributionMastershipCommonpure virtual GetMessageDelay()=0IDataDistributionMastershipCommonpure virtual GetMyState()=0IDataDistributionMastershipCommonpure virtual - GetPrimaryServerId()=0IDataDistributionMastershipCommonpure virtual - GetStateOf(int64_t serverId)=0IDataDistributionMastershipCommonpure virtual - GetUpTime()=0IDataDistributionMastershipCommonpure virtual - Initialize(IDataDistributionSubsystem *transportManager, IDataDistributionMastershipCallback *cbs, const char *hostAddress=NULL, const char *arrayParams[]=NULL, int len=0)=0IDataDistributionMastershipCommonpure virtual - RequestIAmNextPrimary()=0IDataDistributionMastershipCommonpure virtual + GetParameter(const char *paramName)=0IDataDistributionMastershipCommonpure virtual + GetPrimaryServerId()=0IDataDistributionMastershipCommonpure virtual + GetStateOf(int64_t serverId)=0IDataDistributionMastershipCommonpure virtual + GetUpTime()=0IDataDistributionMastershipCommonpure virtual + Initialize(IDataDistributionSubsystem *transportManager, IDataDistributionMastershipCallback *cbs, const char *hostAddress=NULL, const char *arrayParams[]=NULL, int len=0)=0IDataDistributionMastershipCommonpure virtual + RequestIAmNextPrimary()=0IDataDistributionMastershipCommonpure virtual + SetParameter(const char *paramName, const char *paramValue)=0IDataDistributionMastershipCommonpure virtual Start(unsigned long timeout)=0IDataDistributionMastershipCommonpure virtual Stop(unsigned long timeout)=0IDataDistributionMastershipCommonpure virtual
    diff --git a/docs/cppdoc/html/classIDataDistributionMastershipCommon.html b/docs/cppdoc/html/classIDataDistributionMastershipCommon.html index 16822803..e71eae59 100644 --- a/docs/cppdoc/html/classIDataDistributionMastershipCommon.html +++ b/docs/cppdoc/html/classIDataDistributionMastershipCommon.html @@ -98,6 +98,12 @@ virtual OPERATION_RESULT Initialize (IDataDistributionSubsystem *transportManager, IDataDistributionMastershipCallback *cbs, const char *hostAddress=NULL, const char *arrayParams[]=NULL, int len=0)=0  Initialize the subsystem. More...
      +virtual void SetParameter (const char *paramName, const char *paramValue)=0 + Sets a parameter at run-time. More...
    +  +virtual const char * GetParameter (const char *paramName)=0 + Reads a parameter at run-time. More...
    +  virtual OPERATION_RESULT Start (unsigned long timeout)=0  Start the mastership subsystem. More...
      @@ -382,6 +388,36 @@

    Returns
    the DDM_INSTANCE_STATE
    +

    +
    + +

    ◆ GetParameter()

    + +
    +
    + + + + + +
    + + + + + + + + +
    virtual const char* IDataDistributionMastershipCommon::GetParameter (const char * paramName)
    +     		+pure virtual
    +
    + +

    Reads a parameter at run-time.

    +

    paramName the parameter name

    +
    Returns
    parameter value
    +
    @@ -554,6 +590,45 @@

    Returns
    TRUE in case of success
    +

    +
    + +

    ◆ SetParameter()

    + +
    +
    + + + + + +
    + + + + + + + + + + + + + + + + + + +
    virtual void IDataDistributionMastershipCommon::SetParameter (const char * paramName,
    const char * paramValue 
    )
    +     		+pure virtual
    +
    + +

    Sets a parameter at run-time.

    +

    paramName the parameter name paramValue the parameter value

    +
    diff --git a/docs/cppdoc/html/classIDataDistributionMastershipCommon.js b/docs/cppdoc/html/classIDataDistributionMastershipCommon.js index ab311d1e..c90054c0 100644 --- a/docs/cppdoc/html/classIDataDistributionMastershipCommon.js +++ b/docs/cppdoc/html/classIDataDistributionMastershipCommon.js @@ -8,11 +8,13 @@ var classIDataDistributionMastershipCommon = [ "GetLocalServerId", "classIDataDistributionMastershipCommon.html#a4d2ddda3a03e312f0a590370fd9c724d", null ], [ "GetMessageDelay", "classIDataDistributionMastershipCommon.html#a1a18d24fe7b8f6882bc8ebecedfa5e2c", null ], [ "GetMyState", "classIDataDistributionMastershipCommon.html#acf848e01ec68dcd6368ace4b46651c58", null ], + [ "GetParameter", "classIDataDistributionMastershipCommon.html#a02006f147722ca31a4c04f51f2751820", null ], [ "GetPrimaryServerId", "classIDataDistributionMastershipCommon.html#a4631ed8498a766291a17f379a6a3456d", null ], [ "GetStateOf", "classIDataDistributionMastershipCommon.html#ab16d91ca96b1a9b1bb4ae4b6c299cc90", null ], [ "GetUpTime", "classIDataDistributionMastershipCommon.html#ab2bed207c1bc9fd204abb610f8f65eb5", null ], [ "Initialize", "classIDataDistributionMastershipCommon.html#ab58b89e5fd4326b199d779f1b6f0e792", null ], [ "RequestIAmNextPrimary", "classIDataDistributionMastershipCommon.html#a23a5cef9ba7029e5629104021a33d681", null ], + [ "SetParameter", "classIDataDistributionMastershipCommon.html#ac700bdbec73403aa24684cbe58dbafa4", null ], [ "Start", "classIDataDistributionMastershipCommon.html#a4625afc58a0111318e8c0b67b2fcdcf9", null ], [ "Stop", "classIDataDistributionMastershipCommon.html#a7a5a916810dcd69014f914f3e23755a1", null ] ]; \ No newline at end of file diff --git a/docs/cppdoc/html/classIDataDistributionTransport.html b/docs/cppdoc/html/classIDataDistributionTransport.html index d811e971..1aad72c4 100644 --- a/docs/cppdoc/html/classIDataDistributionTransport.html +++ b/docs/cppdoc/html/classIDataDistributionTransport.html @@ -217,7 +217,7 @@

    Returns the server lost timeout.

    -
    Returns
    The server lost timeout
    +
    Returns
    The server lost timeout in milliseconds

    diff --git a/docs/cppdoc/html/functions.html b/docs/cppdoc/html/functions.html index 27aa35f0..67637a98 100644 --- a/docs/cppdoc/html/functions.html +++ b/docs/cppdoc/html/functions.html @@ -216,6 +216,7 @@

    - g -

    • GetParameter() : IDataDistributionChannelBase +, IDataDistributionMastershipCommon
    • GetPrimaryServerId() : IDataDistributionMastershipCommon @@ -378,6 +379,7 @@

      - s -

      • SetParameter() : IDataDistributionChannelBase +, IDataDistributionMastershipCommon
      • SmartDataDistribution() : SmartDataDistribution< T > diff --git a/docs/cppdoc/html/functions_func.html b/docs/cppdoc/html/functions_func.html index 6368ae39..716905e1 100644 --- a/docs/cppdoc/html/functions_func.html +++ b/docs/cppdoc/html/functions_func.html @@ -200,6 +200,7 @@

        - g -

        • GetParameter() : IDataDistributionChannelBase +, IDataDistributionMastershipCommon
        • GetPrimaryServerId() : IDataDistributionMastershipCommon @@ -323,6 +324,7 @@

          - s -

          • SetParameter() : IDataDistributionChannelBase +, IDataDistributionMastershipCommon
          • SmartDataDistribution() : SmartDataDistribution< T > diff --git a/docs/cppdoc/html/navtreedata.js b/docs/cppdoc/html/navtreedata.js index 3219989f..06556479 100644 --- a/docs/cppdoc/html/navtreedata.js +++ b/docs/cppdoc/html/navtreedata.js @@ -50,7 +50,7 @@ var NAVTREE = var NAVTREEINDEX = [ "DataDistributionManagerEnums_8h.html", -"structUnderlyingEventData.html#a9700d4b42c01f03699d2bef36076822c" +"structUnderlyingEventData.html#a3b3b60aecd099db215b310a7a581ecec" ]; var SYNCONMSG = 'click to disable panel synchronisation'; diff --git a/docs/cppdoc/html/navtreeindex0.js b/docs/cppdoc/html/navtreeindex0.js index db000a99..1a0bf2d1 100644 --- a/docs/cppdoc/html/navtreeindex0.js +++ b/docs/cppdoc/html/navtreeindex0.js @@ -139,20 +139,22 @@ var NAVTREEINDEX0 = "classIDataDistributionMastershipCallback.html#ab6e717658b571b053ac2e6fc759c8472":[0,0,11,1], "classIDataDistributionMastershipCallback.html#af74250f64cb834e75e0c0c5e9b0c51c8":[0,0,11,5], "classIDataDistributionMastershipCommon.html":[0,0,12], +"classIDataDistributionMastershipCommon.html#a02006f147722ca31a4c04f51f2751820":[0,0,12,8], "classIDataDistributionMastershipCommon.html#a0ce4cb38aae06361045dc1309c0422b9":[0,0,12,3], "classIDataDistributionMastershipCommon.html#a1a18d24fe7b8f6882bc8ebecedfa5e2c":[0,0,12,6], -"classIDataDistributionMastershipCommon.html#a23a5cef9ba7029e5629104021a33d681":[0,0,12,12], +"classIDataDistributionMastershipCommon.html#a23a5cef9ba7029e5629104021a33d681":[0,0,12,13], "classIDataDistributionMastershipCommon.html#a4076b60990011fd42de0a31007c8b151":[0,0,12,2], "classIDataDistributionMastershipCommon.html#a44255bdcb946f3100959917adcfd3e6e":[0,0,12,0], -"classIDataDistributionMastershipCommon.html#a4625afc58a0111318e8c0b67b2fcdcf9":[0,0,12,13], -"classIDataDistributionMastershipCommon.html#a4631ed8498a766291a17f379a6a3456d":[0,0,12,8], +"classIDataDistributionMastershipCommon.html#a4625afc58a0111318e8c0b67b2fcdcf9":[0,0,12,15], +"classIDataDistributionMastershipCommon.html#a4631ed8498a766291a17f379a6a3456d":[0,0,12,9], "classIDataDistributionMastershipCommon.html#a4d2ddda3a03e312f0a590370fd9c724d":[0,0,12,5], "classIDataDistributionMastershipCommon.html#a6e1ad816a4d5397b4d23feeb4f1854f4":[0,0,12,1], -"classIDataDistributionMastershipCommon.html#a7a5a916810dcd69014f914f3e23755a1":[0,0,12,14], +"classIDataDistributionMastershipCommon.html#a7a5a916810dcd69014f914f3e23755a1":[0,0,12,16], "classIDataDistributionMastershipCommon.html#a9c36846f6a7bee9f1677517e8d92398f":[0,0,12,4], -"classIDataDistributionMastershipCommon.html#ab16d91ca96b1a9b1bb4ae4b6c299cc90":[0,0,12,9], -"classIDataDistributionMastershipCommon.html#ab2bed207c1bc9fd204abb610f8f65eb5":[0,0,12,10], -"classIDataDistributionMastershipCommon.html#ab58b89e5fd4326b199d779f1b6f0e792":[0,0,12,11], +"classIDataDistributionMastershipCommon.html#ab16d91ca96b1a9b1bb4ae4b6c299cc90":[0,0,12,10], +"classIDataDistributionMastershipCommon.html#ab2bed207c1bc9fd204abb610f8f65eb5":[0,0,12,11], +"classIDataDistributionMastershipCommon.html#ab58b89e5fd4326b199d779f1b6f0e792":[0,0,12,12], +"classIDataDistributionMastershipCommon.html#ac700bdbec73403aa24684cbe58dbafa4":[0,0,12,14], "classIDataDistributionMastershipCommon.html#acf848e01ec68dcd6368ace4b46651c58":[0,0,12,7], "classIDataDistributionSubsystem.html":[0,0,13], "classIDataDistributionSubsystem.html#a57ef71f555e939bd0dba355b67e69b83":[0,0,13,0], @@ -247,7 +249,5 @@ var NAVTREEINDEX0 = "structUnderlyingEventData.html":[0,0,21], "structUnderlyingEventData.html#a079ded7363bf0b295d85791b32eeff33":[0,0,21,5], "structUnderlyingEventData.html#a12b66c4401381decefab833a156f8f23":[0,0,21,8], -"structUnderlyingEventData.html#a363669e6a6738e2ad6edd9158ae07d8a":[0,0,21,11], -"structUnderlyingEventData.html#a3b3b60aecd099db215b310a7a581ecec":[0,0,21,10], -"structUnderlyingEventData.html#a7d766896520d9477862be8ad30b50746":[0,0,21,0] +"structUnderlyingEventData.html#a363669e6a6738e2ad6edd9158ae07d8a":[0,0,21,11] }; diff --git a/docs/cppdoc/html/navtreeindex1.js b/docs/cppdoc/html/navtreeindex1.js index 9b5fea4c..1599d23c 100644 --- a/docs/cppdoc/html/navtreeindex1.js +++ b/docs/cppdoc/html/navtreeindex1.js @@ -1,5 +1,7 @@ var NAVTREEINDEX1 = { +"structUnderlyingEventData.html#a3b3b60aecd099db215b310a7a581ecec":[0,0,21,10], +"structUnderlyingEventData.html#a7d766896520d9477862be8ad30b50746":[0,0,21,0], "structUnderlyingEventData.html#a9700d4b42c01f03699d2bef36076822c":[0,0,21,1], "structUnderlyingEventData.html#a9e8adf05a5c1298f77c9fc1d4bccd99c":[0,0,21,3], "structUnderlyingEventData.html#acbaee1c1711a13473dd876c8f2e1357f":[0,0,21,6], diff --git a/docs/cppdoc/html/search/all_6.js b/docs/cppdoc/html/search/all_6.js index dbd4b0b0..a405f5dc 100644 --- a/docs/cppdoc/html/search/all_6.js +++ b/docs/cppdoc/html/search/all_6.js @@ -14,7 +14,7 @@ var searchData= ['getmessagedelay_88',['GetMessageDelay',['../classIDataDistributionMastershipCommon.html#a1a18d24fe7b8f6882bc8ebecedfa5e2c',1,'IDataDistributionMastershipCommon']]], ['getmystate_89',['GetMyState',['../classIDataDistributionMastershipCommon.html#acf848e01ec68dcd6368ace4b46651c58',1,'IDataDistributionMastershipCommon']]], ['getopaquehandle_90',['GetOpaqueHandle',['../classIDataDistributionChannel.html#a620c5c0b00885b01508794465270af21',1,'IDataDistributionChannel']]], - ['getparameter_91',['GetParameter',['../classIDataDistributionChannelBase.html#ad1416d72bdb9955f5d8760e58e3deb41',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName)=0'],['../classIDataDistributionChannelBase.html#a3cdc0c1879fc53fd33dd02df084963c0',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId)=0']]], + ['getparameter_91',['GetParameter',['../classIDataDistributionChannelBase.html#ad1416d72bdb9955f5d8760e58e3deb41',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName)=0'],['../classIDataDistributionChannelBase.html#a3cdc0c1879fc53fd33dd02df084963c0',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId)=0'],['../classIDataDistributionMastershipCommon.html#a02006f147722ca31a4c04f51f2751820',1,'IDataDistributionMastershipCommon::GetParameter(const char *paramName)=0']]], ['getprimaryserverid_92',['GetPrimaryServerId',['../classIDataDistributionMastershipCommon.html#a4631ed8498a766291a17f379a6a3456d',1,'IDataDistributionMastershipCommon']]], ['getprotocol_93',['GetProtocol',['../classIDataDistribution.html#a02f2eb31db9444610fad96e6abfc51a1',1,'IDataDistribution::GetProtocol()'],['../classSmartDataDistributionBase.html#af80be20bf50fe717942785f1045198a6',1,'SmartDataDistributionBase::GetProtocol()']]], ['getprotocollib_94',['GetProtocolLib',['../classIDataDistribution.html#a059e0086fe16ddbd9986718548564e5e',1,'IDataDistribution::GetProtocolLib()'],['../classSmartDataDistributionBase.html#a97dbf0b446c1b9adda6da0ef39687c7c',1,'SmartDataDistributionBase::GetProtocolLib()']]], diff --git a/docs/cppdoc/html/search/all_f.js b/docs/cppdoc/html/search/all_f.js index cc8c36a9..1a4b8d81 100644 --- a/docs/cppdoc/html/search/all_f.js +++ b/docs/cppdoc/html/search/all_f.js @@ -4,7 +4,7 @@ var searchData= ['server_5flost_5ftimeout_152',['SERVER_LOST_TIMEOUT',['../DataDistributionManagerEnums_8h.html#a2b3ce1452c72e4994396c1b2f69f8b00aa21bed4dcc7267e2c3db50de9b5a6655',1,'DataDistributionManagerEnums.h']]], ['serverid_153',['ServerId',['../structClusterHealthElement.html#aa3733ab9e950b3b34555acaeb9b957ce',1,'ClusterHealthElement']]], ['setinformation_154',['SetInformation',['../classSmartDataDistributionChannel.html#ab9d29e9530abad3aae309a8487240c32',1,'SmartDataDistributionChannel']]], - ['setparameter_155',['SetParameter',['../classIDataDistributionChannelBase.html#af342850516a84c88da2c40431949e9ec',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName, const char *paramValue)=0'],['../classIDataDistributionChannelBase.html#af28e9eeaae5fe144370252efc6be1617',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId, const char *paramValue)=0']]], + ['setparameter_155',['SetParameter',['../classIDataDistributionChannelBase.html#af342850516a84c88da2c40431949e9ec',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName, const char *paramValue)=0'],['../classIDataDistributionChannelBase.html#af28e9eeaae5fe144370252efc6be1617',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId, const char *paramValue)=0'],['../classIDataDistributionMastershipCommon.html#ac700bdbec73403aa24684cbe58dbafa4',1,'IDataDistributionMastershipCommon::SetParameter()']]], ['smartdatadistribution_156',['SmartDataDistribution',['../classSmartDataDistribution.html',1,'SmartDataDistribution< T >'],['../classSmartDataDistribution.html#aaad2c4880fdadacd37905f60e02a0c5e',1,'SmartDataDistribution::SmartDataDistribution()']]], ['smartdatadistributionbase_157',['SmartDataDistributionBase',['../classSmartDataDistributionBase.html',1,'SmartDataDistributionBase'],['../classSmartDataDistributionBase.html#a92242785bff191c5a2ffde294f04d9f1',1,'SmartDataDistributionBase::SmartDataDistributionBase()']]], ['smartdatadistributionchannel_158',['SmartDataDistributionChannel',['../classSmartDataDistributionChannel.html',1,'SmartDataDistributionChannel'],['../classSmartDataDistributionChannel.html#aa8dc78954ca97d64089a0876858431e3',1,'SmartDataDistributionChannel::SmartDataDistributionChannel()']]], diff --git a/docs/cppdoc/html/search/functions_5.js b/docs/cppdoc/html/search/functions_5.js index ef5d0b2c..23a6ac69 100644 --- a/docs/cppdoc/html/search/functions_5.js +++ b/docs/cppdoc/html/search/functions_5.js @@ -13,7 +13,7 @@ var searchData= ['getmessagedelay_230',['GetMessageDelay',['../classIDataDistributionMastershipCommon.html#a1a18d24fe7b8f6882bc8ebecedfa5e2c',1,'IDataDistributionMastershipCommon']]], ['getmystate_231',['GetMyState',['../classIDataDistributionMastershipCommon.html#acf848e01ec68dcd6368ace4b46651c58',1,'IDataDistributionMastershipCommon']]], ['getopaquehandle_232',['GetOpaqueHandle',['../classIDataDistributionChannel.html#a620c5c0b00885b01508794465270af21',1,'IDataDistributionChannel']]], - ['getparameter_233',['GetParameter',['../classIDataDistributionChannelBase.html#ad1416d72bdb9955f5d8760e58e3deb41',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName)=0'],['../classIDataDistributionChannelBase.html#a3cdc0c1879fc53fd33dd02df084963c0',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId)=0']]], + ['getparameter_233',['GetParameter',['../classIDataDistributionChannelBase.html#ad1416d72bdb9955f5d8760e58e3deb41',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName)=0'],['../classIDataDistributionChannelBase.html#a3cdc0c1879fc53fd33dd02df084963c0',1,'IDataDistributionChannelBase::GetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId)=0'],['../classIDataDistributionMastershipCommon.html#a02006f147722ca31a4c04f51f2751820',1,'IDataDistributionMastershipCommon::GetParameter(const char *paramName)=0']]], ['getprimaryserverid_234',['GetPrimaryServerId',['../classIDataDistributionMastershipCommon.html#a4631ed8498a766291a17f379a6a3456d',1,'IDataDistributionMastershipCommon']]], ['getprotocol_235',['GetProtocol',['../classIDataDistribution.html#a02f2eb31db9444610fad96e6abfc51a1',1,'IDataDistribution::GetProtocol()'],['../classSmartDataDistributionBase.html#af80be20bf50fe717942785f1045198a6',1,'SmartDataDistributionBase::GetProtocol()']]], ['getprotocollib_236',['GetProtocolLib',['../classIDataDistribution.html#a059e0086fe16ddbd9986718548564e5e',1,'IDataDistribution::GetProtocolLib()'],['../classSmartDataDistributionBase.html#a97dbf0b446c1b9adda6da0ef39687c7c',1,'SmartDataDistributionBase::GetProtocolLib()']]], diff --git a/docs/cppdoc/html/search/functions_a.js b/docs/cppdoc/html/search/functions_a.js index 3ef6f7a0..c7176e75 100644 --- a/docs/cppdoc/html/search/functions_a.js +++ b/docs/cppdoc/html/search/functions_a.js @@ -2,7 +2,7 @@ var searchData= [ ['seekchannel_259',['SeekChannel',['../classIDataDistributionChannelBase.html#ac0b1042252fdb2ba80f29f051dec12a7',1,'IDataDistributionChannelBase::SeekChannel()'],['../classSmartDataDistributionChannel.html#ac3f0809fb7dd207ff46ee64ed2d81968',1,'SmartDataDistributionChannel::SeekChannel(int64_t position)']]], ['setinformation_260',['SetInformation',['../classSmartDataDistributionChannel.html#ab9d29e9530abad3aae309a8487240c32',1,'SmartDataDistributionChannel']]], - ['setparameter_261',['SetParameter',['../classIDataDistributionChannelBase.html#af342850516a84c88da2c40431949e9ec',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName, const char *paramValue)=0'],['../classIDataDistributionChannelBase.html#af28e9eeaae5fe144370252efc6be1617',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId, const char *paramValue)=0']]], + ['setparameter_261',['SetParameter',['../classIDataDistributionChannelBase.html#af342850516a84c88da2c40431949e9ec',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, const char *paramName, const char *paramValue)=0'],['../classIDataDistributionChannelBase.html#af28e9eeaae5fe144370252efc6be1617',1,'IDataDistributionChannelBase::SetParameter(CHANNEL_HANDLE_PARAMETER, DDM_GENERAL_PARAMETER paramId, const char *paramValue)=0'],['../classIDataDistributionMastershipCommon.html#ac700bdbec73403aa24684cbe58dbafa4',1,'IDataDistributionMastershipCommon::SetParameter()']]], ['smartdatadistribution_262',['SmartDataDistribution',['../classSmartDataDistribution.html#aaad2c4880fdadacd37905f60e02a0c5e',1,'SmartDataDistribution']]], ['smartdatadistributionbase_263',['SmartDataDistributionBase',['../classSmartDataDistributionBase.html#a92242785bff191c5a2ffde294f04d9f1',1,'SmartDataDistributionBase']]], ['smartdatadistributionchannel_264',['SmartDataDistributionChannel',['../classSmartDataDistributionChannel.html#aa8dc78954ca97d64089a0876858431e3',1,'SmartDataDistributionChannel']]], diff --git a/docs/javadoc/constant-values.html b/docs/javadoc/constant-values.html index b84910af..c55fa7eb 100644 --- a/docs/javadoc/constant-values.html +++ b/docs/javadoc/constant-values.html @@ -162,27 +162,34 @@

            org.mases.*

            "datadistributionmanager.loglevel.global" + + +public static final String +MastershipLibraryKey +"datadistributionmanager.common.mastershiplib" + + public static final String MaxMessageSizeKey "datadistributionmanager.maxmessagesize" - + public static final String ProtocolKey "datadistributionmanager.common.protocol" - + public static final String ProtocolLibraryKey "datadistributionmanager.common.protolib" - + public static final String @@ -1383,6 +1390,29 @@

            org.mases.*

          • + + + + + + + + + + + + + + + +
            org.mases.datadistributionmanager.configuration.MastershipConfiguration 
            Modifier and TypeConstant FieldValue
            + +public static final StringMastershipGlobalConfigurationBasePropertyKey"datadistributionmanager.mastership."
            +
            +
            • +
          • +
            + diff --git a/docs/javadoc/org/mases/datadistributionmanager/CommonConfiguration.html b/docs/javadoc/org/mases/datadistributionmanager/CommonConfiguration.html index 354badb5..bdebaef7 100644 --- a/docs/javadoc/org/mases/datadistributionmanager/CommonConfiguration.html +++ b/docs/javadoc/org/mases/datadistributionmanager/CommonConfiguration.html @@ -91,7 +91,7 @@

            Class CommonConfiguration
            Direct Known Subclasses:
            -
            KafkaConfiguration, OpenDDSConfiguration
            +
            KafkaConfiguration, MastershipConfiguration, OpenDDSConfiguration
            public abstract class CommonConfiguration
@@ -169,7 +169,7 @@ 
            Field Summary
            
 
            Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration
            
 
 
-GlobalLogLevelKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
+GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
 
 
 
@@ -358,7 +358,7 @@ 
            Method Summary
            
 
            Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration
            
 
 
-getGlobalLogLevel, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout
+getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout
 
            
 
            Methods inherited from class org.mases.datadistributionmanager.BaseConfiguration
            
 
@@ -523,7 +523,7 @@ 
            getCreateChannelTimeout
            
 
            The timeout on create channel
            
 
            
 
            Returns:
            
-
            The create channel timeout
            
+
            The create channel timeout in ms
            
 
            
 
 
@@ -534,7 +534,7 @@ 
            setCreateChannelTimeoutThe timeout on create channel
            
 
            
 
            Parameters:
            
-
            timeout - The create channel timeout
            
+
            timeout - The create channel timeout in ms
            
 
            
 
 
@@ -545,7 +545,7 @@ 
            getChannelSeekTimeout
            
 
            The timeout on seek channel
            
 
            
 
            Returns:
            
-
            The seek timeout
            
+
            The seek timeout in ms
            
 
            
 
 
@@ -556,7 +556,7 @@ 
            setChannelSeekTimeoutThe timeout on seek channel
 
            
 
            Parameters:
            
-
            timeout - The seek timeout
            
+
            timeout - The seek timeout in ms
            
 
            
 
 
@@ -567,7 +567,7 @@ 
            getReceiveTimeout
            
 
            The timeout on channel receive
            
 
            
 
            Returns:
            
-
            The receive timeout
            
+
            The receive timeout in ms
            
 
            
 
 
@@ -589,7 +589,7 @@ 
            getKeepAliveTimeout
            
 
            The timeout on channel keep alive
            
 
            
 
            Returns:
            
-
            The keep-alive timeout
            
+
            The keep-alive timeout in ms
            
 
            
 
 
@@ -600,7 +600,7 @@ 
            setKeepAliveTimeout
            
 
            The timeout on channel keep alive
            
 
            
 
            Parameters:
            
-
            timeout - The keep-alive timeout
            
+
            timeout - The keep-alive timeout in ms
            
 
            
 
 
@@ -611,7 +611,7 @@ 
            getConsumerTimeout
            
 
            The timeout on channel message consume
            
 
            
 
            Returns:
            
-
            The consumer timeout
            
+
            The consumer timeout in ms
            
 
            
 
 
@@ -622,7 +622,7 @@ 
            setConsumerTimeout
            
 
            The timeout on channel message consume
            
 
            
 
            Parameters:
            
-
            timeout - The consumer timeout
            
+
            timeout - The consumer timeout in ms
            
 
            
 
 
@@ -633,7 +633,7 @@ 
            getProducerTimeout
            
 
            The timeout on channel message produce
            
 
            
 
            Returns:
            
-
            The producer timeout
            
+
            The producer timeout in ms
            
 
            
 
 
@@ -644,7 +644,7 @@ 
            setProducerTimeout
            
 
            The timeout on channel message produce
            
 
            
 
            Parameters:
            
-
            timeout - The producer timeout
            
+
            timeout - The producer timeout in ms
            
 
            
 
 
@@ -655,7 +655,7 @@ 
            getCommitTimeout
            
 
            The timeout on channel message commit
            
 
            
 
            Returns:
            
-
            The commit timeout
            
+
            The commit timeout in ms
            
 
            
 
 
@@ -666,7 +666,7 @@ 
            setCommitTimeout
            
 
            The timeout on channel message commit
            
 
            
 
            Parameters:
            
-
            timeout - The commit timeout
            
+
            timeout - The commit timeout in ms
            
 
            
 
 
diff --git a/docs/javadoc/org/mases/datadistributionmanager/GlobalConfiguration.html b/docs/javadoc/org/mases/datadistributionmanager/GlobalConfiguration.html
index 4a42f3ab..adc50a27 100644
--- a/docs/javadoc/org/mases/datadistributionmanager/GlobalConfiguration.html
+++ b/docs/javadoc/org/mases/datadistributionmanager/GlobalConfiguration.html
@@ -11,7 +11,7 @@
 
 
 
-
 
 
-
 
 
-
+
+
+
+
+
            
+
+
            
+
+
            
+
            
+
            Package org.mases.datadistributionmanager.configuration
            
+
            Class MastershipConfiguration
            
+
            
+
            
+
            java.lang.Object
+
            org.mases.datadistributionmanager.BaseConfiguration
+
            org.mases.datadistributionmanager.GlobalConfiguration
+
            org.mases.datadistributionmanager.CommonConfiguration
+
            org.mases.datadistributionmanager.configuration.MastershipConfiguration
            
+
            
+
            
+
            
+
            
+
            
+
            
+
            All Implemented Interfaces:
            
+
            IConfiguration
            
+
            
+
            
+
            public class MastershipConfiguration
+extends CommonConfiguration
            
+
            The configuration class for mastership based on
+ DataDistributionMastershipManager
            
+
            
+
            
+
              
+
+
            • 
+
              
+
+
+
              Field Summary
              
+
              
+

            org.mases.datadistributionmanager.configuration.OpenDDSConfiguration 
            + + + + + + + + + + + + + + + +
            Fields 
            Modifier and TypeFieldDescription
            static StringMastershipGlobalConfigurationBasePropertyKey 
            +
            +
            +

            Fields inherited from class org.mases.datadistributionmanager.CommonConfiguration

            + + +ChannelSeekTimeoutKey, CommitSyncKey, CommitTimeoutKey, ConsumerTimeoutKey, CreateChannelTimeoutKey, EventSyncKey, KeepAliveTimeoutKey, ProducerTimeoutKey, ReceiveTimeoutKey
            +
            +

            Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration

            + + +GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
            +
    + + +
  • +
    + + +

    Constructor Summary

    +
    + + + + + + + + + + + + + + + + + + +
    Constructors 
    ConstructorDescription
    MastershipConfiguration​(String libraryName, +IConfiguration originalConf) +
    Duplicates a configuration
    +
    MastershipConfiguration​(IConfiguration originalConf) +
    Duplicates a configuration
    +
    +
    +
    +
    • + +
  • +
    + + +

    Method Summary

    +
    +
    +
    + + + + + + + + + + + + + + + + + + + + +
    Modifier and TypeMethodDescription
    StringgetProperty​(String property) +
    Generic getter for all configuration properties
    +
    voidsetProperty​(String property, +String value) +
    Generic setter for all configuration properties
    +
    +
    +
    +
    +

    Methods inherited from class org.mases.datadistributionmanager.CommonConfiguration

    + + +getChannelSeekTimeout, getCommitSync, getCommitTimeout, getConsumerTimeout, getCreateChannelTimeout, getEventSync, getKeepAliveTimeout, getProducerTimeout, getReceiveTimeout, setChannelSeekTimeout, setCommitSync, setCommitTimeout, setConsumerTimeout, setCreateChannelTimeout, setEventSync, setKeepAliveTimeout, setProducerTimeout, setReceiveTimeout
    +
    +

    Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration

    + + +getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout
    +
    +

    Methods inherited from class org.mases.datadistributionmanager.BaseConfiguration

    + + +getConfiguration
    +
    +

    Methods inherited from class java.lang.Object

    + + +equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    +
    +
    • + + +
    + +
    +
    + + + + + diff --git a/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSChannelConfiguration.html b/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSChannelConfiguration.html index 7c0af7fa..8c42b86d 100644 --- a/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSChannelConfiguration.html +++ b/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSChannelConfiguration.html @@ -175,7 +175,7 @@

    Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration

    -GlobalLogLevelKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
    +GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
    @@ -225,7 +225,7 @@

    Methods inherited from class org.mases.datadistributionmanager.Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration

    -getGlobalLogLevel, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout
    +getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout

    Methods inherited from class java.lang.Object

    diff --git a/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSConfiguration.html b/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSConfiguration.html index b6b80daf..e11d0c1d 100644 --- a/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSConfiguration.html +++ b/docs/javadoc/org/mases/datadistributionmanager/configuration/OpenDDSConfiguration.html @@ -177,7 +177,7 @@

    Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration

    -GlobalLogLevelKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
    +GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey
    @@ -321,7 +321,7 @@

    Methods inherited from class org.mases.datadistributionmanager.Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration

    -getGlobalLogLevel, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout
    +getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout

    Methods inherited from class java.lang.Object

    diff --git a/docs/javadoc/org/mases/datadistributionmanager/configuration/package-summary.html b/docs/javadoc/org/mases/datadistributionmanager/configuration/package-summary.html index 80305f6e..f6911634 100644 --- a/docs/javadoc/org/mases/datadistributionmanager/configuration/package-summary.html +++ b/docs/javadoc/org/mases/datadistributionmanager/configuration/package-summary.html @@ -156,106 +156,113 @@

    Package org.mases.datadistributionmanager +MastershipConfiguration + +
    The configuration class for mastership based on + DataDistributionMastershipManager
    + + + OpenDDSChannelConfiguration   - + OpenDDSConfiguration
    The configuration class for OpenDDS
    - + OwnershipQosPolicyConfiguration
    The configuration class for OwnershipQosPolicy.
    - + OwnershipStrengthQosPolicyConfiguration
    The configuration class for OwnershipStrengthQosPolicy.
    - + PartitionQosPolicyConfiguration
    The configuration class for PartitionQosPolicy.
    - + PresentationQosPolicyConfiguration
    The configuration class for PresentationQosPolicy.
    - + PropertyQosPolicyConfiguration
    The configuration class for PropertyQosPolicy.
    - + PublisherQosConfiguration
    The configuration class for PublisherQos.
    - + ReaderDataLifecycleQosPolicyConfiguration
    The configuration class for ReaderDataLifecycleQosPolicy.
    - + ReliabilityQosPolicyConfiguration
    The configuration class for ReliabilityQosPolicy.
    - + ResourceLimitsQosPolicyConfiguration
    The configuration class for ResourceLimitsQosPolicy.
    - + SubscriberQosConfiguration
    The configuration class for SubscriberQos.
    - + TimeBasedFilterQosPolicyConfiguration
    The configuration class for TimeBasedFilterQosPolicy.
    - + TopicDataQosPolicyConfiguration
    The configuration class for TopicDataQosPolicy.
    - + TopicQosConfiguration
    The configuration class for TopicQos.
    - + TransportPriorityQosPolicyConfiguration
    The configuration class for TransportPriorityQos.
    - + UserDataQosPolicyConfiguration
    The configuration class for UserDataQosPolicy.
    - + WriterDataLifecycleQosPolicyConfiguration
    The configuration class for WriterDataLifecycleQosPolicy.
    diff --git a/docs/javadoc/org/mases/datadistributionmanager/configuration/package-tree.html b/docs/javadoc/org/mases/datadistributionmanager/configuration/package-tree.html index 5ae6d45f..52648d98 100644 --- a/docs/javadoc/org/mases/datadistributionmanager/configuration/package-tree.html +++ b/docs/javadoc/org/mases/datadistributionmanager/configuration/package-tree.html @@ -80,6 +80,7 @@

    Class Hierarchy

  • org.mases.datadistributionmanager.configuration.KafkaChannelConfiguration
    • +
  • org.mases.datadistributionmanager.configuration.MastershipConfiguration
  • org.mases.datadistributionmanager.configuration.OpenDDSConfiguration
    • +
  • org.mases.datadistributionmanager.configuration.MastershipConfiguration
  • org.mases.datadistributionmanager.configuration.OpenDDSConfiguration