5875
49%
develop: 49%

Ran 10 Jan 2022 12:51PM UTC

Jobs 1

Files 679

Run time 2min

Badge

Embed ▾

pending completion

Build # 5875

Build Type

push

travis-ci-com

Committed by GitHub

Commit Message

[ISSUE #3708] add CorrectLogicOffsetService to periodically correct min logic offset (#3722)

* [ISSUE #3708] add CorrectLogicOffsetService to periodically correct min logic offset; refactor QueueOffsetAssigner.

* Mock getDiskSpaceWarningLevelRatio and getDiskSpaceCleanForciblyRatio to get around configuration protection in unit-test.

* Fix check style.

Run Details

88 of 88 new or added lines in 6 files covered. (100.0%)

22461 of 42729 relevant lines covered (52.57%)

0.53 hits per line

New Missed Lines in Diff

Lines	Coverage	File
1	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
2	100.0	store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetAssigner.java
38	100.0	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java

Uncovered Existing Lines

Lines	Coverage	File
1	100.0	store/src/main/java/org/apache/rocketmq/store/MessageStore.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
2	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
2	100.0	client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
2	100.0	store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java
3	100.0	acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionManager.java
3	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
3	100.0	store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java
3	100.0	store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java
4	100.0	filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java
12	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
12	100.0	store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java
13	100.0	store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
13	100.0	store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
14	100.0	store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java
21	100.0	acl/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java
21	100.0	store/src/main/java/org/apache/rocketmq/store/StoreUtil.java
23	100.0	common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
24	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
25	100.0	store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
28	100.0	store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
37	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
42	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
46	100.0	store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
47	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
56	100.0	store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
59	100.0	client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
63	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java
67	100.0	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
67	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java
70	100.0	common/src/main/java/org/apache/rocketmq/common/UtilAll.java
71	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
76	100.0	store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
80	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
85	100.0	client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
87	100.0	store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
90	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
132	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
155	100.0	store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
161	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
212	100.0	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
236	100.0	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
396	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
401	100.0	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java

Jobs

ID	Job ID	Ran	Files	Coverage
1	5875.1	10 Jan 2022 12:51PM UTC	0	52.57	Travis Job 5875.1

apache / rocketmq / 5875
49%
develop: 49%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 5875

apache / rocketmq / 5875 49% develop: 49%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 5875

apache / rocketmq / 5875
49%
develop: 49%

README BADGES
x