sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-01-26 10:04:02 +03:00
Code

tevent: splitout tevent_queue_add_internal() from tevent_queue_add()

Browse Source 
metze
This commit is contained in:
Stefan Metzmacher 2011-08-09 15:33:37 +02:00
parent aba9d48f55
commit 6b7d58cb4e
1 changed files with 26 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
lib/tevent/tevent_queue.c
View File

@ -144,17 +144,18 @@ static void tevent_queue_immediate_trigger(struct tevent_context *ev,
q->list->trigger(q->list->req, q->list->private_data);
}
bool tevent_queue_add(struct tevent_queue *queue,
struct tevent_context *ev,
struct tevent_req *req,
tevent_queue_trigger_fn_t trigger,
void *private_data)
static struct tevent_queue_entry *tevent_queue_add_internal(
struct tevent_queue *queue,
struct tevent_context *ev,
struct tevent_req *req,
tevent_queue_trigger_fn_t trigger,
void *private_data)
{
struct tevent_queue_entry *e;
e = talloc_zero(req, struct tevent_queue_entry);
if (e == NULL) {
return false;
return NULL;
}
e->queue = queue;
@ -175,11 +176,11 @@ bool tevent_queue_add(struct tevent_queue *queue,
talloc_set_destructor(e, tevent_queue_entry_destructor);
if (!queue->running) {
return true;
return e;
}
if (queue->list->triggered) {
return true;
return e;
}
tevent_schedule_immediate(queue->immediate,
@ -187,6 +188,23 @@ bool tevent_queue_add(struct tevent_queue *queue,
tevent_queue_immediate_trigger,
queue);
return e;
}
bool tevent_queue_add(struct tevent_queue *queue,
struct tevent_context *ev,
struct tevent_req *req,
tevent_queue_trigger_fn_t trigger,
void *private_data)
{
struct tevent_queue_entry *e;
e = tevent_queue_add_internal(queue, ev, req,
trigger, private_data);
if (e == NULL) {
return false;
}
return true;
}