//%2006////////////////////////////////////////////////////////////////////////
//
// Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
// Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
// IBM Corp.; EMC Corporation, The Open Group.
// Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
// Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
// EMC Corporation; VERITAS Software Corporation; The Open Group.
// Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
// EMC Corporation; Symantec Corporation; The Open Group.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to
// deal in the Software without restriction, including without limitation the
// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
// sell copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
// 
// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
// ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
//==============================================================================
//
// Author: Mike Day (mdday@us.ibm.com)
//
// Modified By: Carol Ann Krug Graves, Hewlett-Packard Company
//                  (carolann_graves@hp.com)
//
//%/////////////////////////////////////////////////////////////////////////////

#include "BinaryMessageHandler.h"
#include <Pegasus/Common/Thread.h>

PEGASUS_NAMESPACE_BEGIN

BinaryMessageHandler::BinaryMessageHandler(MessageQueueService *output_q)
   : Base(PEGASUS_QUEUENAME_BINARY_HANDLER),
     _outputQueue(output_q),
     _msg_q()
{

}

BinaryMessageHandler::~BinaryMessageHandler(void)
{
   
}


Boolean BinaryMessageHandler::messageOK(const Message * msg)
{
   return Base::messageOK(msg);
}

void BinaryMessageHandler::handleEnqueue(void)
{
   Message *msg = dequeue();
   handleEnqueue(msg);
}

void BinaryMessageHandler::handleEnqueue(Message * message)
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnqueue(Message *)");
   PEGASUS_ASSERT(message != 0);

   AsyncRequest * asyncRequest;
   AsyncOpNode * op;
   
   message->_async = 0;
   
   PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4, 
		    "Converting legacy message to AsyncLegacyOperationStart");
   op = this->get_op();
   asyncRequest = new AsyncLegacyOperationStart(
      op,
      this->getQueueId(),
      message,
      this->getQueueId());
   op->_flags |= ASYNC_OPFLAGS_FIRE_AND_FORGET;
   

   _handle_async_request(asyncRequest);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::_handle_async_request(AsyncRequest * request)
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::_handle_async_request");

   PEGASUS_ASSERT(request != 0 && request->op != 0 );

   if(request->getType() == async_messages::ASYNC_LEGACY_OP_START || 
      request->getType() == async_messages::ASYNC_LEGACY_OP_RESULT)
   {        
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
		       "Processing ASYNC_LEGACY_OP_* Message.");
      request->op->processing();
      try
      {
	 _msg_q.enqueue(request->op);
      }
      catch(ListFull & )
      {
	 PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
			  "Internal DQueue Full.");
	 Base::_handle_async_request(request);
	 PEG_METHOD_EXIT();
	 return;
      }
       
      catch(...)
      {
	 PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
			  "Internal DQueue Error.");
	 Base::_handle_async_request(request);
	 PEG_METHOD_EXIT();
	 return;
      }
       
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
		       "Allocating pooled thread to handle binary message.");
      if (_thread_pool->allocate_and_awaken(
	 (void *)this, BinaryMessageHandler::handle_binary_message)!=PEGASUS_THREAD_OK)
	{
 	    Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
            	"Not enough threads to handle binary message.");
 
	    Tracer::trace(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL2,
		"Could not allocate thread for %s. " \
 		"Queue has %d messages waiting. ",
                getQueueName(),
 		_msg_q.count());
	}	
   }
   else if(request->getType() == async_messages::CIMSERVICE_STOP)
   {
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
		       "Handling CIMServer Stop Message");
      Base::_handle_async_request(request);
   }
   else
   {
      // pass all other operations to the default handler
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
		       "Passing message to parent.");
#ifdef BINARYMESSAGEHANDLER_DEBUG
      PEGASUS_STD(cout) << "Unexpected Message: type " << request->getType() << PEGASUS_STD(endl);
#endif

      Base::_handle_async_request(request);
   }

   PEG_METHOD_EXIT();

   return;
}

