1 files changed, 159 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/ImplRepo/nestea_i.cpp b/TAO/orbsvcs/tests/ImplRepo/nestea_i.cpp
new file mode 100644
index 00000000000..562e5da3485
--- /dev/null
+++ b/TAO/orbsvcs/tests/ImplRepo/nestea_i.cpp
@@ -0,0 +1,159 @@
+// $Id$
+
+#include "nestea_i.h"
+#include "tao/debug.h"
+#include "ace/ACE.h"
+#include "ace/FILE_Addr.h"
+#include "ace/FILE_Connector.h"
+#include "ace/FILE_IO.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/OS_NS_string.h"
+
+const size_t MAX_UINT32_STR_LEN = 11;  // Largest UINT32 is 8589934591 + NUL is 11 characters
+
+ACE_RCSID(ImplRepo, nestea_i, "$Id$")
+
+Nestea_i::Nestea_i (CORBA::ORB_ptr orb, const char *filename)
+: cans_ (0)
+{
+  orb_ = CORBA::ORB::_duplicate(orb);
+
+  this->data_filename_ = ACE::strnew (filename);
+
+  // @@ This should probably be called from somewhere else
+  this->load_data ();
+}
+
+
+Nestea_i::~Nestea_i (void)
+{
+  delete [] this->data_filename_;
+}
+
+
+// Add <cans> number of cans to the bookshelf.
+
+void
+Nestea_i::drink (CORBA::Long cans)
+{
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG, "Nestea_i::drink %d cans\n", cans));
+
+  this->cans_ += cans;
+
+  this->save_data ();
+}
+
+
+// Removes <cans> number of cans from the bookshelf.
+
+void
+Nestea_i::crush (CORBA::Long cans)
+{
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG, "Nestea_i::crush %d cans\n", cans));
+
+  if (static_cast<ACE_UINT32> (cans) > this->cans_)
+    this->cans_ = 0;
+  else
+    this->cans_ -= cans;
+
+  this->save_data ();
+}
+
+
+// Returns the number of cans in the bookshelf.
+
+CORBA::Long
+Nestea_i::bookshelf_size (void)
+{
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG, "Nestea_i::bookshelf_size\n"));
+
+  return this->cans_;
+}
+
+// Returns comments about your collection.
+
+char *
+Nestea_i::get_praise (void)
+{
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG, "Nestea_i::get_praise\n"));
+
+  if (this->cans_ > 500)
+    return CORBA::string_dup ("Man, that is one excellent Nestea Collection!");
+  else if (this->cans_ > 250)
+    return CORBA::string_dup ("We are getting into the big leagues now!");
+  else if (this->cans_ > 100)
+    return CORBA::string_dup ("Things are looking up!");
+  else if (this->cans_ > 0)
+    return CORBA::string_dup ("Well, it is a start. Drink more Nestea!");
+  else
+    return CORBA::string_dup ("No cans, no praise.");
+}
+
+void
+Nestea_i::shutdown (void)
+{
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG, "Nestea_i::shutdown\n"));
+
+  orb_->shutdown(0);
+}
+
+// Saves bookshelf data to a file.
+
+int
+Nestea_i::save_data (void)
+{
+  ACE_FILE_IO file;
+  ACE_FILE_Connector connector;
+
+  if (connector.connect (file,
+                         ACE_FILE_Addr (this->data_filename_),
+                         0,
+                         ACE_Addr::sap_any) == -1)
+    ACE_ERROR_RETURN ((LM_ERROR,
+                       "%p\n to %s",
+                       "connect",
+                       this->data_filename_),
+                      -1);
+
+  char str[MAX_UINT32_STR_LEN];
+
+  ACE_OS::sprintf (str, "%d", this->cans_);
+
+  return file.send_n (str, ACE_OS::strlen (str) + 1);
+}
+
+
+// Loads bookshelf data from a file.
+
+int
+Nestea_i::load_data (void)
+{
+  ACE_FILE_IO file;
+  ACE_FILE_Connector connector;
+
+  if (connector.connect (file,
+                         ACE_FILE_Addr (this->data_filename_),
+                         0,
+                         ACE_Addr::sap_any) == -1)
+    ACE_ERROR_RETURN ((LM_ERROR,
+                       "%p\n to %s",
+                       "connect",
+                       this->data_filename_),
+                      -1);
+
+  char str[MAX_UINT32_STR_LEN];
+
+  int len = file.recv (str, MAX_UINT32_STR_LEN);
+  str[len] = 0;
+
+  if (len > 0)
+    this->cans_ = ACE_OS::atoi (str);
+  else
+    this->cans_ = 0;
+  return 0;
+}