[
https://issues.apache.org/jira/browse/IGNITE-19993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vyacheslav Koptilin updated IGNITE-19993:
-----------------------------------------
Labels: ignite-3 (was: )
> Reduce sending safe time command
> --------------------------------
>
> Key: IGNITE-19993
> URL: https://issues.apache.org/jira/browse/IGNITE-19993
> Project: Ignite
> Issue Type: Improvement
> Reporter: Vladislav Pyatkov
> Priority: Major
> Labels: ignite-3
>
> *Motivation*
> Safe time propagation is based on messages that are sent at a particular
> interval. A safe-time direct message is less expensive than a command. The
> prpouse of the algorith is reduce sending command to propage safe time.
> *Implementation notes*
> * Send safe time command by the following rule:
> {code}
> If (tSend == null) {
> // Nothing was sent at this lease interval
> sendSafeTimePropagatingCommand(tCurrent)
> } else if (tCurrent - stFreq < tSend && tCurrent - stFreq > tSuc) {
> // An operation was performed in a previous stFreq interval, but it was not
> a success
> sendSafeTimePropagatingCommand(tCurrent)
> if (tSend < tCurrent)
> sendSafeTimePropagatingMessage(tSend, tCurrent)
> } else if (tCurrent - stFreq > tSend && tSend != tSuc) {
> // The last command was unsuccessful
> sendSafeTimePropagatingCommand(tCurrent)
> if (tSend < tCurrent)
> sendSafeTimePropagatingMessage(tSend, tCurrent)
> } else if (tSend < tCurrent) {
> // It is not necessary to send a safe time due to the fact that is moving
> with load
> sendSafeTimePropagatingMessage(tSend, tCurrent)
> }
> {code}
> * Do not send the safe time command if the private one is not completed yet.
> *Difinition of done*
> Safe time propagates through messages in regular load. The safe time command
> is used only in the specific cases described above.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
