Lines Matching refs:observer_fd

1710 necp_client_update_observer_add_internal(struct necp_fd_data *observer_fd, struct necp_client *clie…  in necp_client_update_observer_add_internal()  argument
1714 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_add_internal()
1716 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_add_internal()
1717 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1725 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_add_internal()
1726 observer_fd->update_count++; in necp_client_update_observer_add_internal()
1728 necp_fd_notify(observer_fd, true); in necp_client_update_observer_add_internal()
1731 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1735 necp_client_update_observer_update_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_update_internal() argument
1737 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_update_internal()
1739 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_update_internal()
1740 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1748 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_update_internal()
1749 observer_fd->update_count++; in necp_client_update_observer_update_internal()
1751 necp_fd_notify(observer_fd, true); in necp_client_update_observer_update_internal()
1754 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1758 necp_client_update_observer_remove_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_remove_internal() argument
1760 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_remove_internal()
1762 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_remove_internal()
1763 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1771 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_remove_internal()
1772 observer_fd->update_count++; in necp_client_update_observer_remove_internal()
1774 necp_fd_notify(observer_fd, true); in necp_client_update_observer_remove_internal()
1777 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1791 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_add() local
1792 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_add()
1793 necp_client_update_observer_add_internal(observer_fd, client); in necp_client_update_observer_add()
1810 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_update() local
1811 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_update()
1812 necp_client_update_observer_update_internal(observer_fd, client); in necp_client_update_observer_update()
1829 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_remove() local
1830 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_remove()
1831 necp_client_update_observer_remove_internal(observer_fd, client); in necp_client_update_observer_remove()