summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJilles Tjoelker <jilles@irssi.org>2009-02-28 18:15:14 +0000
committerjilles <jilles@dbcabf3a-b0e7-0310-adc4-f8d773084564>2009-02-28 18:15:14 +0000
commit8a6b0224b937e579d52d1a526de9197a1f1c1e54 (patch)
tree322fb9380e0d7e1e48d10c3afc879a6082fcafe2 /src
parent25b3a531bef219ac6b60a13496eb5dae61510339 (diff)
downloadirssi-8a6b0224b937e579d52d1a526de9197a1f1c1e54.zip
Add the command send/expire timeout only when needed.
This was the last always-on <1s timer. git-svn-id: file:///var/www/svn.irssi.org/SVN/irssi/trunk@5026 dbcabf3a-b0e7-0310-adc4-f8d773084564
Diffstat (limited to 'src')
-rw-r--r--src/irc/core/irc-servers.c38
-rw-r--r--src/irc/core/irc-servers.h2
-rw-r--r--src/irc/core/irc.c2
3 files changed, 32 insertions, 10 deletions
diff --git a/src/irc/core/irc-servers.c b/src/irc/core/irc-servers.c
index d0e38640..23960a38 100644
--- a/src/irc/core/irc-servers.c
+++ b/src/irc/core/irc-servers.c
@@ -398,7 +398,7 @@ void irc_server_send_data(IRC_SERVER_REC *server, const char *data, int len)
}
}
-static void server_cmd_timeout(IRC_SERVER_REC *server, GTimeVal *now)
+static int server_cmd_timeout(IRC_SERVER_REC *server, GTimeVal *now)
{
REDIRECT_REC *redirect;
GSList *link;
@@ -407,20 +407,20 @@ static void server_cmd_timeout(IRC_SERVER_REC *server, GTimeVal *now)
int len;
if (!IS_IRC_SERVER(server))
- return;
+ return 0;
if (server->cmdcount == 0 && server->cmdqueue == NULL)
- return;
+ return 0;
if (g_timeval_cmp(now, &server->wait_cmd) == -1)
- return;
+ return 1;
usecs = get_timeval_diff(now, &server->last_cmd);
if (usecs < server->cmd_queue_speed)
- return;
+ return 1;
server->cmdcount--;
- if (server->cmdqueue == NULL) return;
+ if (server->cmdqueue == NULL) return 1;
/* get command */
cmd = server->cmdqueue->data;
@@ -445,16 +445,33 @@ static void server_cmd_timeout(IRC_SERVER_REC *server, GTimeVal *now)
link = server->cmdqueue;
server->cmdqueue = g_slist_remove_link(server->cmdqueue, link);
g_slist_free_1(link);
+ return 1;
}
/* check every now and then if there's data to be sent in command buffer */
static int servers_cmd_timeout(void)
{
GTimeVal now;
+ GSList *tmp;
+ int keep = 0;
g_get_current_time(&now);
- g_slist_foreach(servers, (GFunc) server_cmd_timeout, &now);
- return 1;
+ for (tmp = servers; tmp != NULL; tmp = tmp->next) {
+ keep |= server_cmd_timeout(tmp->data, &now);
+ }
+ if (keep)
+ return 1;
+ else {
+ cmd_tag = -1;
+ return 0;
+ }
+}
+
+/* Start the timeout for sending data later and decreasing cmdcount again */
+void irc_servers_start_cmd_timeout(void)
+{
+ if (cmd_tag == -1)
+ cmd_tag = g_timeout_add(500, (GSourceFunc) servers_cmd_timeout, NULL);
}
/* Return a string of all channels (and keys, if any have them) in server,
@@ -851,7 +868,7 @@ void irc_servers_init(void)
settings_add_time("flood", "cmd_queue_speed", DEFAULT_CMD_QUEUE_SPEED);
settings_add_int("flood", "cmds_max_at_once", DEFAULT_CMDS_MAX_AT_ONCE);
- cmd_tag = g_timeout_add(500, (GSourceFunc) servers_cmd_timeout, NULL);
+ cmd_tag = -1;
signal_add_first("server connected", (SIGNAL_FUNC) sig_connected);
signal_add_last("server disconnected", (SIGNAL_FUNC) sig_disconnected);
@@ -877,7 +894,8 @@ void irc_servers_init(void)
void irc_servers_deinit(void)
{
- g_source_remove(cmd_tag);
+ if (cmd_tag != -1)
+ g_source_remove(cmd_tag);
signal_remove("server connected", (SIGNAL_FUNC) sig_connected);
signal_remove("server disconnected", (SIGNAL_FUNC) sig_disconnected);
diff --git a/src/irc/core/irc-servers.h b/src/irc/core/irc-servers.h
index 67ee76c1..8c9c1cd7 100644
--- a/src/irc/core/irc-servers.h
+++ b/src/irc/core/irc-servers.h
@@ -122,6 +122,8 @@ void irc_server_send_away(IRC_SERVER_REC *server, const char *reason);
void irc_server_send_data(IRC_SERVER_REC *server, const char *data, int len);
void irc_server_init_isupport(IRC_SERVER_REC *server);
+void irc_servers_start_cmd_timeout(void);
+
void irc_servers_init(void);
void irc_servers_deinit(void);
diff --git a/src/irc/core/irc.c b/src/irc/core/irc.c
index caa9b010..7ae66641 100644
--- a/src/irc/core/irc.c
+++ b/src/irc/core/irc.c
@@ -56,6 +56,8 @@ void irc_send_cmd_full(IRC_SERVER_REC *server, const char *cmd,
return;
len = strlen(cmd);
+ if (server->cmdcount == 0)
+ irc_servers_start_cmd_timeout();
server->cmdcount++;
if (!raw) {