Compressed the Trading Service into a fewer number of files by having

related classes share a file.

1 files changed, 243 insertions, 3 deletions

diff --git a/TAO/orbsvcs/orbsvcs/Trader/Constraint_Interpreter.cpp b/TAO/orbsvcs/orbsvcs/Trader/Constraint_Interpreter.cpp
index 4077030341f..0e953941a94 100644
--- a/TAO/orbsvcs/orbsvcs/Trader/Constraint_Interpreter.cpp
+++ b/TAO/orbsvcs/orbsvcs/Trader/Constraint_Interpreter.cpp
@@ -14,10 +14,66 @@
 // 
 // ========================================================================
 
-
+#include "ace/OS.h"
 #include "Constraint_Interpreter.h"
-#include <ctype.h>
-#include <stdio.h>
+
+  // *************************************************************
+  // TAO_Interpreter
+  // *************************************************************
+
+TAO_Interpreter::~TAO_Interpreter (void)
+{
+  delete root_;
+}
+
+int
+TAO_Interpreter::build_tree(const char* constraints)
+{
+  TAO_Lex_String_Input::reset((char*)constraints);  
+  int return_value = 0;
+
+  yyval.constraint_ = 0;
+  return_value = ::yyparse();
+  
+  if (return_value == 0 && yyval.constraint_ != 0)
+    this->root_ = yyval.constraint_;
+  else
+    {
+      while (yylex() > 0)
+	;
+      this->root_ = 0;
+    }
+  
+  return return_value;
+}
+
+
+int
+TAO_Interpreter::is_empty_string(const char* str)
+{
+  int return_value = 0;
+
+  if (str != 0)
+    {
+      int i = 0;
+      while (str[i] != '\0')
+	{
+	  if (str[i] != ' ')
+	    break;
+
+	  i++;
+	}
+
+      if (str[i] == '\0')
+	return_value = 1;
+    }
+
+  return return_value;
+}
+
+  // *************************************************************
+  // TAO_Constraint_Interpreter
+  // *************************************************************
 
 TAO_Constraint_Interpreter::
 TAO_Constraint_Interpreter(CosTradingRepos::ServiceTypeRepository::TypeStruct* ts,
@@ -75,3 +131,187 @@ TAO_Constraint_Interpreter::evaluate(TAO_Constraint_Evaluator& evaluator)
   return evaluator.evaluate_constraint (this->root_);
 }
 
