Clone Tools
  • last updated a few minutes ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates
ISPN-11685 Update to RxJava 3.0

    • -6
    • +9
    ./impl/ScatteredStateConsumerImpl.java
    • -1
    • +1
    ./impl/ScatteredStateProviderImpl.java
    • -12
    • +13
    ./impl/ScatteredVersionManagerImpl.java
  1. … 135 more files in changeset.
ISPN-11378 Split StateRequestCommand into individual commands

    • -4
    • +2
    ./impl/ScatteredStateConsumerImpl.java
  1. … 36 more files in changeset.
ISPN-11271 Convert async transport executor to the non blocking thread pool

    • -3
    • +3
    ./impl/ScatteredVersionManagerImpl.java
  1. … 54 more files in changeset.
ISPN-10362 Unify command initialization and invocation

Deprecate and remove usages of CommandsFactory::initializeReplicableCommand

    • -2
    • +1
    ./impl/ScatteredVersionManagerImpl.java
  1. … 116 more files in changeset.
ISPN-11109 Deprecate and remove usages of state transfer executor

    • -5
    • +0
    ./impl/ScatteredStateConsumerImpl.java
    • -35
    • +33
    ./impl/ScatteredVersionManagerImpl.java
  1. … 23 more files in changeset.
ISPN-10310 Make StateConsumerImpl non-blocking

    • -22
    • +25
    ./impl/ScatteredStateConsumerImpl.java
  1. … 18 more files in changeset.
ISPN-10984 Scattered cache distributed streams stack overflow

With awaitInitialTransfer disabled, publisher requests can arrive

during the initial state transfer, and in scattered caches

they would fail with StackOverflowError.

Publisher requests will still block for the initial transfer to end

because of ISPN-10864.

Add reproducer and reduce the number of entries in other

DistributedStreamIteratorTest methods.

    • -2
    • +8
    ./impl/ScatteredVersionManagerImpl.java
  1. … 4 more files in changeset.
ISPN-10984 Scattered cache distributed streams stack overflow

With awaitInitialTransfer disabled, publisher requests can arrive

during the initial state transfer, and in scattered caches

they would fail with StackOverflowError.

Publisher requests will still block for the initial transfer to end

because of ISPN-10864.

Add reproducer and reduce the number of entries in other

DistributedStreamIteratorTest methods.

    • -2
    • +8
    ./impl/ScatteredVersionManagerImpl.java
  1. … 4 more files in changeset.
ISPN-10947 Add checkstyle to prevent invoking blocking methods from Flowable

    • -22
    • +26
    ./impl/ScatteredStateConsumerImpl.java
    • -2
    • +5
    ./impl/ScatteredVersionManagerImpl.java
  1. … 12 more files in changeset.
ISPN-10744 Remove deprecated DataContainer methods

    • -4
    • +1
    ./impl/ScatteredStateConsumerImpl.java
  1. … 23 more files in changeset.
ISPN-10018 Coarse-grained logging categories

* Add categories for CONFIG, PERSISTENCE, SECURITY, CONTAINER

* Send all messages with log level >= INFO to the above

    • -1
    • +3
    ./impl/ScatteredPartitionHandlingManagerImpl.java
    • -1
    • +2
    ./impl/ScatteredStateConsumerImpl.java
  1. … 173 more files in changeset.
ISPN-10310 State provider should not block while sending state

    • -36
    • +34
    ./impl/ScatteredStateConsumerImpl.java
    • -41
    • +68
    ./impl/ScatteredStateProviderImpl.java
  1. … 28 more files in changeset.
ISPN-10137 Add missing @Scope and @SurvivesRestarts

* @Scope is required on each component class, except when inherited

