This is basically a complete rollback of r155401, as it was determined that
authorSean Bright <sean@malleable.com>
Tue, 25 Nov 2008 01:01:49 +0000 (01:01 +0000)
committerSean Bright <sean@malleable.com>
Tue, 25 Nov 2008 01:01:49 +0000 (01:01 +0000)
it would be best to maintain API compatibility.  Instead, this commit introduces
ao2_callback_data() which is functionally identical to ao2_callback() except
that it allows you to pass arbitrary data to the callback.

Reviewed by Mark Michelson via ReviewBoard:
http://reviewboard.digium.com/r/64

git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@158959 65c4cc65-6c06-0410-ace0-fbb531ad65f3

16 files changed:
apps/app_queue.c
channels/chan_console.c
channels/chan_iax2.c
channels/chan_sip.c
funcs/func_dialgroup.c
include/asterisk/astobj2.h
main/astobj2.c
main/config.c
main/features.c
main/manager.c
main/taskprocessor.c
res/res_clialiases.c
res/res_phoneprov.c
res/res_timing_pthread.c
res/res_timing_timerfd.c
utils/hashtest2.c

index 3357dd8..e670df2 100644 (file)
@@ -855,7 +855,7 @@ static int queue_hash_cb(const void *obj, const int flags)
        return ast_str_case_hash(q->name);
 }
 
-static int queue_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int queue_cmp_cb(void *obj, void *arg, int flags)
 {
        struct call_queue *q = obj, *q2 = arg;
        return !strcasecmp(q->name, q2->name) ? CMP_MATCH | CMP_STOP : 0;
@@ -1128,7 +1128,7 @@ static int member_hash_fn(const void *obj, const int flags)
        return ret;
 }
 
