mirror of
https://github.com/matrix-construct/construct
synced 2024-11-29 10:12:39 +01:00
ircd/authd: timeout dead authd clients
This commit is contained in:
parent
cc4d393152
commit
ef0b13b960
1 changed files with 33 additions and 1 deletions
34
ircd/authd.c
34
ircd/authd.c
|
@ -43,12 +43,14 @@
|
|||
static int start_authd(void);
|
||||
static void parse_authd_reply(rb_helper * helper);
|
||||
static void restart_authd_cb(rb_helper * helper);
|
||||
static EVH timeout_dead_authd_clients;
|
||||
|
||||
rb_helper *authd_helper;
|
||||
static char *authd_path;
|
||||
|
||||
uint32_t cid = 1;
|
||||
static rb_dictionary *cid_clients;
|
||||
static struct ev_entry *timeout_ev;
|
||||
|
||||
rb_dictionary *bl_stats;
|
||||
|
||||
|
@ -91,6 +93,9 @@ start_authd(void)
|
|||
if(bl_stats == NULL)
|
||||
bl_stats = rb_dictionary_create("blacklist statistics", strcasecmp);
|
||||
|
||||
if(timeout_ev == NULL)
|
||||
timeout_ev = rb_event_addish("timeout_dead_authd_clients", timeout_dead_authd_clients, NULL, 1);
|
||||
|
||||
authd_helper = rb_helper_start("authd", authd_path, parse_authd_reply, restart_authd_cb);
|
||||
|
||||
if(authd_helper == NULL)
|
||||
|
@ -191,7 +196,7 @@ parse_authd_reply(rb_helper * helper)
|
|||
authd_decide_client(client_p, parv[3], parv[4], false, toupper(*parv[2]), parv[5], parv[6]);
|
||||
break;
|
||||
case 'N': /* Notice to client */
|
||||
if(parv != 3)
|
||||
if(parc != 3)
|
||||
{
|
||||
iwarn("authd sent us a result with wrong number of arguments: got %d", parc);
|
||||
restart_authd();
|
||||
|
@ -461,6 +466,33 @@ authd_abort_client(struct Client *client_p)
|
|||
client_p->preClient->authd_cid = 0;
|
||||
}
|
||||
|
||||
static void
|
||||
timeout_dead_authd_clients(void *notused __unused)
|
||||
{
|
||||
rb_dictionary_iter iter;
|
||||
char *id;
|
||||
|
||||
RB_DICTIONARY_FOREACH(id, &iter, cid_clients)
|
||||
{
|
||||
struct Client *client_p;
|
||||
if((client_p = find_id(id)) == NULL)
|
||||
{
|
||||
/* This shouldn't happen... but just in case... */
|
||||
rb_helper_write(authd_helper, "E %x", RB_POINTER_TO_UINT(iter.cur->key));
|
||||
rb_free(id);
|
||||
rb_dictionary_delete(cid_clients, iter.cur->key);
|
||||
continue;
|
||||
}
|
||||
|
||||
if(client_p->preClient->authd_timeout < rb_current_time())
|
||||
{
|
||||
rb_helper_write(authd_helper, "E %x", client_p->preClient->authd_cid);
|
||||
rb_free(id);
|
||||
rb_dictionary_delete(cid_clients, RB_UINT_TO_POINTER(client_p->preClient->authd_cid));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/* Turn a cause char (who rejected us) into the name of the provider */
|
||||
const char *
|
||||
get_provider_string(char cause)
|
||||
|
|
Loading…
Reference in a new issue