diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2014-07-01 17:42:04 +0200 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2014-07-01 17:42:04 +0200 |
| commit | 344a7fd6e0d716f81dc27495e97a7ad9c2ab07b8 (patch) | |
| tree | bd06f4919e5a5827f60e2a536e43e47a4fbed6d2 /java/src/IceInternal/CollocatedRequestHandler.java | |
| parent | Fixed ICE-5569: IceStorm IceMX debug iterator assert (diff) | |
| download | ice-344a7fd6e0d716f81dc27495e97a7ad9c2ab07b8.tar.bz2 ice-344a7fd6e0d716f81dc27495e97a7ad9c2ab07b8.tar.xz ice-344a7fd6e0d716f81dc27495e97a7ad9c2ab07b8.zip | |
IceMX and Python support for the new collocation optimization
Diffstat (limited to 'java/src/IceInternal/CollocatedRequestHandler.java')
| -rw-r--r-- | java/src/IceInternal/CollocatedRequestHandler.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/java/src/IceInternal/CollocatedRequestHandler.java b/java/src/IceInternal/CollocatedRequestHandler.java index 13965c3c10b..245d714a64b 100644 --- a/java/src/IceInternal/CollocatedRequestHandler.java +++ b/java/src/IceInternal/CollocatedRequestHandler.java @@ -315,7 +315,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - out.attachCollocatedObserver(requestId); + out.attachCollocatedObserver(_adapter, requestId); if(_reference.getInvocationTimeout() > 0) { @@ -348,7 +348,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - outAsync.__attachCollocatedObserver(requestId); + outAsync.__attachCollocatedObserver(_adapter, requestId); _adapter.getThreadPool().execute(new InvokeAllAsync(outAsync, outAsync.__getOs(), requestId, 1, false)); @@ -395,7 +395,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - out.attachCollocatedObserver(0); + out.attachCollocatedObserver(_adapter, 0); if(invokeNum > 0) { @@ -454,7 +454,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - outAsync.__attachCollocatedObserver(0); + outAsync.__attachCollocatedObserver(_adapter, 0); if(invokeNum > 0) { |