apache / rocketmq / 7475
48%
develop: 49%

LAST BUILD BRANCH: 4.9.x
DEFAULT BRANCH: develop
Ran
Jobs 2
Files 920
Run time 51s
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
7475

Pull #4592

travis-ci-com

Oliver 
setFile() add synchronized
Pull Request #4592: [ISSUE #4591] Add synchronized

27542 of 57654 relevant lines covered (47.77%)

0.95 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
0.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
1
63.64
 -6.36% broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStorePluginContext.java
1
90.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/transaction/OperationResult.java
1
84.0
 -0.57% broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
1
95.0
 -5.0% broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java
1
90.91
 -9.09% common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java
1
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteSubscriptionGroupRequestHeader.java
1
52.17
 -2.17% common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java
1
50.0
 -2.38% common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java
1
72.53
 -1.1% filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilter.java
1
14.81
 0.66% remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java
1
94.55
 -1.82% store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java
1
0.0
 0.0% store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java
2
21.43
 -1.65% broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
2
87.5
 0.0% client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
2
87.5
 -1.39% client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java
2
45.24
 1.34% client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java
2
84.62
 -15.38% common/src/main/java/org/apache/rocketmq/common/protocol/body/CheckClientRequestBody.java
2
83.33
 -5.56% remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java
2
0.0
 0.0% store/src/main/java/org/apache/rocketmq/store/MessageStore.java
2
96.15
 0.0% store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java
3
80.0
 -13.33% client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
3
72.6
 -2.4% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
3
33.33
 13.33% common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
3
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java
3
63.64
 -6.36% store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java
3
77.78
 -3.47% store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java
4
55.56
 -4.44% broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java
4
73.33
 -16.67% client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
4
70.09
 -3.42% filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java
4
80.77
 2.2% store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java
4
0.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/SubCommandException.java
5
19.23
 -4.58% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java
6
24.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
6
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java
6
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
6
80.0
 0.69% logging/src/main/java/org/apache/rocketmq/logging/InternalLoggerFactory.java
6
89.66
 -2.5% store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java
7
65.54
 0.2% broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
7
69.39
 -4.53% client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/message/MessageExtBatch.java
7
70.83
 -29.17% common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
8
0.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
8
75.61
 -2.77% broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
8
67.57
 -8.19% common/src/main/java/org/apache/rocketmq/common/ConfigManager.java
8
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java
8
55.56
 -44.44% common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java
8
83.67
 -8.83% remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java
8
0.0
 0.0% test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java
9
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/message/MessageType.java
10
27.78
 -10.68% client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
10
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java
10
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/body/UnlockBatchRequestBody.java
10
62.0
 1.13% tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java
11
90.78
 20.19% broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
11
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/constant/PermName.java
11
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java
11
47.83
 -27.17% store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java
12
27.78
 -3.47% broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
12
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
12
70.0
 6.0% store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java
12
56.0
 -4.0% tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java
14
67.27
 -6.73% common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java
14
85.32
 -5.98% common/src/main/java/org/apache/rocketmq/common/protocol/body/RegisterBrokerBody.java
14
46.15
 -0.72% common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
14
72.84
 2.69% store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java
15
85.09
 -0.37% store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
15
0.0
 0.0% test/src/main/java/org/apache/rocketmq/test/factory/ConsumerFactory.java
16
79.28
 -1.8% client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
16
72.88
 1.14% store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
17
56.31
 -10.36% common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java
18
79.83
 -1.08% broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
18
24.32
 -3.15% remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java
19
69.57
 -4.12% broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
20
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
21
25.0
 -60.71% store/src/main/java/org/apache/rocketmq/store/StoreUtil.java
21
64.63
 -6.55% tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
22
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
22
52.73
 -6.85% common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java
22
0.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java
24
57.75
 1.98% logging/src/main/java/org/apache/rocketmq/logging/Slf4jLoggerFactory.java
24
23.08
 -0.61% namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
25
3.11
 0.0% broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
25
61.9
 15.75% common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java
25
0.0
 0.0% test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalProducer.java
26
83.23
 -3.1% acl/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java
26
50.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java
27
63.96
 6.69% broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
27
49.06
 -28.22% broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
27
53.85
 -21.71% client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
27
0.0
 0.0% test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQProducer.java
28
48.57
 9.44% broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java
28
62.63
 9.29% broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java
28
45.76
 -8.52% common/src/main/java/org/apache/rocketmq/common/DataVersion.java
29
7.14
 0.0% broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
30
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
30
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java
30
52.38
 4.17% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
30
32.38
 0.75% tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java
31
38.71
 -8.91% common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
33
45.0
 -1.88% common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
35
28.71
 -2.47% broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
37
66.67
 -5.91% namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
40
33.0
 0.78% broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
42
55.09
 -0.31% client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
43
77.97
 0.1% store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
44
20.79
 -3.3% broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
45
4.67
 -4.19% broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
45
45.37
 0.93% common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
45
64.66
 20.34% common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
47
33.33
 -0.6% client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
47
2.88
 0.0% client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
49
54.92
 -8.63% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java
49
67.0
 -0.2% store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
54
54.17
 -1.32% store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
54
0.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
55
86.97
 3.01% store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
56
39.29
 -23.01% common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
56
0.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java
59
0.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java
61
14.41
 -1.05% broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
61
75.0
 -2.66% remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
62
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
62
0.0
 0.0% tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java
63
58.29
 0.2% client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
66
8.33
 2.0% broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
66
61.75
 -0.22% client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
68
59.86
 1.46% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
70
31.88
 -0.97% common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerRunningInfo.java
73
35.76
 12.62% broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
73
54.3
 -0.29% common/src/main/java/org/apache/rocketmq/common/MixAll.java
73
71.04
 2.8% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
75
38.38
 -0.24% client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
75
48.17
 -10.8% client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java
80
56.35
 13.5% store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
83
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/Configuration.java
88
58.56
 -0.35% client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
91
78.92
 -1.08% client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
92
33.33
 -8.02% tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
93
77.63
 3.86% store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
94
4.93
 -0.16% client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
100
67.71
 -10.8% namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
104
71.25
 2.4% broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
104
0.0
 -34.23% tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
108
0.0
 0.0% broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
111
66.02
 -20.74% common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
113
12.27
 6.39% broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
116
52.4
 3.78% broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
123
60.89
 -8.31% store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
148
76.79
 -9.35% namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
154
51.85
 -28.15% store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
157
44.53
 -4.85% common/src/main/java/org/apache/rocketmq/common/UtilAll.java
160
54.51
 -1.43% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
183
44.07
 -5.93% broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
191
57.37
 -6.21% store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
196
34.42
 -16.04% broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
225
51.79
 -0.06% client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
238
37.95
 -12.45% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
245
55.33
 -3.7% client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
251
74.89
 -9.44% store/src/main/java/org/apache/rocketmq/store/CommitLog.java
283
25.49
 -28.63% broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
297
28.37
 -4.46% common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
357
60.85
 3.13% broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
361
44.75
 -10.53% client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
371
61.93
 -3.79% store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
498
30.31
 -14.97% tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
621
30.8
 13.99% client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
780
29.63
 -8.87% broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
Jobs
ID Job ID Ran Files Coverage
1 7475.1 920
47.6
 Travis Job 7475.1
2 7475.2 920
47.64
 Travis Job 7475.2
Source Files on build 7475