7861
49%

Ran 16 Aug 2022 05:15AM UTC

Jobs 2

Files 1107

Run time 3min

Badge

Embed ▾

pending completion

Build # 7861

Build Type

cron

travis-ci-com

Committed by GitHub

Commit Message

[ISSUE #4813] Add elect policy for controller (#4809)

* feat(controller): add elect policy

1. add epoch and maxOffset in heartbeat.
2. refactor elect logic, now we
elect a new master by elect policy(can expand).
3. add some unit tests

* refactor(controller): refactor some code and format some code

1. refactor some code and format some code

* fix typo in ReplicasInfoManager

1. fix typo in ReplicasInfoManager

* fix wrong method call in ReplicasManagerTest#before

1.fix wrong method call in ReplicasManagerTest#before

* fix wrong call in ReplicasManagerTest#before

1. fix wrong call in ReplicasManagerTest#before

* fix(controller): fix the bug about ReElectMaster

1. fix the bug about ReElectMaster
2. fix some typo

* style(controller): fix typo by checkstyle

1. fix typo by checkstyle

* test(broker): fix invalid usage of "any()" in DLedegerControllerTest#before

1. fix invalid usage of "any()" in DLedegerControllerTest#before

* fix(controller): fix some wrong usage in test

1. fix some wrong usage in test
2. refactor some field type to avoid NPE

Run Details

204 of 204 new or added lines in 13 files covered. (100.0%)

33457 of 68234 relevant lines covered (49.03%)

0.98 hits per line

New Missed Lines in Diff

Lines	Coverage	∆	File
1	76.22	0.0%	controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
1	60.61	0.0%	store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
2	54.59	0.0%	broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java
2	86.96	0.0%	controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java
3	55.71	-2.73%	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
5	73.61	0.0%	controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java
6	83.33	0.0%	controller/src/main/java/org/apache/rocketmq/controller/elect/impl/DefaultElectPolicy.java
7	85.06	-2.3%	controller/src/main/java/org/apache/rocketmq/controller/impl/DefaultBrokerHeartbeatManager.java
9	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java
10	21.99	0.0%	broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
13	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/RegisterBrokerToControllerRequestHeader.java
19	53.66	0.0%	controller/src/main/java/org/apache/rocketmq/controller/BrokerLiveInfo.java

Uncovered Existing Lines

Lines	Coverage	∆	File
1	76.24	-0.99%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
1	53.1	-0.24%	broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
1	61.4	-0.35%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
1	44.62	-0.13%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
1	72.6	-1.37%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
1	60.61	0.0%	store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
2	84.38	-6.25%	store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java
4	85.06	-2.3%	controller/src/main/java/org/apache/rocketmq/controller/impl/DefaultBrokerHeartbeatManager.java
8	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java
9	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/RegisterBrokerToControllerRequestHeader.java
10	86.96	0.0%	controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java
17	30.43	0.0%	controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
22	73.61	0.0%	controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java
36	76.22	0.0%	controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
69	54.59	0.0%	broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java
146	55.71	-2.73%	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
152	21.99	0.0%	broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java

Jobs

ID	Job ID	Ran	Files	Coverage
1	7861.1	16 Aug 2022 05:15AM UTC	1107	49.03	Travis Job 7861.1
2	7861.2	16 Aug 2022 05:17AM UTC	1107	49.12	Travis Job 7861.2

apache / rocketmq / 7861
49%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7861

apache / rocketmq / 7861 49%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7861

apache / rocketmq / 7861
49%

README BADGES
x