modules/server/server.c File Reference

#include "server.h"

Go to the source code of this file.

Functions
int	server_script_init ()
int	server_script_destroy ()
void	connect_to_next_server ()
void	dequeue_messages ()
int	server_support (const char *name, const char **value)
static int	server_secondly ()
static int	server_status (partymember_t *p, const char *text)
static int	server_config_save (const char *handle)
static int	server_close (int why)
static void	server_config_init ()
EXPORT_SCOPE int	start (egg_module_t *modinfo)
Variables
static const char	rcsid [] = "$Id: server.c,v 1.68 2007-09-13 22:20:57 sven Exp $"
current_server_t	current_server = {0}
server_config_t	server_config = {0}
event_owner_t	server_owner
int	cycle_delay = 0
bind_list_t	server_raw_binds []
bind_list_t	server_party_commands []
static config_var_t	server_config_vars []

---

Function Documentation

void connect_to_next_server

(

)

Definition at line 44 of file servsock.c.

                              {
  server_t *serv;

  serv = server_get_next();
  if (!serv) {
    putlog(LOG_MISC, "*", _("Error connecting to next server: no servers are defined!"));
    return;
  }

  str_redup(&current_server.server_host, serv->host);
  str_redup(&current_server.server_self, serv->host);
  str_redup(&current_server.pass, serv->pass);
  current_server.strcmp = strcasecmp;
  if (!server_config.fake005) server_config.fake005 = strdup(":fakeserver 005 fakenick MODES=3 MAXCHANNELS=10 MAXBANS=100 NICKLEN=9 TOPICLEN=307 KICKLEN=307 CHANTYPES=#& PREFIX=(ov)@+ NETWORK=fakenetwork CASEMAPPING=rfc1459 CHANMODES=b,k,l,imnprst :are available on this server");

  if (serv->port) current_server.port = serv->port;
  else current_server.port = server_config.default_port;

  putlog(LOG_SERV, "*", _("Connecting to %s (%d)."), current_server.server_host, current_server.port);
  current_server.idx = egg_connect(current_server.server_host, current_server.port, server_config.connect_timeout);
  if (current_server.idx < 0) {
    putlog(LOG_SERV, "*", _("Error connecting to server."));
  }
  sockbuf_set_handler(current_server.idx, &server_handler, NULL, NULL);
}

void dequeue_messages

(

)

Definition at line 213 of file output.c.

References do_output(), NULL, queue_append, queue_entry_cleanup, queue_entry_to_text, queue_t::queue_head, and queue_unlink.

{
  queue_entry_t *q;
  queue_t *queue = NULL;
  int i, remaining, len;
  char *text, buf[1024];

  /* Choose which queue to select from. */
  for (i = 0; i < 3; i++) {
    if (output_queues[i+3].queue_head) {
      queue = output_queues+i+3;
      break;
    }
    if (output_queues[i].queue_head) {
      queue = output_queues+i;
      break;
    }
  }

  /* No messages to dequeue? */
  if (!queue) return;

  q = queue->queue_head;

  /* Remove it from the queue. */
  queue_unlink(queue, q);

  /* Construct an irc message out of it. */
  text = buf;
  remaining = sizeof(buf);
  queue_entry_to_text(q, text, &remaining);

  /* Now we're done with q, so free anything we need to free and store it
   * in the unused queue. */
  queue_entry_cleanup(q);
  queue_append(&unused_queue, q);

  /* Make sure last 2 chars are \r\n and there's a space left for \0. */
  if (remaining < 3) remaining = 3;
  len = sizeof(buf) - remaining;
  buf[len++] = '\r';
  buf[len++] = '\n';
  buf[len] = 0;

  do_output(buf, len);
}

static int server_close

(

int

why

)

[static]

Definition at line 230 of file server.c.

References _, bind_rem_list(), bind_rem_simple(), channel_destroy, channel_events_destroy, config_get_root(), config_root, config_unlink_table(), cycle_delay, kill_server, nick_clear, NULL, server_binds_destroy, server_clear, server_config_save(), server_script_destroy, server_secondly(), server_status(), and uhost_cache_destroy.

