summaryrefslogtreecommitdiff
path: root/js/src/Ice/ConnectRequestHandler.js
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2017-02-06 11:17:34 +0100
committerBenoit Foucher <benoit@zeroc.com>2017-02-06 11:17:34 +0100
commit18ab8207bd14def950fd399c60d9ee54fab75d3b (patch)
treea82af333127184acc6be6e0969919cb20be5e8b3 /js/src/Ice/ConnectRequestHandler.js
parentFixed ICE-7548 - getAdminProxy no longer returns 0 if synchronization is in p... (diff)
downloadice-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.js11
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));
}