Schema bug fixes (parsable now).

Fixed some leaks.
Internal query API cleanups.
Added latency reporting support.



git-svn-id: http://svn.drobilla.net/lad/libslv2@110 a436a847-0d15-0410-975c-d299462d15a1

4 files changed, 106 insertions, 35 deletions

diff --git a/src/plugin.c b/src/plugin.c
index a6b2344..a024077 100644
--- a/src/plugin.c
+++ b/src/plugin.c
@@ -156,7 +156,7 @@ slv2_plugin_get_property(const SLV2Plugin* p,
 
 	rasqal_query_results* results = slv2_plugin_run_query(p, query);
 	
-	struct _Property* result = slv2_query_get_results(results);
+	SLV2Property result = slv2_query_get_results(results, "value");
 
 	rasqal_free_query_results(results);
 	rasqal_finish();
@@ -169,8 +169,6 @@ slv2_plugin_get_property(const SLV2Plugin* p,
 uint32_t
 slv2_plugin_get_num_ports(const SLV2Plugin* p)
 {
-	uint32_t result = 0;
-	
 	rasqal_init();
 	
     char* query = strjoin(
@@ -179,12 +177,32 @@ slv2_plugin_get_num_ports(const SLV2Plugin* p)
 		"} \n", NULL);
 
 	rasqal_query_results* results = slv2_plugin_run_query(p, query);
+	const size_t result = slv2_query_get_num_results(results, "value");
 	
-	while (!rasqal_query_results_finished(results)) {
-		++result;
-		rasqal_query_results_next(results);
-	}
+	rasqal_free_query_results(results);
+	rasqal_finish();
+	free(query);
 
+	return result;
+}
+
+
+bool
+slv2_plugin_has_latency(const SLV2Plugin* p)
+{
+	assert(p);
+
+	rasqal_init();
+	
+    char* query = 
+		"SELECT DISTINCT ?value FROM data: WHERE { \n"
+		"	plugin: lv2:port     ?port . \n"
+		"	?port   lv2:portHint lv2:reportsLatency . \n"
+		"}\n";
+
+	rasqal_query_results* results = slv2_plugin_run_query(p, query);
+	bool result = ( rasqal_query_results_get_bindings_count(results) > 0 );
+	
 	rasqal_free_query_results(results);
 	rasqal_finish();
     free(query);
@@ -192,3 +210,34 @@ slv2_plugin_get_num_ports(const SLV2Plugin* p)
 	return result;
 }
 
+uint32_t
+slv2_plugin_get_latency_port(const SLV2Plugin* p)
+{
+	assert(p);
+
+	rasqal_init();
+	
+    char* query = 
+		"SELECT DISTINCT ?value FROM data: WHERE { \n"
+		"	plugin: lv2:port     ?port . \n"
+		"	?port   lv2:portHint lv2:reportsLatency ; \n"
+		"           lv2:index    ?index . \n"
+		"}\n";
+
+	rasqal_query_results* results = slv2_plugin_run_query(p, query);
+	
+	struct _Property* result = slv2_query_get_results(results, "index");
+	
+	// FIXME: need a sane error handling strategy
+	assert(result->num_values == 1);
+	char* endptr = 0;
+	uint32_t index = strtol(result->values[0], &endptr, 10);
+	// FIXME: check.. stuff..
+	
+	rasqal_free_query_results(results);
+	rasqal_finish();
+	free(query);
+
+	return index;
+}
+
diff --git a/src/plugininstance.c b/src/plugininstance.c
index 6665fd7..f70866a 100644
--- a/src/plugininstance.c
+++ b/src/plugininstance.c
@@ -85,7 +85,7 @@ slv2_plugin_instantiate(const SLV2Plugin*        plugin,
 	assert(result);
 	assert(slv2_plugin_get_num_ports(plugin) > 0);
 
-	// Connect all ports to NULL (catches bugs)
+	// "Connect" all ports to NULL (catches bugs)
 	for (uint32_t i=0; i < slv2_plugin_get_num_ports(plugin); ++i)
 		result->descriptor->connect_port(result->lv2_handle, i, NULL);
 	
diff --git a/src/port.c b/src/port.c
index db18ab8..111517d 100644
--- a/src/port.c
+++ b/src/port.c
@@ -61,6 +61,8 @@ slv2_port_get_data_type(SLV2Plugin* p,
 	assert(type->values);
 
 	char* ret = type->values[0];
+	type->values[0] = NULL; // prevent deletion
+
 	slv2_property_free(type);
 	return ret;
 }
@@ -87,7 +89,7 @@ slv2_port_get_property(SLV2Plugin* p,
 
 	rasqal_query_results* results = slv2_plugin_run_query(p, query);
 	
-	SLV2Property result = slv2_query_get_results(results);
+	SLV2Property result = slv2_query_get_results(results, "value");
 
 	rasqal_free_query_results(results);
 	rasqal_finish();
@@ -107,8 +109,11 @@ slv2_port_get_symbol(SLV2Plugin* p,
 	SLV2Property prop
 		= slv2_port_get_property(p, index, "lv2:symbol");
 
-	if (prop && prop->num_values == 1)
-		result = strdup(prop->values[0]);
+	if (prop && prop->num_values == 1) {
+		result = prop->values[0];
+		prop->values[0] = NULL; // prevent deletion
+	}
+	
 	slv2_property_free(prop);
 
 	return result;
diff --git a/src/query.c b/src/query.c
index 0517331..8f3ef40 100644
--- a/src/query.c
+++ b/src/query.c
@@ -83,40 +83,57 @@ slv2_plugin_run_query(const SLV2Plugin* p,
 	return results;
 }
 
+size_t
+slv2_query_get_num_results(rasqal_query_results* results, const char* var_name)
+{
+	size_t result = 0;
+
+    while (!rasqal_query_results_finished(results)) {
+		if (!strcmp(rasqal_query_results_get_binding_name(results, 0), var_name)) {
+			++result;
+		}
+        rasqal_query_results_next(results);
+	}
+
+	return result;
+}
 
 SLV2Property
-slv2_query_get_results(rasqal_query_results* results)
+slv2_query_get_results(rasqal_query_results* results, const char* var_name)
 {
 	struct _Property* result = NULL;
-	
-	if (rasqal_query_results_get_count(results) > 0) {
-		result = malloc(sizeof(struct _Property));
-		result->num_values = 0;
-		result->values = NULL;
-	}
-	
-	while (!rasqal_query_results_finished(results)) {
-		
-		rasqal_literal* literal =
-			rasqal_query_results_get_binding_value_by_name(results, "value");
-		assert(literal != NULL);
-		
-		// Add value on to the array.  Yes, this is disgusting.
-		result->num_values++;
-		// FIXME LEAK:
-		result->values = realloc(result->values, result->num_values * sizeof(char*));
-		result->values[result->num_values-1] = strdup(rasqal_literal_as_string(literal));
-		
-		rasqal_query_results_next(results);
-	}
 
-	return result;
+    if (rasqal_query_results_get_bindings_count(results) > 0) {
+        result = malloc(sizeof(struct _Property));
+        result->num_values = 0;
+        result->values = NULL;
+    }
+
+    while (!rasqal_query_results_finished(results)) {
+
+        rasqal_literal* literal =
+            rasqal_query_results_get_binding_value_by_name(results, var_name);
+        assert(literal != NULL);
+
+        // Add value on to the array, reallocing all the way.
+		// Yes, this is disgusting.  Roughly as disgusting as the rasqal query
+		// results API.  coincidentally.
+        result->num_values++;
+        result->values = realloc(result->values, result->num_values * sizeof(char*));
+        result->values[result->num_values-1] = strdup(rasqal_literal_as_string(literal));
+
+        rasqal_query_results_next(results);
+    }
+
+    return result;
 }
 
 void
 slv2_property_free(struct _Property* prop)
 {
-	//struct _Property* prop = (struct _Property*)property;
+	for (size_t i=0; i < prop->num_values; ++i)
+		free(prop->values[i]);
+
 	free(prop->values);
 	free(prop);
 }