{
  void *config_root;

  kill_server(_("server module unloading"));
  cycle_delay = 100;

  config_root = config_get_root("eggdrop");
  config_unlink_table(server_config_vars, config_root, "server", 0, NULL);

  bind_rem_list("raw", server_raw_binds);
  //bind_rem_list("party", server_party_commands);
  bind_rem_simple("secondly", NULL, NULL, server_secondly);
  bind_rem_simple("status", NULL, NULL, server_status);
  bind_rem_simple("config_save", NULL, "eggdrop", server_config_save);

  /* Clear the server and nick lists. */
  server_clear();
  nick_clear();

  server_binds_destroy();

  channel_destroy();
  channel_events_destroy();
  uhost_cache_destroy();

  server_script_destroy();

  return(0);
}

static void server_config_init

(

)

[static]

Definition at line 261 of file server.c.

References server_config_t::chanfile, server_config_t::chaninfo_items, config_exists(), config_get_int(), config_get_root(), config_get_str(), config_link_table(), config_root, config_update_table(), server_config_t::connect_timeout, server_config_t::cycle_delay, server_config_t::dcc_timeout, server_config_t::default_port, server_config_t::fake005, server_config_t::keepnick, server_config_t::max_line_len, nick_add, NULL, server_config_t::ping_timeout, server_config_t::realname, server_add, server_config_t::trigger_on_ignore, and server_config_t::user.

{
  int i;
  char *host, *pass, *nickstr;
  int port;
  void *config_root, *server, *nick, *list;

  /* Set default values. */
  server_config.chanfile = strdup("channels.xml");
  server_config.user = strdup("user");
  server_config.realname = strdup("real name");
  server_config.connect_timeout = 30;
  server_config.ping_timeout = 30;
  server_config.dcc_timeout = 30;
  server_config.trigger_on_ignore = 0;
  server_config.keepnick = 0;
  server_config.cycle_delay = 10;
  server_config.default_port = 6667;
  server_config.fake005 = NULL;
  server_config.max_line_len = 510;
  server_config.chaninfo_items = strdup("Inactive");

  /* Link our config vars. */
  config_root = config_get_root("eggdrop");
  config_link_table(server_config_vars, config_root, "server", 0, NULL);
  config_update_table(server_config_vars, config_root, "server", 0, NULL);

  /* Get the server list. */
  list = config_exists(config_root, "server", 0, "serverlist", 0, NULL);
  for (i = 0; (server = config_exists(list, "server", i, NULL)); i++) {
    host = pass = NULL;
    port = 0;
    config_get_str(&host, server, "host", 0, NULL);
    config_get_str(&pass, server, "pass", 0, NULL);
    config_get_int(&port, server, "port", 0, NULL);
    if (host) server_add(host, port, pass);
  }

  /* And the nick list. */
  list = config_exists(config_root, "server", 0, "nicklist", 0, NULL);
  for (i = 0; (nick = config_exists(list, "nick", i, NULL)); i++) {
    nickstr = NULL;
    config_get_str(&nickstr, nick, NULL);
    if (nickstr) nick_add(nickstr);
  }
}

static int server_config_save

(

const char *

handle

)

[static]

Definition at line 163 of file server.c.

References server_config_t::chanfile, channel_save, config_destroy(), config_exists(), config_get_root(), config_lookup_section(), config_set_int(), config_set_str(), server::host, LOG_MISC, server::next, nick_list, nick_list_len, NULL, server::pass, server::port, putlog(), and server_list.

Referenced by server_close().

{
  server_t *server;
  void *root, *list, *node;
  int i;

  putlog(LOG_MISC, "*", "Saving server config...");
  root = config_get_root("eggdrop");

  /* Erase the server list. */
  list = config_exists(root, "server.serverlist", 0, NULL);
  if (list) config_destroy(list);

  /* Save the server list. */
  list = config_lookup_section(root, "server.serverlist", 0, NULL);
  i = 0;
  for (server = server_list; server; server = server->next) {
    node = config_lookup_section(list, "server", i, NULL);
    config_set_str(server->host, node, "host", 0, NULL);
    config_set_str(server->pass, node, "pass", 0, NULL);
    config_set_int(server->port, node, "port", 0, NULL);
    i++;
  }

  /* Erase the nick list. */
  list = config_exists(root, "server.nicklist", 0, NULL);
  if (list) config_destroy(list);

  /* Save the nick list. */
  list = config_lookup_section(root, "server.nicklist", 0, NULL);
  for (i = 0; i < nick_list_len; i++) {
    config_set_str(nick_list[i], list, "nick", i, NULL);
  }

  /* Save the channel file. */
  putlog(LOG_MISC, "*", "Saving channels file...");
  channel_save(server_config.chanfile);
  return(0);
}

