apache / rocketmq / 7481
48%
develop: 49%

LAST BUILD BRANCH: 4.9.x
DEFAULT BRANCH: develop
Ran
Jobs 2
Files 970
Run time 2min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
7481

Pull #4484

travis-ci-com

RongtongJin 
Change the loading order of HAService
Pull Request #4484: [RIP-44] Support DLedger Controller

3003 of 3003 new or added lines in 67 files covered. (100.0%)

28883 of 60515 relevant lines covered (47.73%)

0.96 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
100.0
 common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
1
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/AlterSyncStateSetEvent.java
1
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/ApplyBrokerIdEvent.java
1
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/ElectMasterEvent.java
1
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
2
100.0
 container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java
2
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerControllerStateMachine.java
2
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/manager/BrokerInfo.java
2
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java
2
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
3
100.0
 container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java
3
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventSerializer.java
3
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventType.java
3
100.0
 store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
4
100.0
 controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java
4
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/io/AbstractHAReader.java
5
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java
6
100.0
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java
6
100.0
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
6
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/io/HAWriter.java
7
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
7
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/AlterSyncStateSetResponseHeader.java
8
100.0
 container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
8
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/event/ControllerResult.java
9
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/DefaultBrokerHeartbeatManager.java
10
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/ElectMasterRequestHeader.java
10
100.0
 controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java
11
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/SyncStateSet.java
14
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/GetReplicaInfoResponseHeader.java
15
100.0
 common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
15
100.0
 common/src/main/java/org/apache/rocketmq/common/utils/FastJsonSerializer.java
16
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/ElectMasterResponseHeader.java
16
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/RegisterBrokerToControllerResponseHeader.java
17
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/GetReplicaInfoRequestHeader.java
18
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/AlterSyncStateSetRequestHeader.java
19
100.0
 controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
19
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java
20
100.0
 common/src/main/java/org/apache/rocketmq/common/EpochEntry.java
21
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
21
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/RegisterBrokerToControllerRequestHeader.java
22
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyBrokerRoleChangedRequestHeader.java
23
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/EpochEntryCache.java
24
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
24
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataCommand.java
25
100.0
 common/src/main/java/org/apache/rocketmq/common/BrokerAddrInfo.java
26
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/GetMetaDataResponseHeader.java
37
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/InSyncStateData.java
40
100.0
 common/src/main/java/org/apache/rocketmq/common/utils/CheckpointFile.java
42
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
42
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java
47
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
48
100.0
 namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
49
100.0
 broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
52
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochCommand.java
54
100.0
 common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java
58
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java
59
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java
61
100.0
 controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java
72
100.0
 controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java
77
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
221
100.0
 broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
1
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
1
100.0
 common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java
1
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
2
100.0
 broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
2
100.0
 store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java
3
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
3
100.0
 namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
4
100.0
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
5
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
6
100.0
 common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java
12
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
13
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
14
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java
16
100.0
 namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
17
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
Jobs
ID Job ID Ran Files Coverage
1 7481.1 0
47.73
 Travis Job 7481.1
2 7481.2 0
47.95
 Travis Job 7481.2
Source Files on build 7481