> On July 8, 2013, 6:40 p.m., Avery Ching wrote: > > giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneToAllMessagesRequest.java, > > lines 138-142 > > <https://reviews.apache.org/r/12174/diff/2/?file=314698#file314698line138> > > > > Isn't this expensive to do the copy into a format that can be processed > > by the same code as the original send messages? Can't we avoid a buffer > > copy by directly deserializing and adding to the message store directly? > > Also, is this compatible with changing the message store between supersteps?
Due to the synchronization issue, currently this "formatting" is the most efficient way to put messages to the message store. > On July 8, 2013, 6:40 p.m., Avery Ching wrote: > > giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneToAllMessages.java, > > lines 105-121 > > <https://reviews.apache.org/r/12174/diff/2/?file=314702#file314702line105> > > > > I don't think these are necessary right? Your request has access to > > conf. createMessage is kepted because now message is created through messageValueFactory.createMessageValue() - Bingjing ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/12174/#review22838 ----------------------------------------------------------- On July 10, 2013, 9:12 p.m., Bingjing Zhang wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/12174/ > ----------------------------------------------------------- > > (Updated July 10, 2013, 9:12 p.m.) > > > Review request for giraph. > > > Bugs: GIRAPH-701 > https://issues.apache.org/jira/browse/GIRAPH-701 > > > Repository: giraph-git > > > Description > ------- > > Add "one-to-all" message sending strategy. > Now when sendMessageToAllEdges is invoked, Giraph may apply "one-to-all" > message sending strategy. > To enable it, use conf.enableOneToAllMsgSending() > > > Diffs > ----- > > giraph-core/src/main/java/org/apache/giraph/bsp/BspService.java ff3f06d > giraph-core/src/main/java/org/apache/giraph/comm/SendCache.java 92d0926 > giraph-core/src/main/java/org/apache/giraph/comm/SendMessageCache.java > 2eeac18 > giraph-core/src/main/java/org/apache/giraph/comm/SendMessageToAllCache.java > PRE-CREATION > giraph-core/src/main/java/org/apache/giraph/comm/ServerData.java a50f673 > > giraph-core/src/main/java/org/apache/giraph/comm/WorkerClientRequestProcessor.java > 89fb3e4 > > giraph-core/src/main/java/org/apache/giraph/comm/messages/OneMessagePerVertexStore.java > bedaf48 > > giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerClientRequestProcessor.java > 7ce0083 > giraph-core/src/main/java/org/apache/giraph/comm/requests/RequestType.java > 4129fb8 > > giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneToAllMessagesRequest.java > PRE-CREATION > giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java > 74f1ba5 > giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java > c4cc96f > giraph-core/src/main/java/org/apache/giraph/counters/GiraphStats.java > 3f25508 > giraph-core/src/main/java/org/apache/giraph/graph/Computation.java 87d5879 > giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java > a9bf3fd > giraph-core/src/main/java/org/apache/giraph/graph/GlobalStats.java f3cbea2 > giraph-core/src/main/java/org/apache/giraph/master/BspServiceMaster.java > 1d3cff0 > giraph-core/src/main/java/org/apache/giraph/metrics/MetricNames.java > cc237ac > giraph-core/src/main/java/org/apache/giraph/partition/PartitionStats.java > b8eeca9 > > giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneToAllMessages.java > PRE-CREATION > > giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdData.java > 26c547b > giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java > 52bac3f > giraph-core/src/test/java/org/apache/giraph/comm/RequestTest.java 2e60c09 > giraph-core/src/test/java/org/apache/giraph/utils/MockUtils.java bc5b5e2 > > giraph-examples/src/test/java/org/apache/giraph/examples/SimpleTriangleClosingComputationTest.java > 7346745 > > Diff: https://reviews.apache.org/r/12174/diff/ > > > Testing > ------- > > Did > mvn clean verify > mvn clean test > > > Thanks, > > Bingjing Zhang > >
