Lines Matching refs:msg
39 const struct cras_connect_message *msg, in handle_client_stream_connect() argument
51 unpack_cras_audio_format(&remote_fmt, &msg->format); in handle_client_stream_connect()
63 stream_config.stream_id = msg->stream_id; in handle_client_stream_connect()
64 stream_config.stream_type = msg->stream_type; in handle_client_stream_connect()
65 stream_config.direction = msg->direction; in handle_client_stream_connect()
66 stream_config.dev_idx = msg->dev_idx; in handle_client_stream_connect()
67 stream_config.flags = msg->flags; in handle_client_stream_connect()
68 stream_config.effects = msg->effects; in handle_client_stream_connect()
70 stream_config.buffer_frames = msg->buffer_frames; in handle_client_stream_connect()
71 stream_config.cb_threshold = msg->cb_threshold; in handle_client_stream_connect()
82 syslog(LOG_DEBUG, "Send connected for stream %x\n", msg->stream_id); in handle_client_stream_connect()
83 if (msg->proto_version == CRAS_PROTO_VER) { in handle_client_stream_connect()
87 msg->stream_id, in handle_client_stream_connect()
96 msg->stream_id, in handle_client_stream_connect()
118 if (msg->proto_version == CRAS_PROTO_VER) { in handle_client_stream_connect()
120 &stream_connected, rc, msg->stream_id, in handle_client_stream_connect()
121 &remote_fmt, 0, msg->effects); in handle_client_stream_connect()
125 &stream_connected_old, rc, msg->stream_id, in handle_client_stream_connect()
141 const struct cras_disconnect_stream_message *msg) in handle_client_stream_disconnect() argument
144 msg->stream_id); in handle_client_stream_disconnect()
150 struct cras_client_audio_debug_info_ready msg; in dump_audio_thread_info() local
153 cras_fill_client_audio_debug_info_ready(&msg); in dump_audio_thread_info()
157 cras_rclient_send_message(client, &msg.header, NULL, 0); in dump_audio_thread_info()
163 struct cras_client_audio_debug_info_ready msg; in dump_audio_thread_snapshots() local
165 cras_fill_client_audio_debug_info_ready(&msg); in dump_audio_thread_snapshots()
167 cras_rclient_send_message(client, &msg.header, NULL, 0); in dump_audio_thread_snapshots()
173 struct cras_client_get_hotword_models_ready *msg; in handle_get_hotword_models() local
178 msg = (struct cras_client_get_hotword_models_ready *)buf; in handle_get_hotword_models()
183 if (hotword_models_size + sizeof(*msg) > CRAS_CLIENT_MAX_MSG_SIZE) { in handle_get_hotword_models()
188 cras_fill_client_get_hotword_models_ready(msg, hotword_models, in handle_get_hotword_models()
190 cras_rclient_send_message(client, &msg->header, NULL, 0); in handle_get_hotword_models()
195 cras_fill_client_get_hotword_models_ready(msg, NULL, 0); in handle_get_hotword_models()
196 cras_rclient_send_message(client, &msg->header, NULL, 0); in handle_get_hotword_models()
203 struct cras_client_volume_changed msg; in send_output_volume_changed() local
206 cras_fill_client_output_volume_changed(&msg, volume); in send_output_volume_changed()
207 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_output_volume_changed()
213 struct cras_client_mute_changed msg; in send_output_mute_changed() local
216 cras_fill_client_output_mute_changed(&msg, muted, in send_output_mute_changed()
218 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_output_mute_changed()
223 struct cras_client_volume_changed msg; in send_capture_gain_changed() local
226 cras_fill_client_capture_gain_changed(&msg, gain); in send_capture_gain_changed()
227 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_capture_gain_changed()
232 struct cras_client_mute_changed msg; in send_capture_mute_changed() local
235 cras_fill_client_capture_mute_changed(&msg, muted, mute_locked); in send_capture_mute_changed()
236 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_capture_mute_changed()
241 struct cras_client_nodes_changed msg; in send_nodes_changed() local
244 cras_fill_client_nodes_changed(&msg); in send_nodes_changed()
245 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_nodes_changed()
252 struct cras_client_active_node_changed msg; in send_active_node_changed() local
255 cras_fill_client_active_node_changed(&msg, dir, node_id); in send_active_node_changed()
256 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_active_node_changed()
263 struct cras_client_node_value_changed msg; in send_output_node_volume_changed() local
266 cras_fill_client_output_node_volume_changed(&msg, node_id, volume); in send_output_node_volume_changed()
267 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_output_node_volume_changed()
274 struct cras_client_node_value_changed msg; in send_node_left_right_swapped_changed() local
278 &msg, node_id, swapped); in send_node_left_right_swapped_changed()
279 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_node_left_right_swapped_changed()
286 struct cras_client_node_value_changed msg; in send_input_node_gain_changed() local
289 cras_fill_client_input_node_gain_changed(&msg, node_id, gain); in send_input_node_gain_changed()
290 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_input_node_gain_changed()
297 struct cras_client_num_active_streams_changed msg; in send_num_active_streams_changed() local
301 &msg, dir, num_active_streams); in send_num_active_streams_changed()
302 cras_rclient_send_message(client, &msg.header, NULL, 0); in send_num_active_streams_changed()
383 struct cras_client_connected msg; in cras_rclient_create() local
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()
415 struct cras_server_message *msg = (struct cras_server_message *)buf; in cras_rclient_buffer_from_client() local
417 if (buf_len < sizeof(*msg)) in cras_rclient_buffer_from_client()
419 if (msg->length != buf_len) in cras_rclient_buffer_from_client()
421 cras_rclient_message_from_client(client, msg, fd); in cras_rclient_buffer_from_client()
431 #define MSG_LEN_VALID(msg, type) ((msg)->length >= sizeof(type)) argument
440 static int is_connect_msg_old(const struct cras_server_message *msg, in is_connect_msg_old() argument
445 if (!MSG_LEN_VALID(msg, struct cras_connect_message_old)) in is_connect_msg_old()
448 old = (struct cras_connect_message_old *)msg; in is_connect_msg_old()
460 const struct cras_server_message *msg, in cras_rclient_message_from_client() argument
464 assert(client && msg); in cras_rclient_message_from_client()
467 switch (msg->id) { in cras_rclient_message_from_client()
477 msg->id); in cras_rclient_message_from_client()
484 switch (msg->id) { in cras_rclient_message_from_client()
486 if (MSG_LEN_VALID(msg, struct cras_connect_message)) { in cras_rclient_message_from_client()
488 (const struct cras_connect_message *)msg, fd); in cras_rclient_message_from_client()
489 } else if (is_connect_msg_old(msg, &cmsg)) { in cras_rclient_message_from_client()
496 if (!MSG_LEN_VALID(msg, struct cras_disconnect_stream_message)) in cras_rclient_message_from_client()
499 (const struct cras_disconnect_stream_message *)msg); in cras_rclient_message_from_client()
502 if (!MSG_LEN_VALID(msg, struct cras_set_system_volume)) in cras_rclient_message_from_client()
505 ((const struct cras_set_system_volume *)msg)->volume); in cras_rclient_message_from_client()
508 if (!MSG_LEN_VALID(msg, struct cras_set_system_mute)) in cras_rclient_message_from_client()
511 ((const struct cras_set_system_mute *)msg)->mute); in cras_rclient_message_from_client()
514 if (!MSG_LEN_VALID(msg, struct cras_set_system_mute)) in cras_rclient_message_from_client()
517 ((const struct cras_set_system_mute *)msg)->mute); in cras_rclient_message_from_client()
520 if (!MSG_LEN_VALID(msg, struct cras_set_system_mute)) in cras_rclient_message_from_client()
523 ((const struct cras_set_system_mute *)msg)->mute); in cras_rclient_message_from_client()
527 (const struct cras_set_system_capture_gain *)msg; in cras_rclient_message_from_client()
528 if (!MSG_LEN_VALID(msg, struct cras_set_system_capture_gain)) in cras_rclient_message_from_client()
534 if (!MSG_LEN_VALID(msg, struct cras_set_system_mute)) in cras_rclient_message_from_client()
537 ((const struct cras_set_system_mute *)msg)->mute); in cras_rclient_message_from_client()
540 if (!MSG_LEN_VALID(msg, struct cras_set_system_mute)) in cras_rclient_message_from_client()
543 ((const struct cras_set_system_mute *)msg)->mute); in cras_rclient_message_from_client()
547 (const struct cras_set_node_attr *)msg; in cras_rclient_message_from_client()
548 if (!MSG_LEN_VALID(msg, struct cras_set_node_attr)) in cras_rclient_message_from_client()
555 (const struct cras_select_node *)msg; in cras_rclient_message_from_client()
556 if (!MSG_LEN_VALID(msg, struct cras_select_node) || in cras_rclient_message_from_client()
564 (const struct cras_add_active_node *)msg; in cras_rclient_message_from_client()
565 if (!MSG_LEN_VALID(msg, struct cras_add_active_node) || in cras_rclient_message_from_client()
573 (const struct cras_rm_active_node *)msg; in cras_rclient_message_from_client()
574 if (!MSG_LEN_VALID(msg, struct cras_rm_active_node) || in cras_rclient_message_from_client()
594 (const struct cras_add_test_dev *)msg; in cras_rclient_message_from_client()
595 if (!MSG_LEN_VALID(msg, struct cras_add_test_dev)) in cras_rclient_message_from_client()
602 (const struct cras_test_dev_command *)msg; in cras_rclient_message_from_client()
603 if (!MSG_LEN_VALID(msg, struct cras_test_dev_command)) in cras_rclient_message_from_client()
618 (const struct cras_config_global_remix *)msg; in cras_rclient_message_from_client()
619 if (!MSG_LEN_VALID(msg, struct cras_config_global_remix) || in cras_rclient_message_from_client()
625 if (size_with_coefficients != msg->length) in cras_rclient_message_from_client()
634 if (!MSG_LEN_VALID(msg, struct cras_get_hotword_models)) in cras_rclient_message_from_client()
637 ((const struct cras_get_hotword_models *)msg)->node_id); in cras_rclient_message_from_client()
642 (const struct cras_set_hotword_model *)msg; in cras_rclient_message_from_client()
643 if (!MSG_LEN_VALID(msg, struct cras_set_hotword_model)) in cras_rclient_message_from_client()
651 (struct cras_register_notification *)msg; in cras_rclient_message_from_client()
652 if (!MSG_LEN_VALID(msg, struct cras_register_notification)) in cras_rclient_message_from_client()
661 (const struct cras_set_aec_dump *)msg; in cras_rclient_message_from_client()
662 if (!MSG_LEN_VALID(msg, struct cras_set_aec_dump)) in cras_rclient_message_from_client()
682 const struct cras_client_message *msg, in cras_rclient_send_message() argument
686 return cras_send_with_fds(client->fd, (const void *)msg, msg->length, in cras_rclient_send_message()