You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by he...@apache.org on 2022/02/15 02:08:07 UTC

[incubator-inlong] branch master updated (0ac5ac5 -> 1c891db)

This is an automated email from the ASF dual-hosted git repository.

healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from 0ac5ac5  [INLONG-2377] DataProxy support PB compression protocol format source. (#2395)
     add 1c891db  [INLONG-2488][TubeMQ] Optimize MsgFileStatisInfo implementation logic (#2495)

No new revisions were added by this update.

Summary of changes:
 .../server/broker/msgstore/MessageStore.java       |  73 ++++--
 .../broker/msgstore/disk/MsgFileStatisInfo.java    | 180 -------------
 .../server/broker/msgstore/disk/MsgFileStore.java  |  79 +++---
 .../server/broker/msgstore/mem/MsgMemStore.java    |  36 ++-
 ...eStatsHolder.java => FileStoreStatsHolder.java} | 285 +++++++++++----------
 .../server/broker/stats/MemStoreStatsHolder.java   |  19 +-
 .../server/broker/web/BrokerAdminServlet.java      |   9 +-
 .../broker/stats/FileStoreStatsHolderTest.java     | 128 +++++++++
 .../broker/stats/MemStoreStatsHolderTest.java      |   4 +-
 9 files changed, 415 insertions(+), 398 deletions(-)
 delete mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/MsgFileStatisInfo.java
 copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/stats/{MemStoreStatsHolder.java => FileStoreStatsHolder.java} (51%)
 create mode 100644 inlong-tubemq/tubemq-server/src/test/java/org/apache/inlong/tubemq/server/broker/stats/FileStoreStatsHolderTest.java