| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | /* Spa ALSA Source
 | 
					
						
							|  |  |  |  * Copyright (C) 2016 Wim Taymans <wim.taymans@gmail.com> | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * This library is free software; you can redistribute it and/or | 
					
						
							|  |  |  |  * modify it under the terms of the GNU Library General Public | 
					
						
							|  |  |  |  * License as published by the Free Software Foundation; either | 
					
						
							|  |  |  |  * version 2 of the License, or (at your option) any later version. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * This library is distributed in the hope that it will be useful, | 
					
						
							|  |  |  |  * but WITHOUT ANY WARRANTY; without even the implied warranty of | 
					
						
							|  |  |  |  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU | 
					
						
							|  |  |  |  * Library General Public License for more details. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * You should have received a copy of the GNU Library General Public | 
					
						
							|  |  |  |  * License along with this library; if not, write to the | 
					
						
							|  |  |  |  * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, | 
					
						
							|  |  |  |  * Boston, MA 02110-1301, USA. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #include <stddef.h>
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #include <asoundlib.h>
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-10 13:36:14 +01:00
										 |  |  | #include <spa/node/node.h>
 | 
					
						
							|  |  |  | #include <spa/utils/list.h>
 | 
					
						
							|  |  |  | #include <spa/param/audio/format.h>
 | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | #include <lib/pod.h>
 | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | #define NAME "alsa-source"
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | #include "alsa-utils.h"
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | #define CHECK_PORT(this,d,p)    ((d) == SPA_DIRECTION_OUTPUT && (p) == 0)
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | static const char default_device[] = "hw:0"; | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | static const uint32_t default_min_latency = 64; | 
					
						
							|  |  |  | static const uint32_t default_max_latency = 1024; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static void reset_props(struct props *props) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	strncpy(props->device, default_device, 64); | 
					
						
							|  |  |  | 	props->min_latency = default_min_latency; | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 	props->max_latency = default_max_latency; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | static int impl_node_enum_params(struct spa_node *node, | 
					
						
							|  |  |  | 				 uint32_t id, uint32_t *index, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 				 const struct spa_pod *filter, | 
					
						
							|  |  |  | 				 struct spa_pod **result, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 				 struct spa_pod_builder *builder) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	struct type *t; | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 	struct spa_pod *param; | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 	uint8_t buffer[1024]; | 
					
						
							|  |  |  | 	struct spa_pod_builder b = { 0 }; | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 	struct props *p; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(index != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(builder != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	t = &this->type; | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 	p = &this->props; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  |       next: | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 	spa_pod_builder_init(&b, buffer, sizeof(buffer)); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	if (id == t->param.idList) { | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 		uint32_t list[] = { t->param.idPropInfo, | 
					
						
							|  |  |  | 				    t->param.idProps }; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 		if (*index < SPA_N_ELEMENTS(list)) | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, id, t->param.List, | 
					
						
							|  |  |  | 				":", t->param.listId, "I", list[*index]); | 
					
						
							|  |  |  | 		else | 
					
						
							|  |  |  | 			return 0; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idPropInfo) { | 
					
						
							|  |  |  | 		switch (*index) { | 
					
						
							|  |  |  | 		case 0: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->param.PropInfo, | 
					
						
							|  |  |  | 				":", t->param.propId, "I", t->prop_device, | 
					
						
							|  |  |  | 				":", t->param.propName, "s", "The ALSA device", | 
					
						
							|  |  |  | 				":", t->param.propType, "S", p->device, sizeof(p->device)); | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 		case 1: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->param.PropInfo, | 
					
						
							|  |  |  | 				":", t->param.propId, "I", t->prop_device_name, | 
					
						
							|  |  |  | 				":", t->param.propName, "s", "The ALSA device name", | 
					
						
							|  |  |  | 				":", t->param.propType, "S-r", p->device_name, sizeof(p->device_name)); | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 		case 2: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->param.PropInfo, | 
					
						
							|  |  |  | 				":", t->param.propId, "I", t->prop_card_name, | 
					
						
							|  |  |  | 				":", t->param.propName, "s", "The ALSA card name", | 
					
						
							|  |  |  | 				":", t->param.propType, "S-r", p->card_name, sizeof(p->card_name)); | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 		case 3: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->param.PropInfo, | 
					
						
							|  |  |  | 				":", t->param.propId, "I", t->prop_min_latency, | 
					
						
							|  |  |  | 				":", t->param.propName, "s", "The minimum latency", | 
					
						
							|  |  |  | 				":", t->param.propType, "ir", p->min_latency, | 
					
						
							| 
									
										
										
										
											2018-02-20 09:32:40 +01:00
										 |  |  | 					SPA_POD_PROP_MIN_MAX(1, INT32_MAX)); | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 			break; | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 		case 4: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->param.PropInfo, | 
					
						
							|  |  |  | 				":", t->param.propId,   "I", t->prop_max_latency, | 
					
						
							|  |  |  | 				":", t->param.propName, "s", "The maximum latency", | 
					
						
							|  |  |  | 				":", t->param.propType, "ir", p->max_latency, | 
					
						
							|  |  |  | 					SPA_POD_PROP_MIN_MAX(1, INT32_MAX)); | 
					
						
							|  |  |  | 			break; | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 		default: | 
					
						
							|  |  |  | 			return 0; | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idProps) { | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 		switch (*index) { | 
					
						
							|  |  |  | 		case 0: | 
					
						
							|  |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							|  |  |  | 				id, t->props, | 
					
						
							|  |  |  | 				":", t->prop_device,      "S",   p->device, sizeof(p->device), | 
					
						
							|  |  |  | 				":", t->prop_device_name, "S-r", p->device_name, sizeof(p->device_name), | 
					
						
							|  |  |  | 				":", t->prop_card_name,   "S-r", p->card_name, sizeof(p->card_name), | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 				":", t->prop_min_latency, "i",   p->min_latency, | 
					
						
							|  |  |  | 				":", t->prop_max_latency, "i",   p->max_latency); | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 			break; | 
					
						
							|  |  |  | 		default: | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return 0; | 
					
						
							| 
									
										
										
										
											2017-12-15 16:30:56 +01:00
										 |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	(*index)++; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 	if (spa_pod_filter(builder, result, param, filter) < 0) | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 		goto next; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 1; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | static int impl_node_set_param(struct spa_node *node, uint32_t id, uint32_t flags, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 			       const struct spa_pod *param) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	struct type *t; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	t = &this->type; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	if (id == t->param.idProps) { | 
					
						
							|  |  |  | 		struct props *p = &this->props; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		if (param == NULL) { | 
					
						
							|  |  |  | 			reset_props(p); | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return 0; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 		} | 
					
						
							|  |  |  | 		spa_pod_object_parse(param, | 
					
						
							|  |  |  | 			":", t->prop_device,      "?S", p->device, sizeof(p->device), | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 			":", t->prop_min_latency, "?i", &p->min_latency, | 
					
						
							|  |  |  | 			":", t->prop_max_latency, "?i", &p->max_latency, NULL); | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-07-25 19:52:31 +02:00
										 |  |  | static int impl_node_send_command(struct spa_node *node, const struct spa_command *command) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2018-01-18 11:57:23 +01:00
										 |  |  | 	int res; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(command != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (SPA_COMMAND_TYPE(command) == this->type.command_node.Start) { | 
					
						
							|  |  |  | 		if (!this->have_format) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EIO; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		if (this->n_buffers == 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EIO; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-01-18 11:57:23 +01:00
										 |  |  | 		if ((res = spa_alsa_start(this, false)) < 0) | 
					
						
							|  |  |  | 			return res; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} else if (SPA_COMMAND_TYPE(command) == this->type.command_node.Pause) { | 
					
						
							| 
									
										
										
										
											2018-01-18 11:57:23 +01:00
										 |  |  | 		if ((res = spa_alsa_pause(this, false)) < 0) | 
					
						
							|  |  |  | 			return res; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2017-03-22 10:04:24 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_set_callbacks(struct spa_node *node, | 
					
						
							| 
									
										
										
										
											2017-06-18 19:48:31 +02:00
										 |  |  | 			const struct spa_node_callbacks *callbacks, | 
					
						
							| 
									
										
										
										
											2017-08-06 06:42:26 +02:00
										 |  |  | 			void *data) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-06-14 18:32:39 +02:00
										 |  |  | 	this->callbacks = callbacks; | 
					
						
							| 
									
										
										
										
											2017-08-06 06:42:26 +02:00
										 |  |  | 	this->callbacks_data = data; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_get_n_ports(struct spa_node *node, | 
					
						
							| 
									
										
										
										
											2017-05-26 18:19:51 +02:00
										 |  |  | 		      uint32_t *n_input_ports, | 
					
						
							|  |  |  | 		      uint32_t *max_input_ports, | 
					
						
							|  |  |  | 		      uint32_t *n_output_ports, | 
					
						
							|  |  |  | 		      uint32_t *max_output_ports) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (n_input_ports) | 
					
						
							|  |  |  | 		*n_input_ports = 0; | 
					
						
							|  |  |  | 	if (max_input_ports) | 
					
						
							|  |  |  | 		*max_input_ports = 0; | 
					
						
							|  |  |  | 	if (n_output_ports) | 
					
						
							|  |  |  | 		*n_output_ports = 1; | 
					
						
							|  |  |  | 	if (max_output_ports) | 
					
						
							|  |  |  | 		*max_output_ports = 1; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_get_port_ids(struct spa_node *node, | 
					
						
							| 
									
										
										
										
											2017-05-26 18:19:51 +02:00
										 |  |  | 		       uint32_t *input_ids, | 
					
						
							| 
									
										
										
										
											2017-11-20 15:26:44 +01:00
										 |  |  | 		       uint32_t n_input_ids, | 
					
						
							|  |  |  | 		       uint32_t *output_ids, | 
					
						
							|  |  |  | 		       uint32_t n_output_ids) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-20 15:26:44 +01:00
										 |  |  | 	if (n_output_ids > 0 && output_ids != NULL) | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		output_ids[0] = 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static int impl_node_add_port(struct spa_node *node, enum spa_direction direction, uint32_t port_id) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static int impl_node_remove_port(struct spa_node *node, enum spa_direction direction, uint32_t port_id) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | impl_node_port_get_info(struct spa_node *node, | 
					
						
							|  |  |  | 			enum spa_direction direction, uint32_t port_id, const struct spa_port_info **info) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(info != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	*info = &this->info; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static void recycle_buffer(struct state *this, uint32_t buffer_id) | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2018-03-08 11:02:21 +01:00
										 |  |  | 	struct buffer *b = &this->buffers[buffer_id]; | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-03-08 11:02:21 +01:00
										 |  |  | 	if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_OUT)) { | 
					
						
							|  |  |  | 		spa_log_trace(this->log, NAME " %p: recycle buffer %u", this, buffer_id); | 
					
						
							|  |  |  | 		spa_list_append(&this->free, &b->link); | 
					
						
							|  |  |  | 		SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT); | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | static int port_get_format(struct spa_node *node, | 
					
						
							|  |  |  | 			   enum spa_direction direction, uint32_t port_id, | 
					
						
							|  |  |  | 			   uint32_t *index, | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 			   struct spa_pod **param, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 			   struct spa_pod_builder *builder) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct state *this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							|  |  |  | 	struct type *t = &this->type; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (!this->have_format) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EIO; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	if (*index > 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return 0; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 	*param = spa_pod_builder_object(builder, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 		t->param.idFormat, t->format, | 
					
						
							|  |  |  | 		"I", t->media_type.audio, | 
					
						
							|  |  |  | 		"I", t->media_subtype.raw, | 
					
						
							|  |  |  | 		":", t->format_audio.format,   "I", this->current_format.info.raw.format, | 
					
						
							| 
									
										
										
										
											2018-04-19 20:09:10 +02:00
										 |  |  | 		":", t->format_audio.layout,   "i", this->current_format.info.raw.layout, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 		":", t->format_audio.rate,     "i", this->current_format.info.raw.rate, | 
					
						
							|  |  |  | 		":", t->format_audio.channels, "i", this->current_format.info.raw.channels); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 1; | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | impl_node_port_enum_params(struct spa_node *node, | 
					
						
							|  |  |  | 			   enum spa_direction direction, uint32_t port_id, | 
					
						
							|  |  |  | 			   uint32_t id, uint32_t *index, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 			   const struct spa_pod *filter, | 
					
						
							|  |  |  | 			   struct spa_pod **result, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 			   struct spa_pod_builder *builder) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	struct type *t; | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 	struct spa_pod *param; | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 	struct spa_pod_builder b = { 0 }; | 
					
						
							|  |  |  | 	uint8_t buffer[1024]; | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 	int res; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(index != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(builder != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	t = &this->type; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  |       next: | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 	spa_pod_builder_init(&b, buffer, sizeof(buffer)); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	if (id == t->param.idList) { | 
					
						
							|  |  |  | 		uint32_t list[] = { t->param.idEnumFormat, | 
					
						
							|  |  |  | 				    t->param.idFormat, | 
					
						
							|  |  |  | 				    t->param.idBuffers, | 
					
						
							|  |  |  | 				    t->param.idMeta }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		if (*index < SPA_N_ELEMENTS(list)) | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 			param = spa_pod_builder_object(&b, id, t->param.List, | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 				":", t->param.listId, "I", list[*index]); | 
					
						
							|  |  |  | 		else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return 0; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idEnumFormat) { | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 		return spa_alsa_enum_format(this, index, filter, result, builder); | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idFormat) { | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 		if ((res = port_get_format(node, direction, port_id, index, ¶m, &b)) <= 0) | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 			return res; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idBuffers) { | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 		if (!this->have_format) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EIO; | 
					
						
							| 
									
										
										
										
											2017-11-07 20:28:07 +01:00
										 |  |  | 		if (*index > 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return 0; | 
					
						
							| 
									
										
										
										
											2017-11-07 20:28:07 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 		param = spa_pod_builder_object(&b, | 
					
						
							| 
									
										
										
										
											2017-11-10 13:36:14 +01:00
										 |  |  | 			id, t->param_buffers.Buffers, | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 			":", t->param_buffers.size,    "iru", this->props.max_latency * | 
					
						
							|  |  |  | 							      this->frame_size, | 
					
						
							|  |  |  | 				SPA_POD_PROP_MIN_MAX(this->props.min_latency * this->frame_size, | 
					
						
							|  |  |  | 						     INT32_MAX), | 
					
						
							|  |  |  | 			":", t->param_buffers.stride,  "i", this->frame_size, | 
					
						
							| 
									
										
										
										
											2017-11-10 13:36:14 +01:00
										 |  |  | 			":", t->param_buffers.buffers, "ir", 2, | 
					
						
							| 
									
										
										
										
											2018-02-20 09:32:40 +01:00
										 |  |  | 				SPA_POD_PROP_MIN_MAX(1, MAX_BUFFERS), | 
					
						
							| 
									
										
										
										
											2017-11-10 13:36:14 +01:00
										 |  |  | 			":", t->param_buffers.align,   "i", 16); | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	else if (id == t->param.idMeta) { | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 		if (!this->have_format) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EIO; | 
					
						
							| 
									
										
										
										
											2017-11-08 11:22:42 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 		switch (*index) { | 
					
						
							|  |  |  | 		case 0: | 
					
						
							| 
									
										
										
										
											2017-11-14 10:17:45 +01:00
										 |  |  | 			param = spa_pod_builder_object(&b, | 
					
						
							| 
									
										
										
										
											2017-11-10 13:36:14 +01:00
										 |  |  | 				id, t->param_meta.Meta, | 
					
						
							|  |  |  | 				":", t->param_meta.type, "I", t->meta.Header, | 
					
						
							|  |  |  | 				":", t->param_meta.size, "i", sizeof(struct spa_meta_header)); | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 			break; | 
					
						
							|  |  |  | 		default: | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return 0; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	(*index)++; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 	if (spa_pod_filter(builder, result, param, filter) < 0) | 
					
						
							| 
									
										
										
										
											2017-11-09 17:07:04 +01:00
										 |  |  | 		goto next; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 1; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int clear_buffers(struct state *this) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	if (this->n_buffers > 0) { | 
					
						
							|  |  |  | 		spa_list_init(&this->free); | 
					
						
							|  |  |  | 		spa_list_init(&this->ready); | 
					
						
							|  |  |  | 		this->n_buffers = 0; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int port_set_format(struct spa_node *node, | 
					
						
							|  |  |  | 			   enum spa_direction direction, uint32_t port_id, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 			   uint32_t flags, const struct spa_pod *format) | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | { | 
					
						
							|  |  |  | 	struct state *this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							|  |  |  | 	int err; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (format == NULL) { | 
					
						
							|  |  |  | 		spa_alsa_pause(this, false); | 
					
						
							|  |  |  | 		clear_buffers(this); | 
					
						
							|  |  |  | 		spa_alsa_close(this); | 
					
						
							|  |  |  | 		this->have_format = false; | 
					
						
							|  |  |  | 	} else { | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 		struct spa_audio_info info = { 0 }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		spa_pod_object_parse(format, | 
					
						
							|  |  |  | 			"I", &info.media_type, | 
					
						
							|  |  |  | 			"I", &info.media_subtype); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		if (info.media_type != this->type.media_type.audio || | 
					
						
							|  |  |  | 		    info.media_subtype != this->type.media_subtype.raw) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-03-17 11:58:09 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-09-21 18:57:41 +02:00
										 |  |  | 		if (spa_format_audio_raw_parse(format, &info.info.raw, &this->type.format_audio) < 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-03-17 11:58:09 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-10-26 15:13:33 +02:00
										 |  |  | 		if ((err = spa_alsa_set_format(this, &info, flags)) < 0) | 
					
						
							|  |  |  | 			return err; | 
					
						
							| 
									
										
										
										
											2017-03-17 11:58:09 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		this->current_format = info; | 
					
						
							|  |  |  | 		this->have_format = true; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (this->have_format) { | 
					
						
							|  |  |  | 		this->info.rate = this->rate; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | impl_node_port_set_param(struct spa_node *node, | 
					
						
							|  |  |  | 			 enum spa_direction direction, uint32_t port_id, | 
					
						
							|  |  |  | 			 uint32_t id, uint32_t flags, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 			 const struct spa_pod *param) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-09-21 18:57:41 +02:00
										 |  |  | 	struct type *t; | 
					
						
							| 
									
										
										
										
											2017-05-22 13:06:18 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-05-22 13:06:18 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2017-09-21 18:57:41 +02:00
										 |  |  | 	t = &this->type; | 
					
						
							| 
									
										
										
										
											2017-05-22 13:06:18 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-05-22 13:06:18 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	if (id == t->param.idFormat) { | 
					
						
							|  |  |  | 		return port_set_format(node, direction, port_id, flags, param); | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_port_use_buffers(struct spa_node *node, | 
					
						
							|  |  |  | 			   enum spa_direction direction, | 
					
						
							|  |  |  | 			   uint32_t port_id, struct spa_buffer **buffers, uint32_t n_buffers) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							|  |  |  | 	int res; | 
					
						
							|  |  |  | 	int i; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-04-04 09:00:49 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (!this->have_format) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EIO; | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (this->n_buffers > 0) { | 
					
						
							|  |  |  | 		spa_alsa_pause(this, false); | 
					
						
							|  |  |  | 		if ((res = clear_buffers(this)) < 0) | 
					
						
							|  |  |  | 			return res; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	for (i = 0; i < n_buffers; i++) { | 
					
						
							|  |  |  | 		struct buffer *b = &this->buffers[i]; | 
					
						
							|  |  |  | 		struct spa_data *d = buffers[i]->datas; | 
					
						
							| 
									
										
										
										
											2017-04-26 18:42:50 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-05-11 09:56:46 +02:00
										 |  |  | 		b->buf = buffers[i]; | 
					
						
							| 
									
										
										
										
											2018-03-08 11:02:21 +01:00
										 |  |  | 		b->flags = 0; | 
					
						
							| 
									
										
										
										
											2016-10-04 19:37:44 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-05-11 09:56:46 +02:00
										 |  |  | 		b->h = spa_buffer_find_meta(b->buf, this->type.meta.Header); | 
					
						
							| 
									
										
										
										
											2017-04-26 18:42:50 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		if (!((d[0].type == this->type.data.MemFd || | 
					
						
							|  |  |  | 		       d[0].type == this->type.data.DmaBuf || | 
					
						
							|  |  |  | 		       d[0].type == this->type.data.MemPtr) && d[0].data != NULL)) { | 
					
						
							|  |  |  | 			spa_log_error(this->log, NAME " %p: need mapped memory", this); | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-10-24 12:58:10 +02:00
										 |  |  | 		spa_list_append(&this->free, &b->link); | 
					
						
							| 
									
										
										
										
											2018-04-30 09:27:20 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-06-25 17:07:59 +02:00
										 |  |  | 		this->threshold = SPA_MIN(d[0].maxsize / this->frame_size, | 
					
						
							|  |  |  | 				this->props.max_latency); | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	this->n_buffers = n_buffers; | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-09-20 19:52:05 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_port_alloc_buffers(struct spa_node *node, | 
					
						
							|  |  |  | 			     enum spa_direction direction, | 
					
						
							|  |  |  | 			     uint32_t port_id, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 			     struct spa_pod **params, | 
					
						
							| 
									
										
										
										
											2017-05-26 18:19:51 +02:00
										 |  |  | 			     uint32_t n_params, | 
					
						
							|  |  |  | 			     struct spa_buffer **buffers, | 
					
						
							|  |  |  | 			     uint32_t *n_buffers) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(buffers != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-04-04 09:00:49 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (this->n_buffers == 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EIO; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | impl_node_port_set_io(struct spa_node *node, | 
					
						
							|  |  |  | 		      enum spa_direction direction, | 
					
						
							|  |  |  | 		      uint32_t port_id, | 
					
						
							|  |  |  | 		      uint32_t id, | 
					
						
							| 
									
										
										
										
											2017-11-22 14:30:04 +01:00
										 |  |  | 		      void *data, size_t size) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | 	struct type *t; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | 	t = &this->type; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(CHECK_PORT(this, direction, port_id), -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | 	if (id == t->io.Buffers) | 
					
						
							| 
									
										
										
										
											2017-11-22 14:30:04 +01:00
										 |  |  | 		this->io = data; | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | 	else | 
					
						
							|  |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static int impl_node_port_reuse_buffer(struct spa_node *node, uint32_t port_id, uint32_t buffer_id) | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(port_id == 0, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (this->n_buffers == 0) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EIO; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (buffer_id >= this->n_buffers) | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EINVAL; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	recycle_buffer(this, buffer_id); | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_node_port_send_command(struct spa_node *node, | 
					
						
							| 
									
										
										
										
											2017-07-25 19:52:31 +02:00
										 |  |  | 			    enum spa_direction direction, uint32_t port_id, const struct spa_command *command) | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2018-01-18 11:57:23 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-03-20 11:37:11 +01:00
										 |  |  | static int impl_node_process(struct spa_node *node) | 
					
						
							| 
									
										
										
										
											2016-11-07 18:23:09 +01:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2017-11-21 19:34:37 +01:00
										 |  |  | 	struct spa_io_buffers *io; | 
					
						
							| 
									
										
										
										
											2018-04-26 17:22:17 +02:00
										 |  |  | 	struct buffer *b; | 
					
						
							| 
									
										
										
										
											2017-04-03 14:56:04 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(node != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-04-03 14:56:04 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(node, struct state, node); | 
					
						
							|  |  |  | 	io = this->io; | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(io != NULL, -EIO); | 
					
						
							| 
									
										
										
										
											2017-04-03 14:56:04 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	if (io->status == SPA_STATUS_HAVE_BUFFER) | 
					
						
							|  |  |  | 		return SPA_STATUS_HAVE_BUFFER; | 
					
						
							| 
									
										
										
										
											2017-04-28 17:22:23 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-08-27 09:16:03 +02:00
										 |  |  | 	if (io->buffer_id < this->n_buffers) { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 		recycle_buffer(this, io->buffer_id); | 
					
						
							|  |  |  | 		io->buffer_id = SPA_ID_INVALID; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2018-04-26 17:22:17 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	if (spa_list_is_empty(&this->ready)) | 
					
						
							|  |  |  | 		return -EPIPE; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	b = spa_list_first(&this->ready, struct buffer, link); | 
					
						
							|  |  |  | 	spa_list_remove(&b->link); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-05-11 09:56:46 +02:00
										 |  |  | 	spa_log_trace(this->log, NAME " %p: dequeue buffer %d", node, b->buf->id); | 
					
						
							| 
									
										
										
										
											2018-04-26 17:22:17 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-05-11 09:56:46 +02:00
										 |  |  | 	io->buffer_id = b->buf->id; | 
					
						
							| 
									
										
										
										
											2018-04-26 17:22:17 +02:00
										 |  |  | 	io->status = SPA_STATUS_HAVE_BUFFER; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return SPA_STATUS_HAVE_BUFFER; | 
					
						
							| 
									
										
										
										
											2016-11-07 18:23:09 +01:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | static const struct spa_dict_item node_info_items[] = { | 
					
						
							| 
									
										
										
										
											2017-09-18 19:15:09 +02:00
										 |  |  | 	{ "media.class", "Audio/Source" }, | 
					
						
							| 
									
										
										
										
											2018-04-26 17:22:17 +02:00
										 |  |  | 	{ "node.driver", "true" }, | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static const struct spa_dict node_info = { | 
					
						
							| 
									
										
										
										
											2017-11-20 15:26:44 +01:00
										 |  |  | 	node_info_items, | 
					
						
							|  |  |  | 	SPA_N_ELEMENTS(node_info_items) | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static const struct spa_node impl_node = { | 
					
						
							| 
									
										
										
										
											2017-06-14 18:32:39 +02:00
										 |  |  | 	SPA_VERSION_NODE, | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | 	&node_info, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	impl_node_enum_params, | 
					
						
							|  |  |  | 	impl_node_set_param, | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	impl_node_send_command, | 
					
						
							|  |  |  | 	impl_node_set_callbacks, | 
					
						
							|  |  |  | 	impl_node_get_n_ports, | 
					
						
							|  |  |  | 	impl_node_get_port_ids, | 
					
						
							|  |  |  | 	impl_node_add_port, | 
					
						
							|  |  |  | 	impl_node_remove_port, | 
					
						
							|  |  |  | 	impl_node_port_get_info, | 
					
						
							|  |  |  | 	impl_node_port_enum_params, | 
					
						
							|  |  |  | 	impl_node_port_set_param, | 
					
						
							|  |  |  | 	impl_node_port_use_buffers, | 
					
						
							|  |  |  | 	impl_node_port_alloc_buffers, | 
					
						
							|  |  |  | 	impl_node_port_set_io, | 
					
						
							|  |  |  | 	impl_node_port_reuse_buffer, | 
					
						
							|  |  |  | 	impl_node_port_send_command, | 
					
						
							| 
									
										
										
										
											2018-03-20 11:37:11 +01:00
										 |  |  | 	impl_node_process, | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | }; | 
					
						
							| 
									
										
										
										
											2016-10-03 19:43:42 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | static int impl_clock_enum_params(struct spa_clock *clock, uint32_t id, uint32_t *index, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 				  struct spa_pod **param, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 				  struct spa_pod_builder *builder) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | static int impl_clock_set_param(struct spa_clock *clock, | 
					
						
							|  |  |  | 				uint32_t id, uint32_t flags, | 
					
						
							| 
									
										
										
										
											2017-11-13 17:57:38 +01:00
										 |  |  | 				const struct spa_pod *param) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return -ENOTSUP; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 18:19:51 +02:00
										 |  |  | static int impl_clock_get_time(struct spa_clock *clock, | 
					
						
							|  |  |  | 			       int32_t *rate, | 
					
						
							|  |  |  | 			       int64_t *ticks, | 
					
						
							|  |  |  | 			       int64_t *monotonic_time) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(clock != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = SPA_CONTAINER_OF(clock, struct state, clock); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (rate) | 
					
						
							|  |  |  | 		*rate = SPA_USEC_PER_SEC; | 
					
						
							|  |  |  | 	if (ticks) | 
					
						
							|  |  |  | 		*ticks = this->last_ticks; | 
					
						
							|  |  |  | 	if (monotonic_time) | 
					
						
							|  |  |  | 		*monotonic_time = this->last_monotonic; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static const struct spa_clock impl_clock = { | 
					
						
							| 
									
										
										
										
											2017-06-14 18:32:39 +02:00
										 |  |  | 	SPA_VERSION_CLOCK, | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	NULL, | 
					
						
							|  |  |  | 	SPA_CLOCK_STATE_STOPPED, | 
					
						
							| 
									
										
										
										
											2017-11-07 17:39:31 +01:00
										 |  |  | 	impl_clock_enum_params, | 
					
						
							|  |  |  | 	impl_clock_set_param, | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	impl_clock_get_time, | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static int impl_get_interface(struct spa_handle *handle, uint32_t interface_id, void **interface) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	struct state *this; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(handle != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(interface != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	this = (struct state *) handle; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	if (interface_id == this->type.node) | 
					
						
							|  |  |  | 		*interface = &this->node; | 
					
						
							|  |  |  | 	else if (interface_id == this->type.clock) | 
					
						
							|  |  |  | 		*interface = &this->clock; | 
					
						
							|  |  |  | 	else | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -ENOENT; | 
					
						
							| 
									
										
										
										
											2016-10-07 13:14:32 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | static int impl_clear(struct spa_handle *handle) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-04-09 10:06:17 +02:00
										 |  |  | static size_t | 
					
						
							|  |  |  | impl_get_size(const struct spa_handle_factory *factory, | 
					
						
							|  |  |  | 	      const struct spa_dict *params) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	return sizeof(struct state); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_init(const struct spa_handle_factory *factory, | 
					
						
							|  |  |  | 	  struct spa_handle *handle, | 
					
						
							|  |  |  | 	  const struct spa_dict *info, | 
					
						
							|  |  |  | 	  const struct spa_support *support, | 
					
						
							|  |  |  | 	  uint32_t n_support) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct state *this; | 
					
						
							|  |  |  | 	uint32_t i; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(factory != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(handle != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	handle->get_interface = impl_get_interface; | 
					
						
							|  |  |  | 	handle->clear = impl_clear; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	this = (struct state *) handle; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	for (i = 0; i < n_support; i++) { | 
					
						
							|  |  |  | 		if (strcmp(support[i].type, SPA_TYPE__TypeMap) == 0) | 
					
						
							|  |  |  | 			this->map = support[i].data; | 
					
						
							|  |  |  | 		else if (strcmp(support[i].type, SPA_TYPE__Log) == 0) | 
					
						
							|  |  |  | 			this->log = support[i].data; | 
					
						
							|  |  |  | 		else if (strcmp(support[i].type, SPA_TYPE_LOOP__DataLoop) == 0) | 
					
						
							|  |  |  | 			this->data_loop = support[i].data; | 
					
						
							|  |  |  | 		else if (strcmp(support[i].type, SPA_TYPE_LOOP__MainLoop) == 0) | 
					
						
							|  |  |  | 			this->main_loop = support[i].data; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	if (this->map == NULL) { | 
					
						
							|  |  |  | 		spa_log_error(this->log, "an id-map is needed"); | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	if (this->data_loop == NULL) { | 
					
						
							|  |  |  | 		spa_log_error(this->log, "a data loop is needed"); | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	if (this->main_loop == NULL) { | 
					
						
							|  |  |  | 		spa_log_error(this->log, "a main loop is needed"); | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 		return -EINVAL; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	init_type(&this->type, this->map); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	this->node = impl_node; | 
					
						
							|  |  |  | 	this->clock = impl_clock; | 
					
						
							|  |  |  | 	this->stream = SND_PCM_STREAM_CAPTURE; | 
					
						
							|  |  |  | 	reset_props(&this->props); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-02-09 18:05:35 +01:00
										 |  |  | 	this->info.flags = SPA_PORT_INFO_FLAG_CAN_USE_BUFFERS | | 
					
						
							|  |  |  | 			   SPA_PORT_INFO_FLAG_LIVE | | 
					
						
							|  |  |  | 			   SPA_PORT_INFO_FLAG_PHYSICAL | | 
					
						
							|  |  |  | 			   SPA_PORT_INFO_FLAG_TERMINAL; | 
					
						
							| 
									
										
										
										
											2017-11-30 16:36:29 +01:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	spa_list_init(&this->free); | 
					
						
							|  |  |  | 	spa_list_init(&this->ready); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	for (i = 0; info && i < info->n_items; i++) { | 
					
						
							|  |  |  | 		if (!strcmp(info->items[i].key, "alsa.card")) { | 
					
						
							|  |  |  | 			snprintf(this->props.device, 63, "%s", info->items[i].value); | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static const struct spa_interface_info impl_interfaces[] = { | 
					
						
							|  |  |  | 	{SPA_TYPE__Node,}, | 
					
						
							|  |  |  | 	{SPA_TYPE__Clock,}, | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-05-25 13:28:15 +02:00
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | impl_enum_interface_info(const struct spa_handle_factory *factory, | 
					
						
							|  |  |  | 			 const struct spa_interface_info **info, | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 			 uint32_t *index) | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	spa_return_val_if_fail(factory != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(info != NULL, -EINVAL); | 
					
						
							|  |  |  | 	spa_return_val_if_fail(index != NULL, -EINVAL); | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	if (*index >= SPA_N_ELEMENTS(impl_interfaces)) | 
					
						
							|  |  |  | 		return 0; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	*info = &impl_interfaces[(*index)++]; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-11-13 09:41:41 +01:00
										 |  |  | 	return 1; | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | static const struct spa_dict_item info_items[] = { | 
					
						
							|  |  |  | 	{ "factory.author", "Wim Taymans <wim.taymans@gmail.com>" }, | 
					
						
							|  |  |  | 	{ "factory.description", "Record audio with the alsa API" }, | 
					
						
							|  |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static const struct spa_dict info = { | 
					
						
							| 
									
										
										
										
											2017-11-20 15:26:44 +01:00
										 |  |  | 	info_items, | 
					
						
							|  |  |  | 	SPA_N_ELEMENTS(info_items) | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-06-14 18:32:39 +02:00
										 |  |  | const struct spa_handle_factory spa_alsa_source_factory = { | 
					
						
							|  |  |  | 	SPA_VERSION_HANDLE_FACTORY, | 
					
						
							|  |  |  | 	NAME, | 
					
						
							| 
									
										
										
										
											2017-09-07 19:55:22 +02:00
										 |  |  | 	&info, | 
					
						
							| 
									
										
										
										
											2018-04-09 10:06:17 +02:00
										 |  |  | 	impl_get_size, | 
					
						
							| 
									
										
										
										
											2017-05-26 08:05:01 +02:00
										 |  |  | 	impl_init, | 
					
						
							|  |  |  | 	impl_enum_interface_info, | 
					
						
							| 
									
										
										
										
											2016-09-20 11:20:43 +02:00
										 |  |  | }; |