Class BaseDistributionInterceptor

    • Field Detail

      • expirationManager

        protected org.infinispan.expiration.impl.InternalExpirationManager<Object,​Object> expirationManager
      • isL1Enabled

        protected boolean isL1Enabled
      • isReplicated

        protected boolean isReplicated
    • Constructor Detail

      • BaseDistributionInterceptor

        public BaseDistributionInterceptor()
    • Method Detail

      • getLog

        protected org.infinispan.util.logging.Log getLog()
        Specified by:
        getLog in class org.infinispan.interceptors.impl.BaseRpcInterceptor
      • configure

        public void configure()
      • remoteGetSingleKey

        protected <C extends org.infinispan.commands.FlagAffectedCommand & org.infinispan.commands.TopologyAffectedCommand> CompletionStage<Void> remoteGetSingleKey​(InvocationContext ctx,
                                                                                                                                                                     C command,
                                                                                                                                                                     Object key,
                                                                                                                                                                     boolean isWrite)
        Fetch a key from its remote owners and store it in the context. Not thread-safe. The invocation context should not be accessed concurrently from multiple threads, so this method should only be used for single-key commands.
      • checkTopologyId

        protected LocalizedCacheTopology checkTopologyId​(org.infinispan.commands.TopologyAffectedCommand command)
      • remoteGetMany

        protected <C extends org.infinispan.commands.FlagAffectedCommand & org.infinispan.commands.TopologyAffectedCommand> CompletionStage<Void> remoteGetMany​(InvocationContext ctx,
                                                                                                                                                                C command,
                                                                                                                                                                Collection<?> keys)
      • handleRemotelyRetrievedKeys

        protected void handleRemotelyRetrievedKeys​(InvocationContext ctx,
                                                   org.infinispan.commands.write.WriteCommand appliedCommand,
                                                   List<?> remoteKeys)
      • remoteReadOnlyCommand

        protected org.infinispan.commands.functional.ReadOnlyKeyCommand remoteReadOnlyCommand​(InvocationContext ctx,
                                                                                              org.infinispan.commands.functional.ReadOnlyKeyCommand command)
      • wrapFunctionalResultOnNonOriginOnReturn

        protected Object wrapFunctionalResultOnNonOriginOnReturn​(Object rv,
                                                                 CacheEntry entry)
      • invokeRemotely

        protected Object invokeRemotely​(InvocationContext ctx,
                                        org.infinispan.commands.write.DataWriteCommand command,
                                        Address primaryOwner)
      • readNeedsRemoteValue

        protected boolean readNeedsRemoteValue​(org.infinispan.commands.FlagAffectedCommand command)
        Returns:
        true if the value is not available on the local node and a read command is allowed to fetch it from a remote node. Does not check if the value is already in the context.