Lines Matching refs:observer_fd

1559 necp_client_update_observer_add_internal(struct necp_fd_data *observer_fd, struct necp_client *clie…  in necp_client_update_observer_add_internal()  argument
1563 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_add_internal()
1565 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_add_internal()
1566 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1574 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_add_internal()
1575 observer_fd->update_count++; in necp_client_update_observer_add_internal()
1577 necp_fd_notify(observer_fd, true); in necp_client_update_observer_add_internal()
1580 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1584 necp_client_update_observer_update_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_update_internal() argument
1586 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_update_internal()
1588 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_update_internal()
1589 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1597 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_update_internal()
1598 observer_fd->update_count++; in necp_client_update_observer_update_internal()
1600 necp_fd_notify(observer_fd, true); in necp_client_update_observer_update_internal()
1603 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1607 necp_client_update_observer_remove_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_remove_internal() argument
1609 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_remove_internal()
1611 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_remove_internal()
1612 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1620 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_remove_internal()
1621 observer_fd->update_count++; in necp_client_update_observer_remove_internal()
1623 necp_fd_notify(observer_fd, true); in necp_client_update_observer_remove_internal()
1626 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1640 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_add() local
1641 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_add()
1642 necp_client_update_observer_add_internal(observer_fd, client); in necp_client_update_observer_add()
1659 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_update() local
1660 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_update()
1661 necp_client_update_observer_update_internal(observer_fd, client); in necp_client_update_observer_update()
1678 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_remove() local
1679 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_remove()
1680 necp_client_update_observer_remove_internal(observer_fd, client); in necp_client_update_observer_remove()