1 /* GLIB - Library of useful routines for C programming
2 * Copyright (C) 1995-1997 Peter Mattis, Spencer Kimball and Josh MacDonald
4 * giounix.c: IO Channels using unix file descriptors
5 * Copyright 1998 Owen Taylor
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Library General Public
9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Library General Public License for more details.
17 * You should have received a copy of the GNU Library General Public
18 * License along with this library; if not, write to the
19 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20 * Boston, MA 02111-1307, USA.
24 * Modified by the GLib Team and others 1997-1999. See the AUTHORS
25 * file for a list of people on the GLib Team. See the ChangeLog
26 * files for a list of changes. These files are distributed with
27 * GLib at ftp://ftp.gtk.org/pub/gtk/.
35 #include <sys/types.h>
43 typedef struct _GIOUnixChannel GIOUnixChannel;
44 typedef struct _GIOUnixWatch GIOUnixWatch;
46 struct _GIOUnixChannel {
51 struct _GIOUnixWatch {
54 GIOCondition condition;
59 static GIOError g_io_unix_read (GIOChannel *channel,
62 guint *bytes_written);
64 static GIOError g_io_unix_write(GIOChannel *channel,
67 guint *bytes_written);
68 static GIOError g_io_unix_seek (GIOChannel *channel,
71 static void g_io_unix_close (GIOChannel *channel);
72 static void g_io_unix_free (GIOChannel *channel);
73 static guint g_io_unix_add_watch (GIOChannel *channel,
75 GIOCondition condition,
78 GDestroyNotify notify);
79 static gboolean g_io_unix_prepare (gpointer source_data,
80 GTimeVal *current_time,
83 static gboolean g_io_unix_check (gpointer source_data,
84 GTimeVal *current_time,
86 static gboolean g_io_unix_dispatch (gpointer source_data,
87 GTimeVal *current_time,
89 static void g_io_unix_destroy (gpointer source_data);
91 GSourceFuncs unix_watch_funcs = {
98 GIOFuncs unix_channel_funcs = {
108 g_io_unix_prepare (gpointer source_data,
109 GTimeVal *current_time,
118 g_io_unix_check (gpointer source_data,
119 GTimeVal *current_time,
122 GIOUnixWatch *data = source_data;
124 return (data->pollfd.revents & data->condition);
128 g_io_unix_dispatch (gpointer source_data,
129 GTimeVal *current_time,
133 GIOUnixWatch *data = source_data;
135 return (*data->callback)(data->channel,
136 data->pollfd.revents & data->condition,
141 g_io_unix_destroy (gpointer source_data)
143 GIOUnixWatch *data = source_data;
145 g_main_remove_poll (&data->pollfd);
146 g_io_channel_unref (data->channel);
151 g_io_unix_read (GIOChannel *channel,
156 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
159 result = read (unix_channel->fd, buf, count);
167 return G_IO_ERROR_INVAL;
169 return G_IO_ERROR_AGAIN;
171 return G_IO_ERROR_UNKNOWN;
176 *bytes_read = result;
177 return G_IO_ERROR_NONE;
182 g_io_unix_write(GIOChannel *channel,
185 guint *bytes_written)
187 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
190 result = write (unix_channel->fd, buf, count);
198 return G_IO_ERROR_INVAL;
200 return G_IO_ERROR_AGAIN;
202 return G_IO_ERROR_UNKNOWN;
207 *bytes_written = result;
208 return G_IO_ERROR_NONE;
213 g_io_unix_seek (GIOChannel *channel,
217 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
233 g_warning ("g_io_unix_seek: unknown seek type");
234 return G_IO_ERROR_UNKNOWN;
237 result = lseek (unix_channel->fd, offset, whence);
244 return G_IO_ERROR_INVAL;
246 return G_IO_ERROR_UNKNOWN;
250 return G_IO_ERROR_NONE;
255 g_io_unix_close (GIOChannel *channel)
257 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
259 close (unix_channel->fd);
263 g_io_unix_free (GIOChannel *channel)
265 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
267 g_free (unix_channel);
271 g_io_unix_add_watch (GIOChannel *channel,
273 GIOCondition condition,
276 GDestroyNotify notify)
278 GIOUnixWatch *watch = g_new (GIOUnixWatch, 1);
279 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
281 watch->channel = channel;
282 g_io_channel_ref (channel);
284 watch->callback = func;
285 watch->condition = condition;
287 watch->pollfd.fd = unix_channel->fd;
288 watch->pollfd.events = condition;
290 g_main_add_poll (&watch->pollfd, priority);
292 return g_source_add (priority, TRUE, &unix_watch_funcs, watch, user_data, notify);
296 g_io_channel_unix_new (gint fd)
298 GIOUnixChannel *unix_channel = g_new (GIOUnixChannel, 1);
299 GIOChannel *channel = (GIOChannel *)unix_channel;
301 g_io_channel_init (channel);
302 channel->funcs = &unix_channel_funcs;
304 unix_channel->fd = fd;
309 g_io_channel_unix_get_fd (GIOChannel *channel)
311 GIOUnixChannel *unix_channel = (GIOUnixChannel *)channel;
312 return unix_channel->fd;