mirror of
https://github.com/signalwire/freeswitch.git
synced 2025-04-26 04:27:25 +00:00
make luarun use a new pool every call
git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@14763 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
parent
4ee9dc1354
commit
e988135dba
src/mod/languages/mod_lua
@ -18,6 +18,7 @@
|
|||||||
%}
|
%}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
%ignore SwitchToMempool;
|
%ignore SwitchToMempool;
|
||||||
%newobject EventConsumer::pop;
|
%newobject EventConsumer::pop;
|
||||||
%newobject Session;
|
%newobject Session;
|
||||||
@ -54,7 +55,7 @@ class Session : public CoreSession {
|
|||||||
virtual switch_status_t run_dtmf_callback(void *input, switch_input_type_t itype);
|
virtual switch_status_t run_dtmf_callback(void *input, switch_input_type_t itype);
|
||||||
void unsetInputCallback(void);
|
void unsetInputCallback(void);
|
||||||
void setInputCallback(char *cbfunc, char *funcargs = NULL);
|
void setInputCallback(char *cbfunc, char *funcargs = NULL);
|
||||||
void setHangupHook(char *func, char *arg = NULL);
|
void setHangupHook(char *func, char *arg);
|
||||||
bool ready();
|
bool ready();
|
||||||
int originate(CoreSession *a_leg_session, char *dest, int timeout);
|
int originate(CoreSession *a_leg_session, char *dest, int timeout);
|
||||||
|
|
||||||
|
@ -32,7 +32,7 @@ class Session : public CoreSession {
|
|||||||
virtual switch_status_t run_dtmf_callback(void *input, switch_input_type_t itype);
|
virtual switch_status_t run_dtmf_callback(void *input, switch_input_type_t itype);
|
||||||
void unsetInputCallback(void);
|
void unsetInputCallback(void);
|
||||||
void setInputCallback(char *cbfunc, char *funcargs = NULL);
|
void setInputCallback(char *cbfunc, char *funcargs = NULL);
|
||||||
void setHangupHook(char *func, char *arg = NULL);
|
void setHangupHook(char *func, char *arg);
|
||||||
bool ready();
|
bool ready();
|
||||||
int originate(CoreSession *a_leg_session, char *dest, int timeout);
|
int originate(CoreSession *a_leg_session, char *dest, int timeout);
|
||||||
|
|
||||||
|
@ -187,16 +187,22 @@ static int lua_parse_and_execute(lua_State * L, char *input_code)
|
|||||||
return error;
|
return error;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
struct lua_thread_helper {
|
||||||
|
switch_memory_pool_t *pool;
|
||||||
|
char *input_code;
|
||||||
|
};
|
||||||
|
|
||||||
static void *SWITCH_THREAD_FUNC lua_thread_run(switch_thread_t *thread, void *obj)
|
static void *SWITCH_THREAD_FUNC lua_thread_run(switch_thread_t *thread, void *obj)
|
||||||
{
|
{
|
||||||
char *input_code = (char *) obj;
|
struct lua_thread_helper *lth = (struct lua_thread_helper *) obj;
|
||||||
|
switch_memory_pool_t *pool = lth->pool;
|
||||||
lua_State *L = lua_init(); /* opens Lua */
|
lua_State *L = lua_init(); /* opens Lua */
|
||||||
|
|
||||||
lua_parse_and_execute(L, input_code);
|
lua_parse_and_execute(L, lth->input_code);
|
||||||
|
|
||||||
if (input_code) {
|
lth = NULL;
|
||||||
free(input_code);
|
|
||||||
}
|
switch_core_destroy_memory_pool(&pool);
|
||||||
|
|
||||||
lua_uninit(L);
|
lua_uninit(L);
|
||||||
|
|
||||||
@ -365,11 +371,18 @@ int lua_thread(const char *text)
|
|||||||
{
|
{
|
||||||
switch_thread_t *thread;
|
switch_thread_t *thread;
|
||||||
switch_threadattr_t *thd_attr = NULL;
|
switch_threadattr_t *thd_attr = NULL;
|
||||||
|
switch_memory_pool_t *pool;
|
||||||
|
lua_thread_helper *lth;
|
||||||
|
|
||||||
switch_threadattr_create(&thd_attr, globals.pool);
|
switch_core_new_memory_pool(&pool);
|
||||||
|
lth = (lua_thread_helper *) switch_core_alloc(pool, sizeof(*lth));
|
||||||
|
lth->pool = pool;
|
||||||
|
lth->input_code = switch_core_strdup(lth->pool, text);
|
||||||
|
|
||||||
|
switch_threadattr_create(&thd_attr, lth->pool);
|
||||||
switch_threadattr_detach_set(thd_attr, 1);
|
switch_threadattr_detach_set(thd_attr, 1);
|
||||||
switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
|
switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
|
||||||
switch_thread_create(&thread, thd_attr, lua_thread_run, strdup(text), globals.pool);
|
switch_thread_create(&thread, thd_attr, lua_thread_run, lth, lth->pool);
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
@ -7747,7 +7747,7 @@ static int _wrap_Session_setInputCallback(lua_State* L) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
static int _wrap_Session_setHangupHook__SWIG_0(lua_State* L) {
|
static int _wrap_Session_setHangupHook(lua_State* L) {
|
||||||
int SWIG_arg = -1;
|
int SWIG_arg = -1;
|
||||||
LUA::Session *arg1 = (LUA::Session *) 0 ;
|
LUA::Session *arg1 = (LUA::Session *) 0 ;
|
||||||
char *arg2 = (char *) 0 ;
|
char *arg2 = (char *) 0 ;
|
||||||
@ -7777,89 +7777,6 @@ fail:
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
static int _wrap_Session_setHangupHook__SWIG_1(lua_State* L) {
|
|
||||||
int SWIG_arg = -1;
|
|
||||||
LUA::Session *arg1 = (LUA::Session *) 0 ;
|
|
||||||
char *arg2 = (char *) 0 ;
|
|
||||||
|
|
||||||
SWIG_check_num_args("setHangupHook",2,2)
|
|
||||||
if(!SWIG_isptrtype(L,1)) SWIG_fail_arg("setHangupHook",1,"LUA::Session *");
|
|
||||||
if(!lua_isstring(L,2)) SWIG_fail_arg("setHangupHook",2,"char *");
|
|
||||||
|
|
||||||
if (!SWIG_IsOK(SWIG_ConvertPtr(L,1,(void**)&arg1,SWIGTYPE_p_LUA__Session,0))){
|
|
||||||
SWIG_fail_ptr("Session_setHangupHook",1,SWIGTYPE_p_LUA__Session);
|
|
||||||
}
|
|
||||||
|
|
||||||
arg2 = (char *)lua_tostring(L, 2);
|
|
||||||
(arg1)->setHangupHook(arg2);
|
|
||||||
SWIG_arg=0;
|
|
||||||
|
|
||||||
return SWIG_arg;
|
|
||||||
|
|
||||||
if(0) SWIG_fail;
|
|
||||||
|
|
||||||
fail:
|
|
||||||
lua_error(L);
|
|
||||||
return SWIG_arg;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
static int _wrap_Session_setHangupHook(lua_State* L) {
|
|
||||||
int argc;
|
|
||||||
int argv[4]={
|
|
||||||
1,2,3,4
|
|
||||||
};
|
|
||||||
|
|
||||||
argc = lua_gettop(L);
|
|
||||||
if (argc == 2) {
|
|
||||||
int _v;
|
|
||||||
{
|
|
||||||
void *ptr;
|
|
||||||
if (SWIG_isptrtype(L,argv[0])==0 || SWIG_ConvertPtr(L,argv[0], (void **) &ptr, SWIGTYPE_p_LUA__Session, 0)) {
|
|
||||||
_v = 0;
|
|
||||||
} else {
|
|
||||||
_v = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (_v) {
|
|
||||||
{
|
|
||||||
_v = lua_isstring(L,argv[1]);
|
|
||||||
}
|
|
||||||
if (_v) {
|
|
||||||
return _wrap_Session_setHangupHook__SWIG_1(L);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (argc == 3) {
|
|
||||||
int _v;
|
|
||||||
{
|
|
||||||
void *ptr;
|
|
||||||
if (SWIG_isptrtype(L,argv[0])==0 || SWIG_ConvertPtr(L,argv[0], (void **) &ptr, SWIGTYPE_p_LUA__Session, 0)) {
|
|
||||||
_v = 0;
|
|
||||||
} else {
|
|
||||||
_v = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (_v) {
|
|
||||||
{
|
|
||||||
_v = lua_isstring(L,argv[1]);
|
|
||||||
}
|
|
||||||
if (_v) {
|
|
||||||
{
|
|
||||||
_v = lua_isstring(L,argv[2]);
|
|
||||||
}
|
|
||||||
if (_v) {
|
|
||||||
return _wrap_Session_setHangupHook__SWIG_0(L);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
lua_pushstring(L,"No matching function for overloaded 'Session_setHangupHook'");
|
|
||||||
lua_error(L);return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
static int _wrap_Session_ready(lua_State* L) {
|
static int _wrap_Session_ready(lua_State* L) {
|
||||||
int SWIG_arg = -1;
|
int SWIG_arg = -1;
|
||||||
LUA::Session *arg1 = (LUA::Session *) 0 ;
|
LUA::Session *arg1 = (LUA::Session *) 0 ;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user