196 #define NETAGENT_SESSION_LOCK(session) lck_mtx_lock(&session->session_lock)  argument
197 #define NETAGENT_SESSION_UNLOCK(session) lck_mtx_unlock(&session->session_lock)  argument
228 static void netagent_delete_session(struct netagent_session *session);
231 static void netagent_handle_register_message(struct netagent_session *session, u_int32_t message_id,
233 static errno_t netagent_handle_register_setopt(struct netagent_session *session, u_int8_t *payload,
237 static void netagent_handle_unregister_message(struct netagent_session *session, u_int32_t message_…
239 static errno_t netagent_handle_unregister_setopt(struct netagent_session *session, u_int8_t *payloa…
243 static void netagent_handle_update_message(struct netagent_session *session, u_int32_t message_id,
245 static errno_t netagent_handle_update_setopt(struct netagent_session *session, u_int8_t *payload,
249 static void netagent_handle_assign_nexus_message(struct netagent_session *session, u_int32_t messag…
251 static errno_t netagent_handle_assign_nexus_setopt(struct netagent_session *session, u_int8_t *payl…
255 static errno_t netagent_handle_assign_group_setopt(struct netagent_session *session, u_int8_t *payl…
259 static errno_t netagent_handle_use_count_setopt(struct netagent_session *session, u_int8_t * __size…
260 static errno_t netagent_handle_use_count_getopt(struct netagent_session *session, u_int8_t * __size…
263 static errno_t netagent_handle_add_token_setopt(struct netagent_session *session, u_int8_t * __size…
264 static errno_t netagent_handle_flush_tokens_setopt(struct netagent_session *session, u_int8_t *payl…
265 static errno_t netagent_handle_token_count_getopt(struct netagent_session *session, u_int8_t * __si…
266 static errno_t netagent_handle_token_low_water_setopt(struct netagent_session *session, u_int8_t * …
267 static errno_t netagent_handle_token_low_water_getopt(struct netagent_session *session, u_int8_t * …
270 static errno_t netagent_handle_reset_client_error_setopt(struct netagent_session *session, u_int8_t…
333 	struct netagent_session *session = (struct netagent_session *)unitinfo;  in netagent_ctl_disconnect()  local
334 	if (session != NULL) {  in netagent_ctl_disconnect()
335 		netagent_delete_session(session);  in netagent_ctl_disconnect()
525 netagent_send_success_response(struct netagent_session *session, u_int8_t message_type, u_int32_t m…  in netagent_send_success_response()  argument
537 	if ((error = netagent_send_ctl_data(session->control_unit, response, response_size))) {  in netagent_send_success_response()
546 netagent_send_error_response(struct netagent_session *session, u_int8_t message_type,  in netagent_send_error_response()  argument
553 	if (session == NULL) {  in netagent_send_error_response()
565 	if ((error = netagent_send_ctl_data(session->control_unit, response, response_size))) {  in netagent_send_error_response()
577 	struct netagent_session *session = (struct netagent_session *)unitinfo;  in netagent_ctl_send()  local
581 	if (session == NULL) {  in netagent_ctl_send()
603 		netagent_handle_register_message(session, header.message_id, header.message_payload_length,  in netagent_ctl_send()
608 		netagent_handle_unregister_message(session, header.message_id, header.message_payload_length,  in netagent_ctl_send()
613 		netagent_handle_update_message(session, header.message_id, header.message_payload_length,  in netagent_ctl_send()
630 		netagent_handle_assign_nexus_message(session, header.message_id, header.message_payload_length,  in netagent_ctl_send()
636 		netagent_send_error_response(session, header.message_type, header.message_id,  in netagent_ctl_send()
659 	struct netagent_session *session = (struct netagent_session *)unitinfo;  in netagent_ctl_getopt()  local
662 	if (session == NULL) {  in netagent_ctl_getopt()
671 		error = netagent_handle_use_count_getopt(session, data, len);  in netagent_ctl_getopt()
676 		error = netagent_handle_token_count_getopt(session, data, len);  in netagent_ctl_getopt()
681 		error = netagent_handle_token_low_water_getopt(session, data, len);  in netagent_ctl_getopt()
699 	struct netagent_session *session = (struct netagent_session *)unitinfo;  in netagent_ctl_setopt()  local
702 	if (session == NULL) {  in netagent_ctl_setopt()
711 		error = netagent_handle_register_setopt(session, data, len);  in netagent_ctl_setopt()
716 		error = netagent_handle_update_setopt(session, data, len);  in netagent_ctl_setopt()
721 		error = netagent_handle_unregister_setopt(session, data, len);  in netagent_ctl_setopt()
726 		error = netagent_handle_assign_nexus_setopt(session, data, len);  in netagent_ctl_setopt()
731 		error = netagent_handle_assign_group_setopt(session, data, len);  in netagent_ctl_setopt()
736 		error = netagent_handle_use_count_setopt(session, data, len);  in netagent_ctl_setopt()
741 		error = netagent_handle_add_token_setopt(session, data, len);  in netagent_ctl_setopt()
746 		error = netagent_handle_flush_tokens_setopt(session, data, len);  in netagent_ctl_setopt()
751 		error = netagent_handle_token_low_water_setopt(session, data, len);  in netagent_ctl_setopt()
756 		error = netagent_handle_reset_client_error_setopt(session, data, len);  in netagent_ctl_setopt()
787 	struct netagent_session *session = netagent_create_session(0);  in netagent_create()  local
788 	if (session == NULL) {  in netagent_create()
792 	session->event_handler = event_handler;  in netagent_create()
793 	session->event_context = context;  in netagent_create()
794 	return session;  in netagent_create()
865 netagent_unregister_session_wrapper(struct netagent_session *session)  in netagent_unregister_session_wrapper()  argument
871 	if (session != NULL) {  in netagent_unregister_session_wrapper()
872 		NETAGENT_SESSION_LOCK(session);  in netagent_unregister_session_wrapper()
873 		wrapper = session->wrapper;  in netagent_unregister_session_wrapper()
878 			if ((session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) &&  in netagent_unregister_session_wrapper()
886 			uuid_copy(unregistered_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_unregister_session_wrapper()
888 			netagent_free_wrapper(session->wrapper);  in netagent_unregister_session_wrapper()
889 			session->wrapper = NULL;  in netagent_unregister_session_wrapper()
892 		NETAGENT_SESSION_UNLOCK(session);  in netagent_unregister_session_wrapper()
903 netagent_delete_session(struct netagent_session *session)  in netagent_delete_session()  argument
905 	if (session != NULL) {  in netagent_delete_session()
906 		netagent_unregister_session_wrapper(session);  in netagent_delete_session()
907 		lck_mtx_destroy(&session->session_lock, &netagent_mtx_grp);  in netagent_delete_session()
908 		kfree_type(struct netagent_session, session);  in netagent_delete_session()
913 netagent_destroy(netagent_session_t session)  in netagent_destroy()  argument
915 	return netagent_delete_session((struct netagent_session *)session);  in netagent_destroy()
938 netagent_handle_register_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapp…  in netagent_handle_register_inner()  argument
942 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_register_inner()
943 	if (session->wrapper != NULL) {  in netagent_handle_register_inner()
944 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_register_inner()
949 	new_wrapper->control_unit = session->control_unit;  in netagent_handle_register_inner()
950 	new_wrapper->event_handler = session->event_handler;  in netagent_handle_register_inner()
951 	new_wrapper->event_context = session->event_context;  in netagent_handle_register_inner()
954 	session->wrapper = new_wrapper;  in netagent_handle_register_inner()
965 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_register_inner()
976 	struct netagent_session *session = (struct netagent_session *)_session;  in netagent_register()  local
977 	if (session == NULL) {  in netagent_register()
1001 	errno_t error = netagent_handle_register_inner(session, new_wrapper);  in netagent_register()
1014 netagent_handle_register_setopt(struct netagent_session *session, u_int8_t *payload,  in netagent_handle_register_setopt()  argument
1022 	if (session == NULL) {  in netagent_handle_register_setopt()
1061 	response_error = netagent_handle_register_inner(session, new_wrapper);  in netagent_handle_register_setopt()
1075 netagent_handle_register_message(struct netagent_session *session, u_int32_t message_id,  in netagent_handle_register_message()  argument
1083 	if (session == NULL) {  in netagent_handle_register_message()
1117 	error = netagent_handle_register_inner(session, new_wrapper);  in netagent_handle_register_message()
1126 	netagent_send_success_response(session, NETAGENT_MESSAGE_TYPE_REGISTER, message_id);  in netagent_handle_register_message()
1130 	netagent_send_error_response(session, NETAGENT_MESSAGE_TYPE_REGISTER, message_id, response_error);  in netagent_handle_register_message()
1136 	struct netagent_session *session = (struct netagent_session *)_session;  in netagent_unregister()  local
1137 	if (session == NULL) {  in netagent_unregister()
1142 	netagent_unregister_session_wrapper(session);  in netagent_unregister()
1147 netagent_handle_unregister_setopt(struct netagent_session *session, u_int8_t *payload,  in netagent_handle_unregister_setopt()  argument
1153 	if (session == NULL) {  in netagent_handle_unregister_setopt()
1159 	netagent_unregister_session_wrapper(session);  in netagent_handle_unregister_setopt()
1166 netagent_handle_unregister_message(struct netagent_session *session, u_int32_t message_id,  in netagent_handle_unregister_message()  argument
1172 	if (session == NULL) {  in netagent_handle_unregister_message()
1178 	netagent_unregister_session_wrapper(session);  in netagent_handle_unregister_message()
1180 	netagent_send_success_response(session, NETAGENT_MESSAGE_TYPE_UNREGISTER, message_id);  in netagent_handle_unregister_message()
1183 …netagent_send_error_response(session, NETAGENT_MESSAGE_TYPE_UNREGISTER, message_id, response_error…  in netagent_handle_unregister_message()
1206 netagent_handle_update_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapper,  in netagent_handle_update_inner()  argument
1218 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_update_inner()
1219 	if (session->wrapper == NULL) {  in netagent_handle_update_inner()
1220 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_update_inner()
1226 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_update_inner()
1228 …if (uuid_compare(session->wrapper->netagent->netagent_uuid, new_wrapper->netagent->netagent_uuid) …  in netagent_handle_update_inner()
1229 	    memcmp(&session->wrapper->netagent->netagent_domain, &new_wrapper->netagent->netagent_domain,  in netagent_handle_update_inner()
1231 	    memcmp(&session->wrapper->netagent->netagent_type, &new_wrapper->netagent->netagent_type,  in netagent_handle_update_inner()
1233 		NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_update_inner()
1234 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_update_inner()
1246 	if (session->wrapper->netagent->netagent_data_size == new_wrapper->netagent->netagent_data_size &&  in netagent_handle_update_inner()
1247 	    memcmp(session->wrapper->netagent, new_wrapper->netagent, sizeof(struct netagent)) == 0 &&  in netagent_handle_update_inner()
1248 …memcmp(netagent_get_data(session->wrapper->netagent), netagent_get_data(new_wrapper->netagent), da…  in netagent_handle_update_inner()
1256 …LIST_FOREACH_SAFE(search_client, &session->wrapper->pending_triggers_list, client_chain, temp_clie…  in netagent_handle_update_inner()
1260 		NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_update_inner()
1261 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_update_inner()
1268 …necp_force_update_client(search_client->client_id, session->wrapper->netagent->netagent_uuid, sess…  in netagent_handle_update_inner()
1279 	new_wrapper->use_count = session->wrapper->use_count;  in netagent_handle_update_inner()
1282 	TAILQ_CONCAT(&new_wrapper->token_list, &session->wrapper->token_list, token_chain);  in netagent_handle_update_inner()
1283 	new_wrapper->token_count = session->wrapper->token_count;  in netagent_handle_update_inner()
1284 	new_wrapper->token_low_water = session->wrapper->token_low_water;  in netagent_handle_update_inner()
1285 	new_wrapper->last_client_error = session->wrapper->last_client_error;  in netagent_handle_update_inner()
1286 	new_wrapper->client_error_count = session->wrapper->client_error_count;  in netagent_handle_update_inner()
1289 	    !(session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE)) {  in netagent_handle_update_inner()
1292 	    (session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) &&  in netagent_handle_update_inner()
1297 	LIST_REMOVE(session->wrapper, list_chain);  in netagent_handle_update_inner()
1298 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_update_inner()
1299 	netagent_free_wrapper(session->wrapper);  in netagent_handle_update_inner()
1300 	session->wrapper = new_wrapper;  in netagent_handle_update_inner()
1301 	new_wrapper->control_unit = session->control_unit;  in netagent_handle_update_inner()
1302 	new_wrapper->event_handler = session->event_handler;  in netagent_handle_update_inner()
1303 	new_wrapper->event_context = session->event_context;  in netagent_handle_update_inner()
1307 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_update_inner()
1324 	struct netagent_session *session = (struct netagent_session *)_session;  in netagent_update()  local
1325 	if (session == NULL) {  in netagent_update()
1349 …errno_t error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNet…  in netagent_update()
1365 netagent_handle_update_setopt(struct netagent_session *session, u_int8_t *payload, size_t payload_l…  in netagent_handle_update_setopt()  argument
1374 	if (session == NULL) {  in netagent_handle_update_setopt()
1414 …response_error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNe…  in netagent_handle_update_setopt()
1430 netagent_handle_update_message(struct netagent_session *session, u_int32_t message_id,  in netagent_handle_update_message()  argument
1440 	if (session == NULL) {  in netagent_handle_update_message()
1474 …response_error = (u_int32_t)netagent_handle_update_inner(session, new_wrapper, data_size, &agent_c…  in netagent_handle_update_message()
1483 	netagent_send_success_response(session, NETAGENT_MESSAGE_TYPE_UPDATE, message_id);  in netagent_handle_update_message()
1494 	netagent_send_error_response(session, NETAGENT_MESSAGE_TYPE_UPDATE, message_id, response_error);  in netagent_handle_update_message()
1501 	struct netagent_session *session = (struct netagent_session *)_session;  in netagent_assign_nexus()  local
1503 	if (session == NULL) {  in netagent_assign_nexus()
1508 	NETAGENT_SESSION_LOCK(session);  in netagent_assign_nexus()
1509 	if (session->wrapper == NULL) {  in netagent_assign_nexus()
1510 		NETAGENT_SESSION_UNLOCK(session);  in netagent_assign_nexus()
1514 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_assign_nexus()
1515 	uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_assign_nexus()
1516 	NETAGENT_UNLOCK(session->wrapper);  in netagent_assign_nexus()
1517 	NETAGENT_SESSION_UNLOCK(session);  in netagent_assign_nexus()
1536 	struct netagent_session *session = (struct netagent_session *)_session;  in netagent_update_flow_protoctl_event()  local
1540 	if (session == NULL) {  in netagent_update_flow_protoctl_event()
1545 	NETAGENT_SESSION_LOCK(session);  in netagent_update_flow_protoctl_event()
1546 	if (session->wrapper == NULL) {  in netagent_update_flow_protoctl_event()
1547 		NETAGENT_SESSION_UNLOCK(session);  in netagent_update_flow_protoctl_event()
1551 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_update_flow_protoctl_event()
1552 	uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_update_flow_protoctl_event()
1553 	NETAGENT_UNLOCK(session->wrapper);  in netagent_update_flow_protoctl_event()
1554 	NETAGENT_SESSION_UNLOCK(session);  in netagent_update_flow_protoctl_event()
1563 netagent_handle_assign_nexus_setopt(struct netagent_session *session, u_int8_t *payload,  in netagent_handle_assign_nexus_setopt()  argument
1572 	if (session == NULL) {  in netagent_handle_assign_nexus_setopt()
1584 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_assign_nexus_setopt()
1585 	if (session->wrapper == NULL) {  in netagent_handle_assign_nexus_setopt()
1586 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_nexus_setopt()
1592 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_assign_nexus_setopt()
1593 	uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_handle_assign_nexus_setopt()
1594 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_assign_nexus_setopt()
1595 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_nexus_setopt()
1634 netagent_handle_assign_nexus_message(struct netagent_session *session, u_int32_t message_id,  in netagent_handle_assign_nexus_message()  argument
1643 	if (session == NULL) {  in netagent_handle_assign_nexus_message()
1649 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_assign_nexus_message()
1650 	if (session->wrapper == NULL) {  in netagent_handle_assign_nexus_message()
1651 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_nexus_message()
1656 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_assign_nexus_message()
1657 	uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_handle_assign_nexus_message()
1658 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_assign_nexus_message()
1659 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_nexus_message()
1702 	netagent_send_success_response(session, NETAGENT_MESSAGE_TYPE_ASSIGN_NEXUS, message_id);  in netagent_handle_assign_nexus_message()
1705 …netagent_send_error_response(session, NETAGENT_MESSAGE_TYPE_ASSIGN_NEXUS, message_id, response_err…  in netagent_handle_assign_nexus_message()
1709 netagent_handle_assign_group_setopt(struct netagent_session *session, u_int8_t *payload,  in netagent_handle_assign_group_setopt()  argument
1718 	if (session == NULL) {  in netagent_handle_assign_group_setopt()
1730 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_assign_group_setopt()
1731 	if (session->wrapper == NULL) {  in netagent_handle_assign_group_setopt()
1732 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_group_setopt()
1738 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_assign_group_setopt()
1739 	uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid);  in netagent_handle_assign_group_setopt()
1740 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_assign_group_setopt()
1741 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_assign_group_setopt()
1780 netagent_handle_use_count_setopt(struct netagent_session *session, u_int8_t * __sized_by(payload_le…  in netagent_handle_use_count_setopt()  argument
1785 	if (session == NULL) {  in netagent_handle_use_count_setopt()
1805 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_use_count_setopt()
1807 	if (session->wrapper == NULL) {  in netagent_handle_use_count_setopt()
1808 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_use_count_setopt()
1814 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_use_count_setopt()
1815 	session->wrapper->use_count = use_count;  in netagent_handle_use_count_setopt()
1816 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_use_count_setopt()
1817 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_use_count_setopt()
1824 netagent_handle_use_count_getopt(struct netagent_session *session, u_int8_t * __sized_by(*buffer_le…  in netagent_handle_use_count_getopt()  argument
1829 	if (session == NULL) {  in netagent_handle_use_count_getopt()
1847 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_use_count_getopt()
1849 	if (session->wrapper == NULL) {  in netagent_handle_use_count_getopt()
1850 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_use_count_getopt()
1856 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_use_count_getopt()
1857 	use_count = session->wrapper->use_count;  in netagent_handle_use_count_getopt()
1858 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_use_count_getopt()
1859 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_use_count_getopt()
1869 netagent_handle_add_token_setopt(struct netagent_session *session, u_int8_t * __sized_by(token_leng…  in netagent_handle_add_token_setopt()  argument
1873 	if (session == NULL) {  in netagent_handle_add_token_setopt()
1891 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_add_token_setopt()
1892 	if (session->wrapper == NULL) {  in netagent_handle_add_token_setopt()
1893 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_add_token_setopt()
1899 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_add_token_setopt()
1900 	if (session->wrapper->token_count >= NETAGENT_MAX_TOKEN_COUNT) {  in netagent_handle_add_token_setopt()
1901 		NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_add_token_setopt()
1902 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_add_token_setopt()
1915 	TAILQ_INSERT_TAIL(&session->wrapper->token_list, token_struct, token_chain);  in netagent_handle_add_token_setopt()
1917 	session->wrapper->token_count++;  in netagent_handle_add_token_setopt()
1920 	session->wrapper->need_tokens_event_deadline = 0;  in netagent_handle_add_token_setopt()
1922 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_add_token_setopt()
1923 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_add_token_setopt()
1929 netagent_handle_flush_tokens_setopt(struct netagent_session *session, __unused u_int8_t *buffer, __…  in netagent_handle_flush_tokens_setopt()  argument
1933 	if (session == NULL) {  in netagent_handle_flush_tokens_setopt()
1939 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_flush_tokens_setopt()
1940 	if (session->wrapper == NULL) {  in netagent_handle_flush_tokens_setopt()
1941 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_flush_tokens_setopt()
1947 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_flush_tokens_setopt()
1950 	TAILQ_FOREACH_SAFE(search_token, &session->wrapper->token_list, token_chain, temp_token) {  in netagent_handle_flush_tokens_setopt()
1951 		TAILQ_REMOVE(&session->wrapper->token_list, search_token, token_chain);  in netagent_handle_flush_tokens_setopt()
1954 	session->wrapper->token_count = 0;  in netagent_handle_flush_tokens_setopt()
1955 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_flush_tokens_setopt()
1956 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_flush_tokens_setopt()
1962 netagent_handle_token_count_getopt(struct netagent_session *session, u_int8_t * __sized_by(*buffer_…  in netagent_handle_token_count_getopt()  argument
1967 	if (session == NULL) {  in netagent_handle_token_count_getopt()
1985 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_token_count_getopt()
1986 	if (session->wrapper == NULL) {  in netagent_handle_token_count_getopt()
1987 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_count_getopt()
1993 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_token_count_getopt()
1994 	token_count = session->wrapper->token_count;  in netagent_handle_token_count_getopt()
1995 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_token_count_getopt()
1996 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_count_getopt()
2006 netagent_handle_token_low_water_setopt(struct netagent_session *session, u_int8_t * __sized_by(buff…  in netagent_handle_token_low_water_setopt()  argument
2011 	if (session == NULL) {  in netagent_handle_token_low_water_setopt()
2031 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_token_low_water_setopt()
2032 	if (session->wrapper == NULL) {  in netagent_handle_token_low_water_setopt()
2033 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_low_water_setopt()
2039 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_token_low_water_setopt()
2040 	session->wrapper->token_low_water = token_low_water;  in netagent_handle_token_low_water_setopt()
2041 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_token_low_water_setopt()
2042 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_low_water_setopt()
2049 netagent_handle_token_low_water_getopt(struct netagent_session *session, u_int8_t * __sized_by(*buf…  in netagent_handle_token_low_water_getopt()  argument
2054 	if (session == NULL) {  in netagent_handle_token_low_water_getopt()
2072 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_token_low_water_getopt()
2073 	if (session->wrapper == NULL) {  in netagent_handle_token_low_water_getopt()
2074 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_low_water_getopt()
2080 	NETAGENT_LOCK_SHARED(session->wrapper);  in netagent_handle_token_low_water_getopt()
2081 	token_low_water = session->wrapper->token_low_water;  in netagent_handle_token_low_water_getopt()
2082 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_token_low_water_getopt()
2083 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_token_low_water_getopt()
2093 netagent_handle_reset_client_error_setopt(struct netagent_session *session, __unused u_int8_t *payl…  in netagent_handle_reset_client_error_setopt()  argument
2097 	if (session == NULL) {  in netagent_handle_reset_client_error_setopt()
2103 	NETAGENT_SESSION_LOCK(session);  in netagent_handle_reset_client_error_setopt()
2104 	if (session->wrapper == NULL) {  in netagent_handle_reset_client_error_setopt()
2105 		NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_reset_client_error_setopt()
2111 	NETAGENT_LOCK_EXCLUSIVE(session->wrapper);  in netagent_handle_reset_client_error_setopt()
2114 	TAILQ_FOREACH_SAFE(search_token, &session->wrapper->token_list, token_chain, temp_token) {  in netagent_handle_reset_client_error_setopt()
2115 		TAILQ_REMOVE(&session->wrapper->token_list, search_token, token_chain);  in netagent_handle_reset_client_error_setopt()
2118 	session->wrapper->last_client_error = 0;  in netagent_handle_reset_client_error_setopt()
2119 	session->wrapper->client_error_count = 0;  in netagent_handle_reset_client_error_setopt()
2121 	NETAGENT_UNLOCK(session->wrapper);  in netagent_handle_reset_client_error_setopt()
2122 	NETAGENT_SESSION_UNLOCK(session);  in netagent_handle_reset_client_error_setopt()