summaryrefslogtreecommitdiff
path: root/ACE/ace/Remote_Name_Space.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/ace/Remote_Name_Space.cpp')
-rw-r--r--ACE/ace/Remote_Name_Space.cpp380
1 files changed, 380 insertions, 0 deletions
diff --git a/ACE/ace/Remote_Name_Space.cpp b/ACE/ace/Remote_Name_Space.cpp
new file mode 100644
index 00000000000..2b55cf684a5
--- /dev/null
+++ b/ACE/ace/Remote_Name_Space.cpp
@@ -0,0 +1,380 @@
+#include "ace/Remote_Name_Space.h"
+#include "ace/Auto_Ptr.h"
+#include "ace/Log_Msg.h"
+#include "ace/SString.h"
+#include "ace/OS_NS_string.h"
+
+ACE_RCSID (ace,
+ Remote_Name_Space,
+ "$Id$")
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+
+int
+ACE_Remote_Name_Space::open (const ACE_TCHAR *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 ACE_TCHAR *hostname,
+ u_short port)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::ACE_Remote_Name_Space");
+ if (this->open (hostname, port) == -1)
+ ACE_ERROR ((LM_ERROR, ACE_LIB_TEXT ("%p\n"), ACE_LIB_TEXT ("ACE_Remote_Name_Space::ACE_Remote_Name_Space")));
+}
+
+int
+ACE_Remote_Name_Space::bind (const ACE_NS_WString &name,
+ const ACE_NS_WString &value,
+ const char *type)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::bind");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> name_urep (name.rep ());
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> value_urep (value.rep ());
+ ACE_UINT32 name_len =
+ static_cast<ACE_UINT32> (name.length () * sizeof (ACE_WCHAR_T));
+ ACE_UINT32 value_len =
+ static_cast<ACE_UINT32> (value.length () * sizeof (ACE_WCHAR_T));
+ ACE_UINT32 type_len =
+ static_cast<ACE_UINT32> (ACE_OS::strlen (type));
+ ACE_Name_Request request (ACE_Name_Request::BIND,
+ name_urep.get (),
+ name_len,
+ value_urep.get (),
+ value_len,
+ type,
+ type_len);
+ return this->ns_proxy_.request_reply (request);
+}
+
+int
+ACE_Remote_Name_Space::rebind (const ACE_NS_WString &name,
+ const ACE_NS_WString &value,
+ const char *type)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::rebind");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> name_urep (name.rep ());
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> value_urep (value.rep ());
+ ACE_UINT32 name_len =
+ static_cast<ACE_UINT32> (name.length () * sizeof (ACE_WCHAR_T));
+ ACE_UINT32 value_len =
+ static_cast<ACE_UINT32> (value.length () * sizeof (ACE_WCHAR_T));
+ ACE_UINT32 type_len =
+ static_cast<ACE_UINT32> (ACE_OS::strlen (type));
+ ACE_Name_Request request (ACE_Name_Request::REBIND,
+ name_urep.get (),
+ name_len,
+ value_urep.get (),
+ value_len,
+ type,
+ type_len);
+ return this->ns_proxy_.request_reply (request);
+}
+
+int
+ACE_Remote_Name_Space::resolve (const ACE_NS_WString &name,
+ ACE_NS_WString &value,
+ char *&type)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::resolve");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> name_urep (name.rep ());
+ ACE_UINT32 name_len =
+ static_cast<ACE_UINT32> (name.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::RESOLVE,
+ name_urep.get (),
+ name_len,
+ 0, 0, 0, 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_NS_WString temp (reply.value (), reply.value_len () / sizeof (ACE_WCHAR_T));
+ value = temp;
+ ACE_NEW_RETURN (type,
+ char[reply.type_len () + 1],
+ -1);
+ ACE_OS::strcpy (type, reply.type ());
+ return 0;
+}
+
+int
+ACE_Remote_Name_Space::unbind (const ACE_NS_WString &name)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::unbind");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> name_urep (name.rep ());
+ ACE_UINT32 name_len =
+ static_cast<ACE_UINT32> (name.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::UNBIND,
+ name_urep.get (),
+ name_len,
+ 0, 0, 0, 0);
+ return this->ns_proxy_.request_reply (request);
+}
+
+int
+ACE_Remote_Name_Space::list_names (ACE_WSTRING_SET &set,
+ const ACE_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_names");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_NAMES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_names")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString name (reply.name (),
+ reply.name_len () / sizeof (ACE_WCHAR_T));
+ set.insert (name);
+ }
+ }
+ return 0;
+}
+
+int
+ACE_Remote_Name_Space::list_values (ACE_WSTRING_SET &set,
+ const ACE_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_values");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_VALUES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_values")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString value (reply.value (),
+ reply.value_len () / sizeof (ACE_WCHAR_T));
+ set.insert (value);
+ }
+ }
+
+ return 0;
+}
+
+int
+ACE_Remote_Name_Space::list_types (ACE_WSTRING_SET &set,
+ const ACE_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_types");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_TYPES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_values")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString type (reply.type ());
+ set.insert (type);
+ }
+ }
+
+ return 0;
+}
+
+int
+ACE_Remote_Name_Space::list_name_entries (ACE_BINDING_SET &set,
+ const ACE_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_name_entries");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_NAME_ENTRIES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_names")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString name (reply.name (),
+ reply.name_len () / sizeof (ACE_WCHAR_T));
+ ACE_NS_WString value (reply.value (),
+ reply.value_len () / sizeof (ACE_WCHAR_T));
+ 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_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_value_entries");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_VALUE_ENTRIES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_values")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString name (reply.name (),
+ reply.name_len () / sizeof (ACE_WCHAR_T));
+ ACE_NS_WString value (reply.value (),
+ reply.value_len () / sizeof (ACE_WCHAR_T));
+ 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_NS_WString &pattern)
+{
+ ACE_TRACE ("ACE_Remote_Name_Space::list_type_entries");
+ ACE_Auto_Basic_Array_Ptr<ACE_WCHAR_T> pattern_urep (pattern.rep ());
+ ACE_UINT32 pattern_len =
+ static_cast<ACE_UINT32> (pattern.length () * sizeof (ACE_WCHAR_T));
+ ACE_Name_Request request (ACE_Name_Request::LIST_TYPE_ENTRIES,
+ pattern_urep.get (),
+ pattern_len,
+ 0, 0, 0, 0);
+
+ if (this->ns_proxy_.send_request (request) == -1)
+ return -1;
+
+ ACE_Name_Request reply (0, 0, 0, 0, 0, 0, 0, 0);
+
+ while (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ if (this->ns_proxy_.recv_reply (reply) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_LIB_TEXT ("%p\n"),
+ ACE_LIB_TEXT ("ACE_Remote_Name_Space::list_values")),
+ -1);
+ if (reply.msg_type () != ACE_Name_Request::MAX_ENUM)
+ {
+ ACE_NS_WString name (reply.name (),
+ reply.name_len () / sizeof (ACE_WCHAR_T));
+ ACE_NS_WString value (reply.value (),
+ reply.value_len () / sizeof (ACE_WCHAR_T));
+ 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
+{
+#if defined (ACE_HAS_DUMP)
+ 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));
+#endif /* ACE_HAS_DUMP */
+}
+
+ACE_END_VERSIONED_NAMESPACE_DECL