diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/plugin.c | 295 | ||||
| -rw-r--r-- | src/slv2_internal.h | 1 |
2 files changed, 154 insertions, 142 deletions
diff --git a/src/plugin.c b/src/plugin.c index 1986f2c..314bbbe 100644 --- a/src/plugin.c +++ b/src/plugin.c @@ -45,7 +45,7 @@ slv2_plugin_new(SLV2World world, SLV2Value uri, librdf_uri* bundle_uri) plugin->binary_uri = NULL; plugin->plugin_class = NULL; plugin->data_uris = slv2_values_new(); - plugin->ports = raptor_new_sequence((void (*)(void*))&slv2_port_free, NULL); + plugin->ports = NULL; plugin->storage = NULL; plugin->rdf = NULL; @@ -66,7 +66,8 @@ slv2_plugin_free(SLV2Plugin p) slv2_value_free(p->binary_uri); p->binary_uri = NULL; - raptor_free_sequence(p->ports); + if (p->ports) + raptor_free_sequence(p->ports); p->ports = NULL; if (p->rdf) { @@ -113,164 +114,105 @@ slv2_plugin_load_if_necessary(SLV2Plugin p) } +/* private */ void -slv2_plugin_load(SLV2Plugin p) +slv2_plugin_load_ports_if_necessary(SLV2Plugin p) { - //printf("Loading cache for %s\n", (const char*)librdf_uri_as_string(p->plugin_uri)); + if (!p->rdf) + slv2_plugin_load(p); - if (!p->storage) { - assert(!p->rdf); - //p->storage = librdf_new_storage(p->world->world, "hashes", NULL, - // "hash-type='memory'"); - p->storage = librdf_new_storage(p->world->world, "trees", NULL, NULL); - if (!p->storage) - p->storage = librdf_new_storage(p->world->world, "memory", NULL, NULL); - p->rdf = librdf_new_model(p->world->world, p->storage, NULL); - } + if (!p->ports) { + p->ports = raptor_new_sequence((void (*)(void*))&slv2_port_free, NULL); - // Parse all the plugin's data files into RDF model - for (unsigned i=0; i < slv2_values_size(p->data_uris); ++i) { - SLV2Value data_uri_val = slv2_values_get_at(p->data_uris, i); - librdf_uri* data_uri = librdf_new_uri(p->world->world, - (const unsigned char*)slv2_value_as_uri(data_uri_val)); - librdf_parser_parse_into_model(p->world->parser, data_uri, NULL, p->rdf); - librdf_free_uri(data_uri); - } + const unsigned char* query = (const unsigned char*) + "PREFIX : <http://lv2plug.in/ns/lv2core#>\n" + "SELECT DISTINCT ?type ?symbol ?index WHERE {\n" + "<> :port ?port .\n" + "?port a ?type ;\n" + " :symbol ?symbol ;\n" + " :index ?index .\n" + "} ORDER BY (?index)"; - // Load plugin_class - const unsigned char* query = (const unsigned char*) - "SELECT DISTINCT ?class WHERE { <> a ?class }"; - - librdf_query* q = librdf_new_query(p->world->world, "sparql", - NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); - - librdf_query_results* results = librdf_query_execute(q, p->rdf); - - while (!librdf_query_results_finished(results)) { - librdf_node* class_node = librdf_query_results_get_binding_value(results, 0); - librdf_uri* class_uri = librdf_node_get_uri(class_node); + librdf_query* q = librdf_new_query(p->world->world, "sparql", + NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); - if (!class_uri) { - librdf_query_results_next(results); - continue; - } + librdf_query_results* results = librdf_query_execute(q, p->rdf); - SLV2Value class = slv2_value_new_librdf_uri(p->world, class_uri); - - if ( ! slv2_value_equals(class, p->world->lv2_plugin_class->uri)) { + int num_ports = 0; + int last_index = -1; - SLV2PluginClass plugin_class = slv2_plugin_classes_get_by_uri( - p->world->plugin_classes, class); + while (!librdf_query_results_finished(results)) { - librdf_free_node(class_node); + librdf_node* type_node = librdf_query_results_get_binding_value(results, 0); + librdf_node* symbol_node = librdf_query_results_get_binding_value(results, 1); + librdf_node* index_node = librdf_query_results_get_binding_value(results, 2); - if (plugin_class) { - p->plugin_class = plugin_class; - slv2_value_free(class); - break; - } - } + assert(librdf_node_is_literal(symbol_node)); + assert(librdf_node_is_literal(index_node)); - slv2_value_free(class); - librdf_query_results_next(results); - } - - if (p->plugin_class == NULL) - p->plugin_class = p->world->lv2_plugin_class; + const char* symbol = (const char*)librdf_node_get_literal_value(symbol_node); + const char* index = (const char*)librdf_node_get_literal_value(index_node); - librdf_free_query_results(results); - librdf_free_query(q); - - // Load ports - query = (const unsigned char*) - "PREFIX : <http://lv2plug.in/ns/lv2core#>\n" - "SELECT DISTINCT ?type ?symbol ?index WHERE {\n" - "<> :port ?port .\n" - "?port a ?type ;\n" - " :symbol ?symbol ;\n" - " :index ?index .\n" - "} ORDER BY (?index)"; - - q = librdf_new_query(p->world->world, "sparql", - NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); - - results = librdf_query_execute(q, p->rdf); + //printf("PORT: %s %s %s\n", type, index, symbol); - int num_ports = 0; - int last_index = -1; + const int this_index = atoi(index); + SLV2Port this_port = NULL; - while (!librdf_query_results_finished(results)) { - - librdf_node* type_node = librdf_query_results_get_binding_value(results, 0); - librdf_node* symbol_node = librdf_query_results_get_binding_value(results, 1); - librdf_node* index_node = librdf_query_results_get_binding_value(results, 2); + // ORDER BY guarantees order + assert(this_index <= num_ports); - assert(librdf_node_is_literal(symbol_node)); - assert(librdf_node_is_literal(index_node)); + // Create a new SLV2Port, and add to template + if (this_index == num_ports) { + assert(this_index == last_index + 1); + this_port = slv2_port_new(p->world, (unsigned)atoi(index), symbol); + raptor_sequence_push(p->ports, this_port); + ++num_ports; + ++last_index; - const char* symbol = (const char*)librdf_node_get_literal_value(symbol_node); - const char* index = (const char*)librdf_node_get_literal_value(index_node); + // More information about a port we already created + } else if (this_index < num_ports) { + this_port = slv2_plugin_get_port_by_index(p, this_index); + } - //printf("PORT: %s %s %s\n", type, index, symbol); + if (this_port) { + raptor_sequence_push(this_port->classes, + slv2_value_new_librdf_uri(p->world, librdf_node_get_uri(type_node))); + } - const int this_index = atoi(index); - SLV2Port this_port = NULL; - - // ORDER BY guarantees order - assert(this_index <= num_ports); - - // Create a new SLV2Port, and add to template - if (this_index == num_ports) { - assert(this_index == last_index + 1); - this_port = slv2_port_new(p->world, (unsigned)atoi(index), symbol); - raptor_sequence_push(p->ports, this_port); - ++num_ports; - ++last_index; - - // More information about a port we already created - } else if (this_index < num_ports) { - this_port = slv2_plugin_get_port_by_index(p, this_index); - } - - if (this_port) { - raptor_sequence_push(this_port->classes, - slv2_value_new_librdf_uri(p->world, librdf_node_get_uri(type_node))); + librdf_free_node(type_node); + librdf_free_node(symbol_node); + librdf_free_node(index_node); + + librdf_query_results_next(results); } - librdf_free_node(type_node); - librdf_free_node(symbol_node); - librdf_free_node(index_node); - - librdf_query_results_next(results); + librdf_free_query_results(results); + librdf_free_query(q); } - - librdf_free_query_results(results); - librdf_free_query(q); +} - // Load binary URI - query = (const unsigned char*) - "PREFIX : <http://lv2plug.in/ns/lv2core#>\n" - "SELECT ?binary WHERE { <> :binary ?binary . }"; - - q = librdf_new_query(p->world->world, "sparql", - NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); - - results = librdf_query_execute(q, p->rdf); - if (!librdf_query_results_finished(results)) { - librdf_node* binary_node = librdf_query_results_get_binding_value(results, 0); - librdf_uri* binary_uri = librdf_node_get_uri(binary_node); - - if (binary_uri) { - SLV2Value binary = slv2_value_new_librdf_uri(p->world, binary_uri); - p->binary_uri = binary; - } +void +slv2_plugin_load(SLV2Plugin p) +{ + //printf("Loading cache for %s\n", slv2_value_as_string(p->plugin_uri)); - librdf_free_node(binary_node); + if (!p->storage) { + assert(!p->rdf); + p->storage = librdf_new_storage(p->world->world, "trees", NULL, NULL); + if (!p->storage) + p->storage = librdf_new_storage(p->world->world, "memory", NULL, NULL); + p->rdf = librdf_new_model(p->world->world, p->storage, NULL); + } + + // Parse all the plugin's data files into RDF model + for (unsigned i=0; i < slv2_values_size(p->data_uris); ++i) { + SLV2Value data_uri_val = slv2_values_get_at(p->data_uris, i); + librdf_uri* data_uri = librdf_new_uri(p->world->world, + (const unsigned char*)slv2_value_as_uri(data_uri_val)); + librdf_parser_parse_into_model(p->world->parser, data_uri, NULL, p->rdf); + librdf_free_uri(data_uri); } - - librdf_free_query_results(results); - librdf_free_query(q); } @@ -297,6 +239,31 @@ slv2_plugin_get_library_uri(SLV2Plugin p) { assert(p); slv2_plugin_load_if_necessary(p); + if (!p->binary_uri) { + const unsigned char* query = (const unsigned char*) + "PREFIX : <http://lv2plug.in/ns/lv2core#>\n" + "SELECT ?binary WHERE { <> :binary ?binary . }"; + + librdf_query* q = librdf_new_query(p->world->world, "sparql", + NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); + + librdf_query_results* results = librdf_query_execute(q, p->rdf); + + if (!librdf_query_results_finished(results)) { + librdf_node* binary_node = librdf_query_results_get_binding_value(results, 0); + librdf_uri* binary_uri = librdf_node_get_uri(binary_node); + + if (binary_uri) { + SLV2Value binary = slv2_value_new_librdf_uri(p->world, binary_uri); + p->binary_uri = binary; + } + + librdf_free_node(binary_node); + } + + librdf_free_query_results(results); + librdf_free_query(q); + } return p->binary_uri; } @@ -311,10 +278,52 @@ slv2_plugin_get_data_uris(SLV2Plugin p) SLV2PluginClass slv2_plugin_get_class(SLV2Plugin p) { - // FIXME: Typical use case this will bring every single plugin model - // into memory - slv2_plugin_load_if_necessary(p); + if (!p->plugin_class) { + const unsigned char* query = (const unsigned char*) + "SELECT DISTINCT ?class WHERE { <> a ?class }"; + + librdf_query* q = librdf_new_query(p->world->world, "sparql", + NULL, query, slv2_value_as_librdf_uri(p->plugin_uri)); + + librdf_query_results* results = librdf_query_execute(q, p->rdf); + + while (!librdf_query_results_finished(results)) { + librdf_node* class_node = librdf_query_results_get_binding_value(results, 0); + librdf_uri* class_uri = librdf_node_get_uri(class_node); + + if (!class_uri) { + librdf_query_results_next(results); + continue; + } + + SLV2Value class = slv2_value_new_librdf_uri(p->world, class_uri); + + if ( ! slv2_value_equals(class, p->world->lv2_plugin_class->uri)) { + + SLV2PluginClass plugin_class = slv2_plugin_classes_get_by_uri( + p->world->plugin_classes, class); + + librdf_free_node(class_node); + + if (plugin_class) { + p->plugin_class = plugin_class; + slv2_value_free(class); + break; + } + } + + slv2_value_free(class); + librdf_query_results_next(results); + } + + if (p->plugin_class == NULL) + p->plugin_class = p->world->lv2_plugin_class; + + librdf_free_query_results(results); + librdf_free_query(q); + } + return p->plugin_class; } @@ -507,7 +516,7 @@ slv2_plugin_get_hints(SLV2Plugin p) uint32_t slv2_plugin_get_num_ports(SLV2Plugin p) { - slv2_plugin_load_if_necessary(p); + slv2_plugin_load_ports_if_necessary(p); return raptor_sequence_size(p->ports); } @@ -517,7 +526,7 @@ slv2_plugin_get_port_float_values(SLV2Plugin p, const char* qname, float* values) { - slv2_plugin_load_if_necessary(p); + slv2_plugin_load_ports_if_necessary(p); for (int i = 0; i < raptor_sequence_size(p->ports); ++i) values[i] = NAN; @@ -576,6 +585,8 @@ uint32_t slv2_plugin_get_num_ports_of_class(SLV2Plugin p, SLV2Value class_1, ...) { + slv2_plugin_load_ports_if_necessary(p); + uint32_t ret = 0; va_list args; @@ -699,7 +710,7 @@ SLV2Port slv2_plugin_get_port_by_index(SLV2Plugin p, uint32_t index) { - slv2_plugin_load_if_necessary(p); + slv2_plugin_load_ports_if_necessary(p); return raptor_sequence_get_at(p->ports, (int)index); } @@ -708,7 +719,7 @@ SLV2Port slv2_plugin_get_port_by_symbol(SLV2Plugin p, SLV2Value symbol) { - slv2_plugin_load_if_necessary(p); + slv2_plugin_load_ports_if_necessary(p); for (int i=0; i < raptor_sequence_size(p->ports); ++i) { SLV2Port port = raptor_sequence_get_at(p->ports, i); if (slv2_value_equals(port->symbol, symbol)) diff --git a/src/slv2_internal.h b/src/slv2_internal.h index 9aea9f9..a6de9ad 100644 --- a/src/slv2_internal.h +++ b/src/slv2_internal.h @@ -69,6 +69,7 @@ struct _SLV2Plugin { SLV2Plugin slv2_plugin_new(SLV2World world, SLV2Value uri, librdf_uri* bundle_uri); void slv2_plugin_load(SLV2Plugin p); void slv2_plugin_load_if_necessary(SLV2Plugin p); +void slv2_plugin_load_ports_if_necessary(SLV2Plugin p); void slv2_plugin_free(SLV2Plugin plugin); void slv2_plugin_get_port_float_values(SLV2Plugin p, const char* qname, |