lib/eggdrop/net.c File Reference

#include <eggdrop/eggdrop.h>

Go to the source code of this file.

Data Structures
struct	connect_info
Defines
#define	EGGNET_LEVEL   (SOCKBUF_LEVEL_INTERNAL+1)
Typedefs
typedef struct connect_info	connect_info_t
Functions
static int	connect_host_resolved (void *client_data, const char *host, char **ips)
static int	egg_connect_timeout (void *client_data)
static int	egg_on_connect (void *client_data, int idx, const char *peer_ip, int peer_port)
static int	egg_on_eof (void *client_data, int idx, int err, const char *errmsg)
static int	egg_on_delete (void *client_data, int idx)
static connect_info_t *	attach (int idx, const char *host, int port, int timeout)
static int	detach (void *client_data, int idx)
int	egg_net_init (void)
int	egg_net_shutdown (void)
int	egg_iprintf (int idx, const char *format,...)
int	egg_server (const char *vip, int port, int *real_port)
int	egg_client (int idx, const char *host, int port, const char *vip, int vport, int timeout)
int	egg_listen (int port, int *real_port)
int	egg_reconnect (int idx, const char *host, int port, int timeout)
int	egg_connect (const char *host, int port, int timeout)
int	egg_proxy_add (egg_proxy_t *proxy)
int	egg_proxy_del (egg_proxy_t *proxy)
egg_proxy_t *	egg_proxy_lookup (const char *name)
int	egg_proxy_set_default (const char *name)
const char *	egg_proxy_get_default ()
Variables
static const char	rcsid [] = "$Id: net.c,v 1.7 2006-09-12 01:50:50 sven Exp $"
static sockbuf_filter_t	net_connect_filter
static char *	default_proxy_name = NULL
static int	default_timeout = 30
static egg_proxy_t **	proxies = NULL
static int	nproxies = 0

---

Define Documentation

#define EGGNET_LEVEL   (SOCKBUF_LEVEL_INTERNAL+1)

Definition at line 26 of file net.c.

Referenced by connect_host_resolved(), egg_connect_timeout(), egg_on_connect(), and egg_on_eof().

---

Typedef Documentation

typedef struct connect_info connect_info_t

---

Function Documentation

static connect_info_t * attach	(	int	idx,
		const char *	host,
		int	port,
		int	timeout
	)			[static]

Definition at line 240 of file net.c.

References default_timeout, connect_info::dns_id, egg_connect_timeout(), connect_info::idx, NULL, connect_info::port, egg_timeval::sec, sockbuf_attach_filter(), timer_create_complex(), connect_info::timer_id, and egg_timeval::usec.

Referenced by egg_client(), and egg_reconnect().

{
  connect_info_t *connect_info = calloc(1, sizeof(*connect_info));

  connect_info->port = port;
  connect_info->idx = idx;
  connect_info->dns_id = -1;
  connect_info->timer_id = -1;
  sockbuf_attach_filter(connect_info->idx, &net_connect_filter, connect_info);
  if (timeout == 0) timeout = default_timeout;
  if (timeout > 0) {
    char buf[128];
    egg_timeval_t howlong;

    snprintf(buf, sizeof(buf), "idx %d to %s/%d", idx, host, port);
    howlong.sec = timeout;
    howlong.usec = 0;
    connect_info->timer_id = timer_create_complex(&howlong, buf, egg_connect_timeout, connect_info, 0, NULL);
  }
  return(connect_info);
}

static int connect_host_resolved	(	void *	client_data,
		const char *	host,
		char **	ips
	)			[static]

Definition at line 166 of file net.c.

References detach(), connect_info::dns_id, EGGNET_LEVEL, connect_info::idx, NULL, connect_info::port, SOCKBUF_CLIENT, SOCKBUF_CONNECTING, sockbuf_on_eof(), sockbuf_set_sock(), SOCKET_CLIENT, socket_create(), SOCKET_NONBLOCK, and SOCKET_TCP.

