Lines Matching refs:observer_fd
1700 necp_client_update_observer_add_internal(struct necp_fd_data *observer_fd, struct necp_client *clie… in necp_client_update_observer_add_internal() argument
1704 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_add_internal()
1706 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_add_internal()
1707 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1715 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_add_internal()
1716 observer_fd->update_count++; in necp_client_update_observer_add_internal()
1718 necp_fd_notify(observer_fd, true); in necp_client_update_observer_add_internal()
1721 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1725 necp_client_update_observer_update_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_update_internal() argument
1727 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_update_internal()
1729 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_update_internal()
1730 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1738 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_update_internal()
1739 observer_fd->update_count++; in necp_client_update_observer_update_internal()
1741 necp_fd_notify(observer_fd, true); in necp_client_update_observer_update_internal()
1744 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1748 necp_client_update_observer_remove_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_remove_internal() argument
1750 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_remove_internal()
1752 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_remove_internal()
1753 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1761 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_remove_internal()
1762 observer_fd->update_count++; in necp_client_update_observer_remove_internal()
1764 necp_fd_notify(observer_fd, true); in necp_client_update_observer_remove_internal()
1767 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1781 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_add() local
1782 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_add()
1783 necp_client_update_observer_add_internal(observer_fd, client); in necp_client_update_observer_add()
1800 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_update() local
1801 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_update()
1802 necp_client_update_observer_update_internal(observer_fd, client); in necp_client_update_observer_update()
1819 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_remove() local
1820 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_remove()
1821 necp_client_update_observer_remove_internal(observer_fd, client); in necp_client_update_observer_remove()