int server_script_destroy

(

)

Definition at line 456 of file scriptcmds.c.

References script_delete_commands(), and script_unlink_vars().

{
  script_delete_commands(server_script_cmds);
  script_unlink_vars(server_script_vars);
  return(0);
}

int server_script_init

(

)

Definition at line 449 of file scriptcmds.c.

References script_create_commands(), and script_link_vars().

{
  script_create_commands(server_script_cmds);
  script_link_vars(server_script_vars);
  return(0);
}

static int server_secondly

(

)

[static]

Definition at line 71 of file server.c.

References connect_to_next_server, cycle_delay, dequeue_messages, current_server_t::idx, kill_server, current_server_t::last_ping_sent, current_server_t::last_ping_time, now, current_server_t::ping_id, server_config_t::ping_timeout, printserv, egg_timeval::sec, SERVER_NOQUEUE, current_server_t::time_to_ping, timer_diff(), timer_get_time(), and egg_timeval::usec.

Referenced by server_close().

{
  if (current_server.idx < 0 && cycle_delay >= 0) {
    /* If there's no idx, see if it's time to jump to the next
     * server. */
    cycle_delay--;
    if (cycle_delay <= 0) {
      cycle_delay = -1;
      connect_to_next_server();
    }
    return(0);
  }

  /* Try to dequeue some stuff. */
  dequeue_messages();

  /* Check to see if we're pinged out once in a while. */
  if (current_server.idx >= 0) {
    if (current_server.time_to_ping == 0) {
      egg_timeval_t now, diff;

      timer_get_time(&now);
      timer_diff(&current_server.last_ping_sent, &now, &diff);

      /* Update ping time if it surpasses the old one, even
       * though we haven't received the actual ping reply. */
      if (diff.sec > current_server.last_ping_time.sec || (diff.sec <= current_server.last_ping_time.sec && diff.usec > current_server.last_ping_time.usec)) {
        current_server.last_ping_time = diff;
      }
      if (diff.sec >= server_config.ping_timeout) {
        kill_server("ping timeout");
      }
    }
    else if (current_server.time_to_ping > 0) {
      current_server.time_to_ping--;
      if (current_server.time_to_ping == 0) {
        current_server.ping_id = random();
        timer_get_time(&current_server.last_ping_sent);
        printserv(SERVER_NOQUEUE, "PING :%d", current_server.ping_id);
      }
    }
  }
  return(0);
}

static int server_status	(	partymember_t *	p,
		const char *	text
	)			[static]

Definition at line 116 of file server.c.

References _, sockbuf_stats_t::bytes_in, sockbuf_stats_t::bytes_out, channel_head, current_server_t::connected, cycle_delay, current_server_t::host, current_server_t::idx, current_server_t::last_ping_time, channel::name, channel::next, current_server_t::nick, channel::nmembers, current_server_t::npings, partymember_printf(), current_server_t::port, sockbuf_stats_t::raw_bytes_in, sockbuf_stats_t::raw_bytes_out, current_server_t::real_name, current_server_t::registered, egg_timeval::sec, current_server_t::server_host, current_server_t::server_self, sockbuf_get_stats(), current_server_t::time_to_ping, egg_timeval::usec, and current_server_t::user.

Referenced by server_close().