from superclass (interfaces don't count)

* @SurvivesRestarts must be duplicated on all subclasses

or implementing classes

    • -0
    • +3
    ./impl/ScatteredVersionManagerImpl.java
  1. … 135 more files in changeset.
ISPN-10137 Make injected fields and methods package-private

    • -10
    • +10
    ./impl/ScatteredVersionManagerImpl.java
  1. … 183 more files in changeset.
ISPN-10322 Create unified interface for initializing commands

    • -1
    • +1
    ./impl/ScatteredVersionManagerImpl.java
  1. … 79 more files in changeset.
ISPN-4075 State transfer should preserve the timestamps of entries

Use InternalMetadataImpl to store the timestamps instead of an

InternalCacheEntry in PutKeyValueCommand.

    • -2
    • +6
    ./impl/ScatteredStateConsumerImpl.java
  1. … 6 more files in changeset.
ISPN-4075 State transfer should preserve the timestamps of entries

Use InternalMetadataImpl to store the timestamps instead of an

InternalCacheEntry in PutKeyValueCommand.

    • -2
    • +6
    ./impl/ScatteredStateConsumerImpl.java
  1. … 7 more files in changeset.
ISPN-9845 Stop exposing InternalMetadata via the persistence SPI

    • -2
    • +2
    ./impl/ScatteredStateConsumerImpl.java
    • -2
    • +1
    ./impl/ScatteredStateProviderImpl.java
  1. … 79 more files in changeset.
ISPN-9846 Ensure Backwards Compatibility with Persistence SPI changes

Rename persistence.spi.MarshalledEntry to MarshallableEntry

MarshalledEntry and MarshalledEntryFactory methods in the spi deprecated

and default methods added for backwards-compatibility.

    • -23
    • +22
    ./impl/ScatteredStateConsumerImpl.java
    • -2
    • +2
    ./impl/ScatteredVersionManagerImpl.java
  1. … 144 more files in changeset.
ISPN-4075 State transfer should preserve the timestamps of entries

* Use PutKeyValueCommand with InternalCacheEntry as value to pass the

created and last use timestamps

* Scattered caches also use PutMapCommand with InternalCacheValue values

* Always copy the timestamps when copying entries

* Ignore -1 timestamp values and use current time instead

    • -1
    • +1
    ./impl/ScatteredStateConsumerImpl.java
  1. … 15 more files in changeset.
ISPN-4075 State transfer should preserve the timestamps of entries

* Use PutKeyValueCommand with InternalCacheEntry as value to pass the

created and last use timestamps

* Scattered caches also use PutMapCommand with InternalCacheValue values

* Always copy the timestamps when copying entries

* Ignore -1 timestamp values and use current time instead

    • -1
    • +1
    ./impl/ScatteredStateConsumerImpl.java
  1. … 15 more files in changeset.
ISPN-7889 BaseDistributionInterceptor.remoteGet may cause concurrency issues

* Rename remoteGet to remoteGetSingleKey and use it only for single-key

commands.

* Rename remoteGetAll to remoteGetMany and use it for all multi-key

commands.

* Throw OutdatedTopologyException.RETRY_SAME_TOPOLOGY after receiving

only UnsureResponses and RETRY_NEXT_TOPOLOGY if there was at least one

CacheNotFoundResponse (and no valid response).

* Make remote scattered reads wait for the right topology

* Improve support for PartitionHandling.ALLOW_READS in scattered caches.

* Make partition availability checks more readable.

* Add asynchronous methods in ControlledRpcManager

    • -5
    • +41
    ./impl/ScatteredPartitionHandlingManagerImpl.java
  1. … 44 more files in changeset.
ISPN-7889 BaseDistributionInterceptor.remoteGet may cause concurrency issues

* Rename remoteGet to remoteGetSingleKey and use it only for single-key

commands.

* Rename remoteGetAll to remoteGetMany and use it for all multi-key

commands.

* Throw OutdatedTopologyException.RETRY_SAME_TOPOLOGY after receiving

only UnsureResponses and RETRY_NEXT_TOPOLOGY if there was at least one

CacheNotFoundResponse (and no valid response).

* Make remote scattered reads wait for the right topology

* Improve support for PartitionHandling.ALLOW_READS in scattered caches.

* Make partition availability checks more readable.

* Add asynchronous methods in ControlledRpcManager

    • -5
    • +41
    ./impl/ScatteredPartitionHandlingManagerImpl.java
  1. … 44 more files in changeset.
ISPN-9693 Move MarshalledEntry and MarshalledEntryFactory to the persistence spi package

    • -1
    • +1
    ./impl/ScatteredVersionManagerImpl.java
  1. … 135 more files in changeset.
ISPN-3791 Silence "ISPN000210: Failed to request state of cache X from node Y" exceptions

Losing the state transfer source is not a problem.

Not having a backup source is a problem, but it is logged separately.

    • -0
    • +3
    ./impl/ScatteredStateConsumerImpl.java
  1. … 1 more file in changeset.
ISPN-9127 Component registry

Introduce BasicComponentRegistry, which handles dependency injection but

doesn't have any logic specific to caches or managers.

Each component has its own lifecycle status, and starting a component

also starts its dependencies. Components can start in parallel.

ComponentRegistry and GlobalComponentRegistry still need to maintain

their own lifecycle status, but it is now possible to start a cache

before all the global components have finished starting.

    • -2
    • +2
    ./impl/ScatteredStateConsumerImpl.java
  1. … 244 more files in changeset.
ISPN-9209 Move TimeService to infinispan-commons

  1. … 138 more files in changeset.
ISPN-9621 Marshallers separated into Persistence and Internal marshaller.

PersistenceMarshaller created based upon ProtoStream. Internal

persistence classes are marshalled using the protostream marshallers

and schema generated by protostream-processor.

The GlobalMarshaller still utilises the same IDs as before for

marshalling internal classes between nodes, but delegates to the

persistence marshaller for marshalling persistence and user classes.

ISPN-7409 user objects are marshalled via the marshaller specified in

SerializationConfiguration and the resulting bytes are wrapped in a

UserObject message. The default marshaller is the JBossMarshaller

with just the user configured external externalizers loaded.

ISPN-9624 StreamingMarshaller interface has been deprecated for external use and

has been replaced with the simplified StreamAwareMarshaller interface.

    • -2
    • +2
    ./impl/ScatteredStateConsumerImpl.java
    • -2
    • +2
    ./impl/ScatteredStateProviderImpl.java
    • -6
    • +6
    ./impl/ScatteredVersionManagerImpl.java
  1. … 176 more files in changeset.
Revert "ISPN-9128 RehashWithSharedStoreTest.testRehashes random failures"

This reverts commit f8531b42313ad957a699813cae18d19690f49fd2.

    • -5
    • +0
    ./impl/ScatteredStateConsumerImpl.java
  1. … 13 more files in changeset.
ISPN-8852 FORCE_WRITE_LOCK should cause AvailabilityException in DEGRADED partition

    • -2
    • +2
    ./impl/ScatteredPartitionHandlingManagerImpl.java
  1. … 8 more files in changeset.