diff options
Diffstat (limited to 'cpp/src/Glacier2/RequestQueue.h')
-rw-r--r-- | cpp/src/Glacier2/RequestQueue.h | 8 |
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; |