servers/registrar/MessageDeliverer.cpp

23 #include "MessageDeliverer.h"
31 MessageDeliverer *MessageDeliverer::sDeliverer = NULL;
162 class MessageDeliverer::Message : public BReferenceable {
238 class MessageDeliverer::TargetMessage
239 	: public DoublyLinkedListLinkImpl<MessageDeliverer::TargetMessage> {
279 class MessageDeliverer::TargetMessageHandle {
336 class MessageDeliverer::TargetPort {
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
459 struct MessageDeliverer::TargetPortMap : public map<port_id, TargetPort*> {
465 /*!	\class MessageDeliverer
469 	For the user of the service only the MessageDeliverer::DeliverMessage()
480 MessageDeliverer::MessageDeliverer()
489 MessageDeliverer::~MessageDeliverer()
503 MessageDeliverer::Init()
511 	fDelivererThread = spawn_thread(MessageDeliverer::_DelivererThreadEntry,
524 MessageDeliverer::CreateDefault()
530 	MessageDeliverer *deliverer = new(nothrow) MessageDeliverer;
547 MessageDeliverer::DeleteDefault()
556 MessageDeliverer *
557 MessageDeliverer::Default()
579 MessageDeliverer::DeliverMessage(BMessage *message, BMessenger target,
603 MessageDeliverer::DeliverMessage(BMessage *message, MessagingTargetSet &targets,
638 MessageDeliverer::DeliverMessage(const void *messageData, int32 messageSize,
699 MessageDeliverer::TargetPort *
700 MessageDeliverer::_GetTargetPort(port_id portID, bool create)
721 MessageDeliverer::_PutTargetPort(TargetPort *port)
734 MessageDeliverer::_SendMessage(Message *message, port_id portID, int32 token)
738 //PRINT("MessageDeliverer::_SendMessage(%p, port: %ld, token: %ld): %lx\n",
745 MessageDeliverer::_DelivererThreadEntry(void *data)
747 	return ((MessageDeliverer*)data)->_DelivererThread();
752 MessageDeliverer::_DelivererThread()
776 //					PRINT("MessageDeliverer::_DelivererThread(): port %ld, "