From e3293d40147f440cc520f77084a3216064a9b4dd Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Thu, 28 Aug 2008 20:03:58 +0200 Subject: client: moved code to client_write() Move the second part of client_write_output() into a separate function. --- src/client.c | 54 ++++++++++++++++++++++++++++-------------------------- 1 file changed, 28 insertions(+), 26 deletions(-) diff --git a/src/client.c b/src/client.c index 531177ab2..d681f8b0b 100644 --- a/src/client.c +++ b/src/client.c @@ -741,41 +741,43 @@ static void client_defer_output(struct client *client, *buf_r = new_sllnode(data, length); } -static void client_write_output(struct client *client) +static void client_write(struct client *client, + const char *data, size_t length) { ssize_t ret; + assert(client->deferred_send == NULL); + + if ((ret = write(client->fd, data, length)) < 0) { + if (errno == EAGAIN || errno == EINTR) { + client->deferred_send = new_sllnode(data, length); + } else { + DEBUG("client %i: problems writing\n", client->num); + client->expired = 1; + return; + } + } else if ((size_t)ret < client->send_buf_used) { + client->deferred_send = new_sllnode(data + ret, length - ret); + } + + if (client->deferred_send) { + DEBUG("client %i: buffer created\n", client->num); + client->deferred_bytes = + client->deferred_send->size + + sizeof(struct sllnode); + } +} + +static void client_write_output(struct client *client) +{ if (client->expired || !client->send_buf_used) return; if (client->deferred_send != NULL) client_defer_output(client, client->send_buf, client->send_buf_used); - else { - if ((ret = write(client->fd, client->send_buf, - client->send_buf_used)) < 0) { - if (errno == EAGAIN || errno == EINTR) { - client->deferred_send = - new_sllnode(client->send_buf, - client->send_buf_used); - } else { - DEBUG("client %i: problems writing\n", - client->num); - client->expired = 1; - return; - } - } else if ((size_t)ret < client->send_buf_used) { - client->deferred_send = - new_sllnode(client->send_buf + ret, - client->send_buf_used - ret); - } - if (client->deferred_send) { - DEBUG("client %i: buffer created\n", client->num); - client->deferred_bytes = - client->deferred_send->size - + sizeof(struct sllnode); - } - } + else + client_write(client, client->send_buf, client->send_buf_used); client->send_buf_used = 0; } -- cgit v1.2.3