diff --git a/channels/chan_local.c b/channels/chan_local.c index 754f49b8c2..a9a27ff8c2 100644 --- a/channels/chan_local.c +++ b/channels/chan_local.c @@ -106,8 +106,8 @@ struct local_pvt { char exten[AST_MAX_EXTENSION]; /* Extension to call */ int reqformat; /* Requested format */ struct ast_jb_conf jb_conf; /*!< jitterbuffer configuration for this local channel */ - struct ast_channel *owner; /* Master Channel */ - struct ast_channel *chan; /* Outbound channel */ + struct ast_channel *owner; /* Master Channel - Bridging happens here */ + struct ast_channel *chan; /* Outbound channel - PBX is run here */ struct ast_module_user *u_owner; /*! reference to keep the module loaded while in use */ struct ast_module_user *u_chan; /*! reference to keep the module loaded while in use */ AST_LIST_ENTRY(local_pvt) list; /* Next entity */ @@ -303,6 +303,7 @@ static void check_bridge(struct local_pvt *p, int isoutbound) p->chan->audiohooks = p->owner->audiohooks; p->owner->audiohooks = audiohooks_swapper; } + ast_app_group_update(p->chan, p->owner); ast_channel_masquerade(p->owner, p->chan->_bridge); ast_set_flag(p, LOCAL_ALREADY_MASQED); } diff --git a/res/res_odbc.c b/res/res_odbc.c index d0580d4cb4..b928ec8a8b 100644 --- a/res/res_odbc.c +++ b/res/res_odbc.c @@ -99,9 +99,11 @@ static int null_hash_fn(const void *obj, const int flags) static void odbc_obj_destructor(void *data) { struct odbc_obj *obj = data; + struct odbc_class *class = obj->parent; + obj->parent = NULL; odbc_obj_disconnect(obj); ast_mutex_destroy(&obj->lock); - ao2_ref(obj->parent, -1); + ao2_ref(class, -1); } static void destroy_table_cache(struct odbc_cache_tables *table) { @@ -556,10 +558,11 @@ static char *handle_cli_odbc_show(struct ast_cli_entry *e, int cmd, struct ast_c while ((class = ao2_iterator_next(&aoi))) { if (!strncasecmp(a->word, class->name, length) && ++which > a->n) { ret = ast_strdup(class->name); - ao2_ref(class, -1); - break; } ao2_ref(class, -1); + if (ret) { + break; + } } if (!ret && !strncasecmp(a->word, "all", length) && ++which > a->n) { ret = ast_strdup("all"); @@ -674,6 +677,8 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) if (!class) return NULL; + ast_assert(ao2_ref(class, 0) > 1); + if (class->haspool) { /* Recycle connections before building another */ aoi = ao2_iterator_init(class->obj_container, 0); @@ -687,6 +692,10 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) ao2_ref(obj, -1); } + if (obj) { + ast_assert(ao2_ref(obj, 0) > 1); + } + if (!obj && (class->count < class->limit)) { class->count++; obj = ao2_alloc(sizeof(*obj), odbc_obj_destructor); @@ -694,12 +703,14 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) ao2_ref(class, -1); return NULL; } + ast_assert(ao2_ref(obj, 0) == 1); ast_mutex_init(&obj->lock); /* obj inherits the outstanding reference to class */ obj->parent = class; if (odbc_obj_connect(obj) == ODBC_FAIL) { ast_log(LOG_WARNING, "Failed to connect to %s\n", name); ao2_ref(obj, -1); + ast_assert(ao2_ref(class, 0) > 0); obj = NULL; } else { obj->used = 1; @@ -721,12 +732,14 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) if (obj) { /* Object is not constructed, so delete outstanding reference to class. */ + ast_assert(ao2_ref(class, 0) > 1); ao2_ref(class, -1); class = NULL; } else { /* No entry: build one */ obj = ao2_alloc(sizeof(*obj), odbc_obj_destructor); if (!obj) { + ast_assert(ao2_ref(class, 0) > 1); ao2_ref(class, -1); return NULL; } @@ -739,6 +752,7 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) obj = NULL; } else { ao2_link(class->obj_container, obj); + ast_assert(ao2_ref(obj, 0) > 1); } class = NULL; } @@ -758,6 +772,9 @@ struct odbc_obj *ast_odbc_request_obj(const char *name, int check) #endif ast_assert(class == NULL); + if (obj) { + ast_assert(ao2_ref(obj, 0) > 1); + } return obj; } @@ -777,10 +794,12 @@ static odbc_status odbc_obj_disconnect(struct odbc_obj *obj) res = SQLDisconnect(obj->con); - if (res == SQL_SUCCESS || res == SQL_SUCCESS_WITH_INFO) { - ast_log(LOG_DEBUG, "Disconnected %d from %s [%s]\n", res, obj->parent->name, obj->parent->dsn); - } else { - ast_log(LOG_DEBUG, "res_odbc: %s [%s] already disconnected\n", obj->parent->name, obj->parent->dsn); + if (obj->parent) { + if (res == SQL_SUCCESS || res == SQL_SUCCESS_WITH_INFO) { + ast_log(LOG_DEBUG, "Disconnected %d from %s [%s]\n", res, obj->parent->name, obj->parent->dsn); + } else { + ast_log(LOG_DEBUG, "res_odbc: %s [%s] already disconnected\n", obj->parent->name, obj->parent->dsn); + } } if ((res = SQLFreeHandle(SQL_HANDLE_DBC, obj->con) == SQL_SUCCESS)) {