summaryrefslogtreecommitdiff
path: root/java/test/Freeze/evictor/ServantI.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/test/Freeze/evictor/ServantI.java')
-rw-r--r--java/test/Freeze/evictor/ServantI.java152
1 files changed, 76 insertions, 76 deletions
diff --git a/java/test/Freeze/evictor/ServantI.java b/java/test/Freeze/evictor/ServantI.java
index db7a7b4423d..3a50bd01054 100644
--- a/java/test/Freeze/evictor/ServantI.java
+++ b/java/test/Freeze/evictor/ServantI.java
@@ -10,40 +10,40 @@
public class ServantI implements Test._ServantOperations
{
static class DelayedResponse extends Thread
- {
- DelayedResponse(Test.AMD_Servant_slowGetValue cb, int val)
- {
- _cb = cb;
- _val = val;
- }
-
- public void
+ {
+ DelayedResponse(Test.AMD_Servant_slowGetValue cb, int val)
+ {
+ _cb = cb;
+ _val = val;
+ }
+
+ public void
run()
{
- try
- {
- sleep(500);
- }
- catch(InterruptedException e)
- {
- // Ignored
- }
- _cb.ice_response(_val);
- }
+ try
+ {
+ sleep(500);
+ }
+ catch(InterruptedException e)
+ {
+ // Ignored
+ }
+ _cb.ice_response(_val);
+ }
- private Test.AMD_Servant_slowGetValue _cb;
- private int _val;
+ private Test.AMD_Servant_slowGetValue _cb;
+ private int _val;
}
ServantI(Test.Servant tie)
{
- _tie = tie;
+ _tie = tie;
}
ServantI(Test.Servant tie, RemoteEvictorI remoteEvictor, Freeze.Evictor evictor, int value)
{
- _tie = tie;
+ _tie = tie;
_remoteEvictor = remoteEvictor;
_evictor = evictor;
_tie.value = value;
@@ -51,7 +51,7 @@ public class ServantI implements Test._ServantOperations
void
init(RemoteEvictorI remoteEvictor, Freeze.Evictor evictor)
- {
+ {
_remoteEvictor = remoteEvictor;
_evictor = evictor;
}
@@ -65,48 +65,48 @@ public class ServantI implements Test._ServantOperations
public int
getValue(Ice.Current current)
{
- synchronized(_tie)
- {
- return _tie.value;
- }
+ synchronized(_tie)
+ {
+ return _tie.value;
+ }
}
public void
slowGetValue_async(Test.AMD_Servant_slowGetValue cb, Ice.Current current)
{
- synchronized(_tie)
- {
- Thread t = new DelayedResponse(cb, _tie.value);
- t.setDaemon(true);
- t.start();
- }
+ synchronized(_tie)
+ {
+ Thread t = new DelayedResponse(cb, _tie.value);
+ t.setDaemon(true);
+ t.start();
+ }
}
public void
setValue(int value, Ice.Current current)
{
- synchronized(_tie)
- {
- _tie.value = value;
- }
+ synchronized(_tie)
+ {
+ _tie.value = value;
+ }
}
public void
setValueAsync_async(Test.AMD_Servant_setValueAsync __cb, int value, Ice.Current current)
{
- synchronized(_tie)
- {
- _setValueAsyncCB = __cb;
- _setValueAsyncValue = value;
+ synchronized(_tie)
+ {
+ _setValueAsyncCB = __cb;
+ _setValueAsyncValue = value;
_tie.notify();
- }
+ }
}
public void
releaseAsync(Ice.Current current)
{
- synchronized(_tie)
- {
+ synchronized(_tie)
+ {
while(_setValueAsyncCB == null)
{
try
@@ -127,66 +127,66 @@ public class ServantI implements Test._ServantOperations
public void
addFacet(String name, String data, Ice.Current current)
- throws Test.AlreadyRegisteredException
+ throws Test.AlreadyRegisteredException
{
- Test._FacetTie tie = new Test._FacetTie();
- tie.ice_delegate(new FacetI(tie, _remoteEvictor, _evictor, 0, data));
+ Test._FacetTie tie = new Test._FacetTie();
+ tie.ice_delegate(new FacetI(tie, _remoteEvictor, _evictor, 0, data));
- try
- {
- _evictor.addFacet(tie, current.id, name);
- }
- catch(Ice.AlreadyRegisteredException ex)
- {
- throw new Test.AlreadyRegisteredException();
- }
+ try
+ {
+ _evictor.addFacet(tie, current.id, name);
+ }
+ catch(Ice.AlreadyRegisteredException ex)
+ {
+ throw new Test.AlreadyRegisteredException();
+ }
}
public void
removeFacet(String name, Ice.Current current)
- throws Test.NotRegisteredException
+ throws Test.NotRegisteredException
{
- try
- {
- _evictor.removeFacet(current.id, name);
- }
- catch(Ice.NotRegisteredException ex)
- {
- throw new Test.NotRegisteredException();
- }
+ try
+ {
+ _evictor.removeFacet(current.id, name);
+ }
+ catch(Ice.NotRegisteredException ex)
+ {
+ throw new Test.NotRegisteredException();
+ }
}
public synchronized int
getTransientValue(Ice.Current current)
{
- return _transientValue;
+ return _transientValue;
}
public synchronized void
setTransientValue(int val, Ice.Current current)
{
- _transientValue = val;
+ _transientValue = val;
}
public void
keepInCache(Ice.Current current)
{
- _evictor.keep(current.id);
+ _evictor.keep(current.id);
}
public void
release(Ice.Current current)
- throws Test.NotRegisteredException
+ throws Test.NotRegisteredException
{
- try
- {
- _evictor.release(current.id);
- }
- catch(Ice.NotRegisteredException e)
- {
- throw new Test.NotRegisteredException();
- }
+ try
+ {
+ _evictor.release(current.id);
+ }
+ catch(Ice.NotRegisteredException e)
+ {
+ throw new Test.NotRegisteredException();
+ }
}
protected RemoteEvictorI _remoteEvictor;