38 static int handle_client_stream_connect(struct cras_rclient *client,  in handle_client_stream_connect()  argument
73 	stream_config.client = client;  in handle_client_stream_connect()
103 	rc = cras_rclient_send_message(client, reply, stream_fds, 2);  in handle_client_stream_connect()
129 	cras_rclient_send_message(client, reply, NULL, 0);  in handle_client_stream_connect()
140 		struct cras_rclient *client,  in handle_client_stream_disconnect()  argument
148 static void dump_audio_thread_info(struct cras_rclient *client)  in dump_audio_thread_info()  argument
157 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in dump_audio_thread_info()
161 static void dump_audio_thread_snapshots(struct cras_rclient *client)  in dump_audio_thread_snapshots()  argument
167 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in dump_audio_thread_snapshots()
170 static void handle_get_hotword_models(struct cras_rclient *client,  in handle_get_hotword_models()  argument
190 	cras_rclient_send_message(client, &msg->header, NULL, 0);  in handle_get_hotword_models()
196 	cras_rclient_send_message(client, &msg->header, NULL, 0);  in handle_get_hotword_models()
204 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_output_volume_changed()  local
207 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_output_volume_changed()
214 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_output_mute_changed()  local
218 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_output_mute_changed()
224 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_capture_gain_changed()  local
227 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_capture_gain_changed()
233 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_capture_mute_changed()  local
236 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_capture_mute_changed()
242 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_nodes_changed()  local
245 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_nodes_changed()
253 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_active_node_changed()  local
256 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_active_node_changed()
264 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_output_node_volume_changed()  local
267 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_output_node_volume_changed()
275 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_node_left_right_swapped_changed()  local
279 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_node_left_right_swapped_changed()
287 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_input_node_gain_changed()  local
290 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_input_node_gain_changed()
298 	struct cras_rclient *client = (struct cras_rclient *)context;  in send_num_active_streams_changed()  local
302 	cras_rclient_send_message(client, &msg.header, NULL, 0);  in send_num_active_streams_changed()
305 static void register_for_notification(struct cras_rclient *client,  in register_for_notification()  argument
312 	cras_observer_get_ops(client->observer, &observer_ops);  in register_for_notification()
362 	if (client->observer) {  in register_for_notification()
364 			cras_observer_remove(client->observer);  in register_for_notification()
365 			client->observer = NULL;  in register_for_notification()
367 			cras_observer_set_ops(client->observer, &observer_ops);  in register_for_notification()
370 		client->observer = cras_observer_add(&observer_ops, client);  in register_for_notification()
382 	struct cras_rclient *client;  in cras_rclient_create()  local
386 	client = (struct cras_rclient *)calloc(1, sizeof(struct cras_rclient));  in cras_rclient_create()
387 	if (!client)  in cras_rclient_create()
390 	client->fd = fd;  in cras_rclient_create()
391 	client->id = id;  in cras_rclient_create()
393 	cras_fill_client_connected(&msg, client->id);  in cras_rclient_create()
395 	cras_rclient_send_message(client, &msg.header, &state_fd, 1);  in cras_rclient_create()
397 	return client;  in cras_rclient_create()
401 void cras_rclient_destroy(struct cras_rclient *client)  in cras_rclient_destroy()  argument
403 	cras_observer_remove(client->observer);  in cras_rclient_destroy()
405 			cras_iodev_list_get_stream_list(), client);  in cras_rclient_destroy()
406 	free(client);  in cras_rclient_destroy()
411 int cras_rclient_buffer_from_client(struct cras_rclient *client,  in cras_rclient_buffer_from_client()  argument
421 	cras_rclient_message_from_client(client, msg, fd);  in cras_rclient_buffer_from_client()
459 int cras_rclient_message_from_client(struct cras_rclient *client,  in cras_rclient_message_from_client()  argument
464 	assert(client && msg);  in cras_rclient_message_from_client()
487 			handle_client_stream_connect(client,  in cras_rclient_message_from_client()
490 			handle_client_stream_connect(client, &cmsg, fd);  in cras_rclient_message_from_client()
498 		handle_client_stream_disconnect(client,  in cras_rclient_message_from_client()
587 		dump_audio_thread_info(client);  in cras_rclient_message_from_client()
590 		dump_audio_thread_snapshots(client);  in cras_rclient_message_from_client()
636 		handle_get_hotword_models(client,  in cras_rclient_message_from_client()
655 			client, (enum CRAS_CLIENT_MESSAGE_ID)m->msg_id,  in cras_rclient_message_from_client()
681 int cras_rclient_send_message(const struct cras_rclient *client,  in cras_rclient_send_message()  argument
686 	return cras_send_with_fds(client->fd, (const void *)msg, msg->length,  in cras_rclient_send_message()