fix messege-count calculation error (#127)
authorJermy Li <lizhangmei@baidu.com>
Mon, 25 Oct 2021 11:24:27 +0000 (19:24 +0800)
committerGitHub <noreply@github.com>
Mon, 25 Oct 2021 11:24:27 +0000 (19:24 +0800)
commitdca01ebb3aefa2ece6b0b2921b15e27e7a740af1
treebba870990a23c79ca765266c4e2eded7561fa8cc
parentac77810b5cd10497f59478511912f269a5c21ac3
fix messege-count calculation error (#127)
22 files changed:
computer-algorithm/src/main/java/com/baidu/hugegraph/computer/algorithm/community/lpa/Lpa.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/master/MasterComputationContext.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStat.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStat.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartitions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageStat.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/RecvMessageStat.java with 73% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffer.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffers.java
computer-test/src/main/java/com/baidu/hugegraph/computer/algorithm/AlgorithmTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/bsp/EtcdBspTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStatTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStatTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/CsvStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/JsonStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerStatTest.java