ThreadReturnType PEGASUS_THREAD_CDECL
BinaryMessageHandler::handle_binary_message(void* parm)
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
      "BinaryMessageHandler::handle_binary_message");

   BinaryMessageHandler* myself =
      reinterpret_cast<BinaryMessageHandler*>(parm);
   PEGASUS_ASSERT(myself != 0);

   AsyncOpNode *op;
   try
   {
      op = myself->_msg_q.dequeue();
   }
   catch(...)
   {
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL2,
         "Internal DQueue Error.");
      PEG_METHOD_EXIT();
      return(0);
   }

   PEGASUS_ASSERT(op != 0);

   // we only receive ASYNC_LEGACY_OP_START and
   // ASYNC_LEGACY_OP_RESULT messages

   Message *legacy = 0;
   AsyncMessage *msg = 0;

   try
   {
      // if there is a response, dispatch the response
      if (op->_response.get() != 0)
      {
         msg = static_cast<AsyncMessage *>(op->_response.get());
         legacy = static_cast<AsyncLegacyOperationResult*>(msg)->get_result();
      }
      else
      {
         // there is no response so there has to be a request
         if (op->_request.get() == 0)
         {
            PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL2,
               "Received OpNode with no messages.");
            PEG_METHOD_EXIT();
            return(0);
         }
         // dispatch the request
         msg = static_cast<AsyncMessage *>(op->_request.get());
         legacy = static_cast<AsyncLegacyOperationStart *>(msg)->get_action();
      }
      if(msg && legacy)
      {
         legacy->_async = 0;

         switch(legacy->getType())
         {
            case CIM_CREATE_CLASS_REQUEST_MESSAGE:
               myself->handleCreateClassRequest(
                  op, (CIMCreateClassRequestMessage *)legacy);
               break;
            case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
               myself->handleCreateInstanceRequest(
                  op, (CIMCreateInstanceRequestMessage *)legacy);
               break;
            case CIM_MODIFY_CLASS_REQUEST_MESSAGE:
               myself->handleModifyClassRequest(
                  op, (CIMModifyClassRequestMessage *)legacy);
               break;
            case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
               myself->handleModifyInstanceRequest(
                  op, (CIMModifyInstanceRequestMessage *)legacy);
               break;
            case CIM_ENUMERATE_CLASSES_REQUEST_MESSAGE: //10
               myself->handleEnumerateClassesRequest(
                  op, (CIMEnumerateClassesRequestMessage *)legacy);
               break;
            case CIM_ENUMERATE_CLASS_NAMES_REQUEST_MESSAGE:
               myself->handleEnumerateClassNamesRequest(
                  op, (CIMEnumerateClassNamesRequestMessage *)legacy);
               break;
            case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
               myself->handleEnumerateInstancesRequest(
                  op, (CIMEnumerateInstancesRequestMessage *)legacy);
               break;
            case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
               myself->handleEnumerateInstanceNamesRequest(
                  op, (CIMEnumerateInstanceNamesRequestMessage *)legacy);
               break;
            case CIM_EXEC_QUERY_REQUEST_MESSAGE:
               myself->handleExecQueryRequest(
                  op, (CIMExecQueryRequestMessage *)legacy);
               break;
            case CIM_ASSOCIATORS_REQUEST_MESSAGE:
               myself->handleAssociatorsRequest(
                  op, (CIMAssociatorsRequestMessage *)legacy);
               break;
            case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
               myself->handleAssociatorNamesRequest(
                  op, (CIMAssociatorNamesRequestMessage *)legacy);
               break;
            case CIM_REFERENCES_REQUEST_MESSAGE:
               myself->handleReferencesRequest(
                  op, (CIMReferencesRequestMessage *)legacy);
               break;
            case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
               myself->handleReferenceNamesRequest(
                  op, (CIMReferenceNamesRequestMessage *)legacy);
               break;
            case CIM_GET_PROPERTY_REQUEST_MESSAGE:
               myself->handleGetPropertyRequest(
                  op, (CIMGetPropertyRequestMessage *)legacy);
               break;
            case CIM_SET_PROPERTY_REQUEST_MESSAGE:
               myself->handleSetPropertyRequest(
                  op, (CIMSetPropertyRequestMessage *)legacy);
               break;
            case CIM_GET_QUALIFIER_REQUEST_MESSAGE:
               myself->handleGetQualifierRequest(
                  op, (CIMGetQualifierRequestMessage *)legacy);
               break;
            case CIM_SET_QUALIFIER_REQUEST_MESSAGE:
               myself->handleSetQualifierRequest(
                  op, (CIMSetQualifierRequestMessage *)legacy);
               break;
            case CIM_DELETE_QUALIFIER_REQUEST_MESSAGE:
               myself->handleDeleteQualifiersRequest(
                  op, (CIMDeleteQualifierRequestMessage *)legacy);
               break;
            case CIM_ENUMERATE_QUALIFIERS_REQUEST_MESSAGE:
               myself->handleEnumerateQualifiersRequest(
                  op, (CIMEnumerateQualifiersRequestMessage *)legacy);
               break;
            case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
               myself->handleInvokeMethodRequest(
                  op, (CIMInvokeMethodRequestMessage *)legacy);
               break;
            //**** response messages ****//
            case CIM_GET_CLASS_RESPONSE_MESSAGE:
               myself->handleGetClassResponse(
                  op, (CIMGetClassResponseMessage *)legacy);
               break;
            case CIM_GET_INSTANCE_RESPONSE_MESSAGE:
               myself->handleGetInstanceResponse(
                  op, (CIMGetInstanceResponseMessage *)legacy);
               break;
            case CIM_DELETE_CLASS_RESPONSE_MESSAGE:
               myself->handleDeleteClassResponse(
                  op, (CIMDeleteClassResponseMessage *)legacy);
               break;
            case CIM_DELETE_INSTANCE_RESPONSE_MESSAGE:
               myself->handleDeleteInstanceResponse(
                  op, (CIMDeleteInstanceResponseMessage *)legacy);
               break;
            case CIM_CREATE_CLASS_RESPONSE_MESSAGE:
               myself->handleCreateClassResponse(
                  op, (CIMCreateClassResponseMessage *)legacy);
               break;
            case CIM_CREATE_INSTANCE_RESPONSE_MESSAGE:
               myself->handleCreateInstanceResponse(
                  op, (CIMCreateInstanceResponseMessage *)legacy);
               break;
            case CIM_MODIFY_CLASS_RESPONSE_MESSAGE:
               myself->handleModifyClassResponse(
                  op, (CIMModifyClassResponseMessage *)legacy);
               break;
            case CIM_MODIFY_INSTANCE_RESPONSE_MESSAGE:
               myself->handleModifyInstanceResponse(
                  op, (CIMModifyInstanceResponseMessage *)legacy);
               break;
            case CIM_ENUMERATE_CLASSES_RESPONSE_MESSAGE:
               myself->handleEnumerateClassesResponse(
                  op, (CIMEnumerateClassesResponseMessage *)legacy);
               break;
            case CIM_ENUMERATE_CLASS_NAMES_RESPONSE_MESSAGE:
               myself->handleEnumerateClassNamesResponse(
                  op, (CIMEnumerateClassNamesResponseMessage *)legacy);
               break;
            case CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE:
               myself->handleEnumerateInstancesResponse(
                  op, (CIMEnumerateInstancesResponseMessage *)legacy);
               break;
            case CIM_ENUMERATE_INSTANCE_NAMES_RESPONSE_MESSAGE:
               myself->handleEnumerateInstanceNamesResponse(
                  op, (CIMEnumerateInstanceNamesResponseMessage *)legacy);
               break;
            case CIM_EXEC_QUERY_RESPONSE_MESSAGE:
               myself->handleExecQueryResponse(
                  op, (CIMExecQueryResponseMessage *)legacy);
               break;
            case CIM_ASSOCIATORS_RESPONSE_MESSAGE:
               myself->handleAssociatorsResponse(
                  op, (CIMAssociatorsResponseMessage *)legacy);
               break;
            case CIM_ASSOCIATOR_NAMES_RESPONSE_MESSAGE:
               myself->handleAssociatorNamesResponse(
                  op, (CIMAssociatorNamesResponseMessage *)legacy);
               break;
            case CIM_REFERENCES_RESPONSE_MESSAGE:
               myself->handleReferencesResponse(
                  op, (CIMReferencesResponseMessage *)legacy);
               break;
            case CIM_REFERENCE_NAMES_RESPONSE_MESSAGE:
               myself->handleReferenceNamesResponse(
                  op, (CIMReferenceNamesResponseMessage *)legacy);
               break;
            case CIM_GET_PROPERTY_RESPONSE_MESSAGE:
               myself->handleGetPropertyResponse(
                  op, (CIMGetPropertyResponseMessage *)legacy);
               break;
            case CIM_SET_PROPERTY_RESPONSE_MESSAGE:
               myself->handleSetPropertyResponse(
                  op, (CIMSetPropertyResponseMessage *)legacy);
               break;
            case CIM_GET_QUALIFIER_RESPONSE_MESSAGE:
               myself->handleGetQualifierResponse(
                  op, (CIMGetQualifierResponseMessage *)legacy);
               break;
            case CIM_SET_QUALIFIER_RESPONSE_MESSAGE:
               myself->handleSetQualifierResponse(
                  op, (CIMSetQualifierResponseMessage *)legacy);
               break;
            case CIM_DELETE_QUALIFIER_RESPONSE_MESSAGE:
               myself->handleDeleteQualifierResponse(
                  op, (CIMDeleteQualifierResponseMessage *)legacy);
               break;
            case CIM_ENUMERATE_QUALIFIERS_RESPONSE_MESSAGE:
               myself->handleEnumerateQualifiersResponse(
                  op, (CIMEnumerateQualifiersResponseMessage *)legacy);
               break;
            case CIM_INVOKE_METHOD_RESPONSE_MESSAGE:
               myself->handleInvokeMethodResponse(
                  op, (CIMInvokeMethodResponseMessage *)legacy);
               break;

            // unexpected requests
            case CIM_PROCESS_INDICATION_REQUEST_MESSAGE:
            case CIM_HANDLE_INDICATION_REQUEST_MESSAGE:
            case CIM_NOTIFY_PROVIDER_REGISTRATION_REQUEST_MESSAGE:
            case CIM_NOTIFY_PROVIDER_TERMINATION_REQUEST_MESSAGE:
            case CIM_NOTIFY_PROVIDER_ENABLE_REQUEST_MESSAGE:
            case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE:
            case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE:
            case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE:
            case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:
            case CIM_DISABLE_MODULE_REQUEST_MESSAGE:
            case CIM_ENABLE_MODULE_REQUEST_MESSAGE:

            case CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE:

            case CIM_NOTIFY_CONFIG_CHANGE_REQUEST_MESSAGE:

            case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE:
            case CIM_GET_CLASS_REQUEST_MESSAGE:
            case CIM_GET_INSTANCE_REQUEST_MESSAGE:
            case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:
            case CIM_DELETE_CLASS_REQUEST_MESSAGE:
            case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
               PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
                  "Received Unexpected legacy request message.");
               myself->_handleRequest(op, legacy);
               break;

            // unexpected replies
            case CIM_PROCESS_INDICATION_RESPONSE_MESSAGE:
            case CIM_NOTIFY_PROVIDER_REGISTRATION_RESPONSE_MESSAGE:
            case CIM_NOTIFY_PROVIDER_TERMINATION_RESPONSE_MESSAGE:
            case CIM_HANDLE_INDICATION_RESPONSE_MESSAGE:
            case CIM_CREATE_SUBSCRIPTION_RESPONSE_MESSAGE:
            case CIM_MODIFY_SUBSCRIPTION_RESPONSE_MESSAGE:
            case CIM_DELETE_SUBSCRIPTION_RESPONSE_MESSAGE:
            case CIM_SUBSCRIPTION_INIT_COMPLETE_RESPONSE_MESSAGE:
            case CIM_DISABLE_MODULE_RESPONSE_MESSAGE:
            case CIM_ENABLE_MODULE_RESPONSE_MESSAGE:
            case CIM_STOP_ALL_PROVIDERS_RESPONSE_MESSAGE:
            case CIM_NOTIFY_PROVIDER_ENABLE_RESPONSE_MESSAGE:
            case CIM_INITIALIZE_PROVIDER_RESPONSE_MESSAGE:
            case CIM_NOTIFY_CONFIG_CHANGE_RESPONSE_MESSAGE:
               break;
            case CIM_EXPORT_INDICATION_RESPONSE_MESSAGE:
            default:
               PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
                  "Received Unexpected legacy response message.");
               myself->_handleResponse(op, legacy);
               break;
         }
      }
      else
      {
         PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
            "Damaged or uninitialized AsyncOpNode received.");
      }
   }
   catch (const Exception& e)
   {
      PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
         "Caught exception: \"" + e.getMessage() +
            "\".  Exiting handle_binary_message.");
   }
   catch (...)
   {
      PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
         "Caught unrecognized exception.  Exiting handle_binary_message.");
   }

   PEG_METHOD_EXIT();
   return(0);
}

