[svn-commits] branch group/new_loader_completion r25609 - /team/group/new_loader_completion...

[svn-commits at lists.digium.com]

Author: kpfleming
Date: Mon May  8 10:17:55 2006
New Revision: 25609

URL: http://svn.digium.com/view/asterisk?rev=25609&view=rev
Log:
update func_realtime for new loader

Modified:
    team/group/new_loader_completion/funcs/func_realtime.c

Modified: team/group/new_loader_completion/funcs/func_realtime.c
URL: http://svn.digium.com/view/asterisk/team/group/new_loader_completion/funcs/func_realtime.c?rev=25609&r1=25608&r2=25609&view=diff
==============================================================================
--- team/group/new_loader_completion/funcs/func_realtime.c (original)
+++ team/group/new_loader_completion/funcs/func_realtime.c Mon May  8 10:17:55 2006
@@ -32,7 +32,7 @@
 
 #include "asterisk.h"
 
-/* ASTERISK_FILE_VERSION(__FILE__, "$Revision$") */
+ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 
 #include "asterisk/file.h"
 #include "asterisk/channel.h"
@@ -43,20 +43,14 @@
 #include "asterisk/lock.h"
 #include "asterisk/logger.h"
 #include "asterisk/utils.h"
-#include "asterisk/module.h"
 #include "asterisk/app.h"
-
-LOCAL_USER_DECL;
-
-static char *tdesc = "Read/Write values from a RealTime repository";
 
 static int function_realtime_read(struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len) 
 {
 	struct ast_variable *var, *head;
-        struct localuser *u;
+        struct ast_module_user *u;
 	char *results;
 	size_t resultslen = 0;
-
 	AST_DECLARE_APP_ARGS(args,
 		AST_APP_ARG(family);
 		AST_APP_ARG(fieldmatch);
@@ -70,7 +64,9 @@
 		ast_log(LOG_WARNING, "Syntax: REALTIME(family|fieldmatch[|value[|delim1[|delim2]]]) - missing argument!\n");
 		return -1;
 	}
-	LOCAL_USER_ADD(u);
+
+	u = ast_module_user_add(chan);
+
 	AST_STANDARD_APP_ARGS(args, data);
 
 	if (!args.delim1)
@@ -81,7 +77,7 @@
 	head = ast_load_realtime(args.family, args.fieldmatch, args.value, NULL);
 
 	if (!head) {
-		LOCAL_USER_REMOVE(u);
+		ast_module_user_remove(u);
 		return -1;
 	}
 	for (var = head; var; var = var->next)
@@ -92,16 +88,15 @@
 		ast_build_string(&results, &resultslen, "%s%s%s%s", var->name, args.delim2, var->value, args.delim1);
 	ast_copy_string(buf, results, len);
 
-	LOCAL_USER_REMOVE(u);
+	ast_module_user_remove(u);
+
 	return 0;
 }
 
 static int function_realtime_write(struct ast_channel *chan, char *cmd, char *data, const char *value)
 {
-        struct localuser *u;
+        struct ast_module_user *u;
 	int res = 0;
-
-
 	AST_DECLARE_APP_ARGS(args,
 		AST_APP_ARG(family);
 		AST_APP_ARG(fieldmatch);
@@ -114,7 +109,8 @@
 		return -1;
 	}
 
-	LOCAL_USER_ADD(u);
+	u = ast_module_user_add(chan);
+
 	AST_STANDARD_APP_ARGS(args, data);
 
 	res = ast_update_realtime(args.family, args.fieldmatch, args.value, args.field, (char *)value, NULL);
@@ -123,7 +119,8 @@
 		ast_log(LOG_WARNING, "Failed to update. Check the debug log for possible data repository related entries.\n");
 	}
 
-	LOCAL_USER_REMOVE(u);
+	ast_module_user_remove(u);
+
 	return 0;
 }
 
@@ -145,30 +142,20 @@
 	.write = function_realtime_write,
 };
 
-static int unload_module(void *mod)
+static int unload_module(void)
 {
         int res = ast_custom_function_unregister(&realtime_function);
 
-	STANDARD_HANGUP_LOCALUSERS;
+	ast_module_user_hangup_all();
 
         return res;
 }
 
-static int load_module(void *mod)
+static int load_module(void)
 {
         int res = ast_custom_function_register(&realtime_function);
 
         return res;
 }
 
-static const char *description(void)
-{
-        return tdesc;
-}
-
-static const char *key(void)
-{
-        return ASTERISK_GPL_KEY;
-}
-
-STD_MOD(MOD_1, NULL, NULL, NULL);
+AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Read/Write values from a RealTime repository");