Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
ISPN-12177 Persist IRAC version during shutdown
- Loading branch information
Showing
33 changed files
with
946 additions
and
195 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
92 changes: 92 additions & 0 deletions
92
core/src/main/java/org/infinispan/commands/irac/IracUpdateVersionCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,92 @@ | ||
| package org.infinispan.commands.irac; | ||
|
|
||
| import java.io.DataInput; | ||
| import java.io.DataOutput; | ||
| import java.io.IOException; | ||
| import java.io.ObjectInput; | ||
| import java.io.ObjectOutput; | ||
| import java.util.HashMap; | ||
| import java.util.Map; | ||
| import java.util.concurrent.CompletionStage; | ||
|
|
||
| import org.infinispan.commands.remote.CacheRpcCommand; | ||
| import org.infinispan.commons.marshall.MarshallUtil; | ||
| import org.infinispan.container.versioning.irac.IracEntryVersion; | ||
| import org.infinispan.container.versioning.irac.IracVersionGenerator; | ||
| import org.infinispan.factories.ComponentRegistry; | ||
| import org.infinispan.remoting.transport.Address; | ||
| import org.infinispan.util.ByteString; | ||
| import org.infinispan.util.concurrent.CompletableFutures; | ||
|
|
||
| /** | ||
| * It transfers the current versions stored in {@link IracVersionGenerator} to the other nodes when joins/leaving events | ||
| * occurs. | ||
| * | ||
| * @author Pedro Ruivo | ||
| * @since 12.0 | ||
| */ | ||
| public class IracUpdateVersionCommand implements CacheRpcCommand { | ||
| public static final byte COMMAND_ID = 32; | ||
| private final ByteString cacheName; | ||
| private Map<Integer, IracEntryVersion> versions; | ||
|
|
||
| public IracUpdateVersionCommand() { | ||
| this(null); | ||
| } | ||
|
|
||
| public IracUpdateVersionCommand(ByteString cacheName) { | ||
| this.cacheName = cacheName; | ||
| } | ||
|
|
||
| public IracUpdateVersionCommand(ByteString cacheName, Map<Integer, IracEntryVersion> segmentsVersion) { | ||
| this(cacheName); | ||
| this.versions = segmentsVersion; | ||
| } | ||
|
|
||
| @Override | ||
| public CompletionStage<?> invokeAsync(ComponentRegistry registry) throws Throwable { | ||
| IracVersionGenerator versionGenerator = registry.getIracVersionGenerator().running(); | ||
| versions.forEach(versionGenerator::updateVersion); | ||
| return CompletableFutures.completedNull(); | ||
| } | ||
|
|
||
| @Override | ||
| public ByteString getCacheName() { | ||
| return cacheName; | ||
| } | ||
|
|
||
| @Override | ||
| public byte getCommandId() { | ||
| return COMMAND_ID; | ||
| } | ||
|
|
||
| @Override | ||
| public boolean isReturnValueExpected() { | ||
| return false; | ||
| } | ||
|
|
||
| @Override | ||
| public Address getOrigin() { | ||
| //no-op, not required. | ||
| return null; | ||
| } | ||
|
|
||
| @Override | ||
| public void setOrigin(Address origin) { | ||
| //no-op, not required. | ||
| } | ||
|
|
||
| @Override | ||
| public void writeTo(ObjectOutput output) throws IOException { | ||
| MarshallUtil.marshallMap(versions, DataOutput::writeInt, ObjectOutput::writeObject, output); | ||
| } | ||
|
|
||
| @Override | ||
| public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException { | ||
| versions = MarshallUtil.unmarshallMap(input, DataInput::readInt, IracUpdateVersionCommand::read, HashMap::new); | ||
| } | ||
|
|
||
| private static IracEntryVersion read(ObjectInput input) throws IOException, ClassNotFoundException { | ||
| return (IracEntryVersion) input.readObject(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.