event.c File Reference

#include <rz_util.h>
#include <rz_vector.h>

Go to the source code of this file.

Classes
struct	rz_event_callback_hook_t

Typedefs
typedef struct rz_event_callback_hook_t	RzEventCallbackHook

Functions
static void	ht_callback_free (HtUPKv *kv)
RZ_API RzEvent *	rz_event_new (void *user)
RZ_API void	rz_event_free (RzEvent *ev)
static RzVector *	get_cbs (RzEvent *ev, int type)
RZ_API RzEventCallbackHandle	rz_event_hook (RzEvent *ev, int type, RzEventCallback cb, void *user)
static bool	del_hook (void *user, const ut64 k, const void *v)
RZ_API void	rz_event_unhook (RzEvent *ev, RzEventCallbackHandle handle)
RZ_API void	rz_event_send (RzEvent *ev, int type, void *data)

Typedef Documentation

RzEventCallbackHook

typedef struct rz_event_callback_hook_t RzEventCallbackHook

Function Documentation

del_hook()

static bool del_hook ( void *  user, const ut64  k, const void *  v  )

static

Definition at line 80 of file event.c.

                                                              {
    int handle = *(int *)user;
    RzVector *cbs = (RzVector *)v;
    RzEventCallbackHook *hook;
    size_t i;
    rz_return_val_if_fail(cbs, false);
    rz_vector_enumerate(cbs, hook, i) {
        if (hook->handle == handle) {
            rz_vector_remove_at(cbs, i, NULL);
            break;
        }
    }
    return true;
}

References handle, rz_event_callback_hook_t::handle, i, NULL, rz_return_val_if_fail, rz_vector_enumerate, rz_vector_remove_at(), and v.

Referenced by rz_event_unhook().

get_cbs()

static RzVector* get_cbs ( RzEvent *  ev, int  type  )

static

Definition at line 47 of file event.c.

                                                {
    RzVector *cbs = ht_up_find(ev->callbacks, (ut64)type, NULL);
    if (!cbs) {
        cbs = rz_vector_new(sizeof(RzEventCallbackHook), NULL, NULL);
        if (cbs) {
            ht_up_insert(ev->callbacks, (ut64)type, cbs);
        }
    }
    return cbs;
}

References rz_event_t::callbacks, NULL, rz_vector_new(), type, and ut64().

Referenced by rz_event_hook().

ht_callback_free()

static void ht_callback_free ( HtUPKv *  kv )

static

Definition at line 13 of file event.c.

                                         {
    rz_vector_free((RzVector *)kv->value);
}

References rz_vector_free().

Referenced by rz_event_new().

rz_event_free()

RZ_API void rz_event_free

(

RzEvent *

ev

)

Definition at line 37 of file event.c.

                                       {
    if (!ev) {
        return;
    }
    rz_vector_fini(&ev->pending_unhook);
    ht_up_free(ev->callbacks);
    rz_vector_fini(&ev->all_callbacks);
    free(ev);
}

References rz_event_t::all_callbacks, rz_event_t::callbacks, free(), rz_event_t::pending_unhook, and rz_vector_fini().

Referenced by rz_bin_free(), rz_bin_new(), rz_core_fini(), rz_event_new(), rz_io_fini(), and rz_spaces_fini().

rz_event_hook()

RZ_API RzEventCallbackHandle rz_event_hook	(	RzEvent *	ev,
		int	type,
		RzEventCallback	cb,
		void *	user
	)

Definition at line 58 of file event.c.

                                                                                                  {
    RzEventCallbackHandle handle = { 0 };
    RzEventCallbackHook hook;
 
    rz_return_val_if_fail(ev, handle);
    hook.cb = cb;
    hook.user = user;
    hook.handle = ev->next_handle++;
    if (type == RZ_EVENT_ALL) {
        rz_vector_push(&ev->all_callbacks, &hook);
    } else {
        RzVector *cbs = get_cbs(ev, type);
        if (!cbs) {
            return handle;
        }
        rz_vector_push(cbs, &hook);
    }
    handle.handle = hook.handle;
    handle.type = type;
    return handle;
}

References rz_event_t::all_callbacks, cb, rz_event_callback_hook_t::cb, get_cbs(), handle, rz_event_callback_hook_t::handle, rz_event_t::next_handle, RZ_EVENT_ALL, rz_return_val_if_fail, rz_vector_push(), type, and rz_event_callback_hook_t::user.