// requests always go to the output queue 
void 
BinaryMessageHandler::_handleRequest(AsyncOpNode *op, Message *msg) 
   throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
      "BinaryMessageHandler::_handleRequest(AsyncOpNode *, Message *)");

   AsyncRequest *async_request =
      static_cast<AsyncRequest *>(op->removeRequest());
   
   msg->_async = 0;
   try 
   {
      _outputQueue->enqueue(msg) ;
   }
   catch(...)
   {
      // Should this exception really just be ignored?
      // It seems like binary_message_handler should catch it.
      PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
         "Unrecognized exception caught and ignored by _handleRequest().");
   }
   
   delete async_request;
   
   _complete_op_node(op, ASYNC_OPSTATE_COMPLETE, 0, 0);
   PEG_METHOD_EXIT();
}

// responses have their destination queue id in the message
void 
BinaryMessageHandler::_handleResponse(AsyncOpNode *op, Message *msg)
   throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::_handleResponse(AsyncOpNode *, Message *)");

   if (op->_response.get() != 0)
   {
      AsyncReply* asyncReply = static_cast<AsyncReply *>(op->removeResponse());
      delete asyncReply;
   }
   msg->_async = 0;
   
   MessageQueue *dest = MessageQueue::lookup(((CIMRequestMessage *)msg)->queueIds.top());
   if(dest == 0)
   {
      PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4,
		       "Bad or non-existent Queue ID for desination in legacy message.");
      delete msg;
   }
   else
   {
      try
      {
	 
	 dest->enqueue(msg);
      }
      catch(...)
      {
          // Should this exception really just be ignored?
          // It seems like binary_message_handler should catch it.
          PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
             "Unrecognized exception caught and ignored by _handleResponse().");
      }
      
   }
   _complete_op_node(op, ASYNC_OPSTATE_COMPLETE, 0, 0);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleCreateClassRequest(
   AsyncOpNode *op, 
   CIMCreateClassRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleCreateClassRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

      
void BinaryMessageHandler::handleGetClassRequest(
   AsyncOpNode *op,
   CIMGetClassRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetClassRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

      
void BinaryMessageHandler::handleModifyClassRequest(
   AsyncOpNode *op, 
   CIMModifyClassRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleModifyClassRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateClassNamesRequest(
   AsyncOpNode *op,
   CIMEnumerateClassNamesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateClassNamesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateClassesRequest(
   AsyncOpNode *op,
   CIMEnumerateClassesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateClassRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}


void BinaryMessageHandler::handleDeleteClassRequest(
   AsyncOpNode *op,
   CIMDeleteClassRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteClassRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleCreateInstanceRequest(
   AsyncOpNode *op,
   CIMCreateInstanceRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleCreateInstanceRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetInstanceRequest(
   AsyncOpNode *op,
   CIMGetInstanceRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetInstanceRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleModifyInstanceRequest(
   AsyncOpNode *op,
   CIMModifyInstanceRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleModifyInstanceRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateInstanceNamesRequest(
   AsyncOpNode *op,
   CIMEnumerateInstanceNamesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateInstanceNamesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateInstancesRequest(
   AsyncOpNode *op,
   CIMEnumerateInstancesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateInstancesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleDeleteInstanceRequest(
   AsyncOpNode *op,
   CIMDeleteInstanceRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteInstanceRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleSetQualifierRequest(
   AsyncOpNode *op,
   CIMSetQualifierRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleSetQualifierRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleGetQualifierRequest(
   AsyncOpNode *op,
   CIMGetQualifierRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetQualifierRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleEnumerateQualifiersRequest(
   AsyncOpNode *op,
   CIMEnumerateQualifiersRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateQualifiersRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleDeleteQualifiersRequest(
   AsyncOpNode *op,
   CIMDeleteQualifierRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteQualifiersRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleReferenceNamesRequest(
   AsyncOpNode *op,
   CIMReferenceNamesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleReferenceNamesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleReferencesRequest(
   AsyncOpNode *op,
   CIMReferencesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleReferencesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleAssociatorNamesRequest(
   AsyncOpNode *op,
   CIMAssociatorNamesRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleAssociatorNamesRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleAssociatorsRequest(
   AsyncOpNode *op,
   CIMAssociatorsRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleAssociatorsRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetPropertyRequest(
   AsyncOpNode *op,
   CIMGetPropertyRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetPropertyRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleSetPropertyRequest(
   AsyncOpNode *op,
   CIMSetPropertyRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleSetPropertyRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleExecQueryRequest(
   AsyncOpNode *op,
   CIMExecQueryRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleExecQueryRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
 
void BinaryMessageHandler::handleInvokeMethodRequest(
   AsyncOpNode *op,
   CIMInvokeMethodRequestMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleInvokeMethodRequest()");
   _handleRequest(op, msg);
   PEG_METHOD_EXIT();
}
      
// **** Response Messages **** //
      
void BinaryMessageHandler::handleCreateClassResponse(
   AsyncOpNode *op,
   CIMCreateClassResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleCreateClassResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetClassResponse(
   AsyncOpNode *op,
   CIMGetClassResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetClassResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleModifyClassResponse(
   AsyncOpNode *op,
   CIMModifyClassResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleModifyClassResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleEnumerateClassNamesResponse(
   AsyncOpNode *op,
   CIMEnumerateClassNamesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateClassNamesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateClassesResponse(
   AsyncOpNode *op,
   CIMEnumerateClassesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateClassesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleDeleteClassResponse(
   AsyncOpNode *op,
   CIMDeleteClassResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteClassResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleCreateInstanceResponse(
   AsyncOpNode *op,
   CIMCreateInstanceResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleCreateInstanceResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetInstanceResponse(
   AsyncOpNode *op,
   CIMGetInstanceResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetInstanceResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleModifyInstanceResponse(
   AsyncOpNode *op,
   CIMModifyInstanceResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleModifyInstanceResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateInstanceNamesResponse(
   AsyncOpNode *op,
   CIMEnumerateInstanceNamesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateInstanceNamesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleEnumerateInstancesResponse(
   AsyncOpNode *op,
   CIMEnumerateInstancesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateInstancesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleDeleteInstanceResponse(
   AsyncOpNode *op,
   CIMDeleteInstanceResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteInstanceResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetPropertyResponse(
   AsyncOpNode *op,
   CIMGetPropertyResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetPropertyResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleSetPropertyResponse(
   AsyncOpNode *op,
   CIMSetPropertyResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleSetPropertyResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}


void BinaryMessageHandler::handleSetQualifierResponse(
   AsyncOpNode *op,
   CIMSetQualifierResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleSetQualifierResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleGetQualifierResponse(
   AsyncOpNode *op,
   CIMGetQualifierResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleGetQualifierResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}
      
void BinaryMessageHandler::handleEnumerateQualifiersResponse(
   AsyncOpNode *op,
   CIMEnumerateQualifiersResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleEnumerateQualifiersResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleDeleteQualifierResponse(
   AsyncOpNode *op,
   CIMDeleteQualifierResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleDeleteQualifierResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleReferenceNamesResponse(
   AsyncOpNode *op,
   CIMReferenceNamesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleReferenceNamesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleReferencesResponse(
   AsyncOpNode *op,
   CIMReferencesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleReferencesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleAssociatorNamesResponse(
   AsyncOpNode *op,
   CIMAssociatorNamesResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleAssociatorNamesResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleAssociatorsResponse(
   AsyncOpNode *op,
   CIMAssociatorsResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleAssociatorsResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

void BinaryMessageHandler::handleExecQueryResponse(
   AsyncOpNode *op,
   CIMExecQueryResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleExecQueryResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}


void BinaryMessageHandler::handleInvokeMethodResponse(
   AsyncOpNode *op,
   CIMInvokeMethodResponseMessage *msg) throw()
{
   PEG_METHOD_ENTER(TRC_BINARY_MSG_HANDLER,
		    "BinaryMessageHandler::handleInvokeMethodResponse()");
   _handleResponse(op, msg);
   PEG_METHOD_EXIT();
}

PEGASUS_NAMESPACE_END