summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPřemysl Janouch <p.janouch@gmail.com>2015-05-08 17:39:26 +0200
committerPřemysl Janouch <p.janouch@gmail.com>2015-05-08 17:39:26 +0200
commit9a02c90e3e7d9ebe8344b296444c1c6d1c46bf59 (patch)
tree9f59495d606e87e1b83164d30d49447ce3a81f1a
parent6414a73d6235a9260d4b1e98877e84d3b1e0a3c0 (diff)
downloadxK-9a02c90e3e7d9ebe8344b296444c1c6d1c46bf59.tar.gz
xK-9a02c90e3e7d9ebe8344b296444c1c6d1c46bf59.tar.xz
xK-9a02c90e3e7d9ebe8344b296444c1c6d1c46bf59.zip
degesch: add server::state, rename stuff
This is in preparation of asynchronous connects.
-rw-r--r--degesch.c96
1 files changed, 56 insertions, 40 deletions
diff --git a/degesch.c b/degesch.c
index 4e67558..e066edf 100644
--- a/degesch.c
+++ b/degesch.c
@@ -974,14 +974,22 @@ buffer_destroy (struct buffer *self)
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
+enum server_state
+{
+ IRC_DISCONNECTED, ///< Not connected
+ IRC_CONNECTED, ///< Trying to register
+ IRC_REGISTERED ///< We can chat now
+};
+
struct server
{
struct app_context *ctx; ///< Application context
- int irc_fd; ///< Socket FD of the server
+ enum server_state state; ///< Connection state
+
+ int socket; ///< Socket FD of the server
struct str read_buffer; ///< Input yet to be processed
- struct poller_fd irc_event; ///< IRC FD event
- bool irc_ready; ///< Whether we may send messages now
+ struct poller_fd read_event; ///< We can read from the socket
SSL_CTX *ssl_ctx; ///< SSL context
SSL *ssl; ///< SSL connection
@@ -1020,9 +1028,9 @@ static void on_irc_reconnect_timeout (void *user_data);
static void
server_init (struct server *self, struct poller *poller)
{
- self->irc_fd = -1;
+ self->socket = -1;
str_init (&self->read_buffer);
- self->irc_ready = false;
+ self->state = IRC_DISCONNECTED;
str_map_init (&self->irc_users);
self->irc_users.key_xfrm = irc_strxfrm;
@@ -1047,10 +1055,10 @@ server_init (struct server *self, struct poller *poller)
static void
server_free (struct server *self)
{
- if (self->irc_fd != -1)
+ if (self->socket != -1)
{
- xclose (self->irc_fd);
- poller_fd_reset (&self->irc_event);
+ xclose (self->socket);
+ poller_fd_reset (&self->read_event);
}
str_free (&self->read_buffer);
@@ -2547,6 +2555,12 @@ irc_is_channel (struct server *s, const char *ident)
return *ident && !!strchr ("#&+!", *ident);
}
+static bool
+irc_is_connected (struct server *s)
+{
+ return s->state != IRC_DISCONNECTED;
+}
+
static void
irc_shutdown (struct server *s)
{
@@ -2555,14 +2569,14 @@ irc_shutdown (struct server *s)
if (s->ssl)
soft_assert (SSL_shutdown (s->ssl) != -1);
else
- soft_assert (shutdown (s->irc_fd, SHUT_WR) == 0);
+ soft_assert (shutdown (s->socket, SHUT_WR) == 0);
}
static void
try_finish_quit (struct app_context *ctx)
{
// TODO: multiserver
- if (ctx->quitting && ctx->server.irc_fd == -1)
+ if (ctx->quitting && !irc_is_connected (&ctx->server))
ctx->polling = false;
}
@@ -2577,7 +2591,7 @@ initiate_quit (struct app_context *ctx)
// Initiate a connection close
// TODO: multiserver
struct server *s = &ctx->server;
- if (s->irc_fd != -1)
+ if (irc_is_connected (s))
// XXX: when we go async, we'll have to flush output buffers first
irc_shutdown (s);
@@ -2614,7 +2628,7 @@ static bool irc_send (struct server *s,
static bool
irc_send (struct server *s, const char *format, ...)
{
- if (!soft_assert (s->irc_fd != -1))
+ if (!soft_assert (irc_is_connected (s)))
{
print_debug ("tried sending a message to a dead server connection");
return false;
@@ -2650,7 +2664,7 @@ irc_send (struct server *s, const char *format, ...)
result = false;
}
}
- else if (write (s->irc_fd, str.str, str.len) != (ssize_t) str.len)
+ else if (write (s->socket, str.str, str.len) != (ssize_t) str.len)
{
LOG_LIBC_FAILURE ("write");
result = false;
@@ -2737,7 +2751,7 @@ irc_initialize_ssl (struct server *s, struct error **e)
}
SSL_set_connect_state (s->ssl);
- if (!SSL_set_fd (s->ssl, s->irc_fd))
+ if (!SSL_set_fd (s->ssl, s->socket))
goto error_ssl_3;
// Avoid SSL_write() returning SSL_ERROR_WANT_READ
SSL_set_mode (s->ssl, SSL_MODE_AUTO_RETRY);
@@ -2826,7 +2840,7 @@ irc_establish_connection (struct server *s,
return false;
}
- s->irc_fd = sockfd;
+ s->socket = sockfd;
return true;
}
@@ -2880,7 +2894,7 @@ make_prompt (struct app_context *ctx, struct str *output)
{
struct server *s = buffer->server;
str_append_c (output, ' ');
- if (s->irc_fd == -1)
+ if (!irc_is_connected (s))
str_append (output, "(disconnected)");
else
{
@@ -3599,13 +3613,13 @@ irc_process_message (const struct irc_message *msg,
}
// XXX: or is the 001 numeric enough? For what?
- if (!s->irc_ready && (!strcasecmp (msg->command, "MODE")
+ if (s->state == IRC_CONNECTED && (!strcasecmp (msg->command, "MODE")
|| !strcasecmp (msg->command, "376") // RPL_ENDOFMOTD
|| !strcasecmp (msg->command, "422"))) // ERR_NOMOTD
{
// XXX: should we really print this?
buffer_send_status (s->ctx, s->buffer, "Successfully connected");
- s->irc_ready = true;
+ s->state = IRC_REGISTERED;
refresh_prompt (s->ctx);
// TODO: parse any response and store the result for us in app_context;
@@ -4024,7 +4038,7 @@ server_command_check (struct app_context *ctx, const char *action)
else
{
struct server *s = ctx->current_buffer->server;
- if (s->irc_fd == -1)
+ if (!irc_is_connected (s))
buffer_send_error (ctx, s->buffer, "Not connected");
else
return true;
@@ -4399,7 +4413,7 @@ handle_command_quit (struct app_context *ctx, char *arguments)
{
// TODO: multiserver
struct server *s = &ctx->server;
- if (s->irc_fd != -1)
+ if (irc_is_connected (s))
{
if (*arguments)
irc_send (s, "QUIT :%s", arguments);
@@ -4471,7 +4485,7 @@ handle_command_connect (struct app_context *ctx, char *arguments)
{
// TODO: multiserver
struct server *s = &ctx->server;
- if (s->irc_fd != -1)
+ if (irc_is_connected (s))
{
buffer_send_error (ctx, s->buffer, "Already connected");
return true;
@@ -4719,7 +4733,7 @@ static void
send_message_to_target (struct server *s,
const char *target, char *message, struct buffer *buffer)
{
- if (s->irc_fd == -1)
+ if (!irc_is_connected (s))
{
buffer_send_error (s->ctx, buffer, "Not connected");
return;
@@ -4801,7 +4815,7 @@ start:
{
// Let it finish the handshake as we don't poll for writability;
// any errors are to be collected by SSL_read() in the next iteration
- struct pollfd pfd = { .fd = s->irc_fd, .events = POLLOUT };
+ struct pollfd pfd = { .fd = s->socket, .events = POLLOUT };
soft_assert (poll (&pfd, 1, 0) > 0);
goto start;
}
@@ -4818,7 +4832,7 @@ irc_fill_read_buffer (struct server *s, struct str *buf)
{
ssize_t n_read;
start:
- n_read = recv (s->irc_fd, buf->str + buf->len,
+ n_read = recv (s->socket, buf->str + buf->len,
buf->alloc - buf->len - 1 /* null byte */, 0);
if (n_read > 0)
@@ -4850,7 +4864,7 @@ static void
irc_queue_reconnect (struct server *s)
{
// TODO: exponentional backoff
- hard_assert (s->irc_fd == -1);
+ hard_assert (s->socket == -1);
buffer_send_status (s->ctx, s->buffer,
"Trying to reconnect in %ld seconds...", s->ctx->reconnect_delay);
poller_timer_set (&s->reconnect_tmr, s->ctx->reconnect_delay * 1000);
@@ -4885,9 +4899,9 @@ on_irc_disconnected (struct server *s)
s->ssl_ctx = NULL;
}
- xclose (s->irc_fd);
- s->irc_fd = -1;
- s->irc_ready = false;
+ xclose (s->socket);
+ s->socket = -1;
+ s->state = IRC_DISCONNECTED;
user_unref (s->irc_user);
s->irc_user = NULL;
@@ -4897,8 +4911,8 @@ on_irc_disconnected (struct server *s)
free (s->irc_user_host);
s->irc_user_host = NULL;
- s->irc_event.closed = true;
- poller_fd_reset (&s->irc_event);
+ s->read_event.closed = true;
+ poller_fd_reset (&s->read_event);
// All of our timers have lost their meaning now
irc_cancel_timers (s);
@@ -4943,7 +4957,7 @@ on_irc_readable (const struct pollfd *fd, struct server *s)
if (fd->revents & ~(POLLIN | POLLHUP | POLLERR))
print_debug ("fd %d: unexpected revents: %d", fd->fd, fd->revents);
- (void) set_blocking (s->irc_fd, false);
+ (void) set_blocking (s->socket, false);
struct str *buf = &s->read_buffer;
enum irc_read_result (*fill_buffer)(struct server *, struct str *)
@@ -4981,7 +4995,7 @@ on_irc_readable (const struct pollfd *fd, struct server *s)
}
}
end:
- (void) set_blocking (s->irc_fd, true);
+ (void) set_blocking (s->socket, true);
irc_process_buffer (buf, irc_process_message, s);
if (disconnected)
@@ -5045,24 +5059,26 @@ irc_connect (struct server *s, bool *should_retry, struct error **e)
error_free (error);
return false;
}
- s->irc_fd = fd;
+ s->socket = fd;
}
else if (!irc_establish_connection (s, irc_host, irc_port, e))
return false;
if (use_ssl && !irc_initialize_ssl (s, e))
{
- xclose (s->irc_fd);
- s->irc_fd = -1;
+ xclose (s->socket);
+ s->socket = -1;
return false;
}
+
+ s->state = IRC_CONNECTED;
buffer_send_status (ctx, s->buffer, "Connection established");
- poller_fd_init (&s->irc_event, &ctx->poller, s->irc_fd);
- s->irc_event.dispatcher = (poller_fd_fn) on_irc_readable;
- s->irc_event.user_data = s;
+ poller_fd_init (&s->read_event, &ctx->poller, s->socket);
+ s->read_event.dispatcher = (poller_fd_fn) on_irc_readable;
+ s->read_event.user_data = s;
- poller_fd_set (&s->irc_event, POLLIN);
+ poller_fd_set (&s->read_event, POLLIN);
irc_reset_connection_timeouts (s);
irc_send (s, "NICK %s", nickname);
@@ -5797,7 +5813,7 @@ on_signal_pipe_readable (const struct pollfd *fd, struct app_context *ctx)
irc_reset_connection_timeouts (s);
// FIXME: use a normal quit message
- if (s->irc_fd != -1)
+ if (irc_is_connected (s))
irc_send (s, "QUIT :Terminated by signal");
initiate_quit (ctx);
}