*** Consumer_Router.cpp.~1~	Mon Dec 18 00:45:38 1995
--- Consumer_Router.cpp	Tue Dec 19 02:07:36 1995
***************
*** 74,84 ****
      ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
  
    while (this->getq (mb) > 0)
!     if (this->put_next (mb) == -1)
!       ACE_ERROR_RETURN ((LM_ERROR, 
! 			 "(%t) put_next failed in %s\n", 
! 			 this->name ()), -1);
! 
    return 0;
    /* Note the implicit OS::thr_exit() via destructor */
  }
--- 74,86 ----
      ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
  
    while (this->getq (mb) > 0)
!     {
!       ACE_DEBUG ((LM_DEBUG, "Consumer_Router is routing via send_peers\n"));
!       if (this->send_peers (mb) == -1)
! 	ACE_ERROR_RETURN ((LM_ERROR, 
! 			   "(%t) send_peers failed in %s\n", 
! 			   this->name ()), -1);
!     }
    return 0;
    /* Note the implicit OS::thr_exit() via destructor */
  }
***************
*** 96,105 ****
        return this->put_next (mb);
      }
    else
!     {
!       ACE_DEBUG ((LM_DEBUG, "Consumer_Router is routing via send_peers\n"));
!       return this->send_peers (mb);
!     }
  }
  
  /* Return information about the Client_Router ACE_Module. */
--- 98,106 ----
        return this->put_next (mb);
      }
    else
!     // Queue up the message, which will be processed by
!     // Consumer_Router::svc().
!     return this->putq (mb);
  }
  
  /* Return information about the Client_Router ACE_Module. */
*** Supplier_Router.cpp.~1~	Mon Dec 18 00:45:38 1995
--- Supplier_Router.cpp	Tue Dec 19 02:09:24 1995
***************
*** 33,47 ****
    assert (this->is_writer ());
  
    ACE_Thread_Control tc (this->thr_mgr_);
!   ACE_Message_Block *message_block = 0;
  
    if (options.debug ())
      ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
  
!   while (this->getq (message_block) > 0)
!     if (this->put_next (message_block) == -1)
!       ACE_ERROR_RETURN ((LM_ERROR, "(%t) put_next failed in %s\n", this->name ()), -1);
! 
    return 0;
    /* Note the implicit OS::thr_exit() via ACE_Thread_Control's destructor */
  }
--- 33,51 ----
    assert (this->is_writer ());
  
    ACE_Thread_Control tc (this->thr_mgr_);
!   ACE_Message_Block *mb = 0;
  
    if (options.debug ())
      ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
  
!   while (this->getq (mb) > 0)
!     {
!       ACE_DEBUG ((LM_DEBUG, "Consumer_Router is routing via send_peers\n"));
!       if (this->send_peers (mb) == -1)
! 	ACE_ERROR_RETURN ((LM_ERROR, 
! 			   "(%t) send_peers failed in %s\n", 
! 			   this->name ()), -1);
!     }
    return 0;
    /* Note the implicit OS::thr_exit() via ACE_Thread_Control's destructor */
  }
***************
*** 90,96 ****
        return this->put_next (mb);
      }
    else
!     return this->send_peers (mb);
  }
  
  /* Return information about the Supplier_Router ACE_Module. */
--- 94,102 ----
        return this->put_next (mb);
      }
    else
!     // Queue up the message, which will be processed by
!     // Supplier_Router::svc().
!     return this->putq (mb);
  }
  
  /* Return information about the Supplier_Router ACE_Module. */
