"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "dso-l2/src/main/java/com/tc/objectserver/handler/GroupMessageBatchContext.java" between
terracotta-core-5.7.0.tar.gz and terracotta-core-5.7.1.tar.gz

About: Terracotta - Clustering technology for Java ("Network Attached Memory", "Distributed Cache"). Source code of the server (5.x) core components.

GroupMessageBatchContext.java  (terracotta-core-5.7.0):GroupMessageBatchContext.java  (terracotta-core-5.7.1)
skipping to change at line 26 skipping to change at line 26
* Terracotta, Inc., a Software AG company * Terracotta, Inc., a Software AG company
* *
*/ */
package com.tc.objectserver.handler; package com.tc.objectserver.handler;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import com.tc.l2.msg.IBatchableGroupMessage; import com.tc.l2.msg.IBatchableGroupMessage;
import com.tc.net.NodeID; import com.tc.net.NodeID;
import com.tc.net.ServerID;
import com.tc.net.groups.AbstractGroupMessage; import com.tc.net.groups.AbstractGroupMessage;
import com.tc.net.groups.GroupException; import com.tc.net.groups.GroupException;
import com.tc.net.groups.GroupManager; import com.tc.net.groups.GroupManager;
import java.util.function.Consumer; import java.util.function.Consumer;
import java.util.function.Function; import java.util.function.Function;
public class GroupMessageBatchContext<M extends IBatchableGroupMessage<E>, E> { public class GroupMessageBatchContext<M extends IBatchableGroupMessage<E>, E> {
private static final Logger LOGGER = LoggerFactory.getLogger(GroupMessageBatch Context.class); private static final Logger LOGGER = LoggerFactory.getLogger(GroupMessageBatch Context.class);
private static final long THRESHOLD = 16 * 1024 * 1024; private static final long THRESHOLD = 16 * 1024 * 1024;
private final Function<E, M> messageFactory; private final Function<E, M> messageFactory;
private final GroupManager<AbstractGroupMessage> groupManager; private final GroupManager<AbstractGroupMessage> groupManager;
private final NodeID target; private final ServerID target;
private final int maximumBatchSize; private final int maximumBatchSize;
private final int idealMessagesInFlight; private final int idealMessagesInFlight;
private final Consumer<NodeID> networkDoneTarget; private final Consumer<ServerID> networkDoneTarget;
private int messagesInFlight; private int messagesInFlight;
private M cachedMessage; private M cachedMessage;
private long nextReplicationID; private long nextReplicationID;
public GroupMessageBatchContext(Function<E, M> messageFactory, GroupManager<Ab stractGroupMessage> groupManager, NodeID target, int maximumBatchSize, int ideal MessagesInFlight, Consumer<NodeID> networkDoneTarget) { public GroupMessageBatchContext(Function<E, M> messageFactory, GroupManager<Ab stractGroupMessage> groupManager, ServerID target, int maximumBatchSize, int ide alMessagesInFlight, Consumer<ServerID> networkDoneTarget) {
this.messageFactory = messageFactory; this.messageFactory = messageFactory;
this.groupManager = groupManager; this.groupManager = groupManager;
this.target = target; this.target = target;
this.maximumBatchSize = maximumBatchSize; this.maximumBatchSize = maximumBatchSize;
this.idealMessagesInFlight = idealMessagesInFlight; this.idealMessagesInFlight = idealMessagesInFlight;
this.networkDoneTarget = networkDoneTarget; this.networkDoneTarget = networkDoneTarget;
} }
/** /**
* Called to send a new activity. This might be added to an existing batch or used to create a new one. In either * Called to send a new activity. This might be added to an existing batch or used to create a new one. In either
 End of changes. 4 change blocks. 
3 lines changed or deleted 4 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)