-static int member_cmp_fn(void *obj1, void *obj2, void *data, int flags)
+static int member_cmp_fn(void *obj1, void *obj2, int flags)
 {
        struct member *mem1 = obj1, *mem2 = obj2;
        return strcasecmp(mem1->interface, mem2->interface) ? 0 : CMP_MATCH | CMP_STOP;
@@ -1642,7 +1642,7 @@ static struct call_queue *find_queue_by_name_rt(const char *queuename, struct as
        char tmpbuf[64];        /* Must be longer than the longest queue param name. */
 
        /* Static queues override realtime. */
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                ao2_lock(q);
                if (!q->realtime) {
                        if (q->dead) {
@@ -1768,7 +1768,7 @@ static struct call_queue *load_realtime_queue(const char *queuename)
        };
 
        /* Find the queue in the in-core list first. */
-       q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER);
+       q = ao2_find(queues, &tmpq, OBJ_POINTER);
 
        if (!q || q->realtime) {
                /*! \note Load from realtime before taking the "queues" container lock, to avoid blocking all
@@ -2237,7 +2237,7 @@ static int compare_weight(struct call_queue *rq, struct member *member)
                }
                ao2_lock(q);
                if (q->count && q->members) {
-                       if ((mem = ao2_find(q->members, member, NULL, OBJ_POINTER))) {
+                       if ((mem = ao2_find(q->members, member, OBJ_POINTER))) {
                                ast_debug(1, "Found matching member %s in queue '%s'\n", mem->interface, q->name);
                                if (q->weight > rq->weight) {
                                        ast_debug(1, "Queue '%s' (weight %d, calls %d) is preferred over '%s' (weight %d, calls %d)\n", q->name, q->weight, q->count, rq->name, rq->weight, rq->count);
@@ -3126,7 +3126,7 @@ static int update_queue(struct call_queue *q, struct member *member, int callcom
                queue_iter = ao2_iterator_init(queues, 0);
                while ((qtmp = ao2_iterator_next(&queue_iter))) {
                        ao2_lock(qtmp);
-                       if ((mem = ao2_find(qtmp->members, member, NULL, OBJ_POINTER))) {
+                       if ((mem = ao2_find(qtmp->members, member, OBJ_POINTER))) {
                                time(&mem->lastcall);
                                mem->calls++;
                                mem->lastqueue = q;
@@ -4176,10 +4176,10 @@ static int remove_from_queue(const char *queuename, const char *interface)
        int res = RES_NOSUCHQUEUE;
 
        ast_copy_string(tmpmem.interface, interface, sizeof(tmpmem.interface));
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                ao2_lock(queues);
                ao2_lock(q);
-               if ((mem = ao2_find(q->members, &tmpmem, NULL, OBJ_POINTER))) {
+               if ((mem = ao2_find(q->members, &tmpmem, OBJ_POINTER))) {
                        /* XXX future changes should beware of this assumption!! */
                        if (!mem->dynamic) {
                                ao2_ref(mem, -1);
@@ -4404,7 +4404,7 @@ static int get_member_penalty(char *queuename, char *interface)
        };
        struct member *mem;
        
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                foundqueue = 1;
                ao2_lock(q);
                if ((mem = interface_exists(q, interface))) {
@@ -4456,7 +4456,7 @@ static void reload_queue_members(void)
                        struct call_queue tmpq = {
                                .name = queue_name,
                        };
-                       cur_queue = ao2_find(queues, &tmpq, NULL, OBJ_POINTER);
+                       cur_queue = ao2_find(queues, &tmpq, OBJ_POINTER);
                }       
 
                if (!cur_queue)
@@ -5080,7 +5080,7 @@ static int queue_function_var(struct ast_channel *chan, const char *cmd, char *d
                return -1;
        }
 
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                ao2_lock(q);
                if (q->setqueuevar) {
                        sl = 0;
@@ -5221,7 +5221,7 @@ static int queue_function_queuewaitingcount(struct ast_channel *chan, const char
                return -1;
        }
 
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                ao2_lock(q);
                count = q->count;
                ao2_unlock(q);
@@ -5257,7 +5257,7 @@ static int queue_function_queuememberlist(struct ast_channel *chan, const char *
                return -1;
        }
 
-       if ((q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+       if ((q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                int buflen = 0, count = 0;
                struct ao2_iterator mem_iter = ao2_iterator_init(q->members, 0);
 
@@ -5514,7 +5514,7 @@ static int reload_queues(int reload)
                        struct call_queue tmpq = {
                                .name = cat,
                        };
-                       if (!(q = ao2_find(queues, &tmpq, NULL, OBJ_POINTER))) {
+                       if (!(q = ao2_find(queues, &tmpq, OBJ_POINTER))) {
                                /* Make one then */
                                if (!(q = alloc_queue(cat))) {
                                        /* TODO: Handle memory allocation failure */
@@ -5592,7 +5592,7 @@ static int reload_queues(int reload)
 
                                                /* Find the old position in the list */
                                                ast_copy_string(tmpmem.interface, interface, sizeof(tmpmem.interface));
-                                               cur = ao2_find(q->members, &tmpmem, NULL, OBJ_POINTER | OBJ_UNLINK);
+                                               cur = ao2_find(q->members, &tmpmem, OBJ_POINTER | OBJ_UNLINK);
                                                newm = create_queue_member(interface, membername, penalty, cur ? cur->paused : 0, state_interface);
                                                ao2_link(q->members, newm);
                                                ao2_ref(newm, -1);
index b9f5c54..ee26f21 100644 (file)
@@ -251,7 +251,7 @@ static struct console_pvt *find_pvt(const char *name)
                .name = name,
        };
 
-       return ao2_find(pvts, &tmp_pvt, NULL, OBJ_POINTER);
+       return ao2_find(pvts, &tmp_pvt, OBJ_POINTER);
 }
 
 /*!
@@ -1351,7 +1351,7 @@ static void build_device(struct ast_config *cfg, const char *name)
        unref_pvt(pvt);
 }
 
-static int pvt_mark_destroy_cb(void *obj, void *arg, void *data, int flags)
+static int pvt_mark_destroy_cb(void *obj, void *arg, int flags)
 {
        struct console_pvt *pvt = obj;
        pvt->destroy = 1;
@@ -1403,7 +1403,7 @@ static int load_config(int reload)
                return -1;
        }
        
-       ao2_callback(pvts, OBJ_NODATA, pvt_mark_destroy_cb, NULL, NULL);
+       ao2_callback(pvts, OBJ_NODATA, pvt_mark_destroy_cb, NULL);
 
        ast_mutex_lock(&globals_lock);
        for (v = ast_variable_browse(cfg, "general"); v; v = v->next)
@@ -1429,7 +1429,7 @@ static int pvt_hash_cb(const void *obj, const int flags)
        return ast_str_case_hash(pvt->name);
 }
 
-static int pvt_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int pvt_cmp_cb(void *obj, void *arg, int flags)
 {
        struct console_pvt *pvt = obj, *pvt2 = arg;
 
index b618d03..7aff8f8 100644 (file)
@@ -1400,7 +1400,7 @@ static int peer_hash_cb(const void *obj, const int flags)
 /*!
  * \note The only member of the peer passed here guaranteed to be set is the name field
  */
-static int peer_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int peer_cmp_cb(void *obj, void *arg, int flags)
 {
        struct iax2_peer *peer = obj, *peer2 = arg;
 
@@ -1420,7 +1420,7 @@ static int user_hash_cb(const void *obj, const int flags)
 /*!
  * \note The only member of the user passed here guaranteed to be set is the name field
  */
-static int user_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int user_cmp_cb(void *obj, void *arg, int flags)
 {
        struct iax2_user *user = obj, *user2 = arg;
 
@@ -1438,7 +1438,7 @@ static struct iax2_peer *find_peer(const char *name, int realtime)
                .name = name,
        };
 
-       peer = ao2_find(peers, &tmp_peer, NULL, OBJ_POINTER);
+       peer = ao2_find(peers, &tmp_peer, OBJ_POINTER);
 
        /* Now go for realtime if applicable */
        if(!peer && realtime)
@@ -1512,7 +1512,7 @@ static void iax2_destroy_helper(struct chan_iax2_pvt *pvt)
                        .name = pvt->username,
                };
 
-               user = ao2_find(users, &tmp_user, NULL, OBJ_POINTER);
+               user = ao2_find(users, &tmp_user, OBJ_POINTER);
                if (user) {
                        ast_atomic_fetchadd_int(&user->curauthreq, -1);
                        user_unref(user);       
@@ -1793,7 +1793,7 @@ static int __find_callno(unsigned short callno, unsigned short dcallno, struct s
 
                        memcpy(&tmp_pvt.addr, sin, sizeof(tmp_pvt.addr));
 
-                       if ((pvt = ao2_find(iax_peercallno_pvts, &tmp_pvt, NULL, OBJ_POINTER))) {
+                       if ((pvt = ao2_find(iax_peercallno_pvts, &tmp_pvt, OBJ_POINTER))) {
                                if (return_locked) {
                                        ast_mutex_lock(&iaxsl[pvt->callno]);
                                }
@@ -5431,7 +5431,7 @@ static char *handle_cli_iax2_unregister(struct ast_cli_entry *e, int cmd, struct
                        };
                        struct iax2_peer *peer;
 
-                       peer = ao2_find(peers, &tmp_peer, NULL, OBJ_POINTER);
+                       peer = ao2_find(peers, &tmp_peer, OBJ_POINTER);
                        if (peer) {
                                expire_registry(peer_ref(peer)); /* will release its own reference when done */
                                peer_unref(peer); /* ref from ao2_find() */
@@ -6323,7 +6323,7 @@ static int authenticate_request(int call_num)
                        .name = p->username,    
                };
 
-               user = ao2_find(users, &tmp_user, NULL, OBJ_POINTER);
+               user = ao2_find(users, &tmp_user, OBJ_POINTER);
                if (user) {
                        if (user->curauthreq == user->maxauthreq)
                                authreq_restrict = 1;
@@ -6373,7 +6373,7 @@ static int authenticate_verify(struct chan_iax2_pvt *p, struct iax_ies *ies)
                .name = p->username,    
        };
 
-       user = ao2_find(users, &tmp_user, NULL, OBJ_POINTER);
+       user = ao2_find(users, &tmp_user, OBJ_POINTER);
        if (user) {
                if (ast_test_flag(p, IAX_MAXAUTHREQ)) {
                        ast_atomic_fetchadd_int(&user->curauthreq, -1);
@@ -10250,7 +10250,7 @@ static int iax2_poke_noanswer(const void *data)
        return 0;
 }
 
-static int iax2_poke_peer_cb(void *obj, void *arg, void *data, int flags)
+static int iax2_poke_peer_cb(void *obj, void *arg, int flags)
 {
        struct iax2_peer *peer = obj;
 
@@ -10690,7 +10690,7 @@ static struct iax2_peer *build_peer(const char *name, struct ast_variable *v, st
        };
 
        if (!temponly) {
-               peer = ao2_find(peers, &tmp_peer, NULL, OBJ_POINTER);
+               peer = ao2_find(peers, &tmp_peer, OBJ_POINTER);
                if (peer && !ast_test_flag(peer, IAX_DELME))
                        firstpass = 0;
        }
@@ -10944,7 +10944,7 @@ static struct iax2_user *build_user(const char *name, struct ast_variable *v, st
        };
 
        if (!temponly) {
-               user = ao2_find(users, &tmp_user, NULL, OBJ_POINTER);
+               user = ao2_find(users, &tmp_user, OBJ_POINTER);
                if (user && !ast_test_flag(user, IAX_DELME))
                        firstpass = 0;
        }
@@ -11144,7 +11144,7 @@ cleanup:
        return user;
 }
 
-static int peer_delme_cb(void *obj, void *arg, void *data, int flags)
+static int peer_delme_cb(void *obj, void *arg, int flags)
 {
        struct iax2_peer *peer = obj;
 
@@ -11153,7 +11153,7 @@ static int peer_delme_cb(void *obj, void *arg, void *data, int flags)
        return 0;
 }
 
-static int user_delme_cb(void *obj, void *arg, void *data, int flags)
+static int user_delme_cb(void *obj, void *arg, int flags)
 {
        struct iax2_user *user = obj;
 
@@ -11166,7 +11166,7 @@ static void delete_users(void)
 {
        struct iax2_registry *reg;
 
-       ao2_callback(users, 0, user_delme_cb, NULL, NULL);
+       ao2_callback(users, 0, user_delme_cb, NULL);
 
        AST_LIST_LOCK(&registrations);
        while ((reg = AST_LIST_REMOVE_HEAD(&registrations, entry))) {
@@ -11186,7 +11186,7 @@ static void delete_users(void)
        }
        AST_LIST_UNLOCK(&registrations);
 
-       ao2_callback(peers, 0, peer_delme_cb, NULL, NULL);
+       ao2_callback(peers, 0, peer_delme_cb, NULL);
 }
 
 static void prune_users(void)
@@ -12434,7 +12434,7 @@ static int unload_module(void)
        return __unload_module();
 }
 
-static int peer_set_sock_cb(void *obj, void *arg, void *data, int flags)
+static int peer_set_sock_cb(void *obj, void *arg, int flags)
 {
        struct iax2_peer *peer = obj;
 
@@ -12451,7 +12451,7 @@ static int pvt_hash_cb(const void *obj, const int flags)
        return pvt->peercallno;
 }
 
-static int pvt_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int pvt_cmp_cb(void *obj, void *arg, int flags)
 {
        struct chan_iax2_pvt *pvt = obj, *pvt2 = arg;
 
@@ -12565,8 +12565,8 @@ static int load_module(void)
                iax2_do_register(reg);
        AST_LIST_UNLOCK(&registrations);        
        
-       ao2_callback(peers, 0, peer_set_sock_cb, NULL, NULL);
-       ao2_callback(peers, 0, iax2_poke_peer_cb, NULL, NULL);
+       ao2_callback(peers, 0, peer_set_sock_cb, NULL);
+       ao2_callback(peers, 0, iax2_poke_peer_cb, NULL);
 
 
        reload_firmware(0);
index 095a063..6c7bf19 100644 (file)
@@ -1962,7 +1962,7 @@ static int peer_hash_cb(const void *obj, const int flags)
 /*!
  * \note The only member of the peer used here is the name field
  */
-static int peer_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int peer_cmp_cb(void *obj, void *arg, int flags)
 {
        struct sip_peer *peer = obj, *peer2 = arg;
 
@@ -1989,7 +1989,7 @@ static int peer_iphash_cb(const void *obj, const int flags)
 /*!
  * \note the peer's addr struct provides to fields combined to make a key: the sin_addr.s_addr and sin_port fields.
  */
-static int peer_ipcmp_cb(void *obj, void *arg, void *data, int flags)
+static int peer_ipcmp_cb(void *obj, void *arg, int flags)
 {
        struct sip_peer *peer = obj, *peer2 = arg;
 
@@ -2018,7 +2018,7 @@ static int dialog_hash_cb(const void *obj, const int flags)
 /*!
  * \note The only member of the dialog used here callid string
  */
-static int dialog_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int dialog_cmp_cb(void *obj, void *arg, int flags)
 {
        struct sip_pvt *pvt = obj, *pvt2 = arg;
        
@@ -4454,15 +4454,15 @@ static struct sip_peer *find_peer(const char *peer, struct sockaddr_in *sin, int
 
        if (peer) {
                ast_copy_string(tmp_peer.name, peer, sizeof(tmp_peer.name));
-               p = ao2_t_callback(peers, OBJ_POINTER, find_by_name, &tmp_peer, &forcenamematch, "ao2_find in peers table");
+               p = ao2_t_callback_data(peers, OBJ_POINTER, find_by_name, &tmp_peer, &forcenamematch, "ao2_find in peers table");
        } else if (sin) { /* search by addr? */
                tmp_peer.addr.sin_addr.s_addr = sin->sin_addr.s_addr;
                tmp_peer.addr.sin_port = sin->sin_port;
                tmp_peer.flags[0].flags = 0;
-               p = ao2_t_find(peers_by_ip, &tmp_peer, NULL, OBJ_POINTER, "ao2_find in peers_by_ip table"); /* WAS:  p = ASTOBJ_CONTAINER_FIND_FULL(&peerl, sin, name, sip_addr_hashfunc, 1, sip_addrcmp); */
+               p = ao2_t_find(peers_by_ip, &tmp_peer, OBJ_POINTER, "ao2_find in peers_by_ip table"); /* WAS:  p = ASTOBJ_CONTAINER_FIND_FULL(&peerl, sin, name, sip_addr_hashfunc, 1, sip_addrcmp); */
                if (!p) {
                        ast_set_flag(&tmp_peer.flags[0], SIP_INSECURE_PORT);
-                       p = ao2_t_find(peers_by_ip, &tmp_peer, NULL, OBJ_POINTER, "ao2_find in peers_by_ip table 2"); /* WAS:  p = ASTOBJ_CONTAINER_FIND_FULL(&peerl, sin, name, sip_addr_hashfunc, 1, sip_addrcmp); */
+                       p = ao2_t_find(peers_by_ip, &tmp_peer, OBJ_POINTER, "ao2_find in peers_by_ip table 2"); /* WAS:  p = ASTOBJ_CONTAINER_FIND_FULL(&peerl, sin, name, sip_addr_hashfunc, 1, sip_addrcmp); */
                        if (p) {
                                return p;
                        }
@@ -6615,7 +6615,7 @@ struct find_call_cb_arg {
  * code to determine whether this is the pvt that we are looking for.
  * Return FALSE if not found, true otherwise. p is unlocked.
  */
-static int find_call_cb(void *__pvt, void *__arg, void *data, int flags)
+static int find_call_cb(void *__pvt, void *__arg, int flags)
 {
        struct sip_pvt *p = __pvt;
        struct find_call_cb_arg *arg = __arg;
@@ -6713,7 +6713,7 @@ restartsearch:
                struct sip_pvt tmp_dialog = {
                        .callid = callid,
                };                      
-               sip_pvt_ptr = ao2_t_find(dialogs, &tmp_dialog, NULL, OBJ_POINTER, "ao2_find in dialogs");
+               sip_pvt_ptr = ao2_t_find(dialogs, &tmp_dialog, OBJ_POINTER, "ao2_find in dialogs");
                if (sip_pvt_ptr) {  /* well, if we don't find it-- what IS in there? */
                        /* Found the call */
                        sip_pvt_lock(sip_pvt_ptr);
@@ -6721,7 +6721,7 @@ restartsearch:
                }
        } else { /* in pedantic mode! -- do the fancy linear search */
                ao2_lock(dialogs);
-               p = ao2_t_callback(dialogs, 0 /* single, data */, find_call_cb, &arg, NULL, "pedantic linear search for dialog");
+               p = ao2_t_callback(dialogs, 0 /* single, data */, find_call_cb, &arg, "pedantic linear search for dialog");
                if (p) {
                        if (sip_pvt_trylock(p)) {
                                ao2_unlock(dialogs);
@@ -12082,7 +12082,7 @@ static struct sip_pvt *get_sip_pvt_byid_locked(const char *callid, const char *t
 
        /* Search dialogs and find the match */
        
-       sip_pvt_ptr = ao2_t_find(dialogs, &tmp_dialog, NULL, OBJ_POINTER, "ao2_find of dialog in dialogs table");
+       sip_pvt_ptr = ao2_t_find(dialogs, &tmp_dialog, OBJ_POINTER, "ao2_find of dialog in dialogs table");
        if (sip_pvt_ptr) {
                /* Go ahead and lock it (and its owner) before returning */
                sip_pvt_lock(sip_pvt_ptr);
@@ -13425,7 +13425,7 @@ static char *_sip_show_peers(int fd, int *total, struct mansession *s, const str
 #undef FORMAT2
 }
 
-static int peer_dump_func(void *userobj, void *arg, void *data, int flags)
+static int peer_dump_func(void *userobj, void *arg, int flags)
 {
        struct sip_peer *peer = userobj;
        int refc = ao2_t_ref(userobj, 0, "");
@@ -13436,7 +13436,7 @@ static int peer_dump_func(void *userobj, void *arg, void *data, int flags)
        return 0;
 }
 
-static int dialog_dump_func(void *userobj, void *arg, void *data, int flags)
+static int dialog_dump_func(void *userobj, void *arg, int flags)
 {
        struct sip_pvt *pvt = userobj;
        int refc = ao2_t_ref(userobj, 0, "");
@@ -13467,11 +13467,11 @@ static char *sip_show_objects(struct ast_cli_entry *e, int cmd, struct ast_cli_a
        if (a->argc != 3)
                return CLI_SHOWUSAGE;
        ast_cli(a->fd, "-= Peer objects: %d static, %d realtime, %d autocreate =-\n\n", speerobjs, rpeerobjs, apeerobjs);
-       ao2_t_callback(peers, OBJ_NODATA, peer_dump_func, &a->fd, NULL, "initiate ao2_callback to dump peers");
+       ao2_t_callback(peers, OBJ_NODATA, peer_dump_func, &a->fd, "initiate ao2_callback to dump peers");
        ast_cli(a->fd, "-= Registry objects: %d =-\n\n", regobjs);
        ASTOBJ_CONTAINER_DUMP(a->fd, tmp, sizeof(tmp), &regl);
        ast_cli(a->fd, "-= Dialog objects:\n\n");
-       ao2_t_callback(dialogs, OBJ_NODATA, dialog_dump_func, &a->fd, NULL, "initiate ao2_callback to dump dialogs");
+       ao2_t_callback(dialogs, OBJ_NODATA, dialog_dump_func, &a->fd, "initiate ao2_callback to dump dialogs");
        return CLI_SUCCESS;
 }
 /*! \brief Print call group and pickup group */
@@ -13551,7 +13551,7 @@ static void cleanup_stale_contexts(char *new, char *old)
    to be destroyed, toss it into the queue. Have a separate
    thread do the locking and destruction */
 
-static int dialog_needdestroy(void *dialogobj, void *arg, void *data, int flags) 
+static int dialog_needdestroy(void *dialogobj, void *arg, int flags) 
 {
        struct sip_pvt *dialog = dialogobj;
        time_t *t = arg;
@@ -13615,7 +13615,7 @@ static int dialog_needdestroy(void *dialogobj, void *arg, void *data, int flags)
 
 /* this func is used with ao2_callback to unlink/delete all marked
    peers */
-static int peer_is_marked(void *peerobj, void *arg, void *data, int flags)
+static int peer_is_marked(void *peerobj, void *arg, int flags)
 {
        struct sip_peer *peer = peerobj;
        return peer->the_mark ? CMP_MATCH : 0;
@@ -13722,7 +13722,7 @@ static char *sip_prune_realtime(struct ast_cli_entry *e, int cmd, struct ast_cli
                                unref_peer(pi, "toss iterator peer ptr");
                        }
                        if (pruned) {
-                               ao2_t_callback(peers, OBJ_NODATA | OBJ_UNLINK | OBJ_MULTIPLE, peer_is_marked, NULL, NULL,
+                               ao2_t_callback(peers, OBJ_NODATA | OBJ_UNLINK | OBJ_MULTIPLE, peer_is_marked, NULL,
                                                "initiating callback to remove marked peers");
                                ast_cli(a->fd, "%d peers pruned.\n", pruned);
                        } else
@@ -13732,7 +13732,7 @@ static char *sip_prune_realtime(struct ast_cli_entry *e, int cmd, struct ast_cli
                if (prunepeer) {
                        struct sip_peer tmp;
                        ast_copy_string(tmp.name, name, sizeof(tmp.name));
-                       if ((peer = ao2_t_find(peers, &tmp, NULL, OBJ_POINTER | OBJ_UNLINK, "finding to unlink from peers"))) {
+                       if ((peer = ao2_t_find(peers, &tmp, OBJ_POINTER | OBJ_UNLINK, "finding to unlink from peers"))) {
                                if (peer->addr.sin_addr.s_addr) {
                                        ao2_t_unlink(peers_by_ip, peer, "unlinking peer from peers_by_ip also");
                                }
@@ -14296,7 +14296,7 @@ static char *sip_unregister(struct ast_cli_entry *e, int cmd, struct ast_cli_arg
 }
 
 /*! \brief Callback for show_chanstats */
-static int show_chanstats_cb(void *__cur, void *__arg, void *data, int flags)
+static int show_chanstats_cb(void *__cur, void *__arg, int flags)
 {
 #define FORMAT2 "%-15.15s  %-11.11s  %-8.8s %-10.10s  %-10.10s (%-2.2s) %-6.6s %-10.10s  %-10.10s ( %%) %-6.6s\n"
 #define FORMAT  "%-15.15s  %-11.11s  %-8.8s %-10.10u%-1.1s %-10.10u (%-2.2u%%) %-6.6u %-10.10u%-1.1s %-10.10u (%-2.2u%%) %-6.6u\n"
@@ -14375,7 +14375,7 @@ static char *sip_show_channelstats(struct ast_cli_entry *e, int cmd, struct ast_
 
        ast_cli(a->fd, FORMAT2, "Peer", "Call ID", "Duration", "Recv: Pack", "Lost", "%", "Jitter", "Send: Pack", "Lost", "Jitter");
        /* iterate on the container and invoke the callback on each item */
-       ao2_t_callback(dialogs, OBJ_NODATA, show_chanstats_cb, &arg, NULL, "callback to sip show chanstats");
+       ao2_t_callback(dialogs, OBJ_NODATA, show_chanstats_cb, &arg, "callback to sip show chanstats");
        ast_cli(a->fd, "%d active SIP channel%s\n", arg.numchans, (arg.numchans != 1) ? "s" : ""); 
        return CLI_SUCCESS;
 }
@@ -14652,7 +14652,7 @@ static const struct cfsubscription_types *find_subscription_type(enum subscripti
 #define FORMAT  "%-15.15s  %-10.10s  %-15.15s  %-15.15s  %-3.3s %-3.3s  %-15.15s %-10.10s\n"
 
 /*! \brief callback for show channel|subscription */
-static int show_channels_cb(void *__cur, void *__arg, void *data, int flags)
+static int show_channels_cb(void *__cur, void *__arg, int flags)
 {
        struct sip_pvt *cur = __cur;
        struct __show_chan_arg *arg = __arg;
@@ -14724,7 +14724,7 @@ static char *sip_show_channels(struct ast_cli_entry *e, int cmd, struct ast_cli_
                ast_cli(arg.fd, FORMAT3, "Peer", "User", "Call ID", "Extension", "Last state", "Type", "Mailbox", "Expiry");
 
        /* iterate on the container and invoke the callback on each item */
-       ao2_t_callback(dialogs, OBJ_NODATA, show_channels_cb, &arg, NULL, "callback to show channels");
+       ao2_t_callback(dialogs, OBJ_NODATA, show_channels_cb, &arg, "callback to show channels");
        
        /* print summary information */
        ast_cli(arg.fd, "%d active SIP %s%s\n", arg.numchans,
@@ -20653,7 +20653,7 @@ static void *do_monitor(void *data)
                   of time since the last time we did it (when MWI is being sent, we can
                   get back to this point every millisecond or less)
                */
-               ao2_t_callback(dialogs, OBJ_UNLINK | OBJ_NODATA | OBJ_MULTIPLE, dialog_needdestroy, &t, NULL,
+               ao2_t_callback(dialogs, OBJ_UNLINK | OBJ_NODATA | OBJ_MULTIPLE, dialog_needdestroy, &t,
                                "callback to remove dialogs w/needdestroy");
 
                /* the old methodology would be to restart the search for dialogs to delete with every 
@@ -21863,7 +21863,7 @@ static struct sip_peer *build_peer(const char *name, struct ast_variable *v, str
                   during reload
                */
                ast_copy_string(tmp_peer.name, name, sizeof(tmp_peer.name));
-               peer = ao2_t_find(peers, &tmp_peer, NULL, OBJ_POINTER | OBJ_UNLINK, "find and unlink peer from peers table");
+               peer = ao2_t_find(peers, &tmp_peer, OBJ_POINTER | OBJ_UNLINK, "find and unlink peer from peers table");
        }
        
        if (peer) {
@@ -22305,7 +22305,7 @@ static struct sip_peer *build_peer(const char *name, struct ast_variable *v, str
        return peer;
 }
 
-static int peer_markall_func(void *device, void *arg, void *data, int flags)
+static int peer_markall_func(void *device, void *arg, int flags)
 {
        struct sip_peer *peer = device;
        peer->the_mark = 1;
@@ -22410,7 +22410,7 @@ static int reload_config(enum channelreloadreason reason)
                /* Then, actually destroy users and registry */
                ASTOBJ_CONTAINER_DESTROYALL(&regl, sip_registry_destroy);
                ast_debug(4, "--------------- Done destroying registry list\n");
-               ao2_t_callback(peers, OBJ_NODATA, peer_markall_func, NULL, NULL, "callback to mark all peers");
+               ao2_t_callback(peers, OBJ_NODATA, peer_markall_func, NULL, "callback to mark all peers");
        }
        
        /* Reset certificate handling for TLS sessions */
@@ -23709,7 +23709,7 @@ static int sip_do_reload(enum channelreloadreason reason)
 
        start_poke = time(0);
        /* Prune peers who still are supposed to be deleted */
-       ao2_t_callback(peers, OBJ_NODATA | OBJ_UNLINK | OBJ_MULTIPLE, peer_is_marked, NULL, NULL,
+       ao2_t_callback(peers, OBJ_NODATA | OBJ_UNLINK | OBJ_MULTIPLE, peer_is_marked, NULL,
                        "callback to remove marked peers");
        
        ast_debug(4, "--------------- Done destroying pruned peers\n");
index a673e34..4e4f633 100644 (file)
@@ -96,7 +96,7 @@ static int group_hash_fn(const void *obj, const int flags)
        return ast_str_hash(g->name);
 }
 
-static int group_cmp_fn(void *obj1, void *name2, void *data, int flags)
+static int group_cmp_fn(void *obj1, void *name2, int flags)
 {
        struct group *g1 = obj1, *g2 = name2;
        char *name = name2;
@@ -112,7 +112,7 @@ static int entry_hash_fn(const void *obj, const int flags)
        return ast_str_hash(e->name);
 }
 
-static int entry_cmp_fn(void *obj1, void *name2, void *data, int flags)
+static int entry_cmp_fn(void *obj1, void *name2, int flags)
 {
        struct group_entry *e1 = obj1, *e2 = name2;
        char *name = name2;
@@ -125,7 +125,7 @@ static int entry_cmp_fn(void *obj1, void *name2, void *data, int flags)
 static int dialgroup_read(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
 {
        struct ao2_iterator i;
-       struct group *grhead = ao2_find(group_container, data, NULL, 0);
+       struct group *grhead = ao2_find(group_container, data, 0);
        struct group_entry *entry;
        size_t bufused = 0;
        int trunc_warning = 0;
@@ -206,7 +206,7 @@ static int dialgroup_write(struct ast_channel *chan, const char *cmd, char *data
        AST_STANDARD_APP_ARGS(args, data);
        AST_NONSTANDARD_APP_ARGS(inter, value, '&');
 
-       if (!(grhead = ao2_find(group_container, args.group, NULL, 0))) {
+       if (!(grhead = ao2_find(group_container, args.group, 0))) {
                /* Create group */
                grhead = ao2_alloc(sizeof(*grhead), group_destroy);
                if (!grhead)
@@ -245,7 +245,7 @@ static int dialgroup_write(struct ast_channel *chan, const char *cmd, char *data
                }
        } else if (strncasecmp(args.op, "del", 3) == 0) {
                for (j = 0; j < inter.argc; j++) {
-                       if ((entry = ao2_find(grhead->entries, inter.faces[j], NULL, OBJ_UNLINK))) {
+                       if ((entry = ao2_find(grhead->entries, inter.faces[j], OBJ_UNLINK))) {
                                ao2_ref(entry, -1);
                        } else {
                                ast_log(LOG_WARNING, "Interface '%s' not found in dialgroup '%s'\n", inter.faces[j], grhead->name);
index 9cbaf78..a8254c6 100644 (file)
@@ -597,9 +597,21 @@ to define callback and hash functions and their arguments.
  * \param flags flags from ao2_callback()
  *
  * The return values are a combination of enum _cb_results.
- * Callback functions are used to search or manipulate objects in a container,
+ * Callback functions are used to search or manipulate objects in a container.
  */
-typedef int (ao2_callback_fn)(void *obj, void *arg, void *data, int flags);
+typedef int (ao2_callback_fn)(void *obj, void *arg, int flags);
+
+/*! \brief
+ * Type of a generic callback function
+ * \param obj pointer to the (user-defined part) of an object.
+ * \param arg callback argument from ao2_callback()
+ * \param data arbitrary data from ao2_callback()
+ * \param flags flags from ao2_callback()
+ *
+ * The return values are a combination of enum _cb_results.
+ * Callback functions are used to search or manipulate objects in a container.
+ */
+typedef int (ao2_callback_data_fn)(void *obj, void *arg, void *data, int flags);
 
 /*! \brief a very common callback is one that matches by address. */
 ao2_callback_fn ao2_match_by_addr;
@@ -832,31 +844,60 @@ struct ao2_list {
  * be used to free the additional reference possibly created by this function.
  */
 #ifdef REF_DEBUG
-#define ao2_t_callback(arg1,arg2,arg3,arg4,arg5,arg6) _ao2_callback_debug((arg1), (arg2), (arg3), (arg4), (arg5), (arg6), __FILE__, __LINE__, __PRETTY_FUNCTION__)
-#define ao2_callback(arg1,arg2,arg3,arg4,arg5)        _ao2_callback_debug((arg1), (arg2), (arg3), (arg4), (arg5), "", __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#define ao2_t_callback(arg1,arg2,arg3,arg4,arg5) _ao2_callback_debug((arg1), (arg2), (arg3), (arg4), (arg5), __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#define ao2_callback(arg1,arg2,arg3,arg4)        _ao2_callback_debug((arg1), (arg2), (arg3), (arg4), "", __FILE__, __LINE__, __PRETTY_FUNCTION__)
 #else
-#define ao2_t_callback(arg1,arg2,arg3,arg4,arg5,arg6) _ao2_callback((arg1), (arg2), (arg3), (arg4), (arg5))
-#define ao2_callback(arg1,arg2,arg3,arg4,arg5)        _ao2_callback((arg1), (arg2), (arg3), (arg4), (arg5))
+#define ao2_t_callback(arg1,arg2,arg3,arg4,arg5) _ao2_callback((arg1), (arg2), (arg3), (arg4))
+#define ao2_callback(arg1,arg2,arg3,arg4)        _ao2_callback((arg1), (arg2), (arg3), (arg4))
 #endif
 void *_ao2_callback_debug(struct ao2_container *c, enum search_flags flags,
-                                                 ao2_callback_fn *cb_fn, void *arg, void *data, char *tag, 
+                                                 ao2_callback_fn *cb_fn, void *arg, char *tag, 
                                                  char *file, int line, const char *funcname);
 void *_ao2_callback(struct ao2_container *c,
                                        enum search_flags flags,
-                                       ao2_callback_fn *cb_fn, void *arg, void *data);
+                                       ao2_callback_fn *cb_fn, void *arg);
+
+/*! \brief
+ * ao2_callback_data() is a generic function that applies cb_fn() to all objects
+ * in a container.  It is functionally identical to ao2_callback() except that
+ * instead of taking an ao2_callback_fn *, it takes an ao2_callback_data_fn *, and
+ * allows the caller to pass in arbitrary data.
+ *
+ * This call would be used instead of ao2_callback() when the caller needs to pass
+ * OBJ_POINTER as part of the flags argument (which in turn requires passing in a
+ * prototype ao2 object for 'arg') and also needs access to other non-global data
+ * to complete it's comparison or task.
+ *
+ * See the documentation for ao2_callback() for argument descriptions.
+ *
+ * \see ao2_callback()
+ */
+#ifdef REF_DEBUG
+#define ao2_t_callback_data(arg1,arg2,arg3,arg4,arg5,arg6) _ao2_callback_data_debug((arg1), (arg2), (arg3), (arg4), (arg5), (arg6), __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#define ao2_callback_data(arg1,arg2,arg3,arg4,arg5)        _ao2_callback_data_debug((arg1), (arg2), (arg3), (arg4), (arg5), "", __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#else
+#define ao2_t_callback_data(arg1,arg2,arg3,arg4,arg5,arg6) _ao2_callback_data((arg1), (arg2), (arg3), (arg4), (arg5))
+#define ao2_callback_data(arg1,arg2,arg3,arg4,arg5)        _ao2_callback_data((arg1), (arg2), (arg3), (arg4), (arg5))
+#endif
+void *_ao2_callback_data_debug(struct ao2_container *c, enum search_flags flags,
+                                                 ao2_callback_data_fn *cb_fn, void *arg, void *data, char *tag, 
+                                                 char *file, int line, const char *funcname);
+void *_ao2_callback_data(struct ao2_container *c,
+                                       enum search_flags flags,
+                                       ao2_callback_data_fn *cb_fn, void *arg, void *data);
 
 /*! ao2_find() is a short hand for ao2_callback(c, flags, c->cmp_fn, arg)
  * XXX possibly change order of arguments ?
  */
 #ifdef REF_DEBUG
-#define ao2_t_find(arg1,arg2,arg3,arg4,arg5) _ao2_find_debug((arg1), (arg2), (arg3), (arg4), (arg5), __FILE__, __LINE__, __PRETTY_FUNCTION__)
-#define ao2_find(arg1,arg2,arg3,arg4)        _ao2_find_debug((arg1), (arg2), (arg3), (arg4), "", __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#define ao2_t_find(arg1,arg2,arg3,arg4) _ao2_find_debug((arg1), (arg2), (arg3), (arg4), __FILE__, __LINE__, __PRETTY_FUNCTION__)
+#define ao2_find(arg1,arg2,arg3)        _ao2_find_debug((arg1), (arg2), (arg3), "", __FILE__, __LINE__, __PRETTY_FUNCTION__)
 #else
-#define ao2_t_find(arg1,arg2,arg3,arg4,arg5) _ao2_find((arg1), (arg2), (arg3), (arg4))
-#define ao2_find(arg1,arg2,arg3,arg4)        _ao2_find((arg1), (arg2), (arg3), (arg4))
+#define ao2_t_find(arg1,arg2,arg3,arg4) _ao2_find((arg1), (arg2), (arg3))
+#define ao2_find(arg1,arg2,arg3)        _ao2_find((arg1), (arg2), (arg3))
 #endif
-void *_ao2_find_debug(struct ao2_container *c, void *arg, void *data, enum search_flags flags, char *tag, char *file, int line, const char *funcname);
-void *_ao2_find(struct ao2_container *c, void *arg, void *data, enum search_flags flags);
+void *_ao2_find_debug(struct ao2_container *c, void *arg, enum search_flags flags, char *tag, char *file, int line, const char *funcname);
+void *_ao2_find(struct ao2_container *c, void *arg, enum search_flags flags);
 
 /*! \brief
  *
index df2f089..02f643c 100644 (file)
@@ -120,6 +120,11 @@ static inline struct astobj2 *INTERNAL_OBJ(void *user_data)
        return p;
 }
 
+enum ao2_callback_type {
+       DEFAULT,
+       WITH_DATA,
+};
+
 /*!
  * \brief convert from a pointer _p to an astobj2 object
  *
@@ -135,7 +140,7 @@ static struct ao2_container *__ao2_container_alloc(struct ao2_container *c, cons
                                                                                        ao2_callback_fn *cmp_fn);
 static struct bucket_list *__ao2_link(struct ao2_container *c, void *user_data);
 static void *__ao2_callback(struct ao2_container *c,
-       const enum search_flags flags, ao2_callback_fn *cb_fn, void *arg, void *data,
+       const enum search_flags flags, void *cb_fn, void *arg, void *data, enum ao2_callback_type type,
                                         char *tag, char *file, int line, const char *funcname);
 static void * __ao2_iterator_next(struct ao2_iterator *a, struct bucket_list **q);
 
@@ -527,7 +532,7 @@ void *_ao2_link(struct ao2_container *c, void *user_data)
 /*!
  * \brief another convenience function is a callback that matches on address
  */
-int ao2_match_by_addr(void *user_data, void *arg, void *data, int flags)
+int ao2_match_by_addr(void *user_data, void *arg, int flags)
 {
        return (user_data == arg) ? (CMP_MATCH | CMP_STOP) : 0;
 }
@@ -542,7 +547,7 @@ void *_ao2_unlink_debug(struct ao2_container *c, void *user_data, char *tag,
        if (INTERNAL_OBJ(user_data) == NULL)    /* safety check on the argument */
                return NULL;
 
-       _ao2_callback_debug(c, OBJ_UNLINK | OBJ_POINTER | OBJ_NODATA, ao2_match_by_addr, user_data, NULL, tag, file, line, funcname);
+       _ao2_callback_debug(c, OBJ_UNLINK | OBJ_POINTER | OBJ_NODATA, ao2_match_by_addr, user_data, tag, file, line, funcname);
 
        return NULL;
 }
@@ -552,7 +557,7 @@ void *_ao2_unlink(struct ao2_container *c, void *user_data)
        if (INTERNAL_OBJ(user_data) == NULL)    /* safety check on the argument */
                return NULL;
 
-       _ao2_callback(c, OBJ_UNLINK | OBJ_POINTER | OBJ_NODATA, ao2_match_by_addr, user_data, NULL);
+       _ao2_callback(c, OBJ_UNLINK | OBJ_POINTER | OBJ_NODATA, ao2_match_by_addr, user_data);
 
        return NULL;
 }
@@ -560,9 +565,18 @@ void *_ao2_unlink(struct ao2_container *c, void *user_data)
 /*! 
  * \brief special callback that matches all 
  */ 
-static int cb_true(void *user_data, void *arg, void *data, int flags)
+static int cb_true(void *user_data, void *arg, int flags)
+{
+       ast_log(LOG_ERROR, "Using default callback (cb_true).  If you see this, something is strange!\n");
+       return CMP_MATCH;
+}
+
+/*!
+ * \brief similar to cb_true, but is an ao2_callback_data_fn instead
+ */
+static int cb_true_data(void *user_data, void *arg, void *data, int flags)
 {
-       ast_log(LOG_ERROR,"If you see this, something is strange!\n");
+       ast_log(LOG_ERROR, "Using default callback (cb_true_data).  If you see this, something is strange!\n");
        return CMP_MATCH;
 }
 
@@ -575,11 +589,13 @@ static int cb_true(void *user_data, void *arg, void *data, int flags)
  * called as often as, say, the ao2_ref func is called.
  */
 static void *__ao2_callback(struct ao2_container *c,
-       const enum search_flags flags, ao2_callback_fn *cb_fn, void *arg, void *data,
+       const enum search_flags flags, void *cb_fn, void *arg, void *data, enum ao2_callback_type type,
        char *tag, char *file, int line, const char *funcname)
 {
        int i, last;    /* search boundaries */
        void *ret = NULL;
+       ao2_callback_fn *cb_default = NULL;
+       ao2_callback_data_fn *cb_withdata = NULL;
 
        if (INTERNAL_OBJ(c) == NULL)    /* safety check on the argument */
                return NULL;
@@ -590,8 +606,22 @@ static void *__ao2_callback(struct ao2_container *c,
        }
 
        /* override the match function if necessary */
-       if (cb_fn == NULL)      /* if NULL, match everything */
-               cb_fn = cb_true;
+       if (cb_fn == NULL) { /* if NULL, match everything */
+               if (type == WITH_DATA) {
+                       cb_withdata = cb_true_data;
+               } else {
+                       cb_default = cb_true;
+               }
+       } else {
+               /* We do this here to avoid the per object casting penalty (even though
+                  that is probably optimized away anyway. */
+               if (type == WITH_DATA) {
+                       cb_withdata = cb_fn;
+               } else {
+                       cb_default = cb_fn;
+               }
+       }
+
        /*
         * XXX this can be optimized.
         * If we have a hash function and lookup by pointer,
@@ -618,7 +648,13 @@ static void *__ao2_callback(struct ao2_container *c,
                struct bucket_list *cur;
 
                AST_LIST_TRAVERSE_SAFE_BEGIN(&c->buckets[i], cur, entry) {
-                       int match = cb_fn(EXTERNAL_OBJ(cur->astobj), arg, data, flags) & (CMP_MATCH | CMP_STOP);
+                       int match = (CMP_MATCH | CMP_STOP);
+
+                       if (type == WITH_DATA) {
+                               match &= cb_withdata(EXTERNAL_OBJ(cur->astobj), arg, data, flags);
+                       } else {
+                               match &= cb_default(EXTERNAL_OBJ(cur->astobj), arg, flags);
+                       }
 
                        /* we found the object, performing operations according flags */
                        if (match == 0) {       /* no match, no stop, continue */
@@ -674,29 +710,43 @@ static void *__ao2_callback(struct ao2_container *c,
 
 void *_ao2_callback_debug(struct ao2_container *c,
                                                 const enum search_flags flags,
-                                                ao2_callback_fn *cb_fn, void *arg, void *data,
+                                                ao2_callback_fn *cb_fn, void *arg,
+                                                char *tag, char *file, int line, const char *funcname)
+{
+       return __ao2_callback(c,flags, cb_fn, arg, NULL, DEFAULT, tag, file, line, funcname);
+}
+
+void *_ao2_callback(struct ao2_container *c, const enum search_flags flags,
+                    ao2_callback_fn *cb_fn, void *arg)
+{
+       return __ao2_callback(c,flags, cb_fn, arg, NULL, DEFAULT, NULL, NULL, 0, NULL);
+}
+
+void *_ao2_callback_data_debug(struct ao2_container *c,
+                                                const enum search_flags flags,
+                                                ao2_callback_data_fn *cb_fn, void *arg, void *data,
                                                 char *tag, char *file, int line, const char *funcname)
 {
-       return __ao2_callback(c,flags, cb_fn, arg, data, tag, file, line, funcname);
+       return __ao2_callback(c, flags, cb_fn, arg, data, WITH_DATA, tag, file, line, funcname);
 }
 
-void *_ao2_callback(struct ao2_container *c,const enum search_flags flags,
-                    ao2_callback_fn *cb_fn, void *arg, void *data)
+void *_ao2_callback_data(struct ao2_container *c, const enum search_flags flags,
+                                       ao2_callback_data_fn *cb_fn, void *arg, void *data)
 {
-       return __ao2_callback(c,flags, cb_fn, arg, data, NULL, NULL, 0, NULL);
+       return __ao2_callback(c, flags, cb_fn, arg, data, WITH_DATA, NULL, NULL, 0, NULL);
 }
 
 /*!
  * the find function just invokes the default callback with some reasonable flags.
  */
-void *_ao2_find_debug(struct ao2_container *c, void *arg, void *data, enum search_flags flags, char *tag, char *file, int line, const char *funcname)
+void *_ao2_find_debug(struct ao2_container *c, void *arg, enum search_flags flags, char *tag, char *file, int line, const char *funcname)
 {
-       return _ao2_callback_debug(c, flags, c->cmp_fn, arg, data, tag, file, line, funcname);
+       return _ao2_callback_debug(c, flags, c->cmp_fn, arg, tag, file, line, funcname);
 }
 
-void *_ao2_find(struct ao2_container *c, void *arg, void *data, enum search_flags flags)
+void *_ao2_find(struct ao2_container *c, void *arg, enum search_flags flags)
 {
-       return _ao2_callback(c, flags, c->cmp_fn, arg, data);
+       return _ao2_callback(c, flags, c->cmp_fn, arg);
 }
 
 /*!
@@ -809,13 +859,13 @@ void * _ao2_iterator_next(struct ao2_iterator *a)
 /* callback for destroying container.
  * we can make it simple as we know what it does
  */
-static int cd_cb(void *obj, void *arg, void *data, int flag)
+static int cd_cb(void *obj, void *arg, int flag)
 {
        _ao2_ref(obj, -1);
        return 0;
 }
        
-static int cd_cb_debug(void *obj, void *arg, void *data, int flag)
+static int cd_cb_debug(void *obj, void *arg, int flag)
 {
        _ao2_ref_debug(obj, -1, "deref object via container destroy",  __FILE__, __LINE__, __PRETTY_FUNCTION__);
        return 0;
@@ -826,7 +876,7 @@ static void container_destruct(void *_c)
        struct ao2_container *c = _c;
        int i;
 
-       _ao2_callback(c, OBJ_UNLINK, cd_cb, NULL, NULL);
+       _ao2_callback(c, OBJ_UNLINK, cd_cb, NULL);
 
        for (i = 0; i < c->n_buckets; i++) {
                struct bucket_list *current;
@@ -846,7 +896,7 @@ static void container_destruct_debug(void *_c)
        struct ao2_container *c = _c;
        int i;
 
-       _ao2_callback_debug(c, OBJ_UNLINK, cd_cb_debug, NULL, NULL, "container_destruct_debug called", __FILE__, __LINE__, __PRETTY_FUNCTION__);
+       _ao2_callback_debug(c, OBJ_UNLINK, cd_cb_debug, NULL, "container_destruct_debug called", __FILE__, __LINE__, __PRETTY_FUNCTION__);
 
        for (i = 0; i < c->n_buckets; i++) {
                struct bucket_list *current;
@@ -862,7 +912,7 @@ static void container_destruct_debug(void *_c)
 }
 
 #ifdef AO2_DEBUG
-static int print_cb(void *obj, void *arg, void *data, int flag)
+static int print_cb(void *obj, void *arg, int flag)
 {
        int *fd = arg;
        char *s = (char *)obj;
@@ -954,7 +1004,7 @@ static char *handle_astobj2_test(struct ast_cli_entry *e, int cmd, struct ast_cl
                ao2_t_ref(obj, -1, "test");
        }
        ast_cli(a->fd, "testing callbacks\n");
-       ao2_t_callback(c1, 0, print_cb, &a->fd, NULL, "test callback");
+       ao2_t_callback(c1, 0, print_cb, &a->fd, "test callback");
        ast_cli(a->fd, "testing iterators, remove every second object\n");
        {
                struct ao2_iterator ai;
@@ -975,7 +1025,7 @@ static char *handle_astobj2_test(struct ast_cli_entry *e, int cmd, struct ast_cl
                }
        }
        ast_cli(a->fd, "testing callbacks again\n");
-       ao2_t_callback(c1, 0, print_cb, &a->fd, NULL, "test callback");
+       ao2_t_callback(c1, 0, print_cb, &a->fd, "test callback");
 
        ast_verbose("now you should see an error message:\n");
        ao2_t_ref(&i, -1, "");  /* i is not a valid object so we print an error here */
index 2169580..4cef91a 100644 (file)
@@ -149,7 +149,7 @@ static int hash_string(const void *obj, const int flags)
        return total;
 }
 
-static int hashtab_compare_strings(void *a, void *b, void *data, int flags)
+static int hashtab_compare_strings(void *a, void *b, int flags)
 {
        const struct inclfile *ae = a, *be = b;
        return !strcmp(ae->fname, be->fname) ? CMP_MATCH | CMP_STOP : 0;
@@ -1517,7 +1517,7 @@ static void set_fn(char *fn, int fn_size, const char *file, const char *configfi
        else
                snprintf(fn, fn_size, "%s/%s", ast_config_AST_CONFIG_DIR, file);
        lookup.fname = fn;
-       *fi = ao2_find(fileset, &lookup, NULL, OBJ_POINTER);
+       *fi = ao2_find(fileset, &lookup, OBJ_POINTER);
        if (!(*fi)) {
                /* set up a file scratch pad */
                struct inclfile *fx = ao2_alloc(sizeof(struct inclfile), inclfile_destroy);
index 7fd76a6..561b2a5 100644 (file)
@@ -296,7 +296,7 @@ static int parkinglot_hash_cb(const void *obj, const int flags)
        return ast_str_case_hash(parkinglot->name);
 }
 
-static int parkinglot_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int parkinglot_cmp_cb(void *obj, void *arg, int flags)
 {
        struct ast_parkinglot *parkinglot = obj, *parkinglot2 = arg;
 
@@ -2855,7 +2855,7 @@ struct ast_parkinglot *find_parkinglot(const char *name)
 
        ast_copy_string(tmp_parkinglot.name, name, sizeof(tmp_parkinglot.name));
 
-       parkinglot = ao2_find(parkinglots, &tmp_parkinglot, NULL, OBJ_POINTER);
+       parkinglot = ao2_find(parkinglots, &tmp_parkinglot, OBJ_POINTER);
 
        if (parkinglot && option_debug)
                ast_log(LOG_DEBUG, "Found Parkinglot: %s\n", parkinglot->name);
index 4af2b79..d2a76bd 100644 (file)
@@ -3568,7 +3568,7 @@ static int variable_count_hash_fn(const void *vvc, const int flags)
        return res;
 }
 
-static int variable_count_cmp_fn(void *obj, void *vstr, void *data, int flags)
+static int variable_count_cmp_fn(void *obj, void *vstr, int flags)
 {
        /* Due to the simplicity of struct variable_count, it makes no difference
         * if you pass in objects or strings, the same operation applies. This is
@@ -3677,7 +3677,7 @@ static void xml_translate(struct ast_str **out, char *in, struct ast_variable *v
 
                if (!in_data) { /* build appropriate line start */
                        ast_str_append(out, 0, xml ? " " : "<tr><td>");
-                       if ((vc = ao2_find(vco, var, NULL, 0)))
+                       if ((vc = ao2_find(vco, var, 0)))
                                vc->count++;
                        else {
                                /* Create a new entry for this one */
index 6fad190..9548304 100644 (file)
@@ -93,7 +93,7 @@ AST_MUTEX_DEFINE_STATIC(cli_ping_cond_lock);
 /*! \brief The astobj2 hash callback for taskprocessors */
 static int tps_hash_cb(const void *obj, const int flags);
 /*! \brief The astobj2 compare callback for taskprocessors */
-static int tps_cmp_cb(void *obj, void *arg, void *data, int flags);
+static int tps_cmp_cb(void *obj, void *arg, int flags);
 
 /*! \brief The task processing function executed by a taskprocessor */
 static void *tps_processing_function(void *data);
@@ -335,7 +335,7 @@ static int tps_hash_cb(const void *obj, const int flags)
 }
 
 /* compare callback for astobj2 */
-static int tps_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int tps_cmp_cb(void *obj, void *arg, int flags)
 {
        struct ast_taskprocessor *lhs = obj, *rhs = arg;
 
@@ -415,7 +415,7 @@ struct ast_taskprocessor *ast_taskprocessor_get(char *name, enum ast_tps_options
                return NULL;
        }
        ao2_lock(tps_singletons);
-       p = ao2_find(tps_singletons, &tmp_tps, NULL, OBJ_POINTER);
+       p = ao2_find(tps_singletons, &tmp_tps, OBJ_POINTER);
        if (p) {
                ao2_unlock(tps_singletons);
                return p;
index 2d9a396..bb0a083 100644 (file)
@@ -59,7 +59,7 @@ static int alias_hash_cb(const void *obj, const int flags)
 }
 
 /*! \brief Comparison function used for aliases */
-static int alias_cmp_cb(void *obj, void *arg, void *data, int flags)
+static int alias_cmp_cb(void *obj, void *arg, int flags)
 {
        const struct cli_alias *alias0 = obj, *alias1 = arg;
 
@@ -88,7 +88,7 @@ static char *cli_alias_passthrough(struct ast_cli_entry *e, int cmd, struct ast_
        const char *line;
 
        /* Try to find the alias based on the CLI entry */
-       if (!(alias = ao2_find(cli_aliases, &tmp, NULL, OBJ_POINTER))) {
+       if (!(alias = ao2_find(cli_aliases, &tmp, OBJ_POINTER))) {
                return 0;
        }
 
@@ -168,7 +168,7 @@ static struct ast_cli_entry cli_alias[] = {
 };
 
 /*! \brief Function called to mark an alias for destruction */
-static int alias_mark(void *obj, void *arg, void *data, int flags)
+static int alias_mark(void *obj, void *arg, int flags)
 {
        struct cli_alias *alias = obj;
        alias->marked = 1;
@@ -176,7 +176,7 @@ static int alias_mark(void *obj, void *arg, void *data, int flags)
 }
 
 /*! \brief Function called to see if an alias is marked for destruction */
-static int alias_marked(void *obj, void *arg, void *data, int flags)
+static int alias_marked(void *obj, void *arg, int flags)
 {
        struct cli_alias *alias = obj;
        return alias->marked ? CMP_MATCH : 0;
@@ -199,7 +199,7 @@ static void load_config(int reload)
 
        /* Mark CLI aliases for pruning */
        if (reload) {
-               ao2_callback(cli_aliases, OBJ_NODATA, alias_mark, NULL, NULL);
+               ao2_callback(cli_aliases, OBJ_NODATA, alias_mark, NULL);
        }
 
        for (v = ast_variable_browse(cfg, "general"); v; v = v->next) {
@@ -229,7 +229,7 @@ static void load_config(int reload)
 
        /* Drop any CLI aliases that should no longer exist */
        if (reload) {
-               ao2_callback(cli_aliases, OBJ_UNLINK | OBJ_NODATA | OBJ_MULTIPLE , alias_marked, NULL, NULL);
+               ao2_callback(cli_aliases, OBJ_UNLINK | OBJ_NODATA | OBJ_MULTIPLE , alias_marked, NULL);
        }
 
        ast_config_destroy(cfg);
index 904731e..031a033 100644 (file)
@@ -237,7 +237,7 @@ static struct phone_profile *find_profile(const char *name)
                .name = name,
        };
 
-       return ao2_find(profiles, &tmp, NULL, OBJ_POINTER);
+       return ao2_find(profiles, &tmp, OBJ_POINTER);
 }
 
 static int profile_hash_fn(const void *obj, const int flags)
@@ -247,7 +247,7 @@ static int profile_hash_fn(const void *obj, const int flags)
        return ast_str_case_hash(profile->name);
 }
 
-static int profile_cmp_fn(void *obj, void *arg, void *data, int flags)
+static int profile_cmp_fn(void *obj, void *arg, int flags)
 {
        const struct phone_profile *profile1 = obj, *profile2 = arg;
 
@@ -293,7 +293,7 @@ static int routes_hash_fn(const void *obj, const int flags)
        return ast_str_case_hash(route->uri);
 }
 
-static int routes_cmp_fn(void *obj, void *arg, void *data, int flags)
+static int routes_cmp_fn(void *obj, void *arg, int flags)
 {
        const struct http_route *route1 = obj, *route2 = arg;
 
@@ -413,7 +413,7 @@ static struct ast_str *phoneprov_callback(struct ast_tcptls_session_instance *se
        struct timeval now = ast_tvnow();
        struct ast_tm tm;
 
-       if (!(route = ao2_find(http_routes, &search_route, NULL, OBJ_POINTER))) {
+       if (!(route = ao2_find(http_routes, &search_route, OBJ_POINTER))) {
                goto out404;
        }
 
@@ -778,7 +778,7 @@ static struct user *find_user(const char *macaddress)
                .macaddress = macaddress,
        };
 
-       return ao2_find(users, &tmp, NULL, OBJ_POINTER);
+       return ao2_find(users, &tmp, OBJ_POINTER);
 }
 
 static int users_hash_fn(const void *obj, const int flags)
@@ -788,7 +788,7 @@ static int users_hash_fn(const void *obj, const int flags)
        return ast_str_case_hash(user->macaddress);
 }
 
-static int users_cmp_fn(void *obj, void *arg, void *data, int flags)
+static int users_cmp_fn(void *obj, void *arg, int flags)
 {
        const struct user *user1 = obj, *user2 = arg;
 
index b9d295e..20999ca 100644 (file)
@@ -273,7 +273,7 @@ static struct pthread_timer *find_timer(int handle, int unlinkobj)
                flags |= OBJ_UNLINK;
        }
 
-       if (!(timer = ao2_find(pthread_timers, &tmp_timer, NULL, flags))) {
+       if (!(timer = ao2_find(pthread_timers, &tmp_timer, flags))) {
                ast_assert(timer != NULL);
                return NULL;
        }
@@ -309,7 +309,7 @@ static int pthread_timer_hash(const void *obj, const int flags)
 /*!
  * \note only PIPE_READ is guaranteed valid 
  */
-static int pthread_timer_cmp(void *obj, void *arg, void *data, int flags)
+static int pthread_timer_cmp(void *obj, void *arg, int flags)
 {
        struct pthread_timer *timer1 = obj, *timer2 = arg;
 
@@ -401,7 +401,7 @@ static void write_byte(int wr_fd)
        } while (0);
 }
 
-static int run_timer(void *obj, void *arg, void *data, int flags)
+static int run_timer(void *obj, void *arg, int flags)
 {
        struct pthread_timer *timer = obj;
 
@@ -427,7 +427,7 @@ static void *do_timing(void *arg)
        while (!timing_thread.stop) {
                struct timespec ts = { 0, };
 
-               ao2_callback(pthread_timers, OBJ_NODATA, run_timer, NULL, NULL);
+               ao2_callback(pthread_timers, OBJ_NODATA, run_timer, NULL);
 
                next_wakeup = ast_tvadd(next_wakeup, ast_tv(0, 5000));
 
index d79b63d..d0ad175 100644 (file)
@@ -80,7 +80,7 @@ static int timerfd_timer_hash(const void *obj, const int flags)
        return timer->handle;
 }
 
-static int timerfd_timer_cmp(void *obj, void *args, void *data, int flags)
+static int timerfd_timer_cmp(void *obj, void *args, int flags)
 {
        struct timerfd_timer *timer1 = obj, *timer2 = args;
        return timer1->handle == timer2->handle ? CMP_MATCH | CMP_STOP : 0;
@@ -120,7 +120,7 @@ static void timerfd_timer_close(int handle)
                .handle = handle,
        };
 
-       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, NULL, OBJ_POINTER))) {
+       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, OBJ_POINTER))) {
                ast_log(LOG_ERROR, "Couldn't find timer with handle %d\n", handle);
                return;
        }
@@ -172,7 +172,7 @@ static int timerfd_timer_enable_continuous(int handle)
                .handle = handle,
        };
 
-       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, NULL, OBJ_POINTER))) {
+       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, OBJ_POINTER))) {
                ast_log(LOG_ERROR, "Couldn't find timer with handle %d\n", handle);
                return -1;
        }
@@ -198,7 +198,7 @@ static int timerfd_timer_disable_continuous(int handle)
                .handle = handle,
        };
 
-       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, NULL, OBJ_POINTER))) {
+       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, OBJ_POINTER))) {
                ast_log(LOG_ERROR, "Couldn't find timer with handle %d\n", handle);
                return -1;
        }
@@ -225,7 +225,7 @@ static enum ast_timing_event timerfd_timer_get_event(int handle)
                .handle = handle,
        };
 
-       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, NULL, OBJ_POINTER))) {
+       if (!(our_timer = ao2_find(timerfd_timers, &find_helper, OBJ_POINTER))) {
                ast_log(LOG_ERROR, "Couldn't find timer with handle %d\n", handle);
                return -1;
        }
index 4158299..3b0c626 100644 (file)
@@ -80,7 +80,7 @@ static int hash_string(const void *obj, const int flags)
        return total;
 }
 
-static int hashtab_compare_strings(void *a, void *b, void *data, int flags)
+static int hashtab_compare_strings(void *a, void *b, int flags)
 {
        const struct ht_element *ae = a, *be = b;
        return !strcmp(ae->key, be->key) ? CMP_MATCH | CMP_STOP : 0;
@@ -137,7 +137,7 @@ static void add_element(void)
        els_added++; /* unprotected, sometimes off, but, not really important, either */
 }
 
-static int do_nothing_cb(void *obj, void *arg, void *data, int flags)
+static int do_nothing_cb(void *obj, void *arg, int flags)
 {
        return 0;
 }
@@ -147,7 +147,7 @@ static void traverse_elements(void)
 #ifdef DEBUG
        printf("Traverse hashtab\n");
 #endif
-       ao2_callback(glob_hashtab, OBJ_NODATA, do_nothing_cb, NULL, NULL);
+       ao2_callback(glob_hashtab, OBJ_NODATA, do_nothing_cb, NULL);
        els_traversals++; /* unprotected, sometimes off, but, not really important, either */
 }
 
@@ -164,7 +164,7 @@ static void * del_element(unsigned int *seedp)
        printf("- %s", keybuf);
 #endif
        lookup.key = keybuf;
-       el = ao2_find(glob_hashtab, &lookup, NULL, OBJ_POINTER);
+       el = ao2_find(glob_hashtab, &lookup, OBJ_POINTER);
        if (el) {
 #ifdef DEBUG
                printf("...YES (el=%x)\n", (unsigned long)el);
@@ -190,7 +190,7 @@ static int lookup_element(unsigned int *seedp)
        x = my_rand(0,glob_highwater-1,seedp);
        sprintf(keybuf, "key%08d", x);
        lookup.key = keybuf;
-       el = ao2_find(glob_hashtab, &lookup, NULL, OBJ_POINTER);
+       el = ao2_find(glob_hashtab, &lookup, OBJ_POINTER);
        els_lookedup++;
        if (el) {
                els_found++;