summaryrefslogtreecommitdiff
path: root/cpp/src/Glacier2/RequestQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Glacier2/RequestQueue.h')
-rw-r--r--cpp/src/Glacier2/RequestQueue.h8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/Glacier2/RequestQueue.h b/cpp/src/Glacier2/RequestQueue.h
index 53f5fd5befb..5bda90a5794 100644
--- a/cpp/src/Glacier2/RequestQueue.h
+++ b/cpp/src/Glacier2/RequestQueue.h
@@ -31,9 +31,9 @@ class Request : public IceUtil::Shared
public:
Request(const Ice::ObjectPrx&, const std::pair<const Ice::Byte*, const Ice::Byte*>&, const Ice::Current&, bool,
- const Ice::Context&, const Ice::AMD_Array_Object_ice_invokePtr&, const Ice::ConnectionPtr&);
+ const Ice::Context&, const Ice::AMD_Array_Object_ice_invokePtr&);
- bool invoke(const InstancePtr&);
+ bool invoke(const InstancePtr&, const Ice::ConnectionPtr&);
bool override(const RequestPtr&) const;
const Ice::ObjectPrx& getProxy() const { return _proxy; }
bool hasOverride() const { return !_override.empty(); }
@@ -47,14 +47,13 @@ private:
const Ice::Context _sslContext;
const std::string _override;
const Ice::AMD_Array_Object_ice_invokePtr _amdCB;
- const Ice::ConnectionPtr _connection;
};
class RequestQueue : public IceUtil::Mutex, public IceUtil::Shared
{
public:
- RequestQueue(const RequestQueueThreadPtr&, const InstancePtr&);
+ RequestQueue(const RequestQueueThreadPtr&, const InstancePtr&, const Ice::ConnectionPtr&);
bool addRequest(const RequestPtr&);
void flushRequests(std::set<Ice::ObjectPrx>&);
@@ -63,6 +62,7 @@ private:
const RequestQueueThreadPtr _requestQueueThread;
const InstancePtr _instance;
+ const Ice::ConnectionPtr _connection;
std::vector<RequestPtr> _requests;
};
typedef IceUtil::Handle<RequestQueue> RequestQueuePtr;