{
  int details = 0;
  channel_t *chan;

  if (text) {
    if (!strcasecmp(text, "all") || !strcasecmp(text, "server")) details = 1;
    else if (*text) return(0);
  }

  partymember_printf(p, "Server module:");
  if (!current_server.connected) {
    if (current_server.idx >= 0) partymember_printf(p, _("   Connecting to server %s/%d."), current_server.server_host, current_server.port);
    else partymember_printf(p, _("   Connecting to next server in %d seconds."), cycle_delay);
    return(0);
  }

  /* First line, who we've connected to. */
  partymember_printf(p, _("   Connected to %s/%d."), current_server.server_self ? current_server.server_self : current_server.server_host, current_server.port);

  /* Second line, who we're connected as. */
  if (current_server.registered) {
    if (current_server.user) partymember_printf(p, _("   Online as %s!%s@%s (%s)."), current_server.nick, current_server.user, current_server.host, current_server.real_name);
    else partymember_printf(p, _("   Online as %s (still waiting for WHOIS result)."), current_server.nick);
  }
  else partymember_printf(p, _("   Still logging in."));

  /* Third line, ping time. */
  if (current_server.time_to_ping >= 0 && current_server.npings > 0) {
    partymember_printf(p, _("   Last server ping %d.%03d seconds"), current_server.last_ping_time.sec, current_server.last_ping_time.usec / 1000);
  }

  /* Print the channel list if we have one. */
  for (chan = channel_head; chan; chan = chan->next) {
    partymember_printf(p, "   %s : %d member%s", chan->name, chan->nmembers, chan->nmembers == 1 ? "" : "s");
  }

  /* Some traffic stats. */
  if (details) {
    sockbuf_stats_t *stats;

    sockbuf_get_stats(current_server.idx, &stats);
    partymember_printf(p, "   Server traffic: %lld in / %lld out (raw), %lld in / %lld out (filtered)", stats->raw_bytes_in, stats->raw_bytes_out, stats->bytes_in, stats->bytes_out);
  }
  return(0);
}

int server_support	(	const char *	name,
		const char **	value
	)

Definition at line 53 of file server.c.

References current_server_t::name, current_server_t::nsupport, NULL, current_server_t::support, and current_server_t::value.

{
  int i;

  for (i = 0; i < current_server.nsupport; i++) {
    if (!strcasecmp(name, current_server.support[i].name)) {
      *value = current_server.support[i].value;
      return(0);
    }
  }
  *value = NULL;
  return(-1);
}

EXPORT_SCOPE int start

(

egg_module_t *

modinfo

)

---

Variable Documentation

current_server_t current_server = {0}

Definition at line 26 of file server.c.

int cycle_delay = 0

Definition at line 34 of file server.c.

const char rcsid[] = "$Id: server.c,v 1.68 2007-09-13 22:20:57 sven Exp $" [static]

Definition at line 21 of file server.c.

server_config_t server_config = {0}

Definition at line 27 of file server.c.

config_var_t server_config_vars[] [static]

Initial value:

 {
  {"chanfile", &server_config.chanfile, CONFIG_STRING},
  
  {"user", &server_config.user, CONFIG_STRING},
  {"realname", &server_config.realname, CONFIG_STRING},

  
  {"connect_timeout", &server_config.connect_timeout, CONFIG_INT},
  {"ping_timeout", &server_config.ping_timeout, CONFIG_INT},
  {"dcc_timeout", &server_config.dcc_timeout, CONFIG_INT},

  {"trigger_on_ignore", &server_config.trigger_on_ignore, CONFIG_INT},
  {"keepnick", &server_config.keepnick, CONFIG_INT},
  {"cycle_delay", &server_config.cycle_delay, CONFIG_INT},
  {"default_port", &server_config.default_port, CONFIG_INT},
  {"max_line_len", &server_config.max_line_len, CONFIG_INT},

  {"chaninfo_items", &server_config.chaninfo_items, CONFIG_STRING},

  {"fake005", &server_config.fake005, CONFIG_STRING},

  {"raw_log", &server_config.raw_log, CONFIG_INT},

  {"ip_lookup", &server_config.ip_lookup, CONFIG_INT},
  {0}
}

Definition at line 203 of file server.c.

event_owner_t server_owner

Initial value:

 {
  "server", 0,
  0, 0,
  0
}

Definition at line 28 of file server.c.

bind_list_t server_party_commands[]

Definition at line 532 of file party_commands.c.

bind_list_t server_raw_binds[]

Definition at line 562 of file input.c.