servers/registrar/MessageRunnerManager.cpp

37 	among these a RunnerEvent added to the event queue. When the event is
39 	runner message to the respective target and schedules the event for the
85 	For each active message runner such an event is used. It invokes
101 	/*!	\brief Hook method invoked when the event is executed.
105 		\param queue The event queue executing the event.
142 		  event(NULL),
149 		The message and the event are delete.
154 		delete event;
203 	RunnerEvent	*event;			//!< Runner event for the message runner.
204 	bool		rescheduled;	/*!< Set to \c true when the event has been
225 	The manager's event queue must already have been stopped
230 	// The event queue should already be stopped, but must still exist.
231 	// If it is still running and an event gets executed after we've locked
235 		if (!fEventQueue->RemoveEvent(info->event))
236 			info->event = NULL;
297 	// create a new event
298 	RunnerEvent *event = NULL;
300 		event = new(nothrow) RunnerEvent(this, info);
301 		if (event) {
302 			info->event = event;
420 			eventRemoved = fEventQueue->RemoveEvent(info->event);
581 		// If the event is not in the event queue and has not been removed
583 		if (!eventRemoved && !fEventQueue->RemoveEvent(info->event))
584 			info->event = NULL;
672 /*!	\brief Invoked when a message runner's event is executed.
674 	If the message runner info is still valid and the event was not just
676 	and the event is rescheduled.
679 	\return \c true, if the event object shall be deleted, \c false otherwise.
690 		// If the event has been rescheduled after being removed from the
698 			// reschedule the event
706 				info->event = NULL;
713 		// event was removed from the event queue, but before we could acquire
714 		// the lock. Simply delete the event.
724 /*!	\brief Schedules the event for a message runner for the next time a
730 	\return \c true, if the event successfully been rescheduled, \c false,
731 			if either all messages have already been sent or the event queue
732 			doesn't allow adding the event (e.g. due to insufficient memory).
738 	// calculate next event time
751 		info->event->SetTime(info->time);
752 		scheduled = fEventQueue->AddEvent(info->event);