+  // *************************************************************
+  // TAO_Preference_Interpreter
+  // *************************************************************
+
+const CORBA::Double TRADER_MAX_DOUBLE = 1.79769313486231570e+308;
+
+TAO_Preference_Interpreter::
+TAO_Preference_Interpreter(CosTradingRepos::ServiceTypeRepository::TypeStruct* ts,
+			   const char* preference,
+			   CORBA::Environment& _env)
+  TAO_THROW_SPEC ((CosTrading::Lookup::IllegalPreference))
+  : TAO_Interpreter ()
+{
+  TAO_Constraint_Validator type_checker(ts);
+
+  if (TAO_Interpreter::is_empty_string(preference))
+    this->root_ = new TAO_Noop_Constraint(TAO_FIRST);
+  else
+    {
+      if (this->build_tree (preference) != 0)
+	TAO_THROW (CosTrading::Lookup::IllegalPreference (preference));	  
+
+      if (type_checker.validate (this->root_) == -1)
+	TAO_THROW (CosTrading::Lookup::IllegalPreference (preference));
+    }
+}
+
+TAO_Preference_Interpreter::
+TAO_Preference_Interpreter(TAO_Constraint_Validator& validator,
+			   const char* preference,
+			   CORBA::Environment& _env)
+  TAO_THROW_SPEC ((CosTrading::Lookup::IllegalPreference))
+    : TAO_Interpreter ()
+{
+  if (TAO_Interpreter::is_empty_string(preference))
+    this->root_ = new TAO_Noop_Constraint(TAO_FIRST);
+  else
+    {
+      if (this->build_tree (preference) != 0)
+	TAO_THROW (CosTrading::Lookup::IllegalPreference (preference));	  
+      
+      if (validator.validate (this->root_) == -1)
+	TAO_THROW (CosTrading::Lookup::IllegalPreference (preference));
+    }
+}
+
+TAO_Preference_Interpreter::~TAO_Preference_Interpreter()
+{
+}
+
+void 
+TAO_Preference_Interpreter::
+order_offer (CosTrading::OfferId offer_id,
+	     CosTrading::Offer* offer)
+{
+  TAO_Constraint_Evaluator evaluator(offer);
+  this->order_offer (offer_id, offer, evaluator);
+}
+
+void 
+TAO_Preference_Interpreter::
+order_offer (CosTrading::OfferId offer_id,
+	     CosTrading::Offer* offer,
+	     TAO_Constraint_Evaluator& evaluator)
+{
+  if (this->root_ != 0)
+    {
+      Preference_Info pref_info;
+      TAO_Expression_Type expr_type = this->root_->expr_type ();
+      
+      pref_info.offer_ = offer;
+      pref_info.offer_id_ = offer_id;
+      pref_info.evaluated_ = CORBA::B_TRUE;
+
+      if (evaluator.evaluate_preference (this->root_, pref_info.value_) == 0)
+	{	  
+	  // If the evaluation succeeds, insert the node into the
+	  // correct place in the queue.
+	  TAO_Expression_Type expr_type = this->root_->expr_type ();
+
+	  if (expr_type == TAO_FIRST)
+	    this->offers_.enqueue_tail (pref_info);
+	  else
+	    this->offers_.enqueue_head (pref_info);
+
+	  if (expr_type == TAO_MIN || expr_type == TAO_MAX)
+	    {	      
+	      Ordered_Offers::ITERATOR offer_iter (this->offers_);
+
+	      // Push the new item down the list until the min/max
+	      // criterion is satisfied. Observe the evaluation
+	      // failed / evaluation suceeded partion in the list.
+	      offer_iter.advance ();
+	      for (int i = 1;
+		   ! offer_iter.done ();
+		   offer_iter.advance (), i++)
+		{
+		  Preference_Info* current_offer;
+		  offer_iter.next (current_offer);
+
+		  // Maintain the sorted order in the first partition.
+		  if (current_offer->evaluated_ == CORBA::B_TRUE &&
+		      ((expr_type == TAO_MIN &&
+		       pref_info.value_ > current_offer->value_) ||
+		      (expr_type == TAO_MAX &&
+		       pref_info.value_ < current_offer->value_)))
+		    {
+		      this->offers_.set (*current_offer, i - 1);
+		      this->offers_.set (pref_info, i);
+		    }
+		  else
+		    break;
+		}
+	    }		
+	}
+      else
+	{
+	  // If the evaluation fails, just tack the sucker onto the
+	  // end of the queue.
+	  pref_info.evaluated_ = CORBA::B_FALSE;
+	  this->offers_.enqueue_tail (pref_info);
+	}
+    }
+}
+
+int
+TAO_Preference_Interpreter::
+remove_offer (CosTrading::OfferId& offer_id,
+	      CosTrading::Offer*& offer)
+{
+  int return_value = -1;
+  Preference_Info pref_info;
+
+  return_value = this->offers_.dequeue_head (pref_info);
+
+  if (return_value == 0)
+    {
+      offer = pref_info.offer_;
+      offer_id = pref_info.offer_id_;
+    }
+  
+  return return_value;
+}
+
+int 
+TAO_Preference_Interpreter::num_offers(void)
+{
+  return this->offers_.size();
+}
+
+  // *************************************************************
+  // Ugly Lex/Yacc Stuff
+  // *************************************************************
+
+char* TAO_Lex_String_Input::string_ = 0;
+char* TAO_Lex_String_Input::current_ = 0;
+char* TAO_Lex_String_Input::end_ = 0;
+
+// Routine to have Lex read its input from the constraint string.
+
+int
+TAO_Lex_String_Input::copy_into(char* buf, int max_size)
+{
+  int chars_left =  TAO_Lex_String_Input::end_ - TAO_Lex_String_Input::current_;
+  int n = (max_size > chars_left) ? chars_left : max_size;
+
+  
+  if (n > 0)
+    {
+      memcpy(buf, TAO_Lex_String_Input::current_, n);
+      TAO_Lex_String_Input::current_ += n;
+    }
+  
+  return n;
+}
+
+void
+TAO_Lex_String_Input::reset(char* input_string)
+{    
+  TAO_Lex_String_Input::string_ = input_string;
+  TAO_Lex_String_Input::current_ = input_string;
+  TAO_Lex_String_Input::end_ = input_string +
+    ACE_OS::strlen(TAO_Lex_String_Input::string_);
+}