Referenced by egg_client().

{
  connect_info_t *connect_info = client_data;
  int sock, idx;

  connect_info->dns_id = -1;

  if (!ips || !ips[0]) {
    idx = connect_info->idx;
    detach(client_data, idx);
    sockbuf_on_eof(idx, EGGNET_LEVEL, -1, "Could not resolve host");
    return(0);
  }

  sock = socket_create(ips[0], connect_info->port, NULL, 0, SOCKET_CLIENT|SOCKET_TCP|SOCKET_NONBLOCK);
  if (sock < 0) {
    idx = connect_info->idx;
    detach(client_data, idx);
    sockbuf_on_eof(idx, EGGNET_LEVEL, -1, "Could not create socket");
    return(0);
  }

  /* Put this socket into the original sockbuf as a client. This allows
   * its connect event to trigger. We don't detach() from it yet, since
   * we provide the timeout services. */
  sockbuf_set_sock(connect_info->idx, sock, SOCKBUF_CLIENT|SOCKBUF_CONNECTING);
  return(0);
}

static int detach	(	void *	client_data,
		int	idx
	)			[static]

Definition at line 262 of file net.c.

References NULL, sockbuf_detach_filter(), timer_destroy(), and connect_info::timer_id.

Referenced by connect_host_resolved(), egg_connect_timeout(), egg_on_connect(), and egg_on_eof().

{
  connect_info_t *connect_info = client_data;

  if (connect_info->timer_id != -1) timer_destroy(connect_info->timer_id);
  sockbuf_detach_filter(idx, &net_connect_filter, NULL);
  free(connect_info);
  return(0);
}

int egg_client	(	int	idx,
		const char *	host,
		int	port,
		const char *	vip,
		int	vport,
		int	timeout
	)

Definition at line 106 of file net.c.

References attach(), connect_host_resolved(), connect_info::dns_id, egg_dns_lookup(), NULL, and sockbuf_new().

Referenced by egg_reconnect(), http_reconnect(), and socks5_reconnect().

{
  connect_info_t *connect_info;

  /* If they don't have their own idx (-1), create one. */
  if (idx < 0) idx = sockbuf_new();

  /* Resolve the hostname. */
  connect_info = attach(idx, host, port, timeout);
  connect_info->dns_id = egg_dns_lookup(host, -1, connect_host_resolved, connect_info, NULL);
  return(idx);
}

int egg_connect	(	const char *	host,
		int	port,
		int	timeout
	)

Definition at line 155 of file net.c.

References egg_reconnect(), and sockbuf_new().

Referenced by connect_to_next_server(), dcc_accept_send(), do_link(), egg_ident_lookup(), got_chat_request(), and script_net_open().

{
  int idx;

  idx = sockbuf_new();
  egg_reconnect(idx, host, port, timeout);
  return(idx);
}

static int egg_connect_timeout

(

void *

client_data

)

[static]

Definition at line 196 of file net.c.

References detach(), connect_info::dns_id, egg_dns_cancel(), EGGNET_LEVEL, connect_info::idx, sockbuf_on_eof(), and connect_info::timer_id.

Referenced by attach().

{
  connect_info_t *connect_info = client_data;
  int idx, dns_id;

  idx = connect_info->idx;
  dns_id = connect_info->dns_id;
  connect_info->timer_id = -1;
  if (dns_id != -1) {
    /* dns_cancel will call connect_host_resolved for us, which
     * will filter up a "dns failed" error. */
    egg_dns_cancel(dns_id, 1);
  }
  else {
    detach(client_data, idx);
    sockbuf_on_eof(idx, EGGNET_LEVEL, -1, "Connect timed out");
  }
  return(0);
}

int egg_iprintf	(	int	idx,
		const char *	format,
			...
	)

Definition at line 68 of file net.c.

References egg_mvsprintf(), and sockbuf_write().

