2016-01-06 10:41:57 +00:00
|
|
|
/*
|
|
|
|
* authd.c: An interface to authd.
|
|
|
|
* (based somewhat on ircd-ratbox dns.c)
|
|
|
|
*
|
|
|
|
* Copyright (C) 2005 Aaron Sethman <androsyn@ratbox.org>
|
|
|
|
* Copyright (C) 2005-2012 ircd-ratbox development team
|
2021-06-01 16:40:02 +00:00
|
|
|
* Copyright (C) 2016 Ariadne Conill <ariadne@dereferenced.org>
|
2016-01-06 10:41:57 +00:00
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
* (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program; if not, write to the Free Software
|
|
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
|
|
|
|
* USA
|
|
|
|
*/
|
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
#include "stdinc.h"
|
|
|
|
#include "rb_lib.h"
|
|
|
|
#include "client.h"
|
|
|
|
#include "ircd_defs.h"
|
|
|
|
#include "parse.h"
|
2016-04-02 21:44:04 +00:00
|
|
|
#include "authproc.h"
|
2016-03-28 07:11:16 +00:00
|
|
|
#include "match.h"
|
|
|
|
#include "logger.h"
|
|
|
|
#include "s_conf.h"
|
|
|
|
#include "s_stats.h"
|
|
|
|
#include "client.h"
|
|
|
|
#include "packet.h"
|
|
|
|
#include "hash.h"
|
|
|
|
#include "send.h"
|
|
|
|
#include "numeric.h"
|
|
|
|
#include "msg.h"
|
|
|
|
#include "dns.h"
|
2016-01-06 10:41:57 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
typedef void (*authd_cb_t)(int, char **);
|
|
|
|
|
|
|
|
struct authd_cb
|
|
|
|
{
|
|
|
|
authd_cb_t fn;
|
|
|
|
int min_parc;
|
|
|
|
};
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
static int start_authd(void);
|
|
|
|
static void parse_authd_reply(rb_helper * helper);
|
|
|
|
static void restart_authd_cb(rb_helper * helper);
|
2016-03-28 07:30:54 +00:00
|
|
|
static EVH timeout_dead_authd_clients;
|
2016-01-06 10:41:57 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void cmd_accept_client(int parc, char **parv);
|
|
|
|
static void cmd_reject_client(int parc, char **parv);
|
|
|
|
static void cmd_dns_result(int parc, char **parv);
|
|
|
|
static void cmd_notice_client(int parc, char **parv);
|
|
|
|
static void cmd_oper_warn(int parc, char **parv);
|
|
|
|
static void cmd_stats_results(int parc, char **parv);
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
rb_helper *authd_helper;
|
|
|
|
static char *authd_path;
|
|
|
|
|
2016-03-28 21:47:51 +00:00
|
|
|
uint32_t cid;
|
2016-03-28 07:11:16 +00:00
|
|
|
static rb_dictionary *cid_clients;
|
2016-03-28 07:30:54 +00:00
|
|
|
static struct ev_entry *timeout_ev;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2023-01-11 18:39:26 +00:00
|
|
|
rb_dictionary *dnsbl_stats = NULL;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-12 14:33:51 +00:00
|
|
|
rb_dlink_list opm_list;
|
|
|
|
struct OPMListener opm_listeners[LISTEN_LAST];
|
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static struct authd_cb authd_cmd_tab[256] =
|
|
|
|
{
|
|
|
|
['A'] = { cmd_accept_client, 4 },
|
|
|
|
['E'] = { cmd_dns_result, 5 },
|
|
|
|
['N'] = { cmd_notice_client, 3 },
|
|
|
|
['R'] = { cmd_reject_client, 7 },
|
|
|
|
['W'] = { cmd_oper_warn, 3 },
|
|
|
|
['X'] = { cmd_stats_results, 3 },
|
|
|
|
['Y'] = { cmd_stats_results, 3 },
|
|
|
|
['Z'] = { cmd_stats_results, 3 },
|
|
|
|
};
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
static int
|
|
|
|
start_authd(void)
|
|
|
|
{
|
|
|
|
char fullpath[PATH_MAX + 1];
|
2021-07-09 00:11:22 +00:00
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
if(authd_path == NULL)
|
|
|
|
{
|
2021-07-09 00:11:22 +00:00
|
|
|
snprintf(fullpath, sizeof(fullpath), "%s/authd", ircd_paths[IRCD_PATH_LIBEXEC]);
|
2016-01-06 10:41:57 +00:00
|
|
|
|
|
|
|
if(access(fullpath, X_OK) == -1)
|
|
|
|
{
|
2021-07-09 00:11:22 +00:00
|
|
|
snprintf(fullpath, sizeof(fullpath), "%s/bin/authd", ConfigFileEntry.dpath);
|
2016-01-06 10:41:57 +00:00
|
|
|
if(access(fullpath, X_OK) == -1)
|
|
|
|
{
|
2016-03-29 00:06:31 +00:00
|
|
|
ierror("Unable to execute authd in %s or %s/bin",
|
|
|
|
ircd_paths[IRCD_PATH_LIBEXEC], ConfigFileEntry.dpath);
|
2020-11-08 19:30:41 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE,
|
2016-03-24 23:45:28 +00:00
|
|
|
"Unable to execute authd in %s or %s/bin",
|
|
|
|
ircd_paths[IRCD_PATH_LIBEXEC], ConfigFileEntry.dpath);
|
2016-01-06 10:41:57 +00:00
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
authd_path = rb_strdup(fullpath);
|
|
|
|
}
|
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
if(cid_clients == NULL)
|
|
|
|
cid_clients = rb_dictionary_create("authd cid to uid mapping", rb_uint32cmp);
|
|
|
|
|
2016-03-28 07:30:54 +00:00
|
|
|
if(timeout_ev == NULL)
|
|
|
|
timeout_ev = rb_event_addish("timeout_dead_authd_clients", timeout_dead_authd_clients, NULL, 1);
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
authd_helper = rb_helper_start("authd", authd_path, parse_authd_reply, restart_authd_cb);
|
|
|
|
|
|
|
|
if(authd_helper == NULL)
|
|
|
|
{
|
2016-03-29 00:06:31 +00:00
|
|
|
ierror("Unable to start authd helper: %s", strerror(errno));
|
2020-11-08 19:30:41 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "Unable to start authd helper: %s", strerror(errno));
|
2016-01-06 10:41:57 +00:00
|
|
|
return 1;
|
|
|
|
}
|
2016-04-30 06:11:08 +00:00
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
ilog(L_MAIN, "authd helper started");
|
2020-11-08 19:30:41 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "authd helper started");
|
2016-01-06 10:41:57 +00:00
|
|
|
rb_helper_run(authd_helper);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2016-04-02 06:16:47 +00:00
|
|
|
static inline uint32_t
|
|
|
|
str_to_cid(const char *str)
|
|
|
|
{
|
|
|
|
long lcid = strtol(str, NULL, 16);
|
|
|
|
|
|
|
|
if(lcid > UINT32_MAX || lcid <= 0)
|
|
|
|
{
|
|
|
|
iwarn("authd sent us back a bad client ID: %lx", lcid);
|
|
|
|
restart_authd();
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
return (uint32_t)lcid;
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline struct Client *
|
2016-06-01 19:55:35 +00:00
|
|
|
cid_to_client(uint32_t ncid, bool del)
|
2016-04-02 06:16:47 +00:00
|
|
|
{
|
|
|
|
struct Client *client_p;
|
|
|
|
|
2016-06-01 19:55:35 +00:00
|
|
|
if(del)
|
|
|
|
client_p = rb_dictionary_delete(cid_clients, RB_UINT_TO_POINTER(ncid));
|
2016-04-02 06:16:47 +00:00
|
|
|
else
|
2016-06-01 19:55:35 +00:00
|
|
|
client_p = rb_dictionary_retrieve(cid_clients, RB_UINT_TO_POINTER(ncid));
|
2016-04-02 06:16:47 +00:00
|
|
|
|
2016-04-02 08:51:54 +00:00
|
|
|
/* If the client's not found, that's okay, it may have already gone away.
|
|
|
|
* --Elizafox */
|
2016-04-02 06:16:47 +00:00
|
|
|
|
|
|
|
return client_p;
|
|
|
|
}
|
|
|
|
|
2016-04-02 06:20:49 +00:00
|
|
|
static inline struct Client *
|
2016-06-01 19:55:35 +00:00
|
|
|
str_cid_to_client(const char *str, bool del)
|
2016-04-02 06:20:49 +00:00
|
|
|
{
|
2016-06-01 19:55:35 +00:00
|
|
|
uint32_t ncid = str_to_cid(str);
|
2016-04-02 06:20:49 +00:00
|
|
|
|
2016-06-01 19:55:35 +00:00
|
|
|
if(ncid == 0)
|
2016-04-02 06:20:49 +00:00
|
|
|
return NULL;
|
|
|
|
|
2016-06-01 19:55:35 +00:00
|
|
|
return cid_to_client(ncid, del);
|
2016-04-02 06:20:49 +00:00
|
|
|
}
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
static void
|
2016-04-02 09:49:01 +00:00
|
|
|
cmd_accept_client(int parc, char **parv)
|
2016-01-06 10:41:57 +00:00
|
|
|
{
|
2016-03-28 07:11:16 +00:00
|
|
|
struct Client *client_p;
|
2016-04-02 09:51:11 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
/* cid to uid (retrieve and delete) */
|
|
|
|
if((client_p = str_cid_to_client(parv[1], true)) == NULL)
|
|
|
|
return;
|
2016-03-08 08:53:25 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
authd_accept_client(client_p, parv[2], parv[3]);
|
|
|
|
}
|
2016-01-06 10:41:57 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void
|
|
|
|
cmd_dns_result(int parc, char **parv)
|
|
|
|
{
|
|
|
|
dns_results_callback(parv[1], parv[2], parv[3], parv[4]);
|
|
|
|
}
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void
|
|
|
|
cmd_notice_client(int parc, char **parv)
|
|
|
|
{
|
|
|
|
struct Client *client_p;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2020-10-28 20:59:43 +00:00
|
|
|
if ((client_p = str_cid_to_client(parv[1], false)) == NULL)
|
|
|
|
return;
|
|
|
|
|
|
|
|
if (IsAnyDead(client_p))
|
2016-04-02 09:49:01 +00:00
|
|
|
return;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
sendto_one_notice(client_p, ":%s", parv[2]);
|
|
|
|
}
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void
|
|
|
|
cmd_reject_client(int parc, char **parv)
|
|
|
|
{
|
|
|
|
struct Client *client_p;
|
2016-03-28 21:47:51 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
/* cid to uid (retrieve and delete) */
|
|
|
|
if((client_p = str_cid_to_client(parv[1], true)) == NULL)
|
|
|
|
return;
|
2016-03-28 07:19:34 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
authd_reject_client(client_p, parv[3], parv[4], toupper(*parv[2]), parv[5], parv[6]);
|
|
|
|
}
|
2016-04-02 06:20:49 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void
|
|
|
|
cmd_oper_warn(int parc, char **parv)
|
|
|
|
{
|
2016-04-03 01:31:32 +00:00
|
|
|
switch(*parv[1])
|
2016-04-02 09:49:01 +00:00
|
|
|
{
|
|
|
|
case 'D': /* Debug */
|
2022-10-21 06:47:15 +00:00
|
|
|
sendto_realops_snomask(SNO_DEBUG, L_NETWIDE, "authd debug: %s", parv[2]);
|
2016-04-03 01:31:32 +00:00
|
|
|
idebug("authd: %s", parv[2]);
|
2016-04-02 09:49:01 +00:00
|
|
|
break;
|
|
|
|
case 'I': /* Info */
|
2022-10-21 06:47:15 +00:00
|
|
|
sendto_realops_snomask(SNO_DEBUG, L_NETWIDE, "authd info: %s", parv[2]);
|
2016-04-03 01:31:32 +00:00
|
|
|
inotice("authd: %s", parv[2]);
|
2016-04-02 09:49:01 +00:00
|
|
|
break;
|
|
|
|
case 'W': /* Warning */
|
2022-10-03 19:00:21 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "authd WARNING: %s", parv[2]);
|
2016-04-03 01:31:32 +00:00
|
|
|
iwarn("authd: %s", parv[2]);
|
2016-04-02 09:49:01 +00:00
|
|
|
break;
|
|
|
|
case 'C': /* Critical (error) */
|
2022-10-03 19:00:21 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "authd CRITICAL: %s", parv[2]);
|
2016-04-03 01:31:32 +00:00
|
|
|
ierror("authd: %s", parv[2]);
|
2016-04-02 09:49:01 +00:00
|
|
|
break;
|
|
|
|
default: /* idk */
|
2022-10-03 19:00:21 +00:00
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "authd sent us an unknown oper notice type (%s): %s", parv[1], parv[2]);
|
2016-04-03 01:31:32 +00:00
|
|
|
ilog(L_MAIN, "authd unknown oper notice type (%s): %s", parv[1], parv[2]);
|
2016-04-02 09:49:01 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
2016-03-26 02:57:42 +00:00
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
static void
|
|
|
|
cmd_stats_results(int parc, char **parv)
|
|
|
|
{
|
|
|
|
/* Select by type */
|
|
|
|
switch(*parv[2])
|
|
|
|
{
|
|
|
|
case 'D':
|
|
|
|
/* parv[0] conveys status */
|
|
|
|
if(parc < 4)
|
|
|
|
{
|
|
|
|
iwarn("authd sent a result with wrong number of arguments: got %d", parc);
|
|
|
|
restart_authd();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
dns_stats_results_callback(parv[1], parv[0], parc - 3, (const char **)&parv[3]);
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
parse_authd_reply(rb_helper * helper)
|
|
|
|
{
|
|
|
|
ssize_t len;
|
|
|
|
int parc;
|
2016-04-02 09:51:11 +00:00
|
|
|
char buf[READBUF_SIZE];
|
2017-07-28 20:50:16 +00:00
|
|
|
char *parv[MAXPARA];
|
2016-03-26 02:57:42 +00:00
|
|
|
|
2016-04-02 09:51:11 +00:00
|
|
|
while((len = rb_helper_read(helper, buf, sizeof(buf))) > 0)
|
2016-04-02 09:49:01 +00:00
|
|
|
{
|
|
|
|
struct authd_cb *cmd;
|
|
|
|
|
2017-07-28 20:50:16 +00:00
|
|
|
parc = rb_string_to_array(buf, parv, sizeof(parv));
|
2016-04-23 03:06:42 +00:00
|
|
|
cmd = &authd_cmd_tab[(unsigned char)*parv[0]];
|
2016-04-02 09:49:01 +00:00
|
|
|
if(cmd->fn != NULL)
|
|
|
|
{
|
|
|
|
if(cmd->min_parc > parc)
|
2016-03-08 08:53:25 +00:00
|
|
|
{
|
2016-04-02 09:49:01 +00:00
|
|
|
iwarn("authd sent a result with wrong number of arguments: expected %d, got %d",
|
|
|
|
cmd->min_parc, parc);
|
2016-03-08 08:53:25 +00:00
|
|
|
restart_authd();
|
2016-04-02 09:49:01 +00:00
|
|
|
continue;
|
2016-03-08 08:53:25 +00:00
|
|
|
}
|
|
|
|
|
2016-04-02 09:49:01 +00:00
|
|
|
cmd->fn(parc, parv);
|
2016-01-06 10:41:57 +00:00
|
|
|
}
|
2016-04-02 10:05:28 +00:00
|
|
|
else
|
|
|
|
{
|
|
|
|
iwarn("authd sent us a bad command type: %c", *parv[0]);
|
|
|
|
restart_authd();
|
|
|
|
continue;
|
|
|
|
}
|
2016-01-06 10:41:57 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
init_authd(void)
|
|
|
|
{
|
|
|
|
if(start_authd())
|
|
|
|
{
|
2016-03-29 00:06:31 +00:00
|
|
|
ierror("Unable to start authd helper: %s", strerror(errno));
|
2016-01-06 10:41:57 +00:00
|
|
|
exit(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
void
|
|
|
|
configure_authd(void)
|
|
|
|
{
|
2016-04-12 14:33:51 +00:00
|
|
|
/* Timeouts */
|
2016-03-28 07:11:16 +00:00
|
|
|
set_authd_timeout("ident_timeout", GlobalSetOptions.ident_timeout);
|
|
|
|
set_authd_timeout("rdns_timeout", ConfigFileEntry.connect_timeout);
|
2016-03-28 21:47:51 +00:00
|
|
|
set_authd_timeout("rbl_timeout", ConfigFileEntry.connect_timeout);
|
2016-04-12 14:33:51 +00:00
|
|
|
|
2016-03-28 21:47:51 +00:00
|
|
|
ident_check_enable(!ConfigFileEntry.disable_auth);
|
2016-04-12 14:33:51 +00:00
|
|
|
|
|
|
|
/* Configure OPM */
|
|
|
|
if(rb_dlink_list_length(&opm_list) > 0 &&
|
|
|
|
(opm_listeners[LISTEN_IPV4].ipaddr[0] != '\0' ||
|
|
|
|
opm_listeners[LISTEN_IPV6].ipaddr[0] != '\0'))
|
|
|
|
{
|
|
|
|
rb_dlink_node *ptr;
|
|
|
|
|
|
|
|
if(opm_listeners[LISTEN_IPV4].ipaddr[0] != '\0')
|
|
|
|
rb_helper_write(authd_helper, "O opm_listener %s %hu",
|
|
|
|
opm_listeners[LISTEN_IPV4].ipaddr, opm_listeners[LISTEN_IPV4].port);
|
|
|
|
|
|
|
|
if(opm_listeners[LISTEN_IPV6].ipaddr[0] != '\0')
|
|
|
|
rb_helper_write(authd_helper, "O opm_listener %s %hu",
|
|
|
|
opm_listeners[LISTEN_IPV6].ipaddr, opm_listeners[LISTEN_IPV6].port);
|
|
|
|
|
|
|
|
RB_DLINK_FOREACH(ptr, opm_list.head)
|
|
|
|
{
|
|
|
|
struct OPMScanner *scanner = ptr->data;
|
|
|
|
rb_helper_write(authd_helper, "O opm_scanner %s %hu",
|
|
|
|
scanner->type, scanner->port);
|
|
|
|
}
|
|
|
|
|
|
|
|
opm_check_enable(true);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
opm_check_enable(false);
|
2023-01-11 01:28:32 +00:00
|
|
|
|
|
|
|
/* Configure DNSBLs */
|
2023-01-11 18:39:26 +00:00
|
|
|
if (dnsbl_stats != NULL)
|
2023-01-11 01:28:32 +00:00
|
|
|
{
|
2023-01-11 18:39:26 +00:00
|
|
|
rb_dictionary_iter iter;
|
|
|
|
struct DNSBLEntry *entry;
|
|
|
|
RB_DICTIONARY_FOREACH(entry, &iter, dnsbl_stats)
|
|
|
|
{
|
|
|
|
rb_helper_write(authd_helper, "O rbl %s %hhu %s :%s", entry->host,
|
|
|
|
entry->iptype, entry->filters, entry->reason);
|
|
|
|
}
|
2023-01-11 01:28:32 +00:00
|
|
|
}
|
2016-03-28 07:11:16 +00:00
|
|
|
}
|
|
|
|
|
2016-04-30 06:11:08 +00:00
|
|
|
static void
|
|
|
|
authd_free_client(struct Client *client_p)
|
|
|
|
{
|
|
|
|
if(client_p == NULL || client_p->preClient == NULL)
|
|
|
|
return;
|
|
|
|
|
|
|
|
if(client_p->preClient->auth.cid == 0)
|
|
|
|
return;
|
|
|
|
|
|
|
|
if(authd_helper != NULL)
|
|
|
|
rb_helper_write(authd_helper, "E %x", client_p->preClient->auth.cid);
|
|
|
|
|
|
|
|
client_p->preClient->auth.accepted = true;
|
|
|
|
client_p->preClient->auth.cid = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
authd_free_client_cb(rb_dictionary_element *delem, void *unused)
|
|
|
|
{
|
|
|
|
struct Client *client_p = delem->data;
|
|
|
|
authd_free_client(client_p);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
authd_abort_client(struct Client *client_p)
|
|
|
|
{
|
|
|
|
rb_dictionary_delete(cid_clients, RB_UINT_TO_POINTER(client_p->preClient->auth.cid));
|
|
|
|
authd_free_client(client_p);
|
|
|
|
}
|
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
static void
|
|
|
|
restart_authd_cb(rb_helper * helper)
|
|
|
|
{
|
2022-10-21 06:47:15 +00:00
|
|
|
iwarn("authd helper died - attempting to restart");
|
|
|
|
sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "authdd helper died - attempting to restart");
|
2016-04-01 07:27:48 +00:00
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
if(helper != NULL)
|
|
|
|
{
|
|
|
|
rb_helper_close(helper);
|
|
|
|
authd_helper = NULL;
|
|
|
|
}
|
2016-04-01 07:27:48 +00:00
|
|
|
|
2016-04-30 06:11:08 +00:00
|
|
|
rb_dictionary_destroy(cid_clients, authd_free_client_cb, NULL);
|
|
|
|
cid_clients = NULL;
|
2016-04-01 07:27:48 +00:00
|
|
|
|
2016-01-06 10:41:57 +00:00
|
|
|
start_authd();
|
2016-04-03 01:31:32 +00:00
|
|
|
configure_authd();
|
2016-01-06 10:41:57 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
restart_authd(void)
|
|
|
|
{
|
2016-04-03 03:30:54 +00:00
|
|
|
ierror("authd restarting...");
|
2016-01-06 10:41:57 +00:00
|
|
|
restart_authd_cb(authd_helper);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
rehash_authd(void)
|
|
|
|
{
|
|
|
|
rb_helper_write(authd_helper, "R");
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
check_authd(void)
|
|
|
|
{
|
|
|
|
if(authd_helper == NULL)
|
|
|
|
restart_authd();
|
|
|
|
}
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
static inline uint32_t
|
|
|
|
generate_cid(void)
|
|
|
|
{
|
|
|
|
if(++cid == 0)
|
|
|
|
cid = 1;
|
|
|
|
|
|
|
|
return cid;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Basically when this is called we begin handing off the client to authd for
|
|
|
|
* processing. authd "owns" the client until processing is finished, or we
|
|
|
|
* timeout from authd. authd will make a decision whether or not to accept the
|
|
|
|
* client, but it's up to other parts of the code (for now) to decide if we're
|
|
|
|
* gonna accept the client and ignore authd's suggestion.
|
|
|
|
*
|
|
|
|
* --Elizafox
|
2016-04-25 20:35:58 +00:00
|
|
|
*
|
|
|
|
* If this is an SSL connection we must defer handing off the client for
|
|
|
|
* reading until it is open and we have the certificate fingerprint, otherwise
|
|
|
|
* it's possible for the client to immediately send data before authd completes
|
|
|
|
* and before the status of the connection is communicated via ssld. This data
|
|
|
|
* could then be processed too early by read_packet().
|
2016-03-28 07:11:16 +00:00
|
|
|
*/
|
|
|
|
void
|
2016-04-25 20:35:58 +00:00
|
|
|
authd_initiate_client(struct Client *client_p, bool defer)
|
2016-03-28 07:11:16 +00:00
|
|
|
{
|
|
|
|
char client_ipaddr[HOSTIPLEN+1];
|
|
|
|
char listen_ipaddr[HOSTIPLEN+1];
|
|
|
|
uint16_t client_port, listen_port;
|
|
|
|
uint32_t authd_cid;
|
|
|
|
|
2016-04-10 14:20:51 +00:00
|
|
|
if(client_p->preClient == NULL || client_p->preClient->auth.cid != 0)
|
2016-03-28 07:11:16 +00:00
|
|
|
return;
|
|
|
|
|
2016-04-10 14:20:51 +00:00
|
|
|
authd_cid = client_p->preClient->auth.cid = generate_cid();
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
/* Collisions are extremely unlikely, so disregard the possibility */
|
2016-03-28 21:47:51 +00:00
|
|
|
rb_dictionary_add(cid_clients, RB_UINT_TO_POINTER(authd_cid), client_p);
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
/* Retrieve listener and client IP's */
|
|
|
|
rb_inet_ntop_sock((struct sockaddr *)&client_p->preClient->lip, listen_ipaddr, sizeof(listen_ipaddr));
|
|
|
|
rb_inet_ntop_sock((struct sockaddr *)&client_p->localClient->ip, client_ipaddr, sizeof(client_ipaddr));
|
|
|
|
|
|
|
|
/* Retrieve listener and client ports */
|
2016-03-31 08:00:29 +00:00
|
|
|
listen_port = ntohs(GET_SS_PORT(&client_p->preClient->lip));
|
|
|
|
client_port = ntohs(GET_SS_PORT(&client_p->localClient->ip));
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-25 20:35:58 +00:00
|
|
|
if(defer)
|
|
|
|
client_p->preClient->auth.flags |= AUTHC_F_DEFERRED;
|
|
|
|
|
2016-03-28 07:32:05 +00:00
|
|
|
/* Add a bit of a fudge factor... */
|
2016-04-10 14:20:51 +00:00
|
|
|
client_p->preClient->auth.timeout = rb_current_time() + ConfigFileEntry.connect_timeout + 10;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2017-08-19 14:11:49 +00:00
|
|
|
rb_helper_write(authd_helper, "C %x %s %hu %s %hu %x", authd_cid, listen_ipaddr, listen_port, client_ipaddr, client_port,
|
|
|
|
#ifdef HAVE_LIBSCTP
|
|
|
|
IsSCTP(client_p) ? IPPROTO_SCTP : IPPROTO_TCP);
|
|
|
|
#else
|
|
|
|
IPPROTO_TCP);
|
|
|
|
#endif
|
2016-03-28 07:11:16 +00:00
|
|
|
}
|
|
|
|
|
2016-04-25 20:35:58 +00:00
|
|
|
static inline void
|
|
|
|
authd_read_client(struct Client *client_p)
|
|
|
|
{
|
|
|
|
/*
|
|
|
|
* When a client has auth'ed, we want to start reading what it sends
|
|
|
|
* us. This is what read_packet() does.
|
|
|
|
* -- adrian
|
|
|
|
*
|
|
|
|
* Above comment was originally in s_auth.c, but moved here with below code.
|
|
|
|
* --Elizafox
|
|
|
|
*/
|
|
|
|
rb_dlinkAddTail(client_p, &client_p->node, &global_client_list);
|
|
|
|
read_packet(client_p->localClient->F, client_p);
|
|
|
|
}
|
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
/* When this is called we have a decision on client acceptance.
|
|
|
|
*
|
2016-04-25 20:35:58 +00:00
|
|
|
* After this point authd no longer "owns" the client, but if
|
|
|
|
* it's flagged as deferred then we're still waiting for a call
|
|
|
|
* to authd_deferred_client().
|
2016-03-28 07:11:16 +00:00
|
|
|
*/
|
2016-04-02 06:05:21 +00:00
|
|
|
static inline void
|
2016-03-28 07:11:16 +00:00
|
|
|
authd_decide_client(struct Client *client_p, const char *ident, const char *host, bool accept, char cause, const char *data, const char *reason)
|
|
|
|
{
|
2016-04-10 14:20:51 +00:00
|
|
|
if(client_p->preClient == NULL || client_p->preClient->auth.cid == 0)
|
2016-03-28 07:11:16 +00:00
|
|
|
return;
|
|
|
|
|
|
|
|
if(*ident != '*')
|
|
|
|
{
|
|
|
|
rb_strlcpy(client_p->username, ident, sizeof(client_p->username));
|
2016-04-23 14:41:27 +00:00
|
|
|
SetGotId(client_p);
|
2016-04-01 07:43:01 +00:00
|
|
|
ServerStats.is_asuc++;
|
2016-03-28 07:11:16 +00:00
|
|
|
}
|
|
|
|
else
|
2016-04-01 07:43:01 +00:00
|
|
|
ServerStats.is_abad++; /* s_auth used to do this, stay compatible */
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
if(*host != '*')
|
|
|
|
rb_strlcpy(client_p->host, host, sizeof(client_p->host));
|
|
|
|
|
2016-04-10 14:20:51 +00:00
|
|
|
rb_dictionary_delete(cid_clients, RB_UINT_TO_POINTER(client_p->preClient->auth.cid));
|
2016-04-02 08:46:31 +00:00
|
|
|
|
2016-04-10 14:20:51 +00:00
|
|
|
client_p->preClient->auth.accepted = accept;
|
|
|
|
client_p->preClient->auth.cause = cause;
|
|
|
|
client_p->preClient->auth.data = (data == NULL ? NULL : rb_strdup(data));
|
|
|
|
client_p->preClient->auth.reason = (reason == NULL ? NULL : rb_strdup(reason));
|
|
|
|
client_p->preClient->auth.cid = 0;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2016-04-25 20:35:58 +00:00
|
|
|
client_p->preClient->auth.flags |= AUTHC_F_COMPLETE;
|
|
|
|
if((client_p->preClient->auth.flags & AUTHC_F_DEFERRED) == 0)
|
|
|
|
authd_read_client(client_p);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
authd_deferred_client(struct Client *client_p)
|
|
|
|
{
|
|
|
|
client_p->preClient->auth.flags &= ~AUTHC_F_DEFERRED;
|
|
|
|
if(client_p->preClient->auth.flags & AUTHC_F_COMPLETE)
|
|
|
|
authd_read_client(client_p);
|
2016-03-28 07:11:16 +00:00
|
|
|
}
|
|
|
|
|
2016-04-02 06:05:21 +00:00
|
|
|
/* Convenience function to accept client */
|
|
|
|
void
|
|
|
|
authd_accept_client(struct Client *client_p, const char *ident, const char *host)
|
|
|
|
{
|
|
|
|
authd_decide_client(client_p, ident, host, true, '\0', NULL, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Convenience function to reject client */
|
|
|
|
void
|
|
|
|
authd_reject_client(struct Client *client_p, const char *ident, const char *host, char cause, const char *data, const char *reason)
|
|
|
|
{
|
|
|
|
authd_decide_client(client_p, ident, host, false, cause, data, reason);
|
|
|
|
}
|
|
|
|
|
2016-03-28 07:30:54 +00:00
|
|
|
static void
|
|
|
|
timeout_dead_authd_clients(void *notused __unused)
|
|
|
|
{
|
|
|
|
rb_dictionary_iter iter;
|
2016-03-28 23:13:57 +00:00
|
|
|
struct Client *client_p;
|
2016-04-30 06:11:08 +00:00
|
|
|
rb_dlink_list freelist = { NULL, NULL, 0 };
|
|
|
|
rb_dlink_node *ptr, *nptr;
|
2016-03-28 07:30:54 +00:00
|
|
|
|
2016-03-28 23:13:57 +00:00
|
|
|
RB_DICTIONARY_FOREACH(client_p, &iter, cid_clients)
|
2016-03-28 07:30:54 +00:00
|
|
|
{
|
2016-04-10 14:20:51 +00:00
|
|
|
if(client_p->preClient->auth.timeout < rb_current_time())
|
2016-04-30 06:11:08 +00:00
|
|
|
{
|
|
|
|
rb_dlinkAddAlloc(client_p, &freelist);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* RB_DICTIONARY_FOREACH is not safe for deletion, so we do this crap */
|
|
|
|
RB_DLINK_FOREACH_SAFE(ptr, nptr, freelist.head)
|
|
|
|
{
|
|
|
|
client_p = ptr->data;
|
2022-11-06 08:14:15 +00:00
|
|
|
authd_abort_client(client_p);
|
|
|
|
rb_dlinkDestroy(ptr, &freelist);
|
2016-03-28 07:30:54 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-06 03:01:56 +00:00
|
|
|
/* Send a new DNSBL entry to authd */
|
2016-03-28 07:11:16 +00:00
|
|
|
void
|
2020-07-06 03:01:56 +00:00
|
|
|
add_dnsbl_entry(const char *host, const char *reason, uint8_t iptype, rb_dlink_list *filters)
|
2016-03-28 07:11:16 +00:00
|
|
|
{
|
|
|
|
rb_dlink_node *ptr;
|
2023-01-11 01:28:32 +00:00
|
|
|
struct DNSBLEntry *entry = rb_malloc(sizeof(*entry));
|
2016-03-28 21:47:51 +00:00
|
|
|
char filterbuf[BUFSIZE] = "*";
|
2016-03-28 07:11:16 +00:00
|
|
|
size_t s = 0;
|
|
|
|
|
2020-07-06 03:01:56 +00:00
|
|
|
if(dnsbl_stats == NULL)
|
|
|
|
dnsbl_stats = rb_dictionary_create("dnsbl statistics", rb_strcasecmp);
|
2016-04-30 06:11:08 +00:00
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
/* Build a list of comma-separated values for authd.
|
|
|
|
* We don't check for validity - do it elsewhere.
|
|
|
|
*/
|
|
|
|
RB_DLINK_FOREACH(ptr, filters->head)
|
|
|
|
{
|
|
|
|
char *filter = ptr->data;
|
|
|
|
size_t filterlen = strlen(filter) + 1;
|
|
|
|
|
|
|
|
if(s + filterlen > sizeof(filterbuf))
|
|
|
|
break;
|
|
|
|
|
|
|
|
snprintf(&filterbuf[s], sizeof(filterbuf) - s, "%s,", filter);
|
|
|
|
|
|
|
|
s += filterlen;
|
|
|
|
}
|
|
|
|
|
|
|
|
if(s)
|
|
|
|
filterbuf[s - 1] = '\0';
|
|
|
|
|
2023-01-11 01:28:32 +00:00
|
|
|
entry->host = rb_strdup(host);
|
|
|
|
entry->reason = rb_strdup(reason);
|
|
|
|
entry->filters = rb_strdup(filterbuf);
|
|
|
|
entry->iptype = iptype;
|
|
|
|
entry->hits = 0;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
2023-01-11 01:28:32 +00:00
|
|
|
rb_dictionary_add(dnsbl_stats, entry->host, entry);
|
2016-03-28 07:11:16 +00:00
|
|
|
rb_helper_write(authd_helper, "O rbl %s %hhu %s :%s", host, iptype, filterbuf, reason);
|
|
|
|
}
|
|
|
|
|
2020-07-06 03:01:56 +00:00
|
|
|
/* Delete a DNSBL entry. */
|
2016-03-28 07:11:16 +00:00
|
|
|
void
|
2020-07-06 03:01:56 +00:00
|
|
|
del_dnsbl_entry(const char *host)
|
2016-03-28 07:11:16 +00:00
|
|
|
{
|
2023-01-11 01:28:32 +00:00
|
|
|
struct DNSBLEntry *entry = rb_dictionary_retrieve(dnsbl_stats, host);
|
|
|
|
|
|
|
|
if(entry != NULL)
|
2016-04-12 14:33:51 +00:00
|
|
|
{
|
2023-01-11 01:28:32 +00:00
|
|
|
rb_dictionary_delete(dnsbl_stats, entry->host);
|
|
|
|
rb_free(entry->host);
|
|
|
|
rb_free(entry->reason);
|
|
|
|
rb_free(entry->filters);
|
|
|
|
rb_free(entry);
|
2016-04-12 14:33:51 +00:00
|
|
|
}
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
rb_helper_write(authd_helper, "O rbl_del %s", host);
|
|
|
|
}
|
|
|
|
|
2016-04-30 06:11:08 +00:00
|
|
|
static void
|
2020-07-06 03:01:56 +00:00
|
|
|
dnsbl_delete_elem(rb_dictionary_element *delem, void *unused)
|
2016-04-30 06:11:08 +00:00
|
|
|
{
|
2023-01-11 01:28:32 +00:00
|
|
|
struct DNSBLEntry *entry = delem->data;
|
2016-04-30 06:11:08 +00:00
|
|
|
|
2023-01-11 01:28:32 +00:00
|
|
|
rb_free(entry->host);
|
|
|
|
rb_free(entry->reason);
|
|
|
|
rb_free(entry->filters);
|
|
|
|
rb_free(entry);
|
2016-04-30 06:11:08 +00:00
|
|
|
}
|
|
|
|
|
2020-07-06 03:01:56 +00:00
|
|
|
/* Delete all the DNSBL entries. */
|
2016-03-28 07:11:16 +00:00
|
|
|
void
|
2020-07-06 03:01:56 +00:00
|
|
|
del_dnsbl_entry_all(void)
|
2016-03-28 07:11:16 +00:00
|
|
|
{
|
2020-07-06 03:01:56 +00:00
|
|
|
if(dnsbl_stats != NULL)
|
|
|
|
rb_dictionary_destroy(dnsbl_stats, dnsbl_delete_elem, NULL);
|
|
|
|
dnsbl_stats = NULL;
|
2016-03-28 07:11:16 +00:00
|
|
|
|
|
|
|
rb_helper_write(authd_helper, "O rbl_del_all");
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Adjust an authd timeout value */
|
2016-04-01 07:43:01 +00:00
|
|
|
bool
|
2016-03-28 07:11:16 +00:00
|
|
|
set_authd_timeout(const char *key, int timeout)
|
|
|
|
{
|
2016-04-01 07:43:01 +00:00
|
|
|
if(timeout <= 0)
|
|
|
|
return false;
|
|
|
|
|
2016-03-28 07:11:16 +00:00
|
|
|
rb_helper_write(authd_helper, "O %s %d", key, timeout);
|
2016-04-01 07:43:01 +00:00
|
|
|
return true;
|
2016-03-28 07:11:16 +00:00
|
|
|
}
|
2016-03-28 07:42:20 +00:00
|
|
|
|
2016-04-01 07:43:01 +00:00
|
|
|
/* Enable identd checks */
|
2016-03-28 07:42:20 +00:00
|
|
|
void
|
|
|
|
ident_check_enable(bool enabled)
|
|
|
|
{
|
|
|
|
rb_helper_write(authd_helper, "O ident_enabled %d", enabled ? 1 : 0);
|
|
|
|
}
|
2016-04-01 07:43:01 +00:00
|
|
|
|
2016-04-12 14:33:51 +00:00
|
|
|
/* Create an OPM listener
|
|
|
|
* XXX - This is a big nasty hack, but it avoids resending duplicate data when
|
|
|
|
* configure_authd() is called.
|
|
|
|
*/
|
|
|
|
void
|
|
|
|
conf_create_opm_listener(const char *ip, uint16_t port)
|
|
|
|
{
|
|
|
|
char ipbuf[HOSTIPLEN];
|
|
|
|
struct OPMListener *listener;
|
|
|
|
|
|
|
|
rb_strlcpy(ipbuf, ip, sizeof(ipbuf));
|
|
|
|
if(ipbuf[0] == ':')
|
|
|
|
{
|
|
|
|
memmove(ipbuf + 1, ipbuf, sizeof(ipbuf) - 1);
|
|
|
|
ipbuf[0] = '0';
|
|
|
|
}
|
|
|
|
|
|
|
|
/* I am much too lazy to use rb_inet_pton and GET_SS_FAMILY for now --Elizafox */
|
|
|
|
listener = &opm_listeners[(strchr(ipbuf, ':') != NULL ? LISTEN_IPV6 : LISTEN_IPV4)];
|
|
|
|
rb_strlcpy(listener->ipaddr, ipbuf, sizeof(listener->ipaddr));
|
|
|
|
listener->port = port;
|
|
|
|
}
|
|
|
|
|
2016-04-02 06:05:21 +00:00
|
|
|
void
|
2016-04-01 07:56:03 +00:00
|
|
|
create_opm_listener(const char *ip, uint16_t port)
|
2016-04-01 07:43:01 +00:00
|
|
|
{
|
2016-04-03 00:28:19 +00:00
|
|
|
char ipbuf[HOSTIPLEN];
|
2016-04-12 14:33:51 +00:00
|
|
|
|
|
|
|
/* XXX duplicated in conf_create_opm_listener */
|
2016-04-03 00:28:19 +00:00
|
|
|
rb_strlcpy(ipbuf, ip, sizeof(ipbuf));
|
|
|
|
if(ipbuf[0] == ':')
|
|
|
|
{
|
|
|
|
memmove(ipbuf + 1, ipbuf, sizeof(ipbuf) - 1);
|
|
|
|
ipbuf[0] = '0';
|
|
|
|
}
|
|
|
|
|
2016-04-12 14:33:51 +00:00
|
|
|
conf_create_opm_listener(ip, port);
|
2016-04-12 14:37:56 +00:00
|
|
|
rb_helper_write(authd_helper, "O opm_listener %s %hu", ipbuf, port);
|
2016-04-12 14:33:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
delete_opm_listener_all(void)
|
|
|
|
{
|
|
|
|
memset(&opm_listeners, 0, sizeof(opm_listeners));
|
|
|
|
rb_helper_write(authd_helper, "O opm_listener_del_all");
|
2016-04-02 06:05:21 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Disable all OPM scans */
|
|
|
|
void
|
|
|
|
opm_check_enable(bool enabled)
|
|
|
|
{
|
2016-04-03 00:45:27 +00:00
|
|
|
rb_helper_write(authd_helper, "O opm_enabled %d", enabled ? 1 : 0);
|
2016-04-02 06:05:21 +00:00
|
|
|
}
|
|
|
|
|
2016-04-12 14:33:51 +00:00
|
|
|
/* Create an OPM proxy scanner
|
|
|
|
* XXX - This is a big nasty hack, but it avoids resending duplicate data when
|
|
|
|
* configure_authd() is called.
|
|
|
|
*/
|
|
|
|
void
|
|
|
|
conf_create_opm_proxy_scanner(const char *type, uint16_t port)
|
|
|
|
{
|
|
|
|
struct OPMScanner *scanner = rb_malloc(sizeof(struct OPMScanner));
|
|
|
|
|
|
|
|
rb_strlcpy(scanner->type, type, sizeof(scanner->type));
|
|
|
|
scanner->port = port;
|
|
|
|
rb_dlinkAdd(scanner, &scanner->node, &opm_list);
|
|
|
|
}
|
|
|
|
|
2016-04-02 06:05:21 +00:00
|
|
|
void
|
2016-04-02 07:29:48 +00:00
|
|
|
create_opm_proxy_scanner(const char *type, uint16_t port)
|
2016-04-02 06:05:21 +00:00
|
|
|
{
|
2016-04-12 14:33:51 +00:00
|
|
|
conf_create_opm_proxy_scanner(type, port);
|
2016-04-02 07:29:48 +00:00
|
|
|
rb_helper_write(authd_helper, "O opm_scanner %s %hu", type, port);
|
2016-04-01 07:43:01 +00:00
|
|
|
}
|
2016-04-03 00:45:27 +00:00
|
|
|
|
|
|
|
void
|
|
|
|
delete_opm_proxy_scanner(const char *type, uint16_t port)
|
|
|
|
{
|
2016-04-12 14:33:51 +00:00
|
|
|
rb_dlink_node *ptr, *nptr;
|
|
|
|
|
|
|
|
RB_DLINK_FOREACH_SAFE(ptr, nptr, opm_list.head)
|
|
|
|
{
|
|
|
|
struct OPMScanner *scanner = ptr->data;
|
|
|
|
|
|
|
|
if(rb_strncasecmp(scanner->type, type, sizeof(scanner->type)) == 0 &&
|
|
|
|
scanner->port == port)
|
|
|
|
{
|
|
|
|
rb_dlinkDelete(ptr, &opm_list);
|
|
|
|
rb_free(scanner);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-04-03 00:45:27 +00:00
|
|
|
rb_helper_write(authd_helper, "O opm_scanner_del %s %hu", type, port);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
delete_opm_proxy_scanner_all(void)
|
|
|
|
{
|
2016-04-12 14:33:51 +00:00
|
|
|
rb_dlink_node *ptr, *nptr;
|
|
|
|
|
|
|
|
RB_DLINK_FOREACH_SAFE(ptr, nptr, opm_list.head)
|
|
|
|
{
|
|
|
|
struct OPMScanner *scanner = ptr->data;
|
|
|
|
|
|
|
|
rb_dlinkDelete(ptr, &opm_list);
|
|
|
|
rb_free(scanner);
|
|
|
|
}
|
|
|
|
|
2016-04-03 00:45:27 +00:00
|
|
|
rb_helper_write(authd_helper, "O opm_scanner_del_all");
|
|
|
|
}
|