Lines Matching refs:observer_fd
1438 necp_client_update_observer_add_internal(struct necp_fd_data *observer_fd, struct necp_client *clie… in necp_client_update_observer_add_internal() argument
1442 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_add_internal()
1444 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_add_internal()
1445 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1453 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_add_internal()
1454 observer_fd->update_count++; in necp_client_update_observer_add_internal()
1456 necp_fd_notify(observer_fd, true); in necp_client_update_observer_add_internal()
1459 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_add_internal()
1463 necp_client_update_observer_update_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_update_internal() argument
1465 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_update_internal()
1467 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_update_internal()
1468 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1476 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_update_internal()
1477 observer_fd->update_count++; in necp_client_update_observer_update_internal()
1479 necp_fd_notify(observer_fd, true); in necp_client_update_observer_update_internal()
1482 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_update_internal()
1486 necp_client_update_observer_remove_internal(struct necp_fd_data *observer_fd, struct necp_client *c… in necp_client_update_observer_remove_internal() argument
1488 NECP_FD_LOCK(observer_fd); in necp_client_update_observer_remove_internal()
1490 if (observer_fd->update_count >= necp_observer_message_limit) { in necp_client_update_observer_remove_internal()
1491 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1499 TAILQ_INSERT_TAIL(&observer_fd->update_list, client_update, chain); in necp_client_update_observer_remove_internal()
1500 observer_fd->update_count++; in necp_client_update_observer_remove_internal()
1502 necp_fd_notify(observer_fd, true); in necp_client_update_observer_remove_internal()
1505 NECP_FD_UNLOCK(observer_fd); in necp_client_update_observer_remove_internal()
1519 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_add() local
1520 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_add()
1521 necp_client_update_observer_add_internal(observer_fd, client); in necp_client_update_observer_add()
1538 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_update() local
1539 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_update()
1540 necp_client_update_observer_update_internal(observer_fd, client); in necp_client_update_observer_update()
1557 struct necp_fd_data *observer_fd = NULL; in necp_client_update_observer_remove() local
1558 LIST_FOREACH(observer_fd, &necp_fd_observer_list, chain) { in necp_client_update_observer_remove()
1559 necp_client_update_observer_remove_internal(observer_fd, client); in necp_client_update_observer_remove()