diff options
author | Benoit Foucher <benoit@zeroc.com> | 2017-02-06 11:17:34 +0100 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2017-02-06 11:17:34 +0100 |
commit | 18ab8207bd14def950fd399c60d9ee54fab75d3b (patch) | |
tree | a82af333127184acc6be6e0969919cb20be5e8b3 /js/src/Ice/ConnectRequestHandler.js | |
parent | Fixed ICE-7548 - getAdminProxy no longer returns 0 if synchronization is in p... (diff) | |
download | ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.tar.bz2 ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.tar.xz ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.zip |
Fixed ICE-7169 and ICE-7375 - add option to specify if batch requests flushed with the communicator/connection should be compressed
Diffstat (limited to 'js/src/Ice/ConnectRequestHandler.js')
-rw-r--r-- | js/src/Ice/ConnectRequestHandler.js | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/js/src/Ice/ConnectRequestHandler.js b/js/src/Ice/ConnectRequestHandler.js index 6b33f5fb760..6126c277234 100644 --- a/js/src/Ice/ConnectRequestHandler.js +++ b/js/src/Ice/ConnectRequestHandler.js @@ -36,7 +36,6 @@ class ConnectRequestHandler this._initialized = false; this._connection = null; - this._compress = false; this._exception = null; this._requests = []; } @@ -67,7 +66,7 @@ class ConnectRequestHandler this._requests.push(out); return AsyncStatus.Queued; } - return out.invokeRemote(this._connection, this._compress, this._response); + return out.invokeRemote(this._connection, this._response); } asyncRequestCanceled(out, ex) @@ -113,11 +112,11 @@ class ConnectRequestHandler // // Implementation of Reference_GetConnectionCallback // - setConnection(values) + setConnection(connection) { Debug.assert(this._exception === null && this._connection === null); - [this._connection, this._compress] = values; + this._connection = connection; // // If this proxy is for a non-local object, and we are using a router, then @@ -213,7 +212,7 @@ class ConnectRequestHandler { try { - request.invokeRemote(this._connection, this._compress, this._response); + request.invokeRemote(this._connection, this._response); } catch(ex) { @@ -238,7 +237,7 @@ class ConnectRequestHandler if(this._reference.getCacheConnection() && exception === null) { - this._requestHandler = new ConnectionRequestHandler(this._reference, this._connection, this._compress); + this._requestHandler = new ConnectionRequestHandler(this._reference, this._connection); this._proxies.forEach(proxy => proxy._updateRequestHandler(this, this._requestHandler)); } |