diff --git a/libs/ldns/install-sh b/libs/ldns/install-sh index 3f83ce9..6781b98 100755 --- a/libs/ldns/install-sh +++ b/libs/ldns/install-sh @@ -1,7 +1,7 @@ #!/bin/sh # install - install a program, script, or datafile -scriptversion=2010-02-06.18; # UTC +scriptversion=2009-04-28.21; # UTC # This originates from X11R5 (mit/util/scripts/install.sh), which was # later released in X11R6 (xc/config/util/install.sh) with the @@ -200,11 +200,7 @@ if test $# -eq 0; then fi if test -z "$dir_arg"; then - do_exit='(exit $ret); exit $ret' - trap "ret=129; $do_exit" 1 - trap "ret=130; $do_exit" 2 - trap "ret=141; $do_exit" 13 - trap "ret=143; $do_exit" 15 + trap '(exit $?); exit' 1 2 13 15 # Set umask so as not to create temps with too-generous modes. # However, 'strip' requires both read and write access to temps. diff --git a/src/mod/languages/mod_python/mod_python.c b/src/mod/languages/mod_python/mod_python.c index 78caf3b..1c0f8e5 100644 --- a/src/mod/languages/mod_python/mod_python.c +++ b/src/mod/languages/mod_python/mod_python.c @@ -26,12 +26,14 @@ * Brian Fertig * Johny Kadarisman * Traun Leyden + * Heimo Stieg * * mod_python.c -- Python Module * */ #include +#include #ifndef _REENTRANT #define _REENTRANT @@ -43,6 +45,7 @@ #include #include "mod_python_extra.h" +#include PyThreadState *mainThreadState = NULL; @@ -50,243 +53,333 @@ void init_freeswitch(void); int py_thread(const char *text); static void set_max_recursion_depth(void); static switch_api_interface_t python_run_interface; +static void print_python_error(const char * script); SWITCH_MODULE_LOAD_FUNCTION(mod_python_load); SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_python_shutdown); SWITCH_MODULE_DEFINITION_EX(mod_python, mod_python_load, mod_python_shutdown, NULL, SMODF_GLOBAL_SYMBOLS); static struct { - switch_memory_pool_t *pool; - char *xml_handler; + switch_memory_pool_t *pool; + char *xml_handler; } globals; struct switch_py_thread { - struct switch_py_thread *prev, *next; - char *cmd; - char *args; - switch_memory_pool_t *pool; - PyThreadState *tstate; + struct switch_py_thread *prev, *next; + char *cmd; + char *args; + switch_memory_pool_t *pool; + PyThreadState *tstate; }; struct switch_py_thread *thread_pool_head = NULL; static switch_mutex_t *THREAD_POOL_LOCK = NULL; + + +/** +* This function is similiar to PyErr_Print. It uses the freeswitch print/log mechanism instead of the python sys.stderr +*/ +static void print_python_error(const char * script) +{ + PyObject *pyType = NULL, *pyValue = NULL, *pyTraceback = NULL, *pyString = NULL; + PyObject *pyModule=NULL, *pyFunction = NULL, *pyResult = NULL; + char * buffer = (char*) malloc( 20 * 1024 * sizeof(char)); + /* Variables for the traceback */ + PyTracebackObject * pyTB = NULL/*, *pyTB2 = NULL*/; + char sTemp[256]; + + if (buffer == NULL ) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Not enough Memory to create the error buffer"); + } + + /* just for security that we will always have a string terminater */ + memset(buffer, 0, 20 * 1024 * sizeof(char) ); + + /*Get the errordata*/ + PyErr_Fetch(&pyType, &pyValue, &pyTraceback); + PyErr_NormalizeException(&pyType, &pyValue, &pyTraceback); + + + /* Printing header*/ + sprintf(buffer, "Python Error by calling script \"%s\": ", script ); + + if (pyType != NULL && (pyString=PyObject_Str(pyType))!=NULL && (PyString_Check(pyString))) + strcat(buffer, PyString_AsString(pyString)); + else + strcat(buffer, " "); + Py_XDECREF(pyString); + + + /*Print error message*/ + if (pyValue != NULL && (pyString=PyObject_Str(pyValue))!=NULL && (PyString_Check(pyString))) { + strcat(buffer, "\nMessage: "); + strcat(buffer, PyString_AsString(pyString)); + } else + strcat(buffer, "\nMessage: "); + Py_XDECREF(pyString); + + + /*Print the traceback*/ + if (pyTraceback != NULL && PyTraceBack_Check(pyTraceback)) { + + /*loading traceback module to create the exception data*/ + pyModule = PyImport_ImportModule("traceback"); + if (pyModule) { + strcat(buffer, "\nException: "); + pyFunction = PyObject_GetAttrString(pyModule, "format_exc"); + if (pyFunction) { + pyResult = PyObject_CallObject(pyFunction, NULL); + if (pyResult && PyString_Check(pyResult)) + strcat(buffer, PyString_AsString(pyResult)); + else + strcat(buffer, ""); + Py_XDECREF(pyFunction); + + } + Py_XDECREF(pyModule); + + } + + /*print traceback header*/ + strcat(buffer, "\nTraceback (most recent call last)"); + pyTB = (PyTracebackObject*) pyTraceback; + + /*Traceback*/ + do { + sprintf((char*)sTemp, "\n\tFile: \"%s\", line %i, in %s", + PyString_AsString(pyTB->tb_frame->f_code->co_filename), + pyTB->tb_lineno, + PyString_AsString(pyTB->tb_frame->f_code->co_name) ); + strcat(buffer, (char*)sTemp); + + pyTB=pyTB->tb_next; + }while(pyTB != NULL ); + } + + PyErr_Restore(pyType,pyValue,pyTraceback); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "%s\n", buffer); + + /* free the resources, we dont need memory leaks here */ + free(buffer); +} + + static void eval_some_python(const char *funcname, char *args, switch_core_session_t *session, switch_stream_handle_t *stream, switch_event_t *params, - char **str, struct switch_py_thread *pt) + char **str, struct switch_py_thread *pt) { - PyThreadState *tstate = NULL; - char *dupargs = NULL; - char *argv[2] = { 0 }; - int argc; - char *script = NULL; - PyObject *module = NULL, *sp = NULL, *stp = NULL, *eve = NULL; - PyObject *function = NULL; - PyObject *arg = NULL; - PyObject *result = NULL; - char *p; - - if (str) { - *str = NULL; - } - - if (args) { - dupargs = strdup(args); - } else { - return; - } - - assert(dupargs != NULL); - - if (!(argc = switch_separate_string(dupargs, ' ', argv, (sizeof(argv) / sizeof(argv[0]))))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No module name specified!\n"); - goto done; - } - - script = strdup(switch_str_nil(argv[0])); - - if ((p = strstr(script, "::"))) { - *p = '\0'; - p += 2; - if (p) { - funcname = p; - } - } - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Invoking py module: %s\n", script); - - tstate = PyThreadState_New(mainThreadState->interp); - if (!tstate) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "error acquiring tstate\n"); - goto done; - } - - /* Save state in thread struct so we can terminate it later if needed */ - if (pt) - pt->tstate = tstate; - - // swap in thread state - PyEval_AcquireThread(tstate); - init_freeswitch(); - - // import the module - module = PyImport_ImportModule((char *) script); - if (!module) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error importing module\n"); - PyErr_Print(); - PyErr_Clear(); - goto done_swap_out; - } - // reload the module - module = PyImport_ReloadModule(module); - if (!module) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error reloading module\n"); - PyErr_Print(); - PyErr_Clear(); - goto done_swap_out; - } - // get the handler function to be called - function = PyObject_GetAttrString(module, (char *) funcname); - if (!function) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Module does not define %s\n", funcname); - PyErr_Print(); - PyErr_Clear(); - goto done_swap_out; - } - - if (session) { - sp = mod_python_conjure_session(module, session); - } - - if (params) { - eve = mod_python_conjure_event(params); - } - - if (stream) { - stp = mod_python_conjure_stream(stream); - if (stream->param_event) { - eve = mod_python_conjure_event(stream->param_event); - } - } - - if (sp && eve && stp) { - arg = Py_BuildValue("(OOOs)", sp, stp, eve, switch_str_nil(argv[1])); - } else if (eve && stp) { - arg = Py_BuildValue("(sOOs)", "na", stp, eve, switch_str_nil(argv[1])); - } else if (eve) { - arg = Py_BuildValue("(Os)", eve, switch_str_nil(argv[1])); - } else if (sp) { - arg = Py_BuildValue("(Os)", sp, switch_str_nil(argv[1])); - } else { - arg = Py_BuildValue("(s)", switch_str_nil(argv[1])); - } - - // invoke the handler - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Call python script \n"); - result = PyEval_CallObjectWithKeywords(function, arg, (PyObject *) NULL); - Py_DECREF(function); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Finished calling python script \n"); - - // check the result and print out any errors - if (result) { - if (str) { - *str = strdup((char *) PyString_AsString(result)); - } - } else if (!PyErr_ExceptionMatches(PyExc_SystemExit)) { - // Print error, but ignore SystemExit - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error calling python script\n"); - PyErr_Print(); - PyErr_Clear(); - PyRun_SimpleString("python_makes_sense"); - PyGC_Collect(); - } + PyThreadState *tstate = NULL; + char *dupargs = NULL; + char *argv[2] = { 0 }; + int argc; + char *script = NULL; + PyObject *module = NULL, *sp = NULL, *stp = NULL, *eve = NULL; + PyObject *function = NULL; + PyObject *arg = NULL; + PyObject *result = NULL; + char *p; + + if (str) { + *str = NULL; + } + + if (args) { + dupargs = strdup(args); + } else { + return; + } + + assert(dupargs != NULL); + + if (!(argc = switch_separate_string(dupargs, ' ', argv, (sizeof(argv) / sizeof(argv[0]))))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No module name specified!\n"); + goto done; + } + + script = strdup(switch_str_nil(argv[0])); + + if ((p = strstr(script, "::"))) { + *p = '\0'; + p += 2; + if (p) { + funcname = p; + } + } + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Invoking py module: %s\n", script); + + tstate = PyThreadState_New(mainThreadState->interp); + if (!tstate) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "error acquiring tstate\n"); + goto done; + } + + /* Save state in thread struct so we can terminate it later if needed */ + if (pt) + pt->tstate = tstate; + + // swap in thread state + PyEval_AcquireThread(tstate); + init_freeswitch(); + + // import the module + module = PyImport_ImportModule((char *) script); + if (!module) + { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error importing module\n"); + print_python_error(script); + PyErr_Clear(); + goto done_swap_out; + } + // reload the module + module = PyImport_ReloadModule(module); + if (!module) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error reloading module\n"); + print_python_error(script); + goto done_swap_out; + } + // get the handler function to be called + function = PyObject_GetAttrString(module, (char *) funcname); + if (!function) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Module does not define %s\n", funcname); + print_python_error(script); + goto done_swap_out; + } + + if (session) { + sp = mod_python_conjure_session(module, session); + } + + if (params) { + eve = mod_python_conjure_event(params); + } + + if (stream) { + stp = mod_python_conjure_stream(stream); + if (stream->param_event) { + eve = mod_python_conjure_event(stream->param_event); + } + } + + if (sp && eve && stp) { + arg = Py_BuildValue("(OOOs)", sp, stp, eve, switch_str_nil(argv[1])); + } else if (eve && stp) { + arg = Py_BuildValue("(sOOs)", "na", stp, eve, switch_str_nil(argv[1])); + } else if (eve) { + arg = Py_BuildValue("(Os)", eve, switch_str_nil(argv[1])); + } else if (sp) { + arg = Py_BuildValue("(Os)", sp, switch_str_nil(argv[1])); + } else { + arg = Py_BuildValue("(s)", switch_str_nil(argv[1])); + } + + // invoke the handler + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Call python script \n"); + result = PyEval_CallObjectWithKeywords(function, arg, (PyObject *) NULL); + Py_DECREF(function); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Finished calling python script \n"); + + // check the result and print out any errors + if (result) { + if (str) { + *str = strdup((char *) PyString_AsString(result)); + } + } else if (!PyErr_ExceptionMatches(PyExc_SystemExit)) { + // Print error, but ignore SystemExit + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error calling python script\n"); + print_python_error(script); + PyRun_SimpleString("python_makes_sense"); + PyGC_Collect(); + } done_swap_out: - if (arg) { - Py_DECREF(arg); - } + if (arg) { + Py_DECREF(arg); + } - if (sp) { - Py_DECREF(sp); - } + if (sp) { + Py_DECREF(sp); + } - if (tstate) { - // thread state must be cleared explicitly or we'll get memory leaks - PyThreadState_Clear(tstate); - PyEval_ReleaseThread(tstate); - PyThreadState_Delete(tstate); - } + if (tstate) { + // thread state must be cleared explicitly or we'll get memory leaks + PyThreadState_Clear(tstate); + PyEval_ReleaseThread(tstate); + PyThreadState_Delete(tstate); + } done: - switch_safe_free(dupargs); - switch_safe_free(script); + switch_safe_free(dupargs); + switch_safe_free(script); } static switch_xml_t python_fetch(const char *section, - const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, void *user_data) + const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, void *user_data) { - switch_xml_t xml = NULL; - char *str = NULL; + switch_xml_t xml = NULL; + char *str = NULL; - if (!zstr(globals.xml_handler)) { - char *mycmd = strdup(globals.xml_handler); + if (!zstr(globals.xml_handler)) { + char *mycmd = strdup(globals.xml_handler); - switch_assert(mycmd); + switch_assert(mycmd); - eval_some_python("xml_fetch", mycmd, NULL, NULL, params, &str, NULL); + eval_some_python("xml_fetch", mycmd, NULL, NULL, params, &str, NULL); - if (str) { - if (zstr(str)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No Result\n"); - } else if (!(xml = switch_xml_parse_str((char *) str, strlen(str)))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Parsing XML Result!\n"); - } - switch_safe_free(str); - } + if (str) { + if (zstr(str)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No Result\n"); + } else if (!(xml = switch_xml_parse_str((char *) str, strlen(str)))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Parsing XML Result!\n"); + } + switch_safe_free(str); + } - free(mycmd); - } + free(mycmd); + } - return xml; + return xml; } static switch_status_t do_config(void) { - char *cf = "python.conf"; - switch_xml_t cfg, xml, settings, param; - - if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Open of %s failed\n", cf); - return SWITCH_STATUS_TERM; - } - - if ((settings = switch_xml_child(cfg, "settings"))) { - for (param = switch_xml_child(settings, "param"); param; param = param->next) { - char *var = (char *) switch_xml_attr_soft(param, "name"); - char *val = (char *) switch_xml_attr_soft(param, "value"); - - if (!strcmp(var, "xml-handler-script")) { - globals.xml_handler = switch_core_strdup(globals.pool, val); - } else if (!strcmp(var, "xml-handler-bindings")) { - if (!zstr(globals.xml_handler)) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "binding '%s' to '%s'\n", globals.xml_handler, val); - switch_xml_bind_search_function(python_fetch, switch_xml_parse_section_string(val), NULL); - } - } else if (!strcmp(var, "startup-script")) { - if (val) { - py_thread(val); - } - } - } - } - - switch_xml_free(xml); - - return SWITCH_STATUS_SUCCESS; + char *cf = "python.conf"; + switch_xml_t cfg, xml, settings, param; + + if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Open of %s failed\n", cf); + return SWITCH_STATUS_TERM; + } + + if ((settings = switch_xml_child(cfg, "settings"))) { + for (param = switch_xml_child(settings, "param"); param; param = param->next) { + char *var = (char *) switch_xml_attr_soft(param, "name"); + char *val = (char *) switch_xml_attr_soft(param, "value"); + + if (!strcmp(var, "xml-handler-script")) { + globals.xml_handler = switch_core_strdup(globals.pool, val); + } else if (!strcmp(var, "xml-handler-bindings")) { + if (!zstr(globals.xml_handler)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "binding '%s' to '%s'\n", globals.xml_handler, val); + switch_xml_bind_search_function(python_fetch, switch_xml_parse_section_string(val), NULL); + } + } else if (!strcmp(var, "startup-script")) { + if (val) { + py_thread(val); + } + } + } + } + + switch_xml_free(xml); + + return SWITCH_STATUS_SUCCESS; } @@ -298,227 +391,227 @@ static switch_status_t do_config(void) static void set_max_recursion_depth(void) { - // assume that a stack frame is approximately 1K, so divide thread stack size (eg, 240K) by - // 1K to get the approx number of stack frames we can hold before blowing up. - int newMaxRecursionDepth = SWITCH_THREAD_STACKSIZE / 1024; - - PyObject *sysModule = PyImport_ImportModule("sys"); - PyObject *setRecursionLimit = PyObject_GetAttrString(sysModule, "setrecursionlimit"); - PyObject *recLimit = Py_BuildValue("(i)", newMaxRecursionDepth); - PyObject *setrecursion_result = PyEval_CallObjectWithKeywords(setRecursionLimit, recLimit, (PyObject *) NULL); - if (setrecursion_result) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Set python recursion limit to %d\n", newMaxRecursionDepth); - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to set recursion limit to %d\n", newMaxRecursionDepth); - PyErr_Print(); - PyErr_Clear(); - PyRun_SimpleString("python_makes_sense"); - PyGC_Collect(); - } + // assume that a stack frame is approximately 1K, so divide thread stack size (eg, 240K) by + // 1K to get the approx number of stack frames we can hold before blowing up. + int newMaxRecursionDepth = SWITCH_THREAD_STACKSIZE / 1024; + + PyObject *sysModule = PyImport_ImportModule("sys"); + PyObject *setRecursionLimit = PyObject_GetAttrString(sysModule, "setrecursionlimit"); + PyObject *recLimit = Py_BuildValue("(i)", newMaxRecursionDepth); + PyObject *setrecursion_result = PyEval_CallObjectWithKeywords(setRecursionLimit, recLimit, (PyObject *) NULL); + if (setrecursion_result) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Set python recursion limit to %d\n", newMaxRecursionDepth); + } else { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to set recursion limit to %d\n", newMaxRecursionDepth); + print_python_error("_freeswitch"); + PyErr_Clear(); + PyRun_SimpleString("python_makes_sense"); + PyGC_Collect(); + } } SWITCH_STANDARD_APP(python_function) { - eval_some_python("handler", (char *) data, session, NULL, NULL, NULL, NULL); + eval_some_python("handler", (char *) data, session, NULL, NULL, NULL, NULL); } static void *SWITCH_THREAD_FUNC py_thread_run(switch_thread_t *thread, void *obj) { - switch_memory_pool_t *pool; - struct switch_py_thread *pt = (struct switch_py_thread *) obj; - - /* Put thread in pool so we keep track of our threads */ - switch_mutex_lock(THREAD_POOL_LOCK); - pt->next = thread_pool_head; - pt->prev = NULL; - if (pt->next) - pt->next->prev = pt; - thread_pool_head = pt; - switch_mutex_unlock(THREAD_POOL_LOCK); - - /* Run the python script */ - eval_some_python("runtime", pt->args, NULL, NULL, NULL, NULL, pt); - - /* Thread is dead, remove from pool */ - switch_mutex_lock(THREAD_POOL_LOCK); - if (pt->next) - pt->next->prev = pt->prev; - if (pt->prev) - pt->prev->next = pt->next; - if (thread_pool_head == pt) - thread_pool_head = pt->next; - switch_mutex_unlock(THREAD_POOL_LOCK); - - pool = pt->pool; - switch_core_destroy_memory_pool(&pool); - - return NULL; + switch_memory_pool_t *pool; + struct switch_py_thread *pt = (struct switch_py_thread *) obj; + + /* Put thread in pool so we keep track of our threads */ + switch_mutex_lock(THREAD_POOL_LOCK); + pt->next = thread_pool_head; + pt->prev = NULL; + if (pt->next) + pt->next->prev = pt; + thread_pool_head = pt; + switch_mutex_unlock(THREAD_POOL_LOCK); + + /* Run the python script */ + eval_some_python("runtime", pt->args, NULL, NULL, NULL, NULL, pt); + + /* Thread is dead, remove from pool */ + switch_mutex_lock(THREAD_POOL_LOCK); + if (pt->next) + pt->next->prev = pt->prev; + if (pt->prev) + pt->prev->next = pt->next; + if (thread_pool_head == pt) + thread_pool_head = pt->next; + switch_mutex_unlock(THREAD_POOL_LOCK); + + pool = pt->pool; + switch_core_destroy_memory_pool(&pool); + + return NULL; } SWITCH_STANDARD_API(api_python) { - eval_some_python("fsapi", (char *) cmd, session, stream, NULL, NULL, NULL); + eval_some_python("fsapi", (char *) cmd, session, stream, NULL, NULL, NULL); - return SWITCH_STATUS_SUCCESS; + return SWITCH_STATUS_SUCCESS; } int py_thread(const char *text) { - switch_thread_t *thread; - switch_threadattr_t *thd_attr = NULL; - switch_memory_pool_t *pool; - struct switch_py_thread *pt; + switch_thread_t *thread; + switch_threadattr_t *thd_attr = NULL; + switch_memory_pool_t *pool; + struct switch_py_thread *pt; - switch_core_new_memory_pool(&pool); - assert(pool != NULL); + switch_core_new_memory_pool(&pool); + assert(pool != NULL); - pt = switch_core_alloc(pool, sizeof(*pt)); - assert(pt != NULL); + pt = switch_core_alloc(pool, sizeof(*pt)); + assert(pt != NULL); - pt->pool = pool; - pt->args = switch_core_strdup(pt->pool, text); + pt->pool = pool; + pt->args = switch_core_strdup(pt->pool, text); - switch_threadattr_create(&thd_attr, pt->pool); - switch_threadattr_detach_set(thd_attr, 1); - switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); - switch_thread_create(&thread, thd_attr, py_thread_run, pt, pt->pool); + switch_threadattr_create(&thd_attr, pt->pool); + switch_threadattr_detach_set(thd_attr, 1); + switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); + switch_thread_create(&thread, thd_attr, py_thread_run, pt, pt->pool); - return 0; + return 0; } SWITCH_STANDARD_API(launch_python) { - if (zstr(cmd)) { - stream->write_function(stream, "USAGE: %s\n", python_run_interface.syntax); - return SWITCH_STATUS_SUCCESS; - } + if (zstr(cmd)) { + stream->write_function(stream, "USAGE: %s\n", python_run_interface.syntax); + return SWITCH_STATUS_SUCCESS; + } - py_thread(cmd); - stream->write_function(stream, "OK\n"); - return SWITCH_STATUS_SUCCESS; + py_thread(cmd); + stream->write_function(stream, "OK\n"); + return SWITCH_STATUS_SUCCESS; } SWITCH_MODULE_LOAD_FUNCTION(mod_python_load) { - switch_api_interface_t *api_interface; - switch_application_interface_t *app_interface; - char *pp = getenv("PYTHONPATH"); + switch_api_interface_t *api_interface; + switch_application_interface_t *app_interface; + char *pp = getenv("PYTHONPATH"); - if (pp) { - char *path = switch_mprintf("%s:%s", pp, SWITCH_GLOBAL_dirs.script_dir); - setenv("PYTHONPATH", path, 1); - free(path); - } else { - setenv("PYTHONPATH", SWITCH_GLOBAL_dirs.script_dir, 1); - } + if (pp) { + char *path = switch_mprintf("%s:%s", pp, SWITCH_GLOBAL_dirs.script_dir); + setenv("PYTHONPATH", path, 1); + free(path); + } else { + setenv("PYTHONPATH", SWITCH_GLOBAL_dirs.script_dir, 1); + } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Python Framework Loading...\n"); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Python Framework Loading...\n"); - globals.pool = pool; + globals.pool = pool; - if (!Py_IsInitialized()) { + if (!Py_IsInitialized()) { - // initialize python system - Py_Initialize(); + // initialize python system + Py_Initialize(); - // create GIL and a threadstate - PyEval_InitThreads(); + // create GIL and a threadstate + PyEval_InitThreads(); - // save threadstate since it's interp field will be needed - // to create new threadstates, and will be needed for shutdown - mainThreadState = PyThreadState_Get(); + // save threadstate since it's interp field will be needed + // to create new threadstates, and will be needed for shutdown + mainThreadState = PyThreadState_Get(); - // set the maximum recursion depth - set_max_recursion_depth(); + // set the maximum recursion depth + set_max_recursion_depth(); - // swap out threadstate since the call threads will create - // their own and swap in their threadstate - PyThreadState_Swap(NULL); + // swap out threadstate since the call threads will create + // their own and swap in their threadstate + PyThreadState_Swap(NULL); - // release GIL - PyEval_ReleaseLock(); - } + // release GIL + PyEval_ReleaseLock(); + } - switch_mutex_init(&THREAD_POOL_LOCK, SWITCH_MUTEX_NESTED, pool); + switch_mutex_init(&THREAD_POOL_LOCK, SWITCH_MUTEX_NESTED, pool); - do_config(); + do_config(); - /* connect my internal structure to the blank pointer passed to me */ - *module_interface = switch_loadable_module_create_module_interface(pool, modname); - SWITCH_ADD_API(api_interface, "pyrun", "run a python script", launch_python, "python "); - SWITCH_ADD_API(api_interface, "python", "run a python script", api_python, "python "); - SWITCH_ADD_APP(app_interface, "python", "Launch python ivr", "Run a python ivr on a channel", python_function, "