servers/registrar/MessageDeliverer.cpp

35 // per port sanity limits
76 DefaultMessagingTargetSet::Next(port_id &port, int32 &token)
81 	port = fTargets[fNextIndex].port;
112 SingleMessagingTargetSet::SingleMessagingTargetSet(port_id port, int32 token)
114 	  fPort(port),
134 SingleMessagingTargetSet::Next(port_id &port, int32 &token)
139 	port = fPort;
328 /*!	\brief Represents a full target port, queuing the not yet delivered
359 PRINT("MessageDeliverer::TargetPort::PushMessage(port: %" B_PRId32 ", %p, %"
393 PRINT("MessageDeliverer::TargetPort::PopMessage(): port: %" B_PRId32 ", %p\n",
408 PRINT("MessageDeliverer::TargetPort::DropTimedOutMessages(): port: %" B_PRId32
436 PRINT("MessageDeliverer::TargetPort::_EnforceLimits(): port: %" B_PRId32
443 PRINT("MessageDeliverer::TargetPort::_EnforceLimits(): port: %" B_PRId32
467 		   as the target port is full.
473 	The class maintains a TargetPort for each target port which was full at the
505 	// create the target port map
566 	messages pending for the target port). If that fails due to a full target
567 	port, the message is queued for later delivery.
574 	- \c B_OK, if sending the message succeeded or if the target port was
590 	(if there are not already messages pending for a target port). If that
591 	fails due to a full target port, the message is queued for later delivery.
599 	  or if the target port was full and the message has been queued,
623 	(if there are not already messages pending for a target port). If that
624 	fails due to a full target port, the message is queued for later delivery.
634 	  or if the target port was full and the message has been queued,
665 		// get the target port
666 		TargetPort *port = _GetTargetPort(portID, true);
667 		if (!port)
671 		if (port->IsEmpty()) {
675 				_PutTargetPort(port);
679 			// if the port is not full, but an error occurred, we skip this target
681 				_PutTargetPort(port);
689 		status_t error = port->PushMessage(message, token);
690 		_PutTargetPort(port);
702 	// get the port from the map
710 	// create a port
711 	TargetPort *port = new(nothrow) TargetPort(portID);
712 	if (!port)
714 	(*fTargetPorts)[portID] = port;
716 	return port;
721 MessageDeliverer::_PutTargetPort(TargetPort *port)
723 	if (!port)
726 	if (port->IsEmpty()) {
727 		fTargetPorts->erase(port->PortID());
728 		delete port;
738 //PRINT("MessageDeliverer::_SendMessage(%p, port: %ld, token: %ld): %lx\n",
763 			TargetPort *port = it->second;
766 			port->DropTimedOutMessages();
770 			while (Message *message = port->PeekMessage(token)) {
773 					error = _SendMessage(message, port->PortID(), token);
776 //					PRINT("MessageDeliverer::_DelivererThread(): port %ld, "
777 //						"message %p timed out\n", port->PortID(), message);
781 					port->PopMessage();
783 					// no luck yet -- port is still full
786 					// unexpected error -- probably the port is gone
792 			// next port
793 			if (portError || port->IsEmpty()) {
796 				delete port;