Lines Matching refs:observer_fd

1695 necp_client_update_observer_add_internal(struct necp_fd_data *observer_fd, struct necp_client *clie…  in necp_client_update_observer_add_internal()  argument
1699 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_add_internal()
1701 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_add_internal()
1702 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1710 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_add_internal()
1711 observer_fd->update_count++; in necp_client_update_observer_add_internal()
1713 necp_fd_notify(observer_fd, true); in necp_client_update_observer_add_internal()
1716 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1720 necp_client_update_observer_update_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_update_internal() argument
1722 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_update_internal()
1724 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_update_internal()
1725 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1733 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_update_internal()
1734 observer_fd->update_count++; in necp_client_update_observer_update_internal()
1736 necp_fd_notify(observer_fd, true); in necp_client_update_observer_update_internal()
1739 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1743 necp_client_update_observer_remove_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_remove_internal() argument
1745 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_remove_internal()
1747 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_remove_internal()
1748 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1756 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_remove_internal()
1757 observer_fd->update_count++; in necp_client_update_observer_remove_internal()
1759 necp_fd_notify(observer_fd, true); in necp_client_update_observer_remove_internal()
1762 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1776 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_add() local
1777 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_add()
1778 necp_client_update_observer_add_internal(observer_fd, client); in necp_client_update_observer_add()
1795 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_update() local
1796 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_update()
1797 necp_client_update_observer_update_internal(observer_fd, client); in necp_client_update_observer_update()
1814 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_remove() local
1815 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_remove()
1816 necp_client_update_observer_remove_internal(observer_fd, client); in necp_client_update_observer_remove()