diff options
Diffstat (limited to 'ace/Remote_Name_Space.cpp')
-rw-r--r-- | ace/Remote_Name_Space.cpp | 312 |
1 files changed, 0 insertions, 312 deletions
diff --git a/ace/Remote_Name_Space.cpp b/ace/Remote_Name_Space.cpp deleted file mode 100644 index a3813ebf610..00000000000 --- a/ace/Remote_Name_Space.cpp +++ /dev/null @@ -1,312 +0,0 @@ -// Remote_Name_Space.cpp -// $Id$ - -#define ACE_BUILD_DLL -#include "ace/Remote_Name_Space.h" - -int -ACE_Remote_Name_Space::open (const char *servername, u_short port) -{ - ACE_TRACE ("ACE_Remote_Name_Space::open"); - ACE_INET_Addr servaddr; - - // Initialize Addr - if (servaddr.set (port, servername) == -1) - return -1; - - // Connect to Name Server process. - if (this->ns_proxy_.open (servaddr) == -1) - return -1; - - return 0; -} - -ACE_Remote_Name_Space::ACE_Remote_Name_Space (void) -{ - ACE_TRACE ("ACE_Remote_Name_Space::ACE_Remote_Name_Space"); -} - -ACE_Remote_Name_Space::ACE_Remote_Name_Space (const char *hostname, - u_short port) -{ - ACE_TRACE ("ACE_Remote_Name_Space::ACE_Remote_Name_Space"); - if (this->open (hostname, port) == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::ACE_Remote_Name_Space")); -} - -int -ACE_Remote_Name_Space::bind (const ACE_WString &name, - const ACE_WString &value, - const char *type) -{ - ACE_TRACE ("ACE_Remote_Name_Space::bind"); - ACE_Name_Request request (ACE_Name_Request::BIND, name.rep (), - name.length () * sizeof (ACE_USHORT16), - value.rep (), - value.length () * sizeof (ACE_USHORT16), - type, strlen (type)); - int result = this->ns_proxy_.request_reply (request); - return result == ACE_Name_Reply::SUCCESS ? 0 : result; -} - -int -ACE_Remote_Name_Space::rebind (const ACE_WString &name, - const ACE_WString &value, - const char *type) -{ - ACE_TRACE ("ACE_Remote_Name_Space::rebind"); - ACE_Name_Request request (ACE_Name_Request::REBIND, name.rep (), - name.length () * sizeof (ACE_USHORT16), - value.rep (), - value.length () * sizeof (ACE_USHORT16), - type, strlen (type)); - int result = this->ns_proxy_.request_reply (request); - return result == ACE_Name_Reply::SUCCESS ? 0 : result; -} - -int -ACE_Remote_Name_Space::resolve (const ACE_WString &name, - ACE_WString &value, - char *&type) -{ - ACE_TRACE ("ACE_Remote_Name_Space::resolve"); - ACE_Name_Request request (ACE_Name_Request::RESOLVE, name.rep (), - name.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply; - - if (this->ns_proxy_.recv_reply (reply) == -1) - return -1; - - ACE_WString temp (reply.value (), reply.value_len () / sizeof (ACE_USHORT16)); - value = temp; - ACE_NEW_RETURN (type, char[reply.type_len ()], -1); - ACE_OS::strcpy (type, reply.type ()); - - return 0; -} - -int -ACE_Remote_Name_Space::unbind (const ACE_WString &name) -{ - ACE_TRACE ("ACE_Remote_Name_Space::unbind"); - ACE_Name_Request request (ACE_Name_Request::UNBIND, name.rep (), - name.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - int result = this->ns_proxy_.request_reply (request); - return result == ACE_Name_Reply::SUCCESS ? 0 : result; -} - -int -ACE_Remote_Name_Space::list_names (ACE_WSTRING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_names"); - ACE_Name_Request request (ACE_Name_Request::LIST_NAMES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_names")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString name (reply.name (), reply.name_len () / sizeof (ACE_USHORT16)); - set.insert (name); - } - } - return 0; -} - -int -ACE_Remote_Name_Space::list_values (ACE_WSTRING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_values"); - ACE_Name_Request request (ACE_Name_Request::LIST_VALUES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_values")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString value (reply.value (), reply.value_len () / sizeof (ACE_USHORT16)); - set.insert (value); - } - } - return 0; -} - -int -ACE_Remote_Name_Space::list_types (ACE_WSTRING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_types"); - ACE_Name_Request request (ACE_Name_Request::LIST_TYPES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_values")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString type (reply.type ()); - set.insert (type); - } - } - return 0; -} - -int -ACE_Remote_Name_Space::list_name_entries (ACE_BINDING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_names"); - ACE_Name_Request request (ACE_Name_Request::LIST_NAME_ENTRIES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_names")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString name (reply.name (), reply.name_len () / sizeof (ACE_USHORT16)); - ACE_WString value (reply.value (), reply.value_len () / sizeof (ACE_USHORT16)); - ACE_Name_Binding entry (name, value, reply.type ()); - - if (set.insert (entry) == -1) - return -1; - } - } - return 0; -} - -int -ACE_Remote_Name_Space::list_value_entries (ACE_BINDING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_values"); - ACE_Name_Request request (ACE_Name_Request::LIST_VALUE_ENTRIES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_values")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString name (reply.name (), reply.name_len () / sizeof (ACE_USHORT16)); - ACE_WString value (reply.value (), reply.value_len () / sizeof (ACE_USHORT16)); - ACE_Name_Binding entry (name, value, reply.type()); - - if (set.insert (entry) == -1) - return -1; - } - } - return 0; -} - -int -ACE_Remote_Name_Space::list_type_entries (ACE_BINDING_SET &set, - const ACE_WString &pattern) -{ - ACE_TRACE ("ACE_Remote_Name_Space::list_types"); - ACE_Name_Request request (ACE_Name_Request::LIST_TYPE_ENTRIES, pattern.rep (), - pattern.length () * sizeof (ACE_USHORT16), - NULL, 0, NULL, 0); - - if (this->ns_proxy_.send_request (request) == -1) - return -1; - - ACE_Name_Request reply (0, NULL, 0, NULL, 0, NULL, 0, 0); - - while (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - if (this->ns_proxy_.recv_reply (reply) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Remote_Name_Space::list_values")); - return -1; - } - if (reply.msg_type () != ACE_Name_Request::MAX_ENUM) - { - ACE_WString name (reply.name (), reply.name_len () / sizeof (ACE_USHORT16)); - ACE_WString value (reply.value (), reply.value_len () / sizeof (ACE_USHORT16)); - ACE_Name_Binding entry (name, value, reply.type()); - - if (set.insert (entry) == -1) - return -1; - } - } - return 0; -} - - -ACE_Remote_Name_Space::~ACE_Remote_Name_Space (void) -{ - ACE_TRACE ("ACE_Remote_Name_Space::~ACE_Remote_Name_Space"); -} - -void -ACE_Remote_Name_Space::dump (void) const -{ - ACE_TRACE ("ACE_Remote_Name_Space::dump"); - - ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this)); - this->ns_proxy_.dump (); - ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP)); -} - |