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

astobj2: Add ao2_weakproxy_find function.

Browse Source 
This function finds a weak proxy in an ao2_container and returns the
real object associated with it.

Change-Id: I9da822049747275f5961b5c0a7f14e87157d65d8
This commit is contained in:
Corey Farrell
2017-10-09 18:51:05 -04:00
parent fd3101e8ad
commit b058f8673a
2 changed files with 53 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
main/astobj2_container.c
View File

@@ -437,6 +437,48 @@ void *__ao2_find(struct ao2_container *c, const void *arg, enum search_flags fla
return __ao2_callback(c, flags, c->cmp_fn, arged, tag, file, line, func);
}
void *__ao2_weakproxy_find(struct ao2_container *c, const void *arg, enum search_flags flags,
const char *tag, const char *file, int line, const char *func)
{
void *proxy;
void *obj = NULL;
enum ao2_lock_req orig_lock;
ast_assert(!!c);
ast_assert(flags & OBJ_SEARCH_MASK);
ast_assert(!(flags & ~(OBJ_SEARCH_MASK | OBJ_NOLOCK)));
if (flags & OBJ_NOLOCK) {
orig_lock = __adjust_lock(c, AO2_LOCK_REQ_RDLOCK, 1);
} else {
orig_lock = AO2_LOCK_REQ_RDLOCK;
ao2_rdlock(c);
}
while ((proxy = ao2_find(c, arg, flags | OBJ_NOLOCK))) {
obj = __ao2_weakproxy_get_object(proxy, 0, tag ?: __PRETTY_FUNCTION__, file, line, func);
if (obj) {
ao2_ref(proxy, -1);
break;
}
/* Upgrade to a write lock */
__adjust_lock(c, AO2_LOCK_REQ_WRLOCK, 1);
ao2_unlink_flags(c, proxy, OBJ_NOLOCK);
ao2_ref(proxy, -1);
}
if (flags & OBJ_NOLOCK) {
/* We'll keep any upgraded lock */
__adjust_lock(c, orig_lock, 1);
} else {
ao2_unlock(c);
}
return obj;
}
/*!
* initialize an iterator so we start from the first object
*/