[svn-commits] eliel: branch eliel/data_api_providers_gsoc2010 r273872 - /team/eliel/data_ap...

[SVN commits to the Digium repositories]

Author: eliel
Date: Sat Jul  3 17:01:02 2010
New Revision: 273872

URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=273872
Log:
Implements de hints data provider.


Modified:
    team/eliel/data_api_providers_gsoc2010/main/pbx.c

Modified: team/eliel/data_api_providers_gsoc2010/main/pbx.c
URL: http://svnview.digium.com/svn/asterisk/team/eliel/data_api_providers_gsoc2010/main/pbx.c?view=diff&rev=273872&r1=273871&r2=273872
==============================================================================
--- team/eliel/data_api_providers_gsoc2010/main/pbx.c (original)
+++ team/eliel/data_api_providers_gsoc2010/main/pbx.c Sat Jul  3 17:01:02 2010
@@ -9717,6 +9717,57 @@
 	}
 }
 
+/*!                             
+ * \internal                            
+ * \brief Implements the hints data provider.
+ */
+static int hints_data_provider_get(const struct ast_data_search *search,
+	struct ast_data *data_root)
+{
+	struct ast_data *data_hint;
+	struct ast_hint *hint;
+	int watchers;
+	struct ast_state_cb *watcher;
+
+	AST_RWLIST_RDLOCK(&hints);
+	if (AST_RWLIST_EMPTY(&hints)) {
+		AST_RWLIST_UNLOCK(&hints);
+		return 0;
+	}
+
+	AST_RWLIST_TRAVERSE(&hints, hint, list) {
+		watchers = 0;
+		AST_LIST_TRAVERSE(&hint->callbacks, watcher, entry) {
+			watchers++;
+		}
+		data_hint = ast_data_add_node(data_root, "hint");
+		if (!data_hint) {
+			continue;
+		}
+		ast_data_add_str(data_hint, "extension", ast_get_extension_name(hint->exten));
+		ast_data_add_str(data_hint, "context", ast_get_context_name(ast_get_extension_context(hint->exten)));
+		ast_data_add_str(data_hint, "application", ast_get_extension_app(hint->exten));
+		ast_data_add_str(data_hint, "state", ast_extension_state2str(hint->laststate));
+		ast_data_add_int(data_hint, "watchers", watchers);
+
+		if (!ast_data_search_match(search, data_hint)) {
+			ast_data_remove_node(data_root, data_hint);
+		}
+	}
+	AST_RWLIST_UNLOCK(&hints);
+
+	return 0;
+}
+
+static const struct ast_data_handler hints_data_provider = {
+	.version = AST_DATA_HANDLER_VERSION,
+	.get = hints_data_provider_get
+};
+
+static const struct ast_data_entry pbx_data_providers[] = {
+	AST_DATA_ENTRY("asterisk/core/hints", &hints_data_provider),
+};
+
 int load_pbx(void)
 {
 	int x;
@@ -9729,6 +9780,7 @@
 
 	ast_verb(1, "Registering builtin applications:\n");
 	ast_cli_register_multiple(pbx_cli, ARRAY_LEN(pbx_cli));
+	ast_data_register_multiple_core(pbx_data_providers, ARRAY_LEN(pbx_data_providers));
 	__ast_custom_function_register(&exception_function, NULL);
 	__ast_custom_function_register(&testtime_function, NULL);