This is an automated email from the ASF dual-hosted git repository.
jxue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git
from 792f21162 [apache/helix] -- Fixes #2590 Removed resetting of the
missingTopStatePartitionsBeyondThresholdGauge to avoid incorrect accounting.
new ff4c5cadd DataRecord Serializer
new df1eb6ae9 Inline
new b93f89a06 tests for get, create, set, update, and data change listeners
new 1f80503b6 deserialize test
new b45361ba3 refactor, update with dataRecord
new 17f8ab3fd set test iteration count to 500
new 09649b34c [helix/metaclient] ZkMetaClient Stress Tests (Part 2) (#2523)
new 0e917599c MetaClient Distributed Semaphore API and Permit object
(#2520)
new 53f9fa7c3 Add API for getDataAndStat (#2535)
new c7a0d28fc Lattice MetaClient Distributed Semaphore Implementation
(#2515)
new f41a2c606 MetaClient LockClient and Semaphore Creation Edge Cases and
Added Exception(#2550)
new 6aa7c2cce ZkClient - only register one time watcher for read data when
not using persist listener. (#2555)
new 5389b1739 MultiThreading Stress Test Lattice - Puppy Logic and
Skeleton (Part 1) (#2549)
new 36231faeb Metaclient leader election - basics (#2558)
new b1f59e6f8 Multithreading stress test lattice - CRUD puppies and
Listener Tests (#2548)
new 52fe73818 Metaclient - Leader election - Track participants and add
participant info (#2562)
new 4eacde331 Metaclient - Leader election - leader change event
notification (#2560)
new 26f319608 Lattice LockClient LockInfoSerializer Implementation(#2580)
new c3afa7f27 Lattice Puppy Stress Test Race Condition Fix and Code
Cleanup (#2579)
new 7a96d9ba8 Add stress test for Metaclient leader election (#2574)
new 2e53694f7 Leader election client - Proactively send leader gone event
when disconnect from ZK (#2585)
The 21 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../helix/metaclient/api/MetaClientInterface.java | 19 +-
.../org/apache/helix/metaclient/api/OpResult.java | 2 +-
.../helix/metaclient/datamodel/DataRecord.java | 5 +
...ion.java => MetaClientNodeExistsException.java} | 11 +-
.../helix/metaclient/impl/zk/ZkMetaClient.java | 73 ++--
.../impl/zk/adapter/DataListenerAdapter.java | 1 +
.../metaclient/impl/zk/util/ZkMetaClientUtil.java | 12 +
.../leaderelection/LeaderElectionClient.java | 318 ++++++++++++--
.../LeaderElectionListenerInterface.java | 15 +-
.../LeaderElectionListenerInterfaceAdapter.java | 64 +++
.../recipes/leaderelection/LeaderInfo.java | 34 +-
.../leaderelection/LeaderInfoSerializer.java | 42 ++
.../recipes/lock/DataRecordSerializer.java | 19 +-
.../recipes/lock/DistributedSemaphore.java | 248 +++++++++++
.../helix/metaclient/recipes/lock/LockClient.java | 19 +-
.../helix/metaclient/recipes/lock/LockInfo.java | 30 +-
.../recipes/lock/LockInfoSerializer.java | 26 +-
.../helix/metaclient/recipes/lock/Permit.java | 87 ++++
.../helix/metaclient/MetaClientTestUtil.java | 25 ++
.../zk/TestConnectStateChangeListenerAndRetry.java | 42 +-
.../zk/TestMultiThreadStressTest/CreatePuppy.java | 77 ++++
.../zk/TestMultiThreadStressTest/DeletePuppy.java | 67 +++
.../zk/TestMultiThreadStressTest/GetPuppy.java | 67 +++
.../zk/TestMultiThreadStressTest/SetPuppy.java | 70 ++++
.../TestMultiThreadStressZKClient.java | 350 ++++++++++++++++
.../zk/TestMultiThreadStressTest/UpdatePuppy.java | 73 ++++
.../metaclient/impl/zk/TestStressZkClient.java | 455 ++++++++++++++++++++-
.../apache/helix/metaclient/impl/zk/TestUtil.java | 92 +++++
.../helix/metaclient/impl/zk/TestZkMetaClient.java | 50 +++
.../metaclient/impl/zk/ZkMetaClientTestBase.java | 2 +
.../helix/metaclient/puppy/AbstractPuppy.java | 91 +++++
.../apache/helix/metaclient/puppy/ExecDelay.java | 63 +++
.../helix/metaclient/puppy/PuppyManager.java | 64 +++
.../apache/helix/metaclient/puppy/PuppyMode.java | 10 +-
.../apache/helix/metaclient/puppy/PuppySpec.java | 42 +-
.../leaderelection/LeaderElectionPuppy.java | 92 +++++
.../recipes/leaderelection/TestLeaderElection.java | 361 ++++++++++++++++
.../TestMultiClientLeaderElection.java | 85 ++++
.../recipes/lock/DistributedSemaphoreTest.java | 105 +++++
.../metaclient/recipes/lock/LockClientTest.java | 36 +-
.../datamodel/serializer/ZNRecordSerializer.java | 2 +-
.../apache/helix/zookeeper/zkclient/ZkClient.java | 2 +-
.../zkclient/TestZkClientPersistWatcher.java | 75 ++--
43 files changed, 3184 insertions(+), 239 deletions(-)
copy
meta-client/src/main/java/org/apache/helix/metaclient/exception/{MetaClientTimeoutException.java
=> MetaClientNodeExistsException.java} (75%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionListenerInterfaceAdapter.java
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderInfoSerializer.java
copy
helix-core/src/main/java/org/apache/helix/healthcheck/ParticipantHealthReportCollector.java
=>
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/DataRecordSerializer.java
(70%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/DistributedSemaphore.java
copy
helix-core/src/main/java/org/apache/helix/store/ZNRecordJsonSerializer.java =>
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/LockInfoSerializer.java
(60%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/Permit.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/MetaClientTestUtil.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/CreatePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/DeletePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/GetPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/SetPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/TestMultiThreadStressZKClient.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/UpdatePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/AbstractPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/ExecDelay.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppyManager.java
copy
helix-core/src/main/java/org/apache/helix/controller/stages/package-info.java
=> meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppyMode.java
(86%)
copy
helix-core/src/main/java/org/apache/helix/monitoring/StateTransitionDataPoint.java
=> meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppySpec.java
(54%)
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/TestLeaderElection.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/TestMultiClientLeaderElection.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/lock/DistributedSemaphoreTest.java