Referenced by dcc_on_connect(), dcc_on_read(), do_ping(), got_join(), got_mode(), got_nlinked(), got_part(), got_passreq(), got_ping(), got_privmsg(), got_version(), got_who(), http_on_connect(), ident_on_connect(), idx_on_connect(), irc_greet(), irc_on_newclient(), irc_on_read(), oldbotnet_on_connect(), on_bcast(), on_botbroadcast(), on_botmsg(), on_chanmsg(), on_extension(), on_join(), on_link(), on_login(), on_lost_bot(), on_new_bot(), on_nick(), on_part(), on_privmsg(), on_quit(), on_unlink(), partyline_idx_chanmsg(), partyline_idx_join(), partyline_idx_nick(), partyline_idx_part(), partyline_idx_privmsg(), partyline_idx_quit(), process_results(), recving_login(), sending_login(), telnet_on_newclient(), and telnet_on_read().

{
  char *ptr, buf[1024];
  int len;
  va_list args;

  va_start(args, format);
  ptr = egg_mvsprintf(buf, sizeof(buf), &len, format, args);
  va_end(args);
  sockbuf_write(idx, ptr, len);
  if (ptr != buf) free(ptr);
  return(len);
}

int egg_listen	(	int	port,
		int *	real_port
	)

Definition at line 121 of file net.c.

References egg_server(), and NULL.

Referenced by dcc_listen(), and script_net_listen().

{
  int idx;

  /* Proxy/firewall/vhost code goes here. */
  idx = egg_server(NULL, port, real_port);
  return(idx);
}

int egg_net_init

(

void

)

Definition at line 53 of file net.c.

References egg_dns_init(), and sockbuf_init().

Referenced by eggdrop_init().

{
  if (egg_dns_init() != 0)
    return (-1);
  return sockbuf_init();
}

int egg_net_shutdown

(

void

)

Definition at line 60 of file net.c.

References egg_dns_shutdown(), and sockbuf_shutdown().

Referenced by eggdrop_shutdown().

{
  if (egg_dns_shutdown() != 0)
    ;
  return sockbuf_shutdown();
}

static int egg_on_connect	(	void *	client_data,
		int	idx,
		const char *	peer_ip,
		int	peer_port
	)			[static]

Definition at line 217 of file net.c.

References detach(), EGGNET_LEVEL, and sockbuf_on_connect().

{
  detach(client_data, idx);
  sockbuf_on_connect(idx, EGGNET_LEVEL, peer_ip, peer_port);
  return(0);
}

static int egg_on_delete	(	void *	client_data,
		int	idx
	)			[static]

Definition at line 230 of file net.c.

References connect_info::dns_id, egg_dns_cancel(), timer_destroy(), and connect_info::timer_id.

{
  connect_info_t *connect_info = client_data;

  if (connect_info->dns_id != -1) egg_dns_cancel(connect_info->dns_id, 0);
  if (connect_info->timer_id != -1) timer_destroy(connect_info->timer_id);
  free(connect_info);
  return(0);
}

static int egg_on_eof	(	void *	client_data,
		int	idx,
		int	err,
		const char *	errmsg
	)			[static]

Definition at line 224 of file net.c.

References detach(), EGGNET_LEVEL, and sockbuf_on_eof().

{
  detach(client_data, idx);
  return sockbuf_on_eof(idx, EGGNET_LEVEL, err, errmsg);
}

int egg_proxy_add

(

egg_proxy_t *

proxy

)

Definition at line 280 of file net.c.

References nproxies.

Referenced by proxy_init().

{
  proxies = realloc(proxies, (nproxies+1) * sizeof(*proxies));
  proxies[nproxies++] = proxy;
  return(0);
}

int egg_proxy_del

(

egg_proxy_t *

proxy

)

Definition at line 287 of file net.c.

References nproxies.

{
  int i;

  for (i = 0; i < nproxies; i++) {
    if (proxies[i] == proxy) break;
  }
  if (i == nproxies) return(-1);
  memmove(proxies+i, proxies+i+1, (nproxies-i-1) * sizeof(*proxies));
  nproxies--;
  return(0);
}

