"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "dso-l2/src/test/java/com/tc/objectserver/entity/ReplicationSenderTest.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.

ReplicationSenderTest.java  (terracotta-core-5.7.0):ReplicationSenderTest.java  (terracotta-core-5.7.1)
skipping to change at line 32 skipping to change at line 32
import com.tc.async.api.Stage; import com.tc.async.api.Stage;
import com.tc.bytes.TCByteBufferFactory; import com.tc.bytes.TCByteBufferFactory;
import com.tc.io.TCByteBufferInput; import com.tc.io.TCByteBufferInput;
import com.tc.io.TCByteBufferInputStream; import com.tc.io.TCByteBufferInputStream;
import com.tc.io.TCByteBufferOutput; import com.tc.io.TCByteBufferOutput;
import com.tc.io.TCByteBufferOutputStream; import com.tc.io.TCByteBufferOutputStream;
import com.tc.l2.msg.ReplicationMessage; import com.tc.l2.msg.ReplicationMessage;
import com.tc.l2.msg.SyncReplicationActivity; import com.tc.l2.msg.SyncReplicationActivity;
import com.tc.net.ClientID; import com.tc.net.ClientID;
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.GroupManager; import com.tc.net.groups.GroupManager;
import com.tc.object.ClientInstanceID; import com.tc.object.ClientInstanceID;
import com.tc.object.EntityID; import com.tc.object.EntityID;
import com.tc.object.FetchID; import com.tc.object.FetchID;
import com.tc.object.session.SessionID; import com.tc.object.session.SessionID;
import com.tc.object.tx.TransactionID; import com.tc.object.tx.TransactionID;
import com.tc.objectserver.handler.ReplicationSendingAction; import com.tc.objectserver.handler.ReplicationSendingAction;
import com.tc.util.Assert; import com.tc.util.Assert;
import com.tc.util.concurrent.SetOnceFlag; import com.tc.util.concurrent.SetOnceFlag;
skipping to change at line 59 skipping to change at line 60
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.mockito.ArgumentMatchers; import org.mockito.ArgumentMatchers;
import static org.mockito.Mockito.doAnswer; import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
public class ReplicationSenderTest { public class ReplicationSenderTest {
NodeID node = mock(NodeID.class); ServerID node = mock(ServerID.class);
SessionID session = mock(SessionID.class); SessionID session = mock(SessionID.class);
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
GroupManager<AbstractGroupMessage> groupMgr = mock(GroupManager.class); GroupManager<AbstractGroupMessage> groupMgr = mock(GroupManager.class);
List<ReplicationMessage> collector = new LinkedList<>(); List<ReplicationMessage> collector = new LinkedList<>();
Sink<ReplicationSendingAction> sink = new Sink<ReplicationSendingAction>() { Sink<ReplicationSendingAction> sink = new Sink<ReplicationSendingAction>() {
@Override @Override
public void addToSink(ReplicationSendingAction context) { public void addToSink(ReplicationSendingAction context) {
context.run(); context.run();
} }
}; };
 End of changes. 2 change blocks. 
1 lines changed or deleted 2 lines changed or added

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