<p>George Joseph <strong>submitted</strong> this change.</p><p><a href="https://gerrit.asterisk.org/c/asterisk/+/16323">View Change</a></p><div style="white-space:pre-wrap">Approvals:
Sean Bright: Looks good to me, but someone else must approve
George Joseph: Looks good to me, approved
Friendly Automation: Approved for Submit
</div><pre style="font-family: monospace,monospace; white-space: pre-wrap;">res_config_sqlite: Remove deprecated module.<br><br>ASTERISK-29598<br><br>Change-Id: I8ef17023f55bf01f2e309b06f4778a8ca7252c91<br>---<br>M build_tools/menuselect-deps.in<br>D configs/samples/res_config_sqlite.conf.sample<br>M configure<br>M configure.ac<br>A doc/UPGRADE-staging/res_config_sqlite_removal.txt<br>M include/asterisk/autoconfig.h.in<br>D res/res_config_sqlite.c<br>7 files changed, 6 insertions(+), 1,942 deletions(-)<br><br></pre><pre style="font-family: monospace,monospace; white-space: pre-wrap;"><span>diff --git a/build_tools/menuselect-deps.in b/build_tools/menuselect-deps.in</span><br><span>index 89c9aa2..37c3be6 100644</span><br><span>--- a/build_tools/menuselect-deps.in</span><br><span>+++ b/build_tools/menuselect-deps.in</span><br><span>@@ -58,7 +58,6 @@</span><br><span> SPEEXDSP=@PBX_SPEEXDSP@</span><br><span> SPEEX_PREPROCESS=@PBX_SPEEX_PREPROCESS@</span><br><span> SQLITE3=@PBX_SQLITE3@</span><br><span style="color: hsl(0, 100%, 40%);">-SQLITE=@PBX_SQLITE@</span><br><span> SRTP=@PBX_SRTP@</span><br><span> SS7=@PBX_SS7@</span><br><span> OPENSSL=@PBX_OPENSSL@</span><br><span>diff --git a/configs/samples/res_config_sqlite.conf.sample b/configs/samples/res_config_sqlite.conf.sample</span><br><span>deleted file mode 100644</span><br><span>index 2d14d46..0000000</span><br><span>--- a/configs/samples/res_config_sqlite.conf.sample</span><br><span>+++ /dev/null</span><br><span>@@ -1,11 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-[general]</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-; The database file.</span><br><span style="color: hsl(0, 100%, 40%);">-dbfile => /var/lib/asterisk/sqlite.db</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-; Both config_table and cdr_table are optional. If config_table is omitted,</span><br><span style="color: hsl(0, 100%, 40%);">-; you must specify it in extconfig.conf. If it is both provided here and in</span><br><span style="color: hsl(0, 100%, 40%);">-; extconfig.conf, the value given here is used. If cdr_table is omitted, CDR</span><br><span style="color: hsl(0, 100%, 40%);">-; support is simply disabled.</span><br><span style="color: hsl(0, 100%, 40%);">-config_table => ast_config</span><br><span style="color: hsl(0, 100%, 40%);">-; cdr_table => ast_cdr</span><br><span>diff --git a/configure b/configure</span><br><span>index f6ca6ea..7d45eb8 100755</span><br><span>--- a/configure</span><br><span>+++ b/configure</span><br><span>@@ -780,10 +780,6 @@</span><br><span> SQLITE3_DIR</span><br><span> SQLITE3_INCLUDE</span><br><span> SQLITE3_LIB</span><br><span style="color: hsl(0, 100%, 40%);">-PBX_SQLITE</span><br><span style="color: hsl(0, 100%, 40%);">-SQLITE_DIR</span><br><span style="color: hsl(0, 100%, 40%);">-SQLITE_INCLUDE</span><br><span style="color: hsl(0, 100%, 40%);">-SQLITE_LIB</span><br><span> PBX_SPEEXDSP</span><br><span> SPEEXDSP_DIR</span><br><span> SPEEXDSP_INCLUDE</span><br><span>@@ -1412,7 +1408,6 @@</span><br><span> with_ss7</span><br><span> with_speex</span><br><span> with_speexdsp</span><br><span style="color: hsl(0, 100%, 40%);">-with_sqlite</span><br><span> with_sqlite3</span><br><span> with_srtp</span><br><span> with_ssl</span><br><span>@@ -2181,7 +2176,6 @@</span><br><span> --with-speex=PATH use Speex files in PATH</span><br><span> --with-speex=PATH use Speex preprocess routines files in PATH</span><br><span> --with-speexdsp=PATH use SpeexDSP files in PATH</span><br><span style="color: hsl(0, 100%, 40%);">- --with-sqlite=PATH use SQLite files in PATH</span><br><span> --with-sqlite3=PATH use SQLite files in PATH</span><br><span> --with-srtp=PATH use Secure RTP files in PATH</span><br><span> --with-ssl=PATH use OpenSSL Secure Sockets Layer files in PATH</span><br><span>@@ -12047,38 +12041,6 @@</span><br><span> </span><br><span> </span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_DESCRIP="SQLite"</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_OPTION="sqlite"</span><br><span style="color: hsl(0, 100%, 40%);">- PBX_SQLITE=0</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-# Check whether --with-sqlite was given.</span><br><span style="color: hsl(0, 100%, 40%);">-if test "${with_sqlite+set}" = set; then :</span><br><span style="color: hsl(0, 100%, 40%);">- withval=$with_sqlite;</span><br><span style="color: hsl(0, 100%, 40%);">- case ${withval} in</span><br><span style="color: hsl(0, 100%, 40%);">- n|no)</span><br><span style="color: hsl(0, 100%, 40%);">- USE_SQLITE=no</span><br><span style="color: hsl(0, 100%, 40%);">- # -1 is a magic value used by menuselect to know that the package</span><br><span style="color: hsl(0, 100%, 40%);">- # was disabled, other than 'not found'</span><br><span style="color: hsl(0, 100%, 40%);">- PBX_SQLITE=-1</span><br><span style="color: hsl(0, 100%, 40%);">- ;;</span><br><span style="color: hsl(0, 100%, 40%);">- y|ye|yes)</span><br><span style="color: hsl(0, 100%, 40%);">- ac_mandatory_list="${ac_mandatory_list} SQLITE"</span><br><span style="color: hsl(0, 100%, 40%);">- ;;</span><br><span style="color: hsl(0, 100%, 40%);">- *)</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_DIR="${withval}"</span><br><span style="color: hsl(0, 100%, 40%);">- ac_mandatory_list="${ac_mandatory_list} SQLITE"</span><br><span style="color: hsl(0, 100%, 40%);">- ;;</span><br><span style="color: hsl(0, 100%, 40%);">- esac</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span> SQLITE3_DESCRIP="SQLite"</span><br><span> SQLITE3_OPTION="sqlite3"</span><br><span> PBX_SQLITE3=0</span><br><span>@@ -29658,103 +29620,6 @@</span><br><span> </span><br><span> </span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-if test "x${PBX_SQLITE}" != "x1" -a "${USE_SQLITE}" != "no"; then</span><br><span style="color: hsl(0, 100%, 40%);">- pbxlibdir=""</span><br><span style="color: hsl(0, 100%, 40%);">- # if --with-SQLITE=DIR has been specified, use it.</span><br><span style="color: hsl(0, 100%, 40%);">- if test "x${SQLITE_DIR}" != "x"; then</span><br><span style="color: hsl(0, 100%, 40%);">- if test -d ${SQLITE_DIR}/lib; then</span><br><span style="color: hsl(0, 100%, 40%);">- pbxlibdir="-L${SQLITE_DIR}/lib"</span><br><span style="color: hsl(0, 100%, 40%);">- else</span><br><span style="color: hsl(0, 100%, 40%);">- pbxlibdir="-L${SQLITE_DIR}"</span><br><span style="color: hsl(0, 100%, 40%);">- fi</span><br><span style="color: hsl(0, 100%, 40%);">- fi</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_ext_lib_check_save_CFLAGS="${CFLAGS}"</span><br><span style="color: hsl(0, 100%, 40%);">- CFLAGS="${CFLAGS} "</span><br><span style="color: hsl(0, 100%, 40%);">- { $as_echo "$as_me:${as_lineno-$LINENO}: checking for sqlite_exec in -lsqlite" >&5</span><br><span style="color: hsl(0, 100%, 40%);">-$as_echo_n "checking for sqlite_exec in -lsqlite... " >&6; }</span><br><span style="color: hsl(0, 100%, 40%);">-if ${ac_cv_lib_sqlite_sqlite_exec+:} false; then :</span><br><span style="color: hsl(0, 100%, 40%);">- $as_echo_n "(cached) " >&6</span><br><span style="color: hsl(0, 100%, 40%);">-else</span><br><span style="color: hsl(0, 100%, 40%);">- ac_check_lib_save_LIBS=$LIBS</span><br><span style="color: hsl(0, 100%, 40%);">-LIBS="-lsqlite ${pbxlibdir} $LIBS"</span><br><span style="color: hsl(0, 100%, 40%);">-cat confdefs.h - <<_ACEOF >conftest.$ac_ext</span><br><span style="color: hsl(0, 100%, 40%);">-/* end confdefs.h. */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* Override any GCC internal prototype to avoid an error.</span><br><span style="color: hsl(0, 100%, 40%);">- Use char because int might match the return type of a GCC</span><br><span style="color: hsl(0, 100%, 40%);">- builtin and then its argument prototype would still apply. */</span><br><span style="color: hsl(0, 100%, 40%);">-#ifdef __cplusplus</span><br><span style="color: hsl(0, 100%, 40%);">-extern "C"</span><br><span style="color: hsl(0, 100%, 40%);">-#endif</span><br><span style="color: hsl(0, 100%, 40%);">-char sqlite_exec ();</span><br><span style="color: hsl(0, 100%, 40%);">-int</span><br><span style="color: hsl(0, 100%, 40%);">-main ()</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-return sqlite_exec ();</span><br><span style="color: hsl(0, 100%, 40%);">- ;</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-_ACEOF</span><br><span style="color: hsl(0, 100%, 40%);">-if ac_fn_c_try_link "$LINENO"; then :</span><br><span style="color: hsl(0, 100%, 40%);">- ac_cv_lib_sqlite_sqlite_exec=yes</span><br><span style="color: hsl(0, 100%, 40%);">-else</span><br><span style="color: hsl(0, 100%, 40%);">- ac_cv_lib_sqlite_sqlite_exec=no</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-rm -f core conftest.err conftest.$ac_objext \</span><br><span style="color: hsl(0, 100%, 40%);">- conftest$ac_exeext conftest.$ac_ext</span><br><span style="color: hsl(0, 100%, 40%);">-LIBS=$ac_check_lib_save_LIBS</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-{ $as_echo "$as_me:${as_lineno-$LINENO}: result: $ac_cv_lib_sqlite_sqlite_exec" >&5</span><br><span style="color: hsl(0, 100%, 40%);">-$as_echo "$ac_cv_lib_sqlite_sqlite_exec" >&6; }</span><br><span style="color: hsl(0, 100%, 40%);">-if test "x$ac_cv_lib_sqlite_sqlite_exec" = xyes; then :</span><br><span style="color: hsl(0, 100%, 40%);">- AST_SQLITE_FOUND=yes</span><br><span style="color: hsl(0, 100%, 40%);">-else</span><br><span style="color: hsl(0, 100%, 40%);">- AST_SQLITE_FOUND=no</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- CFLAGS="${ast_ext_lib_check_save_CFLAGS}"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- # now check for the header.</span><br><span style="color: hsl(0, 100%, 40%);">- if test "${AST_SQLITE_FOUND}" = "yes"; then</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_LIB="${pbxlibdir} -lsqlite "</span><br><span style="color: hsl(0, 100%, 40%);">- # if --with-SQLITE=DIR has been specified, use it.</span><br><span style="color: hsl(0, 100%, 40%);">- if test "x${SQLITE_DIR}" != "x"; then</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_INCLUDE="-I${SQLITE_DIR}/include"</span><br><span style="color: hsl(0, 100%, 40%);">- fi</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_INCLUDE="${SQLITE_INCLUDE} "</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- # check for the header</span><br><span style="color: hsl(0, 100%, 40%);">- ast_ext_lib_check_saved_CPPFLAGS="${CPPFLAGS}"</span><br><span style="color: hsl(0, 100%, 40%);">- CPPFLAGS="${CPPFLAGS} ${SQLITE_INCLUDE}"</span><br><span style="color: hsl(0, 100%, 40%);">- ac_fn_c_check_header_mongrel "$LINENO" "sqlite.h" "ac_cv_header_sqlite_h" "$ac_includes_default"</span><br><span style="color: hsl(0, 100%, 40%);">-if test "x$ac_cv_header_sqlite_h" = xyes; then :</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_HEADER_FOUND=1</span><br><span style="color: hsl(0, 100%, 40%);">-else</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_HEADER_FOUND=0</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- CPPFLAGS="${ast_ext_lib_check_saved_CPPFLAGS}"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if test "x${SQLITE_HEADER_FOUND}" = "x0" ; then</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_LIB=""</span><br><span style="color: hsl(0, 100%, 40%);">- SQLITE_INCLUDE=""</span><br><span style="color: hsl(0, 100%, 40%);">- else</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- PBX_SQLITE=1</span><br><span style="color: hsl(0, 100%, 40%);">- cat >>confdefs.h <<_ACEOF</span><br><span style="color: hsl(0, 100%, 40%);">-#define HAVE_SQLITE 1</span><br><span style="color: hsl(0, 100%, 40%);">-_ACEOF</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- fi</span><br><span style="color: hsl(0, 100%, 40%);">- fi</span><br><span style="color: hsl(0, 100%, 40%);">-fi</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span> if test "x${PBX_SQLITE3}" != "x1" -a "${USE_SQLITE3}" != "no"; then</span><br><span> pbxlibdir=""</span><br><span> # if --with-SQLITE3=DIR has been specified, use it.</span><br><span>diff --git a/configure.ac b/configure.ac</span><br><span>index 13e1c1e..ea6080d 100644</span><br><span>--- a/configure.ac</span><br><span>+++ b/configure.ac</span><br><span>@@ -582,7 +582,6 @@</span><br><span> AST_EXT_LIB_SETUP([SPEEX_PREPROCESS], [Speex preprocess routines], [speex])</span><br><span> AST_EXT_LIB_SETUP([SPEEXDSP], [SpeexDSP], [speexdsp])</span><br><span> AST_EXT_LIB_SETUP_DEPENDENT([SPEEX_PREPROCESS], [speex_preprocess_ctl], [], [speex])</span><br><span style="color: hsl(0, 100%, 40%);">-AST_EXT_LIB_SETUP([SQLITE], [SQLite], [sqlite])</span><br><span> AST_EXT_LIB_SETUP([SQLITE3], [SQLite], [sqlite3])</span><br><span> AST_EXT_LIB_SETUP([SRTP], [Secure RTP], [srtp])</span><br><span> AST_EXT_LIB_SETUP_OPTIONAL([SRTP_256], [SRTP Library AES-256 (ICM)], [SRTP], [srtp])</span><br><span>@@ -2584,8 +2583,6 @@</span><br><span> </span><br><span> AC_SUBST(PBX_SPEEX_PREPROCESS)</span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-AST_EXT_LIB_CHECK([SQLITE], [sqlite], [sqlite_exec], [sqlite.h])</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span> AST_EXT_LIB_CHECK([SQLITE3], [sqlite3], [sqlite3_open], [sqlite3.h], [${PTHREAD_LIBS}], [${PTHREAD_CFLAGS}])</span><br><span> </span><br><span> if test "${PBX_SQLITE3}" != 1; then</span><br><span>diff --git a/doc/UPGRADE-staging/res_config_sqlite_removal.txt b/doc/UPGRADE-staging/res_config_sqlite_removal.txt</span><br><span>new file mode 100644</span><br><span>index 0000000..13c259d</span><br><span>--- /dev/null</span><br><span>+++ b/doc/UPGRADE-staging/res_config_sqlite_removal.txt</span><br><span>@@ -0,0 +1,6 @@</span><br><span style="color: hsl(120, 100%, 40%);">+Subject: res_config_sqlite</span><br><span style="color: hsl(120, 100%, 40%);">+Master-Only: True</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+This module was deprecated in Asterisk 16</span><br><span style="color: hsl(120, 100%, 40%);">+and is now being removed in accordance with</span><br><span style="color: hsl(120, 100%, 40%);">+the Asterisk Module Deprecation policy.</span><br><span>diff --git a/include/asterisk/autoconfig.h.in b/include/asterisk/autoconfig.h.in</span><br><span>index e56f1c8..fc3a9bd 100644</span><br><span>--- a/include/asterisk/autoconfig.h.in</span><br><span>+++ b/include/asterisk/autoconfig.h.in</span><br><span>@@ -906,9 +906,6 @@</span><br><span> #undef HAVE_SPEEX_PREPROCESS</span><br><span> </span><br><span> /* Define to 1 if you have the SQLite library. */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef HAVE_SQLITE</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* Define to 1 if you have the SQLite library. */</span><br><span> #undef HAVE_SQLITE3</span><br><span> </span><br><span> /* Define to 1 if you have the `sqrtl' function. */</span><br><span>diff --git a/res/res_config_sqlite.c b/res/res_config_sqlite.c</span><br><span>deleted file mode 100644</span><br><span>index 2326000..0000000</span><br><span>--- a/res/res_config_sqlite.c</span><br><span>+++ /dev/null</span><br><span>@@ -1,1789 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-/*</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk -- An open source telephony toolkit.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Copyright (C) 2006, Proformatique</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Written by Richard Braun <rbraun@proformatique.com></span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Based on res_sqlite3 by Anthony Minessale II,</span><br><span style="color: hsl(0, 100%, 40%);">- * and res_config_mysql by Matthew Boehm</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * See http://www.asterisk.org for more information about</span><br><span style="color: hsl(0, 100%, 40%);">- * the Asterisk project. Please do not directly contact</span><br><span style="color: hsl(0, 100%, 40%);">- * any of the maintainers of this project for assistance;</span><br><span style="color: hsl(0, 100%, 40%);">- * the project provides a web site, mailing lists and IRC</span><br><span style="color: hsl(0, 100%, 40%);">- * channels for your use.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This program is free software, distributed under the terms of</span><br><span style="color: hsl(0, 100%, 40%);">- * the GNU General Public License Version 2. See the LICENSE file</span><br><span style="color: hsl(0, 100%, 40%);">- * at the top of the source tree.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \page res_config_sqlite</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \section intro_sec Presentation</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * res_config_sqlite is a module for the Asterisk Open Source PBX to</span><br><span style="color: hsl(0, 100%, 40%);">- * support SQLite 2 databases. It can be used to fetch configuration</span><br><span style="color: hsl(0, 100%, 40%);">- * from a database (static configuration files and/or using the Asterisk</span><br><span style="color: hsl(0, 100%, 40%);">- * RealTime Architecture - ARA). It can also be used to log CDR entries.</span><br><span style="color: hsl(0, 100%, 40%);">- * Note that Asterisk already comes with a module named cdr_sqlite.</span><br><span style="color: hsl(0, 100%, 40%);">- * There are two reasons for including it in res_config_sqlite:</span><br><span style="color: hsl(0, 100%, 40%);">- * the first is that rewriting it was a training to learn how to write a</span><br><span style="color: hsl(0, 100%, 40%);">- * simple module for Asterisk, the other is to have the same database open for</span><br><span style="color: hsl(0, 100%, 40%);">- * all kinds of operations, which improves reliability and performance.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \section conf_sec Configuration</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * The main configuration file is res_config_sqlite.conf.sample It must be readable or</span><br><span style="color: hsl(0, 100%, 40%);">- * res_config_sqlite will fail to start. It is suggested to use the sample file</span><br><span style="color: hsl(0, 100%, 40%);">- * in this package as a starting point. The file has only one section</span><br><span style="color: hsl(0, 100%, 40%);">- * named <code>general</code>. Here are the supported parameters :</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * <dl></span><br><span style="color: hsl(0, 100%, 40%);">- * <dt><code>dbfile</code></dt></span><br><span style="color: hsl(0, 100%, 40%);">- * <dd>The absolute path to the SQLite database (the file can be non existent,</span><br><span style="color: hsl(0, 100%, 40%);">- * res_config_sqlite will create it if it has the appropriate rights)</dd></span><br><span style="color: hsl(0, 100%, 40%);">- * <dt><code>config_table</code></dt></span><br><span style="color: hsl(0, 100%, 40%);">- * <dd>The table used for static configuration</dd></span><br><span style="color: hsl(0, 100%, 40%);">- * <dt><code>cdr_table</code></dt></span><br><span style="color: hsl(0, 100%, 40%);">- * <dd>The table used to store CDR entries (if ommitted, CDR support is</span><br><span style="color: hsl(0, 100%, 40%);">- * disabled)</dd></span><br><span style="color: hsl(0, 100%, 40%);">- * </dl></span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * To use res_config_sqlite for static and/or RealTime configuration, refer to the</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk documentation. The file tables.sql can be used to create the</span><br><span style="color: hsl(0, 100%, 40%);">- * needed tables.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \section status_sec Driver status</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * The CLI command <code>show sqlite status</code> returns status information</span><br><span style="color: hsl(0, 100%, 40%);">- * about the running driver.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \section credits_sec Credits</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * res_config_sqlite was developed by Richard Braun at the Proformatique company.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \file</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief res_config_sqlite module.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! \li \ref res_config_sqlite.c uses the configuration file \ref res_config_sqlite.conf</span><br><span style="color: hsl(0, 100%, 40%);">- * \addtogroup configuration_file Configuration Files</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \page res_config_sqlite.conf res_config_sqlite.conf</span><br><span style="color: hsl(0, 100%, 40%);">- * \verbinclude res_config_sqlite.conf.sample</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*** MODULEINFO</span><br><span style="color: hsl(0, 100%, 40%);">- <depend>sqlite</depend></span><br><span style="color: hsl(0, 100%, 40%);">- <support_level>deprecated</support_level></span><br><span style="color: hsl(0, 100%, 40%);">- <deprecated_in>16</deprecated_in></span><br><span style="color: hsl(0, 100%, 40%);">- <removed_in>19</removed_in></span><br><span style="color: hsl(0, 100%, 40%);">- ***/</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk.h"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <sqlite.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/logger.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/app.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/pbx.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/cdr.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/cli.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/lock.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/config.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/module.h"</span><br><span style="color: hsl(0, 100%, 40%);">-#include "asterisk/linkedlists.h"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#define MACRO_BEGIN do {</span><br><span style="color: hsl(0, 100%, 40%);">-#define MACRO_END } while (0)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_NAME "res_config_sqlite"</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_DRIVER "sqlite"</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_DESCRIPTION "Resource Module for SQLite 2"</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_CONF_FILE "res_config_sqlite.conf"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-enum {</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_ID,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_CAT_METRIC,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_VAR_METRIC,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_COMMENTED,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_FILENAME,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_CATEGORY,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_VAR_NAME,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_VAR_VAL,</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_CONFIG_COLUMNS,</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#define SET_VAR(config, to, from) \</span><br><span style="color: hsl(0, 100%, 40%);">-MACRO_BEGIN \</span><br><span style="color: hsl(0, 100%, 40%);">- int __error; \</span><br><span style="color: hsl(0, 100%, 40%);">- \</span><br><span style="color: hsl(0, 100%, 40%);">- __error = set_var(&to, #to, from->value); \</span><br><span style="color: hsl(0, 100%, 40%);">- \</span><br><span style="color: hsl(0, 100%, 40%);">- if (__error) { \</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(config); \</span><br><span style="color: hsl(0, 100%, 40%);">- unload_config(); \</span><br><span style="color: hsl(0, 100%, 40%);">- return 1; \</span><br><span style="color: hsl(0, 100%, 40%);">- } \</span><br><span style="color: hsl(0, 100%, 40%);">-MACRO_END</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-AST_THREADSTORAGE(sql_buf);</span><br><span style="color: hsl(0, 100%, 40%);">-AST_THREADSTORAGE(where_buf);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Maximum number of loops before giving up executing a query. Calls to</span><br><span style="color: hsl(0, 100%, 40%);">- * sqlite_xxx() functions which can return SQLITE_BUSY</span><br><span style="color: hsl(0, 100%, 40%);">- * are enclosed by RES_CONFIG_SQLITE_BEGIN and RES_CONFIG_SQLITE_END, e.g.</span><br><span style="color: hsl(0, 100%, 40%);">- * <pre></span><br><span style="color: hsl(0, 100%, 40%);">- * char *errormsg;</span><br><span style="color: hsl(0, 100%, 40%);">- * int error;</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- * error = sqlite_exec(db, query, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- * RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * if (error)</span><br><span style="color: hsl(0, 100%, 40%);">- * ...;</span><br><span style="color: hsl(0, 100%, 40%);">- * </pre></span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_MAX_LOOPS 10</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Macro used before executing a query.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see RES_CONFIG_SQLITE_MAX_LOOPS.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_BEGIN \</span><br><span style="color: hsl(0, 100%, 40%);">-MACRO_BEGIN \</span><br><span style="color: hsl(0, 100%, 40%);">- int __i; \</span><br><span style="color: hsl(0, 100%, 40%);">- \</span><br><span style="color: hsl(0, 100%, 40%);">- for (__i = 0; __i < RES_CONFIG_SQLITE_MAX_LOOPS; __i++) {</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Macro used after executing a query.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see RES_CONFIG_SQLITE_MAX_LOOPS.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#define RES_CONFIG_SQLITE_END(error) \</span><br><span style="color: hsl(0, 100%, 40%);">- if (error != SQLITE_BUSY) \</span><br><span style="color: hsl(0, 100%, 40%);">- break; \</span><br><span style="color: hsl(0, 100%, 40%);">- usleep(1000); \</span><br><span style="color: hsl(0, 100%, 40%);">- } \</span><br><span style="color: hsl(0, 100%, 40%);">-MACRO_END;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Structure sent to the SQLite callback function for static configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-struct cfg_entry_args {</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_category *cat;</span><br><span style="color: hsl(0, 100%, 40%);">- char *cat_name;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_flags flags;</span><br><span style="color: hsl(0, 100%, 40%);">- const char *who_asked;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Structure sent to the SQLite callback function for RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_rt_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-struct rt_cfg_entry_args {</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *var;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *last;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Structure sent to the SQLite callback function for RealTime configuration</span><br><span style="color: hsl(0, 100%, 40%);">- * (realtime_multi_handler()).</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_rt_multi_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-struct rt_multi_cfg_entry_args {</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- char *initfield;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Allocate a variable.</span><br><span style="color: hsl(0, 100%, 40%);">- * \param var the address of the variable to set (it will be allocated)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param name the name of the variable (for error handling)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param value the value to store in var</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an allocation error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int set_var(char **var, const char *name, const char *value);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Load the configuration file.</span><br><span style="color: hsl(0, 100%, 40%);">- * \see unload_config()</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This function sets dbfile, config_table, and cdr_table. It calls</span><br><span style="color: hsl(0, 100%, 40%);">- * check_vars() before returning, and unload_config() if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int load_config(void);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Free resources related to configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- * \see load_config()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static void unload_config(void);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for CDR support.</span><br><span style="color: hsl(0, 100%, 40%);">- * \param cdr the CDR entry Asterisk sends us.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function each time a CDR entry must be logged if</span><br><span style="color: hsl(0, 100%, 40%);">- * CDR support is enabled.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int cdr_handler(struct ast_cdr *cdr);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief SQLite callback function for static configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This function is passed to the SQLite engine as a callback function to</span><br><span style="color: hsl(0, 100%, 40%);">- * parse a row and store it in a struct ast_config object. It relies on</span><br><span style="color: hsl(0, 100%, 40%);">- * resulting rows being sorted by category.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param arg a pointer to a struct cfg_entry_args object</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argc number of columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argv values in the row</span><br><span style="color: hsl(0, 100%, 40%);">- * \param columnNames names and types of the columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- * \see cfg_entry_args</span><br><span style="color: hsl(0, 100%, 40%);">- * \see sql_get_config_table</span><br><span style="color: hsl(0, 100%, 40%);">- * \see config_handler()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_cfg_entry(void *arg, int argc, char **argv, char **columnNames);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for static configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function when it loads its static configuration,</span><br><span style="color: hsl(0, 100%, 40%);">- * which usually happens at startup and reload.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param file the file to load from the database</span><br><span style="color: hsl(0, 100%, 40%);">- * \param cfg the struct ast_config object to use when storing variables</span><br><span style="color: hsl(0, 100%, 40%);">- * \param flags Optional flags. Not used.</span><br><span style="color: hsl(0, 100%, 40%);">- * \param suggested_incl suggest include.</span><br><span style="color: hsl(0, 100%, 40%);">- * \param who_asked</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval cfg object</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval NULL if an error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_config * config_handler(const char *database, const char *table, const char *file,</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg, struct ast_flags flags, const char *suggested_incl, const char *who_asked);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief SQLite callback function for RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This function is passed to the SQLite engine as a callback function to</span><br><span style="color: hsl(0, 100%, 40%);">- * parse a row and store it in a linked list of struct ast_variable objects.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param arg a pointer to a struct rt_cfg_entry_args object</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argc number of columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argv values in the row</span><br><span style="color: hsl(0, 100%, 40%);">- * \param columnNames names and types of the columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- * \see rt_cfg_entry_args</span><br><span style="color: hsl(0, 100%, 40%);">- * \see realtime_handler()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_rt_cfg_entry(void *arg, int argc, char **argv,</span><br><span style="color: hsl(0, 100%, 40%);">- char **columnNames);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function each time it requires a variable</span><br><span style="color: hsl(0, 100%, 40%);">- * through the RealTime architecture. ap is a list of parameters and</span><br><span style="color: hsl(0, 100%, 40%);">- * values used to find a specific row, e.g one parameter "name" and</span><br><span style="color: hsl(0, 100%, 40%);">- * one value "123" so that the SQL query becomes <code>SELECT * FROM</span><br><span style="color: hsl(0, 100%, 40%);">- * table WHERE name = '123';</code>.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param fields list of parameters and values to match</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval a linked list of struct ast_variable objects</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval NULL if an error occurred</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_rt_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_variable * realtime_handler(const char *database,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *table, const struct ast_variable *fields);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief SQLite callback function for RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This function performs the same actions as add_rt_cfg_entry() except</span><br><span style="color: hsl(0, 100%, 40%);">- * that the rt_multi_cfg_entry_args structure is designed to store</span><br><span style="color: hsl(0, 100%, 40%);">- * categories in addition to variables.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param arg a pointer to a struct rt_multi_cfg_entry_args object</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argc number of columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \param argv values in the row</span><br><span style="color: hsl(0, 100%, 40%);">- * \param columnNames names and types of the columns</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 0 on success.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval 1 if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- * \see rt_multi_cfg_entry_args</span><br><span style="color: hsl(0, 100%, 40%);">- * \see realtime_multi_handler()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_rt_multi_cfg_entry(void *arg, int argc, char **argv,</span><br><span style="color: hsl(0, 100%, 40%);">- char **columnNames);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This function performs the same actions as realtime_handler() except</span><br><span style="color: hsl(0, 100%, 40%);">- * that it can store variables per category, and can return several</span><br><span style="color: hsl(0, 100%, 40%);">- * categories.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param fields list of parameters and values to match</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval a struct ast_config object storing categories and variables.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval NULL if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_rt_multi_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_config * realtime_multi_handler(const char *database,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *table, const struct ast_variable *fields);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for RealTime configuration (variable</span><br><span style="color: hsl(0, 100%, 40%);">- * update).</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function each time a variable has been modified</span><br><span style="color: hsl(0, 100%, 40%);">- * internally and must be updated in the backend engine. keyfield and entity</span><br><span style="color: hsl(0, 100%, 40%);">- * are used to find the row to update, e.g. <code>UPDATE table SET ... WHERE</span><br><span style="color: hsl(0, 100%, 40%);">- * keyfield = 'entity';</code>. ap is a list of parameters and values with the</span><br><span style="color: hsl(0, 100%, 40%);">- * same format as the other realtime functions.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param keyfield the column of the matching cell</span><br><span style="color: hsl(0, 100%, 40%);">- * \param entity the value of the matching cell</span><br><span style="color: hsl(0, 100%, 40%);">- * \param fields list of parameters and new values to update in the database</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval the number of affected rows.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval -1 if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_update_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *keyfield, const char *entity, const struct ast_variable *fields);</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_update2_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *lookup_fields, const struct ast_variable *update_fields);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for RealTime configuration (variable</span><br><span style="color: hsl(0, 100%, 40%);">- * create/store).</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function each time a variable has been created</span><br><span style="color: hsl(0, 100%, 40%);">- * internally and must be stored in the backend engine.</span><br><span style="color: hsl(0, 100%, 40%);">- * are used to find the row to update, e.g. ap is a list of parameters and</span><br><span style="color: hsl(0, 100%, 40%);">- * values with the same format as the other realtime functions.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param fields list of parameters and new values to insert into the database</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval the rowid of inserted row.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval -1 if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_store_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *fields);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for RealTime configuration (destroys</span><br><span style="color: hsl(0, 100%, 40%);">- * variable).</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk will call this function each time a variable has been destroyed</span><br><span style="color: hsl(0, 100%, 40%);">- * internally and must be removed from the backend engine. keyfield and entity</span><br><span style="color: hsl(0, 100%, 40%);">- * are used to find the row to delete, e.g. <code>DELETE FROM table WHERE</span><br><span style="color: hsl(0, 100%, 40%);">- * keyfield = 'entity';</code>. ap is a list of parameters and values with the</span><br><span style="color: hsl(0, 100%, 40%);">- * same format as the other realtime functions.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param database the database to use (ignored)</span><br><span style="color: hsl(0, 100%, 40%);">- * \param table the table to use</span><br><span style="color: hsl(0, 100%, 40%);">- * \param keyfield the column of the matching cell</span><br><span style="color: hsl(0, 100%, 40%);">- * \param entity the value of the matching cell</span><br><span style="color: hsl(0, 100%, 40%);">- * \param fields list of additional parameters for cell matching</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval the number of affected rows.</span><br><span style="color: hsl(0, 100%, 40%);">- * \retval -1 if an error occurred.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_destroy_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *keyfield, const char *entity, const struct ast_variable *fields);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Asterisk callback function for the CLI status command.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \param e CLI command</span><br><span style="color: hsl(0, 100%, 40%);">- * \param cmd</span><br><span style="color: hsl(0, 100%, 40%);">- * \param a CLI argument list</span><br><span style="color: hsl(0, 100%, 40%);">- * \return RESULT_SUCCESS</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static char *handle_cli_show_sqlite_status(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a);</span><br><span style="color: hsl(0, 100%, 40%);">-static char *handle_cli_sqlite_show_tables(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_require_handler(const char *database, const char *table, va_list ap);</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_unload_handler(const char *unused, const char *tablename);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! The SQLite database object. */</span><br><span style="color: hsl(0, 100%, 40%);">-static sqlite *db;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! Set to 1 if CDR support is enabled. */</span><br><span style="color: hsl(0, 100%, 40%);">-static int use_cdr;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! Set to 1 if the CDR callback function was registered. */</span><br><span style="color: hsl(0, 100%, 40%);">-static int cdr_registered;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! Set to 1 if the CLI status command callback function was registered. */</span><br><span style="color: hsl(0, 100%, 40%);">-static int cli_status_registered;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! The path of the database file. */</span><br><span style="color: hsl(0, 100%, 40%);">-static char *dbfile;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! The name of the static configuration table. */</span><br><span style="color: hsl(0, 100%, 40%);">-static char *config_table;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! The name of the table used to store CDR entries. */</span><br><span style="color: hsl(0, 100%, 40%);">-static char *cdr_table;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * The structure specifying all callback functions used by Asterisk for static</span><br><span style="color: hsl(0, 100%, 40%);">- * and RealTime configuration.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_config_engine sqlite_engine =</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- .name = RES_CONFIG_SQLITE_DRIVER,</span><br><span style="color: hsl(0, 100%, 40%);">- .load_func = config_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .realtime_func = realtime_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .realtime_multi_func = realtime_multi_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .store_func = realtime_store_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .destroy_func = realtime_destroy_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .update_func = realtime_update_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .update2_func = realtime_update2_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .require_func = realtime_require_handler,</span><br><span style="color: hsl(0, 100%, 40%);">- .unload_func = realtime_unload_handler,</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * The mutex used to prevent simultaneous access to the SQLite database.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-AST_MUTEX_DEFINE_STATIC(mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * Structure containing details and callback functions for the CLI status</span><br><span style="color: hsl(0, 100%, 40%);">- * command.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_cli_entry cli_status[] = {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_CLI_DEFINE(handle_cli_show_sqlite_status, "Show status information about the SQLite 2 driver"),</span><br><span style="color: hsl(0, 100%, 40%);">- AST_CLI_DEFINE(handle_cli_sqlite_show_tables, "Cached table information about the SQLite 2 driver"),</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct sqlite_cache_columns {</span><br><span style="color: hsl(0, 100%, 40%);">- char *name;</span><br><span style="color: hsl(0, 100%, 40%);">- char *type;</span><br><span style="color: hsl(0, 100%, 40%);">- unsigned char isint; /*!< By definition, only INTEGER PRIMARY KEY is an integer; everything else is a string. */</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_ENTRY(sqlite_cache_columns) list;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct sqlite_cache_tables {</span><br><span style="color: hsl(0, 100%, 40%);">- char *name;</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_HEAD(_columns, sqlite_cache_columns) columns;</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_ENTRY(sqlite_cache_tables) list;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static AST_RWLIST_HEAD_STATIC(sqlite_tables, sqlite_cache_tables);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*</span><br><span style="color: hsl(0, 100%, 40%);">- * Taken from Asterisk 1.2 cdr_sqlite.so.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*! SQL query format to create the CDR table if non existent. */</span><br><span style="color: hsl(0, 100%, 40%);">-static char *sql_create_cdr_table =</span><br><span style="color: hsl(0, 100%, 40%);">-"CREATE TABLE '%q' (\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" id INTEGER,\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" clid VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" src VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" dst VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" dcontext VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" channel VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" dstchannel VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" lastapp VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" lastdata VARCHAR(80) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" start DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" answer DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" end DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" duration INT(11) NOT NULL DEFAULT 0,\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" billsec INT(11) NOT NULL DEFAULT 0,\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" disposition VARCHAR(45) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" amaflags INT(11) NOT NULL DEFAULT 0,\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" accountcode VARCHAR(20) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" uniqueid VARCHAR(32) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" userfield VARCHAR(255) NOT NULL DEFAULT '',\n"</span><br><span style="color: hsl(0, 100%, 40%);">-" PRIMARY KEY (id)\n"</span><br><span style="color: hsl(0, 100%, 40%);">-");";</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * SQL query format to describe the table structure</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#define sql_table_structure "SELECT sql FROM sqlite_master WHERE type='table' AND tbl_name='%s'"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * SQL query format to fetch the static configuration of a file.</span><br><span style="color: hsl(0, 100%, 40%);">- * Rows must be sorted by category.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * \see add_cfg_entry()</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#define sql_get_config_table \</span><br><span style="color: hsl(0, 100%, 40%);">- "SELECT *" \</span><br><span style="color: hsl(0, 100%, 40%);">- " FROM '%q'" \</span><br><span style="color: hsl(0, 100%, 40%);">- " WHERE filename = '%q' AND commented = 0" \</span><br><span style="color: hsl(0, 100%, 40%);">- " ORDER BY cat_metric ASC, var_metric ASC;"</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void free_table(struct sqlite_cache_tables *tblptr)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_columns *col;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- /* Obtain a write lock to ensure there are no read locks outstanding */</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_WRLOCK(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- while ((col = AST_RWLIST_REMOVE_HEAD(&(tblptr->columns), list))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(col);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_HEAD_DESTROY(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(tblptr);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int find_table_cb(void *vtblptr, int argc, char **argv, char **columnNames)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tblptr = vtblptr;</span><br><span style="color: hsl(0, 100%, 40%);">- char *sql = ast_strdupa(argv[0]), *start, *end, *type, *remainder;</span><br><span style="color: hsl(0, 100%, 40%);">- int i;</span><br><span style="color: hsl(0, 100%, 40%);">- AST_DECLARE_APP_ARGS(fie,</span><br><span style="color: hsl(0, 100%, 40%);">- AST_APP_ARG(ld)[100]; /* This means we support up to 100 columns per table */</span><br><span style="color: hsl(0, 100%, 40%);">- );</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_columns *col;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- /* This is really fun. We get to parse an SQL statement to figure out</span><br><span style="color: hsl(0, 100%, 40%);">- * what columns are in the table.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">- if ((start = strchr(sql, '(')) && (end = strrchr(sql, ')'))) {</span><br><span style="color: hsl(0, 100%, 40%);">- start++;</span><br><span style="color: hsl(0, 100%, 40%);">- *end = '\0';</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- /* Abort */</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- AST_STANDARD_APP_ARGS(fie, start);</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < fie.argc; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">- fie.ld[i] = ast_skip_blanks(fie.ld[i]);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(5, "Found field: %s\n", fie.ld[i]);</span><br><span style="color: hsl(0, 100%, 40%);">- if (strncasecmp(fie.ld[i], "PRIMARY KEY", 11) == 0 && (start = strchr(fie.ld[i], '(')) && (end = strchr(fie.ld[i], ')'))) {</span><br><span style="color: hsl(0, 100%, 40%);">- *end = '\0';</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&(tblptr->columns), col, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (strcasecmp(start + 1, col->name) == 0 && strcasestr(col->type, "INTEGER")) {</span><br><span style="color: hsl(0, 100%, 40%);">- col->isint = 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- continue;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- /* type delimiter could be any space character */</span><br><span style="color: hsl(0, 100%, 40%);">- for (type = fie.ld[i]; *type > 32; type++);</span><br><span style="color: hsl(0, 100%, 40%);">- *type++ = '\0';</span><br><span style="color: hsl(0, 100%, 40%);">- type = ast_skip_blanks(type);</span><br><span style="color: hsl(0, 100%, 40%);">- for (remainder = type; *remainder > 32; remainder++);</span><br><span style="color: hsl(0, 100%, 40%);">- *remainder = '\0';</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(col = ast_calloc(1, sizeof(*col) + strlen(fie.ld[i]) + strlen(type) + 2))) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- col->name = (char *)col + sizeof(*col);</span><br><span style="color: hsl(0, 100%, 40%);">- col->type = (char *)col + sizeof(*col) + strlen(fie.ld[i]) + 1;</span><br><span style="color: hsl(0, 100%, 40%);">- strcpy(col->name, fie.ld[i]); /* SAFE */</span><br><span style="color: hsl(0, 100%, 40%);">- strcpy(col->type, type); /* SAFE */</span><br><span style="color: hsl(0, 100%, 40%);">- if (strcasestr(col->type, "INTEGER") && strcasestr(col->type, "PRIMARY KEY")) {</span><br><span style="color: hsl(0, 100%, 40%);">- col->isint = 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_LIST_INSERT_TAIL(&(tblptr->columns), col, list);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct sqlite_cache_tables *find_table(const char *tablename)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tblptr;</span><br><span style="color: hsl(0, 100%, 40%);">- int i, err;</span><br><span style="color: hsl(0, 100%, 40%);">- char *sql, *errstr = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_RDLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < 2; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&sqlite_tables, tblptr, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (strcmp(tblptr->name, tablename) == 0) {</span><br><span style="color: hsl(0, 100%, 40%);">- break;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (tblptr) {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_RDLOCK(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- return tblptr;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (i == 0) {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_WRLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- /* Table structure not cached; build the structure now */</span><br><span style="color: hsl(0, 100%, 40%);">- if (ast_asprintf(&sql, sql_table_structure, tablename) < 0) {</span><br><span style="color: hsl(0, 100%, 40%);">- sql = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(tblptr = ast_calloc(1, sizeof(*tblptr) + strlen(tablename) + 1))) {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Memory error. Cannot cache table '%s'\n", tablename);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- tblptr->name = (char *)tblptr + sizeof(*tblptr);</span><br><span style="color: hsl(0, 100%, 40%);">- strcpy(tblptr->name, tablename); /* SAFE */</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_HEAD_INIT(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "About to query table structure: %s\n", sql);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">- if ((err = sqlite_exec(db, sql, find_table_cb, tblptr, &errstr))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "SQLite error %d: %s\n", err, errstr);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(errstr);</span><br><span style="color: hsl(0, 100%, 40%);">- free_table(tblptr);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (AST_LIST_EMPTY(&(tblptr->columns))) {</span><br><span style="color: hsl(0, 100%, 40%);">- free_table(tblptr);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_INSERT_TAIL(&sqlite_tables, tblptr, list);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_RDLOCK(&(tblptr->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- return tblptr;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#define release_table(a) AST_RWLIST_UNLOCK(&((a)->columns))</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int set_var(char **var, const char *name, const char *value)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- if (*var)</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(*var);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- *var = ast_strdup(value);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!*var) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate variable %s\n", name);</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int check_vars(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- if (!dbfile) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Required parameter undefined: dbfile\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- use_cdr = (cdr_table != NULL);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int load_config(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *config;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *var;</span><br><span style="color: hsl(0, 100%, 40%);">- int error;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_flags config_flags = { 0 };</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- config = ast_config_load(RES_CONFIG_SQLITE_CONF_FILE, config_flags);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (config == CONFIG_STATUS_FILEMISSING || config == CONFIG_STATUS_FILEINVALID) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Unable to load " RES_CONFIG_SQLITE_CONF_FILE "\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (var = ast_variable_browse(config, "general"); var; var = var->next) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!strcasecmp(var->name, "dbfile"))</span><br><span style="color: hsl(0, 100%, 40%);">- SET_VAR(config, dbfile, var);</span><br><span style="color: hsl(0, 100%, 40%);">- else if (!strcasecmp(var->name, "config_table"))</span><br><span style="color: hsl(0, 100%, 40%);">- SET_VAR(config, config_table, var);</span><br><span style="color: hsl(0, 100%, 40%);">- else if (!strcasecmp(var->name, "cdr_table")) {</span><br><span style="color: hsl(0, 100%, 40%);">- SET_VAR(config, cdr_table, var);</span><br><span style="color: hsl(0, 100%, 40%);">- } else</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unknown parameter : %s\n", var->name);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(config);</span><br><span style="color: hsl(0, 100%, 40%);">- error = check_vars();</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- unload_config();</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void unload_config(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tbl;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(dbfile);</span><br><span style="color: hsl(0, 100%, 40%);">- dbfile = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(config_table);</span><br><span style="color: hsl(0, 100%, 40%);">- config_table = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">- cdr_table = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_WRLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- while ((tbl = AST_RWLIST_REMOVE_HEAD(&sqlite_tables, list))) {</span><br><span style="color: hsl(0, 100%, 40%);">- free_table(tbl);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int cdr_handler(struct ast_cdr *cdr)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *errormsg = NULL, *tmp, workspace[500];</span><br><span style="color: hsl(0, 100%, 40%);">- int error, scannum;</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tbl = find_table(cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_columns *col;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_str *sql1 = ast_str_create(160), *sql2 = ast_str_create(16);</span><br><span style="color: hsl(0, 100%, 40%);">- int first = 1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!sql1 || !sql2) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql1);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql2);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tbl) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "No such table: %s\n", cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql1);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql2);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_set(&sql1, 0, "INSERT INTO %s (", cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_set(&sql2, 0, ") VALUES (");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&(tbl->columns), col, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (col->isint) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cdr_format_var(cdr, col->name, &tmp, workspace, sizeof(workspace), 1);</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp) {</span><br><span style="color: hsl(0, 100%, 40%);">- continue;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (sscanf(tmp, "%30d", &scannum) == 1) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql1, 0, "%s%s", first ? "" : ",", col->name);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql2, 0, "%s%d", first ? "" : ",", scannum);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cdr_format_var(cdr, col->name, &tmp, workspace, sizeof(workspace), 0);</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp) {</span><br><span style="color: hsl(0, 100%, 40%);">- continue;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql1, 0, "%s%s", first ? "" : ",", col->name);</span><br><span style="color: hsl(0, 100%, 40%);">- tmp = sqlite_mprintf("%Q", tmp);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql2, 0, "%s%s", first ? "" : ",", tmp);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- first = 0;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- release_table(tbl);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql1, 0, "%s)", ast_str_buffer(sql2));</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql2);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", ast_str_buffer(sql1));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, ast_str_buffer(sql1), NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(sql1);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_cfg_entry(void *arg, int argc, char **argv, char **columnNames)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct cfg_entry_args *args;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *var;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (argc != RES_CONFIG_SQLITE_CONFIG_COLUMNS) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Corrupt table\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- args = arg;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!strcmp(argv[RES_CONFIG_SQLITE_CONFIG_VAR_NAME], "#include")) {</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- char *val;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- val = argv[RES_CONFIG_SQLITE_CONFIG_VAR_VAL];</span><br><span style="color: hsl(0, 100%, 40%);">- cfg = ast_config_internal_load(val, args->cfg, args->flags, "", args->who_asked);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!cfg) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to include %s\n", val);</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- args->cfg = cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!args->cat_name || strcmp(args->cat_name, argv[RES_CONFIG_SQLITE_CONFIG_CATEGORY])) {</span><br><span style="color: hsl(0, 100%, 40%);">- args->cat = ast_category_new_dynamic(argv[RES_CONFIG_SQLITE_CONFIG_CATEGORY]);</span><br><span style="color: hsl(0, 100%, 40%);">- if (!args->cat) {</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(args->cat_name);</span><br><span style="color: hsl(0, 100%, 40%);">- args->cat_name = ast_strdup(argv[RES_CONFIG_SQLITE_CONFIG_CATEGORY]);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!args->cat_name) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_category_destroy(args->cat);</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_category_append(args->cfg, args->cat);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- var = ast_variable_new(argv[RES_CONFIG_SQLITE_CONFIG_VAR_NAME], argv[RES_CONFIG_SQLITE_CONFIG_VAR_VAL], "");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!var) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate variable\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_variable_append(args->cat, var);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_config *config_handler(const char *database, const char *table, const char *file,</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg, struct ast_flags flags, const char *suggested_incl, const char *who_asked)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct cfg_entry_args args;</span><br><span style="color: hsl(0, 100%, 40%);">- char *query, *errormsg = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- int error;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!config_table) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- } else</span><br><span style="color: hsl(0, 100%, 40%);">- table = config_table;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = sqlite_mprintf(sql_get_config_table, table, file);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!query) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">- args.cfg = cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- args.cat = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- args.cat_name = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- args.flags = flags;</span><br><span style="color: hsl(0, 100%, 40%);">- args.who_asked = who_asked;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, add_cfg_entry, &args, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(args.cat_name);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return cfg;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_rt_cfg_entry(void *arg, int argc, char **argv, char **columnNames)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct rt_cfg_entry_args *args;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *var;</span><br><span style="color: hsl(0, 100%, 40%);">- int i;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- args = arg;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < argc; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!argv[i])</span><br><span style="color: hsl(0, 100%, 40%);">- continue;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(var = ast_variable_new(columnNames[i], argv[i], "")))</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!args->var)</span><br><span style="color: hsl(0, 100%, 40%);">- args->var = var;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!args->last)</span><br><span style="color: hsl(0, 100%, 40%);">- args->last = var;</span><br><span style="color: hsl(0, 100%, 40%);">- else {</span><br><span style="color: hsl(0, 100%, 40%);">- args->last->next = var;</span><br><span style="color: hsl(0, 100%, 40%);">- args->last = var;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_variable * realtime_handler(const char *database, const char *table, const struct ast_variable *fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *query, *errormsg = NULL, *op, *tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- struct rt_cfg_entry_args args;</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field = fields;</span><br><span style="color: hsl(0, 100%, 40%);">- int error;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!fields) {</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- op = (strchr(field->name, ' ') == NULL) ? " =" : "";</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "SELECT * FROM '%q' WHERE%s %q%s '%q'"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = sqlite_mprintf(QUERY, table, (config_table && !strcmp(config_table, table)) ? " commented = 0 AND" : "", field->name, op, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!query) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- while ((field = field->next)) {</span><br><span style="color: hsl(0, 100%, 40%);">- op = (strchr(field->name, ' ') == NULL) ? " =" : "";</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = sqlite_mprintf("%s AND %q%s '%q'", query, field->name, op, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_str) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = sqlite_mprintf("%s LIMIT 1;", query);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_str) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">- args.var = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- args.last = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, add_rt_cfg_entry, &args, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_variables_destroy(args.var);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return args.var;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int add_rt_multi_cfg_entry(void *arg, int argc, char **argv, char **columnNames)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct rt_multi_cfg_entry_args *args;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_category *cat;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_variable *var;</span><br><span style="color: hsl(0, 100%, 40%);">- char *cat_name;</span><br><span style="color: hsl(0, 100%, 40%);">- size_t i;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- args = arg;</span><br><span style="color: hsl(0, 100%, 40%);">- cat_name = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- /*</span><br><span style="color: hsl(0, 100%, 40%);">- * cat_name should always be set here, since initfield is forged from</span><br><span style="color: hsl(0, 100%, 40%);">- * params[0] in realtime_multi_handler(), which is a search parameter</span><br><span style="color: hsl(0, 100%, 40%);">- * of the SQL query.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < argc; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!strcmp(args->initfield, columnNames[i]))</span><br><span style="color: hsl(0, 100%, 40%);">- cat_name = argv[i];</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!cat_name) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Bogus SQL results, cat_name is NULL !\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- cat = ast_category_new_dynamic(cat_name);</span><br><span style="color: hsl(0, 100%, 40%);">- if (!cat) {</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_category_append(args->cfg, cat);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < argc; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!argv[i]) {</span><br><span style="color: hsl(0, 100%, 40%);">- continue;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(var = ast_variable_new(columnNames[i], argv[i], ""))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate variable\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_variable_append(cat, var);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct ast_config *realtime_multi_handler(const char *database,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *table, const struct ast_variable *fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *query, *errormsg = NULL, *op, *tmp_str, *initfield;</span><br><span style="color: hsl(0, 100%, 40%);">- struct rt_multi_cfg_entry_args args;</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field = fields;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_config *cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- int error;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!fields) {</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(cfg = ast_config_new())) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate configuration structure\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(initfield = ast_strdup(field->name))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(cfg);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = strchr(initfield, ' ');</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (tmp_str)</span><br><span style="color: hsl(0, 100%, 40%);">- *tmp_str = '\0';</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- op = (!strchr(field->name, ' ')) ? " =" : "";</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- /*</span><br><span style="color: hsl(0, 100%, 40%);">- * Asterisk sends us an already escaped string when searching for</span><br><span style="color: hsl(0, 100%, 40%);">- * "exten LIKE" (uh!). Handle it separately.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = (!strcmp(field->value, "\\_%")) ? "_%" : (char *)field->value;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "SELECT * FROM '%q' WHERE%s %q%s '%q'"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(query = sqlite_mprintf(QUERY, table, (config_table && !strcmp(config_table, table)) ? " commented = 0 AND" : "", field->name, op, tmp_str))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(cfg);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(initfield);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- while ((field = field->next)) {</span><br><span style="color: hsl(0, 100%, 40%);">- op = (!strchr(field->name, ' ')) ? " =" : "";</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = sqlite_mprintf("%s AND %q%s '%q'", query, field->name, op, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_str) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(cfg);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(initfield);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(tmp_str = sqlite_mprintf("%s ORDER BY %q;", query, initfield))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(cfg);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(initfield);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">- args.cfg = cfg;</span><br><span style="color: hsl(0, 100%, 40%);">- args.initfield = initfield;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, add_rt_multi_cfg_entry, &args, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_free(initfield);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_destroy(cfg);</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return cfg;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_update_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *keyfield, const char *entity, const struct ast_variable *fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *query, *errormsg = NULL, *tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field = fields;</span><br><span style="color: hsl(0, 100%, 40%);">- int error, rows_num;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!field) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "UPDATE '%q' SET %q = '%q'"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(query = sqlite_mprintf(QUERY, table, field->name, field->value))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- while ((field = field->next)) {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = sqlite_mprintf("%s, %q = '%q'", query, field->name, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_str) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(tmp_str = sqlite_mprintf("%s WHERE %q = '%q';", query, keyfield, entity))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!error)</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = sqlite_changes(db);</span><br><span style="color: hsl(0, 100%, 40%);">- else</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = -1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return rows_num;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_update2_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *lookup_fields, const struct ast_variable *update_fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *errormsg = NULL, *tmp1, *tmp2;</span><br><span style="color: hsl(0, 100%, 40%);">- int error, rows_num, first = 1;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_str *sql = ast_str_thread_get(&sql_buf, 100);</span><br><span style="color: hsl(0, 100%, 40%);">- struct ast_str *where = ast_str_thread_get(&where_buf, 100);</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!sql) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_set(&sql, 0, "UPDATE %s SET", table);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_set(&where, 0, " WHERE");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (field = lookup_fields; field; field = field->next) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&where, 0, "%s %s = %s",</span><br><span style="color: hsl(0, 100%, 40%);">- first ? "" : " AND",</span><br><span style="color: hsl(0, 100%, 40%);">- tmp1 = sqlite_mprintf("%q", field->name),</span><br><span style="color: hsl(0, 100%, 40%);">- tmp2 = sqlite_mprintf("%Q", field->value));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp1);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp2);</span><br><span style="color: hsl(0, 100%, 40%);">- first = 0;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (first) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "No criteria specified on update to '%s@%s'!\n", table, database);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- first = 1;</span><br><span style="color: hsl(0, 100%, 40%);">- for (field = update_fields; field; field = field->next) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql, 0, "%s %s = %s",</span><br><span style="color: hsl(0, 100%, 40%);">- first ? "" : ",",</span><br><span style="color: hsl(0, 100%, 40%);">- tmp1 = sqlite_mprintf("%q", field->name),</span><br><span style="color: hsl(0, 100%, 40%);">- tmp2 = sqlite_mprintf("%Q", field->value));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp1);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp2);</span><br><span style="color: hsl(0, 100%, 40%);">- first = 0;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_str_append(&sql, 0, " %s", ast_str_buffer(where));</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", ast_str_buffer(sql));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, ast_str_buffer(sql), NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!error) {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = sqlite_changes(db);</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return rows_num;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_store_handler(const char *database, const char *table, const struct ast_variable *fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *errormsg = NULL, *tmp_str, *tmp_keys = NULL, *tmp_keys2 = NULL, *tmp_vals = NULL, *tmp_vals2 = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field = fields;</span><br><span style="color: hsl(0, 100%, 40%);">- int error, rows_id;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!fields) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "INSERT into '%q' (%s) VALUES (%s);"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- do {</span><br><span style="color: hsl(0, 100%, 40%);">- if ( tmp_keys2 ) {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_keys = sqlite_mprintf("%s, %q", tmp_keys2, field->name);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_keys2);</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_keys = sqlite_mprintf("%q", field->name);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_keys) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_vals);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if ( tmp_vals2 ) {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_vals = sqlite_mprintf("%s, '%q'", tmp_vals2, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_vals2);</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_vals = sqlite_mprintf("'%q'", field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_vals) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_keys);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_keys2 = tmp_keys;</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_vals2 = tmp_vals;</span><br><span style="color: hsl(0, 100%, 40%);">- } while ((field = field->next));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(tmp_str = sqlite_mprintf(QUERY, table, tmp_keys, tmp_vals))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_keys);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_vals);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_keys);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_vals);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", tmp_str);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, tmp_str, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!error) {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_id = sqlite_last_insert_rowid(db);</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_id = -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(tmp_str);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return rows_id;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_destroy_handler(const char *database, const char *table,</span><br><span style="color: hsl(0, 100%, 40%);">- const char *keyfield, const char *entity, const struct ast_variable *fields)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *query, *errormsg = NULL, *tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- const struct ast_variable *field;</span><br><span style="color: hsl(0, 100%, 40%);">- int error, rows_num;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!table) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Table name unspecified\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "DELETE FROM '%q' WHERE"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(query = sqlite_mprintf(QUERY, table))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (field = fields; field; field = field->next) {</span><br><span style="color: hsl(0, 100%, 40%);">- tmp_str = sqlite_mprintf("%s %q = '%q' AND", query, field->name, field->value);</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tmp_str) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(tmp_str = sqlite_mprintf("%s %q = '%q';", query, keyfield, entity))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Unable to reallocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">- query = tmp_str;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_lock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!error) {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = sqlite_changes(db);</span><br><span style="color: hsl(0, 100%, 40%);">- } else {</span><br><span style="color: hsl(0, 100%, 40%);">- rows_num = -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_mutex_unlock(&mutex);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return rows_num;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_require_handler(const char *unused, const char *tablename, va_list ap)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tbl = find_table(tablename);</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_columns *col;</span><br><span style="color: hsl(0, 100%, 40%);">- char *elm;</span><br><span style="color: hsl(0, 100%, 40%);">- int type, res = 0;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!tbl) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- while ((elm = va_arg(ap, char *))) {</span><br><span style="color: hsl(0, 100%, 40%);">- type = va_arg(ap, require_type);</span><br><span style="color: hsl(0, 100%, 40%);">- va_arg(ap, int);</span><br><span style="color: hsl(0, 100%, 40%);">- /* Check if the field matches the criteria */</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&tbl->columns, col, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (strcmp(col->name, elm) == 0) {</span><br><span style="color: hsl(0, 100%, 40%);">- /* SQLite only has two types - the 32-bit integer field that</span><br><span style="color: hsl(0, 100%, 40%);">- * is the key column, and everything else (everything else</span><br><span style="color: hsl(0, 100%, 40%);">- * being a string).</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">- if (col->isint && !ast_rq_is_int(type)) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Realtime table %s: column '%s' is an integer field, but Asterisk requires that it not be!\n", tablename, col->name);</span><br><span style="color: hsl(0, 100%, 40%);">- res = -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- break;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- if (!col) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_WARNING, "Realtime table %s requires column '%s', but that column does not exist!\n", tablename, elm);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&(tbl->columns));</span><br><span style="color: hsl(0, 100%, 40%);">- return res;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int realtime_unload_handler(const char *unused, const char *tablename)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tbl;</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_WRLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE_SAFE_BEGIN(&sqlite_tables, tbl, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- if (!strcasecmp(tbl->name, tablename)) {</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_REMOVE_CURRENT(list);</span><br><span style="color: hsl(0, 100%, 40%);">- free_table(tbl);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE_SAFE_END</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static char *handle_cli_show_sqlite_status(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- switch (cmd) {</span><br><span style="color: hsl(0, 100%, 40%);">- case CLI_INIT:</span><br><span style="color: hsl(0, 100%, 40%);">- e->command = "sqlite show status";</span><br><span style="color: hsl(0, 100%, 40%);">- e->usage =</span><br><span style="color: hsl(0, 100%, 40%);">- "Usage: sqlite show status\n"</span><br><span style="color: hsl(0, 100%, 40%);">- " Show status information about the SQLite 2 driver\n";</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- case CLI_GENERATE:</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (a->argc != 3)</span><br><span style="color: hsl(0, 100%, 40%);">- return CLI_SHOWUSAGE;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "SQLite database path: %s\n", dbfile);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "config_table: ");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!config_table)</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "unspecified, must be present in extconfig.conf\n");</span><br><span style="color: hsl(0, 100%, 40%);">- else</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "%s\n", config_table);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "cdr_table: ");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!cdr_table)</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "unspecified, CDR support disabled\n");</span><br><span style="color: hsl(0, 100%, 40%);">- else</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "%s\n", cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return CLI_SUCCESS;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static char *handle_cli_sqlite_show_tables(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_tables *tbl;</span><br><span style="color: hsl(0, 100%, 40%);">- struct sqlite_cache_columns *col;</span><br><span style="color: hsl(0, 100%, 40%);">- int found = 0;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- switch (cmd) {</span><br><span style="color: hsl(0, 100%, 40%);">- case CLI_INIT:</span><br><span style="color: hsl(0, 100%, 40%);">- e->command = "sqlite show tables";</span><br><span style="color: hsl(0, 100%, 40%);">- e->usage =</span><br><span style="color: hsl(0, 100%, 40%);">- "Usage: sqlite show tables\n"</span><br><span style="color: hsl(0, 100%, 40%);">- " Show table information about the SQLite 2 driver\n";</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- case CLI_GENERATE:</span><br><span style="color: hsl(0, 100%, 40%);">- return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (a->argc != 3)</span><br><span style="color: hsl(0, 100%, 40%);">- return CLI_SHOWUSAGE;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_RDLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&sqlite_tables, tbl, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- found++;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "Table %s:\n", tbl->name);</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_TRAVERSE(&(tbl->columns), col, list) {</span><br><span style="color: hsl(0, 100%, 40%);">- fprintf(stderr, "%s\n", col->name);</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, " %20.20s %-30.30s\n", col->name, col->type);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- AST_RWLIST_UNLOCK(&sqlite_tables);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!found) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli(a->fd, "No tables currently in cache\n");</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return CLI_SUCCESS;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int unload_module(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- if (cdr_registered && ast_cdr_unregister(RES_CONFIG_SQLITE_NAME)) {</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (cli_status_registered) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_cli_unregister_multiple(cli_status, ARRAY_LEN(cli_status));</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_engine_deregister(&sqlite_engine);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (db)</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_close(db);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- unload_config();</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*!</span><br><span style="color: hsl(0, 100%, 40%);">- * \brief Load the module</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Module loading including tests for configuration or dependencies.</span><br><span style="color: hsl(0, 100%, 40%);">- * This function can return AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_DECLINE,</span><br><span style="color: hsl(0, 100%, 40%);">- * or AST_MODULE_LOAD_SUCCESS. If a dependency or environment variable fails</span><br><span style="color: hsl(0, 100%, 40%);">- * tests return AST_MODULE_LOAD_FAILURE. If the module can not load the</span><br><span style="color: hsl(0, 100%, 40%);">- * configuration file or other non-critical problem return</span><br><span style="color: hsl(0, 100%, 40%);">- * AST_MODULE_LOAD_DECLINE. On success return AST_MODULE_LOAD_SUCCESS.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-static int load_module(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- char *errormsg = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- int error;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- db = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- cdr_registered = 0;</span><br><span style="color: hsl(0, 100%, 40%);">- cli_status_registered = 0;</span><br><span style="color: hsl(0, 100%, 40%);">- dbfile = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- config_table = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- cdr_table = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- error = load_config();</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error)</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!(db = sqlite_open(dbfile, 0660, &errormsg))) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- errormsg = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- ast_config_engine_register(&sqlite_engine);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (use_cdr) {</span><br><span style="color: hsl(0, 100%, 40%);">- char *query;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* \cond DOXYGEN_CAN_PARSE_THIS */</span><br><span style="color: hsl(0, 100%, 40%);">-#undef QUERY</span><br><span style="color: hsl(0, 100%, 40%);">-#define QUERY "SELECT COUNT(id) FROM %Q;"</span><br><span style="color: hsl(0, 100%, 40%);">-/* \endcond */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- query = sqlite_mprintf(QUERY, cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!query) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- /*</span><br><span style="color: hsl(0, 100%, 40%);">- * Unexpected error.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">- if (error != SQLITE_ERROR) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- errormsg = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">- query = sqlite_mprintf(sql_create_cdr_table, cdr_table);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (!query) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "Unable to allocate SQL query\n");</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- ast_debug(1, "SQL query: %s\n", query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_BEGIN</span><br><span style="color: hsl(0, 100%, 40%);">- error = sqlite_exec(db, query, NULL, NULL, &errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- RES_CONFIG_SQLITE_END(error)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(query);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- ast_log(LOG_ERROR, "%s\n", S_OR(errormsg, sqlite_error_string(error)));</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">- sqlite_freemem(errormsg);</span><br><span style="color: hsl(0, 100%, 40%);">- errormsg = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- error = ast_cdr_register(RES_CONFIG_SQLITE_NAME, RES_CONFIG_SQLITE_DESCRIPTION, cdr_handler);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- cdr_registered = 1;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- error = ast_cli_register_multiple(cli_status, ARRAY_LEN(cli_status));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (error) {</span><br><span style="color: hsl(0, 100%, 40%);">- unload_module();</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_DECLINE;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- cli_status_registered = 1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return AST_MODULE_LOAD_SUCCESS;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/*</span><br><span style="color: hsl(0, 100%, 40%);">- * This module should require "cdr" to enforce startup/shutdown ordering but it</span><br><span style="color: hsl(0, 100%, 40%);">- * loads at REALTIME_DRIVER priority which would cause "cdr" to load too early.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * ast_cdr_register / ast_cdr_unregister is safe for use while "cdr" is not running.</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_LOAD_ORDER, "Realtime SQLite configuration",</span><br><span style="color: hsl(0, 100%, 40%);">- .support_level = AST_MODULE_SUPPORT_DEPRECATED,</span><br><span style="color: hsl(0, 100%, 40%);">- .load = load_module,</span><br><span style="color: hsl(0, 100%, 40%);">- .unload = unload_module,</span><br><span style="color: hsl(0, 100%, 40%);">- .load_pri = AST_MODPRI_REALTIME_DRIVER,</span><br><span style="color: hsl(0, 100%, 40%);">- .requires = "extconfig",</span><br><span style="color: hsl(0, 100%, 40%);">-);</span><br><span></span><br></pre><div style="white-space:pre-wrap"></div><p>To view, visit <a href="https://gerrit.asterisk.org/c/asterisk/+/16323">change 16323</a>. To unsubscribe, or for help writing mail filters, visit <a href="https://gerrit.asterisk.org/settings">settings</a>.</p><div itemscope itemtype="http://schema.org/EmailMessage"><div itemscope itemprop="action" itemtype="http://schema.org/ViewAction"><link itemprop="url" href="https://gerrit.asterisk.org/c/asterisk/+/16323"/><meta itemprop="name" content="View Change"/></div></div>
<div style="display:none"> Gerrit-Project: asterisk </div>
<div style="display:none"> Gerrit-Branch: 19 </div>
<div style="display:none"> Gerrit-Change-Id: I8ef17023f55bf01f2e309b06f4778a8ca7252c91 </div>
<div style="display:none"> Gerrit-Change-Number: 16323 </div>
<div style="display:none"> Gerrit-PatchSet: 3 </div>
<div style="display:none"> Gerrit-Owner: Joshua Colp <jcolp@sangoma.com> </div>
<div style="display:none"> Gerrit-Reviewer: Friendly Automation </div>
<div style="display:none"> Gerrit-Reviewer: George Joseph <gjoseph@digium.com> </div>
<div style="display:none"> Gerrit-Reviewer: Kevin Harwell <kharwell@digium.com> </div>
<div style="display:none"> Gerrit-Reviewer: Sean Bright <sean@seanbright.com> </div>
<div style="display:none"> Gerrit-MessageType: merged </div>