Referenced by new_spaces(), rz_analysis_new(), and rz_core_init().

rz_event_new()

RZ_API RzEvent* rz_event_new

(

void *

user

)

Definition at line 17 of file event.c.

                                         {
    RzEvent *ev = RZ_NEW0(RzEvent);
    if (!ev) {
        return NULL;
    }
 
    ev->user = user;
    ev->next_handle = 0;
    ev->callbacks = ht_up_new(NULL, ht_callback_free, NULL);
    if (!ev->callbacks) {
        goto err;
    }
    rz_vector_init(&ev->all_callbacks, sizeof(RzEventCallbackHook), NULL, NULL);
    rz_vector_init(&ev->pending_unhook, sizeof(RzEventCallbackHandle), NULL, NULL);
    return ev;
err:
    rz_event_free(ev);
    return NULL;
}

References rz_event_t::all_callbacks, rz_event_t::callbacks, err, ht_callback_free(), rz_event_t::next_handle, NULL, rz_event_t::pending_unhook, rz_event_free(), RZ_NEW0, rz_vector_init(), and rz_event_t::user.

Referenced by rz_bin_new(), rz_core_init(), rz_io_init(), and rz_spaces_init().

rz_event_send()

RZ_API void rz_event_send	(	RzEvent *	ev,
		int	type,
		void *	data
	)

Definition at line 115 of file event.c.

                                                             {
    RzEventCallbackHook *hook;
    rz_return_if_fail(ev && !ev->incall);
 
    // send to both the per-type callbacks and to the all_callbacks
    ev->incall = true;
    rz_vector_foreach(&ev->all_callbacks, hook) {
        hook->cb(ev, type, hook->user, data);
    }
    ev->incall = false;
 
    RzVector *cbs = ht_up_find(ev->callbacks, (ut64)type, NULL);
    if (cbs) {
        ev->incall = true;
        rz_vector_foreach(cbs, hook) {
            hook->cb(ev, type, hook->user, data);
        }
        ev->incall = false;
    }
 
    RzEventCallbackHandle *unhook_handle;
    rz_vector_foreach(&ev->pending_unhook, unhook_handle) {
        rz_event_unhook(ev, *unhook_handle);
    }
    rz_vector_clear(&ev->pending_unhook);
}

References rz_event_t::all_callbacks, rz_event_t::callbacks, rz_event_callback_hook_t::cb, rz_event_t::incall, NULL, rz_event_t::pending_unhook, rz_event_unhook(), rz_return_if_fail, rz_vector_clear(), rz_vector_foreach, type, rz_event_callback_hook_t::user, and ut64().

Referenced by map_del(), rz_analysis_class_create(), rz_analysis_class_delete(), rz_analysis_class_delete_attr_raw(), rz_analysis_class_rename(), rz_analysis_class_rename_attr_raw(), rz_analysis_class_set_attr_raw(), rz_bin_file_delete(), rz_bin_file_delete_all(), rz_debug_wait(), rz_io_cache_write(), rz_io_desc_cache_write(), rz_io_desc_close(), rz_io_map_fini(), rz_io_plugin_write(), rz_spaces_count(), rz_spaces_rename(), and spaces_unset_single().

rz_event_unhook()

RZ_API void rz_event_unhook	(	RzEvent *	ev,
		RzEventCallbackHandle	handle
	)

Definition at line 95 of file event.c.

                                                                       {
    rz_return_if_fail(ev);
    if (ev->incall) {
        // when inside a call (meaning rz_event_send currently iterates over the callback vectors),
        // defer the unhook to after the rz_event_send is done.
        rz_vector_push(&ev->pending_unhook, &handle);
        return;
    }
    if (handle.type == RZ_EVENT_ALL) {
        // try to delete it both from each list of callbacks and from
        // the "all_callbacks" vector
        ht_up_foreach(ev->callbacks, del_hook, &handle.handle);
        del_hook(&handle.handle, 0, &ev->all_callbacks);
    } else {
        RzVector *cbs = ht_up_find(ev->callbacks, (ut64)handle.type, NULL);
        rz_return_if_fail(cbs);
        del_hook(&handle.handle, 0, cbs);
    }
}

References rz_event_t::all_callbacks, rz_event_t::callbacks, del_hook(), handle, rz_event_t::incall, NULL, rz_event_t::pending_unhook, RZ_EVENT_ALL, rz_return_if_fail, rz_vector_push(), and ut64().

Referenced by rz_event_send().