54 static void batadv_socket_add_packet(struct batadv_socket_client *socket_client,
66 	struct batadv_socket_client *socket_client;  in batadv_socket_open()  local
73 	socket_client = kmalloc(sizeof(*socket_client), GFP_KERNEL);  in batadv_socket_open()
74 	if (!socket_client) {  in batadv_socket_open()
81 			batadv_socket_client_hash[i] = socket_client;  in batadv_socket_open()
88 		kfree(socket_client);  in batadv_socket_open()
93 	INIT_LIST_HEAD(&socket_client->queue_list);  in batadv_socket_open()
94 	socket_client->queue_len = 0;  in batadv_socket_open()
95 	socket_client->index = i;  in batadv_socket_open()
96 	socket_client->bat_priv = inode->i_private;  in batadv_socket_open()
97 	spin_lock_init(&socket_client->lock);  in batadv_socket_open()
98 	init_waitqueue_head(&socket_client->queue_wait);  in batadv_socket_open()
100 	file->private_data = socket_client;  in batadv_socket_open()
107 	struct batadv_socket_client *socket_client = file->private_data;  in batadv_socket_release()  local
111 	spin_lock_bh(&socket_client->lock);  in batadv_socket_release()
114 	list_for_each_safe(list_pos, list_pos_tmp, &socket_client->queue_list) {  in batadv_socket_release()
122 	batadv_socket_client_hash[socket_client->index] = NULL;  in batadv_socket_release()
123 	spin_unlock_bh(&socket_client->lock);  in batadv_socket_release()
125 	kfree(socket_client);  in batadv_socket_release()
134 	struct batadv_socket_client *socket_client = file->private_data;  in batadv_socket_read()  local
139 	if ((file->f_flags & O_NONBLOCK) && (socket_client->queue_len == 0))  in batadv_socket_read()
148 	error = wait_event_interruptible(socket_client->queue_wait,  in batadv_socket_read()
149 					 socket_client->queue_len);  in batadv_socket_read()
154 	spin_lock_bh(&socket_client->lock);  in batadv_socket_read()
156 	socket_packet = list_first_entry(&socket_client->queue_list,  in batadv_socket_read()
159 	socket_client->queue_len--;  in batadv_socket_read()
161 	spin_unlock_bh(&socket_client->lock);  in batadv_socket_read()
177 	struct batadv_socket_client *socket_client = file->private_data;  in batadv_socket_write()  local
178 	struct batadv_priv *bat_priv = socket_client->bat_priv;  in batadv_socket_write()
269 	icmp_header->uid = socket_client->index;  in batadv_socket_write()
274 		batadv_socket_add_packet(socket_client, icmp_header,  in batadv_socket_write()
286 	batadv_socket_add_packet(socket_client, icmp_header, packet_len);  in batadv_socket_write()
301 	struct batadv_socket_client *socket_client = file->private_data;  in batadv_socket_poll()  local
303 	poll_wait(file, &socket_client->queue_wait, wait);  in batadv_socket_poll()
305 	if (socket_client->queue_len > 0)  in batadv_socket_poll()
346 static void batadv_socket_add_packet(struct batadv_socket_client *socket_client,  in batadv_socket_add_packet()  argument
367 	spin_lock_bh(&socket_client->lock);  in batadv_socket_add_packet()
373 		spin_unlock_bh(&socket_client->lock);  in batadv_socket_add_packet()
378 	list_add_tail(&socket_packet->list, &socket_client->queue_list);  in batadv_socket_add_packet()
379 	socket_client->queue_len++;  in batadv_socket_add_packet()
381 	if (socket_client->queue_len > 100) {  in batadv_socket_add_packet()
382 		socket_packet = list_first_entry(&socket_client->queue_list,  in batadv_socket_add_packet()
388 		socket_client->queue_len--;  in batadv_socket_add_packet()
391 	spin_unlock_bh(&socket_client->lock);  in batadv_socket_add_packet()
393 	wake_up(&socket_client->queue_wait);  in batadv_socket_add_packet()