const char* egg_proxy_get_default

(

)

Definition at line 316 of file net.c.

References default_proxy_name.

{
  return(default_proxy_name);
}

egg_proxy_t* egg_proxy_lookup

(

const char *

name

)

Definition at line 300 of file net.c.

References nproxies, and NULL.

Referenced by egg_reconnect().

{
  int i;

  for (i = 0; i < nproxies; i++) {
    if (proxies[i]->name && !strcasecmp(proxies[i]->name, name)) return(proxies[i]);
  }
  return(NULL);
}

int egg_proxy_set_default

(

const char *

name

)

Definition at line 310 of file net.c.

References default_proxy_name, and str_redup().

Referenced by on_proxy_set(), and proxy_init().

{
  str_redup(&default_proxy_name, name);
  return(0);
}

int egg_reconnect	(	int	idx,
		const char *	host,
		int	port,
		int	timeout
	)

Definition at line 132 of file net.c.

References attach(), default_proxy_name, egg_client(), egg_proxy_lookup(), LOG_MISC, NULL, putlog(), and egg_proxy_t::reconnect.

Referenced by egg_connect(), and got_accept().

{
  egg_proxy_t *proxy;

  if (!default_proxy_name) return egg_client(idx, host, port, NULL, 0, timeout);

  /* If there is a proxy configured, send this request to the right
   * handler. */
  proxy = egg_proxy_lookup(default_proxy_name);
  if (!proxy) {
    putlog(LOG_MISC, "*", "Proxy '%s' selected but not loaded!", default_proxy_name);
    putlog(LOG_MISC, "*", "Trying to connect without proxy.");
    return egg_client(idx, host, port, NULL, 0, timeout);
  }

  /* Ok, so we will connect through the selected proxy. But we still have
   * to set up the timeout handler (to avoid duplication of code in the
   * proxy handlers) if they want one. */
  if (timeout > 0) attach(idx, host, port, timeout);
  proxy->reconnect(idx, host, port);
  return(0);
}

int egg_server	(	const char *	vip,
		int	port,
		int *	real_port
	)

Definition at line 83 of file net.c.

References NULL, sockbuf_new(), SOCKBUF_SERVER, sockbuf_set_sock(), socket_create(), socket_get_name(), SOCKET_NONBLOCK, SOCKET_SERVER, and SOCKET_TCP.

Referenced by bot_init(), egg_listen(), irc_init(), and telnet_init().

{
  int idx, sock, ntries;

  ntries = 0;
  do {
    sock = socket_create(NULL, 0, vip, port+ntries, SOCKET_SERVER|SOCKET_TCP|SOCKET_NONBLOCK);
    ntries++;
  } while (sock < 0 && ntries < 20 && port);

  if (sock < 0) return(sock);

  if (real_port) socket_get_name(sock, NULL, real_port);

  idx = sockbuf_new();
  sockbuf_set_sock(idx, sock, SOCKBUF_SERVER);

  return(idx);
}

---

Variable Documentation

char* default_proxy_name = NULL [static]

Definition at line 50 of file net.c.

Referenced by egg_proxy_get_default(), egg_proxy_set_default(), and egg_reconnect().

int default_timeout = 30 [static]

Definition at line 51 of file net.c.

Referenced by attach().

sockbuf_filter_t net_connect_filter [static]

Initial value:

 {
  "connect", EGGNET_LEVEL,
  egg_on_connect, egg_on_eof, NULL,
  NULL, NULL, NULL,
  NULL, egg_on_delete
}

Definition at line 43 of file net.c.

int nproxies = 0 [static]

Definition at line 278 of file net.c.

Referenced by egg_proxy_add(), egg_proxy_del(), and egg_proxy_lookup().

egg_proxy_t** proxies = NULL [static]

Definition at line 277 of file net.c.

const char rcsid[] = "$Id: net.c,v 1.7 2006-09-12 01:50:50 sven Exp $" [static]

Definition at line 21 of file net.c.