kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-09-05 12:16:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merged revisions 118509 via svnmerge from

Browse Source 
https://origsvn.digium.com/svn/asterisk/branches/1.4

........
r118509 | mmichelson | 2008-05-27 14:07:26 -0500 (Tue, 27 May 2008) | 11 lines

Russell noted to me that in the case that separate threads use their
own addressing system, the fix I made for issue 12376 does not guarantee
uniqueness to the datastores' uids. Though I know of no system that works
this way, I am going to change this right now to prevent trying to track
down some future bug that may occur and cause untold hours of debugging
time to track down.

The change involves using a global counter which increases with each new
chanspy_ds which is created. This guarantees uniqueness.


........


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@118514 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Mark Michelson
2008-05-27 19:08:24 +00:00
parent 4169ea891c
commit 614ae91092
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
apps/app_chanspy.c
View File

@@ -217,6 +217,7 @@ AST_APP_OPTIONS(spy_opts, {
AST_APP_OPTION('d', OPTION_DTMF_SWITCH_MODES),
});
int next_unique_id_to_use = 0;
struct chanspy_translation_helper {
/* spy data */
@@ -293,6 +294,7 @@ static int start_spying(struct ast_channel *chan, const char *spychan_name, stru
struct chanspy_ds {
struct ast_channel *chan;
char unique_id[20];
ast_mutex_t lock;
};
@@ -541,13 +543,11 @@ static struct chanspy_ds *chanspy_ds_free(struct chanspy_ds *chanspy_ds)
if (chanspy_ds->chan) {
struct ast_datastore *datastore;
struct ast_channel *chan;
char uid[20];
chan = chanspy_ds->chan;
ast_channel_lock(chan);
snprintf(uid, sizeof(uid), "%p", chanspy_ds);
if ((datastore = ast_channel_datastore_find(chan, &chanspy_ds_info, uid))) {
if ((datastore = ast_channel_datastore_find(chan, &chanspy_ds_info, chanspy_ds->unique_id))) {
ast_channel_datastore_remove(chan, datastore);
/* chanspy_ds->chan is NULL after this call */
chanspy_ds_destroy(datastore->data);
@@ -565,13 +565,10 @@ static struct chanspy_ds *chanspy_ds_free(struct chanspy_ds *chanspy_ds)
static struct chanspy_ds *setup_chanspy_ds(struct ast_channel *chan, struct chanspy_ds *chanspy_ds)
{
struct ast_datastore *datastore = NULL;
char uid[20];
ast_mutex_lock(&chanspy_ds->lock);
snprintf(uid, sizeof(uid), "%p", chanspy_ds);
if (!(datastore = ast_channel_datastore_alloc(&chanspy_ds_info, uid))) {
if (!(datastore = ast_channel_datastore_alloc(&chanspy_ds_info, chanspy_ds->unique_id))) {
ast_mutex_unlock(&chanspy_ds->lock);
chanspy_ds = chanspy_ds_free(chanspy_ds);
ast_channel_unlock(chan);
@@ -645,6 +642,8 @@ static int common_exec(struct ast_channel *chan, struct ast_flags *flags,
ast_mutex_init(&chanspy_ds.lock);
snprintf(chanspy_ds.unique_id, sizeof(chanspy_ds.unique_id), "%d", ast_atomic_fetchadd_int(&next_unique_id_to_use, +1));
if (chan->_state != AST_STATE_UP)
ast_answer(chan);