Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins')
-rw-r--r--plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/ViewsChangedIndication.java24
-rw-r--r--plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RandomDeadLockTest.java4
-rw-r--r--plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOSessionImpl.java6
-rw-r--r--plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedRequest.java (renamed from plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedNotification.java)21
4 files changed, 32 insertions, 23 deletions
diff --git a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/ViewsChangedIndication.java b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/ViewsChangedIndication.java
index d3fcbc1cab..fcbf696693 100644
--- a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/ViewsChangedIndication.java
+++ b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/ViewsChangedIndication.java
@@ -10,18 +10,17 @@
**************************************************************************/
package org.eclipse.emf.cdo.internal.server.protocol;
+import java.io.IOException;
+
import org.eclipse.emf.cdo.internal.server.Session;
import org.eclipse.emf.cdo.protocol.CDOProtocolConstants;
-
-import org.eclipse.net4j.signal.Indication;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
-
-import java.io.IOException;
+import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
/**
* @author Eike Stepper
*/
-public class ViewsChangedIndication extends Indication
+public class ViewsChangedIndication extends CDOServerIndication
{
public ViewsChangedIndication()
{
@@ -36,11 +35,16 @@ public class ViewsChangedIndication extends Indication
@Override
protected void indicating(ExtendedDataInputStream in) throws IOException
{
- int viewID = in.readInt();
- byte kind = in.readByte();
+ int viewID = in.readInt();
+ byte kind = in.readByte();
+ CDOServerProtocol protocol = (CDOServerProtocol)getProtocol();
+ Session session = protocol.getSession();
+ session.notifyViewsChanged(session, viewID, kind);
+ }
- CDOServerProtocol protocol = (CDOServerProtocol)getProtocol();
- Session session = protocol.getSession();
- session.notifyViewsChanged(session, viewID, kind);
+ @Override
+ protected void responding(ExtendedDataOutputStream out) throws IOException
+ {
+ out.writeBoolean(true);
}
}
diff --git a/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RandomDeadLockTest.java b/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RandomDeadLockTest.java
index fa317be2e0..a74af964ba 100644
--- a/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RandomDeadLockTest.java
+++ b/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RandomDeadLockTest.java
@@ -47,7 +47,7 @@ public class RandomDeadLockTest extends AbstractCDOTest
for (int i = 0; i < 100; i++)
{
- msg("Loop " + i);
+ msg("Session " + i);
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource = transaction.getResource("/test2");
@@ -70,7 +70,7 @@ public class RandomDeadLockTest extends AbstractCDOTest
for (int i =0; i < 1000; i++)
{
- msg("Loop " + i);
+ msg("Transaction " + i);
transaction = session.openTransaction(new ResourceSetImpl());
CDOResource resource = transaction.getResource("/test2");
Category category = Model1Factory.eINSTANCE.createCategory();
diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOSessionImpl.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOSessionImpl.java
index cfb6dda2dc..207d4bea76 100644
--- a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOSessionImpl.java
+++ b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOSessionImpl.java
@@ -37,7 +37,7 @@ import org.eclipse.emf.internal.cdo.bundle.OM;
import org.eclipse.emf.internal.cdo.protocol.OpenSessionRequest;
import org.eclipse.emf.internal.cdo.protocol.OpenSessionResult;
import org.eclipse.emf.internal.cdo.protocol.QueryObjectTypesRequest;
-import org.eclipse.emf.internal.cdo.protocol.ViewsChangedNotification;
+import org.eclipse.emf.internal.cdo.protocol.ViewsChangedRequest;
import org.eclipse.emf.internal.cdo.util.ModelUtil;
import org.eclipse.emf.internal.cdo.util.ProxyResolverURIResourceMap;
@@ -333,7 +333,7 @@ public class CDOSessionImpl extends Container<CDOView> implements CDOSession
try
{
- new ViewsChangedNotification(channel, view.getViewID(), CDOProtocolConstants.VIEW_CLOSED).send();
+ new ViewsChangedRequest(channel, view.getViewID(), CDOProtocolConstants.VIEW_CLOSED).send();
}
catch (Exception ex)
{
@@ -653,7 +653,7 @@ public class CDOSessionImpl extends Container<CDOView> implements CDOSession
{
int id = view.getViewID();
byte kind = getKind(view);
- new ViewsChangedNotification(channel, id, kind).send();
+ new ViewsChangedRequest(channel, id, kind).send();
}
catch (Exception ex)
{
diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedNotification.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedRequest.java
index 5656446a6e..e18a3b47e5 100644
--- a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedNotification.java
+++ b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/protocol/ViewsChangedRequest.java
@@ -10,24 +10,23 @@
**************************************************************************/
package org.eclipse.emf.internal.cdo.protocol;
-import org.eclipse.emf.cdo.protocol.CDOProtocolConstants;
+import java.io.IOException;
+import org.eclipse.emf.cdo.protocol.CDOProtocolConstants;
import org.eclipse.net4j.IChannel;
-import org.eclipse.net4j.signal.Request;
+import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
-
/**
* @author Eike Stepper
*/
-public class ViewsChangedNotification extends Request
+public class ViewsChangedRequest extends CDOClientRequest<Boolean>
{
private int viewID;
private byte kind;
- public ViewsChangedNotification(IChannel channel, int viewID, byte kind)
+ public ViewsChangedRequest(IChannel channel, int viewID, byte kind)
{
super(channel);
this.viewID = viewID;
@@ -43,7 +42,13 @@ public class ViewsChangedNotification extends Request
@Override
protected void requesting(ExtendedDataOutputStream out) throws IOException
{
- out.writeInt(viewID);
- out.writeByte(kind);
+ out.writeInt(viewID);
+ out.writeByte(kind);
+ }
+
+ @Override
+ protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ {
+ return in.readBoolean();
}
}

Back to the top