kernel/fs/node_monitor.cpp

51 	NotificationListener *listener;
112 			NotificationListener &listener);
114 			NotificationListener &listener);
116 			NotificationListener &listener);
134 		void _RemoveListener(monitor_listener *listener);
224 /*!	\brief Notifies the listener of a live query that an entry has been added
228   	\param port The target port of the listener.
229   	\param token The BHandler token of the listener.
307 	TRACE(("%s(dev = %ld, node = %lld, listener = %p\n",
317 	// see if it has the listener we are looking for
318 	monitor_listener* listener = _MonitorListenerFor(monitor,
320 	if (listener == NULL)
323 	_RemoveListener(listener);
335 NodeMonitorService::_RemoveListener(monitor_listener *listener)
337 	uint32 flags = listener->flags;
338 	node_monitor *monitor = listener->monitor;
340 	// remove it from the listener and I/O context lists
341 	monitor->listeners.Remove(listener);
342 	list_remove_link(listener);
344 	if (dynamic_cast<UserNodeListener*>(listener->listener) != NULL) {
345 		// This is a listener we copied ourselves in UpdateUserListener(),
347 		delete listener->listener;
350 	delete listener;
421 /*! Returns the listener that matches the specified port/token pair.
431 	while (monitor_listener* listener = iterator.Next()) {
432 		// does this listener match?
433 		if (*listener->listener == notificationListener)
434 			return listener;
446 	monitor_listener *listener = new(std::nothrow) monitor_listener;
447 	if (listener == NULL) {
448 		// no memory for the listener, so remove the monitor as well if needed
455 	// initialize listener, and add it to the lists
456 	listener->listener = &notificationListener;
457 	listener->flags = flags;
458 	listener->monitor = monitor;
460 	monitor->listeners.Add(listener);
461 	list_add_link_to_head(&context->node_monitors, listener);
472 	TRACE(("%s(dev = %ld, node = %lld, flags = %ld, listener = %p\n",
483 	// add listener
494 	TRACE(("%s(dev = %ld, node = %lld, flags = %ld, listener = %p\n",
506 	while (monitor_listener* listener = iterator.Next()) {
507 		if (*listener->listener == notificationListener) {
509 				listener->flags |= flags;
511 				listener->flags = flags;
522 		   the events for that node and, if so, adds the respective listener
523 		   list to a supplied array of listener lists.
528 	the first listener in the list, that is interested.
534 	\param interestedListeners An array of listener lists. If there are
553 	while (monitor_listener *listener = iterator.Next()) {
554 		if ((listener->flags & flags) == flags) {
577 	while (monitor_listener *listener = iterator.Next()) {
578 		if ((listener->flags & flags) == flags) {
591 	\param interestedListeners An array of listener lists.
609 			monitor_listener *listener = iterator.Current();
610 			if (listener->flags & list->flags)
611 				listener->listener->EventOccurred(*this, &message);
619 			monitor_listener *listener = list->iterator.Current();
620 			if (listener->flags & list->flags)
621 				listener->listener->AllListenersNotified(*this);
947 	NotificationListener& listener)
959 	return AddListener(context, device, node, flags, listener);
965 	NotificationListener& listener)
978 	return _UpdateListener(context, device, node, flags, addFlags, listener);
984 	NotificationListener& listener)
995 	return RemoveListener(context, device, node, listener);
1003 	TRACE(("%s(dev = %ld, node = %lld, listener = %p\n",
1021 	monitor_listener *listener = NULL;
1026 	while ((listener = (monitor_listener*)list_get_next_item(
1027 			&context->node_monitors, listener)) != NULL) {
1030 		if (*listener->listener != userListener)
1033 		listener = (monitor_listener*)list_get_prev_item(
1034 			&context->node_monitors, removeListener = listener);
1035 			// this line sets the listener one item back, allowing us
1051 	TRACE(("%s(dev = %ld, node = %lld, flags = %ld, listener = %p\n",
1063 	while (monitor_listener* listener = iterator.Next()) {
1064 		if (*listener->listener == userListener) {
1065 			listener->flags |= flags;
1125 remove_node_listener(dev_t device, ino_t node, NotificationListener& listener)
1128 		device, node, listener);
1134 	NotificationListener& listener)
1137 		device, node, flags, listener);
1240 /*!	\brief Notifies the listener of a live query that an entry has been added
1242   	\param port The target port of the listener.
1243   	\param token The BHandler token of the listener.
1261 /*!	\brief Notifies the listener of a live query that an entry has been removed
1263   	\param port The target port of the listener.
1264   	\param token The BHandler token of the listener.
1282 /*!	\brief Notifies the listener of a live query that an entry has been changed
1284   	\param port The target port of the listener.
1285   	\param token The BHandler token of the listener.
1327 	UserNodeListener listener(port, token);
1329 		listener);
1338 	UserNodeListener listener(port, token);
1340 		listener);