diff options
| author | Joe George <joe@zeroc.com> | 2021-01-28 16:26:44 -0500 |
|---|---|---|
| committer | Joe George <joe@zeroc.com> | 2021-02-01 16:59:30 -0500 |
| commit | 92a6531e409f2691d82591e185a92299d415fc0f (patch) | |
| tree | 60c79e2a8f327b8f0b6ebc06b06f48a2e8086f6a /cpp/src/IceGrid/RegistryAdminRouter.h | |
| parent | Port Glacier2, IceBox, IceBridge, IceDB, IceXML, icegriddb (diff) | |
| download | ice-92a6531e409f2691d82591e185a92299d415fc0f.tar.bz2 ice-92a6531e409f2691d82591e185a92299d415fc0f.tar.xz ice-92a6531e409f2691d82591e185a92299d415fc0f.zip | |
IceGrid and IceStorm
Diffstat (limited to 'cpp/src/IceGrid/RegistryAdminRouter.h')
| -rw-r--r-- | cpp/src/IceGrid/RegistryAdminRouter.h | 40 |
1 files changed, 22 insertions, 18 deletions
diff --git a/cpp/src/IceGrid/RegistryAdminRouter.h b/cpp/src/IceGrid/RegistryAdminRouter.h index 8deb750fd86..3e214c21cee 100644 --- a/cpp/src/IceGrid/RegistryAdminRouter.h +++ b/cpp/src/IceGrid/RegistryAdminRouter.h @@ -11,51 +11,55 @@ namespace IceGrid { -class RegistryServerAdminRouter : public AdminRouter +class RegistryServerAdminRouter final : public AdminRouter, + public std::enable_shared_from_this<RegistryServerAdminRouter> { public: - RegistryServerAdminRouter(const DatabasePtr&); + RegistryServerAdminRouter(const std::shared_ptr<Database>&); - virtual void ice_invoke_async(const Ice::AMD_Object_ice_invokePtr&, - const std::pair<const Ice::Byte*, const Ice::Byte*>&, - const Ice::Current&); + void ice_invokeAsync(std::pair<const Ice::Byte*, const Ice::Byte*>, + std::function<void(bool, const std::pair<const Ice::Byte*, const Ice::Byte*>&)>, + std::function<void(std::exception_ptr)>, + const Ice::Current& current) override; private: - const DatabasePtr _database; + const std::shared_ptr<Database> _database; }; -class RegistryNodeAdminRouter : public AdminRouter +class RegistryNodeAdminRouter final : public AdminRouter { public: - RegistryNodeAdminRouter(const std::string&, const DatabasePtr&); + RegistryNodeAdminRouter(const std::string&, const std::shared_ptr<Database>&); - virtual void ice_invoke_async(const Ice::AMD_Object_ice_invokePtr&, - const std::pair<const Ice::Byte*, const Ice::Byte*>&, - const Ice::Current&); + void ice_invokeAsync(std::pair<const Ice::Byte*, const Ice::Byte*>, + std::function<void(bool, const std::pair<const Ice::Byte*, const Ice::Byte*>&)>, + std::function<void(std::exception_ptr)>, + const Ice::Current& current) override; private: const std::string _collocNodeName; - const DatabasePtr _database; + const std::shared_ptr<Database> _database; }; -class RegistryReplicaAdminRouter : public AdminRouter +class RegistryReplicaAdminRouter final : public AdminRouter { public: - RegistryReplicaAdminRouter(const std::string&, const DatabasePtr&); + RegistryReplicaAdminRouter(const std::string&, const std::shared_ptr<Database>&); - virtual void ice_invoke_async(const Ice::AMD_Object_ice_invokePtr&, - const std::pair<const Ice::Byte*, const Ice::Byte*>&, - const Ice::Current&); + void ice_invokeAsync(std::pair<const Ice::Byte*, const Ice::Byte*>, + std::function<void(bool, const std::pair<const Ice::Byte*, const Ice::Byte*>&)>, + std::function<void(std::exception_ptr)>, + const Ice::Current& current) override; private: const std::string _name; - const DatabasePtr _database; + const std::shared_ptr<Database> _database; }; } |