diff options
| author | Patrick Griffis <tingping@tingping.se> | 2016-01-25 22:49:12 -0500 |
|---|---|---|
| committer | Patrick Griffis <tingping@tingping.se> | 2016-01-25 22:53:42 -0500 |
| commit | ea9e8d353b4efd68e1f5c7da5962313c7b662f39 (patch) | |
| tree | a4f5ee0bbeef95434c202e1395ea220a587c047f /src/common | |
| parent | f14ad5e9dd7fba1c1c7bb39b47bce38f9de01316 (diff) | |
identd: Use GDataInputStream
Diffstat (limited to 'src/common')
| -rw-r--r-- | src/common/plugin-identd.c | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/src/common/plugin-identd.c b/src/common/plugin-identd.c index acf3a093..659fc4e6 100644 --- a/src/common/plugin-identd.c +++ b/src/common/plugin-identd.c @@ -32,7 +32,6 @@ typedef struct ident_info { GSocketConnection *conn; gchar *username; - gchar read_buf[16]; } ident_info; static int @@ -97,21 +96,22 @@ identd_write_ready (GOutputStream *stream, GAsyncResult *res, ident_info *info) } static void -identd_read_ready (GInputStream *in_stream, GAsyncResult *res, ident_info *info) +identd_read_ready (GDataInputStream *in_stream, GAsyncResult *res, ident_info *info) { GSocketAddress *sok_addr; GOutputStream *out_stream; guint64 local, remote; - gchar buf[512], *p; + gchar *read_buf, buf[512], *p; - if (g_input_stream_read_finish (in_stream, res, NULL)) + if ((read_buf = g_data_input_stream_read_line_finish (in_stream, res, NULL, NULL))) { - local = g_ascii_strtoull (info->read_buf, NULL, 0); - p = strchr (info->read_buf, ','); + local = g_ascii_strtoull (read_buf, NULL, 0); + p = strchr (read_buf, ','); if (!p) goto cleanup; remote = g_ascii_strtoull (p + 1, NULL, 0); + g_free (read_buf); if (!local || !remote || local > G_MAXUINT16 || remote > G_MAXUINT16) goto cleanup; @@ -153,6 +153,7 @@ static gboolean identd_incoming_cb (GSocketService *service, GSocketConnection *conn, GObject *source, gpointer userdata) { + GDataInputStream *data_stream; GInputStream *stream; ident_info *info; @@ -162,8 +163,10 @@ identd_incoming_cb (GSocketService *service, GSocketConnection *conn, g_object_ref (conn); stream = g_io_stream_get_input_stream (G_IO_STREAM (conn)); - g_input_stream_read_async (stream, info->read_buf, sizeof (info->read_buf), G_PRIORITY_DEFAULT, - NULL, (GAsyncReadyCallback)identd_read_ready, info); + data_stream = g_data_input_stream_new (stream); + g_data_input_stream_set_newline_type (data_stream, G_DATA_STREAM_NEWLINE_TYPE_CR_LF); + g_data_input_stream_read_line_async (data_stream, G_PRIORITY_DEFAULT, + NULL, (GAsyncReadyCallback)identd_read_ready, info